- Sort Score
- Result 10 results
- Languages All
Results 381 - 390 of 652 for runes (0.02 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
val capacityWithoutIt = addressState.concurrentCallCapacity - connection.allocationLimit return capacityWithoutIt >= addressState.policy.minimumConcurrentCalls } /** * Prunes any leaked calls and then returns the number of remaining live calls on [connection]. * Calls are leaked if the connection is tracking them but the application code has abandoned
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 16.2K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.h
// supported on embedded on mobile and embedded platforms and will fail if // called. // // Pass "library_filename" to a platform-specific mechanism for dynamically // loading a library. The rules for determining the exact location of the // library are platform-specific and are not documented here. // // On success, returns the newly created library handle and places OK in status. // The caller owns the library handle.
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 15.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java
/** * Tests that the {@code ClassLoader} of {@link FinalizableReferenceQueue} can be unloaded. These * tests are separate from {@link FinalizableReferenceQueueTest} so that they can be excluded from * coverage runs, as the coverage system interferes with them. * * @author Eamonn McManus */ public class FinalizableReferenceQueueClassLoaderUnloadingTest extends TestCase { /*
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 13.3K bytes - Viewed (0) -
cni/pkg/cmd/root.go
SilenceUsage: true, PreRunE: func(c *cobra.Command, args []string) error { if err := istiolog.Configure(logOptions); err != nil { log.Errorf("Failed to configure log %v", err) } return nil }, RunE: func(c *cobra.Command, args []string) (err error) { ctx := c.Context() // Start controlz server _, _ = ctrlz.Run(ctrlzOptions, nil) var cfg *config.Config if cfg, err = constructConfig(); err != nil {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Aug 16 15:33:47 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/prepare-storage.go
// |__ 33a58b40-aecc-4c9f-a22f-ff17bfa33b62 // |__ e870a2c1-d09c-450c-a69c-6eaa54a89b3e // // In this example, `33a58b40-aecc-4c9f-a22f-ff17bfa33b62` directory contains // temporary objects from one of the previous runs of minio server. tmpID := mustGetUUID() tmpOld := pathJoin(diskPath, minioMetaTmpBucket+"-old", tmpID) if err := renameAll(pathJoin(diskPath, minioMetaTmpBucket),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
istioctl/pkg/metrics/metrics_test.go
return nil, nil, nil } func (client mockPromAPI) Snapshot(ctx context.Context, skipHead bool) (promv1.SnapshotResult, error) { return promv1.SnapshotResult{}, nil } func (client mockPromAPI) Rules(ctx context.Context) (promv1.RulesResult, error) { return promv1.RulesResult{}, nil } func (client mockPromAPI) Targets(ctx context.Context) (promv1.TargetsResult, error) { return promv1.TargetsResult{}, nil }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Aug 16 01:35:47 UTC 2024 - 8K bytes - Viewed (0) -
tensorflow/c/c_api_internal.h
}; struct TF_Library { void* lib_handle; TF_Buffer op_list; }; struct TF_Graph { TF_Graph(); mutable tensorflow::mutex mu; tensorflow::Graph graph TF_GUARDED_BY(mu); // Runs shape inference. tensorflow::ShapeRefiner refiner TF_GUARDED_BY(mu); // Maps from name of an operation to the Node* in 'graph'. std::unordered_map<tensorflow::string, tensorflow::Node*> name_map TF_GUARDED_BY(mu);
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat May 13 00:49:12 UTC 2023 - 7.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
taskFaker.runTasks() assertThat(log).isEmpty() // At 100.µs, the coordinator runs the red task and starts a thread for the new coordinator. taskFaker.advanceUntil(100.µs) assertThat(log).containsExactly("red:run@100000") assertThat(taskFaker.executeCallCount).isEqualTo(2) // At 200.µs, the blue task runs. taskFaker.advanceUntil(200.µs)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FluentFuture.java
* means the cause of the {@link ExecutionException} thrown by {@code this.get()} or, if * {@code get()} throws a different kind of exception, that exception itself. * @param executor the executor that runs {@code fallback} if the input fails */ @J2ktIncompatible @Partially.GwtIncompatible("AVAILABLE but requires exceptionType to be Throwable.class") public final <X extends Throwable> FluentFuture<V> catching(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 19.6K bytes - Viewed (0) -
.github/workflows/update-rbe.yml
# to reference the most recent versions of the SIG Build Docker images. name: Update RBE Configs on: workflow_dispatch: permissions: contents: read jobs: rbe: name: Update RBE Configs runs-on: ubuntu-latest if: github.repository == 'tensorflow/tensorflow' # Don't do this in forks steps: - name: Checkout code uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4.2.2
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Fri Nov 01 08:40:10 UTC 2024 - 7.2K bytes - Viewed (0)