Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 391 for ctx_ (0.09 sec)

  1. tests/test_security_oauth2_optional.py

                        "loc": ["body", "grant_type"],
                        "msg": "String should match pattern 'password'",
                        "input": "incorrect",
                        "ctx": {"pattern": "password"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  2. src/cmd/asm/internal/asm/operand_test.go

    	if architecture == nil {
    		panic("asm: unrecognized architecture " + goarch)
    	}
    	ctxt := obj.Linknew(architecture.LinkArch)
    	ctxt.Pkgpath = "pkg"
    	return architecture, ctxt
    }
    
    func newParser(goarch string) *Parser {
    	architecture, ctxt := setArch(goarch)
    	return NewParser(ctxt, architecture, nil)
    }
    
    // tryParse executes parse func in panicOnError=true context.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 18:31:05 UTC 2023
    - 23.9K bytes
    - Viewed (0)
  3. cmd/data-usage-cache.go

    // save the content of the cache to minioMetaBackgroundOpsBucket with the provided name.
    // Note that no locking is done when saving.
    func (d *dataUsageCache) save(ctx context.Context, store objectIO, name string) error {
    	select {
    	case <-ctx.Done():
    		return ctx.Err()
    	case maxConcurrentScannerSaves <- struct{}{}:
    	}
    
    	buf := bytebufferpool.Get()
    	defer func() {
    		<-maxConcurrentScannerSaves
    		buf.Reset()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  4. tensorflow/c/c_api_experimental.h

    TF_CAPI_EXPORT extern void TFE_AbortCollectiveOps(TFE_Context* ctx,
                                                      TF_Status* status);
    
    // Checks the health of collective ops peers. Explicit health check is needed in
    // multi worker collective ops to detect failures in the cluster.  If a peer is
    // down, collective ops may hang.
    TF_CAPI_EXPORT extern void TFE_CollectiveOpsCheckPeerHealth(
        TFE_Context* ctx, const char* task, int64_t timeout_in_ms,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 15.1K bytes
    - Viewed (0)
  5. internal/http/check_port_linux.go

    					_ = syscall.SetsockoptString(int(fdPtr), syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface)
    				}
    			})
    			return nil
    		},
    	}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    	// As we are able to listen on this network, the port is not in use.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  6. cmd/kms-handlers_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    		_, err = globalIAMSys.SetPolicy(ctx, testKMSPolicyName, *policyData)
    		if err != nil {
    			t.Fatal(err)
    		}
    		_, err = globalIAMSys.PolicyDBSet(ctx, accessKey, testKMSPolicyName, regUser, false)
    		if err != nil {
    			t.Fatal(err)
    		}
    	} else {
    		err = globalIAMSys.DeletePolicy(ctx, testKMSPolicyName, false)
    		if err != nil {
    			t.Fatal(err)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  7. cmd/format-erasure.go

    		return err
    	}
    
    	disk.SetDiskID(format.Erasure.This)
    	if healID != "" {
    		ctx := context.Background()
    		ht := initHealingTracker(disk, healID)
    		return ht.save(ctx)
    	}
    	return nil
    }
    
    // loadFormatErasure - loads format.json from disk.
    func loadFormatErasure(disk StorageAPI, heal bool) (format *formatErasureV3, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  8. internal/config/crypto.go

    // ciphertext.
    func Encrypt(k *kms.KMS, plaintext io.Reader, ctx kms.Context) (io.Reader, error) {
    	algorithm := sio.AES_256_GCM
    	if !fips.Enabled && !sioutil.NativeAES() {
    		algorithm = sio.ChaCha20Poly1305
    	}
    
    	key, err := k.GenerateKey(context.Background(), &kms.GenerateKeyRequest{AssociatedData: ctx})
    	if err != nil {
    		return nil, err
    	}
    	stream, err := algorithm.Stream(key.Plaintext)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 5K bytes
    - Viewed (0)
  9. tests/test_regex_deprecated_body.py

                        "input": "nonregexquery",
                        "ctx": {"pattern": "^fixedquery$"},
                    }
                ]
            }
        ) | IsDict(
            # TODO: remove when deprecating Pydantic v1
            {
                "detail": [
                    {
                        "ctx": {"pattern": "^fixedquery$"},
                        "loc": ["body", "q"],
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:40:57 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  10. internal/config/identity/openid/jwt.go

    	return nil
    }
    
    const (
    	audClaim = "aud"
    	azpClaim = "azp"
    )
    
    // Validate - validates the id_token.
    func (r *Config) Validate(ctx context.Context, arn arn.ARN, token, accessToken, dsecs string, claims map[string]interface{}) error {
    	jp := new(jwtgo.Parser)
    	jp.ValidMethods = []string{
    		"RS256", "RS384", "RS512",
    		"ES256", "ES384", "ES512",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 02:46:36 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top