From 5f8de423f190bbb79a62f804151bc24824fa32d8 Mon Sep 17 00:00:00 2001 From: "Matt A. Tobin" Date: Fri, 2 Feb 2018 04:16:08 -0500 Subject: Add m-esr52 at 52.6.0 --- netwerk/test/TestServ.cpp | 146 ++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 146 insertions(+) create mode 100644 netwerk/test/TestServ.cpp (limited to 'netwerk/test/TestServ.cpp') diff --git a/netwerk/test/TestServ.cpp b/netwerk/test/TestServ.cpp new file mode 100644 index 000000000..7ae41636f --- /dev/null +++ b/netwerk/test/TestServ.cpp @@ -0,0 +1,146 @@ +/* vim:set ts=4 sw=4 et cindent: */ +/* 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/. */ + +#include "TestCommon.h" +#include +#include "nsIServiceManager.h" +#include "nsIServerSocket.h" +#include "nsISocketTransport.h" +#include "nsIInputStream.h" +#include "nsIOutputStream.h" +#include "nsNetCID.h" +#include "nsComponentManagerUtils.h" +#include "nsStringAPI.h" +#include "nsCOMPtr.h" +#include "NetwerkTestLogging.h" + +// +// set NSPR_LOG_MODULES=Test:5 +// +static PRLogModuleInfo *gTestLog = nullptr; +#define LOG(args) MOZ_LOG(gTestLog, mozilla::LogLevel::Debug, args) + +class MySocketListener : public nsIServerSocketListener +{ +protected: + virtual ~MySocketListener() = default; + +public: + NS_DECL_THREADSAFE_ISUPPORTS + NS_DECL_NSISERVERSOCKETLISTENER + + MySocketListener() {} +}; + +NS_IMPL_ISUPPORTS(MySocketListener, nsIServerSocketListener) + +NS_IMETHODIMP +MySocketListener::OnSocketAccepted(nsIServerSocket *serv, + nsISocketTransport *trans) +{ + LOG(("MySocketListener::OnSocketAccepted [serv=%p trans=%p]\n", serv, trans)); + + nsAutoCString host; + int32_t port; + + trans->GetHost(host); + trans->GetPort(&port); + + LOG((" -> %s:%d\n", host.get(), port)); + + nsCOMPtr input; + nsCOMPtr output; + nsresult rv; + + rv = trans->OpenInputStream(nsITransport::OPEN_BLOCKING, 0, 0, getter_AddRefs(input)); + if (NS_FAILED(rv)) + return rv; + + rv = trans->OpenOutputStream(nsITransport::OPEN_BLOCKING, 0, 0, getter_AddRefs(output)); + if (NS_FAILED(rv)) + return rv; + + char buf[256]; + uint32_t n; + + rv = input->Read(buf, sizeof(buf), &n); + if (NS_FAILED(rv)) + return rv; + + const char response[] = "HTTP/1.0 200 OK\r\nContent-Type: text/plain\r\n\r\nFooooopy!!\r\n"; + rv = output->Write(response, sizeof(response) - 1, &n); + if (NS_FAILED(rv)) + return rv; + + input->Close(); + output->Close(); + return NS_OK; +} + +NS_IMETHODIMP +MySocketListener::OnStopListening(nsIServerSocket *serv, nsresult status) +{ + LOG(("MySocketListener::OnStopListening [serv=%p status=%x]\n", serv, status)); + QuitPumpingEvents(); + return NS_OK; +} + +static nsresult +MakeServer(int32_t port) +{ + nsresult rv; + nsCOMPtr serv = do_CreateInstance(NS_SERVERSOCKET_CONTRACTID, &rv); + if (NS_FAILED(rv)) + return rv; + + rv = serv->Init(port, true, 5); + if (NS_FAILED(rv)) + return rv; + + rv = serv->GetPort(&port); + if (NS_FAILED(rv)) + return rv; + LOG((" listening on port %d\n", port)); + + rv = serv->AsyncListen(new MySocketListener()); + return rv; +} + +int +main(int argc, char* argv[]) +{ + if (test_common_init(&argc, &argv) != 0) + return -1; + + nsresult rv= (nsresult)-1; + if (argc < 2) { + printf("usage: %s \n", argv[0]); + return -1; + } + + gTestLog = PR_NewLogModule("Test"); + + /* + * The following code only deals with XPCOM registration stuff. and setting + * up the event queues. Copied from TestSocketIO.cpp + */ + + rv = NS_InitXPCOM2(nullptr, nullptr, nullptr); + if (NS_FAILED(rv)) return -1; + + { + rv = MakeServer(atoi(argv[1])); + if (NS_FAILED(rv)) { + LOG(("MakeServer failed [rv=%x]\n", rv)); + return -1; + } + + // Enter the message pump to allow the URL load to proceed. + PumpEvents(); + } // this scopes the nsCOMPtrs + // no nsCOMPtrs are allowed to be alive when you call NS_ShutdownXPCOM + NS_ShutdownXPCOM(nullptr); + return 0; +} -- cgit v1.2.3