- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Oancea (0.15 sec)
-
cmd/test-utils_test.go
setObjectLayer(newObjectLayerFn()) cancel() removeRoots(fsDirs) } } // ExecObjectLayerTestWithDirs - executes object layer tests. // Creates single node and Erasure ObjectLayer instance and runs test for both the layers. func ExecObjectLayerTestWithDirs(t TestErrHandler, objTest objTestTypeWithDirs) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() if localMetacacheMgr != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/consolelogger.go
if ok { if (lg.Entry != log.Entry{}) { logs = append(logs, lg.Entry) } } } }) sys.RUnlock() return } // Cancel - cancels the target func (sys *HTTPConsoleLoggerSys) Cancel() { } // Type - returns type of the target func (sys *HTTPConsoleLoggerSys) Type() types.TargetType { return types.TargetConsole }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
cmd/bucket-replication.go
ReplicationARN: tgt.ARN, }, HeaderSize: headerSize, } newCtx := ctx if globalBucketMonitor.IsThrottled(bucket, tgt.ARN) { var cancel context.CancelFunc newCtx, cancel = context.WithTimeout(ctx, throttleDeadline) defer cancel() } r := bandwidth.NewMonitoredReader(newCtx, globalBucketMonitor, gr, opts) if objInfo.isMultipart() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/site-replication.go
resultsMu.Unlock() return }() continue } wg.Add(1) go func() { defer wg.Done() ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second) defer cancel() result := perfNetRequest( ctx, info.DeploymentID, adminPathPrefix+adminAPIVersionPrefix+adminAPISiteReplicationNetPerf, nil, ) resultsMu.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cni/pkg/nodeagent/net_test.go
UID: "123", }, Spec: corev1.PodSpec{ Containers: containers, }, Status: podStatus, } } func TestServerAddPod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging() fixture := getTestFixure(ctx) netServer := fixture.netServer ztunnelServer := fixture.ztunnelServer podMeta := metav1.ObjectMeta{ Name: "foo",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cmd/jwt_test.go
return token.SignedString([]byte(secretKey)) } // Tests web request authenticator. func TestWebRequestAuthenticate(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:14 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
"istio.io/istio/pkg/monitoring/monitortest" "istio.io/istio/pkg/test/util/assert" ) func TestExistingPodAddedWhenNsLabeled(t *testing.T) { setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: NodeName, },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
internal/grid/grid_test.go
continue } err = resp.Err } t.Log("Client Context canceled. err state:", err) clientCanceled <- time.Now() }(t) start := time.Now() cancel() <-serverCanceled t.Log("server cancel time:", time.Since(start)) clientEnd := <-clientCanceled if !errors.Is(err, context.Canceled) { t.Error("expected context.Canceled, got", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/storage-rest-client.go
// transport is already down. return info, errDiskNotFound } // if 'NoOp' we do not cache the value. if opts.NoOp { ctx, cancel := context.WithTimeout(ctx, 5*time.Second) defer cancel() opts.DiskID = *client.diskID.Load() infop, err := storageDiskInfoRPC.Call(ctx, client.gridConn, &opts) if err != nil { return info, toStorageErr(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
) func (p *poolMeta) Decommission(idx int, pi poolSpaceInfo) error { // Return an error when there is decommission on going - the user needs // to explicitly cancel it first in order to restart decommissioning again. if p.Pools[idx].Decommission != nil && !p.Pools[idx].Decommission.Complete && !p.Pools[idx].Decommission.Failed && !p.Pools[idx].Decommission.Canceled {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1)