Commit 8d802761 authored by liuyu's avatar liuyu

for quick

parent 3430b93d
...@@ -81,15 +81,15 @@ void UdpSend_uplink(uint8_t buffer[],int n,string ip,int port){ ...@@ -81,15 +81,15 @@ void UdpSend_uplink(uint8_t buffer[],int n,string ip,int port){
cAddr.sin_addr.s_addr = inet_addr(ipAddr); //将字符串转整数 cAddr.sin_addr.s_addr = inet_addr(ipAddr); //将字符串转整数
cAddr.sin_port = htons(port); //整数转整数 小端转大端 cAddr.sin_port = htons(port); //整数转整数 小端转大端
//3.通信 //3.通信
char temp[256]; // char temp[256];
int r; int r;
int len = sizeof cAddr; int len = sizeof cAddr;
int sendNum; int sendNum;
sendNum = sendto(clientSocket,buffer,n,0, sendNum = sendto(clientSocket,buffer,n,0,
(struct sockaddr*)&cAddr,len); (struct sockaddr*)&cAddr,len);
close(clientSocket); close(clientSocket);
gettimeofday(&time, NULL); // gettimeofday(&time, NULL);
Logger::ngap().info("udpsend complete, ms: %ld\n", (time.tv_sec*1000 + time.tv_usec/1000)); // Logger::ngap().info("udpsend complete, ms: %ld\n", (time.tv_sec*1000 + time.tv_usec/1000));
} }
void UdpSend_downlink(nlohmann::json aggregation,string ip,int port){ void UdpSend_downlink(nlohmann::json aggregation,string ip,int port){
...@@ -154,15 +154,6 @@ void ngap_app::handle_receive( ...@@ -154,15 +154,6 @@ void ngap_app::handle_receive(
{ {
Logger::ngap().info("starting udp send"); Logger::ngap().info("starting udp send");
Logger::ngap().debug("assoc_id = %d",assoc_id); Logger::ngap().debug("assoc_id = %d",assoc_id);
// for(int i = 0; i < n; i++)
// {
// std::stringstream data;
// data << std::hex << (int)buffer[i];
// std::cout << data.str();
// }
// std::cout<<std::endl;
buffer[n] = sendindex; buffer[n] = sendindex;
buffer[n+1] = stream; buffer[n+1] = stream;
buffer[n+2+0] = (assoc_id >> 24) & 0xFF; // 最高位字节 buffer[n+2+0] = (assoc_id >> 24) & 0xFF; // 最高位字节
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment