Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 296 for closer (0.04 seconds)

  1. cmd/metacache-stream.go

    				continue
    			}
    		}
    	}()
    
    	return objs, nil
    }
    
    // Close and release resources.
    func (w *metacacheWriter) Close() error {
    	if w == nil || w.closer == nil {
    		return nil
    	}
    	w.streamWg.Wait()
    	err := w.closer()
    	w.closer = nil
    	return err
    }
    
    // Reset and start writing to new writer.
    // Close must have been called before this.
    func (w *metacacheWriter) Reset(out io.Writer) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 19.5K bytes
    - Click Count (0)
  2. cmd/bitrot.go

    	}
    	return newWholeBitrotReader(disk, bucket, filePath, algo, tillOffset, sum)
    }
    
    // Close all the readers.
    func closeBitrotReaders(rs []io.ReaderAt) {
    	for _, r := range rs {
    		if r != nil {
    			if br, ok := r.(io.Closer); ok {
    				br.Close()
    			}
    		}
    	}
    }
    
    // Close all the writers.
    func closeBitrotWriters(ws []io.Writer) []error {
    	errs := make([]error, len(ws))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  3. cmd/bitrot_test.go

    	}
    	_, err = writer.Write([]byte("aaaaaaaaaa"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	_, err = writer.Write([]byte("aaaaa"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	if bw, ok := writer.(io.Closer); ok {
    		bw.Close()
    	}
    
    	reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10)
    	b := make([]byte, 10)
    	if _, err = reader.ReadAt(b, 0); err != nil {
    		t.Fatal(err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2K bytes
    - Click Count (0)
  4. internal/s3select/parquet/reader.go

    type Reader struct {
    	io.Closer
    	r *parquetgo.FileReader
    }
    
    // NewParquetReader creates a Reader2 from a io.ReadSeekCloser.
    func NewParquetReader(rsc io.ReadSeekCloser, _ *ReaderArgs) (r *Reader, err error) {
    	fr, err := parquetgo.NewFileReader(rsc)
    	if err != nil {
    		return nil, errParquetParsingError(err)
    	}
    
    	return &Reader{Closer: rsc, r: fr}, nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolutionPolicy.java

    /**
     *
     */
    @Named
    @Singleton
    @Deprecated
    public class DefaultGraphConflictResolutionPolicy implements GraphConflictResolutionPolicy {
        /**
         * artifact, closer to the entry point, is selected
         */
        @Configuration(name = "closer-first", value = "true")
        private boolean closerFirst = true;
    
        /**
         * newer artifact is selected
         */
        @Configuration(name = "newer-first", value = "true")
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolver.java

    import org.apache.maven.artifact.ArtifactScopeEnum;
    
    /**
     * Default conflict resolver.Implements closer newer first policy by default, but could be configured via plexus
     *
     */
    @Named
    @Singleton
    @Deprecated
    public class DefaultGraphConflictResolver implements GraphConflictResolver {
        /**
         * artifact, closer to the entry point, is selected
         */
        @Inject
        protected GraphConflictResolutionPolicy policy;
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  7. cmd/metrics.go

    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    		if closer, ok := enc.(expfmt.Closer); ok {
    			closer.Close()
    		}
    	})
    }
    
    // NoAuthMiddleware no auth middle ware.
    func NoAuthMiddleware(h http.Handler) http.Handler {
    	return h
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:06:31 GMT 2025
    - 16.7K bytes
    - Click Count (0)
  8. cmd/metrics-v2.go

    		for _, mf := range mfs {
    			if err := enc.Encode(mf); err != nil {
    				// client may disconnect for any reasons
    				// we do not have to log this.
    				return
    			}
    		}
    		if closer, ok := enc.(expfmt.Closer); ok {
    			closer.Close()
    		}
    	})
    }
    
    func metricsBucketHandler() http.Handler {
    	return metricsHTTPHandler(bucketCollector, "handler.MetricsBucket")
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  9. architecture/standards/0008-use-nullaway.md

    ## Status
    
    ACCEPTED
    
    ## Consequences
    
    * Classes are forced to have consistent nullability annotations.
    * IDE warnings become more accurate, reducing warnings fatigue.
    * Public API nullability annotations become closer to reality.
    * Java compilation of Gradle code suffers from small performance penalty (up to 10%).
    * Time has to be allocated to clean up existing projects.
    * One has to write NullAway-conformant code even when hacking.
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Dec 11 10:24:40 GMT 2025
    - 4K bytes
    - Click Count (0)
  10. docs/en/docs/how-to/custom-docs-ui-assets.md

    By default, those files are served from a <abbr title="Content Delivery Network: A service, normally composed of several servers, that provides static files, like JavaScript and CSS. It's commonly used to serve those files from the server closer to the client, improving performance.">CDN</abbr>.
    
    But it's possible to customize it, you can set a specific CDN, or serve the files yourself.
    
    ## Custom CDN for JavaScript and CSS { #custom-cdn-for-javascript-and-css }
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 7.8K bytes
    - Click Count (0)
Back to Top