projects / reactos.git / blob
? search:
summary | shortlog | log | commit | commitdiff | tree
history | raw | HEAD
[CRT] Resort to partially syncing msvcrt_flush_buffer() in order to fix some test...
[reactos.git] / reactos / sdk / lib / crt / stdio / file.c
1 /*
2 * PROJECT: ReactOS CRT library
3 * LICENSE: LGPL - See COPYING in the top level directory
4 * FILE: lib/sdk/crt/stdio/file.c
5 * PURPOSE: File CRT functions
6 * PROGRAMMERS: Wine team
7 * Ported to ReactOS by Aleksey Bragin (aleksey@reactos.org)
8 */
9
10 /*********************************************
11 * This file contains ReactOS changes!!
12 * Don't blindly sync it with Wine code!
13 *
14 * If you break Unicode output on the console again, please update this counter:
15 * int hours_wasted_on_this = 42;
16 *********************************************/
17
18 /*
19 * msvcrt.dll file functions
20 *
21 * Copyright 1996,1998 Marcus Meissner
22 * Copyright 1996 Jukka Iivonen
23 * Copyright 1997,2000 Uwe Bonnes
24 * Copyright 2000 Jon Griffiths
25 * Copyright 2004 Eric Pouech
26 * Copyright 2004 Juan Lang
27 *
28 * This library is free software; you can redistribute it and/or
29 * modify it under the terms of the GNU Lesser General Public
30 * License as published by the Free Software Foundation; either
31 * version 2.1 of the License, or (at your option) any later version.
32 *
33 * This library is distributed in the hope that it will be useful,
34 * but WITHOUT ANY WARRANTY; without even the implied warranty of
35 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
36 * Lesser General Public License for more details.
37 *
38 * You should have received a copy of the GNU Lesser General Public
39 * License along with this library; if not, write to the Free Software
40 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
41 *
42 * TODO
43 * Use the file flag hints O_SEQUENTIAL, O_RANDOM, O_SHORT_LIVED
44 */
45
46 #include <precomp.h>
47 #include "wine/unicode.h"
48
49 #include <sys/utime.h>
50 #include <direct.h>
51
52 int *__p__fmode(void);
53 int *__p___mb_cur_max(void);
54
55 extern int _commode;
56
57 #ifndef _IOCOMMIT
58 #define _IOCOMMIT 0x4000
59 #endif
60
61 #ifdef feof
62 #undef feof
63 #endif
64 #ifdef _fileno
65 #undef _fileno
66 #endif
67 #ifdef ferror
68 #undef ferror
69 #endif
70 #ifdef clearerr
71 #undef clearerr
72 #endif
73
74 #undef getc
75 #undef getwc
76 #undef getchar
77 #undef getwchar
78 #undef putc
79 #undef putwc
80 #undef putchar
81 #undef putwchar
82
83 #undef vprintf
84 #undef vwprintf
85
86 /* _access() bit flags FIXME: incomplete */
87 /* defined in crt/io.h */
88
89 /* values for wxflag in file descriptor */
90 #define WX_OPEN 0x01
91 #define WX_ATEOF 0x02
92 #define WX_READNL 0x04 /* read started with \n */
93 #define WX_READEOF 0x04 /* like ATEOF, but for underlying file rather than buffer */
94 #define WX_PIPE 0x08
95 #define WX_READCR 0x08 /* underlying file is at \r */
96 #define WX_DONTINHERIT 0x10
97 #define WX_APPEND 0x20
98 #define WX_TTY 0x40
99 #define WX_TEXT 0x80
100
101 /* values for exflag - it's used differently in msvcr90.dll*/
102 #define EF_UTF8 0x01
103 #define EF_UTF16 0x02
104 #define EF_UNK_UNICODE 0x08
105
106 static char utf8_bom[3] = { 0xef, 0xbb, 0xbf };
107 static char utf16_bom[2] = { 0xff, 0xfe };
108
109 /* FIXME: this should be allocated dynamically */
110 #define MAX_FILES 2048
111 #define FD_BLOCK_SIZE 64
112
113 #define MSVCRT_INTERNAL_BUFSIZ 4096
114
115 /* ioinfo structure size is different in msvcrXX.dll's */
116 typedef struct {
117 HANDLE handle;
118 unsigned char wxflag;
119 char lookahead[3];
120 int exflag;
121 CRITICAL_SECTION crit;
122 } ioinfo;
123
124 /*********************************************************************
125 * __pioinfo (MSVCRT.@)
126 * array of pointers to ioinfo arrays [64]
127 */
128 ioinfo * __pioinfo[MAX_FILES/FD_BLOCK_SIZE] = { 0 };
129
130 /*********************************************************************
131 * __badioinfo (MSVCRT.@)
132 */
133 ioinfo __badioinfo = { INVALID_HANDLE_VALUE, WX_TEXT };
134
135 static int fdstart = 3; /* first unallocated fd */
136 static int fdend = 3; /* highest allocated fd */
137
138 typedef struct {
139 FILE file;
140 CRITICAL_SECTION crit;
141 } file_crit;
142
143 FILE _iob[_IOB_ENTRIES] = { { 0 } };
144 static file_crit* MSVCRT_fstream[MAX_FILES/FD_BLOCK_SIZE] = { NULL };
145 static int MSVCRT_max_streams = 512, MSVCRT_stream_idx;
146
147 /* INTERNAL: process umask */
148 static int MSVCRT_umask = 0;
149
150 /* INTERNAL: static data for tmpnam and _wtmpname functions */
151 static int tmpnam_unique;
152
153 /* This critical section protects the tables __pioinfo and fstreams,
154 * and their related indexes, fdstart, fdend,
155 * and MSVCRT_stream_idx, from race conditions.
156 * It doesn't protect against race conditions manipulating the underlying files
157 * or flags; doing so would probably be better accomplished with per-file
158 * protection, rather than locking the whole table for every change.
159 */
160 static CRITICAL_SECTION MSVCRT_file_cs;
161 static CRITICAL_SECTION_DEBUG MSVCRT_file_cs_debug =
162 {
163 0, 0, &MSVCRT_file_cs,
164 { &MSVCRT_file_cs_debug.ProcessLocksList, &MSVCRT_file_cs_debug.ProcessLocksList },
165 0, 0, { (DWORD_PTR)(__FILE__ ": MSVCRT_file_cs") }
166 };
167 static CRITICAL_SECTION MSVCRT_file_cs = { &MSVCRT_file_cs_debug, -1, 0, 0, 0, 0 };
168 #define LOCK_FILES() do { EnterCriticalSection(&MSVCRT_file_cs); } while (0)
169 #define UNLOCK_FILES() do { LeaveCriticalSection(&MSVCRT_file_cs); } while (0)
170
171 static inline ioinfo* get_ioinfo_nolock(int fd)
172 {
173 ioinfo *ret = NULL;
174 if(fd>=0 && fd<MAX_FILES)
175 ret = __pioinfo[fd/FD_BLOCK_SIZE];
176 if(!ret)
177 return &__badioinfo;
178
179 return ret + (fd%FD_BLOCK_SIZE);
180 }
181
182 static inline ioinfo* get_ioinfo(int fd)
183 {
184 ioinfo *ret = NULL;
185 if(fd < MAX_FILES)
186 ret = __pioinfo[fd/FD_BLOCK_SIZE];
187 if(!ret)
188 return &__badioinfo;
189
190 return ret + (fd%FD_BLOCK_SIZE);
191 }
192
193 static inline FILE* msvcrt_get_file(int i)
194 {
195 file_crit *ret;
196
197 if(i >= MSVCRT_max_streams)
198 return NULL;
199
200 if(i < _IOB_ENTRIES)
201 return &_iob[i];
202
203 ret = MSVCRT_fstream[i/FD_BLOCK_SIZE];
204 if(!ret) {
205 MSVCRT_fstream[i/FD_BLOCK_SIZE] = calloc(FD_BLOCK_SIZE, sizeof(file_crit));
206 if(!MSVCRT_fstream[i/FD_BLOCK_SIZE]) {
207 ERR("out of memory\n");
208 *_errno() = ENOMEM;
209 return NULL;
210 }
211
212 ret = MSVCRT_fstream[i/FD_BLOCK_SIZE] + (i%FD_BLOCK_SIZE);
213 } else
214 ret += i%FD_BLOCK_SIZE;
215
216 return &ret->file;
217 }
218
219 static inline BOOL is_valid_fd(int fd)
220 {
221 return fd >= 0 && fd < fdend && (get_ioinfo(fd)->wxflag & WX_OPEN);
222 }
223
224 /* INTERNAL: Get the HANDLE for a fd
225 * This doesn't lock the table, because a failure will result in
226 * INVALID_HANDLE_VALUE being returned, which should be handled correctly. If
227 * it returns a valid handle which is about to be closed, a subsequent call
228 * will fail, most likely in a sane way.
229 */
230 /*static*/ HANDLE fdtoh(int fd)
231 {
232 if (!is_valid_fd(fd))
233 {
234 WARN(":fd (%d) - no handle!\n",fd);
235 *__doserrno() = 0;
236 *_errno() = EBADF;
237 return INVALID_HANDLE_VALUE;
238 }
239 //if (get_ioinfo(fd)->handle == INVALID_HANDLE_VALUE)
240 //FIXME("returning INVALID_HANDLE_VALUE for %d\n", fd);
241 return get_ioinfo(fd)->handle;
242 }
243
244 /* INTERNAL: free a file entry fd */
245 static void msvcrt_free_fd(int fd)
246 {
247 ioinfo *fdinfo;
248
249 LOCK_FILES();
250 fdinfo = get_ioinfo(fd);
251 if(fdinfo != &__badioinfo)
252 {
253 fdinfo->handle = INVALID_HANDLE_VALUE;
254 fdinfo->wxflag = 0;
255 }
256 TRACE(":fd (%d) freed\n",fd);
257
258 if (fd < 3)
259 {
260 switch (fd)
261 {
262 case 0:
263 SetStdHandle(STD_INPUT_HANDLE, 0);
264 break;
265 case 1:
266 SetStdHandle(STD_OUTPUT_HANDLE, 0);
267 break;
268 case 2:
269 SetStdHandle(STD_ERROR_HANDLE, 0);
270 break;
271 }
272 }
273
274 if (fd == fdend - 1)
275 fdend--;
276 if (fd < fdstart)
277 fdstart = fd;
278 UNLOCK_FILES();
279 }
280
281 /* INTERNAL: Allocate an fd slot from a Win32 HANDLE, starting from fd */
282 /* caller must hold the files lock */
283 static int msvcrt_set_fd(HANDLE hand, int flag, int fd)
284 {
285 ioinfo *fdinfo;
286
287 if (fd >= MAX_FILES)
288 {
289 WARN(":files exhausted!\n");
290 *_errno() = ENFILE;
291 return -1;
292 }
293
294 fdinfo = get_ioinfo(fd);
295 if(fdinfo == &__badioinfo) {
296 int i;
297
298 __pioinfo[fd/FD_BLOCK_SIZE] = calloc(FD_BLOCK_SIZE, sizeof(ioinfo));
299 if(!__pioinfo[fd/FD_BLOCK_SIZE]) {
300 WARN(":out of memory!\n");
301 *_errno() = ENOMEM;
302 return -1;
303 }
304
305 for(i=0; i<FD_BLOCK_SIZE; i++)
306 __pioinfo[fd/FD_BLOCK_SIZE][i].handle = INVALID_HANDLE_VALUE;
307
308 fdinfo = get_ioinfo(fd);
309 }
310
311 fdinfo->handle = hand;
312 fdinfo->wxflag = WX_OPEN | (flag & (WX_DONTINHERIT | WX_APPEND | WX_TEXT | WX_PIPE | WX_TTY));
313 fdinfo->lookahead[0] = '\n';
314 fdinfo->lookahead[1] = '\n';
315 fdinfo->lookahead[2] = '\n';
316 fdinfo->exflag = 0;
317
318 /* locate next free slot */
319 if (fd == fdstart && fd == fdend)
320 fdstart = fdend + 1;
321 else
322 while (fdstart < fdend &&
323 get_ioinfo(fdstart)->handle != INVALID_HANDLE_VALUE)
324 fdstart++;
325 /* update last fd in use */
326 if (fd >= fdend)
327 fdend = fd + 1;
328 TRACE("fdstart is %d, fdend is %d\n", fdstart, fdend);
329
330 switch (fd)
331 {
332 case 0: SetStdHandle(STD_INPUT_HANDLE, hand); break;
333 case 1: SetStdHandle(STD_OUTPUT_HANDLE, hand); break;
334 case 2: SetStdHandle(STD_ERROR_HANDLE, hand); break;
335 }
336
337 return fd;
338 }
339
340 /* INTERNAL: Allocate an fd slot from a Win32 HANDLE */
341 /*static*/ int msvcrt_alloc_fd(HANDLE hand, int flag)
342 {
343 int ret;
344
345 LOCK_FILES();
346 TRACE(":handle (%p) allocating fd (%d)\n",hand,fdstart);
347 ret = msvcrt_set_fd(hand, flag, fdstart);
348 UNLOCK_FILES();
349 return ret;
350 }
351
352 /* INTERNAL: Allocate a FILE* for an fd slot */
353 /* caller must hold the files lock */
354 static FILE* msvcrt_alloc_fp(void)
355 {
356 int i;
357 FILE *file;
358
359 for (i = 3; i < MSVCRT_max_streams; i++)
360 {
361 file = msvcrt_get_file(i);
362 if (!file)
363 return NULL;
364
365 if (file->_flag == 0)
366 {
367 if (i == MSVCRT_stream_idx) MSVCRT_stream_idx++;
368 return file;
369 }
370 }
371
372 return NULL;
373 }
374
375 /* INTERNAL: initialize a FILE* from an open fd */
376 static int msvcrt_init_fp(FILE* file, int fd, unsigned stream_flags)
377 {
378 TRACE(":fd (%d) allocating FILE*\n",fd);
379 if (!is_valid_fd(fd))
380 {
381 WARN(":invalid fd %d\n",fd);
382 *__doserrno() = 0;
383 *_errno() = EBADF;
384 return -1;
385 }
386 file->_ptr = file->_base = NULL;
387 file->_cnt = 0;
388 file->_file = fd;
389 file->_flag = stream_flags;
390 file->_tmpfname = NULL;
391
392 if(file<_iob || file>=_iob+_IOB_ENTRIES)
393 InitializeCriticalSection(&((file_crit*)file)->crit);
394
395 TRACE(":got FILE* (%p)\n",file);
396 return 0;
397 }
398
399 /* INTERNAL: Create an inheritance data block (for spawned process)
400 * The inheritance block is made of:
401 * 00 int nb of file descriptor (NBFD)
402 * 04 char file flags (wxflag): repeated for each fd
403 * 4+NBFD HANDLE file handle: repeated for each fd
404 */
405 unsigned create_io_inherit_block(WORD *size, BYTE **block)
406 {
407 int fd;
408 char* wxflag_ptr;
409 HANDLE* handle_ptr;
410 ioinfo* fdinfo;
411
412 *size = sizeof(unsigned) + (sizeof(char) + sizeof(HANDLE)) * fdend;
413 *block = calloc(1, *size);
414 if (!*block)
415 {
416 *size = 0;
417 return FALSE;
418 }
419 wxflag_ptr = (char*)*block + sizeof(unsigned);
420 handle_ptr = (HANDLE*)(wxflag_ptr + fdend * sizeof(char));
421
422 *(unsigned*)*block = fdend;
423 for (fd = 0; fd < fdend; fd++)
424 {
425 /* to be inherited, we need it to be open, and that DONTINHERIT isn't set */
426 fdinfo = get_ioinfo(fd);
427 if ((fdinfo->wxflag & (WX_OPEN | WX_DONTINHERIT)) == WX_OPEN)
428 {
429 *wxflag_ptr = fdinfo->wxflag;
430 *handle_ptr = fdinfo->handle;
431 }
432 else
433 {
434 *wxflag_ptr = 0;
435 *handle_ptr = INVALID_HANDLE_VALUE;
436 }
437 wxflag_ptr++; handle_ptr++;
438 }
439 return TRUE;
440 }
441
442 /* INTERNAL: Set up all file descriptors,
443 * as well as default streams (stdin, stderr and stdout)
444 */
445 void msvcrt_init_io(void)
446 {
447 STARTUPINFOA si;
448 unsigned int i;
449 ioinfo *fdinfo;
450
451 GetStartupInfoA(&si);
452 if (si.cbReserved2 >= sizeof(unsigned int) && si.lpReserved2 != NULL)
453 {
454 BYTE* wxflag_ptr;
455 HANDLE* handle_ptr;
456 unsigned int count;
457
458 count = *(unsigned*)si.lpReserved2;
459 wxflag_ptr = si.lpReserved2 + sizeof(unsigned);
460 handle_ptr = (HANDLE*)(wxflag_ptr + count);
461
462 count = min(count, (si.cbReserved2 - sizeof(unsigned)) / (sizeof(HANDLE) + 1));
463 count = min(count, MAX_FILES);
464 for (i = 0; i < count; i++)
465 {
466 if ((*wxflag_ptr & WX_OPEN) && *handle_ptr != INVALID_HANDLE_VALUE)
467 msvcrt_set_fd(*handle_ptr, *wxflag_ptr, i);
468
469 wxflag_ptr++; handle_ptr++;
470 }
471 fdend = max( 3, count );
472 for (fdstart = 3; fdstart < fdend; fdstart++)
473 if (get_ioinfo(fdstart)->handle == INVALID_HANDLE_VALUE) break;
474 }
475
476 fdinfo = get_ioinfo(STDIN_FILENO);
477 if (!(fdinfo->wxflag & WX_OPEN) || fdinfo->handle == INVALID_HANDLE_VALUE) {
478 HANDLE h = GetStdHandle(STD_INPUT_HANDLE);
479 DWORD type = GetFileType(h);
480
481 msvcrt_set_fd(h, WX_OPEN|WX_TEXT|((type&0xf)==FILE_TYPE_CHAR ? WX_TTY : 0)
482 |((type&0xf)==FILE_TYPE_PIPE ? WX_PIPE : 0), STDIN_FILENO);
483 }
484
485 fdinfo = get_ioinfo(STDOUT_FILENO);
486 if (!(fdinfo->wxflag & WX_OPEN) || fdinfo->handle == INVALID_HANDLE_VALUE) {
487 HANDLE h = GetStdHandle(STD_OUTPUT_HANDLE);
488 DWORD type = GetFileType(h);
489
490 msvcrt_set_fd(h, WX_OPEN|WX_TEXT|((type&0xf)==FILE_TYPE_CHAR ? WX_TTY : 0)
491 |((type&0xf)==FILE_TYPE_PIPE ? WX_PIPE : 0), STDOUT_FILENO);
492 }
493
494 fdinfo = get_ioinfo(STDERR_FILENO);
495 if (!(fdinfo->wxflag & WX_OPEN) || fdinfo->handle == INVALID_HANDLE_VALUE) {
496 HANDLE h = GetStdHandle(STD_ERROR_HANDLE);
497 DWORD type = GetFileType(h);
498
499 msvcrt_set_fd(h, WX_OPEN|WX_TEXT|((type&0xf)==FILE_TYPE_CHAR ? WX_TTY : 0)
500 |((type&0xf)==FILE_TYPE_PIPE ? WX_PIPE : 0), STDERR_FILENO);
501 }
502
503 TRACE(":handles (%p)(%p)(%p)\n", get_ioinfo(STDIN_FILENO)->handle,
504 get_ioinfo(STDOUT_FILENO)->handle,
505 get_ioinfo(STDERR_FILENO)->handle);
506
507 memset(_iob,0,3*sizeof(FILE));
508 for (i = 0; i < 3; i++)
509 {
510 /* FILE structs for stdin/out/err are static and never deleted */
511 _iob[i]._file = i;
512 _iob[i]._tmpfname = NULL;
513 _iob[i]._flag = (i == 0) ? _IOREAD : _IOWRT;
514 }
515 MSVCRT_stream_idx = 3;
516 }
517
518 /* INTERNAL: Flush stdio file buffer */
519 static int msvcrt_flush_buffer(FILE* file)
520 {
521 if((file->_flag & (_IOREAD|_IOWRT)) == _IOWRT &&
522 file->_flag & (_IOMYBUF|_USERBUF)) {
523 int cnt=file->_ptr-file->_base;
524 if(cnt>0 && _write(file->_file, file->_base, cnt) != cnt) {
525 file->_flag |= _IOERR;
526 return EOF;
527 }
528
529 if(file->_flag & _IORW)
530 file->_flag &= ~_IOWRT;
531
532 #ifdef __REACTOS__ /* CORE-11949 */
533 file->_ptr=file->_base;
534 file->_cnt=0;
535 #endif
536 }
537
538 #ifndef __REACTOS__ /* CORE-11949 */
539 file->_ptr=file->_base;
540 file->_cnt=0;
541 #endif
542 return 0;
543 }
544
545 /*********************************************************************
546 * _isatty (MSVCRT.@)
547 */
548 int CDECL _isatty(int fd)
549 {
550 TRACE(":fd (%d)\n",fd);
551
552 return get_ioinfo_nolock(fd)->wxflag & WX_TTY;
553 }
554
555 /* INTERNAL: Allocate stdio file buffer */
556 /*static*/ BOOL alloc_buffer(FILE* file)
557 {
558 if((file->_file==STDOUT_FILENO || file->_file==STDERR_FILENO)
559 && _isatty(file->_file))
560 return FALSE;
561
562 file->_base = calloc(1, MSVCRT_INTERNAL_BUFSIZ);
563 if(file->_base) {
564 file->_bufsiz = MSVCRT_INTERNAL_BUFSIZ;
565 file->_flag |= _IOMYBUF;
566 } else {
567 file->_base = (char*)(&file->_charbuf);
568 file->_bufsiz = 2;
569 file->_flag |= _IONBF;
570 }
571 file->_ptr = file->_base;
572 file->_cnt = 0;
573 return TRUE;
574 }
575
576 /* INTERNAL: Allocate temporary buffer for stdout and stderr */
577 static BOOL add_std_buffer(FILE *file)
578 {
579 static char buffers[2][BUFSIZ];
580
581 if((file->_file!=STDOUT_FILENO && file->_file!=STDERR_FILENO)
582 || (file->_flag & (_IONBF | _IOMYBUF | _USERBUF))
583 || !_isatty(file->_file))
584 return FALSE;
585
586 file->_ptr = file->_base = buffers[file->_file == STDOUT_FILENO ? 0 : 1];
587 file->_bufsiz = file->_cnt = BUFSIZ;
588 file->_flag |= _USERBUF;
589 return TRUE;
590 }
591
592 /* INTERNAL: Removes temporary buffer from stdout or stderr */
593 /* Only call this function when add_std_buffer returned TRUE */
594 static void remove_std_buffer(FILE *file)
595 {
596 msvcrt_flush_buffer(file);
597 file->_ptr = file->_base = NULL;
598 file->_bufsiz = file->_cnt = 0;
599 file->_flag &= ~_USERBUF;
600 }
601
602 /* INTERNAL: Convert integer to base32 string (0-9a-v), 0 becomes "" */
603 static int msvcrt_int_to_base32(int num, char *str)
604 {
605 char *p;
606 int n = num;
607 int digits = 0;
608
609 while (n != 0)
610 {
611 n >>= 5;
612 digits++;
613 }
614 p = str + digits;
615 *p = 0;
616 while (--p >= str)
617 {
618 *p = (num & 31) + '0';
619 if (*p > '9')
620 *p += ('a' - '0' - 10);
621 num >>= 5;
622 }
623
624 return digits;
625 }
626
627 /* INTERNAL: wide character version of msvcrt_int_to_base32 */
628 static int msvcrt_int_to_base32_w(int num, wchar_t *str)
629 {
630 wchar_t *p;
631 int n = num;
632 int digits = 0;
633
634 while (n != 0)
635 {
636 n >>= 5;
637 digits++;
638 }
639 p = str + digits;
640 *p = 0;
641 while (--p >= str)
642 {
643 *p = (num & 31) + '0';
644 if (*p > '9')
645 *p += ('a' - '0' - 10);
646 num >>= 5;
647 }
648
649 return digits;
650 }
651
652 /* INTERNAL: Create a wide string from an ascii string */
653 wchar_t *msvcrt_wstrdupa(const char *str)
654 {
655 const unsigned int len = strlen(str) + 1 ;
656 wchar_t *wstr = malloc(len* sizeof (wchar_t));
657 if (!wstr)
658 return NULL;
659 MultiByteToWideChar(CP_ACP, MB_PRECOMPOSED,str,len,wstr,len);
660 return wstr;
661 }
662
663 /*********************************************************************
664 * __iob_func(MSVCRT.@)
665 */
666 FILE * CDECL __iob_func(void)
667 {
668 return &_iob[0];
669 }
670
671 /*********************************************************************
672 * _access (MSVCRT.@)
673 */
674 int CDECL _access(const char *filename, int mode)
675 {
676 DWORD attr = GetFileAttributesA(filename);
677
678 TRACE("(%s,%d) %d\n",filename,mode,attr);
679
680 if (!filename || attr == INVALID_FILE_ATTRIBUTES)
681 {
682 _dosmaperr(GetLastError());
683 return -1;
684 }
685 if ((attr & FILE_ATTRIBUTE_READONLY) && (mode & W_OK))
686 {
687 _set_errno(ERROR_ACCESS_DENIED);
688 return -1;
689 }
690 return 0;
691 }
692
693 /*********************************************************************
694 * _access_s (MSVCRT.@)
695 */
696 int CDECL _access_s(const char *filename, int mode)
697 {
698 if (!MSVCRT_CHECK_PMT(filename != NULL) ||
699 !MSVCRT_CHECK_PMT((mode & ~(R_OK | W_OK)) == 0))
700 {
701 _set_errno(EINVAL);
702 return -1;
703 }
704
705 return _access(filename, mode);
706 }
707
708 /*********************************************************************
709 * _waccess (MSVCRT.@)
710 */
711 int CDECL _waccess(const wchar_t *filename, int mode)
712 {
713 DWORD attr = GetFileAttributesW(filename);
714
715 TRACE("(%s,%d) %d\n",debugstr_w(filename),mode,attr);
716
717 if (!filename || attr == INVALID_FILE_ATTRIBUTES)
718 {
719 _dosmaperr(GetLastError());
720 return -1;
721 }
722 if ((attr & FILE_ATTRIBUTE_READONLY) && (mode & W_OK))
723 {
724 _set_errno(ERROR_ACCESS_DENIED);
725 return -1;
726 }
727 return 0;
728 }
729
730 /*********************************************************************
731 * _waccess_s (MSVCRT.@)
732 */
733 int CDECL _waccess_s(const wchar_t *filename, int mode)
734 {
735 if (!MSVCRT_CHECK_PMT(filename != NULL) ||
736 !MSVCRT_CHECK_PMT((mode & ~(R_OK | W_OK)) == 0))
737 {
738 *_errno() = EINVAL;
739 return -1;
740 }
741
742 return _waccess(filename, mode);
743 }
744
745 /*********************************************************************
746 * _chmod (MSVCRT.@)
747 */
748 int CDECL _chmod(const char *path, int flags)
749 {
750 DWORD oldFlags = GetFileAttributesA(path);
751
752 if (oldFlags != INVALID_FILE_ATTRIBUTES)
753 {
754 DWORD newFlags = (flags & _S_IWRITE)? oldFlags & ~FILE_ATTRIBUTE_READONLY:
755 oldFlags | FILE_ATTRIBUTE_READONLY;
756
757 if (newFlags == oldFlags || SetFileAttributesA(path, newFlags))
758 return 0;
759 }
760 _dosmaperr(GetLastError());
761 return -1;
762 }
763
764 /*********************************************************************
765 * _wchmod (MSVCRT.@)
766 */
767 int CDECL _wchmod(const wchar_t *path, int flags)
768 {
769 DWORD oldFlags = GetFileAttributesW(path);
770
771 if (oldFlags != INVALID_FILE_ATTRIBUTES)
772 {
773 DWORD newFlags = (flags & _S_IWRITE)? oldFlags & ~FILE_ATTRIBUTE_READONLY:
774 oldFlags | FILE_ATTRIBUTE_READONLY;
775
776 if (newFlags == oldFlags || SetFileAttributesW(path, newFlags))
777 return 0;
778 }
779 _dosmaperr(GetLastError());
780 return -1;
781 }
782
783 /*********************************************************************
784 * _unlink (MSVCRT.@)
785 */
786 int CDECL _unlink(const char *path)
787 {
788 TRACE("%s\n",debugstr_a(path));
789 if(DeleteFileA(path))
790 return 0;
791 TRACE("failed (%d)\n",GetLastError());
792 _dosmaperr(GetLastError());
793 return -1;
794 }
795
796 /*********************************************************************
797 * _wunlink (MSVCRT.@)
798 */
799 int CDECL _wunlink(const wchar_t *path)
800 {
801 TRACE("(%s)\n",debugstr_w(path));
802 if(DeleteFileW(path))
803 return 0;
804 TRACE("failed (%d)\n",GetLastError());
805 _dosmaperr(GetLastError());
806 return -1;
807 }
808
809 /*********************************************************************
810 * _commit (MSVCRT.@)
811 */
812 int CDECL _commit(int fd)
813 {
814 HANDLE hand = fdtoh(fd);
815
816 TRACE(":fd (%d) handle (%p)\n",fd,hand);
817 if (hand == INVALID_HANDLE_VALUE)
818 return -1;
819
820 if (!FlushFileBuffers(hand))
821 {
822 if (GetLastError() == ERROR_INVALID_HANDLE)
823 {
824 /* FlushFileBuffers fails for console handles
825 * so we ignore this error.
826 */
827 return 0;
828 }
829 TRACE(":failed-last error (%d)\n",GetLastError());
830 _dosmaperr(GetLastError());
831 return -1;
832 }
833 TRACE(":ok\n");
834 return 0;
835 }
836
837 /* _flushall calls fflush which calls _flushall */
838 int CDECL fflush(FILE* file);
839
840 /* INTERNAL: Flush all stream buffer */
841 static int msvcrt_flush_all_buffers(int mask)
842 {
843 int i, num_flushed = 0;
844 FILE *file;
845
846 LOCK_FILES();
847 for (i = 0; i < MSVCRT_stream_idx; i++) {
848 file = msvcrt_get_file(i);
849
850 if (file->_flag)
851 {
852 if(file->_flag & mask) {
853 fflush(file);
854 num_flushed++;
855 }
856 }
857 }
858 UNLOCK_FILES();
859
860 TRACE(":flushed (%d) handles\n",num_flushed);
861 return num_flushed;
862 }
863
864 /*********************************************************************
865 * _flushall (MSVCRT.@)
866 */
867 int CDECL _flushall(void)
868 {
869 return msvcrt_flush_all_buffers(_IOWRT | _IOREAD);
870 }
871
872 /*********************************************************************
873 * fflush (MSVCRT.@)
874 */
875 int CDECL fflush(FILE* file)
876 {
877 if(!file) {
878 msvcrt_flush_all_buffers(_IOWRT);
879 } else if(file->_flag & _IOWRT) {
880 int res;
881
882 _lock_file(file);
883 res = msvcrt_flush_buffer(file);
884 /* FIXME
885 if(!res && (file->_flag & _IOCOMMIT))
886 res = _commit(file->_file) ? EOF : 0;
887 */
888 _unlock_file(file);
889
890 return res;
891 } else if(file->_flag & _IOREAD) {
892 _lock_file(file);
893 file->_cnt = 0;
894 file->_ptr = file->_base;
895 _unlock_file(file);
896
897 return 0;
898 }
899 return 0;
900 }
901
902 /*********************************************************************
903 * _close (MSVCRT.@)
904 */
905 int CDECL _close(int fd)
906 {
907 HANDLE hand;
908 int ret;
909
910 LOCK_FILES();
911 hand = fdtoh(fd);
912 TRACE(":fd (%d) handle (%p)\n",fd,hand);
913 if (hand == INVALID_HANDLE_VALUE)
914 ret = -1;
915 else if (!CloseHandle(hand))
916 {
917 WARN(":failed-last error (%d)\n",GetLastError());
918 _dosmaperr(GetLastError());
919 ret = -1;
920 }
921 else
922 {
923 msvcrt_free_fd(fd);
924 ret = 0;
925 }
926 UNLOCK_FILES();
927 TRACE(":ok\n");
928 return ret;
929 }
930
931 /*********************************************************************
932 * _dup2 (MSVCRT.@)
933 * NOTES
934 * MSDN isn't clear on this point, but the remarks for _pipe
935 * indicate file descriptors duplicated with _dup and _dup2 are always
936 * inheritable.
937 */
938 int CDECL _dup2(int od, int nd)
939 {
940 int ret;
941
942 TRACE("(od=%d, nd=%d)\n", od, nd);
943 LOCK_FILES();
944 if (nd < MAX_FILES && nd >= 0 && is_valid_fd(od))
945 {
946 HANDLE handle;
947
948 if (DuplicateHandle(GetCurrentProcess(), get_ioinfo(od)->handle,
949 GetCurrentProcess(), &handle, 0, TRUE, DUPLICATE_SAME_ACCESS))
950 {
951 int wxflag = get_ioinfo(od)->wxflag & ~_O_NOINHERIT;
952
953 if (is_valid_fd(nd))
954 _close(nd);
955 ret = msvcrt_set_fd(handle, wxflag, nd);
956 if (ret == -1)
957 {
958 CloseHandle(handle);
959 *_errno() = EMFILE;
960 }
961 else
962 {
963 /* _dup2 returns 0, not nd, on success */
964 ret = 0;
965 }
966 }
967 else
968 {
969 ret = -1;
970 _dosmaperr(GetLastError());
971 }
972 }
973 else
974 {
975 *_errno() = EBADF;
976 ret = -1;
977 }
978 UNLOCK_FILES();
979 return ret;
980 }
981
982 /*********************************************************************
983 * _dup (MSVCRT.@)
984 */
985 int CDECL _dup(int od)
986 {
987 int fd, ret;
988
989 LOCK_FILES();
990 fd = fdstart;
991 if (_dup2(od, fd) == 0)
992 ret = fd;
993 else
994 ret = -1;
995 UNLOCK_FILES();
996 return ret;
997 }
998
999 /*********************************************************************
1000 * _eof (MSVCRT.@)
1001 */
1002 int CDECL _eof(int fd)
1003 {
1004 DWORD curpos,endpos;
1005 LONG hcurpos,hendpos;
1006 HANDLE hand = fdtoh(fd);
1007
1008 TRACE(":fd (%d) handle (%p)\n",fd,hand);
1009
1010 if (hand == INVALID_HANDLE_VALUE)
1011 return -1;
1012
1013 if (get_ioinfo(fd)->wxflag & WX_ATEOF) return TRUE;
1014
1015 /* Otherwise we do it the hard way */
1016 hcurpos = hendpos = 0;
1017 curpos = SetFilePointer(hand, 0, &hcurpos, FILE_CURRENT);
1018 endpos = SetFilePointer(hand, 0, &hendpos, FILE_END);
1019
1020 if (curpos == endpos && hcurpos == hendpos)
1021 {
1022 /* FIXME: shouldn't WX_ATEOF be set here? */
1023 return TRUE;
1024 }
1025
1026 SetFilePointer(hand, curpos, &hcurpos, FILE_BEGIN);
1027 return FALSE;
1028 }
1029
1030 /*********************************************************************
1031 * _fcloseall (MSVCRT.@)
1032 */
1033 int CDECL _fcloseall(void)
1034 {
1035 int num_closed = 0, i;
1036 FILE *file;
1037
1038 LOCK_FILES();
1039 for (i = 3; i < MSVCRT_stream_idx; i++) {
1040 file = msvcrt_get_file(i);
1041
1042 if (file->_flag && !fclose(file))
1043 num_closed++;
1044 }
1045 UNLOCK_FILES();
1046
1047 TRACE(":closed (%d) handles\n",num_closed);
1048 return num_closed;
1049 }
1050
1051 /* free everything on process exit */
1052 void msvcrt_free_io(void)
1053 {
1054 unsigned int i;
1055 int j;
1056
1057 _flushall();
1058 _fcloseall();
1059
1060 for(i=0; i<sizeof(__pioinfo)/sizeof(__pioinfo[0]); i++)
1061 free(__pioinfo[i]);
1062
1063 for(j=0; j<MSVCRT_stream_idx; j++)
1064 {
1065 FILE *file = msvcrt_get_file(j);
1066 if(file<_iob || file>=_iob+_IOB_ENTRIES)
1067 {
1068 ((file_crit*)file)->crit.DebugInfo->Spare[0] = 0;
1069 DeleteCriticalSection(&((file_crit*)file)->crit);
1070 }
1071 }
1072
1073 for(i=0; i<sizeof(MSVCRT_fstream)/sizeof(MSVCRT_fstream[0]); i++)
1074 free(MSVCRT_fstream[i]);
1075 }
1076
1077 /*********************************************************************
1078 * _lseeki64 (MSVCRT.@)
1079 */
1080 __int64 CDECL _lseeki64(int fd, __int64 offset, int whence)
1081 {
1082 HANDLE hand = fdtoh(fd);
1083 LARGE_INTEGER ofs;
1084
1085 TRACE(":fd (%d) handle (%p)\n",fd,hand);
1086 if (hand == INVALID_HANDLE_VALUE)
1087 return -1;
1088
1089 if (whence < 0 || whence > 2)
1090 {
1091 *_errno() = EINVAL;
1092 return -1;
1093 }
1094
1095 TRACE(":fd (%d) to %s pos %s\n",
1096 fd,wine_dbgstr_longlong(offset),
1097 (whence==SEEK_SET)?"SEEK_SET":
1098 (whence==SEEK_CUR)?"SEEK_CUR":
1099 (whence==SEEK_END)?"SEEK_END":"UNKNOWN");
1100
1101 /* The MoleBox protection scheme expects msvcrt to use SetFilePointer only,
1102 * so a LARGE_INTEGER offset cannot be passed directly via SetFilePointerEx. */
1103 ofs.QuadPart = offset;
1104 if ((ofs.u.LowPart = SetFilePointer(hand, ofs.u.LowPart, &ofs.u.HighPart, whence)) != INVALID_SET_FILE_POINTER ||
1105 GetLastError() == ERROR_SUCCESS)
1106 {
1107 get_ioinfo(fd)->wxflag &= ~(WX_ATEOF|WX_READEOF);
1108 /* FIXME: What if we seek _to_ EOF - is EOF set? */
1109
1110 return ofs.QuadPart;
1111 }
1112 TRACE(":error-last error (%d)\n",GetLastError());
1113 _dosmaperr(GetLastError());
1114 return -1;
1115 }
1116
1117 /*********************************************************************
1118 * _lseek (MSVCRT.@)
1119 */
1120 LONG CDECL _lseek(int fd, LONG offset, int whence)
1121 {
1122 return (LONG)_lseeki64(fd, offset, whence);
1123 }
1124
1125 /*********************************************************************
1126 * _lock_file (MSVCRT.@)
1127 */
1128 void CDECL _lock_file(FILE *file)
1129 {
1130 if(file>=_iob && file<_iob+_IOB_ENTRIES)
1131 _lock(_STREAM_LOCKS+(file-_iob));
1132 /* ReactOS: string streams dont need to be locked */
1133 else if(!(file->_flag & _IOSTRG))
1134 EnterCriticalSection(&((file_crit*)file)->crit);
1135 }
1136
1137 /*********************************************************************
1138 * _unlock_file (MSVCRT.@)
1139 */
1140 void CDECL _unlock_file(FILE *file)
1141 {
1142 if(file>=_iob && file<_iob+_IOB_ENTRIES)
1143 _unlock(_STREAM_LOCKS+(file-_iob));
1144 /* ReactOS: string streams dont need to be locked */
1145 else if(!(file->_flag & _IOSTRG))
1146 LeaveCriticalSection(&((file_crit*)file)->crit);
1147
1148 }
1149
1150 /*********************************************************************
1151 * _locking (MSVCRT.@)
1152 *
1153 * This is untested; the underlying LockFile doesn't work yet.
1154 */
1155 int CDECL _locking(int fd, int mode, LONG nbytes)
1156 {
1157 BOOL ret;
1158 DWORD cur_locn;
1159 HANDLE hand = fdtoh(fd);
1160
1161 TRACE(":fd (%d) handle (%p)\n",fd,hand);
1162 if (hand == INVALID_HANDLE_VALUE)
1163 return -1;
1164
1165 if (mode < 0 || mode > 4)
1166 {
1167 *_errno() = EINVAL;
1168 return -1;
1169 }
1170
1171 TRACE(":fd (%d) by 0x%08x mode %s\n",
1172 fd,nbytes,(mode==_LK_UNLCK)?"_LK_UNLCK":
1173 (mode==_LK_LOCK)?"_LK_LOCK":
1174 (mode==_LK_NBLCK)?"_LK_NBLCK":
1175 (mode==_LK_RLCK)?"_LK_RLCK":
1176 (mode==_LK_NBRLCK)?"_LK_NBRLCK":
1177 "UNKNOWN");
1178
1179 if ((cur_locn = SetFilePointer(hand, 0L, NULL, SEEK_CUR)) == INVALID_SET_FILE_POINTER)
1180 {
1181 FIXME ("Seek failed\n");
1182 *_errno() = EINVAL; /* FIXME */
1183 return -1;
1184 }
1185 if (mode == _LK_LOCK || mode == _LK_RLCK)
1186 {
1187 int nretry = 10;
1188 ret = 1; /* just to satisfy gcc */
1189 while (nretry--)
1190 {
1191 ret = LockFile(hand, cur_locn, 0L, nbytes, 0L);
1192 if (ret) break;
1193 Sleep(1);
1194 }
1195 }
1196 else if (mode == _LK_UNLCK)
1197 ret = UnlockFile(hand, cur_locn, 0L, nbytes, 0L);
1198 else
1199 ret = LockFile(hand, cur_locn, 0L, nbytes, 0L);
1200 /* FIXME - what about error settings? */
1201 return ret ? 0 : -1;
1202 }
1203
1204 /*********************************************************************
1205 * _fseeki64 (MSVCRT.@)
1206 */
1207 int CDECL _fseeki64(FILE* file, __int64 offset, int whence)
1208 {
1209 int ret;
1210
1211 _lock_file(file);
1212 /* Flush output if needed */
1213 if(file->_flag & _IOWRT)
1214 msvcrt_flush_buffer(file);
1215
1216 if(whence == SEEK_CUR && file->_flag & _IOREAD ) {
1217 whence = SEEK_SET;
1218 offset += _ftelli64(file);
1219 }
1220
1221 /* Discard buffered input */
1222 file->_cnt = 0;
1223 file->_ptr = file->_base;
1224 /* Reset direction of i/o */
1225 if(file->_flag & _IORW) {
1226 file->_flag &= ~(_IOREAD|_IOWRT);
1227 }
1228 /* Clear end of file flag */
1229 file->_flag &= ~_IOEOF;
1230 ret = (_lseeki64(file->_file,offset,whence) == -1)?-1:0;
1231
1232 _unlock_file(file);
1233 return ret;
1234 }
1235
1236 /*********************************************************************
1237 * fseek (MSVCRT.@)
1238 */
1239 int CDECL fseek(FILE* file, long offset, int whence)
1240 {
1241 return _fseeki64( file, offset, whence );
1242 }
1243
1244 /*********************************************************************
1245 * _chsize_s (MSVCRT.@)
1246 */
1247 int CDECL _chsize_s(int fd, __int64 size)
1248 {
1249 __int64 cur, pos;
1250 HANDLE handle;
1251 BOOL ret = FALSE;
1252
1253 TRACE("(fd=%d, size=%s)\n", fd, wine_dbgstr_longlong(size));
1254
1255 if (!MSVCRT_CHECK_PMT(size >= 0)) return EINVAL;
1256
1257 LOCK_FILES();
1258
1259 handle = fdtoh(fd);
1260 if (handle != INVALID_HANDLE_VALUE)
1261 {
1262 /* save the current file pointer */
1263 cur = _lseeki64(fd, 0, SEEK_CUR);
1264 if (cur >= 0)
1265 {
1266 pos = _lseeki64(fd, size, SEEK_SET);
1267 if (pos >= 0)
1268 {
1269 ret = SetEndOfFile(handle);
1270 if (!ret) _dosmaperr(GetLastError());
1271 }
1272
1273 /* restore the file pointer */
1274 _lseeki64(fd, cur, SEEK_SET);
1275 }
1276 }
1277
1278 UNLOCK_FILES();
1279 return ret ? 0 : *_errno();
1280 }
1281
1282 /*********************************************************************
1283 * _chsize (MSVCRT.@)
1284 */
1285 int CDECL _chsize(int fd, long size)
1286 {
1287 /* _chsize_s returns errno on failure but _chsize should return -1 */
1288 return _chsize_s( fd, size ) == 0 ? 0 : -1;
1289 }
1290
1291 /*********************************************************************
1292 * clearerr (MSVCRT.@)
1293 */
1294 void CDECL clearerr(FILE* file)
1295 {
1296 TRACE(":file (%p) fd (%d)\n",file,file->_file);
1297
1298 _lock_file(file);
1299 file->_flag &= ~(_IOERR | _IOEOF);
1300 _unlock_file(file);
1301 }
1302
1303 /*********************************************************************
1304 * rewind (MSVCRT.@)
1305 */
1306 void CDECL rewind(FILE* file)
1307 {
1308 TRACE(":file (%p) fd (%d)\n",file,file->_file);
1309
1310 _lock_file(file);
1311 fseek(file, 0L, SEEK_SET);
1312 clearerr(file);
1313 _unlock_file(file);
1314 }
1315
1316 static int get_flags(const wchar_t* mode, int *open_flags, int* stream_flags)
1317 {
1318 int plus = strchrW(mode, '+') != NULL;
1319
1320 TRACE("%s\n", debugstr_w(mode));
1321
1322 while(*mode == ' ') mode++;
1323
1324 switch(*mode++)
1325 {
1326 case 'R': case 'r':
1327 *open_flags = plus ? _O_RDWR : _O_RDONLY;
1328 *stream_flags = plus ? _IORW : _IOREAD;
1329 break;
1330 case 'W': case 'w':
1331 *open_flags = _O_CREAT | _O_TRUNC | (plus ? _O_RDWR : _O_WRONLY);
1332 *stream_flags = plus ? _IORW : _IOWRT;
1333 break;
1334 case 'A': case 'a':
1335 *open_flags = _O_CREAT | _O_APPEND | (plus ? _O_RDWR : _O_WRONLY);
1336 *stream_flags = plus ? _IORW : _IOWRT;
1337 break;
1338 default:
1339 MSVCRT_INVALID_PMT(0, EINVAL);
1340 return -1;
1341 }
1342
1343 *stream_flags |= _commode;
1344
1345 while (*mode && *mode!=',')
1346 switch (*mode++)
1347 {
1348 case 'B': case 'b':
1349 *open_flags |= _O_BINARY;
1350 *open_flags &= ~_O_TEXT;
1351 break;
1352 case 't':
1353 *open_flags |= _O_TEXT;
1354 *open_flags &= ~_O_BINARY;
1355 break;
1356 case 'D':
1357 *open_flags |= _O_TEMPORARY;
1358 break;
1359 case 'T':
1360 *open_flags |= _O_SHORT_LIVED;
1361 break;
1362 case 'c':
1363 *stream_flags |= _IOCOMMIT;
1364 break;
1365 case 'n':
1366 *stream_flags &= ~_IOCOMMIT;
1367 break;
1368 case 'N':
1369 *open_flags |= _O_NOINHERIT;
1370 break;
1371 case '+':
1372 case ' ':
1373 case 'a':
1374 case 'w':
1375 break;
1376 case 'S':
1377 case 'R':
1378 FIXME("ignoring cache optimization flag: %c\n", mode[-1]);
1379 break;
1380 default:
1381 ERR("incorrect mode flag: %c\n", mode[-1]);
1382 break;
1383 }
1384
1385 if(*mode == ',')
1386 {
1387 static const WCHAR ccs[] = {'c','c','s'};
1388 static const WCHAR utf8[] = {'u','t','f','-','8'};
1389 static const WCHAR utf16le[] = {'u','t','f','-','1','6','l','e'};
1390 static const WCHAR unicode[] = {'u','n','i','c','o','d','e'};
1391
1392 mode++;
1393 while(*mode == ' ') mode++;
1394 if(!MSVCRT_CHECK_PMT(!strncmpW(ccs, mode, sizeof(ccs)/sizeof(ccs[0]))))
1395 return -1;
1396 mode += sizeof(ccs)/sizeof(ccs[0]);
1397 while(*mode == ' ') mode++;
1398 if(!MSVCRT_CHECK_PMT(*mode == '='))
1399 return -1;
1400 mode++;
1401 while(*mode == ' ') mode++;
1402
1403 if(!strncmpiW(utf8, mode, sizeof(utf8)/sizeof(utf8[0])))
1404 {
1405 *open_flags |= _O_U8TEXT;
1406 mode += sizeof(utf8)/sizeof(utf8[0]);
1407 }
1408 else if(!strncmpiW(utf16le, mode, sizeof(utf16le)/sizeof(utf16le[0])))
1409 {
1410 *open_flags |= _O_U16TEXT;
1411 mode += sizeof(utf16le)/sizeof(utf16le[0]);
1412 }
1413 else if(!strncmpiW(unicode, mode, sizeof(unicode)/sizeof(unicode[0])))
1414 {
1415 *open_flags |= _O_WTEXT;
1416 mode += sizeof(unicode)/sizeof(unicode[0]);
1417 }
1418 else
1419 {
1420 MSVCRT_INVALID_PMT(0, EINVAL);
1421 return -1;
1422 }
1423
1424 while(*mode == ' ') mode++;
1425 }
1426
1427 if(!MSVCRT_CHECK_PMT(*mode == 0))
1428 return -1;
1429 return 0;
1430 }
1431
1432 /*********************************************************************
1433 * _fdopen (MSVCRT.@)
1434 */
1435 FILE* CDECL _fdopen(int fd, const char *mode)
1436 {
1437 FILE *ret;
1438 wchar_t *modeW = NULL;
1439
1440 if (mode && !(modeW = msvcrt_wstrdupa(mode))) return NULL;
1441
1442 ret = _wfdopen(fd, modeW);
1443
1444 free(modeW);
1445 return ret;
1446 }
1447
1448 /*********************************************************************
1449 * _wfdopen (MSVCRT.@)
1450 */
1451 FILE* CDECL _wfdopen(int fd, const wchar_t *mode)
1452 {
1453 int open_flags, stream_flags;
1454 FILE* file;
1455
1456 if (get_flags(mode, &open_flags, &stream_flags) == -1) return NULL;
1457
1458 LOCK_FILES();
1459 if (!(file = msvcrt_alloc_fp()))
1460 file = NULL;
1461 else if (msvcrt_init_fp(file, fd, stream_flags) == -1)
1462 {
1463 file->_flag = 0;
1464 file = NULL;
1465 }
1466 else TRACE(":fd (%d) mode (%s) FILE* (%p)\n", fd, debugstr_w(mode), file);
1467 UNLOCK_FILES();
1468
1469 return file;
1470 }
1471
1472 /*********************************************************************
1473 * _filelength (MSVCRT.@)
1474 */
1475 LONG CDECL _filelength(int fd)
1476 {
1477 LONG curPos = _lseek(fd, 0, SEEK_CUR);
1478 if (curPos != -1)
1479 {
1480 LONG endPos = _lseek(fd, 0, SEEK_END);
1481 if (endPos != -1)
1482 {
1483 if (endPos != curPos)
1484 _lseek(fd, curPos, SEEK_SET);
1485 return endPos;
1486 }
1487 }
1488 return -1;
1489 }
1490
1491 /*********************************************************************
1492 * _filelengthi64 (MSVCRT.@)
1493 */
1494 __int64 CDECL _filelengthi64(int fd)
1495 {
1496 __int64 curPos = _lseeki64(fd, 0, SEEK_CUR);
1497 if (curPos != -1)
1498 {
1499 __int64 endPos = _lseeki64(fd, 0, SEEK_END);
1500 if (endPos != -1)
1501 {
1502 if (endPos != curPos)
1503 _lseeki64(fd, curPos, SEEK_SET);
1504 return endPos;
1505 }
1506 }
1507 return -1;
1508 }
1509
1510 /*********************************************************************
1511 * _fileno (MSVCRT.@)
1512 */
1513 int CDECL _fileno(FILE* file)
1514 {
1515 TRACE(":FILE* (%p) fd (%d)\n",file,file->_file);
1516 return file->_file;
1517 }
1518
1519 /*********************************************************************
1520 * _get_osfhandle (MSVCRT.@)
1521 */
1522 intptr_t CDECL _get_osfhandle(int fd)
1523 {
1524 HANDLE hand = fdtoh(fd);
1525 TRACE(":fd (%d) handle (%p)\n",fd,hand);
1526
1527 return (intptr_t)hand;
1528 }
1529
1530 /*********************************************************************
1531 * _mktemp (MSVCRT.@)
1532 */
1533 char * CDECL _mktemp(char *pattern)
1534 {
1535 int numX = 0;
1536 char *retVal = pattern;
1537 int id;
1538 char letter = 'a';
1539
1540 if(!pattern)
1541 return NULL;
1542
1543 while(*pattern)
1544 numX = (*pattern++ == 'X')? numX + 1 : 0;
1545 if (numX < 6)
1546 return NULL;
1547 pattern--;
1548 id = GetCurrentProcessId();
1549 numX = 6;
1550 while(numX--)
1551 {
1552 int tempNum = id / 10;
1553 *pattern-- = id - (tempNum * 10) + '0';
1554 id = tempNum;
1555 }
1556 pattern++;
1557 do
1558 {
1559 *pattern = letter++;
1560 if (GetFileAttributesA(retVal) == INVALID_FILE_ATTRIBUTES)
1561 return retVal;
1562 } while(letter <= 'z');
1563 return NULL;
1564 }
1565
1566 /*********************************************************************
1567 * _wmktemp (MSVCRT.@)
1568 */
1569 wchar_t * CDECL _wmktemp(wchar_t *pattern)
1570 {
1571 int numX = 0;
1572 wchar_t *retVal = pattern;
1573 int id;
1574 wchar_t letter = 'a';
1575
1576 while(*pattern)
1577 numX = (*pattern++ == 'X')? numX + 1 : 0;
1578 if (numX < 5)
1579 return NULL;
1580 pattern--;
1581 id = GetCurrentProcessId();
1582 numX = 6;
1583 while(numX--)
1584 {
1585 int tempNum = id / 10;
1586 *pattern-- = id - (tempNum * 10) + '0';
1587 id = tempNum;
1588 }
1589 pattern++;
1590 do
1591 {
1592 if (GetFileAttributesW(retVal) == INVALID_FILE_ATTRIBUTES &&
1593 GetLastError() == ERROR_FILE_NOT_FOUND)
1594 return retVal;
1595 *pattern = letter++;
1596 } while(letter != '|');
1597 return NULL;
1598 }
1599
1600 /*static*/ unsigned split_oflags(unsigned oflags)
1601 {
1602 int wxflags = 0;
1603 unsigned unsupp; /* until we support everything */
1604
1605 if (oflags & _O_APPEND) wxflags |= WX_APPEND;
1606 if (oflags & _O_BINARY) {/* Nothing to do */}
1607 else if (oflags & _O_TEXT) wxflags |= WX_TEXT;
1608 else if (oflags & _O_WTEXT) wxflags |= WX_TEXT;
1609 else if (oflags & _O_U16TEXT) wxflags |= WX_TEXT;
1610 else if (oflags & _O_U8TEXT) wxflags |= WX_TEXT;
1611 else if (*__p__fmode() & _O_BINARY) {/* Nothing to do */}
1612 else wxflags |= WX_TEXT; /* default to TEXT*/
1613 if (oflags & _O_NOINHERIT) wxflags |= WX_DONTINHERIT;
1614
1615 if ((unsupp = oflags & ~(
1616 _O_BINARY|_O_TEXT|_O_APPEND|
1617 _O_TRUNC|_O_EXCL|_O_CREAT|
1618 _O_RDWR|_O_WRONLY|_O_TEMPORARY|
1619 _O_NOINHERIT|
1620 _O_SEQUENTIAL|_O_RANDOM|_O_SHORT_LIVED|
1621 _O_WTEXT|_O_U16TEXT|_O_U8TEXT
1622 )))
1623 ERR(":unsupported oflags 0x%04x\n",unsupp);
1624
1625 return wxflags;
1626 }
1627
1628 /*********************************************************************
1629 * _pipe (MSVCRT.@)
1630 */
1631 int CDECL _pipe(int *pfds, unsigned int psize, int textmode)
1632 {
1633 int ret = -1;
1634 SECURITY_ATTRIBUTES sa;
1635 HANDLE readHandle, writeHandle;
1636
1637 if (!pfds)
1638 {
1639 *_errno() = EINVAL;
1640 return -1;
1641 }
1642
1643 sa.nLength = sizeof(SECURITY_ATTRIBUTES);
1644 sa.bInheritHandle = !(textmode & _O_NOINHERIT);
1645 sa.lpSecurityDescriptor = NULL;
1646 if (CreatePipe(&readHandle, &writeHandle, &sa, psize))
1647 {
1648 unsigned int wxflags = split_oflags(textmode);
1649 int fd;
1650
1651 LOCK_FILES();
1652 fd = msvcrt_alloc_fd(readHandle, wxflags);
1653 if (fd != -1)
1654 {
1655 pfds[0] = fd;
1656 fd = msvcrt_alloc_fd(writeHandle, wxflags);
1657 if (fd != -1)
1658 {
1659 pfds[1] = fd;
1660 ret = 0;
1661 }
1662 else
1663 {
1664 _close(pfds[0]);
1665 CloseHandle(writeHandle);
1666 *_errno() = EMFILE;
1667 }
1668 }
1669 else
1670 {
1671 CloseHandle(readHandle);
1672 CloseHandle(writeHandle);
1673 *_errno() = EMFILE;
1674 }
1675 UNLOCK_FILES();
1676 }
1677 else
1678 _dosmaperr(GetLastError());
1679
1680 return ret;
1681 }
1682
1683 static int check_bom(HANDLE h, int oflags, BOOL seek)
1684 {
1685 char bom[sizeof(utf8_bom)];
1686 DWORD r;
1687
1688 oflags &= ~(_O_WTEXT|_O_U16TEXT|_O_U8TEXT);
1689
1690 if (!ReadFile(h, bom, sizeof(utf8_bom), &r, NULL))
1691 return oflags;
1692
1693 if (r==sizeof(utf8_bom) && !memcmp(bom, utf8_bom, sizeof(utf8_bom))) {
1694 oflags |= _O_U8TEXT;
1695 }else if (r>=sizeof(utf16_bom) && !memcmp(bom, utf16_bom, sizeof(utf16_bom))) {
1696 if (seek && r>2)
1697 SetFilePointer(h, 2, NULL, FILE_BEGIN);
1698 oflags |= _O_U16TEXT;
1699 }else if (seek) {
1700 SetFilePointer(h, 0, NULL, FILE_BEGIN);
1701 }
1702
1703 return oflags;
1704 }
1705
1706 /*********************************************************************
1707 * _wsopen_s (MSVCRT.@)
1708 */
1709 int CDECL _wsopen_s( int *fd, const wchar_t* path, int oflags, int shflags, int pmode )
1710 {
1711 DWORD access = 0, creation = 0, attrib;
1712 SECURITY_ATTRIBUTES sa;
1713 DWORD sharing, type;
1714 int wxflag;
1715 HANDLE hand;
1716
1717 TRACE("fd*: %p :file (%s) oflags: 0x%04x shflags: 0x%04x pmode: 0x%04x\n",
1718 fd, debugstr_w(path), oflags, shflags, pmode);
1719
1720 if (!MSVCRT_CHECK_PMT( fd != NULL )) return EINVAL;
1721
1722 *fd = -1;
1723 wxflag = split_oflags(oflags);
1724 switch (oflags & (_O_RDONLY | _O_WRONLY | _O_RDWR))
1725 {
1726 case _O_RDONLY: access |= GENERIC_READ; break;
1727 case _O_WRONLY: access |= GENERIC_WRITE; break;
1728 case _O_RDWR: access |= GENERIC_WRITE | GENERIC_READ; break;
1729 }
1730
1731 if (oflags & _O_CREAT)
1732 {
1733 if(pmode & ~(_S_IREAD | _S_IWRITE))
1734 FIXME(": pmode 0x%04x ignored\n", pmode);
1735 else
1736 WARN(": pmode 0x%04x ignored\n", pmode);
1737
1738 if (oflags & _O_EXCL)
1739 creation = CREATE_NEW;
1740 else if (oflags & _O_TRUNC)
1741 creation = CREATE_ALWAYS;
1742 else
1743 creation = OPEN_ALWAYS;
1744 }
1745 else /* no _O_CREAT */
1746 {
1747 if (oflags & _O_TRUNC)
1748 creation = TRUNCATE_EXISTING;
1749 else
1750 creation = OPEN_EXISTING;
1751 }
1752
1753 switch( shflags )
1754 {
1755 case _SH_DENYRW:
1756 sharing = 0L;
1757 break;
1758 case _SH_DENYWR:
1759 sharing = FILE_SHARE_READ;
1760 break;
1761 case _SH_DENYRD:
1762 sharing = FILE_SHARE_WRITE;
1763 break;
1764 case _SH_DENYNO:
1765 sharing = FILE_SHARE_READ | FILE_SHARE_WRITE;
1766 break;
1767 default:
1768 ERR( "Unhandled shflags 0x%x\n", shflags );
1769 return EINVAL;
1770 }
1771 attrib = FILE_ATTRIBUTE_NORMAL;
1772
1773 if (oflags & _O_TEMPORARY)
1774 {
1775 attrib |= FILE_FLAG_DELETE_ON_CLOSE;
1776 access |= DELETE;
1777 sharing |= FILE_SHARE_DELETE;
1778 }
1779
1780 sa.nLength = sizeof( SECURITY_ATTRIBUTES );
1781 sa.lpSecurityDescriptor = NULL;
1782 sa.bInheritHandle = !(oflags & _O_NOINHERIT);
1783
1784 if ((oflags&(_O_WTEXT|_O_U16TEXT|_O_U8TEXT))
1785 && (creation==OPEN_ALWAYS || creation==OPEN_EXISTING)
1786 && !(access&GENERIC_READ))
1787 {
1788 hand = CreateFileW(path, GENERIC_READ, FILE_SHARE_READ|FILE_SHARE_WRITE,
1789 &sa, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, 0);
1790 if (hand != INVALID_HANDLE_VALUE)
1791 {
1792 oflags = check_bom(hand, oflags, FALSE);
1793 CloseHandle(hand);
1794 }
1795 else
1796 oflags &= ~(_O_WTEXT|_O_U16TEXT|_O_U8TEXT);
1797 }
1798
1799 hand = CreateFileW(path, access, sharing, &sa, creation, attrib, 0);
1800 if (hand == INVALID_HANDLE_VALUE) {
1801 WARN(":failed-last error (%d)\n",GetLastError());
1802 _dosmaperr(GetLastError());
1803 return *_errno();
1804 }
1805
1806 if (oflags & (_O_WTEXT|_O_U16TEXT|_O_U8TEXT))
1807 {
1808 if ((access & GENERIC_WRITE) && (creation==CREATE_NEW
1809 || creation==CREATE_ALWAYS || creation==TRUNCATE_EXISTING
1810 || (creation==OPEN_ALWAYS && GetLastError()==ERROR_ALREADY_EXISTS)))
1811 {
1812 if (oflags & _O_U8TEXT)
1813 {
1814 DWORD written = 0, tmp;
1815
1816 while(written!=sizeof(utf8_bom) && WriteFile(hand, (char*)utf8_bom+written,
1817 sizeof(utf8_bom)-written, &tmp, NULL))
1818 written += tmp;
1819 if (written != sizeof(utf8_bom)) {
1820 WARN("error writing BOM\n");
1821 CloseHandle(hand);
1822 _dosmaperr(GetLastError());
1823 return *_errno();
1824 }
1825 }
1826 else
1827 {
1828 DWORD written = 0, tmp;
1829
1830 while(written!=sizeof(utf16_bom) && WriteFile(hand, (char*)utf16_bom+written,
1831 sizeof(utf16_bom)-written, &tmp, NULL))
1832 written += tmp;
1833 if (written != sizeof(utf16_bom))
1834 {
1835 WARN("error writing BOM\n");
1836 CloseHandle(hand);
1837 _dosmaperr(GetLastError());
1838 return *_errno();
1839 }
1840 }
1841 }
1842 else if (access & GENERIC_READ)
1843 oflags = check_bom(hand, oflags, TRUE);
1844 }
1845 type = GetFileType(hand);
1846 if (type == FILE_TYPE_CHAR)
1847 wxflag |= WX_TTY;
1848 else if (type == FILE_TYPE_PIPE)
1849 wxflag |= WX_PIPE;
1850
1851 *fd = msvcrt_alloc_fd(hand, wxflag);
1852 if (*fd == -1)
1853 return *_errno();
1854
1855 if (oflags & _O_WTEXT)
1856 get_ioinfo(*fd)->exflag |= EF_UTF16|EF_UNK_UNICODE;
1857 else if (oflags & _O_U16TEXT)
1858 get_ioinfo(*fd)->exflag |= EF_UTF16;
1859 else if (oflags & _O_U8TEXT)
1860 get_ioinfo(*fd)->exflag |= EF_UTF8;
1861
1862 TRACE(":fd (%d) handle (%p)\n", *fd, hand);
1863 return 0;
1864 }
1865
1866 /*********************************************************************
1867 * _wsopen (MSVCRT.@)
1868 */
1869 int CDECL _wsopen( const wchar_t *path, int oflags, int shflags, ... )
1870 {
1871 int pmode;
1872 int fd;
1873
1874 if (oflags & _O_CREAT)
1875 {
1876 __ms_va_list ap;
1877
1878 __ms_va_start(ap, shflags);
1879 pmode = va_arg(ap, int);
1880 __ms_va_end(ap);
1881 }
1882 else
1883 pmode = 0;
1884
1885 _wsopen_s(&fd, path, oflags, shflags, pmode);
1886 return fd;
1887 }
1888
1889 /*********************************************************************
1890 * _sopen_s (MSVCRT.@)
1891 */
1892 int CDECL _sopen_s( int *fd, const char *path, int oflags, int shflags, int pmode )
1893 {
1894 wchar_t *pathW;
1895 int ret;
1896
1897 if(!MSVCRT_CHECK_PMT(path && (pathW = msvcrt_wstrdupa(path))))
1898 return EINVAL;
1899
1900 ret = _wsopen_s(fd, pathW, oflags, shflags, pmode);
1901 free(pathW);
1902 return ret;
1903 }
1904
1905 /*********************************************************************
1906 * _sopen (MSVCRT.@)
1907 */
1908 int CDECL _sopen( const char *path, int oflags, int shflags, ... )
1909 {
1910 int pmode;
1911 int fd;
1912
1913 if (oflags & _O_CREAT)
1914 {
1915 va_list ap;
1916
1917 va_start(ap, shflags);
1918 pmode = va_arg(ap, int);
1919 va_end(ap);
1920 }
1921 else
1922 pmode = 0;
1923
1924 _sopen_s(&fd, path, oflags, shflags, pmode);
1925 return fd;
1926 }
1927
1928 /*********************************************************************
1929 * _open (MSVCRT.@)
1930 */
1931 int CDECL _open( const char *path, int flags, ... )
1932 {
1933 va_list ap;
1934
1935 if (flags & _O_CREAT)
1936 {
1937 int pmode;
1938 va_start(ap, flags);
1939 pmode = va_arg(ap, int);
1940 va_end(ap);
1941 return _sopen( path, flags, _SH_DENYNO, pmode );
1942 }
1943 else
1944 return _sopen( path, flags, _SH_DENYNO);
1945 }
1946
1947 /*********************************************************************
1948 * _wopen (MSVCRT.@)
1949 */
1950 int CDECL _wopen(const wchar_t *path,int flags,...)
1951 {
1952 va_list ap;
1953
1954 if (flags & _O_CREAT)
1955 {
1956 int pmode;
1957 va_start(ap, flags);
1958 pmode = va_arg(ap, int);
1959 va_end(ap);
1960 return _wsopen( path, flags, _SH_DENYNO, pmode );
1961 }
1962 else
1963 return _wsopen( path, flags, _SH_DENYNO);
1964 }
1965
1966 /*********************************************************************
1967 * _creat (MSVCRT.@)
1968 */
1969 int CDECL _creat(const char *path, int flags)
1970 {
1971 int usedFlags = (flags & _O_TEXT)| _O_CREAT| _O_WRONLY| _O_TRUNC;
1972 return _open(path, usedFlags);
1973 }
1974
1975 /*********************************************************************
1976 * _wcreat (MSVCRT.@)
1977 */
1978 int CDECL _wcreat(const wchar_t *path, int flags)
1979 {
1980 int usedFlags = (flags & _O_TEXT)| _O_CREAT| _O_WRONLY| _O_TRUNC;
1981 return _wopen(path, usedFlags);
1982 }
1983
1984 /*********************************************************************
1985 * _open_osfhandle (MSVCRT.@)
1986 */
1987 int CDECL _open_osfhandle(intptr_t handle, int oflags)
1988 {
1989 DWORD flags;
1990 int fd;
1991
1992 /* _O_RDONLY (0) always matches, so set the read flag
1993 * MFC's CStdioFile clears O_RDONLY (0)! if it wants to write to the
1994 * file, so set the write flag. It also only sets _O_TEXT if it wants
1995 * text - it never sets _O_BINARY.
1996 */
1997 /* don't let split_oflags() decide the mode if no mode is passed */
1998 if (!(oflags & (_O_BINARY | _O_TEXT)))
1999 oflags |= _O_BINARY;
2000
2001 flags = GetFileType((HANDLE)handle);
2002 if (flags==FILE_TYPE_UNKNOWN && GetLastError()!=NO_ERROR)
2003 {
2004 _dosmaperr(GetLastError());
2005 return -1;
2006 }
2007
2008 if (flags == FILE_TYPE_CHAR)
2009 flags = WX_TTY;
2010 else if (flags == FILE_TYPE_PIPE)
2011 flags = WX_PIPE;
2012 else
2013 flags = 0;
2014 flags |= split_oflags(oflags);
2015
2016 fd = msvcrt_alloc_fd((HANDLE)handle, flags);
2017 TRACE(":handle (%ld) fd (%d) flags 0x%08x\n", handle, fd, flags);
2018 return fd;
2019 }
2020
2021 /*********************************************************************
2022 * _rmtmp (MSVCRT.@)
2023 */
2024 int CDECL _rmtmp(void)
2025 {
2026 int num_removed = 0, i;
2027 FILE *file;
2028
2029 LOCK_FILES();
2030 for (i = 3; i < MSVCRT_stream_idx; i++) {
2031 file = msvcrt_get_file(i);
2032
2033 if (file->_tmpfname)
2034 {
2035 fclose(file);
2036 num_removed++;
2037 }
2038 }
2039 UNLOCK_FILES();
2040
2041 if (num_removed)
2042 TRACE(":removed (%d) temp files\n",num_removed);
2043 return num_removed;
2044 }
2045
2046 static inline int get_utf8_char_len(char ch)
2047 {
2048 if((ch&0xf8) == 0xf0)
2049 return 4;
2050 else if((ch&0xf0) == 0xe0)
2051 return 3;
2052 else if((ch&0xe0) == 0xc0)
2053 return 2;
2054 return 1;
2055 }
2056
2057 /*********************************************************************
2058 * (internal) read_utf8
2059 */
2060 static int read_utf8(int fd, wchar_t *buf, unsigned int count)
2061 {
2062 ioinfo *fdinfo = get_ioinfo(fd);
2063 HANDLE hand = fdinfo->handle;
2064 char min_buf[4], *readbuf, lookahead;
2065 DWORD readbuf_size, pos=0, num_read=1, char_len, i, j;
2066
2067 /* make the buffer big enough to hold at least one character */
2068 /* read bytes have to fit to output and lookahead buffers */
2069 count /= 2;
2070 readbuf_size = count < 4 ? 4 : count;
2071 if(readbuf_size<=4 || !(readbuf = malloc(readbuf_size))) {
2072 readbuf_size = 4;
2073 readbuf = min_buf;
2074 }
2075
2076 if(fdinfo->lookahead[0] != '\n') {
2077 readbuf[pos++] = fdinfo->lookahead[0];
2078 fdinfo->lookahead[0] = '\n';
2079
2080 if(fdinfo->lookahead[1] != '\n') {
2081 readbuf[pos++] = fdinfo->lookahead[1];
2082 fdinfo->lookahead[1] = '\n';
2083
2084 if(fdinfo->lookahead[2] != '\n') {
2085 readbuf[pos++] = fdinfo->lookahead[2];
2086 fdinfo->lookahead[2] = '\n';
2087 }
2088 }
2089 }
2090
2091 /* NOTE: this case is broken in native dll, reading
2092 * sometimes fails when small buffer is passed
2093 */
2094 if(count < 4) {
2095 if(!pos && !ReadFile(hand, readbuf, 1, &num_read, NULL)) {
2096 if (GetLastError() == ERROR_BROKEN_PIPE) {
2097 fdinfo->wxflag |= WX_ATEOF;
2098 return 0;
2099 }else {
2100 _dosmaperr(GetLastError());
2101 return -1;
2102 }
2103 }else if(!num_read) {
2104 fdinfo->wxflag |= WX_ATEOF;
2105 return 0;
2106 }else {
2107 pos++;
2108 }
2109
2110 char_len = get_utf8_char_len(readbuf[0]);
2111 if(char_len>pos) {
2112 if(ReadFile(hand, readbuf+pos, char_len-pos, &num_read, NULL))
2113 pos += num_read;
2114 }
2115
2116 if(readbuf[0] == '\n')
2117 fdinfo->wxflag |= WX_READNL;
2118 else
2119 fdinfo->wxflag &= ~WX_READNL;
2120
2121 if(readbuf[0] == 0x1a) {
2122 fdinfo->wxflag |= WX_ATEOF;
2123 return 0;
2124 }
2125
2126 if(readbuf[0] == '\r') {
2127 if(!ReadFile(hand, &lookahead, 1, &num_read, NULL) || num_read!=1)
2128 buf[0] = '\r';
2129 else if(lookahead == '\n')
2130 buf[0] = '\n';
2131 else {
2132 buf[0] = '\r';
2133 if(fdinfo->wxflag & (WX_PIPE | WX_TTY))
2134 fdinfo->lookahead[0] = lookahead;
2135 else
2136 SetFilePointer(fdinfo->handle, -1, NULL, FILE_CURRENT);
2137 }
2138 return 2;
2139 }
2140
2141 if(!(num_read = MultiByteToWideChar(CP_UTF8, 0, readbuf, pos, buf, count))) {
2142 _dosmaperr(GetLastError());
2143 return -1;
2144 }
2145
2146 return num_read*2;
2147 }
2148
2149 if(!ReadFile(hand, readbuf+pos, readbuf_size-pos, &num_read, NULL)) {
2150 if(pos) {
2151 num_read = 0;
2152 }else if(GetLastError() == ERROR_BROKEN_PIPE) {
2153 fdinfo->wxflag |= WX_ATEOF;
2154 if (readbuf != min_buf) free(readbuf);
2155 return 0;
2156 }else {
2157 _dosmaperr(GetLastError());
2158 if (readbuf != min_buf) free(readbuf);
2159 return -1;
2160 }
2161 }else if(!pos && !num_read) {
2162 fdinfo->wxflag |= WX_ATEOF;
2163 if (readbuf != min_buf) free(readbuf);
2164 return 0;
2165 }
2166
2167 pos += num_read;
2168 if(readbuf[0] == '\n')
2169 fdinfo->wxflag |= WX_READNL;
2170 else
2171 fdinfo->wxflag &= ~WX_READNL;
2172
2173 /* Find first byte of last character (may be incomplete) */
2174 for(i=pos-1; i>0 && i>pos-4; i--)
2175 if((readbuf[i]&0xc0) != 0x80)
2176 break;
2177 char_len = get_utf8_char_len(readbuf[i]);
2178 if(char_len+i <= pos)
2179 i += char_len;
2180
2181 if(fdinfo->wxflag & (WX_PIPE | WX_TTY)) {
2182 if(i < pos)
2183 fdinfo->lookahead[0] = readbuf[i];
2184 if(i+1 < pos)
2185 fdinfo->lookahead[1] = readbuf[i+1];
2186 if(i+2 < pos)
2187 fdinfo->lookahead[2] = readbuf[i+2];
2188 }else if(i < pos) {
2189 SetFilePointer(fdinfo->handle, i-pos, NULL, FILE_CURRENT);
2190 }
2191 pos = i;
2192
2193 for(i=0, j=0; i<pos; i++) {
2194 if(readbuf[i] == 0x1a) {
2195 fdinfo->wxflag |= WX_ATEOF;
2196 break;
2197 }
2198
2199 /* strip '\r' if followed by '\n' */
2200 if(readbuf[i] == '\r' && i+1==pos) {
2201 if(fdinfo->lookahead[0] != '\n' || !ReadFile(hand, &lookahead, 1, &num_read, NULL) || !num_read) {
2202 readbuf[j++] = '\r';
2203 }else if(lookahead == '\n' && j==0) {
2204 readbuf[j++] = '\n';
2205 }else {
2206 if(lookahead != '\n')
2207 readbuf[j++] = '\r';
2208
2209 if(fdinfo->wxflag & (WX_PIPE | WX_TTY))
2210 fdinfo->lookahead[0] = lookahead;
2211 else
2212 SetFilePointer(fdinfo->handle, -1, NULL, FILE_CURRENT);
2213 }
2214 }else if(readbuf[i]!='\r' || readbuf[i+1]!='\n') {
2215 readbuf[j++] = readbuf[i];
2216 }
2217 }
2218 pos = j;
2219
2220 if(!(num_read = MultiByteToWideChar(CP_UTF8, 0, readbuf, pos, buf, count))) {
2221 _dosmaperr(GetLastError());
2222 if (readbuf != min_buf) free(readbuf);
2223 return -1;
2224 }
2225
2226 if (readbuf != min_buf) free(readbuf);
2227 return num_read*2;
2228 }
2229
2230 /*********************************************************************
2231 * (internal) read_i
2232 *
2233 * When reading \r as last character in text mode, read() positions
2234 * the file pointer on the \r character while getc() goes on to
2235 * the following \n
2236 */
2237 static int read_i(int fd, void *buf, unsigned int count)
2238 {
2239 DWORD num_read, utf16;
2240 char *bufstart = buf;
2241 HANDLE hand = fdtoh(fd);
2242 ioinfo *fdinfo = get_ioinfo(fd);
2243
2244 if (count == 0)
2245 return 0;
2246
2247 if (fdinfo->wxflag & WX_ATEOF) {
2248 TRACE("already at EOF, returning 0\n");
2249 return 0;
2250 }
2251 /* Don't trace small reads, it gets *very* annoying */
2252 if (count > 4)
2253 TRACE(":fd (%d) handle (%p) buf (%p) len (%d)\n",fd,hand,buf,count);
2254 if (hand == INVALID_HANDLE_VALUE)
2255 {
2256 *_errno() = EBADF;
2257 return -1;
2258 }
2259
2260 utf16 = (fdinfo->exflag & EF_UTF16) != 0;
2261 if (((fdinfo->exflag&EF_UTF8) || utf16) && count&1)
2262 {
2263 *_errno() = EINVAL;
2264 return -1;
2265 }
2266
2267 if((fdinfo->wxflag&WX_TEXT) && (fdinfo->exflag&EF_UTF8))
2268 return read_utf8(fd, buf, count);
2269
2270 if (fdinfo->lookahead[0]!='\n' || ReadFile(hand, bufstart, count, &num_read, NULL))
2271 {
2272 if (fdinfo->lookahead[0] != '\n')
2273 {
2274 bufstart[0] = fdinfo->lookahead[0];
2275 fdinfo->lookahead[0] = '\n';
2276
2277 if (utf16)
2278 {
2279 bufstart[1] = fdinfo->lookahead[1];
2280 fdinfo->lookahead[1] = '\n';
2281 }
2282
2283 if(count>1+utf16 && ReadFile(hand, bufstart+1+utf16, count-1-utf16, &num_read, NULL))
2284 num_read += 1+utf16;
2285 else
2286 num_read = 1+utf16;
2287 }
2288
2289 if(utf16 && (num_read&1))
2290 {
2291 /* msvcr90 uses uninitialized value from the buffer in this case */
2292 /* msvcrt ignores additional data */
2293 ERR("got odd number of bytes in UTF16 mode\n");
2294 num_read--;
2295 }
2296
2297 if (count != 0 && num_read == 0)
2298 {
2299 fdinfo->wxflag |= WX_ATEOF;
2300 TRACE(":EOF %s\n",debugstr_an(buf,num_read));
2301 }
2302 else if (fdinfo->wxflag & WX_TEXT)
2303 {
2304 DWORD i, j;
2305
2306 if (bufstart[0]=='\n' && (!utf16 || bufstart[1]==0))
2307 fdinfo->wxflag |= WX_READNL;
2308 else
2309 fdinfo->wxflag &= ~WX_READNL;
2310
2311 for (i=0, j=0; i<num_read; i+=1+utf16)
2312 {
2313 /* in text mode, a ctrl-z signals EOF */
2314 if (bufstart[i]==0x1a && (!utf16 || bufstart[i+1]==0))
2315 {
2316 fdinfo->wxflag |= WX_ATEOF;
2317 TRACE(":^Z EOF %s\n",debugstr_an(buf,num_read));
2318 break;
2319 }
2320
2321 /* in text mode, strip \r if followed by \n */
2322 if (bufstart[i]=='\r' && (!utf16 || bufstart[i+1]==0) && i+1+utf16==num_read)
2323 {
2324 char lookahead[2];
2325 DWORD len;
2326
2327 lookahead[1] = '\n';
2328 if (ReadFile(hand, lookahead, 1+utf16, &len, NULL) && len)
2329 {
2330 if(lookahead[0]=='\n' && (!utf16 || lookahead[1]==0) && j==0)
2331 {
2332 bufstart[j++] = '\n';
2333 if(utf16) bufstart[j++] = 0;
2334 }
2335 else
2336 {
2337 if(lookahead[0]!='\n' || (utf16 && lookahead[1]!=0))
2338 {
2339 bufstart[j++] = '\r';
2340 if(utf16) bufstart[j++] = 0;
2341 }
2342
2343 if (fdinfo->wxflag & (WX_PIPE | WX_TTY))
2344 {
2345 if (lookahead[0]=='\n' && (!utf16 || !lookahead[1]))
2346 {
2347 bufstart[j++] = '\n';
2348 if (utf16) bufstart[j++] = 0;
2349 }
2350 else
2351 {
2352 fdinfo->lookahead[0] = lookahead[0];
2353 fdinfo->lookahead[1] = lookahead[1];
2354 }
2355 }
2356 else
2357 SetFilePointer(fdinfo->handle, -1-utf16, NULL, FILE_CURRENT);
2358 }
2359 }
2360 else
2361 {
2362 bufstart[j++] = '\r';
2363 if(utf16) bufstart[j++] = 0;
2364 }
2365 }
2366 else if((bufstart[i]!='\r' || (utf16 && bufstart[i+1]!=0))
2367 || (bufstart[i+1+utf16]!='\n' || (utf16 && bufstart[i+3]!=0)))
2368 {
2369 bufstart[j++] = bufstart[i];
2370 if(utf16) bufstart[j++] = bufstart[i+1];
2371 }
2372 }
2373 num_read = j;
2374 }
2375 }
2376 else
2377 {
2378 if (GetLastError() == ERROR_BROKEN_PIPE)
2379 {
2380 TRACE(":end-of-pipe\n");
2381 fdinfo->wxflag |= WX_ATEOF;
2382 return 0;
2383 }
2384 else
2385 {
2386 TRACE(":failed-last error (%d)\n",GetLastError());
2387 return -1;
2388 }
2389 }
2390
2391 if (count > 4)
2392 TRACE("(%u), %s\n",num_read,debugstr_an(buf, num_read));
2393 return num_read;
2394 }
2395
2396 /*********************************************************************
2397 * _read (MSVCRT.@)
2398 */
2399 int CDECL _read(int fd, void *buf, unsigned int count)
2400 {
2401 int num_read;
2402 num_read = read_i(fd, buf, count);
2403 return num_read;
2404 }
2405
2406 /*********************************************************************
2407 * _setmode (MSVCRT.@)
2408 */
2409 int CDECL _setmode(int fd,int mode)
2410 {
2411 int ret = get_ioinfo(fd)->wxflag & WX_TEXT ? _O_TEXT : _O_BINARY;
2412 if(ret==_O_TEXT && (get_ioinfo(fd)->exflag & (EF_UTF8|EF_UTF16)))
2413 ret = _O_WTEXT;
2414
2415 if(mode!=_O_TEXT && mode!=_O_BINARY && mode!=_O_WTEXT
2416 && mode!=_O_U16TEXT && mode!=_O_U8TEXT) {
2417 *_errno() = EINVAL;
2418 return -1;
2419 }
2420
2421 if(mode == _O_BINARY) {
2422 get_ioinfo(fd)->wxflag &= ~WX_TEXT;
2423 get_ioinfo(fd)->exflag &= ~(EF_UTF8|EF_UTF16);
2424 return ret;
2425 }
2426
2427 get_ioinfo(fd)->wxflag |= WX_TEXT;
2428 if(mode == _O_TEXT)
2429 get_ioinfo(fd)->exflag &= ~(EF_UTF8|EF_UTF16);
2430 else if(mode == _O_U8TEXT)
2431 get_ioinfo(fd)->exflag = (get_ioinfo(fd)->exflag & ~EF_UTF16) | EF_UTF8;
2432 else
2433 get_ioinfo(fd)->exflag = (get_ioinfo(fd)->exflag & ~EF_UTF8) | EF_UTF16;
2434
2435 return ret;
2436
2437 }
2438
2439 /*********************************************************************
2440 * _tell (MSVCRT.@)
2441 */
2442 long CDECL _tell(int fd)
2443 {
2444 return _lseek(fd, 0, SEEK_CUR);
2445 }
2446
2447 /*********************************************************************
2448 * _telli64 (MSVCRT.@)
2449 */
2450 __int64 CDECL _telli64(int fd)
2451 {
2452 return _lseeki64(fd, 0, SEEK_CUR);
2453 }
2454
2455 /*********************************************************************
2456 * _tempnam (MSVCRT.@)
2457 */
2458 char * CDECL _tempnam(const char *dir, const char *prefix)
2459 {
2460 char tmpbuf[MAX_PATH];
2461 const char *tmp_dir = getenv("TMP");
2462
2463 if (tmp_dir) dir = tmp_dir;
2464
2465 TRACE("dir (%s) prefix (%s)\n",dir,prefix);
2466 if (GetTempFileNameA(dir,prefix,0,tmpbuf))
2467 {
2468 TRACE("got name (%s)\n",tmpbuf);
2469 DeleteFileA(tmpbuf);
2470 return _strdup(tmpbuf);
2471 }
2472 TRACE("failed (%d)\n",GetLastError());
2473 return NULL;
2474 }
2475
2476 /*********************************************************************
2477 * _wtempnam (MSVCRT.@)
2478 */
2479 wchar_t * CDECL _wtempnam(const wchar_t *dir, const wchar_t *prefix)
2480 {
2481 wchar_t tmpbuf[MAX_PATH];
2482
2483 TRACE("dir (%s) prefix (%s)\n",debugstr_w(dir),debugstr_w(prefix));
2484 if (GetTempFileNameW(dir,prefix,0,tmpbuf))
2485 {
2486 TRACE("got name (%s)\n",debugstr_w(tmpbuf));
2487 DeleteFileW(tmpbuf);
2488 return _wcsdup(tmpbuf);
2489 }
2490 TRACE("failed (%d)\n",GetLastError());
2491 return NULL;
2492 }
2493
2494 /*********************************************************************
2495 * _umask (MSVCRT.@)
2496 */
2497 int CDECL _umask(int umask)
2498 {
2499 int old_umask = MSVCRT_umask;
2500 TRACE("(%d)\n",umask);
2501 MSVCRT_umask = umask;
2502 return old_umask;
2503 }
2504
2505 /*********************************************************************
2506 * _write (MSVCRT.@)
2507 */
2508 int CDECL _write(int fd, const void* buf, unsigned int count)
2509 {
2510 DWORD num_written;
2511 ioinfo *info = get_ioinfo(fd);
2512 HANDLE hand = info->handle;
2513
2514 /* Don't trace small writes, it gets *very* annoying */
2515 #if 0
2516 if (count > 32)
2517 TRACE(":fd (%d) handle (%d) buf (%p) len (%d)\n",fd,hand,buf,count);
2518 #endif
2519 if (hand == INVALID_HANDLE_VALUE)
2520 {
2521 *_errno() = EBADF;
2522 return -1;
2523 }
2524
2525 if (((info->exflag&EF_UTF8) || (info->exflag&EF_UTF16)) && count&1)
2526 {
2527 *_errno() = EINVAL;
2528 return -1;
2529 }
2530
2531 /* If appending, go to EOF */
2532 if (info->wxflag & WX_APPEND)
2533 _lseek(fd, 0, FILE_END);
2534
2535 if (!(info->wxflag & WX_TEXT))
2536 {
2537 if (WriteFile(hand, buf, count, &num_written, NULL)
2538 && (num_written == count))
2539 return num_written;
2540 TRACE("WriteFile (fd %d, hand %p) failed-last error (%d)\n", fd,
2541 hand, GetLastError());
2542 *_errno() = ENOSPC;
2543 }
2544 else
2545 {
2546 unsigned int i, j, nr_lf, size;
2547 char *p = NULL;
2548 const char *q;
2549 const char *s = buf, *buf_start = buf;
2550
2551 if (!(info->exflag & (EF_UTF8|EF_UTF16)))
2552 {
2553 /* find number of \n */
2554 for (nr_lf=0, i=0; i<count; i++)
2555 if (s[i] == '\n')
2556 nr_lf++;
2557 if (nr_lf)
2558 {
2559 size = count+nr_lf;
2560 if ((q = p = malloc(size)))
2561 {
2562 for (s = buf, i = 0, j = 0; i < count; i++)
2563 {
2564 if (s[i] == '\n')
2565 p[j++] = '\r';
2566 p[j++] = s[i];
2567 }
2568 }
2569 else
2570 {
2571 FIXME("Malloc failed\n");
2572 nr_lf = 0;
2573 size = count;
2574 q = buf;
2575 }
2576 }
2577 else
2578 {
2579 size = count;
2580 q = buf;
2581 }
2582 }
2583 else if (info->exflag & EF_UTF16)
2584 {
2585 for (nr_lf=0, i=0; i<count; i+=2)
2586 if (s[i]=='\n' && s[i+1]==0)
2587 nr_lf += 2;
2588 if (nr_lf)
2589 {
2590 size = count+nr_lf;
2591 if ((q = p = malloc(size)))
2592 {
2593 for (s=buf, i=0, j=0; i<count; i++)
2594 {
2595 if (s[i]=='\n' && s[i+1]==0)
2596 {
2597 p[j++] = '\r';
2598 p[j++] = 0;
2599 }
2600 p[j++] = s[i++];
2601 p[j++] = s[i];
2602 }
2603 }
2604 else
2605 {
2606 FIXME("Malloc failed\n");
2607 nr_lf = 0;
2608 size = count;
2609 q = buf;
2610 }
2611 }
2612 else
2613 {
2614 size = count;
2615 q = buf;
2616 }
2617 }
2618 else
2619 {
2620 DWORD conv_len;
2621
2622 for(nr_lf=0, i=0; i<count; i+=2)
2623 if (s[i]=='\n' && s[i+1]==0)
2624 nr_lf++;
2625
2626 conv_len = WideCharToMultiByte(CP_UTF8, 0, (WCHAR*)buf, count/2, NULL, 0, NULL, NULL);
2627 if(!conv_len) {
2628 _dosmaperr(GetLastError());
2629 free(p);
2630 return -1;
2631 }
2632
2633 size = conv_len+nr_lf;
2634 if((p = malloc(count+nr_lf*2+size)))
2635 {
2636 for (s=buf, i=0, j=0; i<count; i++)
2637 {
2638 if (s[i]=='\n' && s[i+1]==0)
2639 {
2640 p[j++] = '\r';
2641 p[j++] = 0;
2642 }
2643 p[j++] = s[i++];
2644 p[j++] = s[i];
2645 }
2646 q = p+count+nr_lf*2;
2647 WideCharToMultiByte(CP_UTF8, 0, (WCHAR*)p, count/2+nr_lf,
2648 p+count+nr_lf*2, conv_len+nr_lf, NULL, NULL);
2649 }
2650 else
2651 {
2652 FIXME("Malloc failed\n");
2653 nr_lf = 0;
2654 size = count;
2655 q = buf;
2656 }
2657 }
2658
2659 if (!WriteFile(hand, q, size, &num_written, NULL))
2660 num_written = -1;
2661 if(p)
2662 free(p);
2663 if (num_written != size)
2664 {
2665 TRACE("WriteFile (fd %d, hand %p) failed-last error (%d), num_written %d\n",
2666 fd, hand, GetLastError(), num_written);
2667 *_errno() = ENOSPC;
2668 return s - buf_start;
2669 }
2670 return count;
2671 }
2672
2673 return -1;
2674 }
2675
2676 /*********************************************************************
2677 * _putw (MSVCRT.@)
2678 */
2679 int CDECL _putw(int val, FILE* file)
2680 {
2681 int len;
2682
2683 _lock_file(file);
2684 len = _write(file->_file, &val, sizeof(val));
2685 if (len == sizeof(val)) {
2686 _unlock_file(file);
2687 return val;
2688 }
2689
2690 file->_flag |= _IOERR;
2691 _unlock_file(file);
2692 return EOF;
2693 }
2694
2695 /*********************************************************************
2696 * fclose (MSVCRT.@)
2697 */
2698 int CDECL fclose(FILE* file)
2699 {
2700 int r, flag;
2701
2702 _lock_file(file);
2703 flag = file->_flag;
2704 free(file->_tmpfname);
2705 file->_tmpfname = NULL;
2706 /* flush stdio buffers */
2707 if(file->_flag & _IOWRT)
2708 fflush(file);
2709 if(file->_flag & _IOMYBUF)
2710 free(file->_base);
2711
2712 r=_close(file->_file);
2713
2714 file->_flag = 0;
2715 _unlock_file(file);
2716 if(file<_iob || file>=_iob+_IOB_ENTRIES)
2717 DeleteCriticalSection(&((file_crit*)file)->crit);
2718
2719 if(file == msvcrt_get_file(MSVCRT_stream_idx-1)) {
2720 while(MSVCRT_stream_idx>3 && !file->_flag) {
2721 MSVCRT_stream_idx--;
2722 file = msvcrt_get_file(MSVCRT_stream_idx-1);
2723 }
2724 }
2725
2726 return ((r == -1) || (flag & _IOERR) ? EOF : 0);
2727 }
2728
2729 /*********************************************************************
2730 * feof (MSVCRT.@)
2731 */
2732 int CDECL feof(FILE* file)
2733 {
2734 return file->_flag & _IOEOF;
2735 }
2736
2737 /*********************************************************************
2738 * ferror (MSVCRT.@)
2739 */
2740 int CDECL ferror(FILE* file)
2741 {
2742 return file->_flag & _IOERR;
2743 }
2744
2745 /*********************************************************************
2746 * _filbuf (MSVCRT.@)
2747 */
2748 int CDECL _filbuf(FILE* file)
2749 {
2750 unsigned char c;
2751 _lock_file(file);
2752
2753 if(file->_flag & _IOSTRG) {
2754 _unlock_file(file);
2755 return EOF;
2756 }
2757
2758 /* Allocate buffer if needed */
2759 if(!(file->_flag & (_IONBF | _IOMYBUF | _USERBUF)))
2760 alloc_buffer(file);
2761
2762 if(!(file->_flag & _IOREAD)) {
2763 if(file->_flag & _IORW)
2764 file->_flag |= _IOREAD;
2765 else {
2766 _unlock_file(file);
2767 return EOF;
2768 }
2769 }
2770
2771 if(!(file->_flag & (_IOMYBUF | _USERBUF))) {
2772 int r;
2773 if ((r = read_i(file->_file,&c,1)) != 1) {
2774 file->_flag |= (r == 0) ? _IOEOF : _IOERR;
2775 _unlock_file(file);
2776 return EOF;
2777 }
2778
2779 _unlock_file(file);
2780 return c;
2781 } else {
2782 file->_cnt = read_i(file->_file, file->_base, file->_bufsiz);
2783 if(file->_cnt<=0) {
2784 file->_flag |= (file->_cnt == 0) ? _IOEOF : _IOERR;
2785 file->_cnt = 0;
2786 _unlock_file(file);
2787 return EOF;
2788 }
2789
2790 file->_cnt--;
2791 file->_ptr = file->_base+1;
2792 c = *(unsigned char *)file->_base;
2793 _unlock_file(file);
2794 return c;
2795 }
2796 }
2797
2798 /*********************************************************************
2799 * fgetc (MSVCRT.@)
2800 */
2801 int CDECL fgetc(FILE* file)
2802 {
2803 unsigned char *i;
2804 unsigned int j;
2805
2806 _lock_file(file);
2807 if (file->_cnt>0) {
2808 file->_cnt--;
2809 i = (unsigned char *)file->_ptr++;
2810 j = *i;
2811 } else
2812 j = _filbuf(file);
2813
2814 _unlock_file(file);
2815 return j;
2816 }
2817
2818 /*********************************************************************
2819 * _fgetchar (MSVCRT.@)
2820 */
2821 int CDECL _fgetchar(void)
2822 {
2823 return fgetc(stdin);
2824 }
2825
2826 /*********************************************************************
2827 * fgets (MSVCRT.@)
2828 */
2829 char * CDECL fgets(char *s, int size, FILE* file)
2830 {
2831 int cc = EOF;
2832 char * buf_start = s;
2833
2834 TRACE(":file(%p) fd (%d) str (%p) len (%d)\n",
2835 file,file->_file,s,size);
2836
2837 _lock_file(file);
2838
2839 while ((size >1) && (cc = fgetc(file)) != EOF && cc != '\n')
2840 {
2841 *s++ = (char)cc;
2842 size --;
2843 }
2844 if ((cc == EOF) && (s == buf_start)) /* If nothing read, return 0*/
2845 {
2846 TRACE(":nothing read\n");
2847 _unlock_file(file);
2848 return NULL;
2849 }
2850 if ((cc != EOF) && (size > 1))
2851 *s++ = cc;
2852 *s = '\0';
2853 TRACE(":got %s\n", debugstr_a(buf_start));
2854 _unlock_file(file);
2855 return buf_start;
2856 }
2857
2858 /*********************************************************************
2859 * fgetwc (MSVCRT.@)
2860 */
2861 wint_t CDECL fgetwc(FILE* file)
2862 {
2863 wint_t ret;
2864 int ch;
2865
2866 _lock_file(file);
2867
2868 if((get_ioinfo(file->_file)->exflag & (EF_UTF8 | EF_UTF16))
2869 || !(get_ioinfo(file->_file)->wxflag & WX_TEXT)) {
2870 char *p;
2871
2872 for(p=(char*)&ret; (wint_t*)p<&ret+1; p++) {
2873 ch = fgetc(file);
2874 if(ch == EOF) {
2875 ret = WEOF;
2876 break;
2877 }
2878 *p = (char)ch;
2879 }
2880 }else {
2881 char mbs[MB_LEN_MAX];
2882 int len = 0;
2883
2884 ch = fgetc(file);
2885 if(ch != EOF) {
2886 mbs[0] = (char)ch;
2887 if(isleadbyte((unsigned char)mbs[0])) {
2888 ch = fgetc(file);
2889 if(ch != EOF) {
2890 mbs[1] = (char)ch;
2891 len = 2;
2892 }
2893 }else {
2894 len = 1;
2895 }
2896 }
2897
2898 if(!len || mbtowc(&ret, mbs, len)==-1)
2899 ret = WEOF;
2900 }
2901
2902 _unlock_file(file);
2903 return ret;
2904 }
2905
2906 /*********************************************************************
2907 * _getw (MSVCRT.@)
2908 */
2909 int CDECL _getw(FILE* file)
2910 {
2911 char *ch;
2912 int i, k;
2913 unsigned int j;
2914 ch = (char *)&i;
2915
2916 _lock_file(file);
2917 for (j=0; j<sizeof(int); j++) {
2918 k = fgetc(file);
2919 if (k == EOF) {
2920 file->_flag |= _IOEOF;
2921 _unlock_file(file);
2922 return EOF;
2923 }
2924 ch[j] = k;
2925 }
2926
2927 _unlock_file(file);
2928 return i;
2929 }
2930
2931 /*********************************************************************
2932 * getwc (MSVCRT.@)
2933 */
2934 wint_t CDECL getwc(FILE* file)
2935 {
2936 return fgetwc(file);
2937 }
2938
2939 /*********************************************************************
2940 * _fgetwchar (MSVCRT.@)
2941 */
2942 wint_t CDECL _fgetwchar(void)
2943 {
2944 return fgetwc(stdin);
2945 }
2946
2947 /*********************************************************************
2948 * getwchar (MSVCRT.@)
2949 */
2950 wint_t CDECL getwchar(void)
2951 {
2952 return _fgetwchar();
2953 }
2954
2955 /*********************************************************************
2956 * fgetws (MSVCRT.@)
2957 */
2958 wchar_t * CDECL fgetws(wchar_t *s, int size, FILE* file)
2959 {
2960 int cc = WEOF;
2961 wchar_t * buf_start = s;
2962
2963 TRACE(":file(%p) fd (%d) str (%p) len (%d)\n",
2964 file,file->_file,s,size);
2965
2966 _lock_file(file);
2967
2968 while ((size >1) && (cc = fgetwc(file)) != WEOF && cc != '\n')
2969 {
2970 *s++ = (char)cc;
2971 size --;
2972 }
2973 if ((cc == WEOF) && (s == buf_start)) /* If nothing read, return 0*/
2974 {
2975 TRACE(":nothing read\n");
2976 _unlock_file(file);
2977 return NULL;
2978 }
2979 if ((cc != WEOF) && (size > 1))
2980 *s++ = cc;
2981 *s = 0;
2982 TRACE(":got %s\n", debugstr_w(buf_start));
2983 _unlock_file(file);
2984 return buf_start;
2985 }
2986
2987 /*********************************************************************
2988 * fwrite (MSVCRT.@)
2989 */
2990 size_t CDECL fwrite(const void *ptr, size_t size, size_t nmemb, FILE* file)
2991 {
2992 size_t wrcnt=size * nmemb;
2993 int written = 0;
2994 if (size == 0)
2995 return 0;
2996
2997 _lock_file(file);
2998
2999 while(wrcnt) {
3000 #ifndef __REACTOS__
3001 if(file->_cnt < 0) {
3002 WARN("negative file->_cnt value in %p\n", file);
3003 file->_flag |= MSVCRT__IOERR;
3004 break;
3005 } else
3006 #endif
3007 if(file->_cnt) {
3008 int pcnt=(file->_cnt>wrcnt)? wrcnt: file->_cnt;
3009 memcpy(file->_ptr, ptr, pcnt);
3010 file->_cnt -= pcnt;
3011 file->_ptr += pcnt;
3012 written += pcnt;
3013 wrcnt -= pcnt;
3014 ptr = (const char*)ptr + pcnt;
3015 } else if((file->_flag & _IONBF)
3016 || ((file->_flag & (_IOMYBUF | _USERBUF)) && wrcnt >= file->_bufsiz)
3017 || (!(file->_flag & (_IOMYBUF | _USERBUF)) && wrcnt >= MSVCRT_INTERNAL_BUFSIZ)) {
3018 size_t pcnt;
3019 int bufsiz;
3020
3021 if(file->_flag & _IONBF)
3022 bufsiz = 1;
3023 else if(!(file->_flag & (_IOMYBUF | _USERBUF)))
3024 bufsiz = MSVCRT_INTERNAL_BUFSIZ;
3025 else
3026 bufsiz = file->_bufsiz;
3027
3028 pcnt = (wrcnt / bufsiz) * bufsiz;
3029
3030 if(msvcrt_flush_buffer(file) == EOF)
3031 break;
3032
3033 if(_write(file->_file, ptr, pcnt) <= 0) {
3034 file->_flag |= _IOERR;
3035 break;
3036 }
3037 written += pcnt;
3038 wrcnt -= pcnt;
3039 ptr = (const char*)ptr + pcnt;
3040 } else {
3041 if(_flsbuf(*(const char*)ptr, file) == EOF)
3042 break;
3043 written++;
3044 wrcnt--;
3045 ptr = (const char*)ptr + 1;
3046 }
3047 }
3048
3049 _unlock_file(file);
3050 return written / size;
3051 }
3052
3053 /*********************************************************************
3054 * fputwc (MSVCRT.@)
3055 * FORKED for ReactOS, don't sync with Wine!
3056 * References:
3057 * - http://jira.reactos.org/browse/CORE-6495
3058 * - http://bugs.winehq.org/show_bug.cgi?id=8598
3059 */
3060 wint_t CDECL fputwc(wchar_t c, FILE* stream)
3061 {
3062 /* If this is a real file stream (and not some temporary one for
3063 sprintf-like functions), check whether it is opened in text mode.
3064 In this case, we have to perform an implicit conversion to ANSI. */
3065 if (!(stream->_flag & _IOSTRG) && get_ioinfo(stream->_file)->wxflag & WX_TEXT)
3066 {
3067 /* Convert to multibyte in text mode */
3068 char mbc[MB_LEN_MAX];
3069 int mb_return;
3070
3071 mb_return = wctomb(mbc, c);
3072
3073 if(mb_return == -1)
3074 return WEOF;
3075
3076 /* Output all characters */
3077 if (fwrite(mbc, mb_return, 1, stream) != 1)
3078 return WEOF;
3079 }
3080 else
3081 {
3082 if (fwrite(&c, sizeof(c), 1, stream) != 1)
3083 return WEOF;
3084 }
3085
3086 return c;
3087 }
3088
3089 /*********************************************************************
3090 * _fputwchar (MSVCRT.@)
3091 */
3092 wint_t CDECL _fputwchar(wint_t wc)
3093 {
3094 return fputwc(wc, stdout);
3095 }
3096
3097 /*********************************************************************
3098 * _wfsopen (MSVCRT.@)
3099 */
3100 FILE * CDECL _wfsopen(const wchar_t *path, const wchar_t *mode, int share)
3101 {
3102 FILE* file;
3103 int open_flags, stream_flags, fd;
3104
3105 TRACE("(%s,%s)\n", debugstr_w(path), debugstr_w(mode));
3106
3107 /* map mode string to open() flags. "man fopen" for possibilities. */
3108 if (get_flags(mode, &open_flags, &stream_flags) == -1)
3109 return NULL;
3110
3111 LOCK_FILES();
3112 fd = _wsopen(path, open_flags, share, _S_IREAD | _S_IWRITE);
3113 if (fd < 0)
3114 file = NULL;
3115 else if ((file = msvcrt_alloc_fp()) && msvcrt_init_fp(file, fd, stream_flags)
3116 != -1)
3117 TRACE(":fd (%d) mode (%s) FILE* (%p)\n", fd, debugstr_w(mode), file);
3118 else if (file)
3119 {
3120 file->_flag = 0;
3121 file = NULL;
3122 }
3123
3124 TRACE(":got (%p)\n",file);
3125 if (fd >= 0 && !file)
3126 _close(fd);
3127 UNLOCK_FILES();
3128 return file;
3129 }
3130
3131 /*********************************************************************
3132 * _fsopen (MSVCRT.@)
3133 */
3134 FILE * CDECL _fsopen(const char *path, const char *mode, int share)
3135 {
3136 FILE *ret;
3137 wchar_t *pathW = NULL, *modeW = NULL;
3138
3139 if (path && !(pathW = msvcrt_wstrdupa(path))) {
3140 _invalid_parameter(NULL, NULL, NULL, 0, 0);
3141 *_errno() = EINVAL;
3142 return NULL;
3143 }
3144 if (mode && !(modeW = msvcrt_wstrdupa(mode)))
3145 {
3146 free(pathW);
3147 _invalid_parameter(NULL, NULL, NULL, 0, 0);
3148 *_errno() = EINVAL;
3149 return NULL;
3150 }
3151
3152 ret = _wfsopen(pathW, modeW, share);
3153
3154 free(pathW);
3155 free(modeW);
3156 return ret;
3157 }
3158
3159 /*********************************************************************
3160 * fopen (MSVCRT.@)
3161 */
3162 FILE * CDECL fopen(const char *path, const char *mode)
3163 {
3164 return _fsopen( path, mode, _SH_DENYNO );
3165 }