- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 258 for frecv (0.1 sec)
-
src/net/rpc/client_test.go
} } // Test that errors in gob shut down the connection. Issue 7689. type R struct { msg []byte // Not exported, so R does not work with gob. } type S struct{} func (s *S) Recv(nul *struct{}, reply *R) error { *reply = R{[]byte("foo")} return nil } func TestGobError(t *testing.T) { defer func() { err := recover() if err == nil { t.Fatal("no error") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 1.7K bytes - Viewed (0) -
tensorflow/compiler/jit/encapsulate_subgraphs_pass_test.cc
Node* recv = RecvAtHost( ops::NodeOut(key_constant, 0), "F1", "F1", "O1", {DT_FLOAT, DT_FLOAT}, b2.opts().WithAttr(kXlaHasHostTransferAttrName, true)); Node* e = Binary(ops::NodeOut(recv, 0), ops::NodeOut(recv, 1), b2.opts() .WithName("E") .WithControlInputs({recv})
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 113.3K bytes - Viewed (0) -
src/runtime/sigqueue.go
// //go:linkname signal_recv os/signal.signal_recv func signal_recv() uint32 { for { // Serve any signals from local copy. for i := uint32(0); i < _NSIG; i++ { if sig.recv[i/32]&(1<<(i&31)) != 0 { sig.recv[i/32] &^= 1 << (i & 31) return i } } // Wait for updates to be available from signal sender. Receive: for { switch sig.state.Load() { default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcPipeHandle.java
if ( fraglen > getMaxRecv() ) { throw new IOException("Unexpected fragment length: " + fraglen); } while ( have < fraglen ) { int r = this.handle.recv(inB, have, fraglen - have); if ( r == 0 ) { throw new IOException("Unexpected EOF"); } have += r; } return have; }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jan 26 11:51:07 UTC 2020 - 5.2K bytes - Viewed (0) -
pkg/istio-agent/tap_proxy.go
} const ( TypeDebugPrefix = "istio.io/debug/" ) func (p *tapProxy) StreamAggregatedResources(downstream DiscoveryStream) error { timeout := time.Second * 15 req, err := downstream.Recv() if err != nil { log.Errorf("failed to recv: %v", err) return err } if strings.HasPrefix(req.TypeUrl, TypeDebugPrefix) { if resp, err := p.xdsProxy.tapRequest(req, timeout); err == nil { err := downstream.Send(resp)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 1.9K bytes - Viewed (0) -
src/runtime/chan_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 31 20:47:35 UTC 2023 - 23.4K bytes - Viewed (0) -
src/cmd/compile/internal/types/fmt.go
case TCHAN: switch t.ChanDir() { case Crecv: b.WriteString("<-chan ") tconv2(b, t.Elem(), 0, mode, visited) case Csend: b.WriteString("chan<- ") tconv2(b, t.Elem(), 0, mode, visited) default: b.WriteString("chan ") if t.Elem() != nil && t.Elem().IsChan() && t.Elem().Sym() == nil && t.Elem().ChanDir() == Crecv { b.WriteByte('(') tconv2(b, t.Elem(), 0, mode, visited)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 12 15:41:17 UTC 2023 - 15.7K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
con := &ProxyConnection{ conID: connectionNumber.Inc(), upstreamError: make(chan error), // can be produced by recv and send downstreamError: make(chan error), // can be produced by recv and send deltaRequestsChan: channels.NewUnbounded[*discovery.DeltaDiscoveryRequest](),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/prepare_tpu_computation_for_tf_export.mlir
// CHECK-SAME-DAG: _xla_original_oc_node_name = // CHECK-SAME-DAG: _xla_token_input_nodes = ["_xla_token_arg_node"] %recv = "tf.XlaRecvFromHost"() {key = "if_op_token_recv_key", shape = #tf_type.shape<>} : () -> tensor<f32> // CHECK: tf.Yield "tf.Yield"(%recv) : (tensor<f32>) -> () }, { // CHECK-NOT: _xla_token_input_nodes
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 14 18:46:36 UTC 2024 - 9.2K bytes - Viewed (0) -
src/go/types/methodset_test.go
T := pkg.Scope().Lookup("T").Type() name := "m" for _, recv := range []Type{T, NewPointer(T)} { // LookupFieldOrMethod and NewMethodSet must match: // either both find m or neither finds it. obj1, _, _ := LookupFieldOrMethod(recv, false, pkg, name) mset := NewMethodSet(recv) if (obj1 != nil) != (mset.Len() == 1) { t.Fatalf("lookup(%v.%s): got obj = %v, mset = %v", recv, name, obj1, mset) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 08 15:27:57 UTC 2023 - 6.7K bytes - Viewed (0)