- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for respAdd (0.16 sec)
-
pkg/xds/server.go
// Envoy can send two DiscoveryRequests with same version and nonce. // when it detects a new resource. We should respond if they change. prev := sets.New(previousResources...) cur := sets.New(request.ResourceNames...) removed := prev.Difference(cur) added := cur.Difference(prev) // We should always respond "alwaysRespond" marked requests to let Envoy finish warming // even though Nonce match and it looks like an ACK.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
// with EDS and SDS. // This can happen with the following sequence // 1. Envoy disconnects and reconnects to Istiod. // 2. Envoy sends EDS request and we respond with it. // 3. Envoy sends CDS request and we respond with clusters. // 4. Envoy detects a change in cluster state and tries to warm those clusters but never sends // an EDS request for them.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
} private var serverSocket: ServerSocket? = null private var sslSocketFactory: SSLSocketFactory? = null private var clientAuth = CLIENT_AUTH_NONE /** * The dispatcher used to respond to HTTP requests. The default dispatcher is a [QueueDispatcher], * which serves a fixed sequence of responses from a [queue][enqueue]. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 37.4K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
EXPECT_EQ(cache.CacheSize(), 0); } TEST(RamFileBlockCacheTest, ParallelReads) { // This fetcher won't respond until either `callers` threads are calling it // concurrently (at which point it will respond with success to all callers), // or 10 seconds have elapsed (at which point it will respond with an error). const int callers = 4; BlockingCounter counter(callers);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Oct 15 03:16:57 UTC 2021 - 23.2K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NbtAddress.java
public static final String MASTER_BROWSER_NAME = "\u0001\u0002__MSBROWSE__\u0002"; /** * A special generic name specified when connecting to a host for which * a name is not known. Not all servers respond to this name. */ public static final String SMBSERVER_NAME = "*SMBSERVER "; /** * A B node only broadcasts name queries. This is the default if a
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 15.2K bytes - Viewed (0) -
pilot/pkg/model/context.go
// force the response. It is important to respond to those requests for Envoy to finish // warming of those resources(Clusters). // This can happen with the following sequence // 1. Envoy disconnects and reconnects to Istiod. // 2. Envoy sends EDS request and we respond with it. // 3. Envoy sends CDS request and we respond with clusters.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
src/net/dnsclient_unix.go
tcpReq[0] = byte(l >> 8) tcpReq[1] = byte(l) return id, udpReq, tcpReq, nil } func checkResponse(reqID uint16, reqQues dnsmessage.Question, respHdr dnsmessage.Header, respQues dnsmessage.Question) bool { if !respHdr.Response { return false } if reqID != respHdr.ID { return false } if reqQues.Type != respQues.Type || reqQues.Class != respQues.Class || !equalASCIIName(reqQues.Name, respQues.Name) { return false
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 24.5K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/authoring-builds/tasks/controlling_task_execution.adoc
The task will be marked as `FAILED`. <<sec:finalizer_tasks,Finalizer tasks>> are executed. If `--continue` is used, other tasks continue running. Tasks that don't respond to interrupts can't be timed out. All of Gradle's built-in tasks respond to timeouts. ==== include::sample[dir="snippets/tasks/timeout/kotlin",files="build.gradle.kts[tags=without-import]"]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Mar 23 22:37:03 UTC 2024 - 14.2K bytes - Viewed (0) -
pkg/registry/apps/deployment/storage/storage.go
} // ProducesMIMETypes returns a list of the MIME types the specified HTTP verb (GET, POST, DELETE, // PATCH) can respond with. func (r *RollbackREST) ProducesMIMETypes(verb string) []string { return nil } // ProducesObject returns an object the specified HTTP verb respond with. It will overwrite storage object if // it is not nil. Only the type of the return object matters, the value will be ignored.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 16.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} @Throws(IOException::class) override fun onReadMessage(bytes: ByteString) { listener.onMessage(this, bytes) } @Synchronized override fun onReadPing(payload: ByteString) { // Don't respond to pings after we've failed or sent the close frame. if (failed || enqueuedClose && messageAndCloseQueue.isEmpty()) return pongQueue.add(payload) runWriter() receivedPingCount++ }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (1)