Commit Graph

49 Commits

Author SHA1 Message Date
clinx
bb950063e8 fix(client): use heartbeat ping flashnode #1000151053
Signed-off-by: clinx <chenlin1@oppo.com>
2025-08-11 17:21:19 +08:00
Victor1319
62b28d0626 refactor(fmt): use gofumpt to format code. #1000063488
Signed-off-by: Victor1319 <zengxuewei@oppo.com>
2025-08-08 14:59:27 +08:00
Victor1319
c3ccdfc7e2 refactor(sdk): remove dp cache code from sdk, client, cli. #1000063488
Signed-off-by: Victor1319 <zengxuewei@oppo.com>
2025-08-08 14:59:27 +08:00
chihe
94fd8c6618 fix(client): remove debug log
close:#1000101999

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:59:24 +08:00
chihe
fb7b1ea7dc fix(client): add debug log for parameter error
close:#1000080725

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:59:24 +08:00
baihailong
967338d137 feat(master): Optimize the client to remove flashnode logic when flashnode returns timeout
. #1000074429

Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-08 14:52:03 +08:00
clinx
72f6196ba6 fix(flashnodeb): asynchronously send flashnode heartbeat message#1000044633
Signed-off-by: clinx <chenlin1@oppo.com>
2025-08-08 14:52:02 +08:00
chihe
31585bd930 fix(flashnode): adjust log level
close:#1000014246

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:52:02 +08:00
baihailong
97612b6b20 feat(flashnode): enable statistic slot hit rate.#1000037792
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-08 14:52:02 +08:00
chihe
b67b08df90 fix(client): do not close conn if encountering limit error
close:#1000023889

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:52:02 +08:00
clinx
143b073232 feat(cli): Remove delay-related monitoring information for flashnode#1000021930
Signed-off-by: clinx <chenlin1@oppo.com>
2025-08-08 14:52:02 +08:00
chihe
f5783cd728 fix(flashnode): add write limit for flashnode
close:#1000023889

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:52:02 +08:00
chihe
6a89226dc5 feat(flashnode): supports return to client directly if data is not cached
close:#1000014246

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:52:01 +08:00
baihailong
5eef58052b feat(master): enable master config flashnode read timeout dynamically.#1000020016
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-08 14:51:45 +08:00
chihe
82a11e620c fix(client): ignore limit and context timeout error
close:#1000014246i,#1000017781

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:51:45 +08:00
chihe
baa7412321 fix(flashnode): do not close channel twice
close:#1000016077

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:51:44 +08:00
chihe
7c026a4daf fix(flashnode): delete pre-allocated size when return from InitForCacheRead
close:#1000012153

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:42:25 +08:00
clinx
238bfdc555 feat(warmup): create flash manual task #22883846
Signed-off-by: clinx <chenlin1@oppo.com>
2025-08-08 14:42:10 +08:00
chihe
ca90d3bac8 feat(master): add setRead/WriteLimits for flashnode
close:#1000004942

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:39:41 +08:00
chihe
380b8dde52 fix(flashnode): reply to client as soon as possible
close:#23109728

Signed-off-by: chihe <chihe@oppo.com>
2025-08-08 14:39:41 +08:00
clinx
c3b9145631 fix(flashnode): code check#23131609
Signed-off-by: clinx <chenlin1@oppo.com>
2025-08-07 16:00:30 +08:00
clinx
19e4fdc075 fix(flashnode): record disk dimension to file read and write operations #23131609
Signed-off-by: clinx <chenlin1@oppo.com>
2025-08-07 16:00:30 +08:00
clinx
cfa8134cc7 feat(flashnode): add read and write latency metrics for cache #1000002444
Signed-off-by: clinx <chenlin1@oppo.com>
2025-08-07 16:00:30 +08:00
chihe
91965b0b44 fix(flashnode): use limitRead for read cache
close:#23123752

Signed-off-by: chihe <chihe@oppo.com>
2025-08-07 16:00:30 +08:00
chihe
9a1adf8212 fix(flashnode): use limitWrite for flashnode instead of disk
close:#23123752

Signed-off-by: chihe <chihe@oppo.com>
2025-08-07 16:00:30 +08:00
chihe
be79605ea0 fix(flashnode): read data source one by one
close:#23095482

