Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 1,754 for closeFn (0.2 sec)

  1. pkg/keepalive/options.go

    	// After having pinged for keepalive check, the server waits for a duration of Timeout and if no activity is seen even after that
    	// the connection is closed.
    	Timeout time.Duration
    	// MaxServerConnectionAge is a duration for the maximum amount of time a
    	// connection may exist before it will be closed by the server sending a GoAway.
    	// A random jitter is added to spread out connection storms.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  2. README.md

    **For more information, please visit the [official project homepage](https://gradle.org)**
    
    ## Getting Started
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sun Mar 24 20:49:08 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. src/net/rpc/jsonrpc/all_test.go

    }
    
    type pipeAddr int
    
    func (pipeAddr) Network() string {
    	return "pipe"
    }
    
    func (pipeAddr) String() string {
    	return "pipe"
    }
    
    func (p *pipe) Close() error {
    	err := p.PipeReader.Close()
    	err1 := p.PipeWriter.Close()
    	if err == nil {
    		err = err1
    	}
    	return err
    }
    
    func (p *pipe) LocalAddr() net.Addr {
    	return pipeAddr(0)
    }
    
    func (p *pipe) RemoteAddr() net.Addr {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Sep 07 01:09:53 UTC 2022
    - 7.8K bytes
    - Viewed (0)
  4. src/cmd/internal/objabi/pkgspecial.go

    	NoRaceFunc bool
    
    	// AllowAsmABI indicates that assembly in this package is allowed to use ABI
    	// selectors in symbol names. Generally this is needed for packages that
    	// interact closely with the runtime package or have performance-critical
    	// assembly.
    	AllowAsmABI bool
    }
    
    var runtimePkgs = []string{
    	"runtime",
    
    	"internal/runtime/atomic",
    	"internal/runtime/exithook",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 02:32:19 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/util/wait/poll.go

    // poller returns a WaitFunc that will send to the channel every interval until
    // timeout has elapsed and then closes the channel.
    //
    // Over very short intervals you may receive no ticks before the channel is
    // closed. A timeout of 0 is interpreted as an infinity, and in such a case
    // it would be the caller's responsibility to close the done channel.
    // Failure to do so would result in a leaked goroutine.
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 26 06:13:35 UTC 2023
    - 14K bytes
    - Viewed (0)
  6. src/database/sql/driver/driver.go

    // used by multiple goroutines concurrently.
    type Stmt interface {
    	// Close closes the statement.
    	//
    	// As of Go 1.1, a Stmt will not be closed if it's in use
    	// by any queries.
    	//
    	// Drivers must ensure all network calls made by Close
    	// do not block indefinitely (e.g. apply a timeout).
    	Close() error
    
    	// NumInput returns the number of placeholder parameters.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Oct 23 09:04:12 UTC 2023
    - 20.9K bytes
    - Viewed (0)
  7. .github/workflows/stale-issues.yml

                It will be closed if no further activity occurs. Thank you.
              close-issue-message: >
                This issue was closed because it has been inactive for 7 days since being marked as stale.
                Please reopen if you'd like to work on this further.
              days-before-pr-stale: 14
              days-before-pr-close: 14
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Nov 23 20:04:38 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  8. src/cmd/go/internal/lockedfile/internal/filelock/filelock_test.go

    	defer remove()
    	rLock(t, f)
    
    	f2 := mustOpen(t, f.Name())
    	defer f2.Close()
    
    	doUnlockTF := false
    	switch runtime.GOOS {
    	case "aix", "solaris":
    		// When using POSIX locks (as on Solaris), we can't safely read-lock the
    		// same inode through two different descriptors at the same time: when the
    		// first descriptor is closed, the second descriptor would still be open but
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 06 22:37:50 UTC 2023
    - 4K bytes
    - Viewed (0)
  9. src/net/internal/socktest/sys_unix.go

    		if so.Err == nil {
    			syscall.Close(s)
    		}
    		return -1, err
    	}
    
    	sw.smu.Lock()
    	defer sw.smu.Unlock()
    	if so.Err != nil {
    		sw.stats.getLocked(so.Cookie).OpenFailed++
    		return -1, so.Err
    	}
    	nso := sw.addLocked(s, family, sotype, proto)
    	sw.stats.getLocked(nso.Cookie).Opened++
    	return s, nil
    }
    
    // Close wraps syscall.Close.
    func (sw *Switch) Close(s int) (err error) {
    	so := sw.sockso(s)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. src/runtime/testdata/testprogcgo/eintr.go

    			return
    		}
    		log.Fatal(err)
    	}
    	wg.Add(2)
    	go func() {
    		defer wg.Done()
    		defer ln.Close()
    		c, err := ln.Accept()
    		if err != nil {
    			log.Fatal(err)
    		}
    		defer c.Close()
    		cf, err := c.(*net.TCPConn).File()
    		if err != nil {
    			log.Fatal(err)
    		}
    		defer cf.Close()
    		if err := syscall.SetNonblock(int(cf.Fd()), false); err != nil {
    			log.Fatal(err)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 05 17:54:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
Back to top