- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 164 for flight (0.19 sec)
-
src/main/java/org/codelibs/fess/entity/PingResponse.java
private static final String NUMBER_OF_DATA_NODES = "number_of_data_nodes"; private static final String NUMBER_OF_PENDING_TASKS = "number_of_pending_tasks"; private static final String NUMBER_OF_IN_FLIGHT_FETCH = "number_of_in_flight_fetch"; private static final String DELAYED_UNASSIGNED_SHARDS = "delayed_unassigned_shards"; private static final String TASK_MAX_WAIT_TIME_IN_QUEUE_IN_MILLIS = "task_max_waiting_in_queue_millis";
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
* The maximum number of requests to execute concurrently. Above this requests queue in memory, * waiting for the running calls to complete. * * If more than [maxRequests] requests are in flight when this is invoked, those requests will * remain in flight. */ var maxRequests = 64 get() = this.withLock { field } set(maxRequests) { require(maxRequests >= 1) { "max < 1: $maxRequests" } this.withLock {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
tensorflow/c/eager/tfe_executor_internal.h
struct TFE_Executor { explicit TFE_Executor(bool async, bool enable_streaming_enqueue, int in_flight_nodes_limit) : owned_executor(new tensorflow::EagerExecutor( async, enable_streaming_enqueue, in_flight_nodes_limit)) {} explicit TFE_Executor(tensorflow::EagerExecutor* executor) : owned_executor(nullptr), unowned_executor(executor) {}
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Tue Nov 22 20:30:59 GMT 2022 - 1.5K bytes - Viewed (0) -
tests/test_tutorial/test_cors/test_tutorial001.py
from fastapi.testclient import TestClient from docs_src.cors.tutorial001 import app def test_cors(): client = TestClient(app) # Test pre-flight response headers = { "Origin": "https://localhost.tiangolo.com", "Access-Control-Request-Method": "GET", "Access-Control-Request-Headers": "X-Example", } response = client.options("/", headers=headers) assert response.status_code == 200, response.text
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Jul 09 18:06:12 GMT 2020 - 1.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
connectResult = launchTcpConnect() nextTcpConnectAtNanos = now + connectDelayNanos awaitTimeoutNanos = connectDelayNanos } // Wait for an in-flight connect to complete or fail. if (connectResult == null) { connectResult = awaitTcpConnect(awaitTimeoutNanos, TimeUnit.NANOSECONDS) ?: continue } if (connectResult.isSuccess) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/metrics-v3-api.go
apiRequestsIncomingTotalMD = NewGaugeMD(apiRequestsIncomingTotal, "Total number of incoming requests", "type") apiRequestsInFlightTotalMD = NewGaugeMD(apiRequestsInFlightTotal, "Total number of requests currently in flight", "name", "type") apiRequestsTotalMD = NewCounterMD(apiRequestsTotal, "Total number of requests", "name", "type") apiRequestsErrorsTotalMD = NewCounterMD(apiRequestsErrorsTotal,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 9.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* lookups) and attempt a new connection them. When failures occur, retries iterate the list of * available routes. * * If the pool gains an eligible connection while DNS, TCP, or TLS work is in flight, this finder * will prefer pooled connections. Only pooled HTTP/2 connections are used for such de-duplication. * * It is possible to cancel the finding process by canceling its call. *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java
import okhttp3.Handshake; import okhttp3.HttpUrl; import okhttp3.OkHttpClient; import okhttp3.Protocol; import okhttp3.Request; import okhttp3.Response; /** * This prints events for a single in-flight call. It won't work for multiple concurrent calls * because we don't know what callStartNanos refers to. */ public final class PrintEventsNonConcurrent { private final OkHttpClient client = new OkHttpClient.Builder()
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Feb 16 23:20:49 GMT 2020 - 5.3K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
mlock sync.RWMutex // mutex for bucket measurement bucketsThrottle map[BucketOptions]*bucketThrottle bucketsMeasurement map[BucketOptions]*bucketMeasurement // Buckets with objects in flight bucketMovingAvgTicker *time.Ticker // Ticker for calculating moving averages ctx context.Context // Context for generate NodeCount uint64 }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 6K bytes - Viewed (0) -
docs/en/layouts/custom.yml
height: 1.25 font: family: *font_family style: Bold # Page description - size: { width: 832, height: 64 } offset: { x: 64, y: 512 } typography: content: *page_description align: start color: *color line: amount: 2 height: 1.5 font: family: *font_family
Others - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Mon Jun 26 14:05:43 GMT 2023 - 6.5K bytes - Viewed (0)