Signed-off-by: chihe <chihe@oppo.com>
2025-08-07 16:00:30 +08:00
chihe
630b48ed2f fix(flashnode): add cacheItem into lru after file is inited
close:#23062373

Signed-off-by: chihe <chihe@oppo.com>
2025-08-07 16:00:27 +08:00
clinx
f3b98b69b1 fix(flashnode): open readlimiter for OpFlashNodeCachePrepare. #23061931
Signed-off-by: clinx <chenlin1@oppo.com>
2025-08-07 16:00:26 +08:00
baihailong
58e68d9ef3 fix(flashnode): OpFlashNodeCachePrepare operation with flow control.#23061931
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 16:00:26 +08:00
chihe
279817ca50 fix(client): modify default value for remoteCacheReadTimeoutSec
close:#23047275

Signed-off-by: chihe <chihe@oppo.com>
2025-08-07 16:00:26 +08:00
shuqiang-zheng
fc3cddfc20 feat(flashnode): modify the name of the disk statistics in heartbeat reporting.
@formatter:off

Signed-off-by: shuqiang-zheng <zhengshuqiang@oppo.com>
2025-08-07 16:00:25 +08:00
shuqiang-zheng
e0880fa4d0 feat(flashnode): clears the cache on flashNode when removing it.
close:#23003554

Signed-off-by: shuqiang-zheng <zhengshuqiang@oppo.com>
2025-08-07 16:00:25 +08:00
shuqiang-zheng
08639d8b52 feat(flashnode): add multi disk support.
close:#23021760

Signed-off-by: shuqiang-zheng <zhengshuqiang@oppo.com>
2025-08-07 16:00:25 +08:00
baihailong
e19232f374 feat(mastersdkcli): enable config remoteCache parameter by volume.
. #23020464

Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 16:00:11 +08:00
baihailong
7bcd569001 fix(flashnode): add volume, clientIp, inode for DataSource.#23013250
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 15:57:57 +08:00
baihailong
5c7dfe077f feat(flashnode): enable flashnode read timeout configured by the master.#22965528
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 15:57:57 +08:00
baihailong
eff580aea8 fix(flashnode): optimize flashnode log level.#22985948
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 15:57:57 +08:00
baihailong
3d7c4917c2 fix(flashnode): optimize flashnode list cost time.#22989953
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 15:57:56 +08:00
baihailong
f6a8a544c2 feat(flashnode): supplement flashnode info for http interface flashnode/get.#22975706
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 15:57:56 +08:00
shuqiang-zheng
f883980012 fix(flashnode): fix slow source return in case of concurrent cache reads.
@formatter:off

Signed-off-by: shuqiang-zheng <zhengshuqiang@oppo.com>
2025-08-07 15:57:56 +08:00
shuqiang-zheng
76007c2d8d fix(flashnode): same cacheBlock may be created multiple times.
close:#22922141

Signed-off-by: shuqiang-zheng <zhengshuqiang@oppo.com>
2025-08-07 15:57:40 +08:00
shuqiang-zheng
101f0e0099 fix(flashnode): fix the problem of high cpu due to frequent gc on flashnode.
close:#22872898

Signed-off-by: shuqiang-zheng <zhengshuqiang@oppo.com>
2025-08-07 15:45:54 +08:00
baihailong
607b49d953 fix(flashnode): optimize metrics of flashnode.#22876448
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 15:45:25 +08:00
baihailong
9025274e8e fix(flashnode): open file for block failed.#22642538
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 15:45:09 +08:00
baihailong
e0db394306 feat(flashnode): alerting when the hit rate is lower.#22633499
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 15:19:33 +08:00
baihailong
1998c55397 fix(flashnode): add statistical metrics for flashnode.#22559602
Signed-off-by: baihailong <baihailong@oppo.com>
2025-08-07 15:19:30 +08:00
slasher
459ec2f5e5 test(flashnode): add test case of flash node
. #22200518

Signed-off-by: slasher <mcq.sejust@gmail.com>
2025-08-07 15:19:03 +08:00
slasher
a3e89bcfaf feat(flashnode): refinement flashnode
. #22200504 #22200509

Signed-off-by: slasher <mcq.sejust@gmail.com>
2025-08-07 15:18:59 +08:00
slasher
b150a10a36 feat(flashnode): add service of flashnode
. #22115361 #22200518 of #21957840

Signed-off-by: slasher <mcq.sejust@gmail.com>
2025-08-07 15:18:46 +08:00