Browse Source

update

disinfection_machine
zhaohe 1 year ago
parent
commit
d3f953abc7
  1. 6
      src/iflytop/components/iflytop_front_end_service/iflytop_front_end_service.cpp
  2. 2
      src/iflytop/components/iflytop_front_end_service/iflytop_front_end_service.hpp

6
src/iflytop/components/iflytop_front_end_service/iflytop_front_end_service.cpp

@ -39,12 +39,6 @@ void IflytopFrontEndService::initialize(string ip) {
ws->setOnMessageCallback([this, webSocket, connectionState](const ix::WebSocketMessagePtr& msg) {}); ws->setOnMessageCallback([this, webSocket, connectionState](const ix::WebSocketMessagePtr& msg) {});
}); });
m_udp.reset(new SimpleUDP());
m_udp->initialize(19003);
m_udp->set_on_recv([this](struct sockaddr_in* from, char* data, size_t len) {
logger->info("recv udp data: {}", string(data, len));
onUdpCmdMessage(from, data, len);
});
m_initialized = true; m_initialized = true;
} }

2
src/iflytop/components/iflytop_front_end_service/iflytop_front_end_service.hpp

@ -58,7 +58,6 @@ class IflytopFrontEndService : public enable_shared_from_this<IflytopFrontEndSer
// //
shared_ptr<ix::WebSocketServer> m_server; shared_ptr<ix::WebSocketServer> m_server;
shared_ptr<ix::WebSocketServer> m_report_server; shared_ptr<ix::WebSocketServer> m_report_server;
shared_ptr<SimpleUDP> m_udp;
bool m_initialized = false; bool m_initialized = false;
public: public:
@ -68,7 +67,6 @@ class IflytopFrontEndService : public enable_shared_from_this<IflytopFrontEndSer
// void sendMessage(const string& message); // void sendMessage(const string& message);
void sendReport(json& report); void sendReport(json& report);
void sendToUDP(struct sockaddr_in* from, const char* data, size_t len) { m_udp->sendto(from, data, len); }
private: private:
void onMessageCallback(weak_ptr<WebSocket> webSocket, shared_ptr<ConnectionState> connectionState, const ix::WebSocketMessagePtr& msg); void onMessageCallback(weak_ptr<WebSocket> webSocket, shared_ptr<ConnectionState> connectionState, const ix::WebSocketMessagePtr& msg);

Loading…
Cancel
Save