⟦483755434⟧

E3 Source Code



WITH Rpc;
WITH Transport;
WITH Transport_Stream;

PACKAGE Rpc_Server IS

   PROCEDURE Begin_Response (Stream : Transport_Stream.Stream_Id;
                             Id     : Rpc.Transaction_Id);

   GENERIC
      Program   : Rpc.Program_Number;
      Supported : Rpc.Version_Range := (0, Rpc.Version_Number'Last);

      WITH PROCEDURE Process_Call (Stream  : Transport_Stream.Stream_Id;
                                   Id      : Rpc.Transaction_Id;
                                   Version : Rpc.Version_Number;
                                   Proc    : Rpc.Procedure_Number) IS <>;

      -- Process one procedure call: get the arguments from
      -- the STREAM, make the call, call BEGIN_RESPONSE
      -- (STREAM, ID), and put the results into the stream.
      -- If an exception is raised, call RETURN_EXCEPTION.
      -- If an unexpected exception is raised, simply let it
      -- propagate.  The caller will catch it.  The caller
      -- will also take care of flushing the stream transmit
      -- buffer on return.


      WITH PROCEDURE Initialize;
      -- Called before entering the main loop

      WITH PROCEDURE Main_Loop_Preprocess;
      -- First statement of the main loop

      WITH PROCEDURE Main_Loop_Postprocess;
      -- Last statement of the main loop

   PROCEDURE Serve (Connection : Transport.Connection_Id);

   -- Serve an incoming RPC connection: Allocate a transport
   -- stream.  Check the incoming package and version.  If
   -- they don't match, transmit an exception.  If they
   -- match, process calls until the connection is
   -- disconnected.  On each call, catch any propagated
   -- exceptions and transmit them, and flush the transmit
   -- buffer.  When the connection is disconnected, or a
   -- protocol error occurs, deallocate the transport stream
   -- and return.


   PROCEDURE Return_Exception (Stream : Transport_Stream.Stream_Id;
                               Id     : Rpc.Transaction_Id;
                               Excep  : Rpc.Exception_Number);

   -- Like Begin_Response (above) except that it returns an exception.
   -- The server must NOT return any data following the exception.



   -- Serve an incoming RPC connection: Allocate a transport
   -- stream.  Check the incoming package and version.  If
   -- they don't match, transmit an exception.  If they
   -- match, process calls until the connection is
   -- disconnected.  On each call, catch any propagated
   -- exceptions and transmit them, and flush the transmit
   -- buffer.  When the connection is disconnected, or a
   -- protocol error occurs, deallocate the transport stream
   -- and return.

END Rpc_Server;
DataMuseum.dk

Rational R1000/400

⟦483755434⟧ Ada Source

Derivation

E3 Source Code

E3 Meta Data
