Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 391 for ctx_ (0.06 sec)

  1. cmd/bucket-encryption-handlers.go

    		_, err := GlobalKMS.GenerateKey(ctx, &kms.GenerateKeyRequest{Name: kmsKey, AssociatedData: kmsContext})
    		if err != nil {
    			if errors.Is(err, kes.ErrKeyNotFound) {
    				writeErrorResponse(ctx, w, toAPIError(ctx, errKMSKeyNotFound), r.URL)
    				return
    			}
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	configData, err := xml.Marshal(encConfig)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  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/local-locker_test.go

    	rResources := make([]string, 1000)
    	quorum := 0
    	l := newLocker()
    	ctx := context.Background()
    	for i := range wResources {
    		arg := dsync.LockArgs{
    			UID:       mustGetUUID(),
    			Resources: []string{mustGetUUID()},
    			Source:    t.Name(),
    			Owner:     "owner",
    			Quorum:    &quorum,
    		}
    		ok, err := l.Lock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  9. 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)
  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