Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 281 for safely (0.06 seconds)

  1. cmd/erasure-object.go

    	m, ok := isObjectDangling(metaArr, errs, dataErrsByPart)
    	if !ok {
    		// We only come here if we cannot figure out if the object
    		// can be deleted safely, in such a scenario return ReadQuorum error.
    		return FileInfo{}, errErasureReadQuorum
    	}
    	tags := make(map[string]string, 16)
    	tags["set"] = strconv.Itoa(er.setIndex)
    	tags["pool"] = strconv.Itoa(er.poolIndex)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/Streams.java

       * stream whose elements are non-null. However, the method goes out of its way to still handle
       * nulls in the stream. This means that the method can safely be used with a stream that contains
       * nulls as long as the *last* element is *not* null.
       *
       * (To "go out of its way," the method tracks a `set` bit so that it can distinguish "the final
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 36.4K bytes
    - Click Count (0)
  3. guava/src/com/google/common/io/BaseEncoding.java

     * <td>1.33
     * <td>=
     * <td>
     * <tr>
     * <td>{@link #base64Url()}
     * <td>A-Z a-z 0-9 - _
     * <td>1.33
     * <td>=
     * <td>Safe to use as filenames, or to pass in URLs without escaping
     * </table>
     *
     * <p>All instances of this class are immutable, so they may be stored safely as static constants.
     *
     * @author Louis Wasserman
     * @since 14.0
     */
    @GwtCompatible
    public abstract class BaseEncoding {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Oct 06 14:51:47 GMT 2025
    - 41.7K bytes
    - Click Count (0)
  4. cmd/server-main.go

    	}
    
    	// Create new bucket metadata system.
    	if globalBucketMetadataSys == nil {
    		globalBucketMetadataSys = NewBucketMetadataSys()
    	} else {
    		// Reinitialize safely when testing.
    		globalBucketMetadataSys.Reset()
    	}
    
    	// Create the bucket bandwidth monitor
    	globalBucketMonitor = bandwidth.NewMonitor(ctx, uint64(totalNodeCount()))
    
    	// Create a new config system.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
  5. CHANGELOG.md

    The rest of this release is our highest-quality release yet. Though we continue to use the word
    _alpha_ in the version name, the only unstable thing in it is some non-final APIs tagged
    `@ExperimentalOkHttpApi`. You can safely use this release in production.
    
     *  Fix: Attempt to read the response even if sending the request failed. This makes it possible
        to handle response statuses like `HTTP/1.1 431 "Request Header Fields Too Large`.
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 05 16:02:59 GMT 2025
    - 36.2K bytes
    - Click Count (2)
  6. android/guava/src/com/google/common/net/InetAddresses.java

       *
       * <p>As long as there are applications that assume that all IP addresses are IPv4 addresses and
       * can therefore be converted safely to integers (for whatever purpose) this function can be used
       * to handle IPv6 addresses as well until the application is suitably fixed.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 47.4K bytes
    - Click Count (0)
  7. cmd/erasure-multipart.go

    	// Wait for all renames to finish.
    	errs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	if err != nil {
    		er.cleanupMultipartPath(ctx, paths...)
    	}
    
    	// We can safely allow RenameFile errors up to len(er.getDisks()) - writeQuorum
    	// otherwise return failure. Cleanup successful renames.
    	return evalDisks(disks, errs), err
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/Futures.java

      // propagate to the input. Cancellation propagation is fundamentally racy so this is fine.
      //
      // Future versions of the JMM may revise safe construction semantics in such a way that we can
      // safely publish these objects and we won't need this whole discussion.
      // TODO(user,lukes): consider adding volatile to all these fields since in current known JVMs
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 64.3K bytes
    - Click Count (0)
  9. internal/grid/connection.go

    	}
    }
    
    func (c *Connection) handleConnectMux(ctx context.Context, m message, subID *subHandlerID) {
    	// Stateless stream:
    	if m.Flags&FlagStateless != 0 {
    		// Reject for now, so we can safely add it later.
    		if true {
    			gridLogIf(ctx, c.queueMsg(m, muxConnectError{Error: "Stateless streams not supported"}))
    			return
    		}
    
    		var handler *StatelessHandler
    		if subID == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/collect/Maps.java

          return fromMap.containsKey(key);
        }
    
        // safe as long as the user followed the <b>Warning</b> in the javadoc
        @SuppressWarnings("unchecked")
        @Override
        public @Nullable V2 get(@Nullable Object key) {
          V1 value = fromMap.get(key);
          if (value != null || fromMap.containsKey(key)) {
            // The cast is safe because of the containsKey check.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 23 17:50:58 GMT 2025
    - 157.6K bytes
    - Click Count (0)
Back to Top