Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 391 for ctx_ (0.04 sec)

  1. cmd/perf-tests.go

    			continue
    		}
    		info := info
    		wg.Add(connectionsPerPeer)
    		for i := 0; i < connectionsPerPeer; i++ {
    			go func() {
    				defer wg.Done()
    				ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second)
    				defer cancel()
    				perfNetRequest(
    					ctx,
    					info.DeploymentID,
    					adminPathPrefix+adminAPIVersionPrefix+adminAPISiteReplicationDevNull,
    					r,
    				)
    			}()
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. internal/dsync/locker.go

    	// * an error on failure of lock request operation.
    	RLock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do write lock for given LockArgs. It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of lock request operation.
    	Lock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do read unlock for given LockArgs. It should return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 18 20:44:38 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  3. tests/serializer_test.go

    	switch value := dbValue.(type) {
    	case []byte:
    		err = field.Set(ctx, dst, bytes.TrimPrefix(value, c.prefix))
    	case string:
    		err = field.Set(ctx, dst, strings.TrimPrefix(value, string(c.prefix)))
    	default:
    		err = fmt.Errorf("unsupported data %#v", dbValue)
    	}
    	return err
    }
    
    func (c *CustomSerializer) Value(ctx context.Context, field *schema.Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Apr 21 14:09:38 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users-race_test.go

    			},
    		)
    	}
    }
    
    func (s *TestSuiteIAM) TestDeleteUserRace(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), 90*time.Second)
    	defer cancel()
    
    	bucket := getRandomBucketName()
    	err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{})
    	if err != nil {
    		c.Fatalf("bucket creat error: %v", err)
    	}
    
    	// Create a policy policy
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. tensorflow/c/eager/dlpack.cc

      int device_id = 0;
      if (parsed_name.has_id) {
        device_id = parsed_name.id;
      }
    
      ctx.device_id = device_id;
      if (device_type == "CPU") {
        ctx.device_type = DLDeviceType::kDLCPU;
      } else if (device_type == "GPU") {
    #if TENSORFLOW_USE_ROCM
        ctx.device_type = DLDeviceType::kDLROCM;
    #else
        ctx.device_type = DLDeviceType::kDLCUDA;
    #endif
      } else {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  6. internal/config/lambda/parse.go

    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	logSubsys = "notify"
    )
    
    func logOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. cmd/signature-v2_test.go

    			break
    		}
    	}
    }
    
    // Tests presigned v2 signature.
    func TestDoesPresignedV2SignatureMatch(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 {
    		t.Fatal(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 14 10:08:40 UTC 2022
    - 8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbSessionImpl.java

            }
    
            while ( true ) {
                Subject s = this.credentials.getSubject();
                if ( ctx == null ) {
                    ctx = createContext(trans, tdomain, negoResp, !anonymous, s);
                }
                token = createToken(ctx, token, s);
    
                if ( token != null ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:41:04 UTC 2021
    - 49K bytes
    - Viewed (0)
  9. src/test/java/jcifs/tests/KerberosTest.java

            Subject s = getInitiatorSubject(getTestUser(), getTestUserPassword(), getTestUserDomainRequired(), null);
            CIFSContext ctx = getContext().withCredentials(new Kerb5Authenticator(s, getTestUserDomainRequired(), getTestUser(), getTestUserPassword()));
            try ( SmbResource f = new SmbFile(getTestShareURL(), ctx) ) {
                f.exists();
            }
            catch ( SmbUnsupportedOperationException e ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Mar 01 09:46:04 UTC 2020
    - 11.5K bytes
    - Viewed (0)
  10. tests/test_tutorial/test_query_param_models/test_tutorial001.py

                            "input": "150",
                            "ctx": {"le": 100},
                        },
                        {
                            "type": "greater_than_equal",
                            "loc": ["query", "offset"],
                            "msg": "Input should be greater than or equal to 0",
                            "input": "-1",
                            "ctx": {"ge": 0},
                        },
                        {
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 17 18:54:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
Back to top