- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for socketio (0.18 sec)
-
internal/http/listener.go
ClientWriteTimeout time.Duration SendBufSize int // SO_SNDBUF size for the socket connection, NOTE: this sets server and client connection RecvBufSize int // SO_RECVBUF size for the socket connection, NOTE: this sets server and client connection Interface string // This is a VRF device passed via `--interface` flag
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/http/check_port_linux.go
if opts.Interface != "" { // When interface is specified look for specifically port availability on // the specified interface if any. _ = syscall.SetsockoptString(int(fdPtr), syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface) } }) return nil }, } ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Viewed (0) -
src/cmd/cgo/godefs.go
fmt.Fprintf(&buf, "// %s %s\n", filepath.Base(args[0]), strings.Join(args[1:], " ")) fmt.Fprintf(&buf, "\n") override := make(map[string]string) // Allow source file to specify override mappings. // For example, the socket data structures refer // to in_addr and in_addr6 structs but we want to be // able to treat them as byte arrays, so the godefs // inputs in package syscall say // // // +godefs map struct_in_addr [4]byte
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Sep 08 14:33:35 GMT 2022 - 4.5K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener.go
package pluginlistener import ( "fmt" "net" "os" "path/filepath" "istio.io/istio/pkg/log" ) func NewListener(path string) (net.Listener, error) { // Remove unix socket before use. if err := os.Remove(path); err != nil && !os.IsNotExist(err) { // Anything other than "file not found" is an error. return nil, fmt.Errorf("failed to remove unix://%s: %v", path, err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.7K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
} } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) IsOnline() bool { // If rest client has not connected yet there is nothing to close. return restClient.rest != nil } func (restClient *ReconnectRESTClient) IsLocal() bool { return false } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) Close() error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// // We want to do the same thing in ambient but can't rely on podSpec injection. So, do effectively the same thing, // but with iptables rules - use `--socket-exists` as a proxy for "is this a forwarded packet" vs "is this originating from // a local node socket". If the latter, outside the pod in the host netns, redirect that traffic to a hardcoded/custom proxy
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} resolvedAddr, err := net.ResolveUnixAddr("unixpacket", addr) if err != nil { return nil, fmt.Errorf("failed to resolve unix addr: %w", err) } // remove potentially existing address // Remove unix socket before use, if one is leftover from previous CNI restart if err := os.Remove(addr); err != nil && !os.IsNotExist(err) { // Anything other than "file not found" is an error.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/monitoring/monitoring.go
if port <= 0 { return } mux := http.NewServeMux() var listener net.Listener var err error if listener, err = net.Listen("tcp", fmt.Sprintf(":%d", port)); err != nil { log.Errorf("unable to listen on socket: %v", err) return } exporter, err := monitoring.RegisterPrometheusExporter(nil, nil) if err != nil { log.Errorf("could not set up prometheus exporter: %v", err) return } mux.Handle(path, exporter)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 07:54:01 GMT 2023 - 1.5K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
s.cniListenServerCancel() } // Start starts up a UDS server which receives events from the CNI chain plugin. func (s *CniPluginServer) Start() error { if s.sockAddress == "" { return fmt.Errorf("no socket address provided") } log.Info("Start a listen server for CNI plugin events") unixListener, err := pluginlistener.NewListener(s.sockAddress) if err != nil { return fmt.Errorf("failed to create CNI listener: %v", err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
internal/http/server.go
} // UseCustomLogger use customized logger for this HTTP *Server func (srv *Server) UseCustomLogger(l *log.Logger) *Server { srv.ErrorLog = l return srv } // UseTCPOptions use custom TCP options on raw socket func (srv *Server) UseTCPOptions(opts TCPOptions) *Server { srv.TCPOptions = opts return srv } // NewServer - creates new HTTP server using given arguments. func NewServer(addrs []string) *Server {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0)