- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 226 for nbrecv (0.15 sec)
-
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/main/java/jcifs/smb1/smb1/SmbTransport.java
/* Unless key returned is null or invalid Transport.loop() always * calls doRecv() after and no one else but the transport thread * should call doRecv(). Therefore it is ok to expect that the data * in sbuf will be preserved for copying into BUF in doRecv(). */ return key; } protected void doSend( Request request ) throws IOException {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 31.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/syscall_linux_s390x.go
netSocket = 1 netBind = 2 netConnect = 3 netListen = 4 netAccept = 5 netGetSockName = 6 netGetPeerName = 7 netSocketPair = 8 netSend = 9 netRecv = 10 netSendTo = 11 netRecvFrom = 12 netShutdown = 13 netSetSockOpt = 14 netGetSockOpt = 15 netSendMsg = 16 netRecvMsg = 17 netAccept4 = 18 netRecvMMsg = 19
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 9.3K 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/cmd/vendor/golang.org/x/tools/go/analysis/passes/copylock/copylock.go
// inadvertently copy a lock, by checking whether // its receiver, parameters, or return values // are locks. func checkCopyLocksFunc(pass *analysis.Pass, name string, recv *ast.FieldList, typ *ast.FuncType) { if recv != nil && len(recv.List) > 0 { expr := recv.List[0].Type if path := lockPath(pass.Pkg, pass.TypesInfo.Types[expr].Type, nil); path != nil { pass.ReportRangef(expr, "%s passes lock by value: %v", name, path) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 9.9K bytes - Viewed (0) -
src/net/net_windows_test.go
}() // Receive first or second connection. s, err := recv(ln, true) if err != nil { t.Fatalf("recv failed: %v", err) } switch s { case "": // First connection data is received, let's get second connection data. case "abc": // First connection is lost forever, but that is ok. return default: t.Fatalf(`"%s" received from recv, but "" or "abc" expected`, s) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.3K bytes - Viewed (0) -
src/go/doc/comment/parse.go
pkg, name, ok := splitDocName(text) var recv string if ok { pkg, recv, _ = splitDocName(pkg) } if pkg != "" { if pkg, ok = d.lookupPkg(pkg); !ok { return nil, false } } else { if ok = d.lookupSym(recv, name); !ok { return nil, false } } link = &DocLink{ ImportPath: pkg, Recv: recv, Name: name, } return link, true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:03 UTC 2023 - 33.5K bytes - Viewed (0)