Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,346 for READ (0.04 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

            }
    
            // Fill the receive buffer without holding any locks.
            val read = source.read(receiveBuffer, remainingByteCount)
            if (read == -1L) throw EOFException()
            remainingByteCount -= read
    
            // Move the received data to the read buffer to the reader can read it. If this source has
            // been closed since this read began we must discard the incoming data and tell the
            // connection we've done so.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  2. docs/en/docs/advanced/settings.md

    Most of these settings are variable (can change), like database URLs. And many could be sensitive, like secrets.
    
    For this reason it's common to provide them in environment variables that are read by the application.
    
    /// tip
    
    To understand environment variables you can read [Environment Variables](../environment-variables.md){.internal-link target=_blank}.
    
    ///
    
    ## Types and validation
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  3. cmd/perf-tests.go

    }
    
    type firstByteRecorder struct {
    	t *time.Time
    	r io.Reader
    }
    
    func (f *firstByteRecorder) Read(p []byte) (n int, err error) {
    	if f.t != nil || len(p) == 0 {
    		return f.r.Read(p)
    	}
    	// Read a single byte.
    	n, err = f.r.Read(p[:1])
    	if n > 0 {
    		t := time.Now()
    		f.t = &t
    	}
    	return n, err
    }
    
    // Runs the speedtest on local MinIO process.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. build-logic/documentation/src/test/resources/org/gradle/test/GroovyClass.groovy

         */
        CombinedInterface groovyProp
    
        /**
         * A read-only groovy property.
         */
        final String readOnlyGroovyProp
    
        /**
         * An array property.
         */
        def String[] arrayProp
    
        private def ignoreMe1;
        public int ignoreMe2;
        protected int ignoreMe3;
        static String ignoreMe4;
    
        /**
         * A read-only property.
         */
        def getReadOnly() {
            'value'
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 915 bytes
    - Viewed (0)
  5. internal/lock/lock.go

    var ErrAlreadyLocked = errors.New("file already locked")
    
    // RLockedFile represents a read locked file, implements a special
    // closer which only closes the associated *os.File when the ref count.
    // has reached zero, i.e when all the readers have given up their locks.
    type RLockedFile struct {
    	*LockedFile
    	mutex sync.Mutex
    	refs  int // Holds read lock refs.
    }
    
    // IsClosed - Check if the rlocked file is already closed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  6. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java

         * @throws IOException If the model could not be deserialized.
         * @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.
         *
    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. guava-tests/test/com/google/common/io/LittleEndianDataOutputStreamTest.java

        out.writeDouble(Double.longBitsToDouble(0xDEADBEEFCAFEBABEL));
    
        byte[] data = baos.toByteArray();
    
        /* Setup input streams */
        DataInput in = new DataInputStream(new ByteArrayInputStream(data));
    
        /* Read in various values NORMALLY */
        byte[] b = new byte[2];
        in.readFully(b);
        assertEquals(-100, b[0]);
        assertEquals(100, b[1]);
        assertEquals(true, in.readBoolean());
        assertEquals(false, in.readBoolean());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/io/LittleEndianDataOutputStreamTest.java

        out.writeDouble(Double.longBitsToDouble(0xDEADBEEFCAFEBABEL));
    
        byte[] data = baos.toByteArray();
    
        /* Setup input streams */
        DataInput in = new DataInputStream(new ByteArrayInputStream(data));
    
        /* Read in various values NORMALLY */
        byte[] b = new byte[2];
        in.readFully(b);
        assertEquals(-100, b[0]);
        assertEquals(100, b[1]);
        assertEquals(true, in.readBoolean());
        assertEquals(false, in.readBoolean());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/compare/comparator_test.go

    func TestComparatorMismatchedConfigs(t *testing.T) {
    	cfg, err := os.ReadFile("testdata/configdump.json")
    	if err != nil {
    		t.Fatalf("Failed to read test data: %v", err)
    	}
    	diffCfg, err := os.ReadFile("testdata/configdump_diff.json")
    	if err != nil {
    		t.Fatalf("Failed to read test data: %v", err)
    	}
    
    	var outputBuffer bytes.Buffer
    	comparator, err := NewComparator(&outputBuffer, map[string][]byte{"default": cfg}, diffCfg)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Mar 12 10:02:09 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  10. src/archive/zip/register.go

    	return &pooledFlateReader{fr: fr}
    }
    
    type pooledFlateReader struct {
    	mu sync.Mutex // guards Close and Read
    	fr io.ReadCloser
    }
    
    func (r *pooledFlateReader) Read(p []byte) (n int, err error) {
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	if r.fr == nil {
    		return 0, errors.New("Read after Close")
    	}
    	return r.fr.Read(p)
    }
    
    func (r *pooledFlateReader) Close() error {
    	r.mu.Lock()
    	defer r.mu.Unlock()
    	var err error
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 3.7K bytes
    - Viewed (0)
Back to top