"service_name": "outbound|2000||s1tcp.none"
      },
      "connect_timeout": 1000000000,
      "circuit_breakers": {
        "thresholds": [
          {
            "max_retries": {
              "value": 1024
            }
          }
        ]
      },
      "LbConfig": null
    },
    "outbound|2001||s1http.none": {
      "name": "outbound|2001||s1http.none",
      "type": 3,
      "eds_cluster_config": {

	defer wg.Wait()

	c1.SetReadDeadline(time.Now().Add(time.Millisecond))
	for i := 0; i < 10; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()

			b1 := make([]byte, 1024)
			b2 := make([]byte, 1024)
			for j := 0; j < 100; j++ {
				_, err := c1.Read(b1)
				copy(b1, b2) // Mutate b1 to trigger potential race
				if err != nil {
					checkForTimeoutError(t, err)

#define PLATFORM_H

extern const char* platform_name;

int max_path_length();

unsigned long long max_memory();

int is_posix_like();

#define KB(x) x
#define MB(x) KB(x)*1024
#define GB(x) MB(x)*1024
#define TB(x) GB(x)*1024

    //
    // TODO(user): Consider scaling by number of mutator threads,
    // e.g. using Thread#activeCount()
    return Math.max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
  }

  /**
   * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
   * as necessary to try to ensure that this will happen.
   *

	// will clobber the test pattern created by the caller
	ADD	$(1024*8), X2

	// Ask signaller to setgid
	MOV	$1, X5
	FENCE
	MOVW	X5, ·Baton(SB)
	FENCE

	// Wait for setgid completion
loop:
	FENCE
	MOVW	·Baton(SB), X5
	OR	X6, X6, X6	// hint that we're in a spin loop
	BNE	ZERO, X5, loop
	FENCE

	// Restore stack
	ADD	$(-1024*8), X2

	"./a"
)

func F1() int {
	var buf [1024]int
	a.F1(uintptr(unsafe.Pointer(&buf[0])))
	return buf[0]
}

func F2() int {
	var buf [1024]int
	a.F2(uintptr(unsafe.Pointer(&buf[0])))
	return buf[0]
}

var t = a.GetT()

func M1() int {
	var buf [1024]int
	t.M1(uintptr(unsafe.Pointer(&buf[0])))
	return buf[0]
}

func M2() int {
	var buf [1024]int
	t.M2(uintptr(unsafe.Pointer(&buf[0])))

  %6 = tfrt_fallback_async.executeop key(1) cost(1024) device("/job:localhost/replica:0/task:0/device:CPU:0") "tf.AddV2"(%arg, %arg) {T = f32} : 1
  %7 = tfrt_fallback_async.executeop key(1) cost(1024) device("/job:localhost/replica:0/task:0/device:CPU:0") "tf.AddV2"(%arg, %arg) {T = f32} : 1

						NUMAAffinity: []int{0},
						Type:         v1.ResourceMemory,
						Size:         1024,
					},
				},
			},
		},
		machineState: NUMANodeMap{
			0: &NUMANodeState{
				MemoryMap: map[v1.ResourceName]*MemoryTable{
					v1.ResourceMemory: {
						Allocatable:    1536,
						Free:           512,
						Reserved:       1024,
						SystemReserved: 512,
						TotalMemSize:   2048,
					},
				},
			},

            inputStream.read(new byte[560])
            inputStream.read(new byte[1000])
            inputStream.read(new byte[1600])
            inputStream.read(new byte[1024])
            inputStream.read(new byte[1024])
            "result"
        }
        1 * context.progress(1562, 4096, 'bytes', '1.5 KiB/4 KiB downloaded')
        1 * context.progress(3162, 4096, 'bytes', '3 KiB/4 KiB downloaded')

import org.dbflute.utflute.core.PlainTestCase;

/**
 * @author shinsuke
 *
 */
public class ContentLengthHelperTest extends PlainTestCase {
    private static long DEFAULT_MAX_LENGTH = 10L * 1024L * 1024L;

    public ContentLengthHelper contentLengthHelper;

    @Override
    protected void setUp() throws Exception {
        super.setUp();