Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for closeFunc (0.24 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go

    		c.forget(graceful)
    	}
    
    	if timer == nil {
    		closeFunc()
    		return false
    	}
    
    	// OK, block sending, but only until timer fires.
    	select {
    	case c.input <- event:
    		return true
    	case <-timer.C:
    		closeFunc()
    		return false
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 12:22:41 UTC 2023
    - 18.7K bytes
    - Viewed (0)
  2. src/internal/poll/fd_windows.go

    		return syscall.EINVAL
    	}
    	// Poller may want to unregister fd in readiness notification mechanism,
    	// so this must be executed before fd.CloseFunc.
    	fd.pd.close()
    	var err error
    	switch fd.kind {
    	case kindNet:
    		// The net package uses the CloseFunc variable for testing.
    		err = CloseFunc(fd.Sysfd)
    	default:
    		err = syscall.CloseHandle(fd.Sysfd)
    	}
    	fd.Sysfd = syscall.InvalidHandle
    	runtime_Semrelease(&fd.csema)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 31 16:50:42 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  3. src/internal/poll/fd_unix.go

    // no remaining references.
    func (fd *FD) destroy() error {
    	// Poller may want to unregister fd in readiness notification mechanism,
    	// so this must be executed before CloseFunc.
    	fd.pd.close()
    
    	err := fd.SysFile.destroy(fd.Sysfd)
    
    	fd.Sysfd = -1
    	runtime_Semrelease(&fd.csema)
    	return err
    }
    
    // Close closes the FD. The underlying file descriptor is closed by the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  4. src/net/http/clientserver_test.go

    	cst.tr.CloseIdleConnections()
    	a2 := get()
    	if a1 == a2 {
    		t.Errorf("didn't close connection")
    	}
    }
    
    type noteCloseConn struct {
    	net.Conn
    	closeFunc func()
    }
    
    func (x noteCloseConn) Close() error {
    	x.closeFunc()
    	return x.Conn.Close()
    }
    
    type testErrorReader struct{ t *testing.T }
    
    func (r testErrorReader) Read(p []byte) (n int, err error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 46.6K bytes
    - Viewed (0)
  5. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/strategy/VersionRangeSelector.java

                upperInclusive = selector.endsWith(CLOSE_INC);
            } else {
                matcher = LOWER_INFINITE_RANGE.matcher(selector);
                if (matcher.matches()) {
                    lowerBound = null;
                    lowerInclusive = true;
                    upperBound = matcher.group(1);
                    upperInclusive = selector.endsWith(CLOSE_INC);
                } else {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 10 21:10:11 UTC 2023
    - 10K bytes
    - Viewed (0)
Back to top