- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 454 for wait4 (0.09 sec)
-
src/internal/trace/testdata/testprog/stacks.go
}() var mu sync.Mutex mu.Lock() go func() { // func7 mu.Lock() mu.Unlock() }() var wg sync.WaitGroup wg.Add(1) go func() { // func8 wg.Wait() }() cv := sync.NewCond(&sync.Mutex{}) go func() { // func9 cv.L.Lock() cv.Wait() cv.L.Unlock() }() ln, err := net.Listen("tcp", "127.0.0.1:0") if err != nil { log.Fatalf("failed to listen: %v", err) } go func() { // func10
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.4K bytes - Viewed (0) -
src/crypto/tls/quic.go
func (c *Conn) quicRejectedEarlyData() { c.quic.events = append(c.quic.events, QUICEvent{ Kind: QUICRejectedEarlyData, }) } // quicWaitForSignal notifies the QUICConn that handshake progress is blocked, // and waits for a signal that the handshake should proceed. // // The handshake may become blocked waiting for handshake bytes // or for the user to provide transport parameters. func (c *Conn) quicWaitForSignal() error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0) -
.github/dependabot.yml
version: 2 updates: # TODO(b/170636568): Enable Maven updates? Perhaps wait until we can more # easily import the generated PRs into our internal repo. # - package-ecosystem: "maven" # directory: "/" # schedule: # interval: "weekly" # groups: # dependencies: # applies-to: version-updates # patterns: # - "*" # - package-ecosystem: "maven" # directory: "/android" # schedule:
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 04 17:08:24 UTC 2024 - 761 bytes - Viewed (0) -
cmd/erasure-multipart.go
} } // Fallback for older uploads without time in the ID. if modTime.IsZero() { wait := deleteMultipartCleanupSleeper.Timer(ctx) fi, err := disk.ReadVersion(ctx, "", minioMetaMultipartBucket, uploadIDPath, "", ReadOptions{}) if err != nil { return nil } modTime = fi.ModTime wait() } if time.Since(modTime) < expiry { return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_tpu_device.cc
<< " output buffers: " << xla_output->shaped_buffer().ToString(); // Wait for definition event of the source tensor so the input buffers are // available. xla_input->WaitForDefinitionEventOnStream(dst_device_to_device_stream); // Wait for the destination tensor buffers to be ready, if they are not // available for an immediate write.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 28 22:53:47 UTC 2024 - 20.9K bytes - Viewed (0) -
pkg/test/framework/suite_test.go
} s := newTestSuite("tid1", runFn1, exitFn1, defaultSettingsFn) s2 := newTestSuite("tid2", runFn2, exitFn2, defaultSettingsFn) go s.Run() waitForRun1.Wait() s2.Run() waitForTestCompletion.Done() waitForExit1Call.Wait() g.Expect(exit2Called).To(Equal(true)) g.Expect(errCode1).To(Equal(0)) g.Expect(errCode2).NotTo(Equal(0)) } func TestSuite_GetResource(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.5K 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 } const rwmutexMaxReaders = 1 << 30
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
cmd/peer-s3-client.go
client := client g.Go(func() error { if client == nil { return errPeerOffline } _, err := client.GetBucketInfo(ctx, bucket, BucketOptions{}) return err }, idx) } errs := g.Wait() var poolErrs []error for poolIdx := 0; poolIdx < sys.poolsCount; poolIdx++ { perPoolErrs := make([]error, 0, len(sys.peerClients)) for i, client := range sys.peerClients {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.3K bytes - Viewed (0) -
cmd/erasure-sets.go
for index := range s.sets { index := index g.Go(func() error { storageInfos[index] = s.sets[index].StorageInfo(ctx) return nil }, index) } // Wait for the go routines. g.Wait() for _, lstorageInfo := range storageInfos { storageInfo.Disks = append(storageInfo.Disks, lstorageInfo.Disks...) } return storageInfo }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.7K bytes - Viewed (0) -
internal/dsync/drwmutex.go
5*time.Second, ) } func log(format string, data ...interface{}) { if dsyncLog { console.Printf(format, data...) } } const ( // dRWMutexAcquireTimeout - default tolerance limit to wait for lock acquisition before. drwMutexAcquireTimeout = 1 * time.Second // 1 second. // dRWMutexRefreshTimeout - default timeout for the refresh call drwMutexRefreshCallTimeout = 5 * time.Second
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0)