mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
fix bug: replication, metadata not replicated
This commit is contained in:
parent
30f138a538
commit
4049c72e6c
|
@ -58,10 +58,14 @@ func ReplicatedWrite(masterNode string, s *storage.Store,
|
||||||
|
|
||||||
pairMap := make(map[string]string)
|
pairMap := make(map[string]string)
|
||||||
if needle.HasPairs() {
|
if needle.HasPairs() {
|
||||||
err := json.Unmarshal(needle.Pairs, &pairMap)
|
tmpMap := make(map[string]string)
|
||||||
|
err := json.Unmarshal(needle.Pairs, &tmpMap)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
glog.V(0).Infoln("Unmarshal pairs error:", err)
|
glog.V(0).Infoln("Unmarshal pairs error:", err)
|
||||||
}
|
}
|
||||||
|
for k, v := range tmpMap {
|
||||||
|
pairMap[storage.PairNamePrefix+k] = v
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
_, err := operation.Upload(u.String(),
|
_, err := operation.Upload(u.String(),
|
||||||
|
|
Loading…
Reference in a new issue