| 921 | } |
| 922 | |
| 923 | bool AsyncHttpClient::getRequest() |
| 924 | { |
| 925 | bool status = false; |
| 926 | bool isReqOpen = false; |
| 927 | |
| 928 | /* Protect against concurrent access. */ |
| 929 | { |
| 930 | MutexGuard<Mutex> guard(m_mutex); |
| 931 | |
| 932 | isReqOpen = m_isReqOpen; |
| 933 | } |
| 934 | |
| 935 | if (false == isReqOpen) |
| 936 | { |
| 937 | m_method = "GET"; |
| 938 | m_payload = nullptr; |
| 939 | m_payloadSize = 0U; |
| 940 | |
| 941 | if (false == m_tcpClient.connected()) |
| 942 | { |
| 943 | status = connect(); |
| 944 | isReqOpen = status; |
| 945 | } |
| 946 | else |
| 947 | { |
| 948 | status = sendRequest(); |
| 949 | isReqOpen = false; |
| 950 | } |
| 951 | |
| 952 | /* Protect against concurrent access. */ |
| 953 | { |
| 954 | MutexGuard<Mutex> guard(m_mutex); |
| 955 | |
| 956 | m_isReqOpen = isReqOpen; |
| 957 | } |
| 958 | } |
| 959 | |
| 960 | return status; |
| 961 | } |
| 962 | |
| 963 | bool AsyncHttpClient::postRequest(const uint8_t* payload, size_t size) |
| 964 | { |
nothing calls this directly
no outgoing calls
no test coverage detected