提交 6536ba06 authored 作者: blu's avatar blu

big refacting of communitation architect

上级 65c86b0b
...@@ -324,11 +324,9 @@ protected: ...@@ -324,11 +324,9 @@ protected:
// serialize packet to raw bytes // serialize packet to raw bytes
char * data = nullptr; char * data = nullptr;
int size = AVPacketSerializer::encode(packet, &data); int size = AVPacketSerializer::encode(packet, &data);
zmq_msg_init_data(&msg, (void*)data, size, NULL, NULL); zmq_msg_init_data(&msg, (void*)data, size, mqPacketFree, NULL);
zmq_send_const(pPub, zmq_msg_data(&msg), size, 0); //zmq_send_const(pPub, zmq_msg_data(&msg), size, 0);
if(data != nullptr) { ret = zmq_msg_send(&msg, pPub, 0);
free(data);
}
av_packet_unref(&packet); av_packet_unref(&packet);
} }
......
...@@ -119,7 +119,7 @@ int decode(char *bytes, int len, AVPacket *pkt) ...@@ -119,7 +119,7 @@ int decode(char *bytes, int len, AVPacket *pkt)
int got = 0; int got = 0;
if (memcmp(PS_MARK_E, bytes + len - strlen(PS_MARK_E), strlen(PS_MARK_E)) != 0 || memcmp(PS_MARK_S, bytes, strlen(PS_MARK_S))) if (memcmp(PS_MARK_E, bytes + len - strlen(PS_MARK_E), strlen(PS_MARK_E)) != 0 || memcmp(PS_MARK_S, bytes, strlen(PS_MARK_S)))
{ {
spdlog::error("invalid packet"); spdlog::error("invalid packet. len {}", len);
return -1; return -1;
} }
//skip mark_s //skip mark_s
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论