Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 409 for slop (0.02 sec)

  1. src/main/java/org/codelibs/fess/ds/DataStore.java

    import org.codelibs.fess.es.config.exentity.DataConfig;
    
    public interface DataStore {
    
        void store(DataConfig config, IndexUpdateCallback callback, DataStoreParams initParamMap);
    
        void stop();
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 962 bytes
    - Viewed (0)
  2. src/main/assemblies/files/service.bat

    if /i %SERVICE_CMD% == remove goto doRemove
    if /i %SERVICE_CMD% == start goto doStart
    if /i %SERVICE_CMD% == stop goto doStop
    if /i %SERVICE_CMD% == manager goto doManagment
    echo Unknown option "%SERVICE_CMD%"
    
    :displayUsage
    echo.
    echo Usage: service.bat install^|remove^|start^|stop^|manager [SERVICE_ID]
    goto:eof
    
    :doStart
    "%EXECUTABLE%" //ES//%SERVICE_ID% %LOG_OPTS%
    if not errorlevel 1 goto started
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 6K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt

    import org.junit.jupiter.api.extension.RegisterExtension
    import org.junit.jupiter.params.ParameterizedTest
    import org.junit.jupiter.params.provider.ValueSource
    
    @Flaky // STDOUT logging enabled for test
    @Timeout(30)
    @Tag("Slow")
    open class ConnectionListenerTest {
      @RegisterExtension
      val platform = PlatformRule()
    
      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
      private var server: MockWebServer? = null
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  4. internal/event/target/nsq.go

    }
    
    // Close - closes underneath connections to NSQD server.
    func (target *NSQTarget) Close() (err error) {
    	close(target.quitCh)
    	if target.producer != nil {
    		// this blocks until complete:
    		target.producer.Stop()
    	}
    	return nil
    }
    
    func (target *NSQTarget) init() error {
    	return target.initOnce.Do(target.initNSQ)
    }
    
    func (target *NSQTarget) initNSQ() error {
    	args := target.args
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  5. src/main/webapp/js/admin/jquery-3.7.1.min.js

    on(){var e=yt(this,ce.extend({},t),o);(i||_.get(this,"finish"))&&e.stop(!0)};return a.finish=a,i||!1===o.queue?this.each(a):this.queue(o.queue,a)},stop:function(i,e,o){var a=function(e){var t=e.stop;delete e.stop,t(o)};return"string"!=typeof i&&(o=e,e=i,i=void 0),e&&this.queue(i||"fx",[]),this.each(function(){var e=!0,t=null!=i&&i+"queueHooks",n=ce.timers,r=_.get(this);if(t)r[t]&&r[t].stop&&a(r[t]);else for(t in r)r[t]&&r[t].stop&&pt.test(t)&&a(r[t]);for(t=n.length;t--;)n[t].elem!==this||null!=i...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 85.5K bytes
    - Viewed (0)
  6. cmd/metacache.go

    	// we intentionally operate on a copy of m, so we can update without locks.
    	t := time.NewTicker(metacacheMaxClientWait / 10)
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Request is done, stop updating.
    			return
    		case <-t.C:
    			m.lastHandout = time.Now()
    
    			if m2, err := rpc.UpdateMetacacheListing(ctx, m); err == nil {
    				if m2.status != scanStateStarted {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. internal/config/scanner/help.go

    		return config.DefaultHelpPostfix(DefaultKVS, key)
    	}
    
    	// Help provides help for config values
    	Help = config.HelpKVS{
    		config.HelpKV{
    			Key:         Speed,
    			Description: `customize scanner speed (default|slowest|slow|fast|fastest)` + defaultHelpPostfix(Speed),
    			Optional:    true,
    			Type:        "string",
    		},
    		config.HelpKV{
    			Key:         ExcessVersions,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 12 07:41:53 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  8. samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt

     */
    class JettyHttpClientTest {
      private val client = HttpClient()
    
      @BeforeEach fun setUp() {
        client.start()
      }
    
      @AfterEach fun tearDown() {
        client.stop()
      }
    
      @Test fun get(server: MockWebServer) {
        server.enqueue(MockResponse(body = "hello, Jetty HTTP Client"))
    
        val request =
          client.newRequest(server.url("/").toUri())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/es/config/exentity/ScheduledJob.java

                job.launchNow();
            }).orElse(() -> {
                throw new JobNotFoundException(this);
            });
        }
    
        public void stop() {
            ComponentUtil.getJobManager().findJobByUniqueOf(LaJobUnique.of(getId())).ifPresent(job -> {
                job.stopNow();
            }).orElse(() -> {
                throw new JobNotFoundException(this);
            });
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       */
      static final class SmoothWarmingUp extends SmoothRateLimiter {
        private final long warmupPeriodMicros;
        /**
         * The slope of the line from the stable interval (when permits == 0), to the cold interval
         * (when permits == maxPermits)
         */
        private double slope;
    
        private double thresholdPermits;
        private double coldFactor;
    
        SmoothWarmingUp(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
Back to top