Search Options

Results per page
Sort
Preferred Languages
Advance

Results 631 - 640 of 845 for CLOSE (0.05 sec)

  1. 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)
  2. 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)
  3. 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)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

                connectionMonitorTask.cancel();
            }
            if (httpClient != null) {
                try {
                    httpClient.close();
                } catch (final IOException e) {
                    logger.error("Failed to close httpClient.", e);
                }
                httpClient = null;
                if (clientConnectionManager != null) {
                    clientConnectionManager.shutdown();
                }
            }
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu May 09 09:29:26 UTC 2024
    - 41K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java

            @Override
            public void close() throws InvokerException {
                List<Exception> causes = null;
                List<AutoCloseable> cs = new ArrayList<>(closeables);
                Collections.reverse(cs);
                for (AutoCloseable c : cs) {
                    if (c != null) {
                        try {
                            c.close();
                        } catch (Exception e) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top