| 73 | *****************************************************************************/ |
| 74 | |
| 75 | AsyncHttpClient::AsyncHttpClient() : |
| 76 | m_processTaskHandle(nullptr), |
| 77 | m_processTaskExit(false), |
| 78 | m_processTaskSemaphore(nullptr), |
| 79 | m_allocator(), |
| 80 | m_tcpClient(), |
| 81 | m_cmdQueue(), |
| 82 | m_evtQueue(), |
| 83 | m_mutex(), |
| 84 | m_hasGlobalMutex(false), |
| 85 | m_isConnected(false), |
| 86 | m_isReqOpen(false), |
| 87 | m_onRspCallback(nullptr), |
| 88 | m_onClosedCallback(), |
| 89 | m_onErrorCallback(), |
| 90 | m_hostname(), |
| 91 | m_port(0U), |
| 92 | m_isSecure(false), |
| 93 | m_base64Authorization(), |
| 94 | m_uri(), |
| 95 | m_headers(), |
| 96 | m_method(), |
| 97 | m_userAgent("AsyncHttpClient"), |
| 98 | m_isHttpVer10(false), |
| 99 | m_isKeepAlive(false), |
| 100 | m_urlEncodedPars(), |
| 101 | m_payload(nullptr), |
| 102 | m_payloadSize(0U), |
| 103 | m_rspPart(RESPONSE_PART_STATUS_LINE), |
| 104 | m_rsp(), |
| 105 | m_rspLine(), |
| 106 | m_transferCoding(TRANSFER_CODING_IDENTITY), |
| 107 | m_contentLength(0U), |
| 108 | m_contentIndex(0U), |
| 109 | m_chunkSize(0U), |
| 110 | m_chunkIndex(0U), |
| 111 | m_chunkBodyPart(CHUNK_SIZE), |
| 112 | m_isError(false) |
| 113 | { |
| 114 | (void)m_cmdQueue.create(CMD_QUEUE_SIZE); |
| 115 | (void)m_evtQueue.create(EVT_QUEUE_SIZE); |
| 116 | (void)m_mutex.create(); |
| 117 | |
| 118 | m_tcpClient.onConnect([this](void* arg, AsyncClient* client) { |
| 119 | Event evt; |
| 120 | |
| 121 | UTIL_NOT_USED(arg); |
| 122 | UTIL_NOT_USED(client); |
| 123 | |
| 124 | memset(&evt, 0, sizeof(evt)); |
| 125 | evt.id = EVENT_ID_CONNECTED; |
| 126 | |
| 127 | (void)m_evtQueue.sendToBack(evt, portMAX_DELAY); |
| 128 | }); |
| 129 | |
| 130 | m_tcpClient.onDisconnect([this](void* arg, AsyncClient* client) { |
| 131 | Event evt; |
| 132 |
nothing calls this directly
no test coverage detected