- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 36 for Ling (0.12 sec)
-
internal/event/target/nats.go
NATSSubject = "subject" NATSUsername = "username" NATSPassword = "password" NATSToken = "token" NATSTLS = "tls" NATSTLSSkipVerify = "tls_skip_verify" NATSPingInterval = "ping_interval" NATSQueueDir = "queue_dir" NATSQueueLimit = "queue_limit" NATSCertAuthority = "cert_authority" NATSClientCert = "client_cert" NATSClientKey = "client_key"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
} } @Test fun emptyPingCallsCallback() { data.write("8900".decodeHex()) // Empty ping clientReader.processNextFrame() callback.assertPing(EMPTY) } @Test fun pingCallsCallback() { data.write("890548656c6c6f".decodeHex()) // Ping with "Hello" clientReader.processNextFrame() callback.assertPing("Hello".encodeUtf8()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
internal/event/target/mysql.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
} } @Test fun pingRoundTrip() { val expectedPayload1 = 7 val expectedPayload2 = 8 writeMedium(frame, 8) // length frame.writeByte(Http2.TYPE_PING) frame.writeByte(Http2.FLAG_ACK) frame.writeInt(0) // connection-level frame.writeInt(expectedPayload1) frame.writeInt(expectedPayload2) // Check writer sends the same bytes.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 28.1K bytes - Viewed (0) -
android/guava/src/com/google/common/net/HttpHeaders.java
* {@code Ping-From}</a> header field name. * * @since 19.0 */ public static final String PING_FROM = "Ping-From"; /** * The HTTP <a href="http://html.spec.whatwg.org/multipage/semantics.html#hyperlink-auditing"> * {@code Ping-To}</a> header field name. * * @since 19.0 */ public static final String PING_TO = "Ping-To"; /** * The HTTP <a
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:08:08 GMT 2024 - 34.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
) val openAtNanos = System.nanoTime() newWebSocket() clientListener.assertOpen() clientListener.assertFailure( SocketTimeoutException::class.java, "sent ping but didn't receive pong within 500ms (after 0 successful ping/pongs)", ) latch.countDown() val elapsedUntilFailure = System.nanoTime() - openAtNanos assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedUntilFailure).toDouble())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
api/go1.8.txt
pkg database/sql/driver, type NamedValue struct, Ordinal int pkg database/sql/driver, type NamedValue struct, Value Value pkg database/sql/driver, type Pinger interface { Ping } pkg database/sql/driver, type Pinger interface, Ping(context.Context) error pkg database/sql/driver, type QueryerContext interface { QueryContext }
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Wed Dec 21 05:25:57 GMT 2016 - 16.3K bytes - Viewed (0) -
internal/grid/connection.go
conn.Close() c.handleMsgWg.Done() }() c.connMu.Lock() connPingInterval := c.connPingInterval c.connMu.Unlock() ping := time.NewTicker(connPingInterval) pingFrame := message{ Op: OpPing, DeadlineMS: 5000, } defer ping.Stop() queue := make([][]byte, 0, maxMergeMessages) merged := make([]byte, 0, writeBufferSize) var queueSize int var buf bytes.Buffer
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/metacache-server-pool.go
// 3) Returning, with ID, stream from list. // // If we don't have a list id we must ask the server if it has a cache or create a new. if o.ID != "" && !o.Transient { // Create or ping with handout... rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)) var c *metacache if rpc == nil { resp := localMetacacheMgr.getBucket(ctx, o.Bucket).findCache(*o) c = &resp
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/BloomFilterStrategies.java
* from the implementation in MURMUR128_MITZ_32 because we're avoiding the multiplication in the * loop and doing a (much simpler) += hash2. We're also changing the index to a positive number by * AND'ing with Long.MAX_VALUE instead of flipping the bits. */ MURMUR128_MITZ_64() { @Override public <T extends @Nullable Object> boolean put( @ParametricNullness T object,
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 10.7K bytes - Viewed (0)