aboutsummaryrefslogtreecommitdiff
path: root/weed-fs/src/pkg
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2012-08-23 23:06:15 -0700
committerChris Lu <chris.lu@gmail.com>2012-08-23 23:06:15 -0700
commitb820609088e5d381bb8690f74df4c6d311bbd99d (patch)
treeb34fb393506586d09b66f9fac8e78d12da07ec73 /weed-fs/src/pkg
parent9f92f2779dac7c3456ca16958ea6fc05a24924e1 (diff)
downloadseaweedfs-b820609088e5d381bb8690f74df4c6d311bbd99d.tar.xz
seaweedfs-b820609088e5d381bb8690f74df4c6d311bbd99d.zip
change name: needle id instead of needle key
Diffstat (limited to 'weed-fs/src/pkg')
-rw-r--r--weed-fs/src/pkg/storage/needle.go12
-rw-r--r--weed-fs/src/pkg/storage/volume.go12
2 files changed, 12 insertions, 12 deletions
diff --git a/weed-fs/src/pkg/storage/needle.go b/weed-fs/src/pkg/storage/needle.go
index 6396b8ef0..ea3cbfb1d 100644
--- a/weed-fs/src/pkg/storage/needle.go
+++ b/weed-fs/src/pkg/storage/needle.go
@@ -15,7 +15,7 @@ import (
type Needle struct {
Cookie uint32 "random number to mitigate brute force lookups"
- Key uint64 "file id"
+ Id uint64 "needle id"
Size uint32 "Data size"
Data []byte "The actual file data"
Checksum int32 "CRC32 to check integrity"
@@ -69,18 +69,18 @@ func (n *Needle) ParsePath(fid string) {
if deltaIndex > 0 {
fid, delta = fid[0:deltaIndex], fid[deltaIndex+1:]
}
- n.Key, n.Cookie = ParseKeyHash(fid)
+ n.Id, n.Cookie = ParseKeyHash(fid)
if delta != "" {
d, e := strconv.ParseUint(delta, 10, 64)
if e == nil {
- n.Key += d
+ n.Id += d
}
}
}
func (n *Needle) Append(w io.Writer) uint32 {
header := make([]byte, 16)
util.Uint32toBytes(header[0:4], n.Cookie)
- util.Uint64toBytes(header[4:12], n.Key)
+ util.Uint64toBytes(header[4:12], n.Id)
n.Size = uint32(len(n.Data))
util.Uint32toBytes(header[12:16], n.Size)
w.Write(header)
@@ -94,7 +94,7 @@ func (n *Needle) Read(r io.Reader, size uint32) (int, error) {
bytes := make([]byte, size+16+4)
ret, e := r.Read(bytes)
n.Cookie = util.BytesToUint32(bytes[0:4])
- n.Key = util.BytesToUint64(bytes[4:12])
+ n.Id = util.BytesToUint64(bytes[4:12])
n.Size = util.BytesToUint32(bytes[12:16])
n.Data = bytes[16 : 16+size]
n.Checksum = int32(util.BytesToUint32(bytes[16+size : 16+size+4]))
@@ -108,7 +108,7 @@ func ReadNeedle(r *os.File) (*Needle, uint32) {
return nil, 0
}
n.Cookie = util.BytesToUint32(bytes[0:4])
- n.Key = util.BytesToUint64(bytes[4:12])
+ n.Id = util.BytesToUint64(bytes[4:12])
n.Size = util.BytesToUint32(bytes[12:16])
rest := 8 - ((n.Size + 16 + 4) % 8)
r.Seek(int64(n.Size+4+rest), 1)
diff --git a/weed-fs/src/pkg/storage/volume.go b/weed-fs/src/pkg/storage/volume.go
index 55e389029..2f156a13b 100644
--- a/weed-fs/src/pkg/storage/volume.go
+++ b/weed-fs/src/pkg/storage/volume.go
@@ -76,19 +76,19 @@ func (v *Volume) write(n *Needle) uint32 {
defer v.accessLock.Unlock()
offset, _ := v.dataFile.Seek(0, 2)
ret := n.Append(v.dataFile)
- nv, ok := v.nm.Get(n.Key)
+ nv, ok := v.nm.Get(n.Id)
if !ok || int64(nv.Offset)*8 < offset {
- v.nm.Put(n.Key, uint32(offset/8), n.Size)
+ v.nm.Put(n.Id, uint32(offset/8), n.Size)
}
return ret
}
func (v *Volume) delete(n *Needle) uint32 {
v.accessLock.Lock()
defer v.accessLock.Unlock()
- nv, ok := v.nm.Get(n.Key)
- //log.Println("key", n.Key, "volume offset", nv.Offset, "data_size", n.Size, "cached size", nv.Size)
+ nv, ok := v.nm.Get(n.Id)
+ //log.Println("key", n.Id, "volume offset", nv.Offset, "data_size", n.Size, "cached size", nv.Size)
if ok {
- v.nm.Delete(n.Key)
+ v.nm.Delete(n.Id)
v.dataFile.Seek(int64(nv.Offset*8), 0)
n.Append(v.dataFile)
return nv.Size
@@ -98,7 +98,7 @@ func (v *Volume) delete(n *Needle) uint32 {
func (v *Volume) read(n *Needle) (int, error) {
v.accessLock.Lock()
defer v.accessLock.Unlock()
- nv, ok := v.nm.Get(n.Key)
+ nv, ok := v.nm.Get(n.Id)
if ok && nv.Offset > 0 {
v.dataFile.Seek(int64(nv.Offset)*8, 0)
return n.Read(v.dataFile, nv.Size)