Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/admin-handlers-idp-ldap.go

    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    	}
    	if listType == "" || listType == "svcacc-only" {
    		serviceAccounts, err = globalIAMSys.ListServiceAccounts(ctx, targetAccount)
    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    	}
    
    	var serviceAccountList []madmin.ServiceAccountInfo
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 21 11:35:40 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  2. cmd/speedtest.go

    			result.Version = Version
    			result.Concurrent = concurrency
    
    			select {
    			case ch <- result:
    			case <-ctx.Done():
    				return
    			}
    		}
    
    		for {
    			select {
    			case <-ctx.Done():
    				// If the client got disconnected stop the speedtest.
    				return
    			default:
    			}
    
    			sopts := speedTestOpts{
    				objectSize:      opts.objectSize,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  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. cmd/erasure-metadata.go

    // pickValidFileInfo - picks one valid FileInfo content and returns from a
    // slice of FileInfo.
    func pickValidFileInfo(ctx context.Context, metaArr []FileInfo, modTime time.Time, etag string, quorum int) (FileInfo, error) {
    	return findFileInfoInQuorum(ctx, metaArr, modTime, etag, quorum)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  10. 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)
Back to top