lnk/microser
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

x86 and arm use same code

Browse Source
This commit is contained in:
lnk
2026-04-07 10:18:44 +08:00
parent c78bc592a8
commit 1b2dd863e9
3 changed files with 13 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
json/save2json.cpp
View File

@@ -366,7 +366,7 @@ void my_rocketmq_send(Ckafka_data_t& data)
rocketmq_producer_send(senddata.c_str(), topic.c_str());//lnk20250623修复偶发性doublefree
}
#if 0
void my_kafka_send(Ckafka_data_t& data)
{
#ifdef __GNUC__
@@ -457,6 +457,7 @@ void my_kafka_send(Ckafka_data_t& data)
printf("\nFailed kafka send, monitor_id:[%s] topic:[%s]\n", key.c_str(), topic.c_str());
}
#endif
void my_datahub_send(Ckafka_data_t& data)
{
@@ -510,7 +511,7 @@ void my_datahub_send(Ckafka_data_t& data)
add_sng_log(data.strText.toAscii().data());
}
DataHub_Send_Datahub(const_cast<char*>(topic.c_str()), const_cast<char*>(senddata.c_str()));
//DataHub_Send_Datahub(const_cast<char*>(topic.c_str()), const_cast<char*>(senddata.c_str()));
printf("\ndatahub send, monitor_id:[%s] topic:[%s] Success\n", key.c_str(), topic.c_str());
}
@@ -544,11 +545,11 @@ void KafkaSendThread::run()
QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss.zzz").toAscii().data());
if (SEND_FLAG == 1) //kafka推送
{
my_kafka_send(data);
//my_kafka_send(data);
}
else if (SEND_FLAG == 2)//datahub推送
{
my_datahub_send(data);
//my_datahub_send(data);
}
else if (SEND_FLAG == 3)//rocketmq推送lnk10-11
{