debug
This commit is contained in:
parent
abb7b1012d
commit
30f1e6625d
|
@ -2,34 +2,31 @@ import rtc_plugins
|
||||||
import time
|
import time
|
||||||
import numpy as np
|
import numpy as np
|
||||||
|
|
||||||
srcUserId = "destUser1"
|
srcUserId = "srcUser1"
|
||||||
destUserId = "srcUser1"
|
destUserId = "destUser1"
|
||||||
|
|
||||||
srcDisplayName = "destDisplayName1"
|
srcDisplayName = "srcDisplayName1"
|
||||||
destDisplayName = "srcDisplayName1"
|
destDisplayName = "destDisplayName1"
|
||||||
srcRoomId = "destRoom1"
|
srcRoomId = "srcRoom1"
|
||||||
destRoomId = "srcRoomId1"
|
destRoomId = "destRoomId1"
|
||||||
srcChannelIndex = 43
|
srcChannelIndex = 42
|
||||||
destChannelIndex = 42
|
destChannelIndex = 43
|
||||||
|
def my_callback(npData, dataSize, dataCount, sampleRate, numChannels, channelIndex):
|
||||||
send_time = 0
|
print(f"dataSize:{dataSize}, dataCount:{dataCount}, sampleRate:{sampleRate}, numChannels:{numChannels}, channelIndex:{channelIndex}")
|
||||||
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)
|
audioData = np.array([0, 1, -1, 0], dtype=np.int16)
|
||||||
ret = rtc_plugins.sendCustomAudioData(destChannelIndex, audioData, 48000, 1, len(audioData))
|
ret = rtc_plugins.sendCustomAudioData(srcChannelIndex, audioData, 48000, 1, len(audioData))
|
||||||
|
ret = rtc_plugins.init(destUserId, destDisplayName, destRoomId, my_callback)
|
||||||
|
|
||||||
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.initRecv(destRoomId, srcUserId, destChannelIndex)
|
||||||
if ret != 0:
|
|
||||||
print(f"initSend fail, ret:{ret}")
|
|
||||||
exit(1)
|
|
||||||
ret = rtc_plugins.initRecv(srcRoomId, destUserId, srcChannelIndex)
|
|
||||||
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)
|
||||||
|
if ret != 0:
|
||||||
|
print(f"initSend fail, ret:{ret}")
|
||||||
|
exit(1)
|
||||||
|
|
||||||
|
while True:
|
||||||
|
time.sleep(3)
|
||||||
|
|
|
@ -11,18 +11,8 @@ srcRoomId = "srcRoom1"
|
||||||
destRoomId = "destRoomId1"
|
destRoomId = "destRoomId1"
|
||||||
srcChannelIndex = 42
|
srcChannelIndex = 42
|
||||||
destChannelIndex = 43
|
destChannelIndex = 43
|
||||||
|
|
||||||
send_time = 0
|
|
||||||
total_time = 0
|
|
||||||
total_cnt = 0
|
|
||||||
def my_callback(npData, dataCount, sampleRate, numChannels, channelIndex):
|
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}")
|
print(f"dataCount:{dataCount}, sampleRate:{sampleRate}, numChannels:{numChannels}, channelIndex:{channelIndex}")
|
||||||
|
|
||||||
|
|
||||||
ret = rtc_plugins.init(srcUserId, srcDisplayName, srcRoomId, my_callback)
|
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}")
|
||||||
|
@ -31,18 +21,13 @@ ret = rtc_plugins.initSend(destRoomId, destChannelIndex)
|
||||||
if ret != 0:
|
if ret != 0:
|
||||||
print(f"initSend fail, ret:{ret}")
|
print(f"initSend fail, ret:{ret}")
|
||||||
exit(1)
|
exit(1)
|
||||||
ret = rtc_plugins.initRecv(srcRoomId, destUserId, srcChannelIndex)
|
ret = rtc_plugins.initRecv(srcRoomId, srcUserId, srcChannelIndex)
|
||||||
if ret != 0:
|
if ret != 0:
|
||||||
print(f"initRecv fail, ret:{ret}")
|
print(f"initRecv fail, ret:{ret}")
|
||||||
exit(1)
|
exit(1)
|
||||||
|
|
||||||
audioData = np.array([0, 1, -1, 0], dtype=np.int16)
|
audioData = np.array([0, 1, -1, 0], dtype=np.int16)
|
||||||
for i in range(100):
|
for i in range(100):
|
||||||
send_time = time.time()
|
|
||||||
ret = rtc_plugins.sendCustomAudioData(destChannelIndex, audioData, 48000, 1, len(audioData))
|
ret = rtc_plugins.sendCustomAudioData(destChannelIndex, audioData, 48000, 1, len(audioData))
|
||||||
if ret != 0:
|
if ret != 0:
|
||||||
print(f"send fail, ret:{ret}")
|
print(f"send fail, ret:{ret}")
|
||||||
time.sleep(3)
|
time.sleep(3)
|
||||||
|
|
||||||
print(f"total_time:{total_time}, total_cnt:{total_cnt}")
|
|
||||||
print(total_time/total_cnt)
|
|
Loading…
Reference in New Issue