NetworkRTCSocket.cpp [plain text]
#include "config.h"
#include "NetworkRTCSocket.h"
#if USE(LIBWEBRTC)
#include "DataReference.h"
#include "LibWebRTCSocketClient.h"
#include "NetworkRTCProvider.h"
#include <WebCore/SharedBuffer.h>
#include <wtf/Function.h>
namespace WebKit {
NetworkRTCSocket::NetworkRTCSocket(uint64_t identifier, NetworkRTCProvider& rtcProvider)
: m_identifier(identifier)
, m_rtcProvider(rtcProvider)
{
}
void NetworkRTCSocket::sendTo(const IPC::DataReference& data, const RTCNetwork::SocketAddress& socketAddress, int packetID, int rtpSendtimeExtensionID, String srtpAuth, int64_t srtpPacketIndex, int dscp)
{
auto buffer = WebCore::SharedBuffer::create(data.data(), data.size());
rtc::PacketOptions options;
options.packet_id = packetID;
options.packet_time_params.rtp_sendtime_extension_id = rtpSendtimeExtensionID;
options.packet_time_params.srtp_packet_index = srtpPacketIndex;
options.dscp = static_cast<rtc::DiffServCodePoint>(dscp);
if (srtpAuth.utf8().length()) {
options.packet_time_params.srtp_auth_key = std::vector<char>(srtpAuth.utf8().data(), srtpAuth.utf8().data() + srtpAuth.utf8().length());
options.packet_time_params.srtp_auth_tag_len = srtpAuth.utf8().length();
} else
options.packet_time_params.srtp_auth_tag_len = -1;
m_rtcProvider.callSocket(m_identifier, [buffer = WTFMove(buffer), socketAddress, options](LibWebRTCSocketClient& client) {
client.sendTo(buffer.get(), socketAddress.value, options);
});
}
void NetworkRTCSocket::close()
{
m_rtcProvider.callSocket(m_identifier, [](LibWebRTCSocketClient& socket) {
socket.close();
});
}
void NetworkRTCSocket::setOption(int option, int value)
{
m_rtcProvider.callSocket(m_identifier, [option, value](LibWebRTCSocketClient& socket) {
socket.setOption(option, value);
});
}
}
#endif // USE(LIBWEBRTC)