WRITE - Code Search

src/main/java/jcifs/internal/smb2/create/LeaseV2CreateContextRequest.java

        SMBUtil.writeInt4(52, dst, dstIndex); // DataLength
        dstIndex += 4;

        // Write context name
        System.arraycopy(CONTEXT_NAME_BYTES, 0, dst, dstIndex, 4);
        dstIndex += 4;

        // Padding to align data to 8-byte boundary
        dstIndex += 4;

        // Write lease V2 data (52 bytes total)
        leaseKey.encode(dst, dstIndex); // LeaseKey (16 bytes)
        dstIndex += 16;

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sat Aug 23 02:21:31 UTC 2025

- 6.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/site-replication-metrics_gen.go

func (z RStat) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 2
	// write "Count"
	err = en.Append(0x82, 0xa5, 0x43, 0x6f, 0x75, 0x6e, 0x74)
	if err != nil {
		return
	}
	err = en.WriteInt64(z.Count)
	if err != nil {
		err = msgp.WrapError(err, "Count")
		return
	}
	// write "Bytes"
	err = en.Append(0xa5, 0x42, 0x79, 0x74, 0x65, 0x73)
	if err != nil {
		return
	}

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Tue Feb 06 06:00:45 UTC 2024

- 40.6K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/hash/SneakyThrows.java

   * However, we can't usually write {@code throw t;} when {@code t} has a static type of {@link
   * Throwable}. But we <i>can</i> write {@code sneakyThrow(t);}.
   *
   * <p>We sometimes also use {@code sneakyThrow} for testing how our code responds to
   * sneaky checked exception.
   *
   * @return never; this method declares a return type of {@link Error} only so that callers can

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Mon Dec 30 18:44:22 UTC 2024

- 2.4K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/base/SneakyThrows.java

   * However, we can't usually write {@code throw t;} when {@code t} has a static type of {@link
   * Throwable}. But we <i>can</i> write {@code sneakyThrow(t);}.
   *
   * <p>We sometimes also use {@code sneakyThrow} for testing how our code responds to
   * sneaky checked exception.
   *
   * @return never; this method declares a return type of {@link Error} only so that callers can

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Mon Feb 03 21:52:39 UTC 2025

- 2.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb2/tree/Smb2TreeDisconnectResponseTest.java

    }

    @Test
    @DisplayName("Should write empty bytes to wire format")
    void testWriteBytesWireFormat() {
        // Given
        byte[] buffer = new byte[256];
        int offset = 10;

        // When
        int bytesWritten = response.writeBytesWireFormat(buffer, offset);

        // Then
        assertEquals(0, bytesWritten);
    }

    @DisplayName("Should write zero bytes at various offsets")

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 14.1K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

 * following lifecycle:
 *
 *  1. [Send request headers][writeRequest].
 *  2. Open a sink to write the request body. Either [known][newKnownLengthSink] or
 *     [chunked][newChunkedSink].
 *  3. Write to and then close that sink.
 *  4. [Read response headers][readResponseHeaders].
 *  5. Open a source to read the response body. Either [fixed-length][newFixedLengthSource],

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Thu Jul 31 04:18:40 UTC 2025

- 17.5K bytes

- Viewed (7)

github.com/minio/minio

cmd/bucket-replication-metrics_gen.go

		return
	}
	// write "Bytes"
	err = en.Append(0xa5, 0x42, 0x79, 0x74, 0x65, 0x73)
	if err != nil {
		return
	}
	err = en.WriteFloat64(z.Curr.Bytes)
	if err != nil {
		err = msgp.WrapError(err, "Curr", "Bytes")
		return
	}
	// write "aq"
	err = en.Append(0xa2, 0x61, 0x71)
	if err != nil {
		return
	}
	// map header, size 2
	// write "Count"

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Thu Mar 21 17:21:35 UTC 2024

- 33.3K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/rdma/RdmaStatistics.java

        recordError();
    }

    /**
     * Record start of a write request
     *
     * @param bytes number of bytes being written
     */
    public void recordWriteRequest(int bytes) {
        // Track that a write was requested
        rdmaWrites.incrementAndGet();
    }

    /**
     * Record successful completion of a write request
     *
     * @param bytes number of bytes successfully written

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Sun Aug 24 00:12:28 UTC 2025

- 10.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/helper/ThemeHelperTest.java

            zos.putNextEntry(viewEntry);
            zos.write("<html>test</html>".getBytes());
            zos.closeEntry();

            // Add CSS file
            ZipEntry cssEntry = new ZipEntry("css/style.css");
            zos.putNextEntry(cssEntry);
            zos.write("body { color: red; }".getBytes());
            zos.closeEntry();
        }
    }

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Jul 19 23:49:30 UTC 2025

- 14.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/netbios/SocketOutputStream.java

    SocketOutputStream(final OutputStream out) {
        super(out);
    }

    @Override
    public synchronized void write(final byte[] b, int off, final int len) throws IOException {
        if (len > 0xFFFF) {
            throw new IOException("write too large: " + len);
        }
        if (off < 4) {
            throw new IOException("NetBIOS socket output buffer requires 4 bytes available before off");

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 07:14:38 UTC 2025

- 1.7K bytes

- Viewed (0)

Search Options