Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 453 for ctx_ (0.02 sec)

  1. istioctl/pkg/xds/client.go

    	if isMCP {
    		// Special credentials handling when using ASM Managed Control Plane.
    		mem, err := getHubMembership(ctx, kubeClient)
    		if err != nil {
    			return nil, fmt.Errorf("failed to query Hub membership: %w", err)
    		}
    		aud = []string{mem.WorkloadIdentityPool}
    	}
    	k8sCreds, err := kubeClient.CreatePerRPCCredentials(ctx, ns, serviceAccount, aud, defaultExpirationSeconds)
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbTransportInternal.java

         */
        boolean ensureConnected () throws IOException;
    
    
        /**
         * @param ctx
         * @param name
         * @param targetHost
         * @param targetDomain
         * @param rn
         * @return dfs referral
         * @throws SmbException
         * @throws CIFSException
         */
        DfsReferralData getDfsReferrals ( CIFSContext ctx, String name, String targetHost, String targetDomain, int rn ) throws CIFSException;
    
    
        /**
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3K bytes
    - Viewed (0)
  3. cmd/post-policy-fan-out.go

    			if opts.Kind != nil {
    				encrd, objectEncryptionKey, err := newEncryptReader(ctx, hr, opts.Kind, opts.KeyID, opts.Key, bucket, req.Key, userDefined, opts.KmsCtx)
    				if err != nil {
    					errs[idx] = err
    					return
    				}
    
    				// do not try to verify encrypted content/
    				hr, err = hash.NewReader(ctx, encrd, -1, "", "", -1)
    				if err != nil {
    					errs[idx] = err
    					return
    				}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. internal/once/init.go

    func (l *Init) DoWithContext(ctx context.Context, f func(context.Context) error) error {
    	if atomic.LoadUint32(&l.done) == 0 {
    		return l.doWithContext(ctx, f)
    	}
    	return nil
    }
    
    func (l *Init) doWithContext(ctx context.Context, f func(context.Context) error) error {
    	l.m.Lock()
    	defer l.m.Unlock()
    	if atomic.LoadUint32(&l.done) == 0 {
    		if err := f(ctx); err != nil {
    			return err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 09 04:20:31 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  5. cmd/bootstrap-peer-server.go

    					offlineEndpoints = append(offlineEndpoints, fmt.Errorf("%s is unreachable: %w", clnt, grid.ErrDisconnected))
    					mu.Unlock()
    					return
    				}
    
    				ctx, cancel := context.WithTimeout(ctx, 2*time.Second)
    				defer cancel()
    
    				err := clnt.Verify(ctx, srcCfg)
    				mu.Lock()
    				if err != nil {
    					bootstrapTraceMsg(fmt.Sprintf("bootstrapVerify: %v, endpoint: %s", err, clnt))
    					if !isNetworkError(err) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. cmd/storage-interface.go

    	DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error
    	DeleteBulk(ctx context.Context, volume string, paths ...string) error
    	WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error
    	UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. tensorflow/c/c_test.c

    void* create(TF_OpKernelConstruction* ctx) {
      TF_DataType type;
      TF_Status* s = TF_NewStatus();
      TF_OpKernelConstruction_GetAttrType(ctx, "foobar", &type, s);
      TF_DeleteStatus(s);
      return NULL;
    }
    
    // A compute function. This will never actually get called in this test, it's
    // just nice to know that it compiles.
    void compute(void* kernel, TF_OpKernelContext* ctx) {
      TF_Tensor* input;
      TF_Status* s = TF_NewStatus();
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Apr 24 20:50:35 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  8. cmd/copy-part-range.go

    	"net/url"
    )
    
    // Writes S3 compatible copy part range error.
    func writeCopyPartErr(ctx context.Context, w http.ResponseWriter, err error, url *url.URL) {
    	switch err {
    	case errInvalidRange:
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidCopyPartRange), url)
    		return
    	case errInvalidRangeSource:
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidCopyPartRangeSource), url)
    		return
    	default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 18 03:27:04 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  9. src/test/java/jcifs/tests/TimeoutTest.java

        protected CIFSContext lowTimeout ( CIFSContext ctx ) {
            return withConfig(ctx, new DelegatingConfiguration(ctx.getConfig()) {
    
                @Override
                public int getSoTimeout () {
                    return 100;
                }
    
            });
    
        }
    
    
        protected CIFSContext fastIdle ( CIFSContext ctx ) {
            return withConfig(ctx, new DelegatingConfiguration(ctx.getConfig()) {
    
                @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 12.4K bytes
    - Viewed (0)
  10. internal/logger/config.go

    }
    
    // LookupConfigForSubSys - lookup logger config, override with ENVs if set, for the given sub-system
    func LookupConfigForSubSys(ctx context.Context, scfg config.Config, subSys string) (cfg Config, err error) {
    	switch subSys {
    	case config.LoggerWebhookSubSys:
    		cfg = lookupLegacyConfigForSubSys(ctx, config.LoggerWebhookSubSys)
    		if cfg, err = lookupLoggerWebhookConfig(scfg, cfg); err != nil {
    			return cfg, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
Back to top