Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 1,666 for writeFn (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

       *
       * 1. visibility of the writes to these fields to Fire.run:
       *
       * The initial write to delegateRef is made definitely visible via the semantics of
       * addListener/SES.schedule. The later racy write in cancel() is not guaranteed to be observed,
       * however that is fine since the correctness is based on the atomic state in our base class. The
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8K bytes
    - Click Count (0)
  2. cmd/xl-storage.go

    		defer xioutil.ODirectPoolLarge.Put(bufp)
    	}
    
    	var written int64
    	if odirectEnabled {
    		written, err = xioutil.CopyAligned(diskHealthWriter(ctx, w), r, *bufp, fileSize, w)
    	} else {
    		written, err = io.CopyBuffer(diskHealthWriter(ctx, w), r, *bufp)
    	}
    	if err != nil {
    		w.Close()
    		return err
    	}
    
    	if written < fileSize && fileSize >= 0 {
    		if truncate {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java

            startLatch.countDown();
    
            // Wait for writer thread to complete
            writerThread.join(1000);
    
            // Wait for all reader threads to complete
            for (Thread thread : readerThreads) {
                thread.join(testDurationMs + 1000);
            }
    
            // Verify that alive was changed to false
            assertFalse("alive should be false after writer thread", dataStore.alive);
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 12.8K bytes
    - Click Count (1)
  4. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt

                bytes = bytes,
              )
            }
          }
    
          override fun toDer(
            writer: DerWriter,
            value: AnyValue,
          ) {
            writer.write("ANY", value.tagClass, value.tag) {
              writer.writeOctetString(value.bytes)
              writer.constructed = value.constructed
            }
          }
        }
    
      internal fun parseGeneralizedTime(string: String): Long {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 15K bytes
    - Click Count (0)
  5. src/test/java/jcifs/internal/smb2/lock/Smb2LockResponseTest.java

                SMBUtil.writeInt2(0, readBuffer, 12); // Reserved bytes
    
                // When
                int written = response.writeBytesWireFormat(writeBuffer, 5);
                int read = response.readBytesWireFormat(readBuffer, 10);
    
                // Then
                assertEquals(0, written);
                assertEquals(4, read);
            }
    
            @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 17.1K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/RequestTest.kt

        assertThat(bodyToHex(body), "Retransmit body").isEqualTo("48656c6c6f")
      }
    
      @Test
      fun file() {
        val file = File.createTempFile("RequestTest", "tmp")
        val writer = FileWriter(file)
        writer.write("abc")
        writer.close()
        val contentType = "text/plain".toMediaType()
        val body: RequestBody = file.asRequestBody(contentType)
        assertThat(body.contentType()).isEqualTo(contentType)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 24.6K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/io/LittleEndianDataInputStreamTest.java

        /* Write out various test values NORMALLY */
        out.write(new byte[] {-100, 100});
        out.writeBoolean(true);
        out.writeBoolean(false);
        out.writeByte(100);
        out.writeByte(-100);
        out.writeByte((byte) 200);
        out.writeChar('a');
        out.writeShort((short) -30000);
        out.writeShort((short) 50000);
        out.writeInt(0xCAFEBABE);
        out.writeLong(0xDEADBEEFCAFEBABEL);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 4.9K bytes
    - Click Count (0)
  8. src/test/java/jcifs/netbios/SessionServicePacketTest.java

        }
    
        @Test
        @DisplayName("writeHeaderWireFormat should write correct header")
        void testWriteHeaderWireFormat() {
            packet.type = SessionServicePacket.SESSION_REQUEST;
            packet.length = 0x1234;
    
            byte[] dst = new byte[10];
            int written = packet.writeHeaderWireFormat(dst, 0);
    
            assertEquals(4, written);
            assertEquals((byte) SessionServicePacket.SESSION_REQUEST, dst[0]);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.5K bytes
    - Click Count (0)
  9. internal/logger/target/console/console.go

    	"github.com/minio/minio/internal/logger"
    )
    
    // Target implements loggerTarget to send log
    // in plain or json format to the standard output.
    type Target struct {
    	output io.Writer
    }
    
    // Validate - validate if the tty can be written to
    func (c *Target) Validate() error {
    	return nil
    }
    
    // Endpoint returns the backend endpoint
    func (c *Target) Endpoint() string {
    	return ""
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  10. cmd/last-minute_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z AccElem) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 3
    	// write "Total"
    	err = en.Append(0x83, 0xa5, 0x54, 0x6f, 0x74, 0x61, 0x6c)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt64(z.Total)
    	if err != nil {
    		err = msgp.WrapError(err, "Total")
    		return
    	}
    	// write "Size"
    	err = en.Append(0xa4, 0x53, 0x69, 0x7a, 0x65)
    	if err != nil {
    		return
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.2K bytes
    - Click Count (0)
Back to Top