Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ioHandler (0.13 sec)

  1. pkg/volume/fc/fc.go

    	wwns    []string
    	lun     string
    	wwids   []string
    	plugin  *fcPlugin
    	// Utility interface that provides API calls to the provider to attach/detach disks.
    	manager diskManager
    	// io handler interface
    	io ioHandler
    	volume.MetricsNil
    }
    
    func (fc *fcDisk) GetPath() string {
    	// safe to use PodVolumeDir now: volume teardown occurs before pod is cleaned up
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  2. pkg/volume/testing/testing.go

    	}
    
    	return pv, nil
    }
    
    var _ volumepathhandler.BlockVolumePathHandler = &FakeVolumePathHandler{}
    
    // NewDeviceHandler Create a new IoHandler implementation
    func NewBlockVolumePathHandler() volumepathhandler.BlockVolumePathHandler {
    	return &FakeVolumePathHandler{}
    }
    
    type FakeVolumePathHandler struct {
    	sync.RWMutex
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  3. src/net/http/transport_test.go

    	retry := true
    	for retry && !t.Failed() {
    		var srvWG sync.WaitGroup
    		inHandler := make(chan bool, 1)
    		mux := NewServeMux()
    		mux.HandleFunc("/fast", func(w ResponseWriter, r *Request) {
    			inHandler <- true
    			srvWG.Done()
    		})
    		mux.HandleFunc("/slow", func(w ResponseWriter, r *Request) {
    			inHandler <- true
    			<-r.Context().Done()
    			srvWG.Done()
    		})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  4. src/net/http/serve_test.go

    }
    func testServerRequestContextCancel_ConnClose(t *testing.T, mode testMode) {
    	inHandler := make(chan struct{})
    	handlerDone := make(chan struct{})
    	ts := newClientServerTest(t, mode, HandlerFunc(func(w ResponseWriter, r *Request) {
    		close(inHandler)
    		<-r.Context().Done()
    		close(handlerDone)
    	})).ts
    	c, err := net.Dial("tcp", ts.Listener.Addr().String())
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
Back to top