// When - simulate concurrent requests
            Thread thread1 = new Thread(() -> transportPool.getSmbTransport(context, address, DEFAULT_PORT, false));
            Thread thread2 = new Thread(() -> transportPool.getSmbTransport(context, address, DEFAULT_PORT, true));

            thread1.start();
            thread2.start();

    return new Stopwatch(ticker);
  }

  /**
   * Creates (and starts) a new stopwatch using {@link System#nanoTime} as its time source.
   *
   * @since 15.0
   */
  public static Stopwatch createStarted() {
    return new Stopwatch().start();
  }

  /**
   * Creates (and starts) a new stopwatch, using the specified time source.
   *
   * @since 15.0
   */

                if (context == null) {
                    context = new byte[8];
                }
            }
            int data = 32;
            if (context != null) {
                data += 8;
            }
            if (targetInformation != null) {
                data += 8;
            }
            final byte[] type2 = new byte[data + target.length + (targetInformation != null ? targetInformation.length : 0)];

    void testWriteSetupWireFormat() {
        byte[] buffer = new byte[100];
        int result = response.writeSetupWireFormat(buffer, 0);

        assertEquals(0, result);
    }

    @Test
    @DisplayName("Test writeParametersWireFormat returns 0")
    void testWriteParametersWireFormat() {
        byte[] buffer = new byte[100];
        int result = response.writeParametersWireFormat(buffer, 0);

public class CurlHelperTest extends UnitFessTestCase {

    private CurlHelper curlHelper;

    @Override
    protected void setUp(TestInfo testInfo) throws Exception {
        super.setUp(testInfo);
        curlHelper = new CurlHelper();
    }

    @Test
    public void test_get() {
        // Mock FessConfig and ResourceUtil
        setupMockConfig("localhost:9200", "", "");

        curlHelper.init();

            default:
                throw new IllegalArgumentException(new String(arr, offset, length));
            }
            count++;
        }

        return value;
    }

    static final char[] HEXCHARS = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F' };

    private static String bin_to_hex(int value, final int length) {
        final char[] arr = new char[length];
        int ai = arr.length;

    private final byte[] in;
    private int inLen;

    /**
     * Creates a new MimeMap instance by loading MIME type mappings from the resource file.
     *
     * @throws IOException if there is an error reading the mime.map resource file
     */
    public MimeMap() throws IOException {
        int n;

        in = new byte[IN_SIZE];

omment}\n${type_declaration}</template><template autoinsert\="true" context\="classbody_context" deleted\="false" description\="Code in new class type bodies" enabled\="true" id\="org.eclipse.jdt.ui.text.codetemplates.classbody" name\="classbody">\n</template><template autoinsert\="true" context\="interfacebody_context" deleted\="false" description\="Code in new interface type bodies" enabled\="true" id\="org.eclipse.jdt.ui.text.codetemplates.interfacebody" name\="interfacebody">\n</template><template...

    }

    @Test
    public void test_multipleInstancesHaveIndependentSettings() {
        final SuppressErrorReportValve valve1 = new SuppressErrorReportValve();
        final SuppressErrorReportValve valve2 = new SuppressErrorReportValve();

        valve1.setShowReport(true);
        valve1.setShowServerInfo(true);

        // valve2 should still have default values

                    addRule(KotlinModifiersBreakingChangeRule, ruleParams)
                    addRule(JApiChangeStatus.NEW, IncubatingMissingRule, ruleParams)
                    addRule(JApiChangeStatus.NEW, SinceAnnotationRule, ruleParams)
                    addRule(JApiChangeStatus.NEW, NewIncubatingAPIRule, ruleParams)

                    addSetupRule(AcceptedRegressionsRuleSetup, [acceptedApiChanges: acceptedChanges])