- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 91 for timeEnd (0.24 sec)
-
src/runtime/netpoll_kqueue.go
// see https://go.dev/issue/59679 for details. if n != -_EINTR && n != -_ETIMEDOUT { println("runtime: kevent on fd", kq, "failed with", -n) throw("runtime: netpoll failed") } // If a timed sleep was interrupted, just return to // recalculate how long we should sleep now. if delay > 0 { return gList{}, 0 } goto retry } var toRun gList delta := int32(0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 21:17:22 UTC 2024 - 4.6K bytes - Viewed (0) -
src/syscall/tables_wasip1.go
EROFS: "Read-only file system", ESPIPE: "Illegal seek", ESRCH: "No such process", ESTALE: "Stale file handle", ETIMEDOUT: "Connection timed out", ETXTBSY: "Text file busy", EXDEV: "Cross-device link", ENOTCAPABLE: "Capabilities insufficient", } // Do the interface allocations only once for common // Errno values. var (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 20:58:35 UTC 2023 - 6.5K bytes - Viewed (0) -
src/runtime/netpoll_aix.go
n, e := poll(&pfds[0], uintptr(len(pfds)), timeout) if n < 0 { if e != _EINTR { println("errno=", e, " len(pfds)=", len(pfds)) throw("poll failed") } unlock(&mtxset) // If a timed sleep was interrupted, just return to // recalculate how long we should sleep now. if timeout > 0 { return gList{}, 0 } goto retry } // Check if some descriptors need to be changed
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/plugin.go
return nil, err } ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() if ok := conn.WaitForStateChange(ctx, connectivity.Connecting); !ok { return nil, errors.New("timed out waiting for gRPC connection to be ready") } p.conn = conn return p.conn, nil } // RegistrationHandler is the handler which is fed to the pluginwatcher API. type RegistrationHandler struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
} else { events.add(Failure(t, response)) } } private fun nextEvent(): Any { return events.poll(10, TimeUnit.SECONDS) ?: throw AssertionError("Timed out waiting for event.") } fun assertTextMessage(payload: String?) { assertThat(nextEvent()).isEqualTo(Message(string = payload)) } fun assertBinaryMessage(payload: ByteString?) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller_test.go
} // Process the controller queue until we get expected results timeout := time.Now().Add(10 * time.Second) lastReportedActionCount := 0 for { if time.Now().After(timeout) { t.Errorf("Test %q: timed out", test.name) break } if ctrl.queue.Len() > 0 { logger.V(5).Info("Non-empty events queue, processing one", "test", test.name, "queueLength", ctrl.queue.Len()) ctrl.processNextWorkItem(context.TODO())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
} try { if (!p.destroyForcibly().waitFor(timeout, TimeUnit.MILLISECONDS)) { logger.warn("Terminating process {} is timed out.", p); } else if (logger.isDebugEnabled()) { logger.debug("Terminated process {}.", p); } } catch (final Exception e) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt
.url(server!!.url("/")) .build(), ) assertFailsWith<IOException> { call.execute() }.also { expected -> assertThat(expected.message).isIn("timeout", "Read timed out") } assertThat(listener.recordedEventTypes()).containsExactly( "ConnectStart", "ConnectEnd", "ConnectionAcquired", "NoNewExchanges", "ConnectionReleased",
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 9.6K bytes - Viewed (0) -
src/runtime/netpoll_wasip1.go
if errno != 0 { if errno != _EINTR { println("errno=", errno, " len(pollsubs)=", len(pollsubs)) throw("poll_oneoff failed") } // If a timed sleep was interrupted, just return to // recalculate how long we should sleep now. if delay > 0 { unlock(&mtx) return gList{}, 0 } goto retry } var toRun gList delta := int32(0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 6.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/TimeoutFuture.java
} else { try { ScheduledFuture<?> timer = timeoutFuture.timer; timeoutFuture.timer = null; // Don't include already elapsed delay in delegate.toString() String message = "Timed out"; // This try-finally block ensures that we complete the timeout future, even if attempting // to produce the message throws (probably StackOverflowError from delegate.toString()) try {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 7.7K bytes - Viewed (0)