162f7f89cc
urp connect update git-svn-id: svn://10.0.0.236/trunk@96522 18797224-902f-48f8-a5cc-f745e15eee43
102 lines
3.1 KiB
C++
102 lines
3.1 KiB
C++
#include "nsIServiceManager.h"
|
|
#include "nsIComponentManager.h"
|
|
|
|
#include "nsIURI.h"
|
|
#include "nsNetUtil.h"
|
|
#include "nsIPref.h"
|
|
#include "plevent.h"
|
|
#include "prmem.h"
|
|
#include "prnetdb.h"
|
|
#include "prthread.h"
|
|
|
|
#include "urpManager.h"
|
|
#include "urpTransport.h"
|
|
|
|
#include "urpITest.h"
|
|
#include "bcIORBComponent.h"
|
|
#include "bcORBComponentCID.h"
|
|
#include "urpTestImpl.h"
|
|
#include <unistd.h>
|
|
|
|
#include "nsIModule.h"
|
|
|
|
#include "bcIXPCOMStubsAndProxies.h"
|
|
#include "bcXPCOMStubsAndProxiesCID.h"
|
|
|
|
static NS_DEFINE_CID(kXPCOMStubsAndProxies,BC_XPCOMSTUBSANDPROXIES_CID);
|
|
static NS_DEFINE_CID(kORBCIID,BC_ORBCOMPONENT_CID);
|
|
|
|
struct localThreadArg {
|
|
urpManager *mgr;
|
|
urpConnection *conn;
|
|
localThreadArg( urpManager *mgr, urpConnection *conn ) {
|
|
this->mgr = mgr;
|
|
this->conn = conn;
|
|
}
|
|
};
|
|
|
|
void thread_start_server( void *arg )
|
|
{
|
|
urpManager *manager = ((localThreadArg *)arg)->mgr;
|
|
urpConnection *connection = ((localThreadArg *)arg)->conn;
|
|
nsresult rv = manager->ReadMessage( connection, PR_FALSE );
|
|
}
|
|
|
|
int main( int argc, char *argv[] ) {
|
|
|
|
char *connectString = "socket,host=localhost,port=2009";
|
|
if( argc == 2 ) connectString = argv[1];
|
|
|
|
nsresult rv = NS_InitXPCOM(NULL, NULL);
|
|
NS_ASSERTION( NS_SUCCEEDED(rv), "NS_InitXPCOM failed" );
|
|
|
|
NS_WITH_SERVICE(bcIORBComponent, _orb, kORBCIID, &rv);
|
|
if (NS_FAILED(rv)) {
|
|
printf("NS_WITH_SERVICE(bcXPC in Marshal failed\n");
|
|
}
|
|
|
|
NS_WITH_SERVICE(bcIXPCOMStubsAndProxies, xpcomStubsAndProxies, kXPCOMStubsAndProxies, &rv);
|
|
if (NS_FAILED(rv)) {
|
|
printf("bcXPCOMStubsAndProxie failed\n");
|
|
return -1;
|
|
}
|
|
|
|
bcIORB *orb;
|
|
_orb->GetORB(&orb);
|
|
bcIStub *stub = nsnull;
|
|
urpITest *object = new urpTestImpl();
|
|
object->AddRef();
|
|
urpITest *proxy = nsnull;
|
|
xpcomStubsAndProxies->GetStub((nsISupports*)object, &stub);
|
|
bcOID oid = orb->RegisterStub(stub);
|
|
|
|
urpTransport* trans = new urpAcceptor();
|
|
PRStatus status = trans->Open(connectString);
|
|
if(status == PR_SUCCESS) printf("succes %ld\n",oid);
|
|
else printf("failed\n");
|
|
object->AddRef();
|
|
urpManager* mngr = new urpManager(PR_FALSE, orb, nsnull);
|
|
rv = NS_OK;
|
|
while(NS_SUCCEEDED(rv)) {
|
|
// rv = mngr->HandleRequest(trans->GetConnection());
|
|
urpConnection *conn = trans->GetConnection();
|
|
if( conn != NULL ) {
|
|
// handle request in new thread
|
|
localThreadArg *arg = new localThreadArg( mngr, conn );
|
|
PRThread *thr = PR_CreateThread( PR_USER_THREAD,
|
|
thread_start_server,
|
|
arg,
|
|
PR_PRIORITY_NORMAL,
|
|
PR_GLOBAL_THREAD,
|
|
PR_UNJOINABLE_THREAD,
|
|
0);
|
|
if( thr == nsnull ) {
|
|
rv = NS_ERROR_FAILURE;
|
|
}
|
|
} else {
|
|
rv = NS_ERROR_FAILURE;
|
|
}
|
|
}
|
|
return 1;
|
|
}
|