- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 636 for tent (0.14 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
internal set /** Received headers yet to be [taken][takeHeaders]. */ private val headersQueue = ArrayDeque<Headers>() /** True if response headers have been sent or received. */ private var hasResponseHeaders: Boolean = false internal val source = FramingSource( maxByteCount = connection.okHttpSettings.initialWindowSize.toLong(), finished = inFinished,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
internal/grid/benchmark_test.go
{name: "responses", fn: benchmarkGridStreamRespOnly}, {name: "twoway", fn: benchmarkGridStreamTwoway}, } for _, test := range tests { b.Run(test.name, func(b *testing.B) { for n := 2; n <= 32; n *= 2 { b.Run("servers="+strconv.Itoa(n), func(b *testing.B) { test.fn(b, n) }) } }) } } func benchmarkGridStreamRespOnly(b *testing.B, n int) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
src/encoding/json/encode_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 29.4K bytes - Viewed (0) -
pkg/util/async/bounded_frequency_runner_test.go
// return the calling line number (for printing) // test the timer's state func checkTimer(name string, t *testing.T, upd timerUpdate, active bool, next time.Duration) { if upd.active != active { t.Fatalf("%s: expected timer active=%v", name, active) } if active && upd.next != next { t.Fatalf("%s: expected timer to be %v, got %v", name, next, upd.next) } } // test and reset the receiver's state
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 12.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/IndexingHelper.java
logger.info("Sent {} docs (Doc:{process {}ms, send {}ms, size {}}, {})", docList.size(), docList.getProcessingTime(), (systemHelper.getCurrentTimeAsLong() - execTime), MemoryUtil.byteCountToDisplaySize(docList.getContentSize()), MemoryUtil.getMemoryUsageLog()); } else {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15.6K bytes - Viewed (0) -
internal/event/target/amqp.go
return err } defer ch.Close() eventData, eErr := target.store.Get(key.Name) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData, ch, confirms); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
try { response = realChain.proceed(request) newRoutePlanner = true } catch (e: IOException) { // An attempt to communicate with a server failed. The request may have been sent. if (!recover(e, call, request, requestSendStarted = e !is ConnectionShutdownException)) { throw e.withSuppressed(recoveredFailures) } else { recoveredFailures += e }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cookie.kt
* * The values of this attribute determine whether this cookie is sent for cross-site calls: * * - "Strict": the cookie is omitted when the subject URL is an embedded resource or a * potentially-destructive navigation. * * - "Lax": the cookie is omitted when the subject URL is an embedded resource. It is sent for * potentially-destructive navigation. This is the default value. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 04:12:05 UTC 2024 - 23.1K bytes - Viewed (0) -
cluster/addons/fluentd-gcp/fluentd-gcp-configmap-old.yaml
# visible in the log viewer # Json Log Example: # {"log":"[info:2016-02-16T16:04:05.930-08:00] Some log text here\n","stream":"stdout","time":"2016-02-17T00:04:05.931087621Z"} # CRI Log Example: # 2016-02-17T00:04:05.931087621Z stdout F [info:2016-02-16T16:04:05.930-08:00] Some log text here <source> @type tail path /var/log/containers/*.log pos_file /var/log/gcp-containers.log.pos
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 26 07:09:07 UTC 2018 - 16.3K bytes - Viewed (0) -
tests/integration/security/pass_through_filter_chain_test.go
"net/http" "testing" "istio.io/istio/pkg/test/framework" "istio.io/istio/pkg/test/framework/components/echo" "istio.io/istio/pkg/test/framework/components/echo/check" "istio.io/istio/pkg/test/framework/components/echo/common/ports" "istio.io/istio/pkg/test/framework/components/echo/config" "istio.io/istio/pkg/test/framework/components/echo/config/param" "istio.io/istio/pkg/test/framework/components/echo/echotest"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.9K bytes - Viewed (0)