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 | ------------------------------------------------------------------------------
-- --
-- GLADE COMPONENTS --
-- --
-- S Y S T E M . R P C --
-- --
-- S p e c --
-- --
-- Copyright (C) 1996-2020 Free Software Foundation, Inc. --
-- --
-- GARLIC is free software; you can redistribute it and/or modify it under --
-- terms of the GNU General Public License as published by the Free Soft- --
-- ware Foundation; either version 2, or (at your option) any later ver- --
-- sion. GARLIC is distributed in the hope that it will be useful, but --
-- WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABI- --
-- LITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public --
-- License for more details. You should have received a copy of the GNU --
-- General Public License distributed with GARLIC; see file COPYING. If --
-- not, write to the Free Software Foundation, 59 Temple Place - Suite 330, --
-- Boston, MA 02111-1307, USA. --
-- --
-- As a special exception, if other files instantiate generics from this --
-- unit, or you link this unit with other files to produce an executable, --
-- this unit does not by itself cause the resulting executable to be --
-- covered by the GNU General Public License. This exception does not --
-- however invalidate any other reasons why the executable file might be --
-- covered by the GNU Public License. --
-- --
------------------------------------------------------------------------------
with Ada.Streams;
with System.Garlic.Streams;
with System.Garlic.Types;
package System.RPC is
type Partition_ID is
range System.Garlic.Types.Null_Partition_ID ..
System.Garlic.Types.Last_Partition_ID;
Communication_Error : exception;
type Params_Stream_Type
(Initial_Size : Ada.Streams.Stream_Element_Count) is new
Ada.Streams.Root_Stream_Type with private;
procedure Read
(Stream : in out Params_Stream_Type;
Item : out Ada.Streams.Stream_Element_Array;
Last : out Ada.Streams.Stream_Element_Offset);
procedure Write
(Stream : in out Params_Stream_Type;
Item : Ada.Streams.Stream_Element_Array);
procedure Do_RPC
(Partition : Partition_ID;
Params : access Params_Stream_Type;
Result : access Params_Stream_Type);
-- Synchronous call
procedure Do_APC
(Partition : Partition_ID;
Params : access Params_Stream_Type);
-- Asynchronous call
type RPC_Receiver is
access procedure
(Params : access Params_Stream_Type;
Result : access Params_Stream_Type);
-- Handled used for incoming RPC
procedure Establish_RPC_Receiver (
Partition : Partition_ID;
Receiver : RPC_Receiver);
private
pragma Inline (Read);
pragma Inline (Write);
type Params_Stream_Type
(Initial_Size : Ada.Streams.Stream_Element_Count)
is new Ada.Streams.Root_Stream_Type with record
X : aliased System.Garlic.Streams.Params_Stream_Type (Initial_Size);
end record;
type Session_Type is mod 2 ** 8;
No_Session : constant Session_Type := Session_Type'First;
procedure Allocate
(Session : out Session_Type;
Partition : Partition_ID);
procedure Deallocate
(Session : Session_Type);
type RPC_Opcode is (RPC_Query,
RPC_Reply,
Abortion_Query,
Abortion_Reply,
APC_Query);
-- Type of operation
type RPC_Header (Kind : RPC_Opcode) is record
case Kind is
when RPC_Query |
RPC_Reply |
Abortion_Query |
Abortion_Reply =>
Session : Session_Type;
when APC_Query =>
null;
end case;
end record;
procedure Insert_RPC_Header
(Params : access System.Garlic.Streams.Params_Stream_Type;
Header : RPC_Header);
-- Add a RPC_Header in front of Params
procedure When_Established;
-- Wait for partition to be established
type Allocate_Task_Procedure is access procedure
(Partition : System.Garlic.Types.Partition_ID;
Session : System.RPC.Session_Type;
-- Stamp : System.Garlic.Types.Stamp_Type;
Params : System.Garlic.Streams.Params_Stream_Access;
Async : Boolean);
type Abort_Task_Procedure is access procedure
(Partition : System.Garlic.Types.Partition_ID;
Session : System.RPC.Session_Type);
type Parameterless_Procedure is access procedure;
procedure Register_Task_Pool
(Allocate_Task : Allocate_Task_Procedure;
Abort_Task : Abort_Task_Procedure;
Initialize : Parameterless_Procedure;
Shutdown : Parameterless_Procedure);
procedure Finalize
(Partition : System.Garlic.Types.Partition_ID;
Waiting : Boolean;
Session : Session_Type);
-- Handle abortion from Do_RPC
end System.RPC;
|