Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for TeardownNetwork (0.26 sec)

  1. pkg/kubelet/container/sync_result.go

    	StartContainer SyncAction = "StartContainer"
    	// KillContainer action
    	KillContainer SyncAction = "KillContainer"
    	// SetupNetwork action
    	SetupNetwork SyncAction = "SetupNetwork"
    	// TeardownNetwork action
    	TeardownNetwork SyncAction = "TeardownNetwork"
    	// InitContainer action
    	InitContainer SyncAction = "InitContainer"
    	// CreatePodSandbox action
    	CreatePodSandbox SyncAction = "CreatePodSandbox"
    	// ConfigPodSandbox action
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 19 15:48:08 UTC 2020
    - 4.6K bytes
    - Viewed (0)
  2. pkg/kubelet/container/sync_result_test.go

    	okResults := []*SyncResult{
    		NewSyncResult(StartContainer, "container_0"),
    		NewSyncResult(SetupNetwork, "pod"),
    	}
    	errResults := []*SyncResult{
    		NewSyncResult(KillContainer, "container_1"),
    		NewSyncResult(TeardownNetwork, "pod"),
    	}
    	errResults[0].Fail(errors.New("error_0"), "message_0")
    	errResults[1].Fail(errors.New("error_1"), "message_1")
    
    	// If the PodSyncResult doesn't contain error result, it should not be error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 16:48:17 UTC 2019
    - 2K bytes
    - Viewed (0)
  3. src/net/dial_test.go

    			if err != nil {
    				t.Error(err)
    				continue
    			}
    			switch addr := c.LocalAddr().(*TCPAddr); {
    			case addr.IP.To4() != nil:
    				dss.teardownNetwork("tcp4")
    			case addr.IP.To16() != nil && addr.IP.To4() == nil:
    				dss.teardownNetwork("tcp6")
    			}
    			c.Close()
    		}
    	}
    }
    
    func TestDialerKeepAlive(t *testing.T) {
    	t.Cleanup(func() {
    		testHookSetKeepAlive = func(KeepAliveConfig) {}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 30.3K bytes
    - Viewed (0)
  4. src/net/mockserver_test.go

    	for i := range dss.lns {
    		go func(i int) {
    			handler(dss, dss.lns[i].Listener)
    			close(dss.lns[i].done)
    		}(i)
    	}
    	return nil
    }
    
    func (dss *dualStackServer) teardownNetwork(network string) error {
    	dss.lnmu.Lock()
    	for i := range dss.lns {
    		if network == dss.lns[i].network && dss.lns[i].Listener != nil {
    			dss.lns[i].Listener.Close()
    			<-dss.lns[i].done
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top