Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 686 for read1 (0.04 sec)

  1. cluster/gce/windows/smoke-test.sh

        -o jsonpath='{.items[*].status.conditions[?(@.type=="Ready")].status}')
      for status in $statuses; do
        if [[ $status == "False" ]]; then
          echo "ERROR: some Windows node has status != Ready"
          echo "kubectl get nodes -l kubernetes.io/os=windows"
          ${kubectl} get nodes -l kubernetes.io/os=windows
          exit 1
        fi
      done
      echo "Verified that all Windows nodes have status Ready"
    }
    
    function untaint_windows_nodes {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 24 07:02:51 UTC 2024
    - 20.6K bytes
    - Viewed (0)
  2. platforms/core-runtime/files/src/main/java/org/gradle/internal/file/RandomAccessFileInputStream.java

            return n;
        }
    
        @Override
        public int read(byte[] bytes) throws IOException {
            return file.read(bytes);
        }
    
        @Override
        public int read() throws IOException {
            return file.read();
        }
    
        @Override
        public int read(byte[] bytes, int offset, int length) throws IOException {
            return file.read(bytes, offset, length);
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:51 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  3. maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsReader.java

         * @throws IOException If the settings could not be deserialized.
         * @throws SettingsParseException If the input format could not be parsed.
         */
        Settings read(File input, Map<String, ?> options) throws IOException, SettingsParseException;
    
        /**
         * Reads the settings from the specified character reader. The reader will be automatically closed before the method
         * returns.
         *
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Wed Sep 06 08:39:32 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  4. src/net/http/responsecontroller.go

    			return nil, nil, errNotSupported()
    		}
    	}
    }
    
    // SetReadDeadline sets the deadline for reading the entire request, including the body.
    // Reads from the request body after the deadline has been exceeded will return an error.
    // A zero value means no deadline.
    //
    // Setting the read deadline after it has been exceeded will not extend it.
    func (c *ResponseController) SetReadDeadline(deadline time.Time) error {
    	rw := c.rw
    	for {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  5. src/io/fs/readfile.go

    }
    
    // ReadFile reads the named file from the file system fs and returns its contents.
    // A successful call returns a nil error, not [io.EOF].
    // (Because ReadFile reads the whole file, the expected EOF
    // from the final Read is not treated as an error to be reported.)
    //
    // If fs implements [ReadFileFS], ReadFile calls fs.ReadFile.
    // Otherwise ReadFile calls fs.Open and uses Read and Close
    // on the returned [File].
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 11 20:25:50 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  6. internal/store/store.go

    	DelList(key []string) error
    	Open() error
    	Delete() error
    	Extension() string
    }
    
    // Key denotes the key present in the store.
    type Key struct {
    	Name   string
    	IsLast bool
    }
    
    // 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Mar 25 16:44:20 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  7. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/btree/BlockStore.java

         * Removes the given block from this store.
         */
        void remove(BlockPayload block);
    
        /**
         * Reads the first block from this store.
         */
        <T extends BlockPayload> T readFirst(Class<T> payloadType);
        
        /**
         * Reads a block from this store.
         */
        <T extends BlockPayload> T read(BlockPointer pos, Class<T> payloadType);
    
        /**
         * Writes a block to this store, adding the block if required.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  8. src/io/pipe.go

    // with code expecting an [io.Writer].
    //
    // Reads and Writes on the pipe are matched one to one
    // except when multiple Reads are needed to consume a single Write.
    // That is, each Write to the [PipeWriter] blocks until it has satisfied
    // one or more Reads from the [PipeReader] that fully consume
    // the written data.
    // The data is copied directly from the Write to the corresponding
    // Read (or Reads); there is no internal buffering.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 18 19:34:35 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  9. platforms/core-execution/execution/src/test/groovy/org/gradle/internal/execution/history/impl/FileCollectionFingerprintSerializerTest.groovy

        def serializer = new FileCollectionFingerprintSerializer(stringInterner)
    
        def "reads and writes empty fingerprints"() {
            when:
            def out = serialize(FileCollectionFingerprint.EMPTY, serializer)
    
            then:
            out == FileCollectionFingerprint.EMPTY
        }
    
        def "reads and writes fingerprints"() {
            def hash = TestHashCodes.hashCodeFrom(1234)
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:46:15 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  10. src/encoding/gob/decoder.go

    	err          error
    }
    
    // NewDecoder returns a new decoder that reads from the [io.Reader].
    // If r does not also implement [io.ByteReader], it will be wrapped in a
    // [bufio.Reader].
    func NewDecoder(r io.Reader) *Decoder {
    	dec := new(Decoder)
    	// We use the ability to read bytes as a plausible surrogate for buffering.
    	if _, ok := r.(io.ByteReader); !ok {
    		r = bufio.NewReader(r)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 08 19:04:28 UTC 2023
    - 7.2K bytes
    - Viewed (0)
Back to top