Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 313 for caliper (0.07 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

       * hosting filesystem becomes unreachable, the iterator will omit elements rather than throwing
       * exceptions.
       *
       * **The caller must [close][Snapshot.close]** each snapshot returned by [Iterator.next]. Failing
       * to do so leaks open files!
       */
      @Synchronized
      @Throws(IOException::class)
      fun snapshots(): MutableIterator<Snapshot> {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/reflect/ClassPath.java

         * manifest entry is already in {@code scannedFiles}, either because it was scanned earlier, or
         * it was intentionally added to the set by the caller, it will not be scanned again.
         *
         * <p>Note that when you call {@code location.scanResources(scannedFiles)}, the location will
         * always be scanned even if {@code scannedFiles} already contains it.
         */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jan 05 17:43:40 UTC 2022
    - 24.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/RateLimiter.java

      private boolean canAcquire(long nowMicros, long timeoutMicros) {
        return queryEarliestAvailable(nowMicros) - timeoutMicros <= nowMicros;
      }
    
      /**
       * Reserves next ticket and returns the wait time that the caller must wait for.
       *
       * @return the required wait time, never negative
       */
      final long reserveAndGetWaitLength(int permits, long nowMicros) {
        long momentAvailable = reserveEarliestAvailable(permits, nowMicros);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  4. internal/s3select/sql/value.go

    		if err != nil {
    			return err
    		}
    		v.setTimestamp(t)
    	}
    	return nil
    }
    
    // inferTypeAsString is used to convert untyped values to string - it
    // is called when the caller requires a string context to proceed.
    func inferTypeAsString(v *Value) {
    	b, ok := v.ToBytes()
    	if !ok {
    		return
    	}
    
    	v.setString(string(b))
    }
    
    func isValidComparisonOperator(op string) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Feb 25 20:31:19 UTC 2022
    - 20.2K bytes
    - Viewed (0)
  5. cmd/admin-heal-ops.go

    		} else {
    			h.countFailed(healType)
    		}
    		if !h.reportProgress {
    			if errors.Is(res.err, errSkipFile) { // this is only sent usually by nopHeal
    				return nil
    			}
    
    			// Report caller of any failure
    			return res.err
    		}
    		res.result.Type = healType
    		if res.err != nil {
    			res.result.Detail = res.err.Error()
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  6. cmd/iam-object-store.go

    			}
    			policyDocs[index] = policyDoc
    			return nil
    		}, index)
    	}
    
    	err := errors.Join(g.Wait()...)
    	return policyDocs, err
    }
    
    // Assumes cache is locked by caller.
    func (iamOS *IAMObjectStore) loadAllFromObjStore(ctx context.Context, cache *iamCache, firstTime bool) error {
    	bootstrapTraceMsgFirstTime := func(s string) {
    		if firstTime {
    			bootstrapTraceMsg(s)
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/MoreExecutors.java

       * {@code invokeAny}. In the latter case, tasks will run serially on the calling thread. Tasks are
       * run to completion before a {@code Future} is returned to the caller (unless the executor has
       * been shutdown).
       *
       * <p>Although all tasks are immediately executed in the thread that submitted the task, this
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    func (s *xlStorage) ReadAll(ctx context.Context, volume string, path string) (buf []byte, err error) {
    	// Specific optimization to avoid re-read from the drives for `format.json`
    	// in-case the caller is a network operation.
    	if volume == minioMetaBucket && path == formatConfigFile {
    		s.RLock()
    		formatData := make([]byte, len(s.formatData))
    		copy(formatData, s.formatData)
    		s.RUnlock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  9. src/archive/tar/common.go

    		}
    	}
    	if sysStat != nil {
    		return h, sysStat(fi, h, doNameLookups)
    	}
    	return h, nil
    }
    
    // FileInfoNames extends [fs.FileInfo].
    // Passing an instance of this to [FileInfoHeader] permits the caller
    // to avoid a system-dependent name lookup by specifying the Uname and Gname directly.
    type FileInfoNames interface {
    	fs.FileInfo
    	// Uname should give a user name.
    	Uname() (string, error)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 13 21:03:27 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2.go

    }
    
    // xlMetaV2Version describes the journal entry, Type defines
    // the current journal entry type other types might be nil based
    // on what Type field carries, it is imperative for the caller
    // to verify which journal type first before accessing rest of the fields.
    type xlMetaV2Version struct {
    	Type             VersionType           `json:"Type" msg:"Type"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
Back to top