}

    @Test
    @DisplayName("Test decode reads correct number of bytes")
    void testDecodeReadsCorrectBytes() throws SMBProtocolDecodingException {
        // Prepare test data
        byte[] buffer = new byte[22];

        // Fill with pattern to verify we read correct bytes
        for (int i = 0; i < buffer.length; i++) {
            buffer[i] = (byte) (i + 1);
        }

        // Decode

 * <tr>
 * <th>{@link URL}</th>
 * <td>bytes</td>
 * <td>characters</td>
 * <td>bytes, characters</td>
 * <td>characters</td>
 * </tr>
 * <tr>
 * <th>{@literal byte[]}</th>
 * <td>bytes</td>
 * <td>characters</td>
 * <td>bytes, characters</td>
 * <td>characters</td>
 * </tr>
 * <tr>
 * <th>{@link String}</th>
 * <td>characters</td>
 * <td>characters</td>
 * <td>characters</td>
 * <td>&times;</td>
 * </tr>

    }

    /**
     * Reads up to b.length bytes of data from this input stream into an array of bytes.
     *
     * @throws IOException
     *             if a network error occurs
     */

    @Override
    public int read(final byte[] b) throws IOException {
        return read(b, 0, b.length);
    }

    /**
     * Reads up to len bytes of data from this input stream into an array of bytes.
     *

			var buf bytes.Buffer
			err := pprof.Lookup("threadcreate").WriteTo(&buf, 0)
			return buf.Bytes(), err
		}
	case madmin.ProfilerGoroutines:
		prof.ext = "txt"
		prof.record("goroutine", 1, "before")
		prof.record("goroutine", 2, "before,debug=2")
		prof.stopFn = func() ([]byte, error) {
			var buf bytes.Buffer
			err := pprof.Lookup("goroutine").WriteTo(&buf, 1)
			return buf.Bytes(), err
		}
	case madmin.ProfilerTrace:

     * Get size of this structure
     *
     * @return size in bytes (16)
     */
    public static int size() {
        return 16; // 8 + 4 + 4
    }

    /**
     * Encode this structure to byte array
     *
     * @param dst destination buffer
     * @param dstIndex starting index
     * @return number of bytes written
     */
    public int encode(byte[] dst, int dstIndex) {

      listeners.put(state, listener);
    }

    return slackApi.authorizeUrl(scopes, redirectUrl(), state, team);
  }

  private ByteString randomToken() {
    byte[] bytes = new byte[16];
    secureRandom.nextBytes(bytes);
    return ByteString.of(bytes);
  }

  private HttpUrl redirectUrl() {
    return mockWebServer.url("/oauth/");
  }

            // Pad with zeros if context handle is shorter than 20 bytes
            for (int i = contextHandle.length; i < 20; i++) {
                buf.enc_ndr_small(0);
            }
        } else {
            // Write 20 zero bytes for null context handle
            for (int i = 0; i < 20; i++) {
                buf.enc_ndr_small(0);
            }
        }

        // When
        byte[] bytes;
        try (ByteArrayOutputStream bout = new ByteArrayOutputStream(); ObjectOutputStream oout = new ObjectOutputStream(bout)) {
            oout.writeObject(original);
            oout.flush();
            bytes = bout.toByteArray();
        }

        SpnegoException restored;

//go:build go1.21

package logger

import (
	"bytes"
	"context"
	"log/slog"
	"strings"
	"testing"
	"time"
)

func TestSlogLogger(t *testing.T) {
	buf := &bytes.Buffer{}
	handler := slog.NewTextHandler(buf, &slog.HandlerOptions{AddSource: true})
	logger := NewSlogLogger(slog.New(handler), Config{LogLevel: Info})

	logger.Trace(context.Background(), time.Now(), func() (string, int64) {
		return "select count(*) from users", 0

            byte[] buffer = new byte[24];
            // alloc (8 bytes) - 0x0000000100000000 (4294967296)
            buffer[4] = 0x01;
            // free (8 bytes) - 0x0000000080000000 (2147483648)
            buffer[12] = (byte) 0x80;
            // sectPerAlloc (4 bytes) - 8
            buffer[16] = 0x08;
            // bytesPerSect (4 bytes) - 512
            buffer[20] = 0x00;