Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 96 of 96 for getOpt (0.04 seconds)

  1. android/guava/src/com/google/common/primitives/Ints.java

        };
      }
    
      /**
       * Returns the {@code int} value whose big-endian representation is stored in the first 4 bytes of
       * {@code bytes}; equivalent to {@code ByteBuffer.wrap(bytes).getInt()}. For example, the input
       * byte array {@code {0x12, 0x13, 0x14, 0x15, 0x33}} would yield the {@code int} value {@code
       * 0x12131415}.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:45:58 GMT 2026
    - 31.3K bytes
    - Click Count (0)
  2. cmd/erasure-server-pool-rebalance.go

    		rcfg, err = getReplicationConfig(ctx, bucket)
    		if err != nil {
    			return err
    		}
    	}
    
    	pool := z.serverPools[poolIdx]
    
    	const envRebalanceWorkers = "_MINIO_REBALANCE_WORKERS"
    	workerSize, err := env.GetInt(envRebalanceWorkers, len(pool.sets))
    	if err != nil {
    		rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb1/netbios/NbtAddress.java

         */
    
        private static final NameServiceClient CLIENT = new NameServiceClient();
    
        private static final int DEFAULT_CACHE_POLICY = 30;
        private static final int CACHE_POLICY = Config.getInt("jcifs.smb1.netbios.cachePolicy", DEFAULT_CACHE_POLICY);
        private static final int FOREVER = -1;
        private static int nbnsIndex = 0;
    
        private static final HashMap ADDRESS_CACHE = new HashMap();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 31.7K bytes
    - Click Count (0)
  4. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java

            if (terminal instanceof TerminalExt te) {
                subs.add("provider=" + te.getProvider().name());
            }
            if (terminal instanceof AbstractPosixTerminal pt) {
                subs.add("pty=" + pt.getPty().getClass().getName());
            }
            return terminal.getClass().getSimpleName() + " (" + String.join(", ", subs) + ")";
        }
    
        protected void preCommands(C context) throws Exception {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Oct 28 13:01:07 GMT 2025
    - 43.2K bytes
    - Click Count (0)
  5. cmd/server-main.go

    	}
    
    	cfCommon := config.ServerConfigCommon{}
    	if err = yaml.Unmarshal(rd, &cfCommon); err != nil {
    		return err
    	}
    
    	configCommonToSrvCtx(cfCommon, ctxt)
    
    	v, err := env.GetInt(EnvErasureSetDriveCount, 0)
    	if err != nil {
    		return err
    	}
    	setDriveCount := uint64(v)
    
    	var pools []poolArgs
    	switch cv.Version {
    	case "v1":
    		cfV1 := config.ServerConfigV1{}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  6. cmd/erasure-server-pool-decom.go

    	ctx = logger.SetReqInfo(ctx, &logger.ReqInfo{})
    
    	const envDecomWorkers = "_MINIO_DECOMMISSION_WORKERS"
    	workerSize, err := env.GetInt(envDecomWorkers, len(pool.sets))
    	if err != nil {
    		decomLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 42.2K bytes
    - Click Count (1)
Back to Top