1 /* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
2 /* vim: set sw=2 ts=8 et tw=80 ft=cpp : */
3 /* This Source Code Form is subject to the terms of the Mozilla Public
4 * License, v. 2.0. If a copy of the MPL was not distributed with this file,
5 * You can obtain one at http://mozilla.org/MPL/2.0/. */
6
7 #include "WebrtcTCPSocketChild.h"
8
9 #include "mozilla/net/NeckoChild.h"
10 #include "mozilla/net/SocketProcessChild.h"
11
12 #include "LoadInfo.h"
13
14 #include "WebrtcTCPSocketLog.h"
15 #include "WebrtcTCPSocketCallback.h"
16
17 using namespace mozilla::ipc;
18
19 namespace mozilla {
20 namespace net {
21
RecvOnClose(const nsresult & aReason)22 mozilla::ipc::IPCResult WebrtcTCPSocketChild::RecvOnClose(
23 const nsresult& aReason) {
24 LOG(("WebrtcTCPSocketChild::RecvOnClose %p\n", this));
25
26 MOZ_ASSERT(mProxyCallbacks, "webrtc TCP callbacks should be non-null");
27 mProxyCallbacks->OnClose(aReason);
28 mProxyCallbacks = nullptr;
29
30 return IPC_OK();
31 }
32
RecvOnConnected(const nsCString & aProxyType)33 mozilla::ipc::IPCResult WebrtcTCPSocketChild::RecvOnConnected(
34 const nsCString& aProxyType) {
35 LOG(("WebrtcTCPSocketChild::RecvOnConnected %p\n", this));
36
37 MOZ_ASSERT(mProxyCallbacks, "webrtc TCP callbacks should be non-null");
38 mProxyCallbacks->OnConnected(aProxyType);
39
40 return IPC_OK();
41 }
42
RecvOnRead(nsTArray<uint8_t> && aReadData)43 mozilla::ipc::IPCResult WebrtcTCPSocketChild::RecvOnRead(
44 nsTArray<uint8_t>&& aReadData) {
45 LOG(("WebrtcTCPSocketChild::RecvOnRead %p\n", this));
46
47 MOZ_ASSERT(mProxyCallbacks, "webrtc TCP callbacks should be non-null");
48 mProxyCallbacks->OnRead(std::move(aReadData));
49
50 return IPC_OK();
51 }
52
WebrtcTCPSocketChild(WebrtcTCPSocketCallback * aProxyCallbacks)53 WebrtcTCPSocketChild::WebrtcTCPSocketChild(
54 WebrtcTCPSocketCallback* aProxyCallbacks)
55 : mProxyCallbacks(aProxyCallbacks) {
56 MOZ_COUNT_CTOR(WebrtcTCPSocketChild);
57
58 LOG(("WebrtcTCPSocketChild::WebrtcTCPSocketChild %p\n", this));
59 }
60
~WebrtcTCPSocketChild()61 WebrtcTCPSocketChild::~WebrtcTCPSocketChild() {
62 MOZ_COUNT_DTOR(WebrtcTCPSocketChild);
63
64 LOG(("WebrtcTCPSocketChild::~WebrtcTCPSocketChild %p\n", this));
65 }
66
AsyncOpen(const nsCString & aHost,const int & aPort,const nsCString & aLocalAddress,const int & aLocalPort,bool aUseTls,const std::shared_ptr<NrSocketProxyConfig> & aProxyConfig)67 void WebrtcTCPSocketChild::AsyncOpen(
68 const nsCString& aHost, const int& aPort, const nsCString& aLocalAddress,
69 const int& aLocalPort, bool aUseTls,
70 const std::shared_ptr<NrSocketProxyConfig>& aProxyConfig) {
71 LOG(("WebrtcTCPSocketChild::AsyncOpen %p %s:%d\n", this, aHost.get(), aPort));
72
73 MOZ_ASSERT(NS_IsMainThread(), "not main thread");
74
75 AddIPDLReference();
76
77 Maybe<net::WebrtcProxyConfig> proxyConfig;
78 Maybe<dom::TabId> tabId;
79 if (aProxyConfig) {
80 proxyConfig = Some(aProxyConfig->GetConfig());
81 tabId = Some(proxyConfig->tabId());
82 }
83
84 if (IsNeckoChild()) {
85 // We're on a content process
86 gNeckoChild->SetEventTargetForActor(this, GetMainThreadEventTarget());
87 gNeckoChild->SendPWebrtcTCPSocketConstructor(this, tabId);
88 } else if (IsSocketProcessChild()) {
89 // We're on a socket process
90 SocketProcessChild::GetSingleton()->SetEventTargetForActor(
91 this, GetMainThreadEventTarget());
92 SocketProcessChild::GetSingleton()->SendPWebrtcTCPSocketConstructor(this,
93 tabId);
94 }
95
96 SendAsyncOpen(aHost, aPort, aLocalAddress, aLocalPort, aUseTls, proxyConfig);
97 }
98
99 } // namespace net
100 } // namespace mozilla
101