Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for dwrite (0.05 sec)

  1. cmd/storage-datatypes_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *CheckPartsHandlerParams) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 4
    	// write "id"
    	err = en.Append(0x84, 0xa2, 0x69, 0x64)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.DiskID)
    	if err != nil {
    		err = msgp.WrapError(err, "DiskID")
    		return
    	}
    	// write "v"
    	err = en.Append(0xa1, 0x76)
    	if err != nil {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  2. cmd/admin-handlers.go

    		anonDrives := []madmin.Disk{}
    		for _, drive := range drives {
    			drive.Endpoint = anonAddr(drive.Endpoint)
    			anonDrives = append(anonDrives, drive)
    		}
    		return anonDrives
    	}
    
    	go func() {
    		defer xioutil.SafeClose(healthInfoCh)
    
    		partialWrite(healthInfo) // Write first message with only version and deployment id populated
    		getAndWritePlatformInfo()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  3. guava/src/com/google/common/cache/LocalCache.java

         * A queue of elements currently in the map, ordered by write time. Elements are added to the
         * tail of the queue on write.
         */
        @GuardedBy("this")
        final Queue<ReferenceEntry<K, V>> writeQueue;
    
        /**
         * A queue of elements currently in the map, ordered by access time. Elements are added to the
         * tail of the queue on access (note that writes count as accesses).
         */
        @GuardedBy("this")
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  4. okhttp-android/src/main/baseline-prof.txt

    HSPLokhttp3/internal/http2/Hpack$Reader;->readInt(II)I
    HSPLokhttp3/internal/http2/Hpack$Writer;-><init>(IZLokio/Buffer;I)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->evictToRecoverBytes(I)I
    HSPLokhttp3/internal/http2/Hpack$Writer;->insertIntoDynamicTable(Lokhttp3/internal/http2/Header;)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->writeByteString(Lokio/ByteString;)V
    HSPLokhttp3/internal/http2/Hpack$Writer;->writeHeaders(Ljava/util/List;)V
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Mar 21 11:22:00 UTC 2022
    - 127.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

          List<ReferenceEntry<Object, Object>> writes = new ArrayList<>();
          Iterator<ReferenceEntry<Object, Object>> i = writeOrder.iterator();
          while (i.hasNext()) {
            ReferenceEntry<Object, Object> entry = i.next();
            if (random.nextBoolean()) {
              segment.recordWrite(entry, 1, map.ticker.read());
              writes.add(entry);
              i.remove();
            }
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 110.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/cache/LocalCacheTest.java

          List<ReferenceEntry<Object, Object>> writes = new ArrayList<>();
          Iterator<ReferenceEntry<Object, Object>> i = writeOrder.iterator();
          while (i.hasNext()) {
            ReferenceEntry<Object, Object> entry = i.next();
            if (random.nextBoolean()) {
              segment.recordWrite(entry, 1, map.ticker.read());
              writes.add(entry);
              i.remove();
            }
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 112.3K bytes
    - Viewed (0)
  7. cmd/object-handlers_test.go

    		for k, value := range customHeaders {
    			req.Header.Set(k, value)
    		}
    	}
    
    	checksumData := func(b []byte, h hash.Hash) string {
    		h.Reset()
    		_, err := h.Write(b)
    		if err != nil {
    			t.Fatal(err)
    		}
    		return base64.StdEncoding.EncodeToString(h.Sum(nil))
    	}
    	// test cases with inputs and expected result for GetObject.
    	testCases := []struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/SmbFile.java

     * file attibutes such as ACLs but it does copy regular attributes as
     * well as create and last write times. This method is almost twice as
     * efficient as manually copying as it employs an additional write
     * thread to read and write data concurrently.
     * <p/>
     * It is not possible (nor meaningful) to copy entire workgroups or
     * servers.
     *
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Mar 13 12:00:57 UTC 2023
    - 107.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

     * to be the last step of the pipeline.
     *
     * <h4>Transforming</h4>
     *
     * To derive the next step by asynchronously applying a function to an input step's value, call
     * {@link #transform(ClosingFunction, Executor)} or {@link #transformAsync(AsyncClosingFunction,
     * Executor)} on the input step.
     *
     * <h4>Catching</h4>
     *
     * To derive the next step from a failed input step, call {@link #catching(Class, ClosingFunction,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        }
        source.close()
      }
    
      /** Confirm that an unacknowledged write times out.  */
      @Test
      fun writeTimeouts() {
        val server = MockWebServer()
        // Sockets on some platforms can have large buffers that mean writes do not block when
        // required. These socket factories explicitly set the buffer sizes on sockets created.
        val socketBufferSize = 4 * 1024
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 131.7K bytes
    - Viewed (0)
Back to top