- Sort Score
- Result 10 results
- Languages All
Results 421 - 430 of 594 for ensures (0.06 sec)
-
src/main/java/jcifs/netbios/NameServiceClientImpl.java
/* * Yes, there is the potential to drop packets * because we might close the socket during a * request. However the chances are slim and the * retry code should ensure the overall request * is serviced. The alternative complicates things * more than I think is worth it. */ if ( this.socket != null ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Aug 14 14:26:22 UTC 2022 - 38.2K bytes - Viewed (0) -
guava/src/com/google/common/io/CharSource.java
* as bytes using the given {@link Charset}. * * <p>If {@link ByteSource#asCharSource} is called on the returned source with the same charset, * the default implementation of this method will ensure that the original {@code CharSource} is * returned, rather than round-trip encoding. Subclasses that override this method should behave * the same way. * * @since 20.0 */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 25.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/MoreFilesTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 16:07:00 UTC 2024 - 26.5K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
throw new ResourceDoesNotExistException("Downloaded file does not exist: " + temp); } // The temporary file is named destination + ".tmp" and is done this way to ensure // that the temporary file is in the same file system as the destination because the // File.renameTo operation doesn't really work across file systems.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 29.9K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErrWithErr(ErrReplicationValidationError, fmt.Errorf("s3:ReplicateDelete permissions missing for replication user: %w", err)), r.URL) return } // fake a versioned delete - to ensure deny policies are not in place err = c.RemoveObject(ctx, clnt.Bucket, obj, minio.RemoveObjectOptions{ VersionID: ui.VersionID, Internal: minio.AdvancedRemoveOptions{ ReplicationDeleteMarker: false,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 23.3K bytes - Viewed (0) -
cmd/generic-handlers.go
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { if origin := w.Header().Get("Access-Control-Allow-Origin"); origin == "null" { // This is a workaround change to ensure that "Origin: null" // incoming request to a response back as "*" instead of "null" w.Header().Set("Access-Control-Allow-Origin", "*") } if globalDNSConfig == nil || !globalBucketFederation ||
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 20.5K bytes - Viewed (0) -
src/test/java/jcifs/tests/EnumTest.java
// only do this if a WINS server is enabled getRequiredProperty("jcifs.netbios.wins"); CIFSContext bctx = withAnonymousCredentials(); // ensure that the domain name gets resolved through WINS so that // it gets the workgroup type. CIFSContext ctx = withConfig(bctx, new DelegatingConfiguration(bctx.getConfig()) { @Override
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Thu Jan 05 13:09:03 UTC 2023 - 25.5K bytes - Viewed (0) -
tensorflow/c/eager/c_api_distributed_test.cc
}; // After the graph pass is registered, it takes effect globally and can affect // other test cases. Define a static variable to switch it on and off. bool GraphErrorInjectionPass::enabled_ = false; // Test to ensure that a registered graph optimization pass is only executed // once (i.e., on the main function side) in running distributed functions. // This test creates a cluster with two workers, create a variable on the
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 23.4K bytes - Viewed (0) -
docs/bucket/replication/README.md
- Active-Active replication - Multi destination replication ## How to use? Ensure that versioning is enabled on the source and target buckets with `mc version` command. If object locking is required, the buckets should have been created with `mc mb --with-lock`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 24 23:46:33 UTC 2023 - 18.2K bytes - Viewed (0) -
internal/s3select/select.go
return 0, err } } return rsc.reader.Read(p) } // Close call to implement io.Closer. Calling Read/Seek after Close reopens the // object for reading and a subsequent Close call is required to ensure // resources are freed. func (rsc *ObjectReadSeekCloser) Close() error { rsc.closerOnce.Do(func() { if rsc.reader != nil { rsc.closerErr = rsc.reader.Close() rsc.reader = nil } })
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 21.2K bytes - Viewed (0)