Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 597 for serving (0.06 sec)

  1. guava/src/com/google/common/util/concurrent/ServiceManager.java

      public ServiceManager startAsync() {
        for (Service service : services) {
          checkState(service.state() == NEW, "Not all services are NEW, cannot start %s", this);
        }
        for (Service service : services) {
          try {
            state.tryStartTiming(service);
            service.startAsync();
          } catch (IllegalStateException e) {
            // This can happen if the service has already been started or stopped (e.g. by another
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt

        set = set or bit
        values[id] = value
        return this
      }
    
      /** Returns true if a value has been assigned for the setting `id`. */
      fun isSet(id: Int): Boolean {
        val bit = 1 shl id
        return set and bit != 0
      }
    
      /** Returns the value for the setting `id`, or 0 if unset. */
      operator fun get(id: Int): Int = values[id]
    
      /** Returns the number of settings that have values assigned. */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ExecutorService service = mock(ExecutorService.class);
        application.addDelayedShutdownHook(service, 2, SECONDS);
        verify(service, Mockito.never()).shutdown();
        application.shutdown();
        InOrder shutdownFirst = Mockito.inOrder(service);
        shutdownFirst.verify(service).shutdown();
        shutdownFirst.verify(service).awaitTermination(2, SECONDS);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractService.java

    import static com.google.common.util.concurrent.Service.State.FAILED;
    import static com.google.common.util.concurrent.Service.State.NEW;
    import static com.google.common.util.concurrent.Service.State.RUNNING;
    import static com.google.common.util.concurrent.Service.State.STARTING;
    import static com.google.common.util.concurrent.Service.State.STOPPING;
    import static com.google.common.util.concurrent.Service.State.TERMINATED;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.8.md

    Action required:
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Feb 20 15:45:02 UTC 2024
    - 312.2K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http/DateFormatting.kt

            // Something was parsed. It's possible the entire string was not consumed but we ignore
            // that. If any of the BROWSER_COMPATIBLE_DATE_FORMAT_STRINGS ended in "'GMT'" we'd have
            // to also check that position.getIndex() == value.length() otherwise parsing might have
            // terminated early, ignoring things like "+01:00". Leaving this as != 0 means that any
            // trailing junk is ignored.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        assertEquals(0, service.runCalled);
        assertEquals(1, service.shutdownCalled);
      }
    
      public void testStop_noStart() {
        FakeService service = new FakeService();
        service.stopAsync().awaitTerminated();
        assertEquals(Service.State.TERMINATED, service.state());
        assertEquals(0, service.startupCalled);
        assertEquals(0, service.runCalled);
        assertEquals(0, service.shutdownCalled);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/DataServiceImpl.java

         * (non-Javadoc)
         *
         * @see org.codelibs.fess.crawler.service.DataService#getCount(java.lang.String)
         */
        @Override
        public int getCount(final String sessionId) {
            return dataHelper.getAccessResultMap(sessionId).size();
        }
    
        /*
         * (non-Javadoc)
         *
         * @see org.codelibs.fess.crawler.service.DataService#delete(java.lang.String)
         */
        @Override
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. istioctl/pkg/describe/describe_test.go

    		},
    		{ // case 8 unknown service
    			args:           strings.Split("service not-a-service", " "),
    			expectedString: "services \"not-a-service\" not found",
    			wantException:  true, // "istioctl experimental describe service not-a-service" should fail
    		},
    		{
    			k8sConfigs: []runtime.Object{
    				&corev1.Service{
    					ObjectMeta: metav1.ObjectMeta{
    						Name:      "productpage",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java

        protected MemoryDataHelper dataHelper;
    
        /*
         * (non-Javadoc)
         *
         * @see
         * org.codelibs.fess.crawler.service.UrlQueueService#updateSessionId(java.lang.String
         * , java.lang.String)
         */
        @Override
        public void updateSessionId(final String oldSessionId, final String newSessionId) {
            // not MT-safe
            final Queue<UrlQueueImpl<Long>> urlQueueList = dataHelper.getUrlQueueList(oldSessionId);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top