Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 81 for Reads (0.02 sec)

  1. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java

        /**
         * Name of the property used to store the project's root directory to use with
         * XInclude support.
         */
        String ROOT_DIRECTORY = "rootDirectory";
    
        /**
         * Reads the model from the specified file.
         *
         * @param input The file to deserialize the model from, must not be {@code null}.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. cmd/erasure-decode.go

    	readTriggerCh := make(chan bool, len(p.readers))
    	defer xioutil.SafeClose(readTriggerCh) // close the channel upon return
    
    	for i := 0; i < p.dataBlocks; i++ {
    		// Setup read triggers for p.dataBlocks number of reads so that it reads in parallel.
    		readTriggerCh <- true
    	}
    
    	disksNotFound := int32(0)
    	bitrotHeal := int32(0)       // Atomic bool flag.
    	missingPartsHeal := int32(0) // Atomic bool flag.
    	readerIndex := 0
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  3. internal/store/store.go

    	}
    	if vals := strings.Split(key.Name, "."); len(vals) == 2 {
    		key.Extension = "." + vals[1]
    		key.Name = strings.TrimSuffix(key.Name, key.Extension)
    	}
    	return
    }
    
    // replayItems - Reads the items from the store and replays.
    func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key {
    	keyCh := make(chan Key)
    
    	go func() {
    		defer xioutil.SafeClose(keyCh)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. src/bytes/buffer.go

    	}
    	return data
    }
    
    // ReadByte reads and returns the next byte from the buffer.
    // If no byte is available, it returns error [io.EOF].
    func (b *Buffer) ReadByte() (byte, error) {
    	if b.empty() {
    		// Buffer is empty, reset to recover space.
    		b.Reset()
    		return 0, io.EOF
    	}
    	c := b.buf[b.off]
    	b.off++
    	b.lastRead = opRead
    	return c, nil
    }
    
    // ReadRune reads and returns the next UTF-8-encoded
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  5. impl/maven-core/src/main/java/org/apache/maven/artifact/repository/metadata/io/MetadataReader.java

         * true}. If {@code false}, unknown elements will be ignored instead of causing a failure.
         */
        String IS_STRICT = "org.apache.maven.artifact.repository.metadata.io.isStrict";
    
        /**
         * Reads the metadata from the specified file.
         *
         * @param input The file to deserialize the metadata from, must not be {@code null}.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  6. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsReader.java

         * true}. If {@code false}, unknown elements will be ignored instead of causing a failure.
         */
        String IS_STRICT = "org.apache.maven.settings.io.isStrict";
    
        /**
         * Reads the settings from the specified file.
         *
         * @param input The file to deserialize the settings from, must not be {@code null}.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  7. compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/ToolchainsReader.java

         * true}. If {@code false}, unknown elements will be ignored instead of causing a failure.
         */
        String IS_STRICT = "org.apache.maven.toolchains.io.isStrict";
    
        /**
         * Reads the toolchains from the specified file.
         *
         * @param input The file to deserialize the toolchains from, must not be {@code null}.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/CharSource.java

      /**
       * Opens a new {@link Stream} for reading text one line at a time from this source. This method
       * returns a new, independent stream each time it is called.
       *
       * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an
       * I/O error occurs while the stream is reading from the source or when the stream is closed, an
       * {@link UncheckedIOException} is thrown.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

            }
          }
          int undrainedIndex = reads.size() - segment.recencyQueue.size();
          checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size()));
          readOrder.addAll(reads);
    
          checkEvictionQueues(map, segment, readOrder, writeOrder);
          checkExpirationTimes(map);
        }
      }
    
      public void testComputeExistingEntry() throws ExecutionException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/cache/LocalCacheTest.java

            }
          }
          int undrainedIndex = reads.size() - segment.recencyQueue.size();
          checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size()));
          readOrder.addAll(reads);
    
          checkEvictionQueues(map, segment, readOrder, writeOrder);
          checkExpirationTimes(map);
        }
      }
    
      public void testComputeExistingEntry() throws ExecutionException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
Back to top