ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-server: always call WebRtcEndpoint#addIceCandidate on RPC onIceCandidate from openvidu-browser

pull/707/head
pabloFuente 2022-03-15 17:37:23 +01:00
parent a34f67639a
commit 87f2613860
1 changed files with 2 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java
View File

@ -757,14 +757,8 @@ public class KurentoSessionManager extends SessionManager {
KurentoParticipant kParticipant = (KurentoParticipant) participant; KurentoParticipant kParticipant = (KurentoParticipant) participant;
log.debug("Request [ICE_CANDIDATE] endpoint={} candidate={} " + "sdpMLineIdx={} sdpMid={} ({})", log.debug("Request [ICE_CANDIDATE] endpoint={} candidate={} " + "sdpMLineIdx={} sdpMid={} ({})",
endpointName, candidate, sdpMLineIndex, sdpMid, participant.getParticipantPublicId()); endpointName, candidate, sdpMLineIndex, sdpMid, participant.getParticipantPublicId());
if (kParticipant.isPublisherEndpointDefined()) {
kParticipant.addIceCandidate(endpointName, new IceCandidate(candidate, sdpMid, sdpMLineIndex)); kParticipant.addIceCandidate(endpointName, new IceCandidate(candidate, sdpMid, sdpMLineIndex));
sessionEventsHandler.onRecvIceCandidate(participant, transactionId, null); sessionEventsHandler.onRecvIceCandidate(participant, transactionId, null);
} else {
throw new OpenViduException(Code.PUBLISHER_ENDPOINT_NOT_FOUND_ERROR_CODE,
"Request to onIceCandidate for connection " + endpointName
+ " gone wrong. There is no publisher endpoint available");
}
} catch (OpenViduException e) { } catch (OpenViduException e) {
log.error("PARTICIPANT {}: Error receiving ICE " + "candidate (epName={}, candidate={})", log.error("PARTICIPANT {}: Error receiving ICE " + "candidate (epName={}, candidate={})",
participant.getParticipantPublicId(), endpointName, candidate, e); participant.getParticipantPublicId(), endpointName, candidate, e);