- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 44 for unblocksig (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go
type lifecycleSignal interface { // Signal signals the event, indicating that the event has occurred. // Signal is idempotent, once signaled the event stays signaled and // it immediately unblocks any goroutine waiting for this event. Signal() // Signaled returns a channel that is closed when the underlying event // has been signaled. Successive calls to Signaled return the same value. Signaled() <-chan struct{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 7.8K bytes - Viewed (0) -
pkg/util/iptables/monitor_test.go
mfe.blockIPTables(true) ipt.DeleteChain(TableNAT, canary) if err := waitForBlocked(mfe); err != nil { t.Errorf("failed waiting for monitor to be blocked from monitoring: %v", err) } // After unblocking the monitor, it should now reload mfe.blockIPTables(false) if err := waitForReloads(&reloads, 2); err != nil { t.Errorf("got unexpected number of reloads after slow flush: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:21:59 UTC 2023 - 9.3K bytes - Viewed (0) -
src/sync/rwmutex.go
if r+1 == 0 || r+1 == -rwmutexMaxReaders { race.Enable() fatal("sync: RUnlock of unlocked RWMutex") } // A writer is pending. if rw.readerWait.Add(-1) == 0 { // The last reader unblocks the writer. runtime_Semrelease(&rw.writerSem, false, 1) } } // Lock locks rw for writing. // If the lock is already locked for reading or writing, // Lock blocks until the lock is available.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
src/net/net_test.go
go func() { // TODO: find a better way to wait // until we're blocked in the cs.Read // call below. Sleep is lame. time.Sleep(100 * time.Millisecond) // Interrupt the upcoming Read, unblocking it: cs.SetReadDeadline(time.Unix(123, 0)) // time in the past }() var buf [1]byte n, err := cs.Read(buf[:1]) if n != 0 || err == nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jan 22 21:04:44 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/kubelet/container/testing/fake_runtime.go
f.Unlock() select { case <-ctx.Done(): case <-f.imagePullTokenBucket: } return image.Image, retErr } // UnblockImagePulls unblocks a certain number of image pulls, if BlockImagePulls is true. func (f *FakeRuntime) UnblockImagePulls(count int) { if f.imagePullTokenBucket != nil { for i := 0; i < count; i++ { select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 00:23:50 UTC 2024 - 13.9K bytes - Viewed (0) -
src/cmd/trace/gstate.go
name := gs.baseName if gs.label != "" { name += " (" + gs.label + ")" } return name } // setStartCause sets the reason a goroutine will be allowed to start soon. // For example, via unblocking or exiting a blocked syscall. func (gs *gState[R]) setStartCause(ts trace.Time, name string, resource uint64, stack trace.Stack) { gs.startCause.time = ts gs.startCause.name = name gs.startCause.resource = resource
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
// After that it is safe to start them here, before that it is not. informersStarted <-chan struct{} // stopCh drives shutdown. When a reception from it unblocks, monitors will shut down. // This channel is also protected by monitorLock. stopCh <-chan struct{} // running tracks whether Run() has been called. // it is protected by monitorLock. running bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
internal/grid/muxclient.go
if requests == nil { go m.handleOneWayStream(responseCh, responses) return &Stream{responses: responseCh, Requests: nil, ctx: m.ctx, cancel: m.cancelFn, muxID: m.MuxID}, nil } // Deliver responses and send unblocks back to the server. go m.handleTwowayResponses(responseCh, responses) go m.handleTwowayRequests(responses, requests)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
src/internal/trace/trace_test.go
func TestTraceFutileWakeup(t *testing.T) { testTraceProg(t, "futile-wakeup.go", func(t *testing.T, tb, _ []byte, _ bool) { // Check to make sure that no goroutine in the "special" trace region // ends up blocking, unblocking, then immediately blocking again. // // The goroutines are careful to call runtime.Gosched in between blocking, // so there should never be a clean block/unblock on the goroutine unless
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 18.5K bytes - Viewed (0) -
tensorflow/c/experimental/saved_model/internal/saved_model_api_test.cc
TF_SavedModel* saved_model = TF_LoadSavedModelWithTags(model_dir.c_str(), ctx, kServeTag, 1, status); // TODO(bmzhao): Change this to expect TF_OK when loading is implemented. // That unblocks writing other tests that require a TF_SavedModel*, // like loading a ConcreteFunction. This test at least checks that the // C API builds and can be minimally run. EXPECT_EQ(TF_GetCode(status), TF_UNIMPLEMENTED);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 23 08:08:45 UTC 2024 - 21.3K bytes - Viewed (0)