Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 303 for knop (0.13 sec)

  1. src/cmd/asm/internal/asm/parse.go

    				p.errorf("misplaced //go:build comment")
    			}
    			continue
    		}
    		if tok != '\n' {
    			p.sawCode = true
    		}
    		if tok == '#' {
    			// A leftover wisp of a #include/#define/etc,
    			// to let us know that p.sawCode should be true now.
    			// Otherwise ignored.
    			continue
    		}
    		return tok
    	}
    }
    
    // line consumes a single assembly line from p.lex of the form
    //
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom.go

    		StartSize:   pi.Free,
    		CurrentSize: pi.Free,
    		TotalSize:   pi.Total,
    	}
    	return nil
    }
    
    func (p poolMeta) IsSuspended(idx int) bool {
    	if idx >= len(p.Pools) {
    		// We don't really know if the pool is suspended or not, since it doesn't exist.
    		return false
    	}
    	return p.Pools[idx].Decommission != nil
    }
    
    func (p *poolMeta) validate(pools []*erasureSets) (bool, error) {
    	type poolInfo struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    		if parityOrig != parityDrives {
    			userDefined[minIOErasureUpgraded] = strconv.Itoa(parityOrig) + "->" + strconv.Itoa(parityDrives)
    		}
    	}
    
    	dataDrives := len(onlineDisks) - parityDrives
    
    	// we now know the number of blocks this object needs for data and parity.
    	// establish the writeQuorum using this data
    	writeQuorum := dataDrives
    	if dataDrives == parityDrives {
    		writeQuorum++
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

      }
    
      /**
       * Returns true when all work currently in progress by the watchdog have completed. This method
       * creates more work for the watchdog and waits for that work to be executed. When it is, we know
       * work that preceded this call is complete.
       */
      private fun awaitWatchdogIdle() {
        val latch = CountDownLatch(1)
        val watchdogJob: AsyncTimeout =
          object : AsyncTimeout() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Futures.java

       * the computation -- makes sense, and if we don't convert it, the user still has to write a
       * try-catch block.
       *
       * If you think you would use this method, let us know. You might also look into the
       * Fork-Join framework: http://docs.oracle.com/javase/tutorial/essential/concurrency/forkjoin.html
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/net/InetAddresses.java

       *
       * <p>{@link InetAddress#getByAddress} is documented as throwing a checked exception "if IP
       * address is of illegal length." We replace it with an unchecked exception, for use by callers
       * who already know that addr is an array of length 4 or 16.
       *
       * @param addr the raw 4-byte or 16-byte IP address in big-endian order
       * @return an InetAddress object created from the raw IP address
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  7. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

                    }
                }
            } else if (userSuppliedConfigurationProcessorCount > 1) {
                //
                // There are too many ConfigurationProcessors so we don't know which one to run so report the error.
                //
                StringBuilder sb = new StringBuilder(String.format(
                        "%nThere can only be one user supplied ConfigurationProcessor, there are %s:%n%n",
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 76.8K bytes
    - Viewed (0)
  8. cmd/bucket-handlers.go

    			// This is not for our server, so we can continue
    			continue
    		}
    
    		wg.Add(1)
    		go func(bucket string) {
    			defer wg.Done()
    			// We go to here, so we know the bucket no longer exists,
    			// but is registered in DNS to this server
    			if err := globalDNSConfig.Delete(bucket); err != nil {
    				dnsLogIf(GlobalContext, fmt.Errorf("Failed to remove DNS entry for %s due to %w",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/Maps.java

       * must be well-behaved with respect to {@link Object#equals} and {@link Object#hashCode}.
       *
       * <p><b>Note:</b>If you only need to know whether two maps have the same mappings, call {@code
       * left.equals(right)} instead of this method.
       *
       * @param left the map to treat as the "left" map for purposes of comparison
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 161.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/Maps.java

       * must be well-behaved with respect to {@link Object#equals} and {@link Object#hashCode}.
       *
       * <p><b>Note:</b>If you only need to know whether two maps have the same mappings, call {@code
       * left.equals(right)} instead of this method.
       *
       * @param left the map to treat as the "left" map for purposes of comparison
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 167.4K bytes
    - Viewed (0)
Back to top