- Sort Score
- Result 10 results
- Languages All
Results 391 - 400 of 946 for CALL (0.03 sec)
-
ci/official/requirements_updater/README.md
`requirements_lock_3_12.txt` for `Python 3.12`). To update the lock files, make sure `ci/official/requirements_updater/requirements.in` contains the desired direct dependencies list and then execute the following command (which will call [pip-compile](https://pypi.org/project/pip-tools/) under the hood): ``` bazel run //ci/official/requirements_updater:requirements.update --repo_env=HERMETIC_PYTHON_VERSION=3.12 ```
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Jun 29 00:19:18 UTC 2024 - 3K bytes - Viewed (0) -
cmd/healthcheck-handler.go
// return how many drives are being healed if any if result.HealingDrives > 0 { w.Header().Set(xhttp.MinIOHealingDrives, strconv.Itoa(result.HealingDrives)) } if !result.Healthy { // As a maintenance call we are purposefully asked to be taken // down, this is for orchestrators to know if we can safely // take this server down, return appropriate error. if opts.Maintenance {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 26 07:44:34 UTC 2024 - 6.9K bytes - Viewed (0) -
tensorflow/c/eager/gradients.h
// onto its internal state after a call to `ComputeGradient`. using GradientTape<AbstractTensorHandle, GradientFunction, TapeTensor>::IsPersistent; // Adds this tensor to the list of watched tensors. // // This is a no-op if the tensor is already being watched either from an // earlier call to `GradientTape::Watch` or being an output of an op with // watched inputs.
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/naughty-disk_test.go
// Programmed errors are stored in errors field. type naughtyDisk struct { // The real disk disk StorageAPI // Programmed errors: API call number => error to return errors map[int]error // The error to return when no error value is programmed defaultErr error // The current API call number callNR int // Data protection mu sync.Mutex }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 10.1K bytes - Viewed (0) -
internal/grid/muxserver.go
msg.setZeroPayloadFlag() m.send(msg) return } msg.Payload = payload msg.setZeroPayloadFlag() m.send(msg) } } // handleRequests will handle the requests from the client and call the handler function. func (m *muxServer) handleRequests(ctx context.Context, msg message, send chan<- []byte, handler StreamHandler, handlerIn <-chan []byte) (handlerErr *RemoteErr) { start := time.Now() defer func() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
boolean run = false; @Override public void run() { run = true; } } private static class TestCallable implements Callable<String> { @Override public String call() { return "foo"; } } /** Simple same thread listening executor service that doesn't handle shutdown. */ private static class TestListeningExecutorService extends AbstractListeningExecutorService {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.2K bytes - Viewed (0) -
internal/once/init.go
// initialized when the provided function returns nil. // Init represents the structure. type Init struct { done uint32 m sync.Mutex } // Do is similar to sync.Once.Do - makes one successful // call to the function. ie, it invokes the function // if it is not successful yet. func (l *Init) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.do(f) } return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 09 04:20:31 UTC 2023 - 2.1K bytes - Viewed (0) -
internal/ringbuffer/README.md
Either side can use `rb.CloseWithError(err error)` to signal an error and close the ring buffer. Any reads or writes will return the error on next call.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
boolean run = false; @Override public void run() { run = true; } } private static class TestCallable implements Callable<String> { @Override public String call() { return "foo"; } } /** Simple same thread listening executor service that doesn't handle shutdown. */ private static class TestListeningExecutorService extends AbstractListeningExecutorService {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.2K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/InvalidatableSet.java
this.delegate = delegate; this.validator = validator; this.errorMessage = errorMessage; } // Override hashCode() to access delegate directly (so that it doesn't trigger the validate() call // via delegate()); it seems inappropriate to throw ISE on this method. @Override public int hashCode() { return delegate.hashCode(); } private void validate() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jan 22 17:29:38 UTC 2024 - 1.8K bytes - Viewed (0)