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
154
155
156
157
158
159
160
161
162
163 | --
-- Copyright (C) 2018-2022, AdaCore
--
-- SPDX-License-Identifier: Apache-2.0
--
with Spawn.Processes.Monitor;
with Spawn.Processes.Windows;
separate (Spawn.Processes)
package body Platform is
use type Ada.Streams.Stream_Element_Offset;
--------------------------
-- Close_Standard_Error --
--------------------------
procedure Close_Standard_Error (Self : in out Process'Class) is
begin
Monitor.Enqueue ((Monitor.Close_Pipe, Self'Unchecked_Access, Stderr));
end Close_Standard_Error;
--------------------------
-- Close_Standard_Input --
--------------------------
procedure Close_Standard_Input (Self : in out Process'Class) is
begin
Monitor.Enqueue ((Monitor.Close_Pipe, Self'Unchecked_Access, Stdin));
end Close_Standard_Input;
---------------------------
-- Close_Standard_Output --
---------------------------
procedure Close_Standard_Output (Self : in out Process'Class) is
begin
Monitor.Enqueue ((Monitor.Close_Pipe, Self'Unchecked_Access, Stdout));
end Close_Standard_Output;
--------------
-- Finalize --
--------------
procedure Finalize
(Self : in out Process'Class;
Status : Process_Status)
is
pragma Unreferenced (Self);
begin
if Status = Running then
raise Program_Error;
end if;
end Finalize;
------------------
-- Kill_Process --
------------------
procedure Kill_Process (Self : in out Process'Class) is
begin
Windows.Do_Kill_Process (Self);
end Kill_Process;
-------------------------
-- Read_Standard_Error --
-------------------------
procedure Read_Standard_Error
(Self : in out Process'Class;
Data : out Ada.Streams.Stream_Element_Array;
Last : out Ada.Streams.Stream_Element_Offset)
is
procedure On_No_Data;
procedure On_No_Data is
begin
Monitor.Enqueue ((Monitor.Watch_Pipe, Self'Unchecked_Access, Stderr));
end On_No_Data;
begin
if Self.Status /= Running then
Last := Data'First - 1;
return;
end if;
Windows.Do_Read (Self, Data, Last, Stderr, On_No_Data'Access);
end Read_Standard_Error;
--------------------------
-- Read_Standard_Output --
--------------------------
procedure Read_Standard_Output
(Self : in out Process'Class;
Data : out Ada.Streams.Stream_Element_Array;
Last : out Ada.Streams.Stream_Element_Offset)
is
procedure On_No_Data;
procedure On_No_Data is
begin
Monitor.Enqueue ((Monitor.Watch_Pipe, Self'Unchecked_Access, Stdout));
end On_No_Data;
begin
if Self.Status /= Running then
Last := Data'First - 1;
return;
end if;
Windows.Do_Read (Self, Data, Last, Stdout, On_No_Data'Access);
end Read_Standard_Output;
-----------
-- Start --
-----------
procedure Start (Self : in out Process'Class) is
begin
Self.Status := Starting;
Self.Exit_Code := -1;
Monitor.Enqueue ((Monitor.Start, Self'Unchecked_Access));
end Start;
-----------------------
-- Terminate_Process --
-----------------------
procedure Terminate_Process (Self : in out Process'Class) is
begin
Windows.Do_Terminate_Process (Self);
end Terminate_Process;
--------------------------
-- Write_Standard_Input --
--------------------------
procedure Write_Standard_Input
(Self : in out Process'Class;
Data : Ada.Streams.Stream_Element_Array;
Last : out Ada.Streams.Stream_Element_Offset)
is
procedure On_No_Data;
----------------
-- On_No_Data --
----------------
procedure On_No_Data is
begin
Monitor.Enqueue ((Monitor.Watch_Pipe, Self'Unchecked_Access, Stdin));
end On_No_Data;
begin
if Self.Status /= Running or Data'Length = 0 then
Last := Data'First - 1;
return;
end if;
Windows.Do_Write (Self, Data, Last, On_No_Data'Access);
end Write_Standard_Input;
end Platform;
|