- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 587 for blocked (0.21 sec)
-
src/runtime/HACKING.md
Some common patterns that mix atomic and non-atomic access are: * Read-mostly variables where updates are protected by a lock. Within the locked region, reads do not need to be atomic, but the write does. Outside the locked region, reads need to be atomic. * Reads that only happen during STW, where no writes can happen during STW, do not need to be atomic.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 13.9K bytes - Viewed (0) -
src/os/file.go
// currently-blocked Read call. // A zero value for t means Read will not time out. // Not all files support setting deadlines; see SetDeadline. func (f *File) SetReadDeadline(t time.Time) error { return f.setReadDeadline(t) } // SetWriteDeadline sets the deadline for any future Write calls and any // currently-blocked Write call.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 23:07:37 UTC 2024 - 25.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// nothing } } void awaitWaiting() { while (!isBlocked()) { if (getState() == State.TERMINATED) { throw new RuntimeException("Thread exited"); } Thread.yield(); } } private boolean isBlocked() { return getState() == Thread.State.WAITING && LockSupport.getBlocker(this) == future; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
src/os/pipe_test.go
t.Parallel() r, w, err := os.Pipe() if err != nil { t.Fatal(err) } testPipeEOF(t, r, w) } // testPipeEOF tests that when the write side of a pipe or FIFO is closed, // a blocked Read call on the reader side returns io.EOF. // // This scenario previously failed to unblock the Read call on darwin. // (See https://go.dev/issue/24164.) func testPipeEOF(t *testing.T, r io.ReadCloser, w io.WriteCloser) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 05 23:35:29 UTC 2023 - 12.4K bytes - Viewed (0) -
src/net/http/cgi/host_test.go
// its output. (for example, from the client having gone away) // // If we fail to do so, the test will time out (and dump its goroutines) with a // call to [Handler.ServeHTTP] blocked on a deferred call to [exec.Cmd.Wait]. func TestCopyError(t *testing.T) { testenv.MustHaveExec(t) h := &Handler{ Path: os.Args[0], Root: "/test.cgi", } ts := httptest.NewServer(h)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 18:29:59 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
// or // b) was force-deleted. // // It's now just waiting for garbage collection. We could wait // for it to actually get removed, but that may be blocked by // finalizers for the pod and thus get delayed. // // Worse, it is possible that there is a cyclic dependency // (pod finalizer waits for PVC to get removed, PVC protection
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/scheduler/scheduler.go
PluginName: e.Name(), QueueingHintFn: defaultQueueingHintFn, }, ) } } return queueingHintMap } // Run begins watching and scheduling. It starts scheduling and blocked until the context is done. func (sched *Scheduler) Run(ctx context.Context) { logger := klog.FromContext(ctx) sched.SchedulingQueue.Run(logger) // We need to start scheduleOne loop in a dedicated goroutine,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 20.8K bytes - Viewed (0) -
internal/grid/muxclient.go
} m.addResponse(Response{Err: ErrIncorrectSequence}) return false } m.RecvSeq++ return true } // response will send handleIncoming response to client. // may never block. // Should return whether the next call would block. func (m *muxClient) response(seq uint32, r Response) { if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "RESP") } if debugPrint {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/xds/server.go
// to tell the receiving goroutines that all data have been sent." // Block until either a request is received or a push is triggered. // We need 2 go routines because 'read' blocks in Recv(). go Receive(ctx) // Wait for the proxy to be fully initialized before we start serving traffic. Because // initialization doesn't have dependencies that will block, there is no need to add any timeout
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// nothing } } void awaitWaiting() { while (!isBlocked()) { if (getState() == State.TERMINATED) { throw new RuntimeException("Thread exited"); } Thread.yield(); } } private boolean isBlocked() { return getState() == Thread.State.WAITING && LockSupport.getBlocker(this) == future; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0)