1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
// @(#)svr.cpp 05/14/97
// Copyright 1994-1995 by Sun Microsystems Inc.
// All Rights Reserved
//
// TEST: simple IIOP server for "cubit.idl" interface.
//
// Starts up, builds an objref, prints its string in debug mode,
// listens for messages, responds to them.
//
// Modified version of Cubit Example written by Sun Microsystems Inc.
// Modified by: Brian Mendel
#include "cubit_i.h"
#include <ace/Get_Opt.h>
#include "corba/orb.h"
#include <corba/debug.h>
#include <connect.h>
extern void
print_exception (const CORBA_Exception *, const char *, FILE *f=stdout);
//
// Standard command line parsing utilities used.
//
int
main (int argc, char *argv[])
{
CORBA_Environment env;
CORBA_Object_ptr obj;
CORBA_ORB_ptr orb_ptr;
CORBA_BOA_ptr oa_ptr;
CORBA_String key = (CORBA_String) "key0";
char *orb_name = "internet";
int idle = -1;
int debug_level = 1;
#if defined (VXWORKS)
char *oa_name = "mv2604d:1000";
int dummy = 1;
orb_ptr = CORBA_ORB_init (dummy, (char **)0, orb_name, env);
#else
orb_ptr = CORBA_ORB_init (argc, argv, orb_name, env);
#endif
if (env.exception () != 0) {
print_exception (env.exception (), "ORB init");
return 1;
}
// Initialize the Basic Object Adapter
oa_ptr = orb_ptr->BOA_init(argc, argv, "ROA");
// Create implementation object with user specified key
Cubit_i_ptr my_cubit = new Cubit_i(key);
if (debug_level >= 1)
{
// Why are we getting the BOA_ptr from here when we've already
// got it above?
CORBA_BOA_ptr oa = TAO_OA_PARAMS::instance()->oa();
CORBA_OctetSeq obj_key;
obj_key.buffer = (CORBA_Octet *) key;
obj_key.length = obj_key.maximum = ACE_OS::strlen ((char *)key);
if (oa)
(void) oa->find(obj_key, obj);
//
// Stringify the objref we'll be implementing, and
// print it to stdout. Someone will take that string
// and give it to some client. Then release the object.
//
CORBA_String str;
str = orb_ptr->object_to_string (obj, env);
if (env.exception () != 0) {
print_exception (env.exception (), "object2string");
return 1;
}
ACE_OS::puts ((char *)str);
ACE_OS::fflush (stdout);
dmsg1 ("listening as object '%s'", str);
}
// Handle requests for this object until we're killed, or one of
// the methods asks us to exit.
//
int terminationStatus = 0;
// Insert Object Key into context
// params->context(&obj_key);
#if !defined(USE_HOMEBREW_EVENT_LOOP)
ACE_Service_Config::run_reactor_event_loop();
#else
while (1)
{
int result = params->reactor()->handle_events ();
if (result == -1)
{
terminationStatus = -1;
break;
}
}
#endif
//
// Shut down the OA -- recycles all underlying resources (e.g. file
// descriptors, etc).
//
oa_ptr->clean_shutdown (env);
return 0;
}
|
