- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 376 for timeEnd (0.34 sec)
-
src/go/doc/testdata/testing.go
// for i := 0; i < b.N; i++ { // fmt.Sprintf("hello") // } // } // The benchmark package will vary b.N until the benchmark function lasts // long enough to be timed reliably. The output // testing.BenchmarkHello 10000000 282 ns/op // means that the loop ran 10000000 times at a speed of 282 ns per loop. // // If a benchmark needs some expensive setup before running, the timer
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Oct 02 02:28:27 UTC 2022 - 11.8K bytes - Viewed (0) -
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) -
src/main/java/jcifs/smb1/util/transport/Transport.java
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 9K 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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* the request completes normally or when it fails due to an exception, in which case [e] should * be non-null. * * If the exchange was canceled or timed out, this will wrap [e] in an exception that provides * that additional context. Otherwise [e] is returned as-is. */ internal fun <E : IOException?> messageDone( exchange: Exchange, requestDone: Boolean,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.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/os/pipe_test.go
wg.Add(1) go func() { defer wg.Done() var buf [count]byte r.SetReadDeadline(time.Now().Add(time.Minute)) c <- true if _, err := r.Read(buf[:]); os.IsTimeout(err) { t.Error("read timed out") } }() wg.Add(1) go func() { defer wg.Done() <-c // Give the other goroutine a chance to enter the Read. // It doesn't matter if this occasionally fails, the test
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0)