mirror of
https://github.com/mozilla/gecko-dev.git
synced 2024-11-02 07:05:24 +00:00
555 lines
15 KiB
C++
555 lines
15 KiB
C++
/* -*- Mode: C; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
|
|
/*
|
|
* The contents of this file are subject to the Netscape Public
|
|
* License Version 1.1 (the "License"); you may not use this file
|
|
* except in compliance with the License. You may obtain a copy of
|
|
* the License at http://www.mozilla.org/NPL/
|
|
*
|
|
* Software distributed under the License is distributed on an "AS
|
|
* IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
|
|
* implied. See the License for the specific language governing
|
|
* rights and limitations under the License.
|
|
*
|
|
* The Original Code is mozilla.org code.
|
|
*
|
|
* The Initial Developer of the Original Code is Netscape
|
|
* Communications Corporation. Portions created by Netscape are
|
|
* Copyright (C) 1998 Netscape Communications Corporation. All
|
|
* Rights Reserved.
|
|
*
|
|
* Contributor(s):
|
|
* Pierre Phaneuf <pp@ludusdesign.com>
|
|
*/
|
|
|
|
#include <stdio.h>
|
|
|
|
#include "nsRepository.h"
|
|
#include "nsIServiceManager.h"
|
|
#include "nsCOMPtr.h"
|
|
#include "nsSpecialSystemDirectory.h" // For exe dir
|
|
|
|
#include "nscore.h"
|
|
#include "nspr.h"
|
|
#include "prmon.h"
|
|
|
|
#include "nsITestProxy.h"
|
|
|
|
#include "nsProxyObjectManager.h"
|
|
#include "nsIEventQueueService.h"
|
|
|
|
static NS_DEFINE_CID(kEventQueueServiceCID, NS_EVENTQUEUESERVICE_CID);
|
|
|
|
/***************************************************************************/
|
|
extern "C" void
|
|
NS_SetupRegistry()
|
|
{
|
|
nsComponentManager::AutoRegister(nsIComponentManager::NS_Startup, NULL /* default */);
|
|
}
|
|
|
|
|
|
/***************************************************************************/
|
|
/* nsTestXPCFoo */
|
|
/***************************************************************************/
|
|
class nsTestXPCFoo : public nsITestProxy
|
|
{
|
|
NS_DECL_ISUPPORTS
|
|
NS_IMETHOD Test(PRInt32 p1, PRInt32 p2, PRInt32* retval);
|
|
NS_IMETHOD Test2();
|
|
NS_IMETHOD Test3(nsISupports *p1, nsISupports **p2);
|
|
|
|
nsTestXPCFoo();
|
|
virtual ~nsTestXPCFoo();
|
|
|
|
};
|
|
|
|
nsTestXPCFoo::nsTestXPCFoo()
|
|
{
|
|
NS_INIT_REFCNT();
|
|
NS_ADDREF_THIS();
|
|
}
|
|
|
|
nsTestXPCFoo::~nsTestXPCFoo()
|
|
{
|
|
}
|
|
|
|
NS_IMPL_ISUPPORTS(nsTestXPCFoo, NS_GET_IID(nsITestProxy))
|
|
|
|
NS_IMETHODIMP nsTestXPCFoo::Test(PRInt32 p1, PRInt32 p2, PRInt32* retval)
|
|
{
|
|
printf("Thread (%d) Test Called successfully! Party on...\n", p1);
|
|
*retval = p1+p2;
|
|
return NS_OK;
|
|
}
|
|
|
|
|
|
NS_IMETHODIMP nsTestXPCFoo::Test2()
|
|
{
|
|
printf("The quick brown netscape jumped over the old lazy ie..\n");
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
NS_IMETHODIMP nsTestXPCFoo::Test3(nsISupports *p1, nsISupports **p2)
|
|
{
|
|
if (p1 != nsnull)
|
|
{
|
|
nsITestProxy *test;
|
|
|
|
p1->QueryInterface(NS_GET_IID(nsITestProxy), (void**)&test);
|
|
|
|
test->Test2();
|
|
PRInt32 a;
|
|
test->Test( 1, 2, &a);
|
|
printf("\n1+2=%d\n",a);
|
|
}
|
|
|
|
|
|
*p2 = new nsTestXPCFoo();
|
|
return NS_OK;
|
|
}
|
|
|
|
/***************************************************************************/
|
|
/* nsTestXPCFoo2 */
|
|
/***************************************************************************/
|
|
class nsTestXPCFoo2 : public nsITestProxy
|
|
{
|
|
NS_DECL_ISUPPORTS
|
|
NS_IMETHOD Test(PRInt32 p1, PRInt32 p2, PRInt32* retval);
|
|
NS_IMETHOD Test2();
|
|
NS_IMETHOD Test3(nsISupports *p1, nsISupports **p2);
|
|
|
|
nsTestXPCFoo2();
|
|
virtual ~nsTestXPCFoo2();
|
|
|
|
};
|
|
|
|
nsTestXPCFoo2::nsTestXPCFoo2()
|
|
{
|
|
NS_INIT_REFCNT();
|
|
NS_ADDREF_THIS();
|
|
}
|
|
|
|
nsTestXPCFoo2::~nsTestXPCFoo2()
|
|
{
|
|
}
|
|
|
|
NS_IMPL_ISUPPORTS(nsTestXPCFoo2,NS_GET_IID(nsITestProxy))
|
|
|
|
NS_IMETHODIMP nsTestXPCFoo2::Test(PRInt32 p1, PRInt32 p2, PRInt32* retval)
|
|
{
|
|
printf("calling back to caller!\n\n");
|
|
|
|
nsIProxyObjectManager* manager;
|
|
nsITestProxy * proxyObject;
|
|
|
|
nsServiceManager::GetService( NS_XPCOMPROXY_PROGID,
|
|
NS_GET_IID(nsIProxyObjectManager),
|
|
(nsISupports **)&manager);
|
|
|
|
printf("ProxyObjectManager: %p \n", manager);
|
|
|
|
PR_ASSERT(manager);
|
|
|
|
manager->GetProxyObject((nsIEventQueue*)p1, NS_GET_IID(nsITestProxy), this, PROXY_SYNC, (void**)&proxyObject);
|
|
proxyObject->Test3(nsnull, nsnull);
|
|
|
|
printf("Deleting Proxy Object\n");
|
|
NS_RELEASE(proxyObject);
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
|
|
NS_IMETHODIMP nsTestXPCFoo2::Test2()
|
|
{
|
|
printf("nsTestXPCFoo2::Test2() called\n");
|
|
|
|
return NS_OK;
|
|
}
|
|
|
|
|
|
NS_IMETHODIMP nsTestXPCFoo2::Test3(nsISupports *p1, nsISupports **p2)
|
|
{
|
|
printf("Got called");
|
|
return NS_OK;
|
|
}
|
|
|
|
|
|
|
|
typedef struct _ArgsStruct
|
|
{
|
|
nsIEventQueue* queue;
|
|
PRInt32 threadNumber;
|
|
}ArgsStruct;
|
|
|
|
|
|
|
|
// This will create two objects both descendants of a single IID.
|
|
void TestCase_TwoClassesOneInterface(void *arg)
|
|
{
|
|
ArgsStruct *argsStruct = (ArgsStruct*) arg;
|
|
|
|
|
|
nsIProxyObjectManager* manager;
|
|
|
|
nsServiceManager::GetService( NS_XPCOMPROXY_PROGID,
|
|
NS_GET_IID(nsIProxyObjectManager),
|
|
(nsISupports **)&manager);
|
|
|
|
printf("ProxyObjectManager: %p \n", manager);
|
|
|
|
PR_ASSERT(manager);
|
|
|
|
nsITestProxy *proxyObject;
|
|
nsITestProxy *proxyObject2;
|
|
|
|
nsTestXPCFoo* foo = new nsTestXPCFoo();
|
|
nsTestXPCFoo2* foo2 = new nsTestXPCFoo2();
|
|
|
|
PR_ASSERT(foo);
|
|
PR_ASSERT(foo2);
|
|
|
|
|
|
manager->GetProxyObject(argsStruct->queue, NS_GET_IID(nsITestProxy), foo, PROXY_SYNC, (void**)&proxyObject);
|
|
|
|
manager->GetProxyObject(argsStruct->queue, NS_GET_IID(nsITestProxy), foo2, PROXY_SYNC, (void**)&proxyObject2);
|
|
|
|
|
|
|
|
if (proxyObject && proxyObject2)
|
|
{
|
|
// release ownership of the real object.
|
|
|
|
PRInt32 a;
|
|
nsresult rv;
|
|
PRInt32 threadNumber = argsStruct->threadNumber;
|
|
|
|
printf("Deleting real Object (%d)\n", threadNumber);
|
|
NS_RELEASE(foo);
|
|
|
|
printf("Deleting real Object 2 (%d)\n", threadNumber);
|
|
NS_RELEASE(foo2);
|
|
|
|
|
|
printf("Thread (%d) Prior to calling proxyObject->Test.\n", threadNumber);
|
|
rv = proxyObject->Test(threadNumber, 0, &a);
|
|
printf("Thread (%d) error: %d.\n", threadNumber, rv);
|
|
|
|
|
|
printf("Thread (%d) Prior to calling proxyObject->Test2.\n", threadNumber);
|
|
rv = proxyObject->Test2();
|
|
printf("Thread (%d) error: %d.\n", threadNumber, rv);
|
|
|
|
printf("Thread (%d) Prior to calling proxyObject2->Test2.\n", threadNumber);
|
|
rv = proxyObject2->Test2();
|
|
printf("Thread (%d) proxyObject2 error: %d.\n", threadNumber, rv);
|
|
|
|
printf("Deleting Proxy Object (%d)\n", threadNumber );
|
|
NS_RELEASE(proxyObject);
|
|
|
|
printf("Deleting Proxy Object 2 (%d)\n", threadNumber );
|
|
NS_RELEASE(proxyObject2);
|
|
}
|
|
|
|
PR_Sleep( PR_MillisecondsToInterval(1000) ); // If your thread goes away, your stack goes away. Only use ASYNC on calls that do not have out parameters
|
|
}
|
|
|
|
|
|
|
|
void TestCase_NestedLoop(void *arg)
|
|
{
|
|
ArgsStruct *argsStruct = (ArgsStruct*) arg;
|
|
|
|
|
|
nsIProxyObjectManager* manager;
|
|
|
|
nsServiceManager::GetService( NS_XPCOMPROXY_PROGID,
|
|
NS_GET_IID(nsIProxyObjectManager),
|
|
(nsISupports **)&manager);
|
|
|
|
printf("ProxyObjectManager: %d \n", manager);
|
|
|
|
PR_ASSERT(manager);
|
|
|
|
nsITestProxy *proxyObject;
|
|
nsTestXPCFoo2* foo = new nsTestXPCFoo2();
|
|
|
|
PR_ASSERT(foo);
|
|
|
|
|
|
manager->GetProxyObject(argsStruct->queue, NS_GET_IID(nsITestProxy), foo, PROXY_SYNC, (void**)&proxyObject);
|
|
|
|
if (proxyObject)
|
|
{
|
|
// release ownership of the real object.
|
|
|
|
nsresult rv;
|
|
PRInt32 threadNumber = argsStruct->threadNumber;
|
|
|
|
printf("Deleting real Object (%d)\n", threadNumber);
|
|
NS_RELEASE(foo);
|
|
|
|
PRInt32 retval;
|
|
|
|
printf("Getting EventQueue...\n");
|
|
|
|
nsIEventQueue* eventQ;
|
|
NS_WITH_SERVICE(nsIEventQueueService, eventQService, kEventQueueServiceCID, &rv);
|
|
if (NS_SUCCEEDED(rv))
|
|
{
|
|
rv = eventQService->GetThreadEventQueue(NS_CURRENT_THREAD, &eventQ);
|
|
if (NS_FAILED(rv))
|
|
rv = eventQService->CreateThreadEventQueue();
|
|
if (NS_FAILED(rv))
|
|
return;
|
|
else
|
|
rv = eventQService->GetThreadEventQueue(NS_CURRENT_THREAD, &eventQ);
|
|
|
|
printf("Thread (%d) Prior to calling proxyObject->Test.\n", threadNumber);
|
|
rv = proxyObject->Test((PRInt32)eventQ, 0, &retval);
|
|
printf("Thread (%d) proxyObject error: %d.\n", threadNumber, rv);
|
|
|
|
printf("Deleting Proxy Object (%d)\n", threadNumber );
|
|
NS_RELEASE(proxyObject);
|
|
}
|
|
|
|
PR_Sleep( PR_MillisecondsToInterval(1000) ); // If your thread goes away, your stack goes away. Only use ASYNC on calls that do not have out parameters
|
|
}
|
|
}
|
|
|
|
|
|
|
|
void TestCase_2(void *arg)
|
|
{
|
|
|
|
ArgsStruct *argsStruct = (ArgsStruct*) arg;
|
|
|
|
nsIProxyObjectManager* manager;
|
|
|
|
nsServiceManager::GetService( NS_XPCOMPROXY_PROGID,
|
|
NS_GET_IID(nsIProxyObjectManager),
|
|
(nsISupports **)&manager);
|
|
|
|
PR_ASSERT(manager);
|
|
|
|
nsITestProxy *proxyObject;
|
|
|
|
manager->GetProxyObject(argsStruct->queue,
|
|
NS_GET_IID(nsITestProxy), // should be CID!
|
|
nsnull,
|
|
NS_GET_IID(nsITestProxy),
|
|
PROXY_SYNC,
|
|
(void**)&proxyObject);
|
|
|
|
if (proxyObject != nsnull)
|
|
{
|
|
NS_RELEASE(proxyObject);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
void TestCase_nsISupports(void *arg)
|
|
{
|
|
|
|
ArgsStruct *argsStruct = (ArgsStruct*) arg;
|
|
|
|
nsIProxyObjectManager* manager;
|
|
|
|
nsServiceManager::GetService( NS_XPCOMPROXY_PROGID,
|
|
NS_GET_IID(nsIProxyObjectManager),
|
|
(nsISupports **)&manager);
|
|
|
|
PR_ASSERT(manager);
|
|
|
|
nsITestProxy *proxyObject;
|
|
nsTestXPCFoo* foo = new nsTestXPCFoo();
|
|
|
|
PR_ASSERT(foo);
|
|
|
|
manager->GetProxyObject(argsStruct->queue, NS_GET_IID(nsITestProxy), foo, PROXY_SYNC, (void**)&proxyObject);
|
|
|
|
if (proxyObject != nsnull)
|
|
{
|
|
nsISupports *bISupports = nsnull, *cISupports = nsnull;
|
|
|
|
proxyObject->Test3(foo, &bISupports);
|
|
proxyObject->Test3(bISupports, &cISupports);
|
|
|
|
nsITestProxy *test;
|
|
bISupports->QueryInterface(NS_GET_IID(nsITestProxy), (void**)&test);
|
|
|
|
test->Test2();
|
|
|
|
NS_RELEASE(foo);
|
|
NS_RELEASE(proxyObject);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/***************************************************************************/
|
|
/* ProxyTest */
|
|
/***************************************************************************/
|
|
|
|
static void PR_CALLBACK ProxyTest( void *arg )
|
|
{
|
|
//TestCase_TwoClassesOneInterface(arg);
|
|
// TestCase_2(arg);
|
|
//TestCase_nsISupports(arg);
|
|
TestCase_NestedLoop(arg);
|
|
|
|
NS_RELEASE( ((ArgsStruct*) arg)->queue);
|
|
free((void*) arg);
|
|
}
|
|
|
|
nsIEventQueue *gEventQueue = nsnull;
|
|
|
|
static void PR_CALLBACK EventLoop( void *arg )
|
|
{
|
|
nsresult rv;
|
|
printf("Creating EventQueue...\n");
|
|
|
|
nsIEventQueue* eventQ;
|
|
NS_WITH_SERVICE(nsIEventQueueService, eventQService, kEventQueueServiceCID, &rv);
|
|
if (NS_SUCCEEDED(rv)) {
|
|
rv = eventQService->GetThreadEventQueue(NS_CURRENT_THREAD, &eventQ);
|
|
if (NS_FAILED(rv))
|
|
rv = eventQService->CreateThreadEventQueue();
|
|
if (NS_FAILED(rv))
|
|
return;
|
|
else
|
|
rv = eventQService->GetThreadEventQueue(NS_CURRENT_THREAD, &eventQ);
|
|
}
|
|
if (NS_FAILED(rv)) return;
|
|
|
|
rv = eventQ->QueryInterface(NS_GET_IID(nsIEventQueue), (void**)&gEventQueue);
|
|
if (NS_FAILED(rv)) return;
|
|
|
|
|
|
printf("Verifing calling Proxy on eventQ thread.\n");
|
|
|
|
nsIProxyObjectManager* manager;
|
|
|
|
nsServiceManager::GetService( NS_XPCOMPROXY_PROGID,
|
|
NS_GET_IID(nsIProxyObjectManager),
|
|
(nsISupports **)&manager);
|
|
|
|
PR_ASSERT(manager);
|
|
|
|
nsITestProxy *proxyObject;
|
|
nsTestXPCFoo* foo = new nsTestXPCFoo();
|
|
|
|
PR_ASSERT(foo);
|
|
|
|
manager->GetProxyObject(gEventQueue, NS_GET_IID(nsITestProxy), foo, PROXY_SYNC, (void**)&proxyObject);
|
|
|
|
PRInt32 a;
|
|
proxyObject->Test(1, 2, &a);
|
|
proxyObject->Test2();
|
|
|
|
|
|
NS_RELEASE(proxyObject);
|
|
delete foo;
|
|
|
|
printf("End of Verification calling Proxy on eventQ thread.\n");
|
|
|
|
|
|
printf("Looping for events.\n");
|
|
|
|
PLEvent* event = nsnull;
|
|
|
|
while ( PR_SUCCESS == PR_Sleep( PR_MillisecondsToInterval(1)) )
|
|
{
|
|
rv = gEventQueue->GetEvent(&event);
|
|
if (NS_FAILED(rv))
|
|
return;
|
|
gEventQueue->HandleEvent(event);
|
|
}
|
|
|
|
gEventQueue->ProcessPendingEvents();
|
|
|
|
printf("Closing down Event Queue.\n");
|
|
delete gEventQueue;
|
|
gEventQueue = nsnull;
|
|
|
|
printf("End looping for events.\n\n");
|
|
}
|
|
|
|
int
|
|
main(int argc, char **argv)
|
|
{
|
|
int numberOfThreads = 1;
|
|
|
|
if (argc > 1)
|
|
numberOfThreads = atoi(argv[1]);
|
|
|
|
NS_SetupRegistry();
|
|
|
|
|
|
static PRThread** threads = (PRThread**) calloc(sizeof(PRThread*), numberOfThreads);
|
|
static PRThread* aEventThread;
|
|
|
|
aEventThread = PR_CreateThread(PR_USER_THREAD,
|
|
EventLoop,
|
|
NULL,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_GLOBAL_THREAD,
|
|
PR_JOINABLE_THREAD,
|
|
0 );
|
|
|
|
|
|
PR_Sleep(PR_MillisecondsToInterval(1000));
|
|
|
|
NS_ASSERTION(gEventQueue, "no main event queue"); // BAD BAD BAD. EVENT THREAD DID NOT CREATE QUEUE. This may be a timing issue, set the
|
|
// sleep about longer, and try again.
|
|
|
|
printf("Spawn Threads:\n");
|
|
for (PRInt32 spawn = 0; spawn < numberOfThreads; spawn++)
|
|
{
|
|
|
|
ArgsStruct *args = (ArgsStruct *) malloc (sizeof(ArgsStruct));
|
|
|
|
args->queue = gEventQueue;
|
|
NS_ADDREF(args->queue);
|
|
args->threadNumber = spawn;
|
|
|
|
threads[spawn] = PR_CreateThread(PR_USER_THREAD,
|
|
ProxyTest,
|
|
args,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_GLOBAL_THREAD,
|
|
PR_JOINABLE_THREAD,
|
|
0 );
|
|
|
|
printf("\tThread (%d) spawned\n", spawn);
|
|
|
|
PR_Sleep( PR_MillisecondsToInterval(250) );
|
|
}
|
|
|
|
printf("All Threads Spawned.\n\n");
|
|
|
|
|
|
|
|
printf("Wait for threads.\n");
|
|
for (PRInt32 i = 0; i < numberOfThreads; i++)
|
|
{
|
|
PRStatus rv;
|
|
printf("Thread (%d) Join...\n", i);
|
|
rv = PR_JoinThread(threads[i]);
|
|
printf("Thread (%d) Joined. (error: %d).\n", i, rv);
|
|
}
|
|
|
|
PR_Interrupt(aEventThread);
|
|
PR_JoinThread(aEventThread);
|
|
|
|
|
|
printf("Calling Cleanup.\n");
|
|
PR_Cleanup();
|
|
|
|
printf("Return zero.\n");
|
|
return 0;
|
|
}
|