diff -r 000000000000 -r 6474c204b198 netwerk/test/TestSyncHTTP.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/netwerk/test/TestSyncHTTP.cpp Wed Dec 31 06:09:35 2014 +0100 @@ -0,0 +1,105 @@ +/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ +/* 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 +#include +#include +#include +#include +#include +#include + +/* + * Test synchronous HTTP. + */ + +#define RETURN_IF_FAILED(rv, what) \ + PR_BEGIN_MACRO \ + if (NS_FAILED(rv)) { \ + printf(what ": failed - %08x\n", rv); \ + return -1; \ + } \ + PR_END_MACRO + +struct TestContext { + nsCOMPtr uri; + nsCOMPtr channel; + nsCOMPtr inputStream; + PRTime t1, t2; + uint32_t bytesRead, totalRead; + + TestContext() + : t1(0), t2(0), bytesRead(0), totalRead(0) + { printf("TestContext [this=%p]\n", (void*)this); } + ~TestContext() + { printf("~TestContext [this=%p]\n", (void*)this); } +}; + +int +main(int argc, char **argv) +{ + nsresult rv; + TestContext *c; + int i, nc=0, npending=0; + char buf[256]; + + if (argc < 2) { + printf("Usage: TestSyncHTTP \n"); + return -1; + } + + c = new TestContext[argc-1]; + + for (i=0; i<(argc-1); ++i, ++nc) { + rv = NS_NewURI(getter_AddRefs(c[i].uri), argv[i+1]); + RETURN_IF_FAILED(rv, "NS_NewURI"); + + rv = NS_OpenURI(getter_AddRefs(c[i].channel), c[i].uri, nullptr, nullptr); + RETURN_IF_FAILED(rv, "NS_OpenURI"); + + nsCOMPtr httpChannel = do_QueryInterface(c[i].channel); + if (httpChannel) + httpChannel->SetOpenHasEventQueue(false); + + // initialize these fields for reading + c[i].bytesRead = 1; + c[i].totalRead = 0; + } + + for (i=0; iOpen(getter_AddRefs(c[i].inputStream)); + RETURN_IF_FAILED(rv, "nsIChannel::OpenInputStream"); + } + + npending = nc; + while (npending) { + for (i=0; i 0) { + rv = c[i].inputStream->Read(buf, sizeof buf, &c[i].bytesRead); + RETURN_IF_FAILED(rv, "nsIInputStream::Read"); + c[i].totalRead += c[i].bytesRead; + + if (c[i].bytesRead == 0) { + c[i].t2 = PR_Now(); + printf("finished GET of: %s\n", argv[i+1]); + printf("total read: %u bytes\n", c[i].totalRead); + printf("total read time: %0.3f\n", + ((double) (c[i].t2 - c[i].t1))/1000000.0); + npending--; + } + } + } + } + + delete[] c; + + NS_ShutdownXPCOM(nullptr); + return 0; +}