)

        synchronized(this@Relay) {
          // Append new upstream bytes into the buffer. Trim it to its max size.
          buffer.write(upstreamBuffer, upstreamBytesRead)
          if (buffer.size > bufferMaxSize) {
            buffer.skip(buffer.size - bufferMaxSize)
          }

          // Now that the file and buffer have bytes, adjust upstreamPos.
          ******@****.***amPos += upstreamBytesRead
        }

  //   * length of whole buffer (int32_t)
  //   * num of strings (int32_t).
  int32_t bytes = data_.size()                            // size of content
                  + sizeof(int32_t) * (num_strings + 2);  // size of header
  // Caller will take ownership of buffer.
  *buffer = reinterpret_cast<char*>(malloc(bytes));

  if (*buffer == nullptr) {
    return -1;
  }

  // Set num of string

// CHECK-NEXT:     tensors: [ {
// CHECK-NEXT:       shape: [ 4, 4, 4 ],
// CHECK-NEXT:       buffer: 1,
// CHECK-NEXT:       name: "arg0",
// CHECK-NEXT:       quantization: {
// CHECK-EMPTY:
// CHECK-NEXT:       },
// CHECK-NEXT:       has_rank: true
// CHECK-NEXT:     }, {
// CHECK-NEXT:       shape: [ 4, 4 ],
// CHECK-NEXT:       buffer: 2,
// CHECK-NEXT:       name: "arg1",
// CHECK-NEXT:       quantization: {
// CHECK-EMPTY:

    protected int readHeaderWireFormat ( byte[] buffer, int bufferIndex ) {
        // these are common between SYNC/ASYNC
        SMBUtil.readInt4(buffer, bufferIndex);
        bufferIndex += 4;
        SMBUtil.readInt2(buffer, bufferIndex);
        this.creditCharge = SMBUtil.readInt2(buffer, bufferIndex + 2);
        bufferIndex += 4;
        this.status = SMBUtil.readInt4(buffer, bufferIndex);
        bufferIndex += 4;

// license that can be found in the LICENSE file.

package main

import "fmt"

type Buffer int

func (*Buffer) Read() {}

type Reader interface {
	Read()
}

func f() *Buffer { return nil }

func g() Reader {
	// implicit interface conversion in assignment during return
	return f()
}

func h() (b *Buffer, ok bool) { return }

func i() (r Reader, ok bool) {

            waitForContent();
            if (readPos != buffer.length) {
                int count = Math.min(length, buffer.length - readPos);
                System.arraycopy(buffer, readPos, dest, offset, count);
                readPos += count;
                return count;
            } else {
                // Closed
                return -1;
            }
        }
    }

    private void waitForContent() {

	testCases := []struct {
		name string
		run  func(sb runtime.Splice, buf *bytes.Buffer)
	}{
		{
			name: "Basic Write",
			run: func(sb runtime.Splice, buf *bytes.Buffer) {
				sb.Write(testBytes0)
				buf.Write(testBytes0)
			},
		},
		{
			name: "Multiple Writes",
			run: func(sb runtime.Splice, buf *bytes.Buffer) {
				for _, b := range testBytes0 {
					sb.Write([]byte{b})
					buf.Write([]byte{b})

            logger.info("");

            MessageBuilder buffer = builder().strong(">>> ");
            append(buffer, event.getMojoExecution());
            buffer.strong(" > ");
            appendForkInfo(buffer, event.getMojoExecution().getMojoDescriptor());
            append(buffer, event.getProject());
            buffer.strong(" >>>");

            logger.info(buffer.toString());
        }
    }

    protected int readParameterWordsWireFormat ( byte[] buffer, int bufferIndex ) {
        int start = bufferIndex;

        this.fid = SMBUtil.readInt2(buffer, bufferIndex);
        bufferIndex += 2;

        this.typeOfLock = buffer[ bufferIndex ];

        if ( ( this.typeOfLock & 0x10 ) == 0x10 ) {
            this.largeFile = true;
        }

        this.newOpLockLevel = buffer[ bufferIndex + 1 ];
        bufferIndex += 2;

  private fun String.map(): String {
    val buffer = Buffer()
    for (codePoint in codePoints()) {
      require(table.map(codePoint, buffer))
    }
    return buffer.readUtf8()
  }

  private fun String.mapExpectingErrors(): String {
    val buffer = Buffer()
    var errorCount = 0
    for (codePoint in codePoints()) {
      if (!table.map(codePoint, buffer)) errorCount++
    }