debugging for commits

common/messages/dbstateMissing.go

@@ -129,7 +129,7 @@ func (m *DBStateMissing) send(dbheight uint32, state interfaces.IState) (msglen
 	return
 }
 
-func NewEnd(inLen int, start uint32, end uint32 ) (s uint32, e uint32){
+func NewEnd(inLen int, start uint32, end uint32) (s uint32, e uint32) {
 	switch {
 	case inLen > 500:
 		return 0, 0

common/messages/dbstateMissing_test.go

@@ -79,32 +79,31 @@ func newDBStateMissing() *DBStateMissing {
 	return msg
 }
 
-
 func Testlimits(t *testing.T) {
 
 	for s := uint32(0); s < 100; s++ {
 		for e := s; e < s+1000; e++ {
 			for in := 0; in < 1000; in++ {
-				ns, ne := NewEnd(in,s,e)
+				ns, ne := NewEnd(in, s, e)
 
 				if s != ns {
-					t.Errorf(" Failed with e %d s %d and in %d",e,s,in)
+					t.Errorf(" Failed with e %d s %d and in %d", e, s, in)
 				}
 
 				if ne > e {
-					t.Errorf(" Failed with e %d s %d and in %d",e,s,in)
+					t.Errorf(" Failed with e %d s %d and in %d", e, s, in)
 				}
 
 				if in > 500 && ne != 0 {
-					t.Errorf(" Failed with e %d s %d and in %d",e,s,in)
+					t.Errorf(" Failed with e %d s %d and in %d", e, s, in)
 				}
 
 				if in <= 500 && in > 200 && ne-ns > 50 {
-					t.Errorf(" Failed with e %d s %d and in %d",e,s,in)
+					t.Errorf(" Failed with e %d s %d and in %d", e, s, in)
 				}
 
 				if in <= 200 && ne-ns > 200 {
-					t.Errorf(" Failed with e %d s %d and in %d",e,s,in)
+					t.Errorf(" Failed with e %d s %d and in %d", e, s, in)
 				}
 			}
 		}

engine/simControl.go

@@ -537,14 +537,39 @@ func SimControl(listenTo int) {
 
 			case 'y' == b[0]:
 				if listenTo >= 0 && listenTo < len(fnodes) {
-					f := fnodes[listenTo]
-					fmt.Println("Holding:")
-					for k := range f.State.Holding {
-						v := f.State.Holding[k]
-						if v != nil {
-							os.Stderr.WriteString((v.String()) + "\n")
-						} else {
-							os.Stderr.WriteString("<nul>\n")
+					if len(b) == 1 || b[1] == 'h' {
+						f := fnodes[listenTo]
+						fmt.Println("Holding:")
+						for k := range f.State.Holding {
+							v := f.State.Holding[k]
+							if v != nil {
+								os.Stderr.WriteString((v.String()) + "\n")
+							} else {
+								os.Stderr.WriteString("<nul>\n")
+							}
+						}
+					} else if b[1] == 'c' {
+						f := fnodes[listenTo]
+						fmt.Println("Commits:")
+						for _, v := range f.State.Commits {
+							if v != nil && len(v) > 0 {
+								os.Stderr.WriteString("[\n")
+								for _, c := range v {
+									os.Stderr.WriteString("  " + (c.String()))
+									cc, ok1 := c.(*messages.CommitChainMsg)
+									cm, ok2 := c.(*messages.CommitEntryMsg)
+									if ok1 && f.State.Holding[cc.CommitChain.EntryHash.Fixed()] != nil {
+										os.Stderr.WriteString(" cc MATCH!\n")
+									} else if ok2 && f.State.Holding[cm.CommitEntry.EntryHash.Fixed()] != nil {
+										os.Stderr.WriteString(" ce MATCH!\n")
+									} else {
+										os.Stderr.WriteString(" no match\n")
+									}
+								}
+								os.Stderr.WriteString("]\n")
+							} else {
+								os.Stderr.WriteString("<nul>\n")
+							}
 						}
 					}
 				}