<commit_before>// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

#include <stdlib.h>
#ifdef _CRTDBG_MAP_ALLOC
#include <crtdbg.h>
#endif
#include "gballoc.h"
#include <stdio.h>
#include <string.h>
#include <signal.h>
#include <ctype.h>
#include <math.h>
#include <time.h>
#include <limits.h>
#include "urlencode.h"
#include "crt_abstractions.h"

#include "threadapi.h"
#include "strings.h"
#include "iothubtest.h"
#include "iot_logging.h"
#include "connection.h"
#include "message_receiver.h"
#include "message_sender.h"
#include "messaging.h"
#include "tlsio.h"
#include "platform.h"
#include "sasl_mechanism.h"
#include "saslclientio.h"
#include "sasl_plain.h"
#include "cbs.h"
#include "consolelogger.h"

const char* AMQP_RECV_ADDRESS_FMT = "%s/ConsumerGroups/%s/Partitions/%u";
const char* AMQP_ADDRESS_PATH_FMT = "/devices/%s/messages/deviceBound";
const char* AMQP_SEND_TARGET_ADDRESS_FMT = "amqps://%s/messages/deviceBound";
const char* AMQP_SEND_AUTHCID_FMT = "<EMAIL>.root.%s";

#define PROTON_DEFAULT_TIMEOUT      20*1000
#define THREAD_CONTINUE             0
#define THREAD_END                  1
#define MAX_DRAIN_TIME              1000.0
#define MAX_SHORT_VALUE             32767         /* maximum (signed) short value */

DEFINE_ENUM_STRINGS(IOTHUB_TEST_CLIENT_RESULT, IOTHUB_TEST_CLIENT_RESULT_VALUES);

typedef enum MESSAGE_SEND_STATE_TAG
{
    MESSAGE_SEND_STATE_NOT_SENT,
    MESSAGE_SEND_STATE_SEND_IN_PROGRESS,<commit_msg>Removed one PROTON_TIMEOUT artifacts from iothubtest<commit_after>// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

#include <stdlib.h>
#ifdef _CRTDBG_MAP_ALLOC
#include <crtdbg.h>
#endif
#include "gballoc.h"
#include <stdio.h>
#include <string.h>
#include <signal.h>
#include <ctype.h>
#include <math.h>
#include <time.h>
#include <limits.h>
#include "urlencode.h"
#include "crt_abstractions.h"

#include "threadapi.h"
#include "strings.h"
#include "iothubtest.h"
#include "iot_logging.h"
#include "connection.h"
#include "message_receiver.h"
#include "message_sender.h"
#include "messaging.h"
#include "tlsio.h"
#include "platform.h"
#include "sasl_mechanism.h"
#include "saslclientio.h"
#include "sasl_plain.h"
#include "cbs.h"
#include "consolelogger.h"

const char* AMQP_RECV_ADDRESS_FMT = "%s/ConsumerGroups/%s/Partitions/%u";
const char* AMQP_ADDRESS_PATH_FMT = "/devices/%s/messages/deviceBound";
const char* AMQP_SEND_TARGET_ADDRESS_FMT = "amqps://%s/messages/deviceBound";
const char* AMQP_SEND_AUTHCID_FMT = "iothubowner@sas.root.%s";

#define THREAD_CONTINUE             0
#define THREAD_END                  1
#define MAX_DRAIN_TIME              1000.0
#define MAX_SHORT_VALUE             32767         /* maximum (signed) short value */

DEFINE_ENUM_STRINGS(IOTHUB_TEST_CLIENT_RESULT, IOTHUB_TEST_CLIENT_RESULT_VALUES);

typedef enum MESSAGE_SEND_STATE_TAG
{
    MESSAGE_SEND_STATE_NOT_SENT,
    MESSAGE_SEND_STATE_SEND_IN_PROGRESS,
{'fraction_non_alphanumeric': 0.11930164888457807, 'fraction_numerical': 0.009699321047526674, 'mean_word_length': 4.9272030651340994, 'pattern_counts': {'":': 0, '<': 22, '<?xml version=': 0, '>': 22, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 1, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3392948', 'n_tokens_mistral': 1184, 'n_tokens_neox': 1142, 'n_words': 245}