debug
This commit is contained in:
parent
91827e8bf4
commit
2662e355b0
2
build.sh
2
build.sh
|
@ -1,6 +1,6 @@
|
||||||
g++ -shared -fPIC \
|
g++ -shared -fPIC \
|
||||||
-I/usr/include/python3.10 -I/usr/include/python3.10/numpy -I./include \
|
-I/usr/include/python3.10 -I/usr/include/python3.10/numpy -I./include \
|
||||||
-L./lib \
|
-L./lib -L/usr/lib/x86_64-linux-gnu \
|
||||||
-DRTC_NUMPY_IMPL \
|
-DRTC_NUMPY_IMPL \
|
||||||
rtc_plugins.cpp util/RTCContext.cpp \
|
rtc_plugins.cpp util/RTCContext.cpp \
|
||||||
-lMRTCEngine -lboost_python310 libboost_numpy310 -lpython3.10 \
|
-lMRTCEngine -lboost_python310 libboost_numpy310 -lpython3.10 \
|
||||||
|
|
|
@ -17,17 +17,17 @@ srcChannelIndex = 46
|
||||||
destChannelIndex = 47
|
destChannelIndex = 47
|
||||||
def my_callback(shmName, dataSize, dataCount, sampleRate, numChannels, channelIndex):
|
def my_callback(shmName, dataSize, dataCount, sampleRate, numChannels, channelIndex):
|
||||||
print(f"dataSize:{dataSize}, dataCount:{dataCount}, sampleRate:{sampleRate}, numChannels:{numChannels}, channelIndex:{channelIndex}")
|
print(f"dataSize:{dataSize}, dataCount:{dataCount}, sampleRate:{sampleRate}, numChannels:{numChannels}, channelIndex:{channelIndex}")
|
||||||
print(shmName)
|
print(f"data:{}shmName)
|
||||||
fd = os.open(shmName, os.O_RDONLY)
|
#fd = os.open(shmName, os.O_RDONLY)
|
||||||
if fd == -1:
|
#if fd == -1:
|
||||||
raise RuntimeError(f"无法打开共享内存 {shmName}")
|
# raise RuntimeError(f"无法打开共享内存 {shmName}")
|
||||||
|
|
||||||
# 2. 创建内存映射
|
## 2. 创建内存映射
|
||||||
shm = mmap.mmap(fd, dataSize, mmap.MAP_SHARED, mmap.PROT_READ)
|
#shm = mmap.mmap(fd, dataSize, mmap.MAP_SHARED, mmap.PROT_READ)
|
||||||
|
|
||||||
# 3. 转换为numpy数组 (零拷贝)
|
## 3. 转换为numpy数组 (零拷贝)
|
||||||
audio_data = np.frombuffer(shm, dtype=c_int16, count=dataCount)
|
#audio_data = np.frombuffer(shm, dtype=c_int16, count=dataCount)
|
||||||
print(f" 前5个采样点: {audio_data[:5]}")
|
#print(f" 前5个采样点: {audio_data[:5]}")
|
||||||
#audioData = np.array([0, 1, -1, 0], dtype=np.int16)
|
#audioData = np.array([0, 1, -1, 0], dtype=np.int16)
|
||||||
#ret = rtc_plugins.sendCustomAudioData(srcChannelIndex, audioData, 48000, 1, len(audioData))
|
#ret = rtc_plugins.sendCustomAudioData(srcChannelIndex, audioData, 48000, 1, len(audioData))
|
||||||
#if ret != 0:
|
#if ret != 0:
|
||||||
|
|
Loading…
Reference in New Issue