Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 328 for readers (0.15 sec)

  1. cmd/metacache-set.go

    		// not a storage error.
    		return nil
    	}
    	readers := make([]*metacacheReader, len(disks))
    	defer func() {
    		for _, r := range readers {
    			r.Close()
    		}
    	}()
    	for i := range disks {
    		r, w := io.Pipe()
    		// Make sure we close the pipe so blocked writes doesn't stay around.
    		defer r.CloseWithError(context.Canceled)
    
    		readers[i] = newMetacacheReader(r)
    		d := disks[i]
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  2. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Sun Mar 05 04:57:35 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  3. 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 May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 02 08:32:06 GMT 2024
    - 17K bytes
    - Viewed (0)
  4. src/archive/zip/writer.go

    	// flag bit is set. However, there are several problems:
    	//
    	//	* Many ZIP readers still do not support UTF-8.
    	//	* If the UTF-8 flag is cleared, several readers simply interpret the
    	//	name and comment fields as whatever the local system encoding is.
    	//
    	// In order to avoid breaking readers without UTF-8 support,
    	// we avoid setting the UTF-8 flag if the strings are CP-437 compatible.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 04 14:28:57 GMT 2024
    - 19.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/CharSource.java

       * independent reader each time it is called.
       *
       * <p>The caller is responsible for ensuring that the returned reader is closed.
       *
       * @throws IOException if an I/O error occurs while of opening the reader
       */
      public BufferedReader openBufferedStream() throws IOException {
        Reader reader = openStream();
        return (reader instanceof BufferedReader)
            ? (BufferedReader) reader
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed May 17 14:35:11 GMT 2023
    - 22.4K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    	var found int
    	var notFound int
    	var foundNotEmpty int
    	var otherFound int
    	for _, readErr := range errs {
    		switch {
    		case readErr == nil:
    			found++
    		case readErr == errFileNotFound || readErr == errVolumeNotFound:
    			notFound++
    		case readErr == errVolumeNotEmpty:
    			foundNotEmpty++
    		default:
    			otherFound++
    		}
    	}
    	found = found + foundNotEmpty + otherFound
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  7. maven-core/src/main/java/org/apache/maven/DefaultMaven.java

            Set<WorkspaceReader> workspaceReaders = new LinkedHashSet<>();
            // 1) Reactor workspace reader
            WorkspaceReader reactorReader = lookup.lookup(WorkspaceReader.class, ReactorReader.HINT);
            workspaceReaders.add(reactorReader);
            // 2) Repository system session-scoped workspace reader (contains ide and exec request reader)
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Fri Apr 12 10:50:18 GMT 2024
    - 27.5K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/CharStreamsTest.java

        Reader reader = new StringReader("abcde");
        assertThrows(EOFException.class, () -> CharStreams.skipFully(reader, 6));
      }
    
      public void testSkipFully() throws IOException {
        String testString = "abcdef";
        Reader reader = new StringReader(testString);
    
        assertEquals(testString.charAt(0), reader.read());
        CharStreams.skipFully(reader, 1);
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

        Reader reader = new StringReader("abcde");
        assertThrows(EOFException.class, () -> CharStreams.skipFully(reader, 6));
      }
    
      public void testSkipFully() throws IOException {
        String testString = "abcdef";
        Reader reader = new StringReader(testString);
    
        assertEquals(testString.charAt(0), reader.read());
        CharStreams.skipFully(reader, 1);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.2K bytes
    - Viewed (0)
  10. src/archive/tar/format.go

    	FormatUnknown
    
    	// The format of the original Unix V7 tar tool prior to standardization.
    	formatV7
    
    	// FormatUSTAR represents the USTAR header format defined in POSIX.1-1988.
    	//
    	// While this format is compatible with most tar readers,
    	// the format has several limitations making it unsuitable for some usages.
    	// Most notably, it cannot support sparse files, files larger than 8GiB,
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 11.3K bytes
    - Viewed (0)
Back to top