aboutsummaryrefslogtreecommitdiff
path: root/weed/server/volume_server.go
diff options
context:
space:
mode:
authorGuo Lei <snipergg@163.com>2022-11-14 16:19:27 +0800
committerGitHub <noreply@github.com>2022-11-14 00:19:27 -0800
commit5b905fb2b74049437fcd939c0304a7e34d051234 (patch)
tree2c654eb74ee30f5c9e20a6c26de4ede1d04543d9 /weed/server/volume_server.go
parentd90aa31d5f5b846c13bbeabfbd7d89260c21020c (diff)
downloadseaweedfs-5b905fb2b74049437fcd939c0304a7e34d051234.tar.xz
seaweedfs-5b905fb2b74049437fcd939c0304a7e34d051234.zip
Lazy loading (#3958)
* types packages is imported more than onece * lazy-loading * fix bugs * fix bugs * fix unit tests * fix test error * rename function * unload ldb after initial startup * Don't load ldb when starting volume server if ldbtimeout is set. * remove uncessary unloadldb * Update weed/command/server.go Co-authored-by: Chris Lu <chrislusf@users.noreply.github.com> * Update weed/command/volume.go Co-authored-by: Chris Lu <chrislusf@users.noreply.github.com> Co-authored-by: guol-fnst <goul-fnst@fujitsu.com> Co-authored-by: Chris Lu <chrislusf@users.noreply.github.com>
Diffstat (limited to 'weed/server/volume_server.go')
-rw-r--r--weed/server/volume_server.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/server/volume_server.go b/weed/server/volume_server.go
index 8c6c63c56..5d7e5c7b0 100644
--- a/weed/server/volume_server.go
+++ b/weed/server/volume_server.go
@@ -41,6 +41,7 @@ type VolumeServer struct {
grpcDialOption grpc.DialOption
needleMapKind storage.NeedleMapKind
+ ldbTimout int64
FixJpgOrientation bool
ReadMode string
compactionBytePerSecond int64
@@ -68,6 +69,7 @@ func NewVolumeServer(adminMux, publicMux *http.ServeMux, ip string,
inflightUploadDataTimeout time.Duration,
hasSlowRead bool,
readBufferSizeMB int,
+ ldbTimeout int64,
) *VolumeServer {
v := util.GetViper()
@@ -99,12 +101,13 @@ func NewVolumeServer(adminMux, publicMux *http.ServeMux, ip string,
inflightUploadDataTimeout: inflightUploadDataTimeout,
hasSlowRead: hasSlowRead,
readBufferSizeMB: readBufferSizeMB,
+ ldbTimout: ldbTimeout,
}
vs.SeedMasterNodes = masterNodes
vs.checkWithMaster()
- vs.store = storage.NewStore(vs.grpcDialOption, ip, port, grpcPort, publicUrl, folders, maxCounts, minFreeSpaces, idxFolder, vs.needleMapKind, diskTypes)
+ vs.store = storage.NewStore(vs.grpcDialOption, ip, port, grpcPort, publicUrl, folders, maxCounts, minFreeSpaces, idxFolder, vs.needleMapKind, diskTypes, ldbTimeout)
vs.guard = security.NewGuard(whiteList, signingKey, expiresAfterSec, readSigningKey, readExpiresAfterSec)
handleStaticResources(adminMux)