Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 218 for ShutDown (0.19 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        protected void doStart() {
          notifyStarted();
        }
    
        @Override
        protected void doStop() {
          notifyStopped();
        }
      }
    
      /*
       * A NoOp service that will delay the startup and shutdown notification for a configurable amount
       * of time.
       */
      private static class NoOpDelayedService extends NoOpService {
        private long delay;
    
        public NoOpDelayedService(long delay) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

          barrier.await(1, SECONDS);
          executor.execute(barrierTask);
          // timeout means the second task wasn't even tried
          barrier.await(1, SECONDS);
        } finally {
          service.shutdown();
        }
      }
    
      public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);
        final SettableFuture<?> future = SettableFuture.create();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. cmd/server-main.go

    		Usage:  "bind to a specific ADDRESS:PORT for embedded Console UI, ADDRESS can be an IP or hostname",
    		EnvVar: "MINIO_CONSOLE_ADDRESS",
    	},
    	cli.DurationFlag{
    		Name:   "shutdown-timeout",
    		Value:  time.Second * 30,
    		Usage:  "shutdown timeout to gracefully shutdown server (DEPRECATED)",
    		EnvVar: "MINIO_SHUTDOWN_TIMEOUT",
    		Hidden: true,
    	},
    
    	cli.DurationFlag{
    		Name:   "idle-timeout",
    		Value:  xhttp.DefaultIdleTimeout,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  4. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

          barrier.await(1, SECONDS);
          executor.execute(barrierTask);
          // timeout means the second task wasn't even tried
          barrier.await(1, SECONDS);
        } finally {
          service.shutdown();
        }
      }
    
      public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);
        final SettableFuture<?> future = SettableFuture.create();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Service.java

      /** Returns the lifecycle state of the service. */
      State state();
    
      /**
       * If the service is {@linkplain State#STARTING starting} or {@linkplain State#RUNNING running},
       * this initiates service shutdown and returns immediately. If the service is {@linkplain
       * State#NEW new}, it is {@linkplain State#TERMINATED terminated} without having been started nor
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  6. ci/official/containers/linux_arm64/devel.usertools/code_check_full.bats

    }
    
    
    teardown_file() {
        bazel shutdown
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Aug 14 18:47:44 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  7. cmd/erasure-sets.go

    	}
    
    	return storageInfo
    }
    
    // Shutdown shutsdown all erasure coded sets in parallel
    // returns error upon first error.
    func (s *erasureSets) Shutdown(ctx context.Context) error {
    	g := errgroup.WithNErrs(len(s.sets))
    
    	for index := range s.sets {
    		index := index
    		g.Go(func() error {
    			return s.sets[index].Shutdown(ctx)
    		}, index)
    	}
    
    	for _, err := range g.Wait() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt

          object : okhttp3.mockwebserver.Dispatcher() {
            override fun dispatch(request: RecordedRequest): MockResponse = TODO()
    
            override fun peek(): MockResponse = TODO()
    
            override fun shutdown() = TODO()
          }
      }
    
      @Test
      fun dns() {
        var dns: Dns = Dns { TODO() }
    
        val system: Dns = Dns.SYSTEM
      }
    
      @Test
      fun eventListener() {
        val eventListener =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 46.5K bytes
    - Viewed (0)
  9. cmd/test-utils_test.go

    }
    
    // Deleting the temporary backend and stopping the server.
    func (testServer TestServer) Stop() {
    	testServer.cancel()
    	testServer.Server.Close()
    	testServer.Obj.Shutdown(context.Background())
    	os.RemoveAll(testServer.Root)
    	for _, ep := range testServer.Disks {
    		for _, disk := range ep.Endpoints {
    			os.RemoveAll(disk.Path)
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

     *       MoreExecutors.directExecutor());
     *
     *     Runtime.getRuntime().addShutdownHook(new Thread() {
     *       public void run() {
     *         // Give the services 5 seconds to stop to ensure that we are responsive to shutdown
     *         // requests.
     *         try {
     *           manager.stopAsync().awaitStopped(5, TimeUnit.SECONDS);
     *         } catch (TimeoutException timeout) {
     *           // stopping timed out
     *         }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
Back to top