- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 166 for IMMEDIATE (0.12 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* is exhausted. * * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it. */ object DisconnectAtEnd : SocketPolicy /** * Request immediate close of connection without even reading the request. Use to simulate buggy * SSL servers closing connections in response to unrecognized TLS extensions. */ object DisconnectAtStart : SocketPolicy /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 4.6K bytes - Viewed (0) -
src/net/http/http.go
// maxInt64 is the effective "infinite" value for the Server and // Transport's byte-limiting readers. const maxInt64 = 1<<63 - 1 // aLongTimeAgo is a non-zero time, far in the past, used for // immediate cancellation of network operations. var aLongTimeAgo = time.Unix(1, 0) // omitBundledHTTP2 is set by omithttp2.go when the nethttpomithttp2 // build tag is set. That means h2_bundle.go isn't compiled in and we
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.1K bytes - Viewed (0) -
platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Codec.kt
val sharedIdentities: ReadIdentities override val isolate: ReadIsolate val classLoader: ClassLoader fun beanStateReaderFor(beanType: Class<*>): BeanStateReader /** * When in immediate mode, [read] calls are NOT suspending. * Useful for bridging with non-suspending serialization protocols such as [java.io.Serializable]. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 23:09:56 UTC 2024 - 7.9K bytes - Viewed (0) -
cmd/bitrot-streaming.go
// sequent of operations: // 1) pipe.Write() // 2) pipe.Close() // Now pipe.Close() can return before the data is read on the other end of the pipe and written to the disk // Hence an immediate Read() on the file can return incorrect data. if b.canClose != nil { b.canClose.Wait() } // Recycle the buffer. if b.byteBuf != nil { globalBytePoolCap.Load().Put(b.byteBuf) b.byteBuf = nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/util/filesystem/watcher.go
// errorHandler() is invoked (if non-nil) whenever an error occurs initializing or watching the specified path. // // If path is a directory, only the directory and immediate children are watched. // // If path does not exist or cannot be watched, an error is passed to errorHandler() and eventHandler() is called at pollInterval. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 23:09:15 UTC 2024 - 5.7K bytes - Viewed (0) -
src/time/tick_test.go
tim.Reset(1) assertTick() Sleep(sched) tim.Reset(10000 * Second) drainAsync() noTick() // Test that len sees an immediate tick arrive // for Reset of timer in heap. tim.Reset(1) assertLen() assertTick() // Test that len sees an immediate tick arrive // for Reset of timer NOT in heap. tim.Stop() drainAsync() tim.Reset(1) assertLen() assertTick() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
src/net/http/cgi/integration_test.go
t.Errorf("got a Content-Type of %q; expected it to start with %q", got, tt.wantCT) } }) } } // golang.org/issue/7198 func Test500WithNoHeaders(t *testing.T) { want500Test(t, "/immediate-disconnect") } func Test500WithNoContentType(t *testing.T) { want500Test(t, "/no-content-type") } func Test500WithEmptyHeaders(t *testing.T) { want500Test(t, "/empty-headers") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 07 18:42:44 UTC 2023 - 5.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* be transmitted until the web socket is open. * * * **Open:** the web socket has been accepted by the remote peer and is fully operational. * Messages in either direction are enqueued for immediate transmission. * * * **Closing:** one of the peers on the web socket has initiated a graceful shutdown. The web * socket will continue to transmit already-enqueued messages but will refuse to enqueue new * ones. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.3K bytes - Viewed (0) -
cmd/erasure-multipart.go
_ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath, DeleteOptions{ Recursive: false, Immediate: false, }) _ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath+".meta", DeleteOptions{ Recursive: false, Immediate: false, }) return nil }, index) } g.Wait() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go
var healthCheckError error if kmsPluginCloseGracePeriod < minKMSPluginCloseGracePeriod { kmsPluginCloseGracePeriod = minKMSPluginCloseGracePeriod } // really make sure that the immediate check does not hang var cancel context.CancelFunc ctx, cancel = context.WithTimeout(ctx, kmsPluginCloseGracePeriod) defer cancel()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0)