This commit is contained in:
wangjiyu 2025-04-14 18:24:16 +08:00
parent c6b0a5cb08
commit 41d47101d2
5 changed files with 13 additions and 11 deletions

View File

@ -17,7 +17,7 @@ ret = rtc_plugins.init(srcUserId, srcDisplayName, srcRoomId, my_callback)
if ret != 0: if ret != 0:
print(f"init fail, ret:{ret}") print(f"init fail, ret:{ret}")
exit(1) exit(1)
ret = rtc_plugins.initSend(destRoomId, destChannelIndex) ret = rtc_plugins.initSend(srcRoomId, destRoomId, destChannelIndex)
if ret != 0: if ret != 0:
print(f"initSend fail, ret:{ret}") print(f"initSend fail, ret:{ret}")
exit(1) exit(1)

View File

@ -23,7 +23,7 @@ ret = rtc_plugins.initRecv(destRoomId, srcUserId, destChannelIndex)
if ret != 0: if ret != 0:
print(f"initRecv fail, ret:{ret}") print(f"initRecv fail, ret:{ret}")
exit(1) exit(1)
ret = rtc_plugins.initSend(srcRoomId, srcChannelIndex) ret = rtc_plugins.initSend(destRoomId, srcRoomId, srcChannelIndex)
if ret != 0: if ret != 0:
print(f"initSend fail, ret:{ret}") print(f"initSend fail, ret:{ret}")
exit(1) exit(1)

View File

@ -17,7 +17,7 @@ ret = rtc_plugins.init(srcUserId, srcDisplayName, srcRoomId, my_callback)
if ret != 0: if ret != 0:
print(f"init fail, ret:{ret}") print(f"init fail, ret:{ret}")
exit(1) exit(1)
ret = rtc_plugins.initSend(destRoomId, destChannelIndex) ret = rtc_plugins.initSend(srcRoomId, destRoomId, destChannelIndex)
if ret != 0: if ret != 0:
print(f"initSend fail, ret:{ret}") print(f"initSend fail, ret:{ret}")
exit(1) exit(1)

View File

@ -507,13 +507,14 @@ bool RTCContext::initRecv(const char* destRoomId, const char* srcUserId, const i
return true; return true;
} }
bool RTCContext::initSend(const char* destRoomId, const int16_t destChannelIndex) bool RTCContext::initSend(const char* srcRoomId, const char* destRoomId, const int16_t destChannelIndex)
{ {
while (!isOnRoom_) while (!isOnRoom_)
{ {
std::cout << "wait for OnRoom" << std::endl; std::cout << "wait for OnRoom" << std::endl;
sleep(3); sleep(3);
} }
if (std::string(srcRoomId) != std::string(destRoomId)) {
std::cout << "join multi room" << std::endl; std::cout << "join multi room" << std::endl;
int16_t ret1 = rtcEngine_->joinMultiRoom(destRoomId); int16_t ret1 = rtcEngine_->joinMultiRoom(destRoomId);
if (ret1 != 0) if (ret1 != 0)
@ -521,6 +522,7 @@ bool RTCContext::initSend(const char* destRoomId, const int16_t destChannelIndex
std::cout << "joinMultiRoom fail, ret:" << ret1; std::cout << "joinMultiRoom fail, ret:" << ret1;
return false; return false;
} }
}
mrtc::MRTCAudioOption option; mrtc::MRTCAudioOption option;
strcpy(option.dstRoomId, destRoomId); strcpy(option.dstRoomId, destRoomId);

View File

@ -83,7 +83,7 @@ public:
mrtc::IMRTCEngine* getRtcEngine() const; mrtc::IMRTCEngine* getRtcEngine() const;
bool init(const char* selfUserId, const char* selfDisplayName, const char* selfRoomId); bool init(const char* selfUserId, const char* selfDisplayName, const char* selfRoomId);
bool initRecv(const char* destRoomId, const char* srcUserId, const int16_t destChannelIndex); bool initRecv(const char* destRoomId, const char* srcUserId, const int16_t destChannelIndex);
bool initSend(const char* destRoomId, const int16_t destChannelIndex); bool initSend(const char* srcRoomId, const char* destRoomId, const int16_t destChannelIndex);
void* getpData() const; void* getpData() const;
void setpData(void* pData); void setpData(void* pData);