Function AcceptNAConn

rpc/accept.go:56–67

AcceptNAConn accepts connection as a naconn.NAConn. Default accept function of RPC server, and also the only accept function for the connections from a NAConnPool. Corresponding dialer is naconn.Dial/naconn.DialEx.

(ctx context.Context, conn net.Conn)

//
// Corresponding dialer is naconn.Dial/naconn.DialEx.
func AcceptNAConn(ctx context.Context, conn net.Conn) (net.Conn, error) {
	naconn, err := Accept(conn)
	if err != nil {
		log.WithFields(log.Fields{
			"local":  conn.LocalAddr(),
			"remote": conn.RemoteAddr(),
		}).WithError(err).Error("failed to accept NAConn")
		_ = conn.Close()
		return nil, err
	}
	return naconn, nil
}