source: trunk/src/kernel32/oslibdos.cpp@ 2300

Last change on this file since 2300 was 2300, checked in by sandervl, 26 years ago

PB: Started with named pipe api implementation

File size: 25.1 KB
Line 
1/*
2 * Wrappers for OS/2 Dos* API
3 *
4 * Copyright 1998-2000 Sander van Leeuwen (sandervl@xs4all.nl)
5 * Copyright 1999-2000 Edgar Buerkle <Edgar.Buerkle@gmx.net>
6 * Copyright 2000 Przemyslaw Dobrowolski <dobrawka@asua.org.pl>
7 *
8 * Project Odin Software License can be found in LICENSE.TXT
9 *
10 */
11#define INCL_BASE
12#define INCL_DOSEXCEPTIONS
13#define INCL_DOSMEMMGR
14#define INCL_DOSPROCESS
15#define INCL_DOSERRORS
16#define INCL_NPIPES
17#include <os2wrap.h> //Odin32 OS/2 api wrappers
18#include <stdlib.h>
19#include <stdio.h>
20#include <string.h>
21#include <win32type.h>
22#include <winconst.h>
23#include <misc.h>
24#include "initterm.h"
25#include "oslibdos.h"
26#include "dosqss.h"
27
28/***********************************
29 * PH: fixups for missing os2win.h *
30 ***********************************/
31
32void _System SetLastError(ULONG ulError);
33
34APIRET APIENTRY DosAliasMem(PVOID pb, ULONG cb, PPVOID ppbAlias, ULONG fl);
35
36//******************************************************************************
37//TODO: Assumes entire memory range has the same protection flags!
38//TODO: Check if this works for code aliases...
39//******************************************************************************
40DWORD OSLibDosAliasMem(LPVOID pb, ULONG cb, LPVOID *ppbAlias, ULONG fl)
41{
42 DWORD rc;
43 DWORD attr;
44 DWORD size = cb;
45
46 cb = (cb-1) & ~0xfff;
47 cb+= PAGE_SIZE;
48
49 rc = DosQueryMem(pb, &size, &attr);
50 if(rc) {
51 dprintf(("OSLibDosAliasMem: DosQueryMem %x %x return %d", pb, size, rc));
52 return rc;
53 }
54 size = (size-1) & ~0xfff;
55 size+= PAGE_SIZE;
56 if(size != cb) {
57 dprintf(("ERROR: OSLibDosAliasMem: size != cb (%x!=%x)!!!!!!!!", size, cb));
58 //ignore this and continue return 5;
59 attr = fl; //just use original protection flags (NOT CORRECT)
60 }
61 attr &= (PAG_READ|PAG_WRITE|PAG_EXECUTE|PAG_GUARD|PAG_DEFAULT);
62 if(attr != fl) {
63 rc = DosSetMem(pb, size, fl);
64 if(rc) {
65 dprintf(("OSLibDosAliasMem: DosSetMem %x %x return %d", pb, size, rc));
66 attr = fl;
67 //just continue for now
68 //return rc;
69 }
70 }
71 rc = DosAliasMem(pb, cb, ppbAlias, 2);
72 if(rc) {
73 dprintf(("OSLibDosAliasMem: DosAliasMem %x %x return %d", pb, cb, rc));
74 return rc;
75 }
76 if(attr != fl) {
77 rc = DosSetMem(pb, size, attr);
78 if(rc) {
79 dprintf(("OSLibDosAliasMem: DosSetMem (2) %x %x return %d", pb, size, rc));
80 return rc;
81 }
82 }
83 return 0;
84}
85//******************************************************************************
86//NT returns addresses aligned at 64k, so we do too.
87//******************************************************************************
88DWORD OSLibDosAllocMem(LPVOID *lplpMemAddr, DWORD size, DWORD flags)
89{
90 LPVOID memaddr;
91 DWORD offset;
92 APIRET rc;
93
94 rc = DosAllocMem(&memaddr, size, PAG_READ | flAllocMem);
95 if(rc) {
96 return rc;
97 }
98 DosEnterCritSec();
99 DosFreeMem(memaddr);
100 offset = (DWORD)memaddr & 0xFFFF;
101 if(offset) {
102 DosAllocMem(&memaddr, 64*1024 - offset, PAG_READ | flAllocMem);
103 }
104 rc = DosAllocMem(lplpMemAddr, size, flags | flAllocMem);
105 DosExitCritSec();
106 if((DWORD)*lplpMemAddr & 0xFFFF) {//still not at 64k boundary?
107 DosFreeMem(*lplpMemAddr);
108 rc = OSLibDosAllocMem(lplpMemAddr, size, flags);
109 }
110 if(offset) {
111 DosFreeMem(memaddr);
112 }
113
114 return rc;
115}
116//******************************************************************************
117//******************************************************************************
118DWORD OSLibDosFreeMem(LPVOID lpMemAddr)
119{
120 return DosFreeMem(lpMemAddr);
121}
122//******************************************************************************
123//NOTE: If name == NULL, allocated gettable unnamed shared memory
124//******************************************************************************
125DWORD OSLibDosAllocSharedMem(LPVOID *lplpMemAddr, DWORD size, DWORD flags, LPSTR name)
126{
127 APIRET rc;
128 char *sharedmemname = NULL;
129
130 if(name) {
131 sharedmemname = (char *)malloc(strlen(name) + 16);
132 strcpy(sharedmemname, "\\SHAREMEM\\");
133 strcat(sharedmemname, name);
134 }
135 else flags |= OBJ_GETTABLE;
136
137 rc = DosAllocSharedMem(lplpMemAddr, sharedmemname, size, flags);
138 if(name) {
139 free(sharedmemname);
140 }
141 return rc;
142}
143//******************************************************************************
144//NOTE: If name == NULL, assume gettable unnamed shared memory
145//******************************************************************************
146DWORD OSLibDosGetNamedSharedMem(LPVOID *lplpMemAddr, LPSTR name)
147{
148 APIRET rc;
149 char *sharedmemname = NULL;
150
151 if(name) {
152 sharedmemname = (char *)malloc(strlen(name) + 16);
153 strcpy(sharedmemname, "\\SHAREMEM\\");
154 strcat(sharedmemname, name);
155 rc = DosGetNamedSharedMem(lplpMemAddr, sharedmemname, PAG_READ|PAG_WRITE);
156 if(name) {
157 free(sharedmemname);
158 }
159 }
160 else rc = DosGetSharedMem((LPVOID)*(DWORD *)lplpMemAddr, PAG_READ|PAG_WRITE);
161
162 return rc;
163}
164//******************************************************************************
165//******************************************************************************
166DWORD OSLibDosQueryMem(LPVOID lpMemAddr, DWORD *lpRangeSize, DWORD *lpAttr)
167{
168 return DosQueryMem(lpMemAddr, lpRangeSize, lpAttr);
169}
170//******************************************************************************
171//******************************************************************************
172DWORD OSLibDosSetMem(LPVOID lpMemAddr, DWORD size, DWORD flags)
173{
174 APIRET rc;
175
176 rc = DosSetMem(lpMemAddr, size, flags);
177 switch(rc) {
178 case ERROR_INVALID_ADDRESS:
179 return OSLIB_ERROR_INVALID_ADDRESS;
180 case ERROR_ACCESS_DENIED:
181 return OSLIB_ERROR_ACCESS_DENIED;
182 default:
183 return rc;
184 }
185}
186//******************************************************************************
187//******************************************************************************
188DWORD OSLibDosOpen(char *lpszFileName, DWORD flags)
189{
190 APIRET rc;
191 HFILE hFile;
192 ULONG ulAction;
193 DWORD os2flags = OPEN_FLAGS_NOINHERIT;
194
195
196 if(flags & OSLIB_ACCESS_READONLY)
197 os2flags |= OPEN_ACCESS_READONLY;
198 else
199 if(flags & OSLIB_ACCESS_READWRITE)
200 os2flags |= OPEN_ACCESS_READWRITE;
201
202 if(flags & OSLIB_ACCESS_SHAREDENYNONE)
203 os2flags |= OPEN_SHARE_DENYNONE;
204 else
205 if(flags & OSLIB_ACCESS_SHAREDENYREAD)
206 os2flags |= OPEN_SHARE_DENYREAD;
207 else
208 if(flags & OSLIB_ACCESS_SHAREDENYWRITE)
209 os2flags |= OPEN_SHARE_DENYWRITE;
210
211tryopen:
212 rc = DosOpen(lpszFileName, /* File path name */
213 &hFile, /* File handle */
214 &ulAction, /* Action taken */
215 0L, /* File primary allocation */
216 0L, /* File attribute */
217 OPEN_ACTION_FAIL_IF_NEW |
218 OPEN_ACTION_OPEN_IF_EXISTS, /* Open function type */
219 os2flags,
220 0L); /* No extended attribute */
221
222 if(rc) {
223 if(rc == ERROR_TOO_MANY_OPEN_FILES) {
224 ULONG CurMaxFH;
225 LONG ReqCount = 32;
226
227 rc = DosSetRelMaxFH(&ReqCount, &CurMaxFH);
228 if(rc) {
229 dprintf(("DosSetRelMaxFH returned %d", rc));
230 return 0;
231 }
232 dprintf(("DosOpen failed -> increased nr open files to %d", CurMaxFH));
233 goto tryopen;
234 }
235 return 0;
236 }
237 else return hFile;
238}
239//******************************************************************************
240//******************************************************************************
241DWORD OSLibDosClose(DWORD hFile)
242{
243 return DosClose(hFile);
244}
245//******************************************************************************
246//******************************************************************************
247DWORD OSLibDosRead(DWORD hFile, LPVOID lpBuffer, DWORD size, DWORD *nrBytesRead)
248{
249 return DosRead(hFile, lpBuffer, size, nrBytesRead);
250}
251//******************************************************************************
252//******************************************************************************
253DWORD OSLibDosWrite(DWORD hFile, LPVOID lpBuffer, DWORD size, DWORD *nrBytesWritten)
254{
255 return DosWrite(hFile, lpBuffer, size, nrBytesWritten);
256}
257//******************************************************************************
258//******************************************************************************
259DWORD OSLibDosSetFilePtr(DWORD hFile, DWORD offset, DWORD method)
260{
261 DWORD os2method;
262 DWORD newoffset;
263 APIRET rc;
264
265 switch(method) {
266 case OSLIB_SETPTR_FILE_CURRENT:
267 os2method = FILE_CURRENT;
268 break;
269 case OSLIB_SETPTR_FILE_BEGIN:
270 os2method = FILE_BEGIN ;
271 break;
272 case OSLIB_SETPTR_FILE_END:
273 os2method = FILE_END;
274 break;
275 default:
276 return OSLIB_ERROR_INVALID_PARAMETER;
277 }
278 rc = DosSetFilePtr(hFile, offset, os2method, &newoffset);
279 if(rc) {
280 return -1;
281 }
282 else return newoffset;
283}
284//******************************************************************************
285//******************************************************************************
286//@@@PH Note: this routine is nothing but a QUICK'N'DIRTY HACK!
287//@@@PH this function should be implemented accordingly to NTDLL's
288// RtlSecondsSince1980ToTime
289// RtlTimeToSecondsSince1980
290static void iFDATEFTIME2FILETIME(FDATE fdOS2, FTIME ftOS2, LPFILETIME pftWin32)
291{
292 float f;
293 #define facSECOND 2 // as encoded in OS/2
294 #define facMINUTE 60
295 #define facHOUR 3600
296 #define facDAY 86400
297 #define facMONTH facDAY * 30 // cough, cough :)
298 #define facYEAR facDAY * 365
299
300 /* pftWin32 is 100ns based from 01.01.1601 00:00:00 */
301 f = (fdOS2.year + 379) * facYEAR // 1980 - 1601
302 + (fdOS2.month - 0 ) * facMONTH
303 + (fdOS2.day - 1 ) * facDAY
304 + (ftOS2.hours ) * facHOUR
305 + (ftOS2.minutes ) * facMINUTE
306 + (ftOS2.twosecs ) * facSECOND;
307
308 f *= 10000; // convert to 100ns base
309 pftWin32->dwHighDateTime = (f / (float)(0xffffffff) );
310 pftWin32->dwLowDateTime = (f - (float)((float)pftWin32->dwHighDateTime *
311 (float)0xffffffff) );
312}
313
314BOOL OSLibDosGetFileAttributesEx(PSZ pszName,
315 ULONG ulDummy,
316 PVOID pBuffer)
317{
318 APIRET rc; /* API return code */
319 FILESTATUS3 fs3; /* file information structure */
320 LPWIN32_FILE_ATTRIBUTE_DATA lpFad = (LPWIN32_FILE_ATTRIBUTE_DATA) pBuffer;
321
322 // Note: we only handle standard "GetFileExInfoStandard" requests
323 rc = DosQueryPathInfo(pszName, /* query the file information */
324 FIL_STANDARD,
325 &fs3,
326 sizeof(fs3));
327 if (rc != NO_ERROR) /* check for errors */
328 return FALSE; /* raise error condition */
329
330 // convert structure
331 lpFad->dwFileAttributes = fs3.attrFile; // directly interchangeable
332 iFDATEFTIME2FILETIME(fs3.fdateCreation, fs3.ftimeCreation, &lpFad->ftCreationTime);
333 iFDATEFTIME2FILETIME(fs3.fdateLastAccess, fs3.ftimeLastAccess, &lpFad->ftLastAccessTime);
334 iFDATEFTIME2FILETIME(fs3.fdateLastWrite, fs3.ftimeLastWrite, &lpFad->ftLastWriteTime);
335
336 /* @@@PH we might add Aurora support ...
337 lpFad->nFileSizeHigh = info.nFileSizeHigh;
338 */
339 lpFad->nFileSizeHigh = 0;
340 lpFad->nFileSizeLow = fs3.cbFile;
341
342 return TRUE;
343}
344//******************************************************************************
345//******************************************************************************
346DWORD OSLibDosSearchPath(DWORD cmd, char *path, char *name, char *full_name,
347 DWORD length_fullname)
348{
349 switch(cmd) {
350 case OSLIB_SEARCHDIR:
351 if(DosSearchPath(SEARCH_IGNORENETERRS, path,
352 name, full_name, length_fullname) != 0) {
353 return 0;
354 }
355 return strlen(full_name);
356
357
358 case OSLIB_SEARCHCURDIR:
359 if(DosSearchPath(SEARCH_IGNORENETERRS | SEARCH_CUR_DIRECTORY, path,
360 name, full_name, length_fullname) != 0) {
361 return 0;
362 }
363 return strlen(full_name);
364
365 case OSLIB_SEARCHFILE:
366 {
367 FILESTATUS3 fileinfo;
368
369 if(DosQueryPathInfo(name, FIL_STANDARD, &fileinfo, sizeof(fileinfo)) != 0) {
370 return 0;
371 }
372 strncpy(full_name, name, length_fullname);
373 return strlen(full_name);
374 }
375
376 case OSLIB_SEARCHENV:
377 {
378 char *env = getenv(path);
379 if(env == NULL)
380 return 0;
381
382 while(*env != '=') env++;
383 env++;
384 while(*env == ' ') env++;
385 if(DosSearchPath(SEARCH_IGNORENETERRS | SEARCH_ENVIRONMENT, env,
386 name, full_name, length_fullname) != 0) {
387 return 0;
388 }
389 return strlen(full_name);
390 }
391 }
392 return 0;
393}
394//******************************************************************************
395//******************************************************************************
396DWORD OSLibDosCreate(CHAR *lpFileName,
397 DWORD dwAccess,
398 DWORD dwShare,
399 LPSECURITY_ATTRIBUTES lpSecurityAttributes,
400 DWORD dwCreation,
401 DWORD dwFlags,
402 HANDLE hTemplate,
403 DWORD *dwFile)
404{
405 APIRET rc;
406 HFILE hFile;
407 ULONG ulAction=0;
408 DWORD os2Attrib=0;
409 DWORD os2Flags = 0; //OPEN_FLAGS_NOINHERIT;
410 DWORD os2Open=0;
411
412 if(dwAccess == (GENERIC_READ_W | GENERIC_WRITE_W))
413 os2Flags |= OPEN_ACCESS_READWRITE;
414 else if(dwAccess & GENERIC_WRITE_W)
415 os2Flags |= OPEN_ACCESS_WRITEONLY;
416 else if(dwAccess & GENERIC_READ_W)
417 os2Flags |= OPEN_ACCESS_READONLY;
418
419 if(dwShare == 0)
420 os2Flags |= OPEN_SHARE_DENYREADWRITE;
421 else if(dwShare == (FILE_SHARE_READ_W | FILE_SHARE_WRITE_W))
422 os2Flags |= OPEN_SHARE_DENYNONE;
423 else if(dwShare & FILE_SHARE_READ_W)
424 os2Flags |= OPEN_SHARE_DENYWRITE;
425 else if(dwShare & FILE_SHARE_WRITE_W)
426 os2Flags |= OPEN_SHARE_DENYREAD;
427
428 if(dwCreation == CREATE_NEW_W)
429 os2Open = OPEN_ACTION_FAIL_IF_EXISTS | OPEN_ACTION_CREATE_IF_NEW;
430 else if(dwCreation == CREATE_ALWAYS_W)
431 os2Open = OPEN_ACTION_REPLACE_IF_EXISTS | OPEN_ACTION_CREATE_IF_NEW;
432 else if(dwCreation == OPEN_EXISTING_W)
433 os2Open = OPEN_ACTION_OPEN_IF_EXISTS | OPEN_ACTION_FAIL_IF_NEW;
434 else if(dwCreation == OPEN_ALWAYS_W)
435 os2Open = OPEN_ACTION_OPEN_IF_EXISTS | OPEN_ACTION_CREATE_IF_NEW;
436 else if(dwCreation == TRUNCATE_EXISTING_W)
437 os2Open = OPEN_ACTION_REPLACE_IF_EXISTS;// |OPEN_ACTION_FAIL_IF_NEW;
438
439 if(dwFlags & FILE_ATTRIBUTE_READONLY_W)
440 os2Attrib |= FILE_READONLY;
441 if(dwFlags & FILE_ATTRIBUTE_HIDDEN_W)
442 os2Attrib |= FILE_HIDDEN;
443 if(dwFlags & FILE_ATTRIBUTE_SYSTEM_W)
444 os2Attrib |= FILE_SYSTEM;
445 if(dwFlags & FILE_ATTRIBUTE_DIRECTORY_W)
446 os2Attrib |= FILE_DIRECTORY;
447 if(dwFlags & FILE_ATTRIBUTE_ARCHIVE_W)
448 os2Attrib |= FILE_ARCHIVED;
449 if(dwFlags & FILE_ATTRIBUTE_NORMAL_W)
450 os2Attrib |= FILE_NORMAL;
451
452 if(dwFlags & FILE_FLAG_WRITE_THROUGH_W)
453 os2Flags |= OPEN_FLAGS_WRITE_THROUGH;
454 if(dwFlags & FILE_FLAG_NO_BUFFERING_W)
455 os2Flags |= OPEN_FLAGS_NO_CACHE;
456 if(dwFlags & FILE_FLAG_RANDOM_ACCESS_W)
457 os2Flags |= OPEN_FLAGS_RANDOM;
458 if(dwFlags & FILE_FLAG_SEQUENTIAL_SCAN_W)
459 os2Flags |= OPEN_FLAGS_SEQUENTIAL;
460
461 // TODO:
462 // if(dwFlags & FILE_FLAG_OVERLAPPED_W)
463 // if(dwFlags & FILE_FLAG_DELETE_ON_CLOSE_W
464
465 rc = DosOpen(lpFileName, &hFile, &ulAction, 0,
466 os2Attrib, os2Open, os2Flags, 0);
467
468 if(rc)
469 {
470 // TODO: TEST TEST
471 dprintf(("DosOpen Error rc:%d, try without GENERIC_WRITE_W", rc));
472 if(dwAccess & GENERIC_WRITE_W)
473 os2Flags &= ~(OPEN_ACCESS_READWRITE | OPEN_ACCESS_WRITEONLY);
474 rc = DosOpen(lpFileName, &hFile, &ulAction, 0,
475 os2Attrib, os2Open, os2Flags, 0);
476 if(rc)
477 {
478 dprintf(("DosOpen Error rc:%d os2Attrib:%X os2Open:%X os2Flags:%X",
479 rc, os2Attrib, os2Open, os2Flags));
480 hFile = -1;
481 }
482 }
483
484 *dwFile = hFile;
485 return rc;
486}
487//******************************************************************************
488//(without changing file pointer)
489//******************************************************************************
490DWORD OSLibDosGetFileSize(DWORD hFile)
491{
492 FILESTATUS3 fsts3ConfigInfo = {{0}};
493 ULONG ulBufSize = sizeof(FILESTATUS3);
494
495 DosQueryFileInfo(hFile, FIL_STANDARD, &fsts3ConfigInfo, ulBufSize);
496 return fsts3ConfigInfo.cbFile;
497}
498//******************************************************************************
499//******************************************************************************
500DWORD OSLibDosSetFilePtr2(DWORD hFile, DWORD offset, DWORD method)
501{
502 DWORD newoffset;
503 APIRET rc;
504
505
506 rc = DosSetFilePtr(hFile, offset, method, &newoffset);
507 if(rc) {
508 dprintf(("DosSetFilePtr Error rc:%d", rc));
509 return -1;
510 }
511 else return newoffset;
512}
513//******************************************************************************
514//(FlushBuffer)
515//******************************************************************************
516DWORD OSLibDosResetBuffer(DWORD hFile)
517{
518 return DosResetBuffer(hFile);
519}
520//******************************************************************************
521//******************************************************************************
522DWORD OSLibDosDupHandle(DWORD hFile, DWORD *hNew)
523{
524 *hNew = -1;
525 return DosDupHandle(hFile, hNew);
526}
527//******************************************************************************
528//******************************************************************************
529void OSLibDosDisableHardError(BOOL fTurnOff)
530{
531 DosError((fTurnOff) ? FERR_DISABLEHARDERR : FERR_ENABLEHARDERR);
532}
533//******************************************************************************
534//Returns time spent in kernel & user mode in milliseconds
535//******************************************************************************
536BOOL OSLibDosQueryProcTimes(DWORD procid, ULONG *kerneltime, ULONG *usertime)
537{
538 APIRET rc;
539 char *buf;
540 ULONG size;
541 ULONG nrthreads = 4;
542
543tryagain:
544 size = sizeof(QTOPLEVEL)+sizeof(QGLOBAL)+sizeof(QPROCESS) + nrthreads*sizeof(QTHREAD);
545 buf = (char *)malloc(size);
546 rc = DosQuerySysState(0x1, RESERVED, procid, RESERVED, (PCHAR)buf, size);
547
548 if(rc) {
549 free(buf);
550 if(rc == ERROR_BUFFER_OVERFLOW) {
551 nrthreads += 4;
552 goto tryagain;
553 }
554 return FALSE;
555 }
556 PQTOPLEVEL top = (PQTOPLEVEL)buf;
557
558 *kerneltime = 0;
559 *usertime = 0;
560 for(int i=0;i<top->procdata->threadcnt;i++) {
561 *kerneltime += top->procdata->threads[i].systime;
562 *usertime += top->procdata->threads[i].usertime;
563 }
564 free(buf);
565 return TRUE;
566}
567//******************************************************************************
568//******************************************************************************
569// TODO: implement SecurityAttributes parameter
570DWORD OSLibDosCreateNamedPipe(LPCTSTR lpName,
571 DWORD dwOpenMode,
572 DWORD dwPipeMode,
573 DWORD nMaxInstances,
574 DWORD nOutBufferSize,
575 DWORD nInBufferSize,
576 DWORD nDefaultTimeOut,
577 void* lpSecurityAttributes)
578{ DWORD dwOS2Mode = 0;
579 DWORD dwOS2PipeMode = 0;
580 LPSTR lpOS2Name;
581 DWORD hPipe;
582 DWORD rc;
583
584 if (dwOpenMode & PIPE_ACCESS_DUPLEX_W)
585 dwOS2Mode |= NP_ACCESS_DUPLEX;
586 else
587 if (dwOpenMode & PIPE_ACCESS_INBOUND_W)
588 dwOS2Mode |= NP_ACCESS_INBOUND;
589 else
590 if (dwOpenMode & PIPE_ACCESS_OUTBOUND_W)
591 dwOS2Mode |= NP_ACCESS_OUTBOUND;
592 // TODO:
593 // if(dwOpenMode & FILE_FLAG_OVERLAPPED)
594 // if(dwOpenMode & WRITE_DAC)
595 // if(dwOpenMode & WRITE_OWNER)
596 // if(dwOpenMode & ACCESS_SYSTEM_SECURITY)
597 if(dwOpenMode & FILE_FLAG_WRITE_THROUGH_W)
598 dwOS2Mode |= NP_WRITEBEHIND; // FIXME: I'm not sure!
599
600 if (dwPipeMode & PIPE_WAIT_W)
601 dwOS2PipeMode |= NP_WAIT;
602 if (dwPipeMode & PIPE_NOWAIT_W)
603 dwOS2PipeMode |= NP_NOWAIT;
604 if (dwPipeMode & PIPE_READMODE_BYTE_W)
605 dwOS2PipeMode |= NP_READMODE_BYTE;
606 if (dwPipeMode & PIPE_READMODE_MESSAGE_W)
607 dwOS2PipeMode |= NP_READMODE_MESSAGE;
608 if (dwPipeMode & PIPE_TYPE_BYTE_W)
609 dwOS2PipeMode |= NP_TYPE_BYTE;
610 if (dwPipeMode & PIPE_TYPE_MESSAGE_W)
611 dwOS2PipeMode |= NP_TYPE_MESSAGE;
612
613 if (nMaxInstances>0xff)
614 {
615 SetLastError(87); // ERROR_INVALID_PARAMETER
616 return -1; // INVALID_HANDLE_VALUE
617 }
618 dwOS2PipeMode |= nMaxInstances;
619
620 // we must delete string \.\ because
621 // in Windows named pipes scheme is a \.\PIPE\pipename
622 // but in OS/2 only \PIPE\pipename
623 lpOS2Name = (LPSTR)lpName + 3;
624
625
626 dprintf(("DosCreateNPipe(%s,%x,%x,%x,%x,%x)",lpOS2Name,dwOS2Mode,dwOS2PipeMode,nInBufferSize,nOutBufferSize,nDefaultTimeOut));
627 rc=DosCreateNPipe(lpOS2Name,
628 &hPipe,
629 dwOS2Mode,
630 dwOS2PipeMode,
631 nInBufferSize,
632 nInBufferSize,
633 nDefaultTimeOut); // Timeouts must be tested!
634
635 dprintf(("DosCreateNPipe rc=%d",rc));
636 if (rc)
637 {
638 if ( rc == ERROR_PIPE_BUSY ) SetLastError(ERROR_PIPE_BUSY_W);
639 else
640 if ( rc == ERROR_PATH_NOT_FOUND ) SetLastError(ERROR_PATH_NOT_FOUND_W);
641 else
642 if ( rc == ERROR_NOT_ENOUGH_MEMORY ) SetLastError(ERROR_NOT_ENOUGH_MEMORY_W);
643 else
644 if ( rc == ERROR_INVALID_PARAMETER ) SetLastError(ERROR_INVALID_PARAMETER_W);
645 else
646 if ( rc == ERROR_OUT_OF_STRUCTURES ) SetLastError(ERROR_OUT_OF_STRUCTURES_W);
647 else
648 // Unknown error
649 SetLastError(ERROR_INVALID_PARAMETER_W); // fixme!
650 return -1; // INVALID_HANDLE_VALUE
651 }
652 return hPipe;
653}
654
655//******************************************************************************
656//******************************************************************************
657// TODO: implement lpOverlapped parameter!
658BOOL OSLibDosConnectNamedPipe(DWORD hNamedPipe, LPOVERLAPPED lpOverlapped)
659{
660 DWORD rc;
661
662 rc=DosConnectNPipe(hNamedPipe);
663 dprintf(("DosConnectNPipe rc=%d",rc));
664
665 if (!rc) return (TRUE);
666 else
667 if (rc==ERROR_BROKEN_PIPE) SetLastError(ERROR_BROKEN_PIPE_W);
668 else
669 if (rc==ERROR_BAD_PIPE) SetLastError(ERROR_BAD_PIPE_W);
670 else
671 if (rc==ERROR_PIPE_NOT_CONNECTED) SetLastError(ERROR_PIPE_NOT_CONNECTED_W);
672 else
673 // TODO: Implemnt this using Windows Errors
674 // if (rc==ERROR_INTERRUPT)
675 SetLastError(ERROR_PIPE_NOT_CONNECTED_W);
676
677 return (FALSE);
678}
679
680//******************************************************************************
681//******************************************************************************
682BOOL OSLibDosCallNamedPipe( LPCTSTR lpNamedPipeName,
683 LPVOID lpInBuffer,
684 DWORD nInBufferSize,
685 LPVOID lpOutBuffer,
686 DWORD nOutBufferSize,
687 LPDWORD lpBytesRead,
688 DWORD nTimeOut )
689{
690 LPSTR lpOS2Name;
691 DWORD rc;
692 // we must delete string \.\ because
693 // in Windows named pipes scheme is a \.\PIPE\pipename
694 // but in OS/2 only \PIPE\pipename
695 lpOS2Name = (LPSTR)lpNamedPipeName + 3;
696
697 rc=DosCallNPipe(lpOS2Name,
698 lpInBuffer,
699 nInBufferSize,
700 lpOutBuffer,
701 nOutBufferSize,
702 lpBytesRead,
703 nTimeOut );
704
705
706 if (!rc) return (TRUE);
707 else
708 if ( rc==ERROR_FILE_NOT_FOUND ) SetLastError(ERROR_FILE_NOT_FOUND_W);
709 else
710 if ( rc==ERROR_PATH_NOT_FOUND ) SetLastError(ERROR_PATH_NOT_FOUND_W);
711 else
712 if ( rc==ERROR_ACCESS_DENIED ) SetLastError(ERROR_ACCESS_DENIED_W);
713 else
714 if ( rc==ERROR_MORE_DATA ) SetLastError(ERROR_MORE_DATA_W);
715 else
716 if ( rc==ERROR_PIPE_BUSY ) SetLastError(ERROR_PIPE_BUSY_W);
717 else
718 if ( rc==ERROR_BAD_FORMAT ) SetLastError(ERROR_BAD_FORMAT_W);
719 else
720 if ( rc==ERROR_BROKEN_PIPE ) SetLastError(ERROR_BROKEN_PIPE_W);
721 else
722 if ( rc==ERROR_BAD_PIPE ) SetLastError(ERROR_BAD_PIPE_W);
723 else
724 if ( rc==ERROR_PIPE_NOT_CONNECTED ) SetLastError(ERROR_PIPE_NOT_CONNECTED_W);
725 else
726 // TODO: Implemnt this using Windows Errors
727 // if (rc==ERROR_INTERRUPT)
728 SetLastError(233);
729
730 return (FALSE);
731}
732
733//******************************************************************************
734//******************************************************************************
735BOOL OSLibDosTransactNamedPipe( DWORD hNamedPipe,
736 LPVOID lpInBuffer,
737 DWORD nInBufferSize,
738 LPVOID lpOutBuffer,
739 DWORD nOutBufferSize,
740 LPDWORD lpBytesRead,
741 LPOVERLAPPED lpOverlapped)
742{
743 DWORD rc;
744
745 rc=DosTransactNPipe(hNamedPipe,
746 lpOutBuffer,
747 nOutBufferSize,
748 lpInBuffer,
749 nInBufferSize,
750 lpBytesRead);
751
752 if (!rc) return (TRUE);
753 else
754 if ( rc==ERROR_ACCESS_DENIED ) SetLastError(ERROR_ACCESS_DENIED_W);
755 else
756 if ( rc==ERROR_MORE_DATA ) SetLastError(ERROR_MORE_DATA_W);
757 else
758 if ( rc==ERROR_PIPE_BUSY ) SetLastError(ERROR_PIPE_BUSY_W);
759 else
760 if ( rc==ERROR_BAD_FORMAT ) SetLastError(ERROR_BAD_FORMAT_W);
761 else
762 if ( rc==ERROR_BROKEN_PIPE ) SetLastError(ERROR_BROKEN_PIPE_W);
763 else
764 if ( rc==ERROR_BAD_PIPE ) SetLastError(ERROR_BAD_PIPE_W);
765 else
766 if ( rc==ERROR_PIPE_NOT_CONNECTED ) SetLastError(ERROR_PIPE_NOT_CONNECTED_W);
767 else
768 // Unknown error
769 SetLastError(ERROR_PIPE_NOT_CONNECTED_W);
770
771 return FALSE;
772}
Note: See TracBrowser for help on using the repository browser.