Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 988 for readers (0.18 sec)

  1. maven-core/src/main/java/org/apache/maven/resolver/MavenChainedWorkspaceReader.java

        protected List<WorkspaceReader> readers;
        protected WorkspaceRepository repository;
    
        /**
         * Creates a new workspace reader by chaining the specified readers.
         *
         * @param readers The readers to chain must not be {@code null}.
         */
        public MavenChainedWorkspaceReader(WorkspaceReader... readers) {
            setReaders(Arrays.asList(readers));
        }
    
        @Override
    Java
    - Registered: Sun Apr 21 03:35:09 GMT 2024
    - Last Modified: Fri Apr 12 10:50:18 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  2. cmd/erasure-decode.go

    }
    
    // Heal reads from readers, reconstruct shards and writes the data to the writers.
    func (e Erasure) Heal(ctx context.Context, writers []io.Writer, readers []io.ReaderAt, totalLength int64, prefer []bool) (derr error) {
    	if len(writers) != e.parityBlocks+e.dataBlocks {
    		return errInvalidArgument
    	}
    
    	reader := newParallelReader(readers, e, 0, totalLength)
    	if len(readers) == len(prefer) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  3. cmd/local-locker_test.go

    			continue
    		}
    		t.Run(fmt.Sprintf("%d-locks", locks), func(t *testing.T) {
    			// Number of readers per lock...
    			for _, readers := range []int{1, 10, 100} {
    				if locks > 1000 && readers > 1 {
    					continue
    				}
    				if testing.Short() && readers > 10 {
    					continue
    				}
    				t.Run(fmt.Sprintf("%d-read", readers), func(t *testing.T) {
    					l := newLocker()
    					for i := 0; i < locks; i++ {
    						var tmp [16]byte
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 05 04:57:35 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  4. cmd/metacache-set.go

    		}
    
    		if vnf == len(readers) {
    			return errVolumeNotFound
    		}
    
    		// Break if all at EOF or error.
    		if atEOF+hasErr == len(readers) {
    			if hasErr > 0 && opts.finished != nil {
    				opts.finished(errs)
    			}
    			break
    		}
    
    		if fnf == len(readers) {
    			return errFileNotFound
    		}
    
    		if agree == len(readers) {
    			// Everybody agreed
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 18 04:42:11 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  5. cmd/erasure-heal_test.go

    		closeBitrotWriters(writers)
    		if err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    
    		readers := make([]io.ReaderAt, len(disks))
    		for i, disk := range disks {
    			shardFilesize := erasure.ShardFileSize(test.size)
    			readers[i] = newBitrotReader(disk, nil, "testbucket", "testobject", shardFilesize, test.algorithm, bitrotWriterSum(writers[i]), erasure.ShardSize())
    		}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  6. istioctl/pkg/analyze/analyze.go

    				return nil, err
    			}
    			readers = append(readers, dirReaders...)
    		} else {
    			if !isValidFile(f) {
    				fmt.Fprintf(cmd.ErrOrStderr(), "Skipping file %v, recognized file extensions are: %v\n", f, fileExtensions)
    				continue
    			}
    			rs, err := gatherFile(f)
    			if err != nil {
    				return nil, err
    			}
    			readers = append(readers, rs)
    		}
    	}
    	return readers, nil
    }
    
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Apr 02 08:32:06 GMT 2024
    - 17K bytes
    - Viewed (0)
  7. maven-core/src/main/java/org/apache/maven/resolver/RepositorySystemSessionFactory.java

         * should be set up as very last thing before using resolver session, that is built by invoking
         * {@link SessionBuilder#build()} method.
         *
         * @param request The maven execution request, must not be {@code null}.
         * @return The session builder "ready to use" without workspace readers.
         */
    Java
    - Registered: Sun Apr 21 03:35:09 GMT 2024
    - Last Modified: Fri Jan 19 11:00:28 GMT 2024
    - 1.7K bytes
    - Viewed (0)
  8. cmd/streaming-signature-v4_test.go

    	}
    	testCases := []testCase{
    		// Test - 1 - small bufio reader.
    		{
    			bufio.NewReaderSize(readers[0], 16),
    			errLineTooLong,
    			nil,
    			nil,
    		},
    		// Test - 2 - unexpected end of the reader.
    		{
    			bufio.NewReader(readers[1]),
    			io.ErrUnexpectedEOF,
    			nil,
    			nil,
    		},
    		// Test - 3 - line too long bigger than 4k+1
    		{
    			bufio.NewReader(readers[2]),
    			errLineTooLong,
    			nil,
    			nil,
    		},
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 5.7K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java

            final Iterator<ImageReader> readers = ImageIO.getImageReaders(input);
            if (readers.hasNext()) {
                final ImageReader reader = readers.next();
                try {
                    reader.setInput(input);
                    final ImageReadParam param = reader.getDefaultReadParam();
                    final int width = reader.getWidth(0);
                    final int height = reader.getHeight(0);
    Java
    - Registered: Mon Apr 22 08:04:10 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/io/MultiReader.java

    import java.io.IOException;
    import java.io.Reader;
    import java.util.Iterator;
    import javax.annotation.CheckForNull;
    
    /**
     * A {@link Reader} that concatenates multiple readers.
     *
     * @author Bin Zhu
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    class MultiReader extends Reader {
      private final Iterator<? extends CharSource> it;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 28 20:13:02 GMT 2023
    - 2.4K bytes
    - Viewed (0)
Back to top