diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-05-28 14:32:16 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-05-28 14:32:16 -0700 |
| commit | 74332e1a619b3be449994e38f26247e4cdf883ef (patch) | |
| tree | 40b5121fe05ed6c661989be970f5d7b48f4ea6e3 /weed/filesys | |
| parent | be0e88a6068e61f17330502e3128723f0b2640d4 (diff) | |
| download | seaweedfs-74332e1a619b3be449994e38f26247e4cdf883ef.tar.xz seaweedfs-74332e1a619b3be449994e38f26247e4cdf883ef.zip | |
minor
Diffstat (limited to 'weed/filesys')
| -rw-r--r-- | weed/filesys/dirty_page.go | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/weed/filesys/dirty_page.go b/weed/filesys/dirty_page.go index e4e743166..584db809d 100644 --- a/weed/filesys/dirty_page.go +++ b/weed/filesys/dirty_page.go @@ -2,7 +2,6 @@ package filesys import ( "sync" - "sort" "fmt" "bytes" "io" @@ -63,7 +62,7 @@ func (pages *ContinuousDirtyPages) AddPage(ctx context.Context, offset int64, da if pages.f.wfs.chunkSizeLimit > 0 && pages.totalSize() >= pages.f.wfs.chunkSizeLimit { chunk, err = pages.saveToStorage(ctx) pages.pages = nil - glog.V(3).Infof("%s/%s add split [%d,%d)", pages.f.dir.Path, pages.f.Name, chunk.Offset, chunk.Offset+int64(chunk.Size)) + glog.V(3).Infof("%s/%s over size limit [%d,%d)", pages.f.dir.Path, pages.f.Name, chunk.Offset, chunk.Offset+int64(chunk.Size)) } return } @@ -87,6 +86,9 @@ func (pages *ContinuousDirtyPages) FlushToStorage(ctx context.Context) (chunk *f if chunk, err = pages.saveToStorage(ctx); err == nil { pages.pages = nil + if chunk != nil { + glog.V(3).Infof("%s/%s flush [%d,%d)", pages.f.dir.Path, pages.f.Name, chunk.Offset, chunk.Offset+int64(chunk.Size)) + } } return } @@ -104,10 +106,6 @@ func (pages *ContinuousDirtyPages) saveToStorage(ctx context.Context) (*filer_pb return nil, nil } - sort.Slice(pages.pages, func(i, j int) bool { - return pages.pages[i].Offset < pages.pages[j].Offset - }) - var fileId, host string if err := pages.f.wfs.withFilerClient(func(client filer_pb.SeaweedFilerClient) error { |