Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,190 for reads (2.12 sec)

  1. internal/ringbuffer/README.md

    Regular Reads will block until data is available, but not wait for a full buffer. 
    Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space.
    
    `TryRead` and `TryWrite` are still available for non-blocking reads and writes.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  2. internal/ioutil/read_file.go

    	_, err = io.ReadFull(f, dst)
    	return dst, st, err
    }
    
    // ReadFile reads the named file and returns the contents.
    // A successful call returns err == nil, not err == EOF.
    // Because ReadFile reads the whole file, it does not treat an EOF from Read
    // as an error to be reported.
    //
    // passes NOATIME flag for reads on Unix systems to avoid atime updates.
    func ReadFile(name string) ([]byte, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 09 18:17:51 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/Resources.java

        }
      }
    
      /**
       * Returns a {@link CharSource} that reads from the given URL using the given character set.
       *
       * @since 14.0
       */
      public static CharSource asCharSource(URL url, Charset charset) {
        return asByteSource(url).asCharSource(charset);
      }
    
      /**
       * Reads all bytes from a URL into a byte array.
       *
       * @param url the URL to read from
       * @return a byte array containing all the bytes from the URL
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Aug 02 13:50:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_experimental_reader.h

    TF_CAPI_EXPORT extern TFE_MonitoringCounterReader*
    TFE_MonitoringNewCounterReader(const char* name);
    
    // Reads the value of a counter that was created with 0 labels.
    TF_CAPI_EXPORT extern int64_t TFE_MonitoringReadCounter0(
        TFE_MonitoringCounterReader*);
    
    // Reads the value of specific cell of a counter that was created with 1 label.
    TF_CAPI_EXPORT extern int64_t TFE_MonitoringReadCounter1(
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 20 03:14:47 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/io/LittleEndianDataInputStream.java

        return (int) in.skip(n);
      }
    
      @CanIgnoreReturnValue // to skip a byte
      @Override
      public int readUnsignedByte() throws IOException {
        int b1 = in.read();
        if (0 > b1) {
          throw new EOFException();
        }
    
        return b1;
      }
    
      /**
       * Reads an unsigned {@code short} as specified by {@link DataInputStream#readUnsignedShort()},
       * except using little-endian byte order.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  6. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java

         * @throws ModelParseException If the input format could not be parsed.
         * @deprecated Use {@link #read(Path, Map)} instead.
         */
        @Deprecated
        Model read(File input, Map<String, ?> options) throws IOException, ModelParseException;
    
        /**
         * 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)
  7. cmd/local-locker_gen.go

    				return
    			}
    		case "Writes":
    			z.Writes, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Writes")
    				return
    			}
    		case "Reads":
    			z.Reads, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "Reads")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  8. src/bytes/buffer.go

    }
    
    var errUnreadByte = errors.New("bytes.Buffer: UnreadByte: previous operation was not a successful read")
    
    // UnreadByte unreads the last byte returned by the most recent successful
    // read operation that read at least one byte. If a write has happened since
    // the last read, if the last read returned an error, or if the read read zero
    // bytes, UnreadByte returns an error.
    func (b *Buffer) UnreadByte() error {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/CharStreams.java

        int nRead;
        long total = 0;
        while ((nRead = from.read(buf)) != -1) {
          to.write(buf, 0, nRead);
          total += nRead;
        }
        return total;
      }
    
      /**
       * Reads all characters from a {@link Readable} object into a {@link String}. Does not close the
       * {@code Readable}.
       *
       * @param r the object to read from
       * @return a string containing all the characters
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 17 14:35:11 UTC 2023
    - 10.9K bytes
    - Viewed (0)
Back to top