Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 453 for ctx_ (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top