mirror of
https://github.com/mozilla/gecko-dev.git
synced 2024-10-27 04:05:32 +00:00
09f4c06235
This replaces the tunnel using a new nr_socket implementation. Proxy detection code is still done in the peer connction. However, the result is only used to detect a proxy. The result is unused. Address resolution is done by necko code in the parent process. The new socket wraps a WebrtcProxyChannel which uses necko to handle proxy negotiation. This has a happy side effect of enabling all authentication modes that necko already supports for http proxies. This adds a protocol for Necko to manage, WebrtcProxyChannel. This new protocol serves as a pipe for a CONNECT tunnel. It is only used in WebRtc and not built in no WebRtc builds. --HG-- extra : rebase_source : a951841f95eaaa0562886cf76b405b01f1adf70e extra : intermediate-source : 5c3da21957fc80b07188bc8a405437b858027a22 extra : source : 594a32883463ab051677ba06e22fa6d062b4b4a9
129 lines
3.9 KiB
C++
129 lines
3.9 KiB
C++
/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
|
|
/* vim: set sw=2 ts=8 et tw=80 ft=cpp : */
|
|
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
|
* You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
/*
|
|
Copyright (c) 2007, Adobe Systems, Incorporated
|
|
Copyright (c) 2013, Mozilla
|
|
|
|
All rights reserved.
|
|
|
|
Redistribution and use in source and binary forms, with or without
|
|
modification, are permitted provided that the following conditions are
|
|
met:
|
|
|
|
* Redistributions of source code must retain the above copyright
|
|
notice, this list of conditions and the following disclaimer.
|
|
|
|
* Redistributions in binary form must reproduce the above copyright
|
|
notice, this list of conditions and the following disclaimer in the
|
|
documentation and/or other materials provided with the distribution.
|
|
|
|
* Neither the name of Adobe Systems, Network Resonance, Mozilla nor
|
|
the names of its contributors may be used to endorse or promote
|
|
products derived from this software without specific prior written
|
|
permission.
|
|
|
|
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
|
"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
|
LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
|
A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
|
OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
|
DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
|
THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
|
OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
|
|
#ifndef nr_socket_proxy_h__
|
|
#define nr_socket_proxy_h__
|
|
|
|
#include <list>
|
|
|
|
#include "mozilla/net/WebrtcProxyChannelCallback.h"
|
|
|
|
#include "nsTArray.h"
|
|
|
|
extern "C" {
|
|
#include "nr_api.h"
|
|
#include "nr_socket.h"
|
|
#include "transport_addr.h"
|
|
}
|
|
|
|
#include "nr_socket_prsock.h"
|
|
|
|
namespace mozilla
|
|
{
|
|
using namespace net;
|
|
|
|
namespace net
|
|
{
|
|
class WebrtcProxyChannelWrapper;
|
|
} // namespace net
|
|
|
|
class NrSocketProxyData;
|
|
class NrSocketProxyConfig;
|
|
|
|
class NrSocketProxy : public NrSocketBase,
|
|
public WebrtcProxyChannelCallback
|
|
{
|
|
public:
|
|
NS_INLINE_DECL_THREADSAFE_REFCOUNTING(NrSocketProxy, override)
|
|
|
|
explicit NrSocketProxy(const std::shared_ptr<NrSocketProxyConfig>& aConfig);
|
|
|
|
// NrSocketBase
|
|
int create(nr_transport_addr *aAddr) override;
|
|
int connect(nr_transport_addr *aAddr) override;
|
|
void close() override;
|
|
int write(const void* aBuffer,
|
|
size_t aCount,
|
|
size_t* aWrote) override;
|
|
int read(void* aBuffer, size_t aCount, size_t* aRead) override;
|
|
int getaddr(nr_transport_addr* aAddr) override;
|
|
int sendto(const void* aBuffer,
|
|
size_t aCount,
|
|
int aFlags,
|
|
nr_transport_addr* aAddr) override;
|
|
int recvfrom(void* aBuffer,
|
|
size_t aCount,
|
|
size_t* aRead,
|
|
int aFlags,
|
|
nr_transport_addr* aAddr) override;
|
|
int listen(int aBacklog) override;
|
|
int accept(nr_transport_addr* aAddr, nr_socket** aSocket) override;
|
|
|
|
// WebrtcProxyChannelCallback
|
|
void OnClose(nsresult aReason) override;
|
|
void OnConnected() override;
|
|
void OnRead(nsTArray<uint8_t>&& aReadData) override;
|
|
|
|
size_t CountUnreadBytes() const;
|
|
|
|
// for gtests
|
|
void AssignChannel_DoNotUse(WebrtcProxyChannelWrapper* aWrapper);
|
|
|
|
protected:
|
|
virtual ~NrSocketProxy();
|
|
|
|
private:
|
|
void DoCallbacks();
|
|
|
|
bool mClosed;
|
|
|
|
size_t mReadOffset;
|
|
std::list<NrSocketProxyData> mReadQueue;
|
|
|
|
std::shared_ptr<NrSocketProxyConfig> mConfig;
|
|
|
|
RefPtr<WebrtcProxyChannelWrapper> mWebrtcProxyChannel;
|
|
};
|
|
|
|
} // namespace mozilla
|
|
|
|
#endif // nr_socket_proxy_h__
|