- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 515 for down (0.02 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
val call: RealCall get() = this@RealCall /** * Attempt to enqueue this async call on [executorService]. This will attempt to clean up * if the executor has been shut down by reporting the call as failed. */ fun executeOn(executorService: ExecutorService) { client.dispatcher.assertLockNotHeld() var success = false try {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 17.8K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/lease/LeaseManager.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 18.8K bytes - Viewed (0) -
cmd/iam-etcd-store.go
} func (ies *IAMEtcdStore) watch(ctx context.Context, keyPath string) <-chan iamWatchEvent { ch := make(chan iamWatchEvent) // go routine to read events from the etcd watch channel and send them // down `ch` go func() { for { outerLoop: watchCh := ies.client.Watch(ctx, keyPath, etcd.WithPrefix(), etcd.WithKeysOnly()) for { select { case <-ctx.Done(): return
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
* Fix: Don't crash when an HTTP/2 call is redirected while the connection is being shut down. * Fix: Don't drop headers of healthy streams that raced with `GOAWAY` frames. This bug would cause HTTP/2 streams to occasional hang when the connection was shutting down. * Fix: Honor `OkHttpClient.retryOnConnectionFailure()` when the response is a
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
/** * Establish the transport connection * * @throws Exception if the connection fails */ protected abstract void doConnect() throws Exception; /* * Tear down a connection. If the hard parameter is true, the diconnection * procedure should not initiate or wait for any outstanding requests on * this transport. */ /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 27.8K bytes - Viewed (0) -
cmd/batch-expire.go
if lastDel.ExpireAll { toDel[lastDelIndex].DeleteMarkerCount = deleteMarkerCountMap[lastDel.Name] // delete the key delete(deleteMarkerCountMap, lastDel.Name) } } // send down filtered entries to be deleted using // DeleteObjects method if len(toDel) > 10 { // batch up to 10 objects/versions to be expired simultaneously. xfer := make([]expireObjInfo, len(toDel)) copy(xfer, toDel)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Apr 22 11:16:32 UTC 2025 - 23K bytes - Viewed (0) -
src/bytes/buffer.go
return i } if b.buf == nil && n <= smallBufferSize { b.buf = make([]byte, n, smallBufferSize) return 0 } c := cap(b.buf) if n <= c/2-m { // We can slide things down instead of allocating a new // slice. We only need m+n <= c to slide, but // we instead let capacity get twice as large so we // don't spend all our time copying. copy(b.buf, b.buf[b.off:])
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon May 19 17:38:56 UTC 2025 - 16K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
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, "") } @Test
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 35.5K bytes - Viewed (0) -
docs/smb3-features/05-rdma-smb-direct-design.md
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 35.9K bytes - Viewed (0) -
cmd/bucket-replication.go
for _, tgtArn := range tgtArns { tgt := globalBucketTargetSys.GetRemoteTargetClient(bucket, tgtArn) // the target online status should not be used here while deciding // whether to replicate as the target could be temporarily down opts.TargetArn = tgtArn replicate := cfg.Replicate(opts) var synchronous bool if tgt != nil { synchronous = tgt.replicateSync } dsc.Set(newReplicateTargetDecision(tgtArn, replicate, synchronous))
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0)