diff options
Diffstat (limited to 'unmaintained')
| -rw-r--r-- | unmaintained/stream_read_volume/stream_read_volume.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/unmaintained/stream_read_volume/stream_read_volume.go b/unmaintained/stream_read_volume/stream_read_volume.go index b002c5061..cdbfa2c44 100644 --- a/unmaintained/stream_read_volume/stream_read_volume.go +++ b/unmaintained/stream_read_volume/stream_read_volume.go @@ -5,13 +5,14 @@ import ( "errors" "flag" "fmt" + "io" + "github.com/seaweedfs/seaweedfs/weed/operation" "github.com/seaweedfs/seaweedfs/weed/pb" "github.com/seaweedfs/seaweedfs/weed/pb/volume_server_pb" "github.com/seaweedfs/seaweedfs/weed/security" "github.com/seaweedfs/seaweedfs/weed/util" "google.golang.org/grpc" - "io" ) var ( @@ -29,7 +30,7 @@ func main() { vid := uint32(*volumeId) eachNeedleFunc := func(resp *volume_server_pb.ReadAllNeedlesResponse) error { - fmt.Printf("%d,%x%08x %d\n", resp.VolumeId, resp.NeedleId, resp.Cookie, len(resp.NeedleBlob)) + fmt.Printf("%d,%x%08x %d %v %d %x\n", resp.VolumeId, resp.NeedleId, resp.Cookie, len(resp.NeedleBlob), resp.NeedleBlobCompressed, resp.LastModified, resp.Crc) return nil } |