- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 495 for DELAY (0.05 sec)
-
src/runtime/netpoll_wasip1.go
func netpollBreak() {} func netpoll(delay int64) (gList, int32) { lock(&mtx) // If delay >= 0, we include a subscription of type Clock that we use as // a timeout. If delay < 0, we omit the subscription and allow poll_oneoff // to block indefinitely. pollsubs := subs if delay >= 0 { timeout := &subs[0] clock := timeout.u.subscriptionClock() clock.timeout = uint64(delay) } else { pollsubs = subs[1:]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 6.1K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/fixture/GradleBuildExperimentRunner.java
private final long delay; private final TimeUnit unit; public DelayBeforeBuildMutator(long delay, TimeUnit unit) { this.unit = unit; this.delay = delay; } @Override public void beforeBuild(BuildContext context) { try { unit.sleep(delay); } catch (InterruptedException e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/config/monitor/monitor_test.go
callCount int configs []*config.Config err error ) delay := make(chan struct{}, 1) someConfigFunc := func() ([]*config.Config, error) { switch callCount { case 0: configs = createConfigSet err = nil case 3: configs = nil err = errors.New("snapshotFunc can't connect") delay <- struct{}{} } callCount++ return configs, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 4.8K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/ConfigureTimeouts.java
.callTimeout(10, TimeUnit.SECONDS) .build(); } public void run() throws Exception { Request request = new Request.Builder() .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay. .build(); try (Response response = client.newCall(request).execute()) { System.out.println("Response completed: " + response); } }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Sep 28 18:00:26 UTC 2019 - 1.5K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/grpcecho_test.go
targetPort: grpc port: 7071 `, ConfigString: ` apiVersion: networking.istio.io/v1alpha3 kind: VirtualService metadata: name: echo-delay spec: hosts: - echo-app.default.svc.cluster.local http: - fault: delay: percent: 100 fixedDelay: 100ms route: - destination: host: echo-app.default.svc.cluster.local `,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 8.3K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MockExecutor.java
singleScheduledActions.add(command); } @Override public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { singleScheduledActions.add(command); return null; } @Override public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) { throw new UnsupportedOperationException(); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 07 08:18:49 UTC 2021 - 4.4K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/systemd/inhibit_linux.go
if err != nil { return 0, fmt.Errorf("failed reading InhibitDelayMaxUSec property from logind: %w", err) } delay, ok := res.Value().(uint64) if !ok { return 0, fmt.Errorf("InhibitDelayMaxUSec from logind is not a uint64 as expected") } // InhibitDelayMaxUSec is in microseconds duration := time.Duration(delay) * time.Microsecond return duration, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 6.2K bytes - Viewed (0) -
src/image/gif/writer.go
} // EncodeAll writes the images in g to w in GIF format with the // given loop count and delay between frames. func EncodeAll(w io.Writer, g *GIF) error { if len(g.Image) == 0 { return errors.New("gif: must provide at least one image") } if len(g.Image) != len(g.Delay) { return errors.New("gif: mismatched image and delay lengths") } e := encoder{g: *g}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:38:09 UTC 2024 - 11.9K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
@Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 17 17:12:37 UTC 2024 - 6.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/AbstractIntervalController.java
protected boolean ignoreException = true; /* * (non-Javadoc) * * @see org.codelibs.fess.crawler.interval.IntervalController#delay(int) */ @Override public void delay(final int type) { try { switch (type) { case PRE_PROCESSING: delayBeforeProcessing(); break; case POST_PROCESSING:
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 2.3K bytes - Viewed (0)