diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-11 12:37:41 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-11 12:37:41 -0700 |
| commit | b7f0ba3800b2a2e9a1268e8b90714d3ab1281c72 (patch) | |
| tree | 2adbec9be6f13d1ea80361dd9cf32d91d8ecdae7 | |
| parent | 417125457e104b1447350b2be06808dd95d7b312 (diff) | |
| download | seaweedfs-b7f0ba3800b2a2e9a1268e8b90714d3ab1281c72.tar.xz seaweedfs-b7f0ba3800b2a2e9a1268e8b90714d3ab1281c72.zip | |
refactoring
| -rw-r--r-- | weed/filer2/filer.go | 6 | ||||
| -rw-r--r-- | weed/log_buffer/log_buffer.go (renamed from weed/queue/log_buffer.go) | 2 | ||||
| -rw-r--r-- | weed/log_buffer/sealed_buffer.go (renamed from weed/queue/sealed_buffer.go) | 2 |
3 files changed, 5 insertions, 5 deletions
diff --git a/weed/filer2/filer.go b/weed/filer2/filer.go index af17bf56c..578a2707f 100644 --- a/weed/filer2/filer.go +++ b/weed/filer2/filer.go @@ -12,8 +12,8 @@ import ( "github.com/karlseguin/ccache" "github.com/chrislusf/seaweedfs/weed/glog" + "github.com/chrislusf/seaweedfs/weed/log_buffer" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" - "github.com/chrislusf/seaweedfs/weed/queue" "github.com/chrislusf/seaweedfs/weed/util" "github.com/chrislusf/seaweedfs/weed/wdclient" ) @@ -35,7 +35,7 @@ type Filer struct { DirQueuesPath string buckets *FilerBuckets Cipher bool - metaLogBuffer *queue.LogBuffer + metaLogBuffer *log_buffer.LogBuffer } func NewFiler(masters []string, grpcDialOption grpc.DialOption, filerGrpcPort uint32, notifyFn func()) *Filer { @@ -45,7 +45,7 @@ func NewFiler(masters []string, grpcDialOption grpc.DialOption, filerGrpcPort ui fileIdDeletionQueue: util.NewUnboundedQueue(), GrpcDialOption: grpcDialOption, } - f.metaLogBuffer = queue.NewLogBuffer(time.Minute, f.logFlushFunc, notifyFn) + f.metaLogBuffer = log_buffer.NewLogBuffer(time.Minute, f.logFlushFunc, notifyFn) go f.loopProcessingDeletion() diff --git a/weed/queue/log_buffer.go b/weed/log_buffer/log_buffer.go index 78c5b75ae..3b3396128 100644 --- a/weed/queue/log_buffer.go +++ b/weed/log_buffer/log_buffer.go @@ -1,4 +1,4 @@ -package queue +package log_buffer import ( "sync" diff --git a/weed/queue/sealed_buffer.go b/weed/log_buffer/sealed_buffer.go index 23cec92c9..c5160fad0 100644 --- a/weed/queue/sealed_buffer.go +++ b/weed/log_buffer/sealed_buffer.go @@ -1,4 +1,4 @@ -package queue +package log_buffer import "time" |