diff options
| author | Jianfei Wang <wjf@megvii.com> | 2016-04-06 17:03:32 +0800 |
|---|---|---|
| committer | Jianfei Wang <me@thinxer.com> | 2016-04-09 14:38:01 +0800 |
| commit | 18254d9aaef18f6b836a710e7726711da9aef543 (patch) | |
| tree | cfc771c2b9705fc8eab34a1ec1232d3af22cda0f /go/operation/sync_volume.go | |
| parent | f0cc264757f433457cc5bd306f1ba8be321ee26b (diff) | |
| download | seaweedfs-18254d9aaef18f6b836a710e7726711da9aef543.tar.xz seaweedfs-18254d9aaef18f6b836a710e7726711da9aef543.zip | |
replace util/bytes.go with binary.BigEndian
Diffstat (limited to 'go/operation/sync_volume.go')
| -rw-r--r-- | go/operation/sync_volume.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/go/operation/sync_volume.go b/go/operation/sync_volume.go index 54944a64e..626b2a7ba 100644 --- a/go/operation/sync_volume.go +++ b/go/operation/sync_volume.go @@ -1,6 +1,7 @@ package operation import ( + "encoding/binary" "encoding/json" "fmt" "net/url" @@ -42,9 +43,9 @@ func GetVolumeIdxEntries(server string, vid string, eachEntryFn func(key uint64, values.Add("volume", vid) line := make([]byte, 16) err := util.GetBufferStream("http://"+server+"/admin/sync/index", values, line, func(bytes []byte) { - key := util.BytesToUint64(bytes[:8]) - offset := util.BytesToUint32(bytes[8:12]) - size := util.BytesToUint32(bytes[12:16]) + key := binary.BigEndian.Uint64(bytes[:8]) + offset := binary.BigEndian.Uint32(bytes[8:12]) + size := binary.BigEndian.Uint32(bytes[12:16]) eachEntryFn(key, offset, size) }) if err != nil { |