- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 55 for ack (0.02 sec)
-
tensorflow/compiler/mlir/tensorflow/tests/graphdef2mlir/graph-function-defs.pbtxt
# Verify that we properly import call site function attributes. # CHECK: tf.If # CHECK-SAME: then_branch = @ # CHECK-SAME: then_branch.how_many = 32 # CHECK-SAME: then_branch.ping = "ack" node { name: "Placeholder" op: "Placeholder" attr { key: "dtype" value { type: DT_INT32 } } attr { key: "shape" value { shape {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Apr 24 00:20:25 UTC 2020 - 7.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
if (streamId != 0) throw IOException("TYPE_PING streamId != 0") val payload1 = source.readInt() val payload2 = source.readInt() val ack = flags and FLAG_ACK != 0 handler.ping(ack, payload1, payload2) } @Throws(IOException::class) private fun readGoAway( handler: Handler, length: Int, flags: Int, streamId: Int, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt
} override fun settings( clearPrevious: Boolean, settings: Settings, ) { fail("") } override fun ackSettings() { fail("") } override fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { fail("") } override fun goAway( lastGoodStreamId: Int, errorCode: ErrorCode, debugData: ByteString, ) { fail("")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcgen.go
// and can't understand normal Istio RDS - in particular expects "" instead of "/" as // default prefix, and is expects just the route for one host. // handleAck will detect if the message is an ACK or NACK, and update/log/count // using the generic structures. "Classical" CDS/LDS/RDS/EDS use separate logic - // this is used for the API-based LDS and generic messages.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
.build() connection.start(sendConnectionPreface = false) // verify the peer received the ACK val ackFrame = peer.takeFrame() assertThat(ackFrame.type).isEqualTo(Http2.TYPE_SETTINGS) assertThat(ackFrame.streamId).isEqualTo(0) assertThat(ackFrame.ack).isTrue() taskFaker.runTasks() return connection } private fun updateMaxConcurrentStreams(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
reader.nextFrame( requireSettings = false, object : BaseTestHandler() { override fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { assertThat(ack).isTrue() assertThat(payload1).isEqualTo(expectedPayload1) assertThat(payload2).isEqualTo(expectedPayload2) } }, ) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 28.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* * We need to apply the settings and ack them atomically. This is because some HTTP/2 * implementations (nghttp2) forbid peers from taking advantage of settings before they have * acknowledged! In particular, we shouldn't send frames that assume a new `initialWindowSize` * until we send the frame that acknowledges this new size. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
src/sync/atomic/atomic_test.go
N = int32(1e2) } c := make(chan bool, 2) X := [2]int32{} ack := [2][3]int32{{-1, -1, -1}, {-1, -1, -1}} for p := 0; p < 2; p++ { go func(me int) { he := 1 - me for i := int32(1); i < N; i++ { StoreInt32(&X[me], i) my := LoadInt32(&X[he]) StoreInt32(&ack[me][i%3], my) for w := 1; LoadInt32(&ack[he][i%3]) == -1; w++ { if w%1000 == 0 { runtime.Gosched() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:37:29 UTC 2024 - 71.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt
type: Int, flags: Int, ): String { if (flags == 0) return "" when (type) { // Special case types that have 0 or 1 flag. TYPE_SETTINGS, TYPE_PING -> return if (flags == FLAG_ACK) "ACK" else BINARY[flags] TYPE_PRIORITY, TYPE_RST_STREAM, TYPE_GOAWAY, TYPE_WINDOW_UPDATE -> return BINARY[flags] } val result = if (flags < FLAGS.size) FLAGS[flags]!! else BINARY[flags]
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.7K bytes - Viewed (0) -
internal/http/dial_linux.go
// the TCP fast open connect. This feature is supported // since Linux 4.11. _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_FASTOPEN_CONNECT, 1) // Enable TCP quick ACK, John Nagle says // "Set TCP_QUICKACK. If you find a case where that makes things worse, let me know." _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_QUICKACK, 1) /// Enable keep-alive {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 4.8K bytes - Viewed (0)