mirror of
				https://github.com/openimsdk/open-im-server.git
				synced 2025-11-04 11:22:10 +08:00 
			
		
		
		
	update pingHandler method send args.
This commit is contained in:
		
							parent
							
								
									7118104fad
								
							
						
					
					
						commit
						cfdf86ccc4
					
				@ -103,7 +103,7 @@ func (c *Client) pingHandler(appData string) error {
 | 
			
		||||
 | 
			
		||||
	log.ZDebug(c.ctx, "ping Handler Success.", "appData", appData)
 | 
			
		||||
 | 
			
		||||
	return c.writePongMsg()
 | 
			
		||||
	return c.writePongMsg(appData)
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (c *Client) pongHandler(_ string) error {
 | 
			
		||||
@ -158,7 +158,7 @@ func (c *Client) readMessage() {
 | 
			
		||||
			return
 | 
			
		||||
 | 
			
		||||
		case PingMessage:
 | 
			
		||||
			err := c.writePongMsg()
 | 
			
		||||
			err := c.writePongMsg("")
 | 
			
		||||
			log.ZError(c.ctx, "writePongMsg", err)
 | 
			
		||||
 | 
			
		||||
		case CloseMessage:
 | 
			
		||||
@ -380,7 +380,7 @@ func (c *Client) writePingMsg() error {
 | 
			
		||||
	return c.conn.WriteMessage(PingMessage, nil)
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (c *Client) writePongMsg() error {
 | 
			
		||||
func (c *Client) writePongMsg(appData string) error {
 | 
			
		||||
	if c.closed.Load() {
 | 
			
		||||
		return nil
 | 
			
		||||
	}
 | 
			
		||||
@ -393,5 +393,5 @@ func (c *Client) writePongMsg() error {
 | 
			
		||||
		return err
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	return c.conn.WriteMessage(PongMessage, nil)
 | 
			
		||||
	return c.conn.WriteMessage(PongMessage, []byte(appData))
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user