AgoraIO-Extensions / AgoraIO-Extensions/Agora-Python-Server-SDK

Unable to resend the received frame

Abierto
#2 0 comentarios 0 reacciones 0 asignados Ver en GitHub
Lenguaje dominante
Python
Estrellas
18
Forks
5
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

Hi,

I am trying to send the received from in onFrame function:

def on_frame(self, channel_id, remote_uid, frame:VideoFrame):
logger.info(f"on_frame, channel_id={channel_id}, remote_uid={remote_uid}, width={frame.width}, height={frame.height}, y_stride={frame.y_stride}, u_stride={frame.u_stride}, v_stride={frame.v_stride}, len_y={len(frame.y_buffer)}, len_u={len(frame.u_buffer)}, len_v={len(frame.v_buffer)}")

if self._save_to_disk:
file_path = os.path.join(log_folder, channel_id + "_" + remote_uid + '.yuv')
y_size = frame.y_stride * frame.height
uv_size = (frame.u_stride * frame.height // 2)
# logger.info(f"on_frame, file_path={file_path}, y_size={y_size}, uv_size={uv_size}, len_y={len(frame.y_buffer)}, len_u={len(frame.u_buffer)}, len_v={len(frame.v_buffer)}")
# self.push_yuv_frame()
with open(file_path, 'ab') as f:
f.write(frame.y_buffer[:y_size])
f.write(frame.u_buffer[:uv_size])
f.write(frame.v_buffer[:uv_size])
# if self.video_frame_sender!=None:
# logger.info(f"on_frame, file_path={file_path}, y_size={y_size}, uv_size={uv_size}, len_y={len(frame.y_buffer)}, len_u={len(frame.u_buffer)}, len_v={len(frame.v_buffer)}")
# exit()
# if self.loop:
self.push_yuv_frame(frame, self.video_frame_sender, "Frame Metadata")
# await asyncio.create_task(self.push_yuv_frame(frame, self.video_frame_sender, "hello metadata"))

return 1

def on_user_video_track_subscribed(self, agora_local_user, user_id, info, agora_remote_video_track):
logger.info(f"on_user_video_track_subscribed, agora_local_user={agora_local_user}, user_id={user_id}, info={info}, agora_remote_video_track={agora_remote_video_track}")
return 0
def push_yuv_frame(self,frame: VideoFrame, video_sender: VideoFrameSender, metadata: str):
yuv_buffer = bytearray(frame.y_buffer) + bytearray(frame.u_buffer) + bytearray(frame.v_buffer)

external_frame = ExternalVideoFrame()
external_frame.buffer = yuv_buffer
external_frame.type = 1 # Assuming a certain type, modify as necessary
external_frame.format = 1 # Assuming YUV format, modify as necessary
external_frame.stride = frame.y_stride
external_frame.height = frame.height
external_frame.timestamp = 0 # Modify if timestamp handling is needed
external_frame.metadata = metadata

ret = video_sender.send_video_frame(external_frame)
logger.info(f"Frame sent with status {ret}")
exit(0)

In video frame observer. I am not sure whether you support this or not? Where I can do that?

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.