171
172 public Collection getAcceptors()
173 {
174 return getAcceptors(null, null);
175 }
176
177 public synchronized void unregisterAcceptor(Acceptor acceptor)
178 {
179 acceptors.remove(acceptor);
180 }
181
182 public void close()
183 {
184 try {
185 if (orb.transportDebugFlag) {
186 dprint(".close->");
187 }
188 for (Object cc : outboundConnectionCaches.values()) {
189 ((ConnectionCache)cc).close() ;
190 }
191 for (Object cc : inboundConnectionCaches.values()) {
192 ((ConnectionCache)cc).close() ;
193 }
194 getSelector(0).close();
195 } finally {
196 if (orb.transportDebugFlag) {
197 dprint(".close<-");
198 }
199 }
200 }
201
202 ////////////////////////////////////////////////////
203 //
204 // CorbaTransportManager
205 //
206
207 public Collection getAcceptors(String objectAdapterManagerId,
208 ObjectAdapterId objectAdapterId)
209 {
210 // REVISIT - need to filter based on arguments.
211
212 // REVISIT - initialization will be moved to OA.
|
171
172 public Collection getAcceptors()
173 {
174 return getAcceptors(null, null);
175 }
176
177 public synchronized void unregisterAcceptor(Acceptor acceptor)
178 {
179 acceptors.remove(acceptor);
180 }
181
182 public void close()
183 {
184 try {
185 if (orb.transportDebugFlag) {
186 dprint(".close->");
187 }
188 for (Object cc : outboundConnectionCaches.values()) {
189 ((ConnectionCache)cc).close() ;
190 }
191 for (Object icc : inboundConnectionCaches.values()) {
192 ((ConnectionCache)icc).close() ;
193 unregisterAcceptor(((InboundConnectionCache)icc).getAcceptor());
194 }
195 getSelector(0).close();
196 } finally {
197 if (orb.transportDebugFlag) {
198 dprint(".close<-");
199 }
200 }
201 }
202
203 ////////////////////////////////////////////////////
204 //
205 // CorbaTransportManager
206 //
207
208 public Collection getAcceptors(String objectAdapterManagerId,
209 ObjectAdapterId objectAdapterId)
210 {
211 // REVISIT - need to filter based on arguments.
212
213 // REVISIT - initialization will be moved to OA.
|