add blocking slave replication

Andrey Perepechaev · Andrey Perepechaev · commit 7f69a5826b8e · 2015-01-13T15:48:18.000+03:00
diff --git a/replication/binlogsyncer.go b/replication/binlogsyncer.go
@@ -163,8 +163,7 @@ func (b *BinlogSyncer) writeBinglogDumpCommand(p Position) error {
 	binary.LittleEndian.PutUint32(data[pos:], p.Pos)
 	pos += 4
 
-	//only support 0x01 BINGLOG_DUMP_NON_BLOCK
-	binary.LittleEndian.PutUint16(data[pos:], BINLOG_DUMP_NON_BLOCK)
+	binary.LittleEndian.PutUint16(data[pos:], BINLOG_DUMP_NEVER_STOP)
 	pos += 2
 
 	binary.LittleEndian.PutUint32(data[pos:], b.serverID)
diff --git a/replication/const.go b/replication/const.go
@@ -24,6 +24,7 @@ const (
 )
 
 const (
+	BINLOG_DUMP_NEVER_STOP  uint16 = 0x00
 	BINLOG_DUMP_NON_BLOCK   uint16 = 0x01
 	BINLOG_THROUGH_POSITION uint16 = 0x02
 	BINLOG_THROUGH_GTID     uint16 = 0x04

Original file line number	Diff line number	Diff line change
`@@ -24,6 +24,7 @@ const (`
`24`	`24`	`)`
`25`	`25`
`26`	`26`	`const (`
	`27`	`+ BINLOG_DUMP_NEVER_STOP uint16 = 0x00`
`27`	`28`	`BINLOG_DUMP_NON_BLOCK uint16 = 0x01`
`28`	`29`	`BINLOG_THROUGH_POSITION uint16 = 0x02`
`29`	`30`	`BINLOG_THROUGH_GTID uint16 = 0x04`