wangjiyu
/
rtc_plugins
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add test send recv

This commit is contained in:
wangjiyu 2025-04-14 16:38:06 +08:00
parent 63d9838311
commit 2bf1e14e89
2 changed files with 83 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
test_time_r.py Normal file
View File

@ -0,0 +1,35 @@
import rtc_plugins
import time
import numpy as np
srcUserId = "destUser1"
destUserId = "srcUser1"
srcDisplayName = "destDisplayName1"
destDisplayName = "srcDisplayName1"
srcRoomId = "destRoom1"
destRoomId = "srcRoomId1"
srcChannelIndex = 43
destChannelIndex = 42
send_time = 0
total_time = 0
total_cnt = 0
def my_callback(npData, dataCount, sampleRate, numChannels, channelIndex):
global destChannelIndex
audioData = np.array([0, 1, -1, 0], dtype=np.int16)
ret = rtc_plugins.sendCustomAudioData(destChannelIndex, audioData, 48000, 1, len(audioData))
ret = rtc_plugins.init(srcUserId, srcDisplayName, srcRoomId, my_callback)
if ret != 0:
print(f"init fail, ret:{ret}")
exit(1)
ret = rtc_plugins.initSend(destRoomId, destChannelIndex)
if ret != 0:
print(f"initSend fail, ret:{ret}")
exit(1)
ret = rtc_plugins.initRecv(destRoomId, srcUserId, destChannelIndex)
if ret != 0:
print(f"initRecv fail, ret:{ret}")
exit(1)

48
test_time_s.py Normal file
View File

@ -0,0 +1,48 @@
import rtc_plugins
import time
import numpy as np
srcUserId = "srcUser1"
destUserId = "destUser1"
srcDisplayName = "srcDisplayName1"
destDisplayName = "destDisplayName1"
srcRoomId = "srcRoom1"
destRoomId = "destRoomId1"
srcChannelIndex = 42
destChannelIndex = 43
send_time = 0
total_time = 0
total_cnt = 0
def my_callback(npData, dataCount, sampleRate, numChannels, channelIndex):
global total_time, total_cnt
recv_time = time.time()
total_time = total_time + (recv_time - send_time)
total_cnt = total_cnt + 1
print(f"dataCount:{dataCount}, sampleRate:{sampleRate}, numChannels:{numChannels}, channelIndex:{channelIndex}")
ret = rtc_plugins.init(srcUserId, srcDisplayName, srcRoomId, my_callback)
if ret != 0:
print(f"init fail, ret:{ret}")
exit(1)
ret = rtc_plugins.initSend(destRoomId, destChannelIndex)
if ret != 0:
print(f"initSend fail, ret:{ret}")
exit(1)
ret = rtc_plugins.initRecv(destRoomId, srcUserId, destChannelIndex)
if ret != 0:
print(f"initRecv fail, ret:{ret}")
exit(1)
audioData = np.array([0, 1, -1, 0], dtype=np.int16)
for i in range(100):
send_time = time.time()
ret = rtc_plugins.sendCustomAudioData(destChannelIndex, audioData, 48000, 1, len(audioData))
if ret != 0:
print(f"send fail, ret:{ret}")
time.sleep(3)
print(f"total_time:{total_time}, total_cnt:{total_cnt}")
print(total_time/total_cnt)