| 603 | } |
| 604 | |
| 605 | void AsyncHttpClient::processCmdQueue() |
| 606 | { |
| 607 | if (true == takeGlobalMutex()) |
| 608 | { |
| 609 | Cmd cmd; |
| 610 | |
| 611 | if (true == m_cmdQueue.receive(&cmd, 0U)) |
| 612 | { |
| 613 | switch (cmd.id) |
| 614 | { |
| 615 | case CMD_ID_GET: |
| 616 | if (false == getRequest()) |
| 617 | { |
| 618 | onError(ERR_CONN); |
| 619 | notifyClosed(); |
| 620 | giveGlobalMutex(); |
| 621 | } |
| 622 | break; |
| 623 | |
| 624 | case CMD_ID_POST: |
| 625 | if (false == postRequest(cmd.u.data.data, cmd.u.data.size)) |
| 626 | { |
| 627 | onError(ERR_CONN); |
| 628 | notifyClosed(); |
| 629 | giveGlobalMutex(); |
| 630 | } |
| 631 | break; |
| 632 | |
| 633 | default: |
| 634 | break; |
| 635 | }; |
| 636 | } |
| 637 | else |
| 638 | { |
| 639 | giveGlobalMutex(); |
| 640 | } |
| 641 | } |
| 642 | } |
| 643 | |
| 644 | void AsyncHttpClient::processEvtQueue() |
| 645 | { |