Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 1,957 for closeFn (0.24 sec)

  1. 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)
  2. 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)
  3. pkg/test/framework/integration/component.go

    package integration
    
    import (
    	"io"
    
    	"istio.io/istio/pkg/test/framework/resource"
    )
    
    var _ io.Closer = &component{}
    
    type component struct {
    	name        string
    	id          resource.ID
    	handleClose func(*component)
    }
    
    func (c *component) ID() resource.ID {
    	return c.id
    }
    
    func (c *component) Close() error {
    	if c.handleClose != nil {
    		c.handleClose(c)
    	}
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 29 20:42:01 UTC 2020
    - 1.1K 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. subprojects/core/src/main/java/org/gradle/util/internal/DisconnectableInputStream.java

            }
        }
    
        /**
         * Closes this {@code InputStream} for reading. Any threads blocked in read() will receive an end-of-stream. Also requests that the
         * reader thread stop reading, if possible, but does not block waiting for this to happen.
         *
         * <p>NOTE: this method does not close the source input stream.</p>
         */
        @Override
        public void close() throws IOException {
            lock.lock();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 07 08:18:46 UTC 2021
    - 6.5K bytes
    - Viewed (0)
  8. .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)
  9. 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)
  10. 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)
Back to top