- Sort Score
- Result 10 results
- Languages All
Results 291 - 300 of 453 for ctx_ (0.03 sec)
-
internal/logger/target/testlogger/testlogger.go
return types.TargetStats{} } func (t *testLogger) Init(ctx context.Context) error { return nil } func (t *testLogger) IsOnline(ctx context.Context) bool { return t.current.Load() != nil } func (t *testLogger) Cancel() { t.current.Store(nil) } func (t *testLogger) Send(ctx context.Context, entry interface{}) error { tb := t.current.Load()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4K bytes - Viewed (0) -
cmd/erasure-metadata-utils_test.go
} } func TestShuffleDisks(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() nDisks := 16 disks, err := getRandomDisks(nDisks) if err != nil { t.Fatal(err) } objLayer, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, disks...)) if err != nil { removeRoots(disks) t.Fatal(err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 7.4K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
| kubectl --kubeconfig=c1.yaml apply -f -`, Args: cobra.NoArgs, RunE: func(c *cobra.Command, args []string) error { if err := opts.prepare(ctx); err != nil { return err } client, err := ctx.CLIClient() if err != nil { return err } out, warn, err := CreateRemoteSecret(client, opts) if err != nil {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 15 16:31:46 UTC 2024 - 23.3K bytes - Viewed (0) -
src/main/java/org/codelibs/core/naming/InitialContextUtil.java
assertArgumentNotEmpty("jndiName", jndiName); try { return ctx.lookup(jndiName); } catch (final NamingException ex) { throw new NamingRuntimeException(ex); } }
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 3K bytes - Viewed (0) -
cmd/namespace-lock_test.go
t.Skip("long test skip it") ctx := context.Background() for i := 0; i < 10000; i++ { nsLk := newNSLock(false) // lk1; ref=1 if !nsLk.lock(ctx, "volume", "path", "source", "opsID", false, time.Second) { t.Fatal("failed to acquire lock") } // lk2 lk2ch := make(chan struct{}) go func() { defer close(lk2ch)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 3.1K bytes - Viewed (0) -
internal/grid/manager.go
} m.handlers.init() if ctx == nil { ctx = context.Background() } for _, host := range o.Hosts { if host == o.Local { if found { return nil, fmt.Errorf("grid: local host found multiple times") } found = true // No connection to local. continue } m.targets[host] = newConnection(connectionParams{ ctx: ctx, id: m.ID,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 10.6K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
) func TestCheckValid(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() objLayer, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil { t.Fatalf("unable initialize config file, %s", err) } initAllSubsystems(ctx) initConfigSubsystem(ctx, objLayer)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 05 21:26:41 UTC 2024 - 14.3K bytes - Viewed (0) -
cmd/config-current_test.go
package cmd import ( "context" "os" "testing" "github.com/minio/minio/internal/config" ) func TestServerConfig(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() objLayer, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 2K bytes - Viewed (0) -
tests/transaction_test.go
} }) } func TestCancelTransaction(t *testing.T) { ctx := context.Background() ctx, cancelFunc := context.WithCancel(ctx) cancelFunc() user := *GetUser("cancel_transaction", Config{}) DB.Create(&user) err := DB.WithContext(ctx).Transaction(func(tx *gorm.DB) error { var result User tx.First(&result, user.ID) return nil })
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Sat Sep 14 12:58:29 UTC 2024 - 12.9K bytes - Viewed (0) -
cmd/erasure-decode.go
} } } else if err != nil { return err } if err = e.DecodeDataAndParityBlocks(ctx, bufs); err != nil { return err } w := multiWriter{ writers: writers, writeQuorum: 1, errs: make([]error, len(writers)), } if err = w.Write(ctx, bufs); err != nil { return err } } return derr
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0)