- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 636 for Calling (0.16 sec)
-
pkg/kubelet/cm/dra/plugin/client.go
logger.V(4).Info(log("calling NodePrepareResources rpc"), "request", req) conn, err := p.getOrCreateGRPCConn() if err != nil { return nil, err } ctx, cancel := context.WithTimeout(ctx, p.clientTimeout) defer cancel() nodeClient := drapb.NewNodeClient(conn) response, err := nodeClient.NodePrepareResources(ctx, req)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 16:27:05 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/proxy/config/config.go
c.logger.V(3).Info("Calling handler.OnServiceSynced()") c.eventHandlers[i].OnServiceSynced() } } func (c *ServiceConfig) handleAddService(obj interface{}) { service, ok := obj.(*v1.Service) if !ok { utilruntime.HandleError(fmt.Errorf("unexpected object type: %v", obj)) return } for i := range c.eventHandlers { c.logger.V(4).Info("Calling handler.OnServiceAdd")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 15.1K bytes - Viewed (0) -
platforms/core-configuration/configuration-problems-base/src/main/kotlin/org/gradle/internal/configuration/problems/ProblemFactory.kt
interface ProblemFactory { /** * Returns a default location inferred from the calling thread's state. */ fun locationForCaller(consumer: String? = null): PropertyTrace /** * Creates a problem with the given message and exception. * * Problem has no documentation, and a default location is inferred from the calling thread's state. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 21:59:50 UTC 2024 - 2.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/resolver/ResolutionAccess.java
*/ public interface ResolutionAccess { /** * Get the owner of the resolution. */ ResolutionHost getHost(); /** * Get the request attributes for this resolution. Calling this method will lock-in the * request attributes from further mutation but will not perform resolution. */ ImmutableAttributes getAttributes(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:36:01 UTC 2024 - 2K bytes - Viewed (0) -
subprojects/core-api/src/main/java/org/gradle/api/provider/ListProperty.java
/** * {@inheritDoc} * * <p> * This is similar to calling {@link #value(Iterable)} with a <code>null</code> argument. * </p> */ @Override ListProperty<T> unset(); /** * {@inheritDoc} * * <p> * This is similar to calling {@link #convention(Iterable)} with a <code>null</code> argument. * </p> */ @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 16:06:55 UTC 2024 - 2.2K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/model/CalculatedModelValue.java
/** * Updates the current value. The function is passed the current value or {@code null} if there is no value, and the function's return value is * used as the new value. * * <p>The calling thread must own the mutable state from which the value is calculated (via {@link ModelContainer#fromMutableState(Function)}). At most a single thread
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 08:26:24 UTC 2024 - 2.4K bytes - Viewed (0) -
src/iter/pull_test.go
} // Make sure we don't panic again if we try to call next or stop. if _, ok := next(); ok { t.Fatal("next returned true after iterator panicked") } // Calling stop again should be a no-op. stop() }) t.Run("stop", func(t *testing.T) { next, stop := Pull(panicCleanupSeq()) x, ok := next() if !ok || x != 55 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:28 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/object_api_suite_test.go
data []byte } func (r *testOneByteReadNoEOF) Read(p []byte) (n int, err error) { if r.eof { return 0, io.EOF } n = copy(p, r.data) r.eof = true return n, nil } // Wrapper for calling testMakeBucket for both Erasure and FS. func TestMakeBucket(t *testing.T) { ExecObjectLayerTest(t, testMakeBucket) } // Tests validate bucket creation.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 33.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/FileLockManager.java
@ServiceScope(Scope.Global.class) public interface FileLockManager { /** * Creates a lock for the given file with the given mode. Acquires a lock with the given mode, which is held until the lock is * released by calling {@link FileLock#close()}. This method blocks until the lock can be acquired. * * @param target The file to be locked. * @param options The lock options.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/volume/csi/csi_client_test.go
c.t.Log("calling fake.NodeUnstageVolume...") req := &csipbv1.NodeUnstageVolumeRequest{ VolumeId: volID, StagingTargetPath: stagingTargetPath, } _, err := c.nodeClient.NodeUnstageVolume(ctx, req) return err } func (c *fakeCsiDriverClient) NodeSupportsNodeExpand(ctx context.Context) (bool, error) { c.t.Log("calling fake.NodeSupportsNodeExpand...")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.9K bytes - Viewed (0)