- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for unwrapping (0.83 sec)
-
src/sync/poolqueue.go
typ, val unsafe.Pointer } const dequeueBits = 32 // dequeueLimit is the maximum size of a poolDequeue. // // This must be at most (1<<dequeueBits)/2 because detecting fullness // depends on wrapping around the ring buffer without wrapping around // the index. We divide by 4 so this fits in an int on 32-bit. const dequeueLimit = (1 << dequeueBits) / 4 // dequeueNil is used in poolDequeue to represent interface{}(nil).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 18:12:29 UTC 2024 - 8.3K bytes - Viewed (0) -
src/io/ioutil/ioutil.go
return nil, err } slices.SortFunc(list, func(a, b os.FileInfo) int { return strings.Compare(a.Name(), b.Name()) }) return list, nil } // NopCloser returns a ReadCloser with a no-op Close method wrapping // the provided Reader r. // // Deprecated: As of Go 1.16, this function simply calls [io.NopCloser]. func NopCloser(r io.Reader) io.ReadCloser { return io.NopCloser(r) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 3.2K bytes - Viewed (0) -
src/net/http/transport_internal_test.go
package http import ( "bytes" "context" "crypto/tls" "errors" "io" "net" "net/http/internal/testcert" "strings" "testing" ) // Issue 15446: incorrect wrapping of errors when server closes an idle connection. func TestTransportPersistConnReadLoopEOF(t *testing.T) { ln := newLocalListener(t) defer ln.Close() connc := make(chan net.Conn, 1) go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 15:57:17 UTC 2024 - 6.2K bytes - Viewed (0) -
src/cmd/compile/internal/inline/interleaved/interleaved.go
// removed them all. var parens []*ir.ParenExpr var mark func(ir.Node) ir.Node mark = func(n ir.Node) ir.Node { if _, ok := n.(*ir.ParenExpr); ok { return n // already visited n.X before wrapping } ok := match(n) ir.EditChildren(n, mark) if ok { paren := ir.NewParenExpr(n.Pos(), n) paren.SetType(n.Type()) paren.SetTypecheck(n.Typecheck())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 20:42:52 UTC 2024 - 5.1K bytes - Viewed (0) -
src/os/error.go
return ok && terr.Timeout() } func underlyingErrorIs(err, target error) bool { // Note that this function is not errors.Is: // underlyingError only unwraps the specific error-wrapping types // that it historically did, not all errors implementing Unwrap(). err = underlyingError(err) if err == target { return true } // To preserve prior behavior, only examine syscall errors.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 4.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/session/scope/internal/SessionScope.java
+ "a org.eclipse.sisu.Typed or javax.enterprise.inject.Typed annotation"); } } /** * A provider wrapping an existing provider with a cache * @param <T> the provided type */ protected static class CachingProvider<T> implements Provider<T> { private final Provider<T> provider;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 7.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/transforms/pin_ops_with_side_effects.cc
}).wasInterrupted()) { ops_with_side_effects.push_back(&op); } } OpBuilder builder(fn.getContext()); // The control tokens generated by the last ControlNodeOp wrapping. Will be // empty until the first ControlNodeOp was generated, then have constant size // 1. llvm::SmallVector<Value, 1> control_tokens; for (auto *op : ops_with_side_effects) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
type ProxyWatcher struct { result chan Event stopCh chan struct{} mutex sync.Mutex stopped bool } var _ Interface = &ProxyWatcher{} // NewProxyWatcher creates new ProxyWatcher by wrapping a channel func NewProxyWatcher(ch chan Event) *ProxyWatcher { return &ProxyWatcher{ result: ch, stopCh: make(chan struct{}), stopped: false, } } // Stop implements Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1)