diff options
| author | chris.lu@gmail.com <chris.lu@gmail.com@282b0af5-e82d-9cf1-ede4-77906d7719d0> | 2011-12-17 06:50:51 +0000 |
|---|---|---|
| committer | chris.lu@gmail.com <chris.lu@gmail.com@282b0af5-e82d-9cf1-ede4-77906d7719d0> | 2011-12-17 06:50:51 +0000 |
| commit | 1fed603df9c90dcfe64f8639949b07654ca3f718 (patch) | |
| tree | cd5c4506f6f357d30079d60c5b0d0872f542a1f3 /weed-fs/src/pkg | |
| parent | 10930ce6b651c4a05a1c85213c1b5c1c1ff7045a (diff) | |
| download | seaweedfs-1fed603df9c90dcfe64f8639949b07654ca3f718.tar.xz seaweedfs-1fed603df9c90dcfe64f8639949b07654ca3f718.zip | |
now working for registering volume id ~ machine mapping
git-svn-id: https://weed-fs.googlecode.com/svn/trunk@13 282b0af5-e82d-9cf1-ede4-77906d7719d0
Diffstat (limited to 'weed-fs/src/pkg')
| -rw-r--r-- | weed-fs/src/pkg/directory/volume_mapping.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed-fs/src/pkg/directory/volume_mapping.go b/weed-fs/src/pkg/directory/volume_mapping.go index ffc90ec7d..e9a0647e5 100644 --- a/weed-fs/src/pkg/directory/volume_mapping.go +++ b/weed-fs/src/pkg/directory/volume_mapping.go @@ -39,7 +39,8 @@ func NewMapper(dirname string, filename string, capacity int) (m *Mapper) { log.Println("Mapping File Read", e) } else { decoder := gob.NewDecoder(dataFile) - decoder.Decode(m.Machines) + defer dataFile.Close() + decoder.Decode(&m.Machines) for _, list := range m.Machines { //TODO: what if a list has mixed readers and writers? Now it's treated as readonly allCanWrite := false @@ -50,7 +51,6 @@ func NewMapper(dirname string, filename string, capacity int) (m *Mapper) { m.writers = append(m.writers, list) } } - dataFile.Close() log.Println("Loaded mapping size", len(m.Machines)) } return |