- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 608 for seni (0.05 sec)
-
tensorflow/compiler/mlir/tf2xla/tests/legalize-tf-communication.mlir
// the generated `mhlo.send`. // CHECK-LABEL: func @host_compute_one_operand_no_results // CHECK-SAME: ([[ARG0:%.*]]: tensor<i32>) func.func @host_compute_one_operand_no_results(%arg0: tensor<i32>) { // CHECK: [[INIT_TOKEN:%.*]] = mhlo.create_token // CHECK: [[SEND_TOKEN:%.*]] = "mhlo.send"([[ARG0]], [[INIT_TOKEN]]) // CHECK-NOT: "mhlo.after_all"
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 08 18:24:20 UTC 2024 - 38.3K bytes - Viewed (0) -
src/net/http/fcgi/child.go
// Consume the entire body, so the host isn't still writing to // us when we close the socket below in the !keepConn case, // otherwise we'd send a RST. (golang.org/issue/4183) // TODO(bradfitz): also bound this copy in time. Or send // some sort of abort request to the host, so the host // can properly cut off the client sending all the data. // For now just bound it a little and
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.3K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
}) } // AdsPushAll will send updates to all nodes, with a full push. // Mainly used in Debug interface. func AdsPushAll(s *DiscoveryServer) { s.AdsPushAll(&model.PushRequest{ Full: true, Push: s.globalPushContext(), Reason: model.NewReasonStats(model.DebugTrigger), }) } // AdsPushAll will send updates to all nodes, for a full config or incremental EDS.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
src/net/net_windows_test.go
time.Sleep(alittle) // Send second connection data (with delay in a separate goroutine). result := make(chan error) go func() { time.Sleep(alittle) err := send(ln.Addr().String(), "abc") if err != nil { result <- err } result <- nil }() defer func() { err := <-result if err != nil { t.Fatalf("send failed: %v", err) } }()
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/os/signal/signal_test.go
c := make(chan os.Signal, 1) Notify(c, syscall.SIGHUP) defer Stop(c) // Send this process a SIGHUP t.Logf("sighup...") syscall.Kill(syscall.Getpid(), syscall.SIGHUP) waitSig(t, c, syscall.SIGHUP) // Ask for everything we can get. The buffer size has to be // more than 1, since the runtime might send SIGURG signals. // Using 10 is arbitrary. c1 := make(chan os.Signal, 10) Notify(c1)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// Assume the server won't send a TLS ServerHello until we send a TLS ClientHello. If // that happens, then we will have buffered bytes that are needed by the SSLSocket! // This check is imperfect: it doesn't tell us whether a handshake will succeed, just // that it will almost certainly fail because the proxy has sent unexpected data.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 18.6K bytes - Viewed (0) -
src/crypto/tls/handshake_client.go
if !ok { c.sendAlert(alertUnexpectedMessage) return unexpectedMessageError(shd, msg) } // If the server requested a certificate then we have to send a // Certificate message, even if it's empty because we don't have a // certificate to send. if certRequested { certMsg = new(certificateMsg) certMsg.certificates = chainToSend.Certificate
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 38.6K bytes - Viewed (0) -
src/net/net_fake.go
dn = maxPacketSize } dn, err = pq.send(dt, b[:dn], from, true) n += dn if err != nil { return n, err } b = b[dn:] if len(b) == 0 { return n, nil } } } func (pq *packetQueue) send(dt *deadlineTimer, b []byte, from sockaddr, block bool) (n int, err error) { if from == nil { return 0, os.NewSyscallError("send", syscall.EINVAL) } if len(b) > maxPacketSize {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 19:24:21 UTC 2024 - 26.4K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
been received. Previously these events were incorrectly sent too early, when OkHttp was ready to read the response headers or body, which mislead tracing tools. Note that the `responseFailed()` event always used to follow one of these events; now it may be sent without them. * New: Upgrade to Kotlin 1.3.61.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 17 13:25:31 UTC 2024 - 25.2K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
// 2. Service waypoints: in ztunnel, we would defer handling service traffic if the service has a waypoint, and instead // send to the waypoint. However, with sidecars this is problematic. We don't know which service is the intended destination // until *after* we apply policies. If we then sent to a service waypoint, we apply service policies twice. // This can be problematic: double mirroring, fault injection, request manipulation, ....
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0)