diff options
| -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" |