Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 120 for interrupted (0.19 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

                throw new CrawlerSystemException("Process terminated.", e);
            } finally {
                if (mt != null) {
                    mt.setFinished(true);
                    try {
                        mt.interrupt();
                    } catch (final Exception e) {}
                }
                if (currentProcess != null) {
                    try {
                        currentProcess.destroy();
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. ci/official/README.md

    #   destroys some temporary bazel data and causes longer builds.
    #
    #   You will need the NVIDIA Container Toolkit for GPU testing:
    #   https://github.com/NVIDIA/nvidia-container-toolkit
    #
    #   Note: if you interrupt a bazel command on docker (ctrl-c), you
    #   will need to run `docker exec tf pkill bazel` to quit bazel.
    #
    #   Note: new files created from the container are owned by "root".
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Feb 01 03:21:19 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

            // don't copy the mayInterruptIfRunning bit, for consistency with the server, to ensure that
            // interruptTask() is called if and only if the bit is true and because we cannot infer the
            // interrupt status from non AbstractFuture futures.
            state = other.state;
    
            notifyAndClearListeners();
            return;
          }
    
          /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 19:37:41 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

      override fun request(): Request = originalRequest
    
      /**
       * Immediately closes the socket connection if it's currently held. Use this to interrupt an
       * in-flight request from any thread. It's the caller's responsibility to close the request body
       * and response body streams; otherwise resources may be leaked.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

        Thread.sleep(100)
        val threads = arrayOfNulls<Thread>(Thread.activeCount() * 2)
        Thread.enumerate(threads)
        for (t in threads) {
          if (t != null && t.name == "OkHttp TaskRunner") {
            t.interrupt()
          }
        }
        Thread.sleep(100)
        assertThat(realTaskRunner.activeQueues()).isEmpty()
      }
    
      @Test fun connectionPreWarmingHttp1() {
        taskFaker.advanceUntil(System.nanoTime())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  6. src/main/java/jcifs/util/transport/Transport.java

            Thread t = this.thread;
            if ( t != null && Thread.currentThread() != t ) {
                this.thread = null;
                try {
                    log.debug("Interrupting transport thread");
                    t.interrupt();
                    log.debug("Joining transport thread");
                    t.join(timeout);
                    log.debug("Joined transport thread");
                }
                catch ( InterruptedException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

                executor.awaitTermination(executorTerminationTimeout, TimeUnit.SECONDS);
            } catch (final InterruptedException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to interrupt executor.", e);
                }
            } finally {
                executor.shutdownNow();
            }
    
            if (!deleteUrlList.isEmpty()) {
                deleteDocuments();
            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  8. cni/test/install_cni.go

    	// the CNI binary installed.
    	if err := installer.Run(ctx); err != nil {
    		if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
    			// Error was caused by interrupt/termination signal
    			t.Logf("installer complete: %v", err)
    		} else {
    			t.Errorf("installer failed: %v", err)
    		}
    	}
    
    	if cleanErr := installer.Cleanup(); cleanErr != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

        this.futures = checkNotNull(futures);
        this.allMustSucceed = allMustSucceed;
        this.collectsValues = collectsValues;
      }
    
      @Override
      @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller.
      protected final void afterDone() {
        super.afterDone();
    
        @RetainedLocalRef ImmutableCollection<? extends Future<?>> localFutures = futures;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  10. docs/en/docs/deployment/concepts.md

    Now that we know the difference between the terms **process** and **program**, let's continue talking about deployments.
    
    ## Running on Startup
    
    In most cases, when you create a web API, you want it to be **always running**, uninterrupted, so that your clients can always access it. This is of course, unless you have a specific reason why you want it to run only in certain situations, but most of the time you want it constantly running and **available**.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Sep 18 16:09:57 UTC 2024
    - 17.8K bytes
    - Viewed (0)
Back to top