X-Git-Url: https://git.toastfreeware.priv.at/toast/stream2beamer.git/blobdiff_plain/a1f8e26a972c2a7db5346e51813c6095044486b6..e97741140341d1c98f6cb350d819a988c8b73bbd:/lagarde.py diff --git a/lagarde.py b/lagarde.py index 55b1e1f..f31bc2d 100755 --- a/lagarde.py +++ b/lagarde.py @@ -223,22 +223,28 @@ class WebRTCClient: def create_answer_done(self, gst_promise): reply = gst_promise.get_reply() answer = reply.get_value('answer') + gst_promise = Gst.Promise.new_with_change_func(self.set_local_description_done) + self.webrtcbin.emit('set-local-description', answer, gst_promise) + sdp_message = answer.sdp mids = [sdp_message.get_media(i).get_attribute_val('mid') for i in range(sdp_message.medias_len())] user_fragments = [sdp_message.get_media(i).get_attribute_val('ice-ufrag') for i in range(sdp_message.medias_len())] - self.events.sdp_info.put_nowait((mids, user_fragments)) sdp_answer = sdp_message.as_text() - log.info(f'Send SDP answer') - log.debug(f'SDP answer:\n{sdp_answer}') - self.events.sdp_answer.put_nowait(sdp_answer) - gst_promise = Gst.Promise.new_with_change_func(self.set_local_description_done) - self.webrtcbin.emit('set-local-description', answer, gst_promise) + self.mids_uf = mids, user_fragments + self.answer = sdp_answer def set_local_description_done(self, gst_promise): gst_promise.get_reply() + sdp_answer = self.answer + log.info(f'Send SDP answer') + log.debug(f'SDP answer:\n{sdp_answer}') + self.events.sdp_answer.put_nowait(sdp_answer) + mids, user_fragments = self.mids_uf + self.events.sdp_info.put_nowait((mids, user_fragments)) + async def run(self): bus = Gst.Pipeline.get_bus(self.pipe) self.pipe.set_state(Gst.State.PLAYING)