Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 74 for Timer (0.1 sec)

  1. src/main/java/org/codelibs/fess/app/job/AllJobScheduler.java

     */
    package org.codelibs.fess.app.job;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.app.logic.AccessContextLogic;
    import org.codelibs.fess.app.service.ScheduledJobService;
    import org.codelibs.fess.es.config.exbhv.JobLogBhv;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/timer/TimeoutTarget.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.core.timer;
    
    /**
     * タイムアウトを処理するインターフェースです。
     *
     * @author higa
     *
     */
    @FunctionalInterface
    public interface TimeoutTarget {
    
        /**
         * タイムアウトの処理を記述します。
         */
        void expired();
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 904 bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/ApiExtractor.java

    import org.codelibs.core.beans.BeanDesc;
    import org.codelibs.core.beans.PropertyDesc;
    import org.codelibs.core.beans.factory.BeanDescFactory;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.crawler.Constants;
    import org.codelibs.fess.crawler.client.AccessTimeoutTarget;
    import org.codelibs.fess.crawler.client.http.Authentication;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

    import java.util.concurrent.atomic.AtomicBoolean;
    
    import org.codelibs.core.io.CloseableUtil;
    import org.codelibs.core.io.InputStreamUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.crawler.Constants;
    import org.codelibs.fess.crawler.builder.RequestDataBuilder;
    import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.core.timer;
    
    import junit.framework.TestCase;
    
    /**
     * @author higa
     *
     */
    public class TimeoutManagerTest extends TestCase {
    
        private int expiredCount;
    
        protected void setUp() throws Exception {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  6. cmd/mrf.go

    				// let recently failed networks to reconnect
    				// making MRF wait for 1s before retrying,
    				// i.e 4 reconnect attempts.
    				time.Sleep(time.Second)
    			}
    
    			// wait on timer per heal
    			wait := healSleeper.Timer(context.Background())
    
    			scan := madmin.HealNormalScan
    			if u.BitrotScan {
    				scan = madmin.HealDeepScan
    			}
    
    			if u.Object == "" {
    				healBucket(u.Bucket, scan)
    			} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  7. internal/kms/config.go

    		// Keep the default key in the KES cache to prevent availability issues
    		// when MinIO restarts
    		go func() {
    			timer := time.NewTicker(10 * time.Second)
    			defer timer.Stop()
    			defaultKey := env.Get(EnvKESDefaultKey, "")
    			for {
    				select {
    				case <-ctx.Done():
    					return
    				case <-timer.C:
    					client.DescribeKey(ctx, defaultKey)
    				}
    			}
    		}()
    
    		return &KMS{
    			Type:       MinKES,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.timer;
    
    import java.util.stream.Collectors;
    
    import org.apache.commons.text.StringEscapeUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.Constants;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java

    import org.codelibs.core.io.CloseableUtil;
    import org.codelibs.core.io.FileUtil;
    import org.codelibs.core.io.InputStreamUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.crawler.Constants;
    import org.codelibs.fess.crawler.builder.RequestDataBuilder;
    import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu May 23 01:54:36 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  10. doc/godebug.md

    pre-Go 1.24 behavior.
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change.
    There are no runtime metrics for this change,
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
Back to top