Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for retryInterval (0.06 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java

         */
        public long getRetryInterval() {
            return retryInterval;
        }
    
        /**
         * Sets the retry interval.
         * @param retryInterval The retry interval in milliseconds.
         */
        public void setRetryInterval(final long retryInterval) {
            this.retryInterval = retryInterval;
        }
    
        /**
         * Returns the request listener.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  2. cmd/dynamic-timeouts.go

    	mutex         sync.Mutex
    	retryInterval time.Duration
    }
    
    type dynamicTimeoutOpts struct {
    	timeout       time.Duration
    	minimum       time.Duration
    	retryInterval time.Duration
    }
    
    func newDynamicTimeoutWithOpts(opts dynamicTimeoutOpts) *dynamicTimeout {
    	dt := newDynamicTimeout(opts.timeout, opts.minimum)
    	dt.retryInterval = opts.retryInterval
    	return dt
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  3. cmd/namespace-lock.go

    	start := UTCNow()
    
    	newCtx, cancel := context.WithCancel(ctx)
    	if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{
    		Timeout:       timeout.Timeout(),
    		RetryInterval: timeout.RetryInterval(),
    	}) {
    		timeout.LogFailure()
    		defer cancel()
    		if err := newCtx.Err(); err == context.Canceled {
    			return LockContext{ctx: ctx, cancel: func() {}}, err
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

            this.sizeForDelete = sizeForDelete;
        }
    
        /**
         * Sets the retry interval in milliseconds.
         *
         * @param retryInterval The retry interval.
         */
        public void setRetryInterval(final long retryInterval) {
            this.retryInterval = retryInterval;
        }
    
        /**
         * Sets the maximum retry count.
         *
         * @param maxRetryCount The maximum retry count.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  5. cmd/shared-lock.go

    package cmd
    
    import (
    	"context"
    	"time"
    )
    
    var sharedLockTimeout = newDynamicTimeoutWithOpts(dynamicTimeoutOpts{
    	timeout:       30 * time.Second,
    	minimum:       10 * time.Second,
    	retryInterval: time.Minute,
    })
    
    type sharedLock struct {
    	lockContext chan LockContext
    }
    
    func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) {
    	for {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  6. fess-crawler-lasta/src/main/resources/crawler/client.xml

    		class="org.codelibs.fess.crawler.client.FaultTolerantClient" instance="prototype">
    		<property name="crawlerClient">internalHttpClient</property>
    		<property name="maxRetryCount">5</property>
    		<property name="retryInterval">500</property>
    	</component>
    
    	<component name="fsClient"
    		class="org.codelibs.fess.crawler.client.fs.FileSystemClient" instance="prototype">
    		<property name="charset">"UTF-8"</property>
    	</component>
    
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Tue Aug 08 12:54:47 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  7. cmd/iam.go

    			}
    		}
    
    		if !openidInit || !ldapInit || !authNInit || !authZInit {
    			retryInterval := time.Duration(r.Float64() * float64(3*time.Second))
    			if !openidInit {
    				logger.Info("Waiting for OpenID to be initialized.. (retrying in %s)", retryInterval)
    			}
    			if !ldapInit {
    				logger.Info("Waiting for LDAP to be initialized.. (retrying in %s)", retryInterval)
    			}
    			if !authNInit {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
Back to top