- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 167 for waiters (1.93 sec)
-
cmd/kubeadm/app/cmd/phases/init/waitcontrolplane.go
return handleError(err) } waiter.SetTimeout(data.Cfg().Timeouts.ControlPlaneComponentHealthCheck.Duration) if features.Enabled(data.Cfg().ClusterConfiguration.FeatureGates, features.WaitForAllControlPlaneComponents) { err = waiter.WaitForControlPlaneComponents(&data.Cfg().ClusterConfiguration) } else { err = waiter.WaitForAPI() } if err != nil { return handleError(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 5K bytes - Viewed (0) -
src/image/png/writer.go
} } // An encoder is an io.Writer that satisfies writes by writing PNG IDAT chunks, // including an 8-byte header and 4-byte CRC checksum per Write call. Such calls // should be relatively infrequent, since writeIDATs uses a [bufio.Writer]. // // This method should only be called from writeIDATs (via writeImage). // No other code should treat an encoder as an io.Writer. func (e *encoder) Write(b []byte) (int, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 11 17:08:05 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/erasure-encode.go
} // Encode reads from the reader, erasure-encodes the data and writes to the writers. func (e *Erasure) Encode(ctx context.Context, src io.Reader, writers []io.Writer, buf []byte, quorum int) (total int64, err error) { writer := &multiWriter{ writers: writers, writeQuorum: quorum, errs: make([]error, len(writers)), } for { var blocks [][]byte
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.9K bytes - Viewed (0) -
src/runtime/proc.go
// "locked" sentinel value. M's on this list remain visible to the GC // because their mp.curg is on allgs. extraM atomic.Uintptr // Number of M's in the extraM list. extraMLength atomic.Uint32 // Number of waiters in lockextra. extraMWaiters atomic.Uint32 // Number of extra M's in use by threads. extraMInUse atomic.Uint32 ) // lockextra locks the extra list and returns the list head.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/dryrun/dryrun.go
} return errorsutil.NewAggregate(errs) } // Waiter is an implementation of apiclient.Waiter that should be used for dry-running type Waiter struct{} // NewWaiter returns a new Waiter object that talks to the given Kubernetes cluster func NewWaiter() apiclient.Waiter { return &Waiter{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/join/waitcontrolplane.go
return nil } waiter, err := newControlPlaneWaiter(data.DryRun(), 0, nil, data.OutputWriter()) if err != nil { return errors.Wrap(err, "error creating waiter") } waiter.SetTimeout(data.Cfg().Timeouts.ControlPlaneComponentHealthCheck.Duration) if err := waiter.WaitForControlPlaneComponents(&initCfg.ClusterConfiguration); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 15:33:38 UTC 2024 - 2.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
final TestCloseable closeable2 = new TestCloseable("closeable2"); final TestCloseable closeable3 = new TestCloseable("closeable3"); final TestCloseable closeable4 = new TestCloseable("closeable4"); final Waiter waiter = new Waiter(); final CountDownLatch futureCancelled = new CountDownLatch(1); final Exception exception = new Exception(); final Closeable mockCloseable = Mockito.mock(Closeable.class); @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
final TestCloseable closeable2 = new TestCloseable("closeable2"); final TestCloseable closeable3 = new TestCloseable("closeable3"); final TestCloseable closeable4 = new TestCloseable("closeable4"); final Waiter waiter = new Waiter(); final CountDownLatch futureCancelled = new CountDownLatch(1); final Exception exception = new Exception(); final Closeable mockCloseable = Mockito.mock(Closeable.class); @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
cmd/erasure-decode.go
} // Decode reads from readers, reconstructs data if needed and writes the data to the writer. // A set of preferred drives can be supplied. In that case they will be used and the data reconstructed. func (e Erasure) Decode(ctx context.Context, writer io.Writer, readers []io.ReaderAt, offset, length, totalLength int64, prefer []bool) (written int64, derr error) { if offset < 0 || length < 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0) -
src/sync/rwmutex.go
// // [the Go memory model]: https://go.dev/ref/mem type RWMutex struct { w Mutex // held if there are pending writers writerSem uint32 // semaphore for writers to wait for completing readers readerSem uint32 // semaphore for readers to wait for completing writers readerCount atomic.Int32 // number of pending readers readerWait atomic.Int32 // number of departing readers }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0)