- Sort Score
- Result 10 results
- Languages All
Results 631 - 640 of 845 for CLOSE (0.04 sec)
-
cmd/warm-backend-gcs.go
return "", gcsToObjectError(err, gcs.Bucket, key) } if _, err := xioutil.Copy(w, data); err != nil { return "", gcsToObjectError(err, gcs.Bucket, key) } return "", w.Close() } // FIXME: add support for remote version ID in GCS remote tier and remove this. // Currently it's a no-op.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/config-current.go
if err != nil { return err } if etcdCfg.Enabled { etcdClnt, err := etcd.New(etcdCfg) if err != nil { return err } etcdClnt.Close() } case config.IdentityOpenIDSubSys: if _, err := openid.LookupConfig(s, NewHTTPTransport(), xhttp.DrainBody, globalSite.Region()); err != nil { return err } case config.IdentityLDAPSubSys:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 30.1K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
defer timeout(5 * time.Second)() rb.Reset() done := make(chan struct{}) go func() { defer close(done) time.Sleep(10 * time.Millisecond) fn() }() rb.CloseWithError(errors.New("test error")) <-done rb.Reset() done = make(chan struct{}) go func() { defer close(done) fn() }() time.Sleep(10 * time.Millisecond) rb.CloseWithError(errors.New("test error"))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu May 09 09:29:26 UTC 2024 - 41K bytes - Viewed (0) -
src/main/java/jcifs/SmbResource.java
*/ InputStream openInputStream () throws CIFSException; /** * Close/release the file * * This releases all resources that this file holds. If not using strict mode this is currently a no-op. * * @see java.lang.AutoCloseable#close() */ @Override void close (); /** * Fetch all children *
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Dec 20 14:09:34 UTC 2020 - 26K bytes - Viewed (1) -
cmd/prepare-storage.go
// connect to list of endpoints and load all Erasure disk formats, validate the formats are correct // and are in quorum, if no formats are found attempt to initialize all of them for the first // time. additionally make sure to close all the disks used in this attempt.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
cmd/utils.go
if err != nil { return nil, err } err = pprof.StartCPUProfile(f) if err != nil { return nil, err } prof.stopFn = func() ([]byte, error) { pprof.StopCPUProfile() err := f.Close() if err != nil { return nil, err } defer RemoveAll(dirPath) return ioutilx.ReadFile(fn) } case madmin.ProfilerCPUIO: // at 10k or more goroutines fgprof is likely to become
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:22:04 UTC 2024 - 31.9K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 38K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
} return this; } /** * {@inheritDoc} * * @see java.lang.AutoCloseable#close() */ @Override public void close () { release(); } /** * */ public void release () { long usage = this.usageCount.decrementAndGet();
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Nov 01 18:12:21 UTC 2020 - 24.1K bytes - Viewed (0) -
cmd/object-api-interface.go
// Object operations. // GetObjectNInfo returns a GetObjectReader that satisfies the // ReadCloser interface. The Close method runs any cleanup // functions, so it must always be called after reading till EOF // // IMPORTANTLY, when implementations return err != nil, this // function MUST NOT return a non-nil ReadCloser.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 21:57:20 UTC 2024 - 17.3K bytes - Viewed (0)