.

t/neo/marshal.go

@@ -272,3 +272,35 @@ func (p *PartitionChanges) NEODecode(data []byte) (int, error) {
 	}
 	return 0 /* + TODO variable part */, nil
 }
+
+func (p *StartOperation) NEODecode(data []byte) (int, error) {
+	p.Backup = bool((data[0:])[0])
+	return 1 /* + TODO variable part */, nil
+}
+
+func (p *StopOperation) NEODecode(data []byte) (int, error) {
+	return 0 /* + TODO variable part */, nil
+}
+
+func (p *UnfinishedTransactions) NEODecode(data []byte) (int, error) {
+	return 0 /* + TODO variable part */, nil
+}
+
+func (p *AnswerUnfinishedTransactions) NEODecode(data []byte) (int, error) {
+	p.MaxTID = BigEndian.Uint64(data[0:])
+	{
+		l := BigEndian.Uint32(data[8:])
+		data = data[12:]
+		p.TidList = make([]struct{ UnfinishedTID neo.Tid }, l)
+		for i := 0; i < l; i++ {
+			a := &p.TidList[i]
+			a.UnfinishedTID = BigEndian.Uint64(data[0:])
+			data = data[8:]
+		}
+	}
+	return 0 /* + TODO variable part */, nil
+}
+
+func (p *LockedTransactions) NEODecode(data []byte) (int, error) {
+	return 0 /* + TODO variable part */, nil
+}

t/neo/proto.go

@@ -298,7 +298,6 @@ type PartitionChanges struct {
         }
 }
 
-/*
 // Tell a storage nodes to start an operation. Until a storage node receives
 // this message, it must not serve client nodes. PM -> S.
 type StartOperation struct {
@@ -328,6 +327,7 @@ type AnswerUnfinishedTransactions struct {
 // Answer locked transactions  S -> PM.
 type LockedTransactions struct {
 }
+/*
 
 type AnswerLockedTransactions struct {
 	TidDict map[Tid]Tid     // ttid -> tid