written - Code Search

src/main/java/jcifs/smb/SmbRandomAccessFile.java

        }
        return 0;
    }

    @Override
    public void write(final int b) throws SmbException {
        this.tmp[0] = (byte) b;
        write(this.tmp, 0, 1);
    }

    @Override
    public void write(final byte b[]) throws SmbException {
        write(b, 0, b.length);
    }

    @Override
    public void write(final byte b[], int off, int len) throws SmbException {
        if (len <= 0) {

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 16 01:32:48 GMT 2025

- 18.8K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/collect/MapMaker.java

   * be performed atomically on the returned map. Additionally, {@code size} and {@code
   * containsValue} are implemented as bulk read operations, and thus may fail to observe concurrent
   * writes.
   *
   * @return a serializable concurrent map having the requested features
   */
  public <K, V> ConcurrentMap<K, V> makeMap() {
    if (!useCustomMap) {

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Aug 07 16:05:33 GMT 2025

- 12.8K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt

    DeflaterSink(buffer, Deflater(Deflater.DEFAULT_COMPRESSION, true)).use { sink ->
      sink.write(Buffer().write(message1), message1.size.toLong())
    }
    buffer.writeByte(0x00)
    // Trailing data. We use the Okio segment size to make sure it's still in the input buffer.
    buffer.write(ByteArray(8192))
    inflater.inflate(buffer)
    assertThat(buffer.readByteString()).isEqualTo(message1)

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Sun Sep 21 06:26:07 GMT 2025

- 6.4K bytes

- Click Count (0)

github.com/minio/minio

internal/s3select/genmessage.go

	prelude := buf.Bytes()
	binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude))
	buf.Write(header)
	message := buf.Bytes()
	binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(message))

	fmt.Println(buf.Bytes())
}

func genProgressHeader() {
	buf := new(bytes.Buffer)

	buf.WriteByte(13)
	buf.WriteString(":message-type")
	buf.WriteByte(7)

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Thu Aug 19 01:35:22 GMT 2021

- 4.4K bytes

- Click Count (0)

github.com/minio/minio

internal/s3select/sql/record.go

type Record interface {
	Get(name string) (*Value, error)

	// Set a value.
	// Can return a different record type.
	Set(name string, value *Value) (Record, error)
	WriteCSV(writer io.Writer, opts WriteCSVOpts) error
	WriteJSON(writer io.Writer) error

	// Clone the record and if possible use the destination provided.
	Clone(dst Record) Record
	Reset()

	// Returns underlying representation
	Raw() (SelectObjectFormat, any)

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 3.4K bytes

- Click Count (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();
        }
    }

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Wed Jan 14 14:29:07 GMT 2026

- 14.7K bytes

- Click Count (0)

github.com/golang/go

src/cmd/asm/internal/asm/parse.go

		return nil, false
	}
	p.patch()
	return p.firstProg, true
}

// ParseSymABIs parses p's assembly code to find text symbol
// definitions and references and writes a symabis file to w.
func (p *Parser) ParseSymABIs(w io.Writer) bool {
	operands := make([][]lex.Token, 0, 3)
	for {
		word, _, operands1, ok := p.line(operands)
		if !ok {
			break
		}
		operands = operands1

Created: Tue Apr 07 11:13:11 GMT 2026

- Last Modified: Tue Feb 17 19:57:47 GMT 2026

- 37.3K bytes

- Click Count (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")

Created: Sun Apr 05 00:10:12 GMT 2026

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

- 14.1K bytes

- Click Count (0)

github.com/apache/maven

impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Decrypt.java

        if (secDispatcher.isAnyEncryptedString(encrypted)) {
            context.terminal.writer().println(secDispatcher.decrypt(encrypted));
            return OK;
        } else {
            context.terminal.writer().println(messageBuilderFactory.builder().error("Malformed encrypted string"));
            return BAD_OPERATION;
        }
    }

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Tue Dec 17 09:50:45 GMT 2024

- 2.1K bytes

- Click Count (0)

github.com/codelibs/fess-suggest

src/main/java/org/codelibs/fess/suggest/index/writer/SuggestWriterResult.java

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.suggest.index.writer;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

/**
 * The SuggestWriterResult class is used to store and manage the results of a suggest writer operation.
 * It keeps track of any failures that occur during the operation.
 */
public class SuggestWriterResult {
    /**

Created: Fri Apr 17 09:08:13 GMT 2026

- Last Modified: Fri Jul 04 14:00:23 GMT 2025

- 1.9K bytes

- Click Count (0)

Search Options