Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for initializer (0.18 sec)

  1. cmd/iam.go

    			group:         group,
    		}
    	} else {
    		sys.store = &IAMStoreSys{IAMStorageAPI: newIAMEtcdStore(etcdClient, sys.usersSysType)}
    	}
    }
    
    // Initialized checks if IAM is initialized
    func (sys *IAMSys) Initialized() bool {
    	if sys == nil {
    		return false
    	}
    	sys.Lock()
    	defer sys.Unlock()
    	return sys.store != nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  2. cmd/test-utils_test.go

    	return objLayer, formattedDisks, nil
    }
    
    // removeRoots - Cleans up initialized directories during tests.
    func removeRoots(roots []string) {
    	for _, root := range roots {
    		os.RemoveAll(root)
    	}
    }
    
    // creates a bucket for the tests and returns the bucket name.
    // initializes the specified API endpoints for the tests.
    // initializes the root and returns its path.
    // return credentials.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    				logger.Fatal(err, "Unable to initialize backend")
    			}
    			retry := time.Duration(r.Float64() * float64(5*time.Second))
    			storageLogIf(ctx, fmt.Errorf("Unable to initialize backend: %w, retrying in %s", err, retry))
    			time.Sleep(retry)
    			attempt++
    			continue
    		}
    		break
    	}
    
    	// initialize the incomplete uploads cache
    	z.mpCache = xsync.NewMapOf[string, MultipartInfo]()
    
    	go z.cleanupStaleMPCache(ctx)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  4. cmd/xl-storage_test.go

    			t.Fatalf("Unable to change permission to temporary directory %v. %v", permDeniedDir, err)
    		}
    
    		// Initialize xlStorage storage layer for permission denied error.
    		_, err = newLocalXLStorage(permDeniedDir)
    		if err != nil && err != errDiskAccessDenied {
    			t.Fatalf("Unable to initialize xlStorage, %s", err)
    		}
    
    		if err = os.Chmod(permDeniedDir, 0o755); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    		return ObjectInfo{}, toObjectErr(errInvalidArgument)
    	}
    
    	// Initialize parts metadata
    	partsMetadata := make([]FileInfo, len(storageDisks))
    
    	fi := newFileInfo(pathJoin(minioMetaBucket, key), dataDrives, parityDrives)
    	fi.DataDir = mustGetUUID()
    
    	// Initialize erasure metadata.
    	for index := range partsMetadata {
    		partsMetadata[index] = fi
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    					Config:  rcfg,
    					remotes: tgts,
    				}
    			}
    		}
    	}
    
    	vcfg, _ := globalBucketVersioningSys.Get(cache.Info.Name)
    
    	// return initialized object layer
    	objAPI := newObjectLayerFn()
    	// object layer not initialized, return.
    	if objAPI == nil {
    		return cache, errServerNotInitialized
    	}
    
    	poolIdx, setIdx, _ := s.GetDiskLoc()
    
    	disks, err := objAPI.GetDisks(poolIdx, setIdx)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbSessionImpl.java

                    /*
                     * Create SMB signature digest if necessary
                     * Only the first SMB_COM_SESSION_SETUP_ANX with non-null or
                     * blank password initializes signing.
                     */
                    if ( !anonymous && isSignatureSetupRequired() ) {
                        if ( isExternalAuth(getContext(), npa) ) {
                            /*
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:41:04 UTC 2021
    - 49K bytes
    - Viewed (0)
  8. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	defer obj.Shutdown(context.Background())
    
    	// initialize the server and obtain the credentials and root.
    	// credentials are necessary to sign the HTTP request.
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    		t.Fatalf("Unable to initialize server config. %s", err)
    	}
    
    	defer removeRoots(fsDirs)
    
    	z := obj.(*erasureServerPools)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  9. cmd/api-errors.go

    	},
    	ErrServerNotInitialized: {
    		Code:           "XMinioServerNotInitialized",
    		Description:    "Server not initialized yet, please try again.",
    		HTTPStatusCode: http.StatusServiceUnavailable,
    	},
    	ErrIAMNotInitialized: {
    		Code:           "XMinioIAMNotInitialized",
    		Description:    "IAM sub-system not initialized yet, please try again.",
    		HTTPStatusCode: http.StatusServiceUnavailable,
    	},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (0)
  10. tensorflow/c/c_api.h

    // Creates a TF_WhileParams for creating a while loop in `g`. `inputs` are
    // outputs that already exist in `g` used as initial values for the loop
    // variables.
    //
    // The returned TF_WhileParams will have all fields initialized except
    // `cond_output`, `body_outputs`, and `name`. The `body_outputs` buffer will be
    // allocated to size `ninputs`. The caller should build `cond_graph` and
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Oct 26 21:08:15 UTC 2023
    - 82.3K bytes
    - Viewed (0)
Back to top