diff options
| author | chrislu <chris.lu@gmail.com> | 2022-01-15 14:49:59 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-01-15 14:49:59 -0800 |
| commit | cb25d100b7ef44ce1e27e0d1f4a965e1acc7b098 (patch) | |
| tree | 4eed6c92c763c3e1f6800f3bafc32178768e5720 | |
| parent | fd83009c058b0264b18f6ec39994ab9eb9836007 (diff) | |
| download | seaweedfs-cb25d100b7ef44ce1e27e0d1f4a965e1acc7b098.tar.xz seaweedfs-cb25d100b7ef44ce1e27e0d1f4a965e1acc7b098.zip | |
add debug zero
| -rw-r--r-- | weed/filesys/page_writer.go | 2 | ||||
| -rw-r--r-- | weed/filesys/page_writer/chunked_file_writer.go | 1 | ||||
| -rw-r--r-- | weed/filesys/page_writer/chunked_stream_writer.go | 12 | ||||
| -rw-r--r-- | weed/filesys/page_writer/debug_content.go | 17 |
4 files changed, 21 insertions, 11 deletions
diff --git a/weed/filesys/page_writer.go b/weed/filesys/page_writer.go index 5c06bc44d..02b5f1f35 100644 --- a/weed/filesys/page_writer.go +++ b/weed/filesys/page_writer.go @@ -84,6 +84,8 @@ func (pw *PageWriter) ReadDirtyDataAt(data []byte, offset int64) (maxStop int64) data = data[readSize:] } + checkByteZero("page writer read", p, 0, maxStop-offset) + return } diff --git a/weed/filesys/page_writer/chunked_file_writer.go b/weed/filesys/page_writer/chunked_file_writer.go index d2f94dafd..948547878 100644 --- a/weed/filesys/page_writer/chunked_file_writer.go +++ b/weed/filesys/page_writer/chunked_file_writer.go @@ -73,6 +73,7 @@ func (cw *ChunkedFileWriter) ReadDataAt(p []byte, off int64) (maxStop int64) { glog.Errorf("reading temp file: %v", err) break } + checkByteZero("temp file writer read", p, logicStart-off, logicStop-off) maxStop = max(maxStop, logicStop) } } diff --git a/weed/filesys/page_writer/chunked_stream_writer.go b/weed/filesys/page_writer/chunked_stream_writer.go index 6c7136645..a38193131 100644 --- a/weed/filesys/page_writer/chunked_stream_writer.go +++ b/weed/filesys/page_writer/chunked_stream_writer.go @@ -1,7 +1,6 @@ package page_writer import ( - "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/util" "github.com/chrislusf/seaweedfs/weed/util/mem" "io" @@ -82,16 +81,7 @@ func (cw *ChunkedStreamWriter) ReadDataAt(p []byte, off int64) (maxStop int64) { copy(p[logicStart-off:logicStop-off], memChunk.buf[logicStart-memChunkBaseOffset:logicStop-memChunkBaseOffset]) maxStop = max(maxStop, logicStop) - isAllZero := true - for i := logicStart - off; i < logicStop-off; i++ { - if p[i] != 0 { - isAllZero = false - break - } - } - if isAllZero { - glog.Errorf("Copied content is all Zero [%d,%d)", logicStart-off, logicStop-off) - } + checkByteZero("stream writer read", p, logicStart-off, logicStop-off) } } diff --git a/weed/filesys/page_writer/debug_content.go b/weed/filesys/page_writer/debug_content.go new file mode 100644 index 000000000..2e5734ced --- /dev/null +++ b/weed/filesys/page_writer/debug_content.go @@ -0,0 +1,17 @@ +package page_writer + +import "github.com/chrislusf/seaweedfs/weed/glog" + +func checkByteZero(message string, p []byte, start, stop int64) { + isAllZero := true + for i := start; i < stop; i++ { + if p[i] != 0 { + isAllZero = false + break + } + } + if isAllZero { + glog.Errorf("%s is all zeros [%d,%d)", message, start, stop) + } + +} |
