Buf - Code Search

src/main/java/jcifs/internal/smb1/trans/SmbComTransactionResponse.java


    /**
     * @param buffer
     */
    public void setBuffer ( byte[] buffer ) {
        this.txn_buf = buffer;
    }


    /**
     * @return the txn_buf
     */
    public byte[] releaseBuffer () {
        byte[] buf = this.txn_buf;
        this.txn_buf = null;
        return buf;
    }


    /**
     * @return the subCommand
     */
    public final byte getSubCommand () {

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Sun Jul 01 13:12:10 GMT 2018

- 9.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/local-locker_gen_test.go

	v := localLockMap{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodelocalLockMap Msgsize() is inaccurate")
	}

	vn := localLockMap{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}
}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Mon Feb 19 22:54:46 GMT 2024

- 6.7K bytes

- Viewed (0)

github.com/minio/minio

internal/dsync/lock-args_gen_test.go

	v := LockArgs{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodeLockArgs Msgsize() is inaccurate")
	}

	vn := LockArgs{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}
}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Nov 21 01:09:35 GMT 2023

- 4.4K bytes

- Viewed (0)

github.com/minio/minio

docs/debugging/inspect/export.go

	hdrVer, buf, e := msgp.ReadUintBytes(buf)
	if e != nil {
		return 0, buf, e
	}
	metaVer, buf, e := msgp.ReadUintBytes(buf)
	if e != nil {
		return 0, buf, e
	}
	if hdrVer > xlHeaderVersion {
		return 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl header version %d", metaVer)
	}
	if metaVer > xlMetaVersion {
		return 0, buf, fmt.Errorf("decodeXLHeaders: Unknown xl meta version %d", metaVer)
	}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Tue Nov 08 15:58:02 GMT 2022

- 9.1K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/hash/HashingInputStreamTest.java

    assertEquals(4, numOfByteRead);

    assertEquals(expectedHash, in.hash());
  }

  public void testHash_hashesCorrectlyReadOutOfBound() throws Exception {
    HashCode expectedHash = Hashing.md5().hashBytes(testBytes);
    HashingInputStream in = new HashingInputStream(Hashing.md5(), buffer);

    byte[] buf = new byte[100];
    int numOfByteRead = in.read(buf, 0, buf.length);

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Fri Oct 02 16:24:50 GMT 2020

- 5K bytes

- Viewed (0)

github.com/codelibs/corelib

src/main/java/org/codelibs/core/text/JsonUtil.java

        final StringBuilder buf = new StringBuilder(len * 2);

        for (int i = 0; i < len; i++) {
            c = value.charAt(i);
            switch (c) {
            case '\\':
            case '"':
                buf.append('\\');
                buf.append(c);
                break;
            case '/':
                buf.append('\\');
                buf.append(c);
                break;

Java

- Registered: Fri May 03 20:58:11 GMT 2024

- Last Modified: Thu Mar 07 01:59:08 GMT 2024

- 2.3K bytes

- Viewed (0)

github.com/golang/go

src/bytes/reader_test.go

		}
	}
}

func TestReaderDoubleUnreadRune(t *testing.T) {
	buf := NewBuffer([]byte("groucho"))
	if _, _, err := buf.ReadRune(); err != nil {
		// should not happen
		t.Fatal(err)
	}
	if err := buf.UnreadByte(); err != nil {
		// should not happen
		t.Fatal(err)
	}
	if err := buf.UnreadByte(); err == nil {
		t.Fatal("UnreadByte: expected error, got nil")
	}
}

Go

- Registered: Tue Apr 30 11:13:12 GMT 2024

- Last Modified: Mon Dec 13 18:45:54 GMT 2021

- 8K bytes

- Viewed (0)

github.com/google/guava

guava-tests/benchmark/com/google/common/io/CharStreamsCopyBenchmark.java

    OLD {
      @Override
      long copy(Readable from, Appendable to) throws IOException {
        CharBuffer buf = CharStreams.createBuffer();
        long total = 0;
        while (from.read(buf) != -1) {
          ((Buffer) buf).flip();
          to.append(buf);
          total += buf.remaining();
          ((Buffer) buf).clear();
        }
        return total;
      }
    },
    NEW {
      @Override

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Thu Feb 23 18:59:54 GMT 2023

- 3.2K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/benchmark/com/google/common/io/CharStreamsCopyBenchmark.java

    OLD {
      @Override
      long copy(Readable from, Appendable to) throws IOException {
        CharBuffer buf = CharStreams.createBuffer();
        long total = 0;
        while (from.read(buf) != -1) {
          ((Buffer) buf).flip();
          to.append(buf);
          total += buf.remaining();
          ((Buffer) buf).clear();
        }
        return total;
      }
    },
    NEW {
      @Override

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Thu Feb 23 18:59:54 GMT 2023

- 3.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/site-replication-utils_gen_test.go

	v := SiteResyncStatus{}
	var buf bytes.Buffer
	msgp.Encode(&buf, &v)

	m := v.Msgsize()
	if buf.Len() > m {
		t.Log("WARNING: TestEncodeDecodeSiteResyncStatus Msgsize() is inaccurate")
	}

	vn := SiteResyncStatus{}
	err := msgp.Decode(&buf, &vn)
	if err != nil {
		t.Error(err)
	}

	buf.Reset()
	msgp.Encode(&buf, &v)
	err = msgp.NewReader(&buf).Skip()
	if err != nil {
		t.Error(err)
	}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Mon Nov 14 15:16:40 GMT 2022

- 2.4K bytes

- Viewed (0)

Search Options