Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 515 for down (0.02 sec)

  1. 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)
  2. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

                fileCache.remove(path);
            }
        }
    
        /**
         * Shutdown the lease manager
         */
        public void shutdown() {
            log.info("Shutting down lease manager");
    
            // Stop cleanup executor
            if (cleanupExecutor != null) {
                cleanupExecutor.shutdown();
                try {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. docs/smb3-features/05-rdma-smb-direct-design.md

        @Override
        public void shutdown() {
            if (endpointGroup != null) {
                try {
                    endpointGroup.close();
                } catch (Exception e) {
                    log.error("Error shutting down DiSNI", e);
                }
            }
            initialized = false;
        }
    }
    
    class DisniRdmaConnection extends RdmaConnection {
        private final RdmaActiveEndpoint endpoint;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  10. 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)
Back to top