Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for AfterFunc (0.08 sec)

  1. cni/pkg/nodeagent/cni-watcher.go

    			return
    		default:
    			// 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
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/ztunnelserver.go

    		},
    		pods: pods,
    	}, nil
    }
    
    func (z *ztunnelServer) Close() error {
    	return z.listener.Close()
    }
    
    func (z *ztunnelServer) Run(ctx context.Context) {
    	context.AfterFunc(ctx, func() { _ = z.Close() })
    
    	// Allow at most 5 requests per second. This is still a ridiculous amount; at most we should have 2 ztunnels on our node,
    	// and they will only connect once and persist.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  3. api/go1.21.txt

    pkg bytes, method (*Buffer) Available() int #53685
    pkg cmp, func Compare[$0 Ordered]($0, $0) int #59488
    pkg cmp, func Less[$0 Ordered]($0, $0) bool #59488
    pkg cmp, type Ordered interface {} #59488
    pkg context, func AfterFunc(Context, func()) func() bool #57928
    pkg context, func WithDeadlineCause(Context, time.Time, error) (Context, CancelFunc) #56661
    pkg context, func WithoutCancel(Context) Context #40221
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Aug 07 09:39:17 UTC 2023
    - 25.6K bytes
    - Viewed (0)
  4. cmd/server-main.go

    				go startSFTPServer(globalServerCtxt.SFTP)
    			})
    		}
    	}()
    
    	go func() {
    		if globalEnableSyncBoot {
    			defer bootstrapTrace("unfreezeServices", unfreezeServices)
    			t := time.AfterFunc(5*time.Minute, func() {
    				warnings = append(warnings,
    					color.YellowBold("- Initializing the config subsystem is taking longer than 5 minutes. Please remove 'MINIO_SYNC_BOOT=on' to not freeze the APIs"))
    			})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  5. internal/grid/grid_test.go

    	// Wait for the server start the request.
    	<-reqStarted
    
    	// Block until we have exceeded the deadline several times over.
    	nowBlocking := make(chan struct{})
    	var mu sync.Mutex
    	time.AfterFunc(time.Second, func() {
    		mu.Lock()
    		cancel()
    		close(nowBlocking)
    		mu.Unlock()
    	})
    	if inCap > 0 {
    		go func() {
    			defer close(st.Requests)
    			if !blockReq {
    				<-nowBlocking
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  6. api/go1.txt

    pkg time, const Thursday Weekday
    pkg time, const Tuesday Weekday
    pkg time, const UnixDate ideal-string
    pkg time, const Wednesday Weekday
    pkg time, func After(Duration) <-chan Time
    pkg time, func AfterFunc(Duration, func()) *Timer
    pkg time, func Date(int, Month, int, int, int, int, int, *Location) Time
    pkg time, func FixedZone(string, int) *Location
    pkg time, func LoadLocation(string) (*Location, error)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top