- Sort Score
- Result 10 results
- Languages All
Results 381 - 390 of 1,382 for close (0.29 sec)
-
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/AcceptedApiChangesJsonFileManager.groovy
jsonFile.withWriter { fileWriter -> def writer = new JsonWriter(fileWriter) writer.setIndent(" ") new Gson().toJson([acceptedApiChanges: []], Object, writer) writer.close() } }Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 1K bytes - Viewed (0) -
cmd/os_other.go
d, err := Open(dirPath) if err != nil { if osErrToFileErr(err) == errFileNotFound { return nil } return osErrToFileErr(err) } defer d.Close() maxEntries := 1000 for { // Read up to max number of entries. fis, err := d.Readdir(maxEntries) if err != nil { if err == io.EOF { break } err = osErrToFileErr(err)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Sep 13 15:14:36 UTC 2023 - 4K bytes - Viewed (0) -
cmd/service.go
globalServiceFreezeMu.Lock() // Close when we reach 0 globalServiceFreezeCnt-- if globalServiceFreezeCnt <= 0 { // Set to a nil channel. var _ch chan struct{} if val := globalServiceFreeze.Swap(_ch); val != nil { if ch, ok := val.(chan struct{}); ok && ch != nil { // Close previous non-nil channel. xioutil.SafeClose(ch) } }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Feb 28 07:02:14 UTC 2024 - 3.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/CrawlerClient.java
*/ ResponseData execute(RequestData data); /** * Closes the crawler client and releases any resources associated with it. * This default implementation does nothing. * * @throws Exception if an error occurs during closing */ @Override default void close() throws Exception { // nothing }Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Sat Mar 15 06:52:00 UTC 2025 - 1.8K bytes - Viewed (0) -
internal/config/dns/etcd_dns.go
return json.Marshal(&SrvRecord{ Host: ip, Port: json.Number(port), TTL: ttl, CreationDate: t, }) } // Close closes the internal etcd client and cannot be used further func (c *CoreDNS) Close() error { c.etcdClient.Close() return nil } // List - Retrieves list of DNS entries for the domain. func (c *CoreDNS) List() (map[string][]SrvRecord, error) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/msrpc/SamrAliasHandle.java
if (rpc.retval != 0) { throw new SmbException(rpc.retval, false); } } /** * Closes this SAM alias handle. * * @throws IOException if an I/O error occurs during handle closure */ public void close() throws IOException { final MsrpcSamrCloseHandle rpc = new MsrpcSamrCloseHandle(this); handle.sendrecv(rpc); if (rpc.retval != 0) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.4K bytes - Viewed (0) -
cmd/sftp-server-driver.go
} // TransferError will catch network errors during transfer. // When TransferError() is called Close() will also // be called, so we do not need to Wait() here. func (w *writerAt) TransferError(err error) { _ = w.w.CloseWithError(err) _ = w.r.CloseWithError(err) w.err = err } func (w *writerAt) Close() (err error) { switch { case len(w.buffer) > 0:
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Feb 10 16:35:49 UTC 2025 - 11.6K bytes - Viewed (0) -
src/test/java/org/codelibs/core/io/InputStreamUtilTest.java
try { assertNotNull("1", InputStreamUtil.getBytes(is)); } finally { is.close(); } }Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 1.2K bytes - Viewed (0) -
guava/src/com/google/common/io/BaseEncoding.java
return read == 0 ? -1 : read; } buf[i] = (byte) b; } return i - off; } @Override public void close() throws IOException { reader.close(); } }; } @Override public BaseEncoding omitPadding() { return (paddingChar == null) ? this : newInstance(alphabet, null); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Oct 06 14:51:47 UTC 2025 - 41.7K bytes - Viewed (0) -
internal/event/target/mqtt.go
_, err := target.isActive() if err != nil { return err } return target.send(eventData) } // Close - does nothing and available for interface compatibility. func (target *MQTTTarget) Close() error { if target.client != nil { target.client.Disconnect(100) } close(target.quitCh) return nil } func (target *MQTTTarget) init() error { return target.initOnce.Do(target.initMQTT) }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.2K bytes - Viewed (0)