- Sort Score
- Result 10 results
- Languages All
Results 361 - 370 of 594 for ensures (0.09 sec)
-
internal/logger/target/kafka/kafka.go
sconfig.Net.TLS.Config.InsecureSkipVerify = h.kconfig.TLS.SkipVerify sconfig.Net.TLS.Config.ClientAuth = h.kconfig.TLS.ClientAuth sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs // These settings are needed to ensure that kafka client doesn't hang on brokers // refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 sconfig.Producer.Retry.Max = 2 sconfig.Producer.Retry.Backoff = (10 * time.Second)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
README.md
service iptables restart ``` ## Test MinIO Connectivity ### Test using MinIO Console MinIO Server comes with an embedded web based object browser. Point your web browser to <http://127.0.0.1:9000> to ensure your server has started successfully. > NOTE: MinIO runs console on random port by default, if you wish to choose a specific port use `--console-address` to pick a specific interface and port. ### Things to consider
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:34:11 UTC 2024 - 18.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
fun scheduleOpener(address: Address) { addressStates[address]?.scheduleOpener() } fun scheduleCloser() { cleanupQueue.schedule(cleanupTask) } /** * Ensure enough connections open to [address] to satisfy its [ConnectionPool.AddressPolicy]. * If there are already enough connections, we're done. * If not, we create one and then schedule the task to run again immediately. */
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
// Sets XLA's minimum cluster size. This has global effect. TF_CAPI_EXPORT void TF_SetXlaMinClusterSize(int size); // Gets/Sets TF/XLA flag for whether(true) or not(false) to disable constant // folding. This is for testing to ensure that XLA is being tested rather than // Tensorflow's CPU implementation through constant folding. TF_CAPI_EXPORT unsigned char TF_GetXlaConstantFoldingDisabled(); TF_CAPI_EXPORT void TF_SetXlaConstantFoldingDisabled(
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 15.1K bytes - Viewed (0) -
cmd/xl-storage-meta-inline.go
if err != nil { return fmt.Errorf("xlMetaInlineData: %w", err) } } return nil } // repair will copy all seemingly valid data entries from a corrupted set. // This does not ensure that data is correct, but will allow all operations to complete. func (x *xlMetaInlineData) repair() { data := *x if len(data) == 0 { return } if !data.versionOK() { *x = nil return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 9.5K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
value = other.value; throwable = other.throwable; // don't copy the mayInterruptIfRunning bit, for consistency with the server, to ensure that // interruptTask() is called if and only if the bit is true and because we cannot infer the // interrupt status from non AbstractFuture futures. state = other.state;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jan 22 19:37:41 UTC 2024 - 12.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
+ "the fact that the shadowed ReadLock and WriteLock are never used or " + "exposed by the superclass implementation. If the implementation has " + "changed, the code must be re-inspected to ensure that the " + "assumption is still valid.", 24, ReentrantReadWriteLock.class.getMethods().length); } private enum MyOrder { FIRST, SECOND, THIRD; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
+ "the fact that the shadowed ReadLock and WriteLock are never used or " + "exposed by the superclass implementation. If the implementation has " + "changed, the code must be re-inspected to ensure that the " + "assumption is still valid.", 24, ReentrantReadWriteLock.class.getMethods().length); } private enum MyOrder { FIRST, SECOND, THIRD; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.1K bytes - Viewed (0) -
README.md
desired TensorFlow version, for example, branch `r2.8` for version 2.8. * Apply (that is, cherry-pick) the desired changes and resolve any code conflicts. * Run TensorFlow tests and ensure they pass. * [Build](https://www.tensorflow.org/install/source) the TensorFlow pip package from source. ## Continuous build status You can find more community-supported platforms and configurations in the
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Oct 05 15:00:10 UTC 2023 - 11.9K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
c.queue.Run(stop) c.pods.ShutdownHandlers() } func (c *Controller) Reconcile(key types.NamespacedName) error { pod := c.pods.Get(key.Name, key.Namespace) if pod == nil { delete(c.repairedPods, key) // Ensure we do not leak // Pod deleted, nothing to do return nil } return c.ReconcilePod(pod) } func (c *Controller) ReconcilePod(pod *corev1.Pod) (err error) { if !c.matchesFilter(pod) {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0)