update

matrixorigin · Feb 24, 2025 · a207787 · a207787
1 parent e4ff93f
commit a207787
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 109 deletions.
diff --git a/pkg/frontend/mysql_protocol_predefines.go b/pkg/frontend/mysql_protocol_predefines.go
@@ -324,6 +324,7 @@ const (
 	CLIENT_CAN_HANDLE_EXPIRED_PASSWORDS   uint32 = 0x00400000
 	CLIENT_SESSION_TRACK                  uint32 = 0x00800000
 	CLIENT_DEPRECATE_EOF                  uint32 = 0x01000000
+	CLIENT_ZSTD_COMPRESSION_ALGORITHM     uint32 = 0x04000000
 )
 
 // server status
@@ -367,6 +368,7 @@ const (
 	COM_TIME                CommandType = 0x0f
 	COM_DELAYED_INSERT      CommandType = 0x10
 	COM_CHANGE_USER         CommandType = 0x11
+	COM_REGISTER_SLAVE      CommandType = 0x15
 	COM_STMT_PREPARE        CommandType = 0x16
 	COM_STMT_EXECUTE        CommandType = 0x17
 	COM_STMT_SEND_LONG_DATA CommandType = 0x18
@@ -375,6 +377,7 @@ const (
 	COM_SET_OPTION          CommandType = 0x1b
 	COM_STMT_FETCH          CommandType = 0x1c
 	COM_DAEMON              CommandType = 0x1d
+	COM_BINLOG_DUMP_GTID    CommandType = 0x1e
 	COM_RESET_CONNECTION    CommandType = 0x1f
 )
 

diff --git a/pkg/frontend/replication.go b/pkg/frontend/replication.go
diff --git a/pkg/frontend/server.go b/pkg/frontend/server.go
@@ -88,7 +88,6 @@ func (mo *MOServer) GetRoutineManager() *RoutineManager {
 func (mo *MOServer) Start() error {
 	logutil.Infof("Server Listening on : %s ", mo.addr)
 	mo.running = true
-	go startReplication(mo.rm.ctx)
 	mo.startListener()
 	setMoServerStarted(mo.service, true)
 	return nil