replication: check hostname length

Author: dveeden

canal/config.go

@@ -105,7 +105,8 @@ type Config struct {
 	// Set Dialer
 	Dialer client.Dialer
 
-	// Set Localhost
+	// Set the hostname that is used when registering as replica. This is similar to `report_host` in MySQL.
+	// This will be truncated if it is longer than 255 characters.
 	Localhost string
 
 	// EventCacheCount is the capacity of the BinlogStreamer internal event channel.

replication/binlogsyncer.go

@@ -573,13 +573,17 @@ func (b *BinlogSyncer) writeBinlogDumpMariadbGTIDCommand(gset mysql.GTIDSet) err
 	return b.writeBinlogDumpCommand(mysql.Position{Name: "", Pos: 0})
 }
 
-// localHostname returns the hostname that register slave would register as.
+// localHostname returns the hostname that register replica would register as.
+// this gets truncated to 255 bytes.
 func (b *BinlogSyncer) localHostname() string {
-	if len(b.cfg.Localhost) == 0 {
-		h, _ := os.Hostname()
+	h := b.cfg.Localhost
+	if len(h) == 0 {
+		h, _ = os.Hostname()
+	}
+	if len(h) <= 255 {
 		return h
 	}
-	return b.cfg.Localhost
+	return h[:255]
 }
 
 func (b *BinlogSyncer) writeRegisterSlaveCommand() error {