// if expected.length == 0, off has to be 0 but length doesn't matter--result will be empty
      int off = expected.length == 0 ? 0 : random.nextInt(expected.length);
      int len = expected.length == 0 ? 4 : random.nextInt(expected.length - off);

      ByteSourceFactory sliced = SourceSinkFactories.asSlicedByteSourceFactory(factory, off, len);
      suite.addTest(suiteForBytes(sliced, bytes, name + ".slice[long, long]", desc, false));

            }
            if (line.startsWith("\"buildTime\"")) {
                var date = line.substring(line.indexOf("\"", 12) + 1, line.lastIndexOf("\""))
                date = date.substring(0, 4) + "-" + date.substring(4, 6) + "-" + date.substring(6, 8)
                versions[version!!] = date
            }
        }
        return versions
    }


    private

                        byte[] buffer = new byte[100];
                        int written = req.writeBytesWireFormat(buffer, 0);
                        success[index] = (written == 4 && SMBUtil.readInt2(buffer, 0) == 4);
                    } catch (Exception e) {
                        success[index] = false;
                    }
                });
                threads[i].start();
            }

        assertEquals(52, SMBUtil.readInt4(buffer, 12)); // DataLength

        // Verify context name
        byte[] nameBytes = new byte[4];
        System.arraycopy(buffer, 16, nameBytes, 0, 4);
        assertEquals("DLse", new String(nameBytes));

        // Verify lease key (first 16 bytes of data)
        byte[] leaseKeyBytes = new byte[16];
        System.arraycopy(buffer, 24, leaseKeyBytes, 0, 16);

        try {
            int family = SMBUtil.readInt2(data, offset);
            if (family == 2) { // AF_INET
                byte[] addr = new byte[4];
                System.arraycopy(data, offset + 4, addr, 0, 4);
                return InetAddress.getByAddress(addr);
            } else if (family == 23) { // AF_INET6
                byte[] addr = new byte[16];
                System.arraycopy(data, offset + 8, addr, 0, 16);

<img src="/img/async/concurrent-burgers/concurrent-burgers-03.png" class="illustration">

Вы платите. 💸

Кассир выдаёт вам номер вашей очереди.

<img src="/img/async/concurrent-burgers/concurrent-burgers-04.png" class="illustration">

Пока вы ждёте, вы вместе со своей возлюбленной идёте и выбираете столик, садитесь и долго болтаете (ваши бургеры очень «навороченные», поэтому им нужно время на приготовление).

    class ParameterizedInit {
        static Stream<Arguments> validRanges() {
            byte[] src = new byte[] { 0, 1, 2, 3 };
            return Stream.of(Arguments.of(src, 0, 0, new byte[] {}), Arguments.of(src, 0, 4, new byte[] { 0, 1, 2, 3 }),
                    Arguments.of(src, 1, 2, new byte[] { 1, 2 }), Arguments.of(src, 3, 1, new byte[] { 3 }));
        }

        @ParameterizedTest(name = "slice off={1}, len={2}")

		{bucketNames[0], objectNames[0], uploadIDs[0], 3, "ijkl", "09a0877d04abf8759f99adec02baf579", int64(len("abcd")), "09a0877d04abf8759f99adec02baf579"},
		{bucketNames[0], objectNames[0], uploadIDs[0], 4, "mnop", "e132e96a5ddad6da8b07bba6f6131fef", int64(len("abcd")), "e132e96a5ddad6da8b07bba6f6131fef"},
		// Cases 5-7.
		// Create parts with 3 uploadID's for the same object.

            SMBUtil.writeInt2(EncryptionNegotiateContext.CIPHER_AES128_CCM, buffer, 2);

            EncryptionNegotiateContext context = new EncryptionNegotiateContext();
            int bytesRead = context.decode(buffer, 0, 4);

            assertEquals(4, bytesRead);
            assertNotNull(context.getCiphers());
            assertEquals(1, context.getCiphers().length);

github.com/felixge/fgprof v0.9.5 h1:8+vR6yu2vvSKn08urWyEuxx75NWPEvybbkBirEpsbVY=
github.com/felixge/fgprof v0.9.5/go.mod h1:yKl+ERSa++RYOs32d8K6WEXCB4uXdLls4ZaZPpayhMM=
github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=
github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw=