From 7c11d681f99fc03fb93005d9ec24c39ecdb1ce79 Mon Sep 17 00:00:00 2001 From: wangjiyu Date: Wed, 16 Apr 2025 15:59:45 +0800 Subject: [PATCH] debug --- rtc_plugins.cpp | 4 ++++ test_time_r.py | 4 +++- util/RTCContext.cpp | 2 +- util/RTCContext.h | 4 ++-- 4 files changed, 10 insertions(+), 4 deletions(-) diff --git a/rtc_plugins.cpp b/rtc_plugins.cpp index c4fc061..ea69045 100644 --- a/rtc_plugins.cpp +++ b/rtc_plugins.cpp @@ -109,6 +109,9 @@ int sendCustomAudioData(int16_t destChannelIndex, py::object pD, return -1; } } +RetAudioFrame getData() { + return RTCContext::instance().getData(); +} /* int sendCustomAudioData(const int16_t destChannelIndex, py::object pyData, int32_t sampleRate, uint64_t channelNum, @@ -200,6 +203,7 @@ BOOST_PYTHON_MODULE(rtc_plugins) { py::def("initSend", &initSend); py::def("sendCustomAudioData", &sendCustomAudioData); py::def("getSize", &getSize); + py::def("getData", &getData); } catch (...) { PyErr_SetString(PyExc_RuntimeError, "Module initialization failed"); } diff --git a/test_time_r.py b/test_time_r.py index f95ff77..2293651 100644 --- a/test_time_r.py +++ b/test_time_r.py @@ -58,4 +58,6 @@ while True: print("resend succ") size = rtc_plugins.getSize() print(f"data size:{size}") - time.sleep(30) + frame = rtc_plugins.getData() + print(f"dataCount:{frame.dataCount}") + time.sleep(3) diff --git a/util/RTCContext.cpp b/util/RTCContext.cpp index 1e9ba91..40f9d8b 100644 --- a/util/RTCContext.cpp +++ b/util/RTCContext.cpp @@ -305,7 +305,7 @@ void printTimestamp() { // 转换为本地时间(可读格式) std::time_t time = std::chrono::system_clock::to_time_t(now); std::cout << "Timestamp: " << timestamp << "." << milliseconds - << " (Local: " << std::ctime(&time) << ")"; + << " (Local: " << std::ctime(&time) << ")" << std::endl; } void RTCContext::onAudioProcess(const char* roomId, const char* peerId, mrtc::MRTCAudioFrame& audioFrame, diff --git a/util/RTCContext.h b/util/RTCContext.h index 42124e7..d4ae311 100644 --- a/util/RTCContext.h +++ b/util/RTCContext.h @@ -96,6 +96,8 @@ public: bool initRecv(const char* destRoomId, const char* srcUserId, const int16_t destChannelIndex); bool initSend(const char* srcRoomId, const char* destRoomId, const int16_t destChannelIndex, const uint8_t channelNum); int16_t getSize(); + void setData(const mrtc::MRTCAudioFrame& frame); + RetAudioFrame getData(); void* getpData() const; void setpData(void* pData); @@ -137,6 +139,4 @@ private: void onAudioProcess(const char* roomId, const char* peerId, mrtc::MRTCAudioFrame& audioFrame, mrtc::MRTCAudioSourceType audioSourceType); void onProducer(uint32_t msgId, mrtc::MRTCProducerInfo& info); - void setData(const mrtc::MRTCAudioFrame& frame); - RetAudioFrame getData(); };