Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,629 for closeFn (0.13 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. .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)
  6. 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)
  7. 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)
  8. src/runtime/chan.go

    	if c == nil {
    		panic(plainError("close of nil channel"))
    	}
    
    	lock(&c.lock)
    	if c.closed != 0 {
    		unlock(&c.lock)
    		panic(plainError("close of closed channel"))
    	}
    
    	if raceenabled {
    		callerpc := getcallerpc()
    		racewritepc(c.raceaddr(), callerpc, abi.FuncPCABIInternal(closechan))
    		racerelease(c.raceaddr())
    	}
    
    	c.closed = 1
    
    	var glist gList
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ContiguousSet.java

       * (inclusive) to {@code upper} (inclusive). (These are the same values contained in {@code
       * Range.closed(lower, upper)}.)
       *
       * @throws IllegalArgumentException if {@code lower} is greater than {@code upper}
       * @since 23.0
       */
      public static ContiguousSet<Integer> closed(int lower, int upper) {
        return create(Range.closed(lower, upper), DiscreteDomain.integers());
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Nov 30 21:54:06 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  10. src/internal/fuzz/sys_windows.go

    		sys:           sharedMemSys{mapObj: mapObj},
    	}, nil
    }
    
    // Close unmaps the shared memory and closes the temporary file. If this
    // sharedMem was created with sharedMemTempFile, Close also removes the file.
    func (m *sharedMem) Close() error {
    	// Attempt all operations, even if we get an error for an earlier operation.
    	// os.File.Close may fail due to I/O errors, but we still want to delete
    	// the temporary file.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 20 18:35:25 UTC 2023
    - 4.5K bytes
    - Viewed (0)
Back to top