Commit 8be71aec authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent ed777fda
...@@ -246,7 +246,7 @@ func (pt *PartitionTable) String() string { ...@@ -246,7 +246,7 @@ func (pt *PartitionTable) String() string {
return buf.String() return buf.String()
} }
// ToMsg creates message that represents parttion table state. // ToMsg creates message that represents partition table state.
func (pt *PartitionTable) ToMsg() *proto.SendPartitionTable { func (pt *PartitionTable) ToMsg() *proto.SendPartitionTable {
msg := &proto.SendPartitionTable{ msg := &proto.SendPartitionTable{
PTid: pt.PTid, PTid: pt.PTid,
...@@ -271,7 +271,7 @@ func (pt *PartitionTable) ToMsg() *proto.SendPartitionTable { ...@@ -271,7 +271,7 @@ func (pt *PartitionTable) ToMsg() *proto.SendPartitionTable {
func PartTabFromMsg(msg *proto.SendPartitionTable) *PartitionTable { func PartTabFromMsg(msg *proto.SendPartitionTable) *PartitionTable {
pt := &PartitionTable{ pt := &PartitionTable{
PTid: msg.PTid, PTid: msg.PTid,
r_: int(msg.NumReplicas + 1 - 1), // NOTE NEO/py treates NumReplicas as n(replica)-1 r_: int(msg.NumReplicas + 1 - 1), // NOTE NEO/py treats NumReplicas as n(replica)-1
} }
for i, row := range msg.RowList { for i, row := range msg.RowList {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment