Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 61 for Timer (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. src/main/java/org/codelibs/fess/app/job/ScriptExecutorJob.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.job;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.es.config.exentity.JobLog;
    import org.codelibs.fess.es.config.exentity.ScheduledJob;
    import org.codelibs.fess.exception.ScheduledJobException;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/job/PythonJob.java

    import java.util.Map;
    
    import org.apache.commons.lang3.RandomStringUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.exception.JobProcessingException;
    import org.codelibs.fess.helper.ProcessHelper;
    import org.codelibs.fess.mylasta.direction.FessConfig;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    		// time.
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		randSleepFor := func() time.Duration {
    			return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64())
    		}
    
    		timer := time.NewTimer(randSleepFor())
    		defer timer.Stop()
    
    		var (
    			quit     bool
    			traceMsg string
    		)
    
    		for {
    			select {
    			case rebalErr := <-doneCh:
    				quit = true
    				now := time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  8. cmd/callhome.go

    			return false
    		case <-callhomeTimer.C:
    			if !globalCallhomeConfig.Enabled() {
    				// Stop the processing as callhome got disabled
    				return false
    			}
    
    			performCallhome(ctx)
    
    			// Reset the timer for next cycle.
    			callhomeTimer.Reset(globalCallhomeConfig.FrequencyDur())
    		}
    	}
    }
    
    func performCallhome(ctx context.Context) {
    	deadline := 10 * time.Second // Default deadline is 10secs for callhome
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.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.io.ByteArrayOutputStream;
    import java.io.OutputStream;
    import java.util.Arrays;
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.apache.commons.text.StringEscapeUtils;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/job/CrawlJob.java

    import org.apache.commons.lang3.SystemUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.Constants;
    import org.codelibs.fess.es.config.exbhv.ScheduledJobBhv;
    import org.codelibs.fess.exception.JobProcessingException;
    import org.codelibs.fess.exec.Crawler;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jun 23 04:13:47 UTC 2024
    - 15.1K bytes
    - Viewed (0)
Back to top