Merge branch 'haproxy'
This commit is contained in:
commit
c83c5a1cc5
session-dealer/mysql
|
@ -339,7 +339,7 @@ func filterQueryPieceBySQL(mqp *model.PooledMysqlQueryPiece, querySQL []byte) (*
|
||||||
func (ms *MysqlSession) composeQueryPiece() (mqp *model.PooledMysqlQueryPiece) {
|
func (ms *MysqlSession) composeQueryPiece() (mqp *model.PooledMysqlQueryPiece) {
|
||||||
clientIP := ms.clientIP
|
clientIP := ms.clientIP
|
||||||
clientPort := ms.clientPort
|
clientPort := ms.clientPort
|
||||||
if clientIP == nil || len(*clientIP) < 1 {
|
if clientIP == nil {
|
||||||
clientIP = ms.srcIP
|
clientIP = ms.srcIP
|
||||||
clientPort = ms.serverPort
|
clientPort = ms.serverPort
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue