Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1001 - 1010 of 1,026 for Access (0.12 sec)

  1. cmd/erasure-object.go

    	}
    
    	var (
    		modTime     time.Time
    		etag        string
    		fi          FileInfo
    		onlineMeta  []FileInfo
    		onlineDisks []StorageAPI
    		err         error
    	)
    
    	for success := range done {
    		totalResp++
    		if success {
    			validResp++
    		}
    
    		if totalResp >= minDisks && opts.FastGetObjInfo {
    			rw.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  2. istioctl/pkg/analyze/analyze.go

    			output, err := formatting.Print(outputMessages, msgOutputFormat, colorize)
    			if err != nil {
    				return err
    			}
    			fmt.Fprintln(cmd.OutOrStdout(), output)
    
    			// An extra message on success
    			if len(outputMessages) == 0 {
    				if parseErrors == 0 {
    					if len(readers) > 0 {
    						var files []string
    						for _, r := range readers {
    							files = append(files, r.Name)
    						}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 31 06:53:50 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/ImmutableRangeSet.java

        }
    
        @Override
        public boolean contains(@CheckForNull Object o) {
          if (o == null) {
            return false;
          }
          try {
            @SuppressWarnings("unchecked") // we catch CCE's
            C c = (C) o;
            return ImmutableRangeSet.this.contains(c);
          } catch (ClassCastException e) {
            return false;
          }
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 27K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/FluentFuture.java

          Function<? super V, T> function, Executor executor) {
        return (FluentFuture<T>) Futures.transform(this, function, executor);
      }
    
      /**
       * Registers separate success and failure callbacks to be run when this {@code Future}'s
       * computation is {@linkplain java.util.concurrent.Future#isDone() complete} or, if the
       * computation is already complete, immediately.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  5. cmd/erasure-multipart.go

    			// did not do anything.
    			return pi, IncompleteBody{Bucket: bucket, Object: object}
    		}
    
    		return pi, toObjectErr(err, minioMetaMultipartBucket, partPath)
    	}
    
    	// Return success.
    	return PartInfo{
    		PartNumber:     partInfo.Number,
    		ETag:           partInfo.ETag,
    		LastModified:   partInfo.ModTime,
    		Size:           partInfo.Size,
    		ActualSize:     partInfo.ActualSize,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

        // If the server returned an illegal server_max_window_bits, fail the web socket.
        if (serverMaxWindowBits != null && serverMaxWindowBits !in 8..15) return false
    
        // Success.
        return true
      }
    
      @Throws(IOException::class)
      internal fun checkUpgradeSuccess(
        response: Response,
        exchange: Exchange?,
      ) {
        if (response.code != 101) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

                // while that underlying work is still running.
                //
                // So that is why we cancel only in the case of CAS success.
                taskFuture.cancel(false);
              }
            };
        // Adding the listener to both futures guarantees that newFuture will always be set. Adding to
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  8. cmd/erasure-metadata.go

    			objInfo.RestoreExpires, _ = restoreStatus.Expiry()
    		}
    	}
    	objInfo.Checksum = fi.Checksum
    	objInfo.decryptPartsChecksums(nil)
    	objInfo.Inlined = fi.InlineData()
    	// Success.
    	return objInfo
    }
    
    // TransitionInfoEquals returns true if transition related information are equal, false otherwise.
    func (fi FileInfo) TransitionInfoEquals(ofi FileInfo) bool {
    	switch {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  9. cmd/format-erasure.go

    		return nil, err
    	}
    
    	if heal {
    		info, err := disk.DiskInfo(context.Background(), DiskInfoOptions{NoOp: heal})
    		if err != nil {
    			return nil, err
    		}
    		format.Info = info
    	}
    
    	// Success.
    	return format, nil
    }
    
    // Valid formatErasure basic versions.
    func checkFormatErasureValue(formatErasure *formatErasureV3, disk StorageAPI) error {
    	// Validate format version and format type.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  10. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

                    buff.debug("debug").a(' ');
                    buff.info("info").a(' ');
                    buff.warning("warning").a(' ');
                    buff.error("error").a(' ');
                    buff.success("success").a(' ');
                    buff.failure("failure").a(' ');
                    buff.strong("strong").a(' ');
                    buff.mojo("mojo").a(' ');
                    buff.project("project");
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 76.8K bytes
    - Viewed (0)
Back to top