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/storage/needle.go | |
| parent | f0cc264757f433457cc5bd306f1ba8be321ee26b (diff) | |
| download | seaweedfs-18254d9aaef18f6b836a710e7726711da9aef543.tar.xz seaweedfs-18254d9aaef18f6b836a710e7726711da9aef543.zip | |
replace util/bytes.go with binary.BigEndian
Diffstat (limited to 'go/storage/needle.go')
| -rw-r--r-- | go/storage/needle.go | 29 |
1 files changed, 18 insertions, 11 deletions
diff --git a/go/storage/needle.go b/go/storage/needle.go index d6345adb1..66cf5b22a 100644 --- a/go/storage/needle.go +++ b/go/storage/needle.go @@ -1,7 +1,6 @@ package storage import ( - "encoding/hex" "errors" "fmt" "io/ioutil" @@ -15,7 +14,6 @@ import ( "github.com/chrislusf/seaweedfs/go/glog" "github.com/chrislusf/seaweedfs/go/images" "github.com/chrislusf/seaweedfs/go/operation" - "github.com/chrislusf/seaweedfs/go/util" ) const ( @@ -213,16 +211,25 @@ func (n *Needle) ParsePath(fid string) (err error) { } func ParseKeyHash(key_hash_string string) (uint64, uint32, error) { - if len(key_hash_string)%2 == 1 { - key_hash_string = "0" + key_hash_string - } - key_hash_bytes, khe := hex.DecodeString(key_hash_string) - key_hash_len := len(key_hash_bytes) - if khe != nil || key_hash_len <= 4 || key_hash_len > 12 { - glog.V(0).Infoln("Invalid key_hash", key_hash_string, "length:", key_hash_len, "error", khe) + key, hash, ok := parseKeyHash(key_hash_string) + if !ok { return 0, 0, errors.New("Invalid key and hash:" + key_hash_string) } - key := util.BytesToUint64(key_hash_bytes[0 : key_hash_len-4]) - hash := util.BytesToUint32(key_hash_bytes[key_hash_len-4 : key_hash_len]) return key, hash, nil } + +func parseKeyHash(keyhash string) (uint64, uint32, bool) { + if len(keyhash) <= 8 || len(keyhash) > 24 { + return 0, 0, false + } + split := len(keyhash) - 8 + key, err := strconv.ParseUint(keyhash[:split], 16, 64) + if err != nil { + return 0, 0, false + } + hash, err := strconv.ParseUint(keyhash[split:], 16, 32) + if err != nil { + return 0, 0, false + } + return key, uint32(hash), true +} |
