Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 228 for ShutDown (0.06 sec)

  1. okhttp/src/test/java/okhttp3/CallKotlinTest.kt

        val proxySelector = RecordingProxySelector()
        proxySelector.proxies.add(Proxy(Proxy.Type.HTTP, TestUtil.UNREACHABLE_ADDRESS_IPV4))
        proxySelector.proxies.add(Proxy.NO_PROXY)
        server.shutdown()
    
        client =
          client.newBuilder()
            .proxySelector(proxySelector)
            .readTimeout(Duration.ofMillis(100))
            .connectTimeout(Duration.ofMillis(100))
            .build()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

         * that once the Thread returns to the Executor that this Executor composes, the interruption
         * will still be present. If the composed Executor is an ExecutorService, it can respond to
         * shutdown() by returning tasks queued on that Thread after {@link #worker} drains the queue.
         */
        @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
        private void workOnQueue() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

         * that once the Thread returns to the Executor that this Executor composes, the interruption
         * will still be present. If the composed Executor is an ExecutorService, it can respond to
         * shutdown() by returning tasks queued on that Thread after {@link #worker} drains the queue.
         */
        @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
        private void workOnQueue() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. CHANGELOG.md

        `LoggingEventListener.androidLogging()` write HTTP calls or events to Logcat.
    
     *  New: `OkHttpClient.webSocketCloseTimeout` configures how long a web socket connection will wait
        for a graceful shutdown before it performs an abrupt shutdown.
    
     *  Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`
    
     *  Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:31:39 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

            reader.nextFrame(false, inFrame)
            inFrames.add(inFrame)
          }
        }
      }
    
      fun openSocket(): Socket = Socket("localhost", port)
    
      @Synchronized override fun close() {
        executor.shutdown()
        socket?.closeQuietly()
        serverSocket?.closeQuietly()
      }
    
      override fun toString(): String = "MockHttp2Peer[$port]"
    
      private class OutFrame(
        val sequence: Int,
        val start: Long,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/core/timer/TimeoutManager.java

                if (logger.isDebugEnabled()) {
                    logger.debug("TimeoutManagerThread stopped.");
                }
                thread = null;
                try {
                    executorService.shutdown();
                    executorService.awaitTermination(60, TimeUnit.SECONDS);
                } catch (final InterruptedException e) {
                    if (logger.isDebugEnabled()) {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. src/test/java/jcifs/tests/WatchTest.java

            this.base = createTestDirectory();
        }
    
    
        @Override
        @After
        public void tearDown () throws Exception {
            if ( this.executor != null ) {
                this.executor.shutdown();
                if ( this.future != null ) {
                    this.future.cancel(true);
                }
                this.executor.awaitTermination(1, TimeUnit.SECONDS);
            }
            if ( this.base != null ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 8.4K bytes
    - Viewed (0)
  8. cmd/mrf.go

    		return
    	}
    
    	select {
    	case m.opCh <- op:
    	default:
    	}
    }
    
    // Do not accept new MRF operations anymore and start to save
    // the current heal status in one available disk
    func (m *mrfState) shutdown() {
    	atomic.StoreInt32(&m.closing, 1)
    	m.wg.Wait()
    	close(m.opCh)
    	atomic.StoreInt32(&m.closed, 1)
    
    	if len(m.opCh) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

                }
              }
              return result
            }
    
            override fun peek(): MockResponse = queueDispatcher.peek()
    
            override fun shutdown() {
              queueDispatcher.shutdown()
            }
          }
        client =
          client.newBuilder()
            .proxy(server.toProxyAddress())
            .build()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  10. cmd/logging.go

    	logger.LogOnceIf(ctx, "sftp", err, id, errKind...)
    }
    
    func shutdownLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "shutdown", err, errKind...)
    }
    
    func stsLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "sts", err, errKind...)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top