diff options
| author | yulai.li <blacktear23@gmail.com> | 2021-08-26 18:25:08 +0800 |
|---|---|---|
| committer | yulai.li <blacktear23@gmail.com> | 2021-08-26 18:25:08 +0800 |
| commit | c1dc5ab4ac90589fd5c4eaf75f7f2d4e870ae91d (patch) | |
| tree | 3d519201a435c614113d8057eb762a7d5048cd33 | |
| parent | 318757ef8c4989db91ac645a1ce2da0f9097bd6a (diff) | |
| download | seaweedfs-c1dc5ab4ac90589fd5c4eaf75f7f2d4e870ae91d.tar.xz seaweedfs-c1dc5ab4ac90589fd5c4eaf75f7f2d4e870ae91d.zip | |
Add deleterange_concurrency to filer configuration file
| -rw-r--r-- | weed/command/scaffold/filer.toml | 2 | ||||
| -rw-r--r-- | weed/filer/tikv/tikv_store.go | 10 |
2 files changed, 11 insertions, 1 deletions
diff --git a/weed/command/scaffold/filer.toml b/weed/command/scaffold/filer.toml index 25c372e9d..c8cb70131 100644 --- a/weed/command/scaffold/filer.toml +++ b/weed/command/scaffold/filer.toml @@ -236,3 +236,5 @@ enabled = false # If you have many pd address, use ',' split then: # pdaddrs = "pdhost1:2379, pdhost2:2379, pdhost3:2379" pdaddrs = "localhost:2379" +# Concurrency for TiKV delete range +deleterange_concurrency = 1 diff --git a/weed/filer/tikv/tikv_store.go b/weed/filer/tikv/tikv_store.go index e14cf5190..e85f7a740 100644 --- a/weed/filer/tikv/tikv_store.go +++ b/weed/filer/tikv/tikv_store.go @@ -16,6 +16,10 @@ import ( "github.com/tikv/client-go/v2/txnkv" ) +var ( + _ filer.FilerStore = ((*TikvStore)(nil)) +) + func init() { filer.Stores = append(filer.Stores, &TikvStore{}) } @@ -36,7 +40,11 @@ func (store *TikvStore) Initialize(config util.Configuration, prefix string) err for _, item := range strings.Split(pdAddrsStr, ",") { pdAddrs = append(pdAddrs, strings.TrimSpace(item)) } - store.deleteRangeConcurrency = 1 + drc := config.GetInt(prefix + "deleterange_concurrency") + if drc <= 0 { + drc = 1 + } + store.deleteRangeConcurrency = drc return store.initialize(pdAddrs) } |