- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 51 for listen (0.18 sec)
-
cmd/listen-notification-handlers.go
return } } rulesMap := event.NewRulesMap(eventNames, pattern, event.TargetID{ID: mustGetUUID()}) setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/http/listener.go
func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.listeners { listener.listeners[i].Close() } return nil } // Addr - net.Listener interface compatible method returns net.Addr. In case of multiple TCP listeners, it returns '0.0.0.0' as IP address. func (listener *httpListener) Addr() (addr net.Addr) { addr = listener.listeners[0].Addr()
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/grid/debug.go
panic(err) } } } } func getHosts(n int) (hosts []string, listeners []net.Listener, err error) { for i := 0; i < n; i++ { l, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { if l, err = net.Listen("tcp6", "[::1]:0"); err != nil { return nil, nil, fmt.Errorf("httptest: failed to listen on a port: %v", err) } } addr := l.Addr() hosts = append(hosts, "http://"+addr.String())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 4.2K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener.go
} var err error listener, err := net.Listen("unix", path) if err != nil { return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err) } // Update file permission so that cni plugin has permission to access it. if _, err := os.Stat(path); err != nil { return nil, fmt.Errorf("cni listener file %q doesn't exist", path) }
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) -
cni/pkg/nodeagent/cni-watcher.go
// If the cniListener exits, at least we should record an error log log.Errorf("CNI listener server exiting unexpectedly: %v", err) } }() context.AfterFunc(s.ctx, func() { if err := s.cniListenServer.Close(); err != nil { log.Errorf("CNI listen server terminated with error: %v", err) } else { log.Debug("CNI listen server terminated") } }) return nil }
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) -
cmd/peer-rest-client.go
} return nil }) } // Listen - listen on peers. func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) { go func() { for { client.doListen(ctx, listenCh, v) select { case <-ctx.Done(): return default: // There was error in the REST request, retry after sometime as probably the peer is down. time.Sleep(5 * time.Second) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
internal/logger/logrotate.go
w.pw.CloseWithError(nil) if w.f != nil { if err := w.closeCurrentFile(); err != nil { return err } } return nil } var stdErrEnc = json.NewEncoder(os.Stderr) func (w *Writer) listen() { for { var r io.Reader = w.pr if w.opts.MaximumFileSize > 0 { r = io.LimitReader(w.pr, w.opts.MaximumFileSize) } if _, err := io.Copy(w.f, r); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
if err != nil { return nil, fmt.Errorf("failed to listen unix: %w", err) } return &ztunnelServer{ listener: l, conns: &connMgr{ connectionSet: map[*ZtunnelConnection]struct{}{}, }, pods: pods, }, nil } func (z *ztunnelServer) Close() error { return z.listener.Close() } func (z *ztunnelServer) Run(ctx context.Context) {
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) -
cmd/sftp-server.go
SSHConfig: sshConfig, HandleSFTPSession: handleSFTPSession, }) if err != nil { logger.Fatal(err, "Unable to start SFTP Server") } err = sftpServer.Listen() if err != nil { logger.Fatal(err, "SFTP Server had an unrecoverable error while accepting connections") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 11:07:40 GMT 2024 - 10.4K bytes - Viewed (0) -
istioctl/pkg/dashboard/dashboard.go
cmd.HelpFunc()(cmd, args) return nil }, } dashboardCmd.PersistentFlags().IntVarP(&listenPort, "port", "p", 0, "Local port to listen to") dashboardCmd.PersistentFlags().StringVar(&bindAddress, "address", "localhost", "Address to listen on. Only accepts IP address or localhost as a value. "+ "When localhost is supplied, istioctl will try to bind on both 127.0.0.1 and ::1 "+
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0)