- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for chan (0.17 sec)
-
cni/pkg/nodeagent/server_test.go
type WaitGroup struct { count int32 done chan struct{} } func NewWaitGroup() *WaitGroup { return &WaitGroup{ done: make(chan struct{}), } } func NewWaitForNCalls(t *testing.T, n int32) (*WaitGroup, func()) { wg := &WaitGroup{ done: make(chan struct{}), } wg.Add(n) return wg, func() { select { case <-wg.C():
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
cni/pkg/install/install_test.go
t.Fatal(err) } // Listen for isReady to be set to true ticker := time.NewTicker(500 * time.Millisecond) defer ticker.Stop() readyChan := make(chan bool) go func(ctx context.Context, tick <-chan time.Time) { for { select { case <-ctx.Done(): return case <-tick: if isReady.Load().(bool) { readyChan <- true } }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
if sent == nil { panic("expected snapshot sent") } sendAck(ztunClient) // now remove the pod ztunnelServer := fixture.ztunServer errChan := make(chan error) go func() { errChan <- ztunnelServer.PodDeleted(ctx, uid) }() // read the msg to delete from ztunnel m, fds = readRequest(t, ztunClient) assert.Equal(t, len(fds), 0)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
udsSockDir := t.TempDir() udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe() os.Stdout = w
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
}) return g } type watcher struct { resultsChan chan string errorChan chan error ctx context.Context } func withContext(ctx context.Context) *watcher { return &watcher{ resultsChan: make(chan string, 1), errorChan: make(chan error, 1), ctx: ctx, } } func (w *watcher) Go(f func(chan string) error) { go func() { if err := f(w.resultsChan); err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} type updateRequest struct { Update []byte Fd *int Resp chan updateResponse } type ZtunnelConnection struct { u *net.UnixConn Updates chan updateRequest } func newZtunnelConnection(u *net.UnixConn) *ZtunnelConnection { return &ZtunnelConnection{u: u, Updates: make(chan updateRequest, 100)} } func (z *ZtunnelConnection) Close() { z.u.Close() }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/cmd/install-cni/main.go
"istio.io/istio/pkg/log" ) func main() { // Create context that cancels on termination signal ctx, cancel := context.WithCancel(context.Background()) sigChan := make(chan os.Signal, 1) signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM) go func(sigChan chan os.Signal, cancel context.CancelFunc) { sig := <-sigChan log.Infof("Exit signal received: %s", sig) cancel() }(sigChan, cancel) rootCmd := cmd.GetCommand()
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.2K bytes - Viewed (0) -
cni/pkg/log/uds.go
} l.loggingServer = loggingServer return l } // StartUDSLogServer starts up a UDS server which receives log reported from CNI network plugin. func (l *UDSLogger) StartUDSLogServer(sockAddress string, stop <-chan struct{}) error { if sockAddress == "" { return nil } log.Info("Start a UDS server for CNI plugin logs") unixListener, err := uds.NewListener(sockAddress) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c, nil } func (c *Controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced) c.queue.Run(stop) c.pods.ShutdownHandlers() } func (c *Controller) Reconcile(key types.NamespacedName) error {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
return fmt.Errorf("cannot update resource %s, got status %s", scope.Name, resp.Status) } return nil } func (c *ControlzClient) PutScopes(scopes []*ScopeInfo) error { ch := make(chan struct { err error scopeName string }, len(scopes)) var wg sync.WaitGroup for _, scope := range scopes { wg.Add(1) go func(si *ScopeInfo) { defer wg.Done() err := c.PutScope(si)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0)