- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 31 for acknowledged (0.17 sec)
-
src/main/java/org/codelibs/fess/es/client/SearchEngineClient.java
.execute().actionGet(fessConfig.getIndexIndicesTimeout()); if (indexResponse.isAcknowledged()) { logger.info("Created {} index.", indexName); return true; } if (logger.isDebugEnabled()) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 84.1K bytes - Viewed (0) -
internal/grid/muxserver.go
ctx: ctx, cancel: cancel, parent: c, inbound: nil, outBlock: make(chan struct{}, outboundCap), LastPing: time.Now().Unix(), BaseFlags: c.baseFlags, } // Acknowledge Mux created. // Send async. var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() var ack message ack.Op = OpAckMux ack.Flags = m.BaseFlags ack.MuxID = m.ID m.send(ack)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
common-protos/k8s.io/api/core/v1/generated.proto
// is empty if no IPs have been allocated yet. // +optional // +patchStrategy=merge // +patchMergeKey=ip repeated PodIP podIPs = 12; // RFC 3339 date and time at which the object was acknowledged by the Kubelet. // This is before the Kubelet pulled the container image(s) for the pod. // +optional optional k8s.io.apimachinery.pkg.apis.meta.v1.Time startTime = 7;
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 255.8K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Ascii.java
* identification, or may be used to obtain station status, or both. * * @since 8.0 */ public static final byte ENQ = 5; /** * Acknowledge: A communication control character transmitted by a receiver as an affirmative * response to a sender. * * @since 8.0 */ public static final byte ACK = 6; /**
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Jul 19 15:43:07 GMT 2021 - 21.6K bytes - Viewed (0) -
CHANGELOG.md
calls and that can receive data faster than they can process it. Previously, OkHttp limited HTTP/2 to 16 MiB of unacknowledged data per connection. With this fix there is a limit of 16 MiB of unacknowledged data per stream and no per-connection limit. * Fix: Don't close a `Deflater` while we're still using it to compress a web socket message. We
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
val server = serverListener.assertOpen() for (i in 0 until messageCount) { serverListener.assertBinaryMessage(message) } serverListener.assertClosing(1001, "") // When the server acknowledges the close the connection shuts down gracefully. server.close(1000, null) clientListener.assertClosing(1000, "") clientListener.assertClosed(1000, "") serverListener.assertClosed(1001, "") }
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) -
guava/src/com/google/common/collect/ArrayTable.java
* do, when columnKeys is empty but rowKeys isn't, rowKeyList() can contain * elements but rowKeySet() will be empty and containsRow() won't * acknowledge them. */ rowKeyToIndex = Maps.indexMap(rowList); columnKeyToIndex = Maps.indexMap(columnList); @SuppressWarnings("unchecked") @Nullable
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 26.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ArrayTable.java
* do, when columnKeys is empty but rowKeys isn't, rowKeyList() can contain * elements but rowKeySet() will be empty and containsRow() won't * acknowledge them. */ rowKeyToIndex = Maps.indexMap(rowList); columnKeyToIndex = Maps.indexMap(columnList); @SuppressWarnings("unchecked") @Nullable
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 21:19:52 GMT 2024 - 26.3K bytes - Viewed (0) -
LICENSE
permission to run the unmodified Program. The output from running a covered work is covered by this License only if the output, given its content, constitutes a covered work. This License acknowledges your rights of fair use or other equivalent, as provided by copyright law. You may make, run and propagate covered works that you do not convey, without conditions so long as your license otherwise remains
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 33.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
assertFailsWith<SocketTimeoutException> { source.readByte() // If Content-Length was accurate, this would return -1 immediately. } source.close() } /** Confirm that an unacknowledged write times out. */ @Test fun writeTimeouts() { val server = MockWebServer() // Sockets on some platforms can have large buffers that mean writes do not block when
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0)