added install batch similar to that provided in /reactos. Removed deprecated Makefile.
[reactos.git] / posix / server / ob / session.c
1 /* $Id: session.c,v 1.3 2002/10/29 04:45:54 rex Exp $
2 *
3 * PROJECT : ReactOS / POSIX+ Environment Subsystem Server
4 * FILE : reactos/subsys/psx/server/ob/session.c
5 * DESCRIPTION: terminal
6 * DATE : 2002-04-04
7 * AUTHOR : Emanuele Aliberti <eal@users.sf.net>
8 *
9 * --------------------------------------------------------------------
10 *
11 * This software is free software; you can redistribute it and/or
12 * modify it under the terms of the GNU General Public License as
13 * published by the Free Software Foundation; either version 2 of the
14 * License, or (at your option) any later version.
15 *
16 * This software is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
19 * General Public License for more details.
20 *
21 * You should have received a copy of the GNU General Public License
22 * along with this software; see the file COPYING. If not, write
23 * to the Free Software Foundation, Inc., 675 Mass Ave, Cambridge,
24 * MA 02139, USA.
25 *
26 * --------------------------------------------------------------------
27 */
28 #include <psxss.h>
29
30 #define LOCK_ALL_SESSIONS RtlEnterCriticalSection(& Sessions.Lock)
31 #define UNLOCK_ALL_SESSIONS RtlLeaveCriticalSection(& Sessions.Lock)
32 #define LOCK_THIS_SESSION RtlEnterCriticalSection(& Session->Lock)
33 #define UNLOCK_THIS_SESSION RtlLeaveCriticalSection(& Session->Lock)
34
35
36 /* A double-linked list for the PSX_SESSION instances */
37
38 static struct
39 {
40 ULONG NextFreeId;
41 LONG Count;
42 PPSX_SESSION List;
43 CRITICAL_SECTION Lock;
44
45 } Sessions;
46
47 /**** FUNCTIONS ******************************************************/
48
49 /**********************************************************************
50 * PsxInitializeSessions/0
51 *
52 * DESCRIPTION
53 * Initialize the PSX session manager.
54 * ARGUMENTS
55 * None.
56 * RETURN VALUE
57 * None.
58 */
59 NTSTATUS STDCALL
60 PsxInitializeSessions (VOID)
61 {
62 debug_print (L"PSXSS: ->"__FUNCTION__);
63 /* Initalize the attributes */
64 Sessions.NextFreeId = 0;
65 Sessions.Count = 0;
66 Sessions.List = NULL;
67 RtlInitializeCriticalSection (& Sessions.Lock);
68 return STATUS_SUCCESS;
69 }
70 /**********************************************************************
71 * PsxCreateSessionObjects/1 PRIVATE
72 *
73 */
74 PRIVATE NTSTATUS STDCALL
75 PsxCreateSessionObjects (
76 IN PLPC_MAX_MESSAGE pRequest,
77 IN OUT PPSX_SESSION pSession
78 )
79 {
80 NTSTATUS Status;
81 OBJECT_ATTRIBUTES Oa;
82 WCHAR NameBuffer [NAME_BUFFER_SIZE];
83 UNICODE_STRING Name;
84 SECURITY_QUALITY_OF_SERVICE Sqos;
85 PSX_CONNECT_PORT_DATA ConnectData;
86 ULONG ConnectDataSize = sizeof ConnectData;
87
88 /* Port */
89 swprintf (
90 NameBuffer,
91 PSX_NS_SESSION_PORT_TEMPLATE,
92 PSX_NS_SUBSYSTEM_DIRECTORY_NAME,
93 PSX_NS_SESSION_DIRECTORY_NAME,
94 pRequest->Header.Cid.UniqueProcess
95 );
96 debug_print (L"PSXSS: "__FUNCTION__": %s", NameBuffer);
97 RtlInitUnicodeString (& Name, NameBuffer);
98 InitializeObjectAttributes (& Oa, & Name, 0, NULL, NULL);
99 RtlZeroMemory (& Sqos, sizeof Sqos);
100 ConnectData.ConnectionType = PSX_CONNECTION_TYPE_SERVER;
101 ConnectData.Version = PSX_LPC_PROTOCOL_VERSION;
102 ConnectData.PortIdentifier = 0;
103 Status = NtConnectPort (
104 & pSession->TerminalChannel.hPort,
105 & Name,
106 & Sqos,
107 NULL,
108 NULL,
109 NULL,
110 (PVOID) & ConnectData,
111 & ConnectDataSize
112 );
113 if (!NT_SUCCESS(Status))
114 {
115 debug_print (L"PSXSS: "__FUNCTION__": NtConnectPort failed with %08x\n", Status);
116 return Status;
117 }
118 /* TODO: */
119 /* Section */
120 swprintf (
121 NameBuffer,
122 PSX_NS_SESSION_DATA_TEMPLATE,
123 PSX_NS_SUBSYSTEM_DIRECTORY_NAME,
124 PSX_NS_SESSION_DIRECTORY_NAME,
125 pRequest->Header.Cid.UniqueProcess
126 );
127 debug_print (L"PSXSS: "__FUNCTION__": %s", NameBuffer);
128 RtlInitUnicodeString (& Name, NameBuffer);
129 InitializeObjectAttributes (& Oa, & Name, 0, 0, 0);
130 Status = NtOpenSection (
131 & pSession->TerminalChannel.Section.Handle,
132 SECTION_ALL_ACCESS, /* DesiredAccess */
133 & Oa
134 );
135 if (!NT_SUCCESS(Status))
136 {
137 NtClose (pSession->TerminalChannel.hPort);
138 debug_print (L"PSXSS: "__FUNCTION__": NtOpenSection failed with %08x\n", Status);
139 return Status;
140 }
141 pSession->TerminalChannel.Section.BaseAddress = NULL;
142 pSession->TerminalChannel.Section.ViewSize = PSX_TERMINAL_SECTION_SIZE;
143 Status = NtMapViewOfSection (
144 pSession->TerminalChannel.Section.Handle,
145 NtCurrentProcess(),
146 & pSession->TerminalChannel.Section.BaseAddress,
147 0, /* ZeroBits */
148 0, /* Commitsize */
149 0, /* SectionOffset */
150 & pSession->TerminalChannel.Section.ViewSize,
151 ViewUnmap,
152 0, /* AllocationType */
153 PAGE_READWRITE /* Protect 4 */
154 );
155 if (!NT_SUCCESS(Status))
156 {
157 NtClose (pSession->TerminalChannel.hPort);
158 NtClose (pSession->TerminalChannel.Section.Handle);
159 debug_print (L"PSXSS: "__FUNCTION__": NtMapViewOfSection failed with %08x\n", Status);
160 return Status;
161 }
162 return Status;
163 }
164 /**********************************************************************
165 * PsxCreateSession/3
166 *
167 * DESCRIPTION
168 * Create a new PSX_SESSION object and insert it in the
169 * PSX sessions table.
170 * ARGUMENTS
171 * MessageHeader
172 * Id
173 * RETURN VALUE
174 * A status value on error; otherwise STATUS_SUCCESS.
175 */
176 NTSTATUS STDCALL
177 PsxCreateSession (
178 IN PLPC_MAX_MESSAGE pRequest,
179 IN HANDLE hConnectedPort,
180 IN ULONG ulPortIdentifier
181 )
182 {
183 PPSX_SESSION Session = NULL;
184
185 debug_print (L"PSXSS: ->"__FUNCTION__);
186 /* Create the PSX_SESSION object */
187 Session = RtlAllocateHeap (Server.Heap, 0, sizeof (PSX_SESSION));
188 if (NULL == Session)
189 {
190 debug_print (L"PSXSS: "__FUNCTION__": failed to create a new session object");
191 return STATUS_MEMORY_NOT_ALLOCATED;
192 }
193 RtlZeroMemory (Session, sizeof (PSX_SESSION));
194 /* Initialiaze the new PSX_SESSION object */
195 Session->SessionChannel.hPort = hConnectedPort;
196 Session->SessionChannel.ulPortIdentifier = ulPortIdentifier;
197 LOCK_ALL_SESSIONS;
198 Session->Id = Sessions.NextFreeId ++;
199 UNLOCK_ALL_SESSIONS;
200 Session->Status = SESSION_STATUS_INITIALIZATION;
201 Session->Heap =
202 RtlCreateHeap (
203 HEAP_GROWABLE,
204 NULL,
205 65536,
206 65536,
207 NULL,
208 NULL
209 );
210 if (INVALID_HANDLE_VALUE == Session->Heap)
211 {
212 RtlFreeHeap (Server.Heap, 0, Session);
213 debug_print (L"PSX: "__FUNCTION__": failed to create a new heap for session # %d", Session->Id);
214 return STATUS_MEMORY_NOT_ALLOCATED;
215 }
216 RtlInitializeCriticalSection (& Session->Lock);
217 /* TODO: open the terminal's shared section */
218 /* TODO: connect to the terminal's port */
219 /* Inset the new PSX_SESSION object in the sessions table */
220 LOCK_ALL_SESSIONS;
221 if (NULL == Sessions.List)
222 {
223 Sessions.List = Session;
224 Session->Previous = Session;
225 }
226 Session->Next = Sessions.List; /* Last one points to the top one */
227 Session->Previous = Sessions.List->Previous;
228 Sessions.List->Previous = Session; /* Top one now points to the new one (tail) */
229 ++ Sessions.Count;
230 UNLOCK_ALL_SESSIONS;
231 /* DONE */
232 debug_print (L""__FUNCTION__": session # %d created", Session->Id);
233 Session->Status = SESSION_STATUS_READY;
234 return STATUS_SUCCESS;
235 }
236 /**********************************************************************
237 * PsxTerminateSession/1
238 *
239 * DESCRIPTION
240 * Remove a PSX_SESSION object from the PSX sessions table and
241 * destroy it.
242 *
243 * ARGUMENTS
244 *
245 * RETURN VALUE
246 * A status value on error; otherwise STATUS_SUCCESS.
247 */
248 NTSTATUS STDCALL
249 PsxTerminateSession (
250 IN PPSX_SESSION Session
251 )
252 {
253 LONG Id;
254 PPSX_SESSION Previous = NULL;
255 PPSX_SESSION Next = NULL;
256
257 /* Release any resource managed by the session */
258 RtlDestroyHeap (Session->Heap);
259 /* Remove the session object from the sessions table */
260 LOCK_ALL_SESSIONS;
261 Id = Session->Id;
262 Previous = Session->Previous;
263 Next = Session->Next;
264 /* TODO: handle the case of no session left */
265 Next->Previous = Previous;
266 Previous->Next = Next;
267 -- Sessions.Count;
268 UNLOCK_ALL_SESSIONS;
269 /* Delete the old PSX_SESSION object */
270 RtlFreeHeap (Server.Heap, 0, Session);
271 /* DONE */
272 debug_print(L"PSX: session # %d deleted", Id);
273 return STATUS_SUCCESS;
274 }
275
276 NTSTATUS STDCALL
277 PsxWriteTerminalSession (
278 IN PPSX_SESSION Session,
279 IN PVOID Buffer,
280 IN ULONG Size,
281 IN OUT PULONG Written
282 )
283 {
284 LOCK_THIS_SESSION;
285 /* TODO: lock this session's section for writing */
286 /* TODO: copy the data in this session's section */
287 /* TODO: request a WRITE operation to the session terminal */
288 /* TODO: unlock this session's section */
289 UNLOCK_THIS_SESSION;
290 }
291
292 NTSTATUS STDCALL
293 PsxReadTerminalSession (
294 IN PPSX_SESSION Session,
295 OUT PVOID Buffer,
296 IN ULONG Size,
297 IN OUT PULONG Read
298 )
299 {
300 LOCK_THIS_SESSION;
301 /* TODO: lock this session's section for reading */
302 /* TODO: request a READ operation to the session terminal */
303 /* TODO: copy the data from this session's section */
304 /* TODO: unlock this session's section */
305 UNLOCK_THIS_SESSION;
306 }
307 /* EOF */