- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for Pairing (0.14 sec)
-
internal/dsync/dsync_test.go
}, } code := m.Run() stopLockServers() os.Exit(code) } func TestSimpleLock(t *testing.T) { dm := NewDRWMutex(ds, "test") dm.Lock(id, source) // fmt.Println("Lock acquired, waiting...") time.Sleep(testDrwMutexRefreshCallTimeout) dm.Unlock(context.Background()) } func TestSimpleLockUnlockMultipleTimes(t *testing.T) { dm := NewDRWMutex(ds, "test") dm.Lock(id, source)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
internal/grid/connection.go
continue } c.reconnectMu.Lock() remoteUUID := uuid.UUID(r.ID) if c.remoteID != nil { c.reconnected() } c.remoteID = &remoteUUID if debugPrint { fmt.Println(c.Local, "Connected Waiting for Messages") } // Handle messages... c.handleMessages(c.ctx, conn) // Reconnect unless we are shutting down (debug only). if c.State() == StateShutdown { conn.Close() return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/api-router.go
// ListBuckets apiRouter.Methods(http.MethodGet).Path(SlashSeparator). HandlerFunc(s3APIMiddleware(api.ListBucketsHandler)) // S3 browser with signature v4 adds '//' for ListBuckets request, so rather // than failing with UnknownAPIRequest we simply handle it for now. apiRouter.Methods(http.MethodGet).Path(SlashSeparator + SlashSeparator). HandlerFunc(s3APIMiddleware(api.ListBucketsHandler))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
src/archive/zip/reader.go
} if strings.HasSuffix(f.Name, "/") { // The ZIP specification (APPNOTE.TXT) specifies that directories, which // are technically zero-byte files, must not have any associated file // data. We previously tried failing here if f.CompressedSize64 != 0, // but it turns out that a number of implementations (namely, the Java // jar tool) don't properly set the storage method on directories
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
n = tw } t.mu.Lock() defer t.mu.Unlock() t.objAPI = objAPI t.updateWorkers(n) } // PendingTasks returns the number of ILM transition tasks waiting for a worker // goroutine. func (t *transitionState) PendingTasks() int { return len(t.transitionCh) } // ActiveTasks returns the number of active (ongoing) ILM transition tasks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
if err == nil { break } installLog.Warnf("Istio CNI is configured as chained plugin, but cannot find existing CNI network config: %v", err) installLog.Infof("Waiting for CNI network config file to be written in %v...", cfg.mountedCNINetDir) if err := watcher.Wait(ctx); err != nil { return "", err } } cniConfigFilepath := filepath.Join(cfg.mountedCNINetDir, filename)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/metacache-server-pool.go
// No cache found, no entries found. return entries, io.EOF } if c.status == scanStateError || c.status == scanStateNone { o.ID = "" o.Create = false o.debugln("scan status", c.status, " - waiting a roundtrip to create") } else { // Continue listing o.ID = c.id go func(meta metacache) { // Continuously update while we wait. t := time.NewTicker(metacacheMaxClientWait / 10)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cni/pkg/install/cniconfig_test.go
defer cancel() result, err := getCNIConfigFilepath(ctx1, cfg) if err != nil { assert.Equal(t, result, "") if err == context.DeadlineExceeded { t.Fatalf("timed out waiting for expected %s", expectedFilepath) } t.Fatal(err) } if result != expectedFilepath { t.Fatalf("expected %s, got %s", expectedFilepath, result) } // Successful test case
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 17 02:22:22 GMT 2023 - 15.4K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} atomic.StoreInt64(&p.health.lastStarted, time.Now().UnixNano()) p.health.waiting.Add(1) ctx = context.WithValue(ctx, healthDiskCtxKey{}, &healthDiskCtxValue{lastSuccess: &p.health.lastSuccess}) si := p.updateStorageMetrics(s, paths...) var once sync.Once return ctx, func(errp *error) { p.health.waiting.Add(-1) once.Do(func() { if errp != nil { err := *errp
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
} func waitForTokenData(client kube.CLIClient, secret *v1.Secret) (ca, token []byte, err error) { ca, token, err = tokenDataFromSecret(secret) if err == nil { return } log.Infof("Waiting for data to be populated in %s", secret.Name) err = backoff.Retry( func() error { secret, err = client.Kube().CoreV1().Secrets(secret.Namespace).Get(context.TODO(), secret.Name, metav1.GetOptions{}) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0)