private void doInvoke(DynamicImplementation servant, org.omg.CORBA.ServerRequest request) { try { servant.invoke(request); } catch (org.omg.CORBA.SystemException se) { throw se; } catch (Throwable th) { if (m_poa_manager.m_orb.m_trace != null) { String[] msg = { toString(), " Exception in servant invoke method, UNKOWN thrown: " }; m_trace.printStackTrace(Trace.DEBUG, msg, th); } throw new org.omg.CORBA.UNKNOWN(); } }
public void dispatchRequest( QueuedResponseHandler responseHandler ) { if ( responseHandler != null ){ if(setPOAKey(responseHandler)) { this.rootPOAManager.put( responseHandler ); if ( this.orb.m_trace != null) { ServerRequest request = responseHandler.getServerRequest(); this.orb.printTrace( Trace.DEEP_DEBUG, new String[]{ toString(), " Dispatching ", responseHandler.toString() } ); } } } else { throw new BAD_PARAM( "null response handler" ); } }
/** * The obsolete invocation using server request. Implemented for * compatibility reasons, but is it more effectinve to use * {@link #_invoke}. * * @param request a server request. */ public void invoke(ServerRequest request) { // "destroy" has a void return type, the two other methods - boolean. Streamable result = request.operation().equals("destroy") ? null : new BooleanHolder(); gnu.CORBA.ServiceRequestAdapter.invoke(request, this, result); }
/** * Executes "_is_a" request on the ServantDelegate. * * @param servant * The target servant of the "_is_a" request. * @param request * The queued request to be executed. */ private void invoke_is_a(POAImpl poa, org.omg.PortableServer.Servant servant, org.omg.CORBA.ServerRequest request) { try { es.tid.TIDorbj.core.poa.ServantDelegate deleg = (es.tid.TIDorbj.core.poa.ServantDelegate) servant._get_delegate(); org.omg.CORBA.ORB orb = poa.m_orb; org.omg.CORBA.NVList params = orb.create_list(1); org.omg.CORBA.Any $s = orb.create_any(); $s.type(orb.get_primitive_tc(org.omg.CORBA.TCKind.tk_string)); params.add_value("s", $s, org.omg.CORBA.ARG_IN.value); request.arguments(params); String itf = $s.extract_string(); boolean result = deleg.is_a(servant, itf); org.omg.CORBA.Any resultAny = orb.create_any(); resultAny.insert_boolean(result); request.set_result(resultAny); } catch (org.omg.CORBA.SystemException se) { throw se; } catch (Throwable th) { if ( this.m_orb.m_trace != null) { m_trace.printStackTrace( Trace.DEBUG, new String[]{ toString(), " Exception in servant invoke \"_is_a\" method, ", "UNKOWN thrown: " }, th ); } throw new org.omg.CORBA.UNKNOWN(); } }
public ServerRequest getServerRequest() { throw new NO_IMPLEMENT( "LocateRequest doesn't have a peer ServerRequest", 0, CompletionStatus.COMPLETED_NO ); }
public ServerRequest getServerRequest() { return this.serverRequest; }
/** * Handle the invocation via passed request. * * @param request the data structure, used both to pass parameters * and return results of the invocation. */ public abstract void invoke(ServerRequest request);
public abstract ServerRequest getServerRequest();