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
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
// -*- Mode: C++; -*-
// Package : omniORB2
// corbaBoa.h Created on: 23/7/99
// Author : David Riddoch (djr)
//
// Copyright (C) 1996-1999 AT&T Laboratories Cambridge
//
// This file is part of the omniORB library
//
// The omniORB library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
// Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public
// License along with this library. If not, see http://www.gnu.org/licenses/
//
//
// Description:
// Implementation of the BOA interface, built upon the POA interface.
//
#ifndef __CORBABOA_H__
#define __CORBABOA_H__
#ifndef __OMNI_OBJECTADAPTER_H__
#include <objectAdapter.h>
#endif
#ifdef _core_attr
# error "A local CPP macro _core_attr has already been defined."
#endif
#if defined(_OMNIORB_LIBRARY)
# define _core_attr
#else
# define _core_attr _OMNIORB_NTDLL_IMPORT
#endif
OMNI_NAMESPACE_BEGIN(omni)
class omniOrbBOA : public CORBA::BOA, public omniObjAdapter
{
public:
omniOrbBOA(int is_nil);
virtual ~omniOrbBOA();
////////////////
// CORBA::BOA //
////////////////
virtual void impl_is_ready(CORBA::ImplementationDef_ptr, CORBA::Boolean);
virtual void impl_shutdown();
virtual void destroy();
virtual void obj_is_ready(omniOrbBoaServant*, CORBA::ImplementationDef_ptr);
virtual void obj_is_ready(CORBA::Object_ptr, CORBA::ImplementationDef_ptr);
virtual void dispose(CORBA::Object_ptr);
virtual CORBA::Object_ptr create(const CORBA::ReferenceData&,
CORBA::_objref_InterfaceDef*,
CORBA::ImplementationDef_ptr);
virtual CORBA::ReferenceData* get_id(CORBA::Object_ptr);
virtual void change_implementation(CORBA::Object_ptr,
CORBA::ImplementationDef_ptr);
virtual CORBA::Principal_ptr get_principal(CORBA::Object_ptr,
CORBA::Environment_ptr);
virtual void deactivate_impl(CORBA::ImplementationDef_ptr);
virtual void deactivate_obj(CORBA::Object_ptr);
////////////////////////////
// Override CORBA::Object //
////////////////////////////
virtual _CORBA_Boolean _non_existent();
virtual void* _ptrToObjRef(const char* repoId);
virtual void _NP_incrRefCount();
virtual void _NP_decrRefCount();
/////////////////////////////
// Override omniObjAdapter //
/////////////////////////////
virtual void incrRefCount();
virtual void decrRefCount();
virtual void dispatch(omniCallHandle&, omniLocalIdentity*);
virtual void dispatch(omniCallHandle&,
const _CORBA_Octet* key, int keysize);
virtual void dispatch(omniCallDescriptor&, omniLocalIdentity*);
virtual int objectExists(const _CORBA_Octet* key, int keysize);
virtual void lastInvocationHasCompleted(omniLocalIdentity* id);
virtual void* _ptrToClass(int* cptr);
static inline omniOrbBOA* _downcast(omniObjAdapter* a) {
return a ? (omniOrbBOA*)a->_ptrToClass(&_classid) : 0;
}
static _core_attr int _classid;
//////////////
// Internal //
//////////////
static omniOrbBOA* theBOA();
// Returns a reference to the BOA if it exists, or
// zero (not nil) if not.
inline void incrRefCount_locked() { pd_refCount++; }
// Must hold <boa_lock>.
inline omniObjTableEntry** activeObjList() { return &pd_activeObjList; }
// Must hold <boa_lock>.
void dispose(omniIdentity*);
// Deactivates the given object, returning silently on failure.
// The caller must hold <omni::internalLock> and <boa_lock> on
// entry. Both are always released before this function returns.
// This function does not throw any exceptions.
void synchronise_request();
private:
enum { IDLE, ACTIVE, DESTROYED } pd_state;
// Protected by <omni::internalLock>.
int pd_refCount;
// Protected by <boa_lock>.
omniObjTableEntry* pd_activeObjList;
// A list of objects activated in this adapter.
// Protected by <boa_lock>.
int pd_nblocked;
// The number of threads blocked in impl_is_ready().
// Protected by <boa_lock> and <pd_signal>.
int pd_nwaiting;
// The number of threads blocked in
// synchronise_request().
// Protected by <omni::internalLock>.
omni_tracedcondition* pd_state_signal;
// Uses <omni::internalLock> as lock. Signalled
// on state change.
};
OMNI_NAMESPACE_END(omni)
#undef _core_attr
#endif // __OMNIORB_BOA_H__
|
