- Sort Score
- Num 10 results
- Language All
Results 111 - 120 of 526 for loom (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/util/concurrent/ForwardingCondition.java
import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Condition; /** Forwarding wrapper around a {@code Condition}. */ @SuppressWarnings("WaitNotInLoop") // We are just delegating; _our user_ must loop. @J2ktIncompatible @GwtIncompatible abstract class ForwardingCondition implements Condition { abstract Condition delegate(); @Override public void await() throws InterruptedException {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 24 18:55:30 GMT 2025 - 1.8K bytes - Click Count (0) -
CONTRIBUTING.md
to ask any questions. ## Finding issues to work on If you are looking for good first issues, take a look at the list of [good first issues](https://github.com/gradle/gradle/labels/good%20first%20issue) that should be actionable and ready for a contribution.
Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Mar 27 18:43:39 GMT 2026 - 19.1K bytes - Click Count (0) -
android/guava/src/com/google/common/primitives/UnsignedBytes.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 16:38:16 GMT 2026 - 21K bytes - Click Count (0) -
cmd/callhome.go
// will keep performing the callhome. If the leader goes down for some reason, // the lock will be released and another node will acquire it and take over // because of this loop. for { if !globalCallhomeConfig.Enabled() { return } if !runCallhome(ctx, objAPI) { // callhome was disabled or context was canceled return }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
cmd/format-erasure_test.go
for j := range setDriveCount { newFormat := format.Clone() newFormat.Erasure.This = format.Erasure.Sets[i][j] formats[i*setDriveCount+j] = newFormat } } b.ReportAllocs() for b.Loop() { _, _ = getFormatErasureInQuorumOld(formats) } } func BenchmarkGetFormatErasureInQuorum(b *testing.B) { setCount := 200 setDriveCount := 15Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.7K bytes - Click Count (0) -
internal/s3select/json/preader_test.go
f, err := os.ReadFile(filepath.Join("testdata", file.Name())) if err != nil { b.Fatal(err) } b.SetBytes(int64(len(f))) b.ReportAllocs() b.ResetTimer() var record sql.Record for b.Loop() { r := NewPReader(io.NopCloser(bytes.NewBuffer(f)), &ReaderArgs{}) for { record, err = r.Read(record) if err != nil { break } } r.Close() if err != io.EOF {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 2.5K bytes - Click Count (0) -
internal/s3select/json/reader_test.go
f, err := os.ReadFile(filepath.Join("testdata", file.Name())) if err != nil { b.Fatal(err) } b.SetBytes(int64(len(f))) b.ReportAllocs() b.ResetTimer() var record sql.Record for b.Loop() { r := NewReader(io.NopCloser(bytes.NewBuffer(f)), &ReaderArgs{}) for { record, err = r.Read(record) if err != nil { break } } r.Close() if err != io.EOF {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 2.4K bytes - Click Count (0) -
tensorflow/c/checkpoint_reader.h
// Returns a map from variable names to their data types. Slices of a // partitioned tensor are combined into a single entry. const TensorSliceReader::VarToDataTypeMap& GetVariableToDataTypeMap() const; // Attempts to look up the tensor named "name" and stores the found result in // "out_tensor". void GetTensor(const std::string& name, std::unique_ptr<tensorflow::Tensor>* out_tensor,
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Wed Jan 07 04:56:09 GMT 2026 - 3.1K bytes - Click Count (0) -
android/guava/src/com/google/common/io/ReaderInputStream.java
result = encoder.flush(byteBuffer); } else { result = encoder.encode(charBuffer, byteBuffer, endOfInput); } if (result.isOverflow()) { // Not enough room in output buffer--drain it, creating a bigger buffer if necessary. startDraining(true); continue DRAINING; } else if (result.isUnderflow()) { // If encoder underflows, it means either:
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Apr 14 16:36:11 GMT 2025 - 9.3K bytes - Click Count (0) -
helm/minio/templates/_helper_create_policy.txt
MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys.Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Mar 21 06:38:06 GMT 2023 - 2K bytes - Click Count (0)