Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 1,382 for close (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top