Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for handlePong (0.22 sec)

  1. internal/grid/connection.go

    		c.handleUnblockClMux(m)
    	case OpDisconnectServerMux:
    		c.handleDisconnectServerMux(m)
    	case OpDisconnectClientMux:
    		c.handleDisconnectClientMux(m)
    	case OpPing:
    		c.handlePing(ctx, m)
    	case OpPong:
    		c.handlePong(ctx, m)
    	case OpRequest:
    		c.handleRequest(ctx, m, subID)
    	case OpAckMux:
    		c.handleAckMux(ctx, m)
    	case OpConnectMux:
    		c.handleConnectMux(ctx, m, subID)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  2. cni/pkg/log/uds.go

    	Time  time.Time `json:"time"`
    	Msg   string    `json:"msg"`
    }
    
    func NewUDSLogger() *UDSLogger {
    	l := &UDSLogger{}
    	mux := http.NewServeMux()
    	mux.HandleFunc(constants.UDSLogPath, l.handleLog)
    	loggingServer := &http.Server{
    		Handler: mux,
    	}
    	l.loggingServer = loggingServer
    	return l
    }
    
    // StartUDSLogServer starts up a UDS server which receives log reported from CNI network plugin.
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 01:05:12 GMT 2023
    - 3.3K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/ztunnelserver.go

    				return
    			}
    
    			log.Errorf("failed to accept conn: %v", err)
    			continue
    		}
    		log.Debug("connection accepted")
    		go func() {
    			log.Debug("handling conn")
    			if err := z.handleConn(ctx, conn); err != nil {
    				log.Errorf("failed to handle conn: %v", err)
    			}
    		}()
    	}
    }
    
    // ZDS protocol is very simple, for every message sent, and ack is sent.
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 12.4K bytes
    - Viewed (0)
Back to top