Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for startResync (0.06 sec)

  1. cmd/admin-handlers-site-replication.go

    	op := madmin.SiteResyncOp(vars["operation"])
    	var (
    		status madmin.SRResyncOpStatus
    		err    error
    	)
    	switch op {
    	case madmin.SiteResyncStart:
    		status, err = globalSiteReplicationSys.startResync(ctx, objectAPI, peerSite)
    	case madmin.SiteResyncCancel:
    		status, err = globalSiteReplicationSys.cancelResync(ctx, objectAPI, peerSite)
    	default:
    		err = errSRInvalidRequest(errInvalidArgument)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  2. cmd/site-replication.go

    		}
    	}
    	return pi, true
    }
    
    // startResync initiates resync of data to peerSite specified. The overall site resync status
    // is maintained in .minio.sys/buckets/site-replication/resync/<deployment-id.meta>, while collecting
    // individual bucket resync status in .minio.sys/buckets/<bucket-name>/replication/resync.bin
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

            thrownByExecutionThread);
      }
    
      public void testServiceStartStop() throws Exception {
        WaitOnRunService service = new WaitOnRunService();
        assertFalse(service.startUpCalled);
    
        service.startAsync().awaitRunning();
        assertTrue(service.startUpCalled);
        assertEquals(Service.State.RUNNING, service.state());
    
        enterRun.await(); // to avoid stopping the service until run() is invoked
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

              public final void addListener(Listener listener, Executor executor) {
                service1.startAsync();
                delegate.addListener(listener, executor);
              }
    
              // Delegates from here on down
              @Override
              public final Service startAsync() {
                return delegate.startAsync();
              }
    
              @Override
              public final Service stopAsync() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 20:34:52 UTC 2025
    - 25.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      public final Throwable failureCause() {
        return delegate.failureCause();
      }
    
      /**
       * @since 15.0
       */
      @CanIgnoreReturnValue
      @Override
      public final Service startAsync() {
        delegate.startAsync();
        return this;
      }
    
      /**
       * @since 15.0
       */
      @CanIgnoreReturnValue
      @Override
      public final Service stopAsync() {
        delegate.stopAsync();
        return this;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

      public final Throwable failureCause() {
        return delegate.failureCause();
      }
    
      /**
       * @since 15.0
       */
      @CanIgnoreReturnValue
      @Override
      public final Service startAsync() {
        delegate.startAsync();
        return this;
      }
    
      /**
       * @since 15.0
       */
      @CanIgnoreReturnValue
      @Override
      public final Service stopAsync() {
        delegate.stopAsync();
        return this;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/api/WebApiRequestTest.java

            public ServletContext getServletContext() {
                return null;
            }
    
            @Override
            public AsyncContext startAsync() throws IllegalStateException {
                return null;
            }
    
            @Override
            public AsyncContext startAsync(ServletRequest servletRequest, ServletResponse servletResponse) throws IllegalStateException {
                return null;
            }
    
            @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/api/WebApiManagerTest.java

                return null;
            }
    
            @Override
            public jakarta.servlet.AsyncContext startAsync() {
                return null;
            }
    
            @Override
            public jakarta.servlet.AsyncContext startAsync(jakarta.servlet.ServletRequest req, jakarta.servlet.ServletResponse res) {
                return null;
            }
    
            @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/fess/filter/CorsFilterTest.java

                return null;
            }
    
            @Override
            public jakarta.servlet.AsyncContext startAsync() {
                return null;
            }
    
            @Override
            public jakarta.servlet.AsyncContext startAsync(jakarta.servlet.ServletRequest req, jakarta.servlet.ServletResponse res) {
                return null;
            }
    
            @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/cors/CorsHandlerTest.java

                    return null;
                }
    
                @Override
                public jakarta.servlet.AsyncContext startAsync() {
                    return null;
                }
    
                @Override
                public jakarta.servlet.AsyncContext startAsync(ServletRequest servletRequest, ServletResponse servletResponse) {
                    return null;
                }
    
                @Override
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 25.9K bytes
    - Viewed (0)
Back to top