| | |
| | | const std::string& payload = msg->get_payload(); |
| | | switch (msg->get_opcode()) { |
| | | case websocketpp::frame::opcode::text: |
| | | LOG(INFO)<<"on_message = " << payload; |
| | | total_num=total_num+1; |
| | | LOG(INFO)<<total_num<<",on_message = " << payload; |
| | | if((total_num+1)==wav_index) |
| | | { |
| | | websocketpp::lib::error_code ec; |
| | | m_client.close(m_hdl, websocketpp::close::status::going_away, "", ec); |
| | | if (ec){ |
| | | LOG(ERROR)<< "Error closing connection " << ec.message(); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | |
| | | send_wav_data(wav_list[i], wav_ids[i]); |
| | | } |
| | | WaitABit(); |
| | | m_client.close(m_hdl, websocketpp::close::status::going_away, "", ec); |
| | | if (ec){ |
| | | LOG(ERROR)<< "Error closing connection " << ec.message(); |
| | | } |
| | | |
| | | asio_thread.join(); |
| | | |
| | | } |
| | | |
| | | // The open handler will signal that we are ready to start sending data |
| | |
| | | websocketpp::lib::mutex m_lock; |
| | | bool m_open; |
| | | bool m_done; |
| | | int total_num=0; |
| | | }; |
| | | |
| | | int main(int argc, char* argv[]) { |