server: Added access rights mapping to file objects.
[wine] / dlls / ntdll / file.c
1 /*
2  * Copyright 1999, 2000 Juergen Schmied
3  *
4  * This library is free software; you can redistribute it and/or
5  * modify it under the terms of the GNU Lesser General Public
6  * License as published by the Free Software Foundation; either
7  * version 2.1 of the License, or (at your option) any later version.
8  *
9  * This library is distributed in the hope that it will be useful,
10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
12  * Lesser General Public License for more details.
13  *
14  * You should have received a copy of the GNU Lesser General Public
15  * License along with this library; if not, write to the Free Software
16  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
17  */
18
19 #include "config.h"
20 #include "wine/port.h"
21
22 #include <stdlib.h>
23 #include <string.h>
24 #include <stdio.h>
25 #include <errno.h>
26 #include <assert.h>
27 #ifdef HAVE_UNISTD_H
28 # include <unistd.h>
29 #endif
30 #ifdef HAVE_SYS_ERRNO_H
31 #include <sys/errno.h>
32 #endif
33 #ifdef HAVE_LINUX_MAJOR_H
34 # include <linux/major.h>
35 #endif
36 #ifdef HAVE_SYS_STATVFS_H
37 # include <sys/statvfs.h>
38 #endif
39 #ifdef HAVE_SYS_PARAM_H
40 # include <sys/param.h>
41 #endif
42 #ifdef HAVE_SYS_TIME_H
43 # include <sys/time.h>
44 #endif
45 #ifdef HAVE_UTIME_H
46 # include <utime.h>
47 #endif
48 #ifdef STATFS_DEFINED_BY_SYS_VFS
49 # include <sys/vfs.h>
50 #else
51 # ifdef STATFS_DEFINED_BY_SYS_MOUNT
52 #  include <sys/mount.h>
53 # else
54 #  ifdef STATFS_DEFINED_BY_SYS_STATFS
55 #   include <sys/statfs.h>
56 #  endif
57 # endif
58 #endif
59
60 #ifdef HAVE_IOKIT_IOKITLIB_H
61 # include <IOKit/IOKitLib.h>
62 # include <CoreFoundation/CFNumber.h> /* for kCFBooleanTrue, kCFBooleanFalse */
63 # include <paths.h>
64 #endif
65
66 #define NONAMELESSUNION
67 #define NONAMELESSSTRUCT
68 #include "ntstatus.h"
69 #define WIN32_NO_STATUS
70 #include "wine/unicode.h"
71 #include "wine/debug.h"
72 #include "thread.h"
73 #include "wine/server.h"
74 #include "ntdll_misc.h"
75
76 #include "winternl.h"
77 #include "winioctl.h"
78
79 WINE_DEFAULT_DEBUG_CHANNEL(ntdll);
80
81 mode_t FILE_umask = 0;
82
83 #define SECSPERDAY         86400
84 #define SECS_1601_TO_1970  ((369 * 365 + 89) * (ULONGLONG)SECSPERDAY)
85
86 /**************************************************************************
87  *                 NtOpenFile                           [NTDLL.@]
88  *                 ZwOpenFile                           [NTDLL.@]
89  *
90  * Open a file.
91  *
92  * PARAMS
93  *  handle    [O] Variable that receives the file handle on return
94  *  access    [I] Access desired by the caller to the file
95  *  attr      [I] Structure describing the file to be opened
96  *  io        [O] Receives details about the result of the operation
97  *  sharing   [I] Type of shared access the caller requires
98  *  options   [I] Options for the file open
99  *
100  * RETURNS
101  *  Success: 0. FileHandle and IoStatusBlock are updated.
102  *  Failure: An NTSTATUS error code describing the error.
103  */
104 NTSTATUS WINAPI NtOpenFile( PHANDLE handle, ACCESS_MASK access,
105                             POBJECT_ATTRIBUTES attr, PIO_STATUS_BLOCK io,
106                             ULONG sharing, ULONG options )
107 {
108     return NtCreateFile( handle, access, attr, io, NULL, 0,
109                          sharing, FILE_OPEN, options, NULL, 0 );
110 }
111
112 /**************************************************************************
113  *              NtCreateFile                            [NTDLL.@]
114  *              ZwCreateFile                            [NTDLL.@]
115  *
116  * Either create a new file or directory, or open an existing file, device,
117  * directory or volume.
118  *
119  * PARAMS
120  *      handle       [O] Points to a variable which receives the file handle on return
121  *      access       [I] Desired access to the file
122  *      attr         [I] Structure describing the file
123  *      io           [O] Receives information about the operation on return
124  *      alloc_size   [I] Initial size of the file in bytes
125  *      attributes   [I] Attributes to create the file with
126  *      sharing      [I] Type of shared access the caller would like to the file
127  *      disposition  [I] Specifies what to do, depending on whether the file already exists
128  *      options      [I] Options for creating a new file
129  *      ea_buffer    [I] Pointer to an extended attributes buffer
130  *      ea_length    [I] Length of ea_buffer
131  *
132  * RETURNS
133  *  Success: 0. handle and io are updated.
134  *  Failure: An NTSTATUS error code describing the error.
135  */
136 NTSTATUS WINAPI NtCreateFile( PHANDLE handle, ACCESS_MASK access, POBJECT_ATTRIBUTES attr,
137                               PIO_STATUS_BLOCK io, PLARGE_INTEGER alloc_size,
138                               ULONG attributes, ULONG sharing, ULONG disposition,
139                               ULONG options, PVOID ea_buffer, ULONG ea_length )
140 {
141     static const WCHAR pipeW[] = {'\\','?','?','\\','p','i','p','e','\\'};
142     static const WCHAR mailslotW[] = {'\\','?','?','\\','M','A','I','L','S','L','O','T','\\'};
143     ANSI_STRING unix_name;
144     int created = FALSE;
145
146     TRACE("handle=%p access=%08lx name=%s objattr=%08lx root=%p sec=%p io=%p alloc_size=%p\n"
147           "attr=%08lx sharing=%08lx disp=%ld options=%08lx ea=%p.0x%08lx\n",
148           handle, access, debugstr_us(attr->ObjectName), attr->Attributes,
149           attr->RootDirectory, attr->SecurityDescriptor, io, alloc_size,
150           attributes, sharing, disposition, options, ea_buffer, ea_length );
151
152     if (!attr || !attr->ObjectName) return STATUS_INVALID_PARAMETER;
153
154     if (alloc_size) FIXME( "alloc_size not supported\n" );
155
156     /* check for named pipe */
157
158     if (attr->ObjectName->Length > sizeof(pipeW) &&
159         !memicmpW( attr->ObjectName->Buffer, pipeW, sizeof(pipeW)/sizeof(WCHAR) ))
160     {
161         SERVER_START_REQ( open_named_pipe )
162         {
163             req->access = access;
164             req->attributes = (attr) ? attr->Attributes : 0;
165             req->rootdir = attr ? attr->RootDirectory : 0;
166             req->flags = options;
167             wine_server_add_data( req, attr->ObjectName->Buffer,
168                                   attr->ObjectName->Length );
169             io->u.Status = wine_server_call( req );
170             *handle = reply->handle;
171         }
172         SERVER_END_REQ;
173         return io->u.Status;
174     }
175
176     /* check for mailslot */
177
178     if (attr->ObjectName->Length > sizeof(mailslotW) &&
179         !memicmpW( attr->ObjectName->Buffer, mailslotW, sizeof(mailslotW)/sizeof(WCHAR) ))
180     {
181         SERVER_START_REQ( open_mailslot )
182         {
183             req->access = access & GENERIC_WRITE;
184             req->attributes = (attr) ? attr->Attributes : 0;
185             req->rootdir = attr ? attr->RootDirectory : 0;
186             req->sharing = sharing;
187             wine_server_add_data( req, attr->ObjectName->Buffer,
188                                   attr->ObjectName->Length );
189             io->u.Status = wine_server_call( req );
190             *handle = reply->handle;
191         }
192         SERVER_END_REQ;
193         return io->u.Status;
194     }
195
196     if (attr->RootDirectory)
197     {
198         FIXME( "RootDirectory %p not supported\n", attr->RootDirectory );
199         return STATUS_OBJECT_NAME_NOT_FOUND;
200     }
201
202     io->u.Status = wine_nt_to_unix_file_name( attr->ObjectName, &unix_name, disposition,
203                                               !(attr->Attributes & OBJ_CASE_INSENSITIVE) );
204
205     if (io->u.Status == STATUS_BAD_DEVICE_TYPE)
206     {
207         SERVER_START_REQ( open_file_object )
208         {
209             req->access     = access;
210             req->attributes = attr->Attributes;
211             req->rootdir    = attr->RootDirectory;
212             req->sharing    = sharing;
213             wine_server_add_data( req, attr->ObjectName->Buffer, attr->ObjectName->Length );
214             io->u.Status = wine_server_call( req );
215             *handle = reply->handle;
216         }
217         SERVER_END_REQ;
218         return io->u.Status;
219     }
220
221     if (io->u.Status == STATUS_NO_SUCH_FILE &&
222         disposition != FILE_OPEN && disposition != FILE_OVERWRITE)
223     {
224         created = TRUE;
225         io->u.Status = STATUS_SUCCESS;
226     }
227
228     if (io->u.Status == STATUS_SUCCESS)
229     {
230         SERVER_START_REQ( create_file )
231         {
232             req->access     = access;
233             req->attributes = attr->Attributes;
234             req->sharing    = sharing;
235             req->create     = disposition;
236             req->options    = options;
237             req->attrs      = attributes;
238             wine_server_add_data( req, unix_name.Buffer, unix_name.Length );
239             io->u.Status = wine_server_call( req );
240             *handle = reply->handle;
241         }
242         SERVER_END_REQ;
243         RtlFreeAnsiString( &unix_name );
244     }
245     else WARN("%s not found (%lx)\n", debugstr_us(attr->ObjectName), io->u.Status );
246
247     if (io->u.Status == STATUS_SUCCESS)
248     {
249         if (created) io->Information = FILE_CREATED;
250         else switch(disposition)
251         {
252         case FILE_SUPERSEDE:
253             io->Information = FILE_SUPERSEDED;
254             break;
255         case FILE_CREATE:
256             io->Information = FILE_CREATED;
257             break;
258         case FILE_OPEN:
259         case FILE_OPEN_IF:
260             io->Information = FILE_OPENED;
261             break;
262         case FILE_OVERWRITE:
263         case FILE_OVERWRITE_IF:
264             io->Information = FILE_OVERWRITTEN;
265             break;
266         }
267     }
268
269     return io->u.Status;
270 }
271
272 /***********************************************************************
273  *                  Asynchronous file I/O                              *
274  */
275 static void WINAPI FILE_AsyncReadService(void*, PIO_STATUS_BLOCK, ULONG);
276 static void WINAPI FILE_AsyncWriteService(void*, PIO_STATUS_BLOCK, ULONG);
277
278 typedef struct async_fileio
279 {
280     HANDLE              handle;
281     PIO_APC_ROUTINE     apc;
282     void*               apc_user;
283     char*               buffer;
284     unsigned int        count;
285     off_t               offset;
286     int                 queue_apc_on_error;
287     BOOL                avail_mode;
288     int                 fd;
289     HANDLE              event;
290 } async_fileio;
291
292 static void fileio_terminate(async_fileio *fileio, IO_STATUS_BLOCK* iosb)
293 {
294     TRACE("data: %p\n", fileio);
295
296     wine_server_release_fd( fileio->handle, fileio->fd );
297     if ( fileio->event != INVALID_HANDLE_VALUE )
298         NtSetEvent( fileio->event, NULL );
299
300     if (fileio->apc && 
301         (iosb->u.Status == STATUS_SUCCESS || fileio->queue_apc_on_error))
302         fileio->apc( fileio->apc_user, iosb, iosb->Information );
303
304     RtlFreeHeap( GetProcessHeap(), 0, fileio );
305 }
306
307
308 static ULONG fileio_queue_async(async_fileio* fileio, IO_STATUS_BLOCK* iosb, 
309                                 BOOL do_read)
310 {
311     PIO_APC_ROUTINE     apc = do_read ? FILE_AsyncReadService : FILE_AsyncWriteService;
312     NTSTATUS            status;
313
314     SERVER_START_REQ( register_async )
315     {
316         req->handle = fileio->handle;
317         req->io_apc = apc;
318         req->io_sb = iosb;
319         req->io_user = fileio;
320         req->type = do_read ? ASYNC_TYPE_READ : ASYNC_TYPE_WRITE;
321         req->count = (fileio->count < iosb->Information) ? 
322             0 : fileio->count - iosb->Information;
323         status = wine_server_call( req );
324     }
325     SERVER_END_REQ;
326
327     if ( status ) iosb->u.Status = status;
328     if ( iosb->u.Status != STATUS_PENDING )
329     {
330         (apc)( fileio, iosb, iosb->u.Status );
331         return iosb->u.Status;
332     }
333     NtCurrentTeb()->num_async_io++;
334     return STATUS_SUCCESS;
335 }
336
337 /***********************************************************************
338  *           FILE_GetNtStatus(void)
339  *
340  * Retrieve the Nt Status code from errno.
341  * Try to be consistent with FILE_SetDosError().
342  */
343 NTSTATUS FILE_GetNtStatus(void)
344 {
345     int err = errno;
346
347     TRACE( "errno = %d\n", errno );
348     switch (err)
349     {
350     case EAGAIN:    return STATUS_SHARING_VIOLATION;
351     case EBADF:     return STATUS_INVALID_HANDLE;
352     case EBUSY:     return STATUS_DEVICE_BUSY;
353     case ENOSPC:    return STATUS_DISK_FULL;
354     case EPERM:
355     case EROFS:
356     case EACCES:    return STATUS_ACCESS_DENIED;
357     case ENOTDIR:   return STATUS_OBJECT_PATH_NOT_FOUND;
358     case ENOENT:    return STATUS_OBJECT_NAME_NOT_FOUND;
359     case EISDIR:    return STATUS_FILE_IS_A_DIRECTORY;
360     case EMFILE:
361     case ENFILE:    return STATUS_TOO_MANY_OPENED_FILES;
362     case EINVAL:    return STATUS_INVALID_PARAMETER;
363     case ENOTEMPTY: return STATUS_DIRECTORY_NOT_EMPTY;
364     case EPIPE:     return STATUS_PIPE_BROKEN;
365     case EIO:       return STATUS_DEVICE_NOT_READY;
366 #ifdef ENOMEDIUM
367     case ENOMEDIUM: return STATUS_NO_MEDIA_IN_DEVICE;
368 #endif
369     case ENOTTY:
370     case EOPNOTSUPP:return STATUS_NOT_SUPPORTED;
371     case ECONNRESET:return STATUS_PIPE_DISCONNECTED;
372     case ENOEXEC:   /* ?? */
373     case ESPIPE:    /* ?? */
374     case EEXIST:    /* ?? */
375     default:
376         FIXME( "Converting errno %d to STATUS_UNSUCCESSFUL\n", err );
377         return STATUS_UNSUCCESSFUL;
378     }
379 }
380
381 /***********************************************************************
382  *             FILE_AsyncReadService      (INTERNAL)
383  *
384  *  This function is called while the client is waiting on the
385  *  server, so we can't make any server calls here.
386  */
387 static void WINAPI FILE_AsyncReadService(void *user, PIO_STATUS_BLOCK iosb, ULONG status)
388 {
389     async_fileio *fileio = (async_fileio*)user;
390     int result;
391     int already = iosb->Information;
392
393     TRACE("%p %p 0x%lx\n", iosb, fileio->buffer, status);
394
395     switch (status)
396     {
397     case STATUS_ALERTED: /* got some new data */
398         if (iosb->u.Status != STATUS_PENDING) FIXME("unexpected status %08lx\n", iosb->u.Status);
399         /* check to see if the data is ready (non-blocking) */
400         if ( fileio->avail_mode )
401             result = read(fileio->fd, &fileio->buffer[already], 
402                           fileio->count - already);
403         else
404         {
405             result = pread(fileio->fd, &fileio->buffer[already],
406                            fileio->count - already,
407                            fileio->offset + already);
408             if ((result < 0) && (errno == ESPIPE))
409                 result = read(fileio->fd, &fileio->buffer[already], 
410                               fileio->count - already);
411         }
412
413         if (result < 0)
414         {
415             if (errno == EAGAIN || errno == EINTR)
416             {
417                 TRACE("Deferred read %d\n", errno);
418                 iosb->u.Status = STATUS_PENDING;
419             }
420             else /* check to see if the transfer is complete */
421                 iosb->u.Status = FILE_GetNtStatus();
422         }
423         else if (result == 0)
424         {
425             iosb->u.Status = iosb->Information ? STATUS_SUCCESS : STATUS_END_OF_FILE;
426         }
427         else
428         {
429             iosb->Information += result;
430             if (iosb->Information >= fileio->count || fileio->avail_mode)
431                 iosb->u.Status = STATUS_SUCCESS;
432             else
433             {
434                 /* if we only have to read the available data, and none is available,
435                  * simply cancel the request. If data was available, it has been read
436                  * while in by previous call (NtDelayExecution)
437                  */
438                 iosb->u.Status = (fileio->avail_mode) ? STATUS_SUCCESS : STATUS_PENDING;
439             }
440
441             TRACE("read %d more bytes %ld/%d so far (%s)\n",
442                   result, iosb->Information, fileio->count, 
443                   (iosb->u.Status == STATUS_SUCCESS) ? "success" : "pending");
444         }
445         /* queue another async operation ? */
446         if (iosb->u.Status == STATUS_PENDING)
447             fileio_queue_async(fileio, iosb, TRUE);
448         else
449             fileio_terminate(fileio, iosb);
450         break;
451     default:
452         iosb->u.Status = status;
453         fileio_terminate(fileio, iosb);
454         break;
455     }
456 }
457
458
459 /******************************************************************************
460  *  NtReadFile                                  [NTDLL.@]
461  *  ZwReadFile                                  [NTDLL.@]
462  *
463  * Read from an open file handle.
464  *
465  * PARAMS
466  *  FileHandle    [I] Handle returned from ZwOpenFile() or ZwCreateFile()
467  *  Event         [I] Event to signal upon completion (or NULL)
468  *  ApcRoutine    [I] Callback to call upon completion (or NULL)
469  *  ApcContext    [I] Context for ApcRoutine (or NULL)
470  *  IoStatusBlock [O] Receives information about the operation on return
471  *  Buffer        [O] Destination for the data read
472  *  Length        [I] Size of Buffer
473  *  ByteOffset    [O] Destination for the new file pointer position (or NULL)
474  *  Key           [O] Function unknown (may be NULL)
475  *
476  * RETURNS
477  *  Success: 0. IoStatusBlock is updated, and the Information member contains
478  *           The number of bytes read.
479  *  Failure: An NTSTATUS error code describing the error.
480  */
481 NTSTATUS WINAPI NtReadFile(HANDLE hFile, HANDLE hEvent,
482                            PIO_APC_ROUTINE apc, void* apc_user,
483                            PIO_STATUS_BLOCK io_status, void* buffer, ULONG length,
484                            PLARGE_INTEGER offset, PULONG key)
485 {
486     int unix_handle, flags;
487
488     TRACE("(%p,%p,%p,%p,%p,%p,0x%08lx,%p,%p),partial stub!\n",
489           hFile,hEvent,apc,apc_user,io_status,buffer,length,offset,key);
490
491     if (!io_status) return STATUS_ACCESS_VIOLATION;
492
493     io_status->Information = 0;
494     io_status->u.Status = wine_server_handle_to_fd( hFile, GENERIC_READ, &unix_handle, &flags );
495     if (io_status->u.Status) return io_status->u.Status;
496
497     if (flags & FD_FLAG_RECV_SHUTDOWN)
498     {
499         wine_server_release_fd( hFile, unix_handle );
500         return STATUS_PIPE_DISCONNECTED;
501     }
502
503     if (flags & FD_FLAG_TIMEOUT)
504     {
505         if (hEvent)
506         {
507             /* this shouldn't happen, but check it */
508             FIXME("NIY-hEvent\n");
509             wine_server_release_fd( hFile, unix_handle );
510             return STATUS_NOT_IMPLEMENTED;
511         }
512         io_status->u.Status = NtCreateEvent(&hEvent, EVENT_ALL_ACCESS, NULL, 0, 0);
513         if (io_status->u.Status)
514         {
515             wine_server_release_fd( hFile, unix_handle );
516             return io_status->u.Status;
517         }
518     }
519
520     if (flags & (FD_FLAG_OVERLAPPED|FD_FLAG_TIMEOUT))
521     {
522         async_fileio*   fileio;
523         NTSTATUS ret;
524
525         if (!(fileio = RtlAllocateHeap(GetProcessHeap(), 0, sizeof(async_fileio))))
526         {
527             wine_server_release_fd( hFile, unix_handle );
528             if (flags & FD_FLAG_TIMEOUT) NtClose(hEvent);
529             return STATUS_NO_MEMORY;
530         }
531         fileio->handle = hFile;
532         fileio->count = length;
533         if ( offset == NULL ) 
534             fileio->offset = 0;
535         else
536         {
537             fileio->offset = offset->QuadPart;
538             if (offset->u.HighPart && fileio->offset == offset->u.LowPart)
539                 FIXME("High part of offset is lost\n");
540         } 
541         fileio->apc = apc;
542         fileio->apc_user = apc_user;
543         fileio->buffer = buffer;
544         fileio->queue_apc_on_error = 0;
545         fileio->avail_mode = (flags & FD_FLAG_AVAILABLE);
546         fileio->fd = unix_handle;  /* FIXME */
547         fileio->event = hEvent;
548         NtResetEvent(hEvent, NULL);
549
550         io_status->u.Status = STATUS_PENDING;
551         ret = fileio_queue_async(fileio, io_status, TRUE);
552         if (ret != STATUS_SUCCESS)
553         {
554             wine_server_release_fd( hFile, unix_handle );
555             if (flags & FD_FLAG_TIMEOUT) NtClose(hEvent);
556             return ret;
557         }
558         if (flags & FD_FLAG_TIMEOUT)
559         {
560             do
561             {
562                 ret = NtWaitForSingleObject(hEvent, TRUE, NULL);
563             }
564             while (ret == STATUS_USER_APC && io_status->u.Status == STATUS_PENDING);
565             NtClose(hEvent);
566             if (ret != STATUS_USER_APC)
567                 fileio->queue_apc_on_error = 1;
568         }
569         else
570         {
571             LARGE_INTEGER   timeout;
572
573             /* let some APC be run, this will read some already pending data */
574             timeout.u.LowPart = timeout.u.HighPart = 0;
575             ret = NtDelayExecution( TRUE, &timeout );
576             /* the apc didn't run and therefore the completion routine now
577              * needs to be sent errors.
578              * Note that there is no race between setting this flag and
579              * returning errors because apc's are run only during alertable
580              * waits */
581             if (ret != STATUS_USER_APC)
582                 fileio->queue_apc_on_error = 1;
583         }
584         TRACE("= 0x%08lx\n", io_status->u.Status);
585         return io_status->u.Status;
586     }
587
588     if (offset)
589     {
590         FILE_POSITION_INFORMATION   fpi;
591
592         fpi.CurrentByteOffset = *offset;
593         io_status->u.Status = NtSetInformationFile(hFile, io_status, &fpi, sizeof(fpi), 
594                                                    FilePositionInformation);
595         if (io_status->u.Status)
596         {
597             wine_server_release_fd( hFile, unix_handle );
598             return io_status->u.Status;
599         }
600     }
601     /* code for synchronous reads */
602     while ((io_status->Information = read( unix_handle, buffer, length )) == -1)
603     {
604         if ((errno == EAGAIN) || (errno == EINTR)) continue;
605         if (errno == EFAULT)
606         {
607             io_status->Information = 0;
608             io_status->u.Status = STATUS_ACCESS_VIOLATION;
609         }
610         else io_status->u.Status = FILE_GetNtStatus();
611         break;
612     }
613     if (io_status->u.Status == STATUS_SUCCESS && io_status->Information == 0)
614     {
615         struct stat st;
616         if (fstat( unix_handle, &st ) != -1 && S_ISSOCK( st.st_mode ))
617             io_status->u.Status = STATUS_PIPE_BROKEN;
618         else
619             io_status->u.Status = STATUS_END_OF_FILE;
620     }
621     wine_server_release_fd( hFile, unix_handle );
622     TRACE("= 0x%08lx (%lu)\n", io_status->u.Status, io_status->Information);
623     return io_status->u.Status;
624 }
625
626 /***********************************************************************
627  *             FILE_AsyncWriteService      (INTERNAL)
628  *
629  *  This function is called while the client is waiting on the
630  *  server, so we can't make any server calls here.
631  */
632 static void WINAPI FILE_AsyncWriteService(void *ovp, IO_STATUS_BLOCK *iosb, ULONG status)
633 {
634     async_fileio *fileio = (async_fileio *) ovp;
635     int result;
636     int already = iosb->Information;
637
638     TRACE("(%p %p 0x%lx)\n",iosb, fileio->buffer, status);
639
640     switch (status)
641     {
642     case STATUS_ALERTED:
643         /* write some data (non-blocking) */
644         if ( fileio->avail_mode )
645             result = write(fileio->fd, &fileio->buffer[already], 
646                            fileio->count - already);
647         else
648         {
649             result = pwrite(fileio->fd, &fileio->buffer[already], 
650                             fileio->count - already, fileio->offset + already);
651             if ((result < 0) && (errno == ESPIPE))
652                 result = write(fileio->fd, &fileio->buffer[already], 
653                                fileio->count - already);
654         }
655
656         if (result < 0)
657         {
658             if (errno == EAGAIN || errno == EINTR) iosb->u.Status = STATUS_PENDING;
659             else iosb->u.Status = FILE_GetNtStatus();
660         }
661         else
662         {
663             iosb->Information += result;
664             iosb->u.Status = (iosb->Information < fileio->count) ? STATUS_PENDING : STATUS_SUCCESS;
665             TRACE("wrote %d more bytes %ld/%d so far\n", 
666                   result, iosb->Information, fileio->count);
667         }
668         if (iosb->u.Status == STATUS_PENDING)
669             fileio_queue_async(fileio, iosb, FALSE);
670         else
671             fileio_terminate(fileio, iosb);
672         break;
673     default:
674         iosb->u.Status = status;
675         fileio_terminate(fileio, iosb);
676         break;
677     }
678 }
679
680 /******************************************************************************
681  *  NtWriteFile                                 [NTDLL.@]
682  *  ZwWriteFile                                 [NTDLL.@]
683  *
684  * Write to an open file handle.
685  *
686  * PARAMS
687  *  FileHandle    [I] Handle returned from ZwOpenFile() or ZwCreateFile()
688  *  Event         [I] Event to signal upon completion (or NULL)
689  *  ApcRoutine    [I] Callback to call upon completion (or NULL)
690  *  ApcContext    [I] Context for ApcRoutine (or NULL)
691  *  IoStatusBlock [O] Receives information about the operation on return
692  *  Buffer        [I] Source for the data to write
693  *  Length        [I] Size of Buffer
694  *  ByteOffset    [O] Destination for the new file pointer position (or NULL)
695  *  Key           [O] Function unknown (may be NULL)
696  *
697  * RETURNS
698  *  Success: 0. IoStatusBlock is updated, and the Information member contains
699  *           The number of bytes written.
700  *  Failure: An NTSTATUS error code describing the error.
701  */
702 NTSTATUS WINAPI NtWriteFile(HANDLE hFile, HANDLE hEvent,
703                             PIO_APC_ROUTINE apc, void* apc_user,
704                             PIO_STATUS_BLOCK io_status, 
705                             const void* buffer, ULONG length,
706                             PLARGE_INTEGER offset, PULONG key)
707 {
708     int unix_handle, flags;
709
710     TRACE("(%p,%p,%p,%p,%p,%p,0x%08lx,%p,%p)!\n",
711           hFile,hEvent,apc,apc_user,io_status,buffer,length,offset,key);
712
713     if (!io_status) return STATUS_ACCESS_VIOLATION;
714
715     io_status->Information = 0;
716     io_status->u.Status = wine_server_handle_to_fd( hFile, GENERIC_WRITE, &unix_handle, &flags );
717     if (io_status->u.Status) return io_status->u.Status;
718
719     if (flags & FD_FLAG_SEND_SHUTDOWN)
720     {
721         wine_server_release_fd( hFile, unix_handle );
722         return STATUS_PIPE_DISCONNECTED;
723     }
724
725     if (flags & FD_FLAG_TIMEOUT)
726     {
727         if (hEvent)
728         {
729             /* this shouldn't happen, but check it */
730             FIXME("NIY-hEvent\n");
731             wine_server_release_fd( hFile, unix_handle );
732             return STATUS_NOT_IMPLEMENTED;
733         }
734         io_status->u.Status = NtCreateEvent(&hEvent, EVENT_ALL_ACCESS, NULL, 0, 0);
735         if (io_status->u.Status)
736         {
737             wine_server_release_fd( hFile, unix_handle );
738             return io_status->u.Status;
739         }
740     }
741
742     if (flags & (FD_FLAG_OVERLAPPED|FD_FLAG_TIMEOUT))
743     {
744         async_fileio*   fileio;
745         NTSTATUS ret;
746
747         if (!(fileio = RtlAllocateHeap(GetProcessHeap(), 0, sizeof(async_fileio))))
748         {
749             wine_server_release_fd( hFile, unix_handle );
750             if (flags & FD_FLAG_TIMEOUT) NtClose(hEvent);
751             return STATUS_NO_MEMORY;
752         }
753         fileio->handle = hFile;
754         fileio->count = length;
755         if (offset)
756         {
757             fileio->offset = offset->QuadPart;
758             if (offset->u.HighPart && fileio->offset == offset->u.LowPart)
759                 FIXME("High part of offset is lost\n");
760         }
761         else  
762         {
763             fileio->offset = 0;
764         }
765         fileio->apc = apc;
766         fileio->apc_user = apc_user;
767         fileio->buffer = (void*)buffer;
768         fileio->queue_apc_on_error = 0;
769         fileio->avail_mode = (flags & FD_FLAG_AVAILABLE);
770         fileio->fd = unix_handle;  /* FIXME */
771         fileio->event = hEvent;
772         NtResetEvent(hEvent, NULL);
773
774         io_status->Information = 0;
775         io_status->u.Status = STATUS_PENDING;
776         ret = fileio_queue_async(fileio, io_status, FALSE);
777         if (ret != STATUS_SUCCESS)
778         {
779             wine_server_release_fd( hFile, unix_handle );
780             if (flags & FD_FLAG_TIMEOUT) NtClose(hEvent);
781             return ret;
782         }
783         if (flags & FD_FLAG_TIMEOUT)
784         {
785             do
786             {
787                 ret = NtWaitForSingleObject(hEvent, TRUE, NULL);
788             }
789             while (ret == STATUS_USER_APC && io_status->u.Status == STATUS_PENDING);
790             NtClose(hEvent);
791             if (ret != STATUS_USER_APC)
792                 fileio->queue_apc_on_error = 1;
793         }
794         else
795         {
796             LARGE_INTEGER   timeout;
797
798             /* let some APC be run, this will write as much data as possible */
799             timeout.u.LowPart = timeout.u.HighPart = 0;
800             ret = NtDelayExecution( TRUE, &timeout );
801             /* the apc didn't run and therefore the completion routine now
802              * needs to be sent errors.
803              * Note that there is no race between setting this flag and
804              * returning errors because apc's are run only during alertable
805              * waits */
806             if (ret != STATUS_USER_APC)
807                 fileio->queue_apc_on_error = 1;
808         }
809         return io_status->u.Status;
810     }
811
812     if (offset)
813     {
814         FILE_POSITION_INFORMATION   fpi;
815
816         fpi.CurrentByteOffset = *offset;
817         io_status->u.Status = NtSetInformationFile(hFile, io_status, &fpi, sizeof(fpi),
818                                                    FilePositionInformation);
819         if (io_status->u.Status)
820         {
821             wine_server_release_fd( hFile, unix_handle );
822             return io_status->u.Status;
823         }
824     }
825
826     /* synchronous file write */
827     while ((io_status->Information = write( unix_handle, buffer, length )) == -1)
828     {
829         if ((errno == EAGAIN) || (errno == EINTR)) continue;
830         if (errno == EFAULT)
831         {
832             io_status->Information = 0;
833             io_status->u.Status = STATUS_INVALID_USER_BUFFER;
834         }
835         else if (errno == ENOSPC) io_status->u.Status = STATUS_DISK_FULL;
836         else io_status->u.Status = FILE_GetNtStatus();
837         break;
838     }
839     wine_server_release_fd( hFile, unix_handle );
840     return io_status->u.Status;
841 }
842
843 /**************************************************************************
844  *              NtDeviceIoControlFile                   [NTDLL.@]
845  *              ZwDeviceIoControlFile                   [NTDLL.@]
846  *
847  * Perform an I/O control operation on an open file handle.
848  *
849  * PARAMS
850  *  DeviceHandle     [I] Handle returned from ZwOpenFile() or ZwCreateFile()
851  *  Event            [I] Event to signal upon completion (or NULL)
852  *  ApcRoutine       [I] Callback to call upon completion (or NULL)
853  *  ApcContext       [I] Context for ApcRoutine (or NULL)
854  *  IoStatusBlock    [O] Receives information about the operation on return
855  *  IoControlCode    [I] Control code for the operation to perform
856  *  InputBuffer      [I] Source for any input data required (or NULL)
857  *  InputBufferSize  [I] Size of InputBuffer
858  *  OutputBuffer     [O] Source for any output data returned (or NULL)
859  *  OutputBufferSize [I] Size of OutputBuffer
860  *
861  * RETURNS
862  *  Success: 0. IoStatusBlock is updated.
863  *  Failure: An NTSTATUS error code describing the error.
864  */
865 NTSTATUS WINAPI NtDeviceIoControlFile(HANDLE DeviceHandle, HANDLE hEvent,
866                                       PIO_APC_ROUTINE UserApcRoutine, 
867                                       PVOID UserApcContext,
868                                       PIO_STATUS_BLOCK IoStatusBlock,
869                                       ULONG IoControlCode,
870                                       PVOID InputBuffer,
871                                       ULONG InputBufferSize,
872                                       PVOID OutputBuffer,
873                                       ULONG OutputBufferSize)
874 {
875     TRACE("(%p,%p,%p,%p,%p,0x%08lx,%p,0x%08lx,%p,0x%08lx)\n",
876           DeviceHandle, hEvent, UserApcRoutine, UserApcContext,
877           IoStatusBlock, IoControlCode, 
878           InputBuffer, InputBufferSize, OutputBuffer, OutputBufferSize);
879
880     if (CDROM_DeviceIoControl(DeviceHandle, hEvent,
881                               UserApcRoutine, UserApcContext,
882                               IoStatusBlock, IoControlCode,
883                               InputBuffer, InputBufferSize,
884                               OutputBuffer, OutputBufferSize) == STATUS_NO_SUCH_DEVICE)
885     {
886         /* it wasn't a CDROM */
887         FIXME("Unimplemented dwIoControlCode=%08lx\n", IoControlCode);
888         IoStatusBlock->u.Status = STATUS_NOT_IMPLEMENTED;
889         IoStatusBlock->Information = 0;
890         if (hEvent) NtSetEvent(hEvent, NULL);
891     }
892     return IoStatusBlock->u.Status;
893 }
894
895 /***********************************************************************
896  *           pipe_completion_wait   (Internal)
897  */
898 static void CALLBACK pipe_completion_wait(HANDLE event, PIO_STATUS_BLOCK iosb, ULONG status)
899 {
900     TRACE("for %p/%p, status=%08lx\n", event, iosb, status);
901
902     if (iosb)
903         iosb->u.Status = status;
904     NtSetEvent(event, NULL);
905     TRACE("done\n");
906 }
907
908 /**************************************************************************
909  *              NtFsControlFile                 [NTDLL.@]
910  *              ZwFsControlFile                 [NTDLL.@]
911  *
912  * Perform a file system control operation on an open file handle.
913  *
914  * PARAMS
915  *  DeviceHandle     [I] Handle returned from ZwOpenFile() or ZwCreateFile()
916  *  Event            [I] Event to signal upon completion (or NULL)
917  *  ApcRoutine       [I] Callback to call upon completion (or NULL)
918  *  ApcContext       [I] Context for ApcRoutine (or NULL)
919  *  IoStatusBlock    [O] Receives information about the operation on return
920  *  FsControlCode    [I] Control code for the operation to perform
921  *  InputBuffer      [I] Source for any input data required (or NULL)
922  *  InputBufferSize  [I] Size of InputBuffer
923  *  OutputBuffer     [O] Source for any output data returned (or NULL)
924  *  OutputBufferSize [I] Size of OutputBuffer
925  *
926  * RETURNS
927  *  Success: 0. IoStatusBlock is updated.
928  *  Failure: An NTSTATUS error code describing the error.
929  */
930 NTSTATUS WINAPI NtFsControlFile(HANDLE DeviceHandle, HANDLE Event OPTIONAL, PIO_APC_ROUTINE ApcRoutine,
931                                 PVOID ApcContext, PIO_STATUS_BLOCK IoStatusBlock, ULONG FsControlCode,
932                                 PVOID InputBuffer, ULONG InputBufferSize, PVOID OutputBuffer, ULONG OutputBufferSize)
933 {
934     NTSTATUS ret;
935
936     TRACE("(%p,%p,%p,%p,%p,0x%08lx,%p,0x%08lx,%p,0x%08lx)\n",
937     DeviceHandle,Event,ApcRoutine,ApcContext,IoStatusBlock,FsControlCode,
938     InputBuffer,InputBufferSize,OutputBuffer,OutputBufferSize);
939
940     if(!IoStatusBlock) return STATUS_INVALID_PARAMETER;
941
942     switch(FsControlCode)
943     {
944         case FSCTL_DISMOUNT_VOLUME:
945             ret = DIR_unmount_device( DeviceHandle );
946             break;
947
948         case FSCTL_PIPE_LISTEN :
949         {
950             HANDLE internal_event;
951
952             if(!Event)
953             {
954                 OBJECT_ATTRIBUTES obj;
955                 InitializeObjectAttributes(&obj, NULL, 0, 0, NULL);
956                 ret = NtCreateEvent(&internal_event, EVENT_ALL_ACCESS, &obj, FALSE, FALSE);
957                 if(ret != STATUS_SUCCESS) return ret;
958             }
959
960             SERVER_START_REQ(connect_named_pipe)
961             {
962                 req->handle = DeviceHandle;
963                 req->event = Event ? Event : internal_event;
964                 req->func = pipe_completion_wait;
965                 ret = wine_server_call(req);
966             }
967             SERVER_END_REQ;
968
969             if(ret == STATUS_SUCCESS)
970             {
971                 if(Event)
972                     ret = STATUS_PENDING;
973                 else
974                 {
975                     do
976                         ret = NtWaitForSingleObject(internal_event, TRUE, NULL);
977                     while(ret == STATUS_USER_APC);
978                     NtClose(internal_event);
979                 }
980             }
981             break;
982         }
983         case FSCTL_PIPE_DISCONNECT :
984             SERVER_START_REQ(disconnect_named_pipe)
985             {
986                 req->handle = DeviceHandle;
987                 ret = wine_server_call(req);
988                 if (!ret && reply->fd != -1) close(reply->fd);
989             }
990             SERVER_END_REQ;
991             break;
992         default :
993             FIXME("Unsupported FsControlCode %lx\n", FsControlCode);
994             ret = STATUS_NOT_SUPPORTED;
995             break;
996     }
997     IoStatusBlock->u.Status = ret;
998     return ret;
999 }
1000
1001 /******************************************************************************
1002  *  NtSetVolumeInformationFile          [NTDLL.@]
1003  *  ZwSetVolumeInformationFile          [NTDLL.@]
1004  *
1005  * Set volume information for an open file handle.
1006  *
1007  * PARAMS
1008  *  FileHandle         [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1009  *  IoStatusBlock      [O] Receives information about the operation on return
1010  *  FsInformation      [I] Source for volume information
1011  *  Length             [I] Size of FsInformation
1012  *  FsInformationClass [I] Type of volume information to set
1013  *
1014  * RETURNS
1015  *  Success: 0. IoStatusBlock is updated.
1016  *  Failure: An NTSTATUS error code describing the error.
1017  */
1018 NTSTATUS WINAPI NtSetVolumeInformationFile(
1019         IN HANDLE FileHandle,
1020         PIO_STATUS_BLOCK IoStatusBlock,
1021         PVOID FsInformation,
1022         ULONG Length,
1023         FS_INFORMATION_CLASS FsInformationClass)
1024 {
1025         FIXME("(%p,%p,%p,0x%08lx,0x%08x) stub\n",
1026         FileHandle,IoStatusBlock,FsInformation,Length,FsInformationClass);
1027         return 0;
1028 }
1029
1030 /******************************************************************************
1031  *  NtQueryInformationFile              [NTDLL.@]
1032  *  ZwQueryInformationFile              [NTDLL.@]
1033  *
1034  * Get information about an open file handle.
1035  *
1036  * PARAMS
1037  *  hFile    [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1038  *  io       [O] Receives information about the operation on return
1039  *  ptr      [O] Destination for file information
1040  *  len      [I] Size of FileInformation
1041  *  class    [I] Type of file information to get
1042  *
1043  * RETURNS
1044  *  Success: 0. IoStatusBlock and FileInformation are updated.
1045  *  Failure: An NTSTATUS error code describing the error.
1046  */
1047 NTSTATUS WINAPI NtQueryInformationFile( HANDLE hFile, PIO_STATUS_BLOCK io,
1048                                         PVOID ptr, LONG len, FILE_INFORMATION_CLASS class )
1049 {
1050     static const size_t info_sizes[] =
1051     {
1052         0,
1053         sizeof(FILE_DIRECTORY_INFORMATION),            /* FileDirectoryInformation */
1054         sizeof(FILE_FULL_DIRECTORY_INFORMATION),       /* FileFullDirectoryInformation */
1055         sizeof(FILE_BOTH_DIRECTORY_INFORMATION),       /* FileBothDirectoryInformation */
1056         sizeof(FILE_BASIC_INFORMATION),                /* FileBasicInformation */
1057         sizeof(FILE_STANDARD_INFORMATION),             /* FileStandardInformation */
1058         sizeof(FILE_INTERNAL_INFORMATION),             /* FileInternalInformation */
1059         sizeof(FILE_EA_INFORMATION),                   /* FileEaInformation */
1060         sizeof(FILE_ACCESS_INFORMATION),               /* FileAccessInformation */
1061         sizeof(FILE_NAME_INFORMATION)-sizeof(WCHAR),   /* FileNameInformation */
1062         sizeof(FILE_RENAME_INFORMATION)-sizeof(WCHAR), /* FileRenameInformation */
1063         0,                                             /* FileLinkInformation */
1064         sizeof(FILE_NAMES_INFORMATION)-sizeof(WCHAR),  /* FileNamesInformation */
1065         sizeof(FILE_DISPOSITION_INFORMATION),          /* FileDispositionInformation */
1066         sizeof(FILE_POSITION_INFORMATION),             /* FilePositionInformation */
1067         sizeof(FILE_FULL_EA_INFORMATION),              /* FileFullEaInformation */
1068         sizeof(FILE_MODE_INFORMATION),                 /* FileModeInformation */
1069         sizeof(FILE_ALIGNMENT_INFORMATION),            /* FileAlignmentInformation */
1070         sizeof(FILE_ALL_INFORMATION)-sizeof(WCHAR),    /* FileAllInformation */
1071         sizeof(FILE_ALLOCATION_INFORMATION),           /* FileAllocationInformation */
1072         sizeof(FILE_END_OF_FILE_INFORMATION),          /* FileEndOfFileInformation */
1073         0,                                             /* FileAlternateNameInformation */
1074         sizeof(FILE_STREAM_INFORMATION)-sizeof(WCHAR), /* FileStreamInformation */
1075         0,                                             /* FilePipeInformation */
1076         0,                                             /* FilePipeLocalInformation */
1077         0,                                             /* FilePipeRemoteInformation */
1078         sizeof(FILE_MAILSLOT_QUERY_INFORMATION),       /* FileMailslotQueryInformation */
1079         0,                                             /* FileMailslotSetInformation */
1080         0,                                             /* FileCompressionInformation */
1081         0,                                             /* FileObjectIdInformation */
1082         0,                                             /* FileCompletionInformation */
1083         0,                                             /* FileMoveClusterInformation */
1084         0,                                             /* FileQuotaInformation */
1085         0,                                             /* FileReparsePointInformation */
1086         0,                                             /* FileNetworkOpenInformation */
1087         0,                                             /* FileAttributeTagInformation */
1088         0                                              /* FileTrackingInformation */
1089     };
1090
1091     struct stat st;
1092     int fd;
1093
1094     TRACE("(%p,%p,%p,0x%08lx,0x%08x)\n", hFile, io, ptr, len, class);
1095
1096     io->Information = 0;
1097
1098     if (class <= 0 || class >= FileMaximumInformation)
1099         return io->u.Status = STATUS_INVALID_INFO_CLASS;
1100     if (!info_sizes[class])
1101     {
1102         FIXME("Unsupported class (%d)\n", class);
1103         return io->u.Status = STATUS_NOT_IMPLEMENTED;
1104     }
1105     if (len < info_sizes[class])
1106         return io->u.Status = STATUS_INFO_LENGTH_MISMATCH;
1107
1108     if ((io->u.Status = wine_server_handle_to_fd( hFile, 0, &fd, NULL )))
1109         return io->u.Status;
1110
1111     switch (class)
1112     {
1113     case FileBasicInformation:
1114         {
1115             FILE_BASIC_INFORMATION *info = ptr;
1116
1117             if (fstat( fd, &st ) == -1)
1118                 io->u.Status = FILE_GetNtStatus();
1119             else if (!S_ISREG(st.st_mode) && !S_ISDIR(st.st_mode))
1120                 io->u.Status = STATUS_INVALID_INFO_CLASS;
1121             else
1122             {
1123                 if (S_ISDIR(st.st_mode)) info->FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
1124                 else info->FileAttributes = FILE_ATTRIBUTE_ARCHIVE;
1125                 if (!(st.st_mode & (S_IWUSR | S_IWGRP | S_IWOTH)))
1126                     info->FileAttributes |= FILE_ATTRIBUTE_READONLY;
1127                 RtlSecondsSince1970ToTime( st.st_mtime, &info->CreationTime);
1128                 RtlSecondsSince1970ToTime( st.st_mtime, &info->LastWriteTime);
1129                 RtlSecondsSince1970ToTime( st.st_ctime, &info->ChangeTime);
1130                 RtlSecondsSince1970ToTime( st.st_atime, &info->LastAccessTime);
1131             }
1132         }
1133         break;
1134     case FileStandardInformation:
1135         {
1136             FILE_STANDARD_INFORMATION *info = ptr;
1137
1138             if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1139             else
1140             {
1141                 if ((info->Directory = S_ISDIR(st.st_mode)))
1142                 {
1143                     info->AllocationSize.QuadPart = 0;
1144                     info->EndOfFile.QuadPart      = 0;
1145                     info->NumberOfLinks           = 1;
1146                     info->DeletePending           = FALSE;
1147                 }
1148                 else
1149                 {
1150                     info->AllocationSize.QuadPart = (ULONGLONG)st.st_blocks * 512;
1151                     info->EndOfFile.QuadPart      = st.st_size;
1152                     info->NumberOfLinks           = st.st_nlink;
1153                     info->DeletePending           = FALSE; /* FIXME */
1154                 }
1155             }
1156         }
1157         break;
1158     case FilePositionInformation:
1159         {
1160             FILE_POSITION_INFORMATION *info = ptr;
1161             off_t res = lseek( fd, 0, SEEK_CUR );
1162             if (res == (off_t)-1) io->u.Status = FILE_GetNtStatus();
1163             else info->CurrentByteOffset.QuadPart = res;
1164         }
1165         break;
1166     case FileInternalInformation:
1167         {
1168             FILE_INTERNAL_INFORMATION *info = ptr;
1169
1170             if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1171             else info->IndexNumber.QuadPart = st.st_ino;
1172         }
1173         break;
1174     case FileEaInformation:
1175         {
1176             FILE_EA_INFORMATION *info = ptr;
1177             info->EaSize = 0;
1178         }
1179         break;
1180     case FileEndOfFileInformation:
1181         {
1182             FILE_END_OF_FILE_INFORMATION *info = ptr;
1183
1184             if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1185             else info->EndOfFile.QuadPart = S_ISDIR(st.st_mode) ? 0 : st.st_size;
1186         }
1187         break;
1188     case FileAllInformation:
1189         {
1190             FILE_ALL_INFORMATION *info = ptr;
1191
1192             if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1193             else if (!S_ISREG(st.st_mode) && !S_ISDIR(st.st_mode))
1194                 io->u.Status = STATUS_INVALID_INFO_CLASS;
1195             else
1196             {
1197                 if ((info->StandardInformation.Directory = S_ISDIR(st.st_mode)))
1198                 {
1199                     info->BasicInformation.FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
1200                     info->StandardInformation.AllocationSize.QuadPart = 0;
1201                     info->StandardInformation.EndOfFile.QuadPart      = 0;
1202                     info->StandardInformation.NumberOfLinks           = 1;
1203                     info->StandardInformation.DeletePending           = FALSE;
1204                 }
1205                 else
1206                 {
1207                     info->BasicInformation.FileAttributes = FILE_ATTRIBUTE_ARCHIVE;
1208                     info->StandardInformation.AllocationSize.QuadPart = (ULONGLONG)st.st_blocks * 512;
1209                     info->StandardInformation.EndOfFile.QuadPart      = st.st_size;
1210                     info->StandardInformation.NumberOfLinks           = st.st_nlink;
1211                     info->StandardInformation.DeletePending           = FALSE; /* FIXME */
1212                 }
1213                 if (!(st.st_mode & (S_IWUSR | S_IWGRP | S_IWOTH)))
1214                     info->BasicInformation.FileAttributes |= FILE_ATTRIBUTE_READONLY;
1215                 RtlSecondsSince1970ToTime( st.st_mtime, &info->BasicInformation.CreationTime);
1216                 RtlSecondsSince1970ToTime( st.st_mtime, &info->BasicInformation.LastWriteTime);
1217                 RtlSecondsSince1970ToTime( st.st_ctime, &info->BasicInformation.ChangeTime);
1218                 RtlSecondsSince1970ToTime( st.st_atime, &info->BasicInformation.LastAccessTime);
1219                 info->InternalInformation.IndexNumber.QuadPart = st.st_ino;
1220                 info->EaInformation.EaSize = 0;
1221                 info->AccessInformation.AccessFlags = 0;  /* FIXME */
1222                 info->PositionInformation.CurrentByteOffset.QuadPart = lseek( fd, 0, SEEK_CUR );
1223                 info->ModeInformation.Mode = 0;  /* FIXME */
1224                 info->AlignmentInformation.AlignmentRequirement = 1;  /* FIXME */
1225                 info->NameInformation.FileNameLength = 0;
1226                 io->Information = sizeof(*info) - sizeof(WCHAR);
1227             }
1228         }
1229         break;
1230     case FileMailslotQueryInformation:
1231         {
1232             FILE_MAILSLOT_QUERY_INFORMATION *info = ptr;
1233
1234             SERVER_START_REQ( set_mailslot_info )
1235             {
1236                 req->handle = hFile;
1237                 req->flags = 0;
1238                 io->u.Status = wine_server_call( req );
1239                 if( io->u.Status == STATUS_SUCCESS )
1240                 {
1241                     info->MaximumMessageSize = reply->max_msgsize;
1242                     info->MailslotQuota = 0;
1243                     info->NextMessageSize = reply->next_msgsize;
1244                     info->MessagesAvailable = reply->msg_count;
1245                     info->ReadTimeout.QuadPart = reply->read_timeout * -10000;
1246                 }
1247             }
1248             SERVER_END_REQ;
1249         }
1250         break;
1251     default:
1252         FIXME("Unsupported class (%d)\n", class);
1253         io->u.Status = STATUS_NOT_IMPLEMENTED;
1254         break;
1255     }
1256     wine_server_release_fd( hFile, fd );
1257     if (io->u.Status == STATUS_SUCCESS && !io->Information) io->Information = info_sizes[class];
1258     return io->u.Status;
1259 }
1260
1261 /******************************************************************************
1262  *  NtSetInformationFile                [NTDLL.@]
1263  *  ZwSetInformationFile                [NTDLL.@]
1264  *
1265  * Set information about an open file handle.
1266  *
1267  * PARAMS
1268  *  handle  [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1269  *  io      [O] Receives information about the operation on return
1270  *  ptr     [I] Source for file information
1271  *  len     [I] Size of FileInformation
1272  *  class   [I] Type of file information to set
1273  *
1274  * RETURNS
1275  *  Success: 0. io is updated.
1276  *  Failure: An NTSTATUS error code describing the error.
1277  */
1278 NTSTATUS WINAPI NtSetInformationFile(HANDLE handle, PIO_STATUS_BLOCK io,
1279                                      PVOID ptr, ULONG len, FILE_INFORMATION_CLASS class)
1280 {
1281     int fd;
1282
1283     TRACE("(%p,%p,%p,0x%08lx,0x%08x)\n", handle, io, ptr, len, class);
1284
1285     if ((io->u.Status = wine_server_handle_to_fd( handle, 0, &fd, NULL )))
1286         return io->u.Status;
1287
1288     io->u.Status = STATUS_SUCCESS;
1289     switch (class)
1290     {
1291     case FileBasicInformation:
1292         if (len >= sizeof(FILE_BASIC_INFORMATION))
1293         {
1294             struct stat st;
1295             const FILE_BASIC_INFORMATION *info = ptr;
1296
1297             if (info->LastAccessTime.QuadPart || info->LastWriteTime.QuadPart)
1298             {
1299                 ULONGLONG sec, nsec;
1300                 struct timeval tv[2];
1301
1302                 if (!info->LastAccessTime.QuadPart || !info->LastWriteTime.QuadPart)
1303                 {
1304
1305                     tv[0].tv_sec = tv[0].tv_usec = 0;
1306                     tv[1].tv_sec = tv[1].tv_usec = 0;
1307                     if (!fstat( fd, &st ))
1308                     {
1309                         tv[0].tv_sec = st.st_atime;
1310                         tv[1].tv_sec = st.st_mtime;
1311                     }
1312                 }
1313                 if (info->LastAccessTime.QuadPart)
1314                 {
1315                     sec = RtlLargeIntegerDivide( info->LastAccessTime.QuadPart, 10000000, &nsec );
1316                     tv[0].tv_sec = sec - SECS_1601_TO_1970;
1317                     tv[0].tv_usec = (UINT)nsec / 10;
1318                 }
1319                 if (info->LastWriteTime.QuadPart)
1320                 {
1321                     sec = RtlLargeIntegerDivide( info->LastWriteTime.QuadPart, 10000000, &nsec );
1322                     tv[1].tv_sec = sec - SECS_1601_TO_1970;
1323                     tv[1].tv_usec = (UINT)nsec / 10;
1324                 }
1325                 if (futimes( fd, tv ) == -1) io->u.Status = FILE_GetNtStatus();
1326             }
1327
1328             if (io->u.Status == STATUS_SUCCESS && info->FileAttributes)
1329             {
1330                 if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1331                 else
1332                 {
1333                     if (info->FileAttributes & FILE_ATTRIBUTE_READONLY)
1334                     {
1335                         if (S_ISDIR( st.st_mode))
1336                             WARN("FILE_ATTRIBUTE_READONLY ignored for directory.\n");
1337                         else
1338                             st.st_mode &= ~0222; /* clear write permission bits */
1339                     }
1340                     else
1341                     {
1342                         /* add write permission only where we already have read permission */
1343                         st.st_mode |= (0600 | ((st.st_mode & 044) >> 1)) & (~FILE_umask);
1344                     }
1345                     if (fchmod( fd, st.st_mode ) == -1) io->u.Status = FILE_GetNtStatus();
1346                 }
1347             }
1348         }
1349         else io->u.Status = STATUS_INVALID_PARAMETER_3;
1350         break;
1351
1352     case FilePositionInformation:
1353         if (len >= sizeof(FILE_POSITION_INFORMATION))
1354         {
1355             const FILE_POSITION_INFORMATION *info = ptr;
1356
1357             if (lseek( fd, info->CurrentByteOffset.QuadPart, SEEK_SET ) == (off_t)-1)
1358                 io->u.Status = FILE_GetNtStatus();
1359         }
1360         else io->u.Status = STATUS_INVALID_PARAMETER_3;
1361         break;
1362
1363     case FileEndOfFileInformation:
1364         if (len >= sizeof(FILE_END_OF_FILE_INFORMATION))
1365         {
1366             struct stat st;
1367             const FILE_END_OF_FILE_INFORMATION *info = ptr;
1368
1369             /* first try normal truncate */
1370             if (ftruncate( fd, (off_t)info->EndOfFile.QuadPart ) != -1) break;
1371
1372             /* now check for the need to extend the file */
1373             if (fstat( fd, &st ) != -1 && (off_t)info->EndOfFile.QuadPart > st.st_size)
1374             {
1375                 static const char zero;
1376
1377                 /* extend the file one byte beyond the requested size and then truncate it */
1378                 /* this should work around ftruncate implementations that can't extend files */
1379                 if (pwrite( fd, &zero, 1, (off_t)info->EndOfFile.QuadPart ) != -1 &&
1380                     ftruncate( fd, (off_t)info->EndOfFile.QuadPart ) != -1) break;
1381             }
1382             io->u.Status = FILE_GetNtStatus();
1383         }
1384         else io->u.Status = STATUS_INVALID_PARAMETER_3;
1385         break;
1386
1387     case FileMailslotSetInformation:
1388         {
1389             FILE_MAILSLOT_SET_INFORMATION *info = ptr;
1390
1391             SERVER_START_REQ( set_mailslot_info )
1392             {
1393                 req->handle = handle;
1394                 req->flags = MAILSLOT_SET_READ_TIMEOUT;
1395                 req->read_timeout = info->ReadTimeout.QuadPart / -10000;
1396                 io->u.Status = wine_server_call( req );
1397             }
1398             SERVER_END_REQ;
1399         }
1400         break;
1401
1402     default:
1403         FIXME("Unsupported class (%d)\n", class);
1404         io->u.Status = STATUS_NOT_IMPLEMENTED;
1405         break;
1406     }
1407     wine_server_release_fd( handle, fd );
1408     io->Information = 0;
1409     return io->u.Status;
1410 }
1411
1412
1413 /******************************************************************************
1414  *              NtQueryFullAttributesFile   (NTDLL.@)
1415  */
1416 NTSTATUS WINAPI NtQueryFullAttributesFile( const OBJECT_ATTRIBUTES *attr,
1417                                            FILE_NETWORK_OPEN_INFORMATION *info )
1418 {
1419     ANSI_STRING unix_name;
1420     NTSTATUS status;
1421
1422     if (!(status = wine_nt_to_unix_file_name( attr->ObjectName, &unix_name, FILE_OPEN,
1423                                               !(attr->Attributes & OBJ_CASE_INSENSITIVE) )))
1424     {
1425         struct stat st;
1426
1427         if (stat( unix_name.Buffer, &st ) == -1)
1428             status = FILE_GetNtStatus();
1429         else if (!S_ISREG(st.st_mode) && !S_ISDIR(st.st_mode))
1430             status = STATUS_INVALID_INFO_CLASS;
1431         else
1432         {
1433             if (S_ISDIR(st.st_mode))
1434             {
1435                 info->FileAttributes          = FILE_ATTRIBUTE_DIRECTORY;
1436                 info->AllocationSize.QuadPart = 0;
1437                 info->EndOfFile.QuadPart      = 0;
1438             }
1439             else
1440             {
1441                 info->FileAttributes          = FILE_ATTRIBUTE_ARCHIVE;
1442                 info->AllocationSize.QuadPart = (ULONGLONG)st.st_blocks * 512;
1443                 info->EndOfFile.QuadPart      = st.st_size;
1444             }
1445             if (!(st.st_mode & (S_IWUSR | S_IWGRP | S_IWOTH)))
1446                 info->FileAttributes |= FILE_ATTRIBUTE_READONLY;
1447             RtlSecondsSince1970ToTime( st.st_mtime, &info->CreationTime );
1448             RtlSecondsSince1970ToTime( st.st_mtime, &info->LastWriteTime );
1449             RtlSecondsSince1970ToTime( st.st_ctime, &info->ChangeTime );
1450             RtlSecondsSince1970ToTime( st.st_atime, &info->LastAccessTime );
1451             if (DIR_is_hidden_file( attr->ObjectName ))
1452                 info->FileAttributes |= FILE_ATTRIBUTE_HIDDEN;
1453         }
1454         RtlFreeAnsiString( &unix_name );
1455     }
1456     else WARN("%s not found (%lx)\n", debugstr_us(attr->ObjectName), status );
1457     return status;
1458 }
1459
1460
1461 /******************************************************************************
1462  *              NtQueryAttributesFile   (NTDLL.@)
1463  *              ZwQueryAttributesFile   (NTDLL.@)
1464  */
1465 NTSTATUS WINAPI NtQueryAttributesFile( const OBJECT_ATTRIBUTES *attr, FILE_BASIC_INFORMATION *info )
1466 {
1467     FILE_NETWORK_OPEN_INFORMATION full_info;
1468     NTSTATUS status;
1469
1470     if (!(status = NtQueryFullAttributesFile( attr, &full_info )))
1471     {
1472         info->CreationTime.QuadPart   = full_info.CreationTime.QuadPart;
1473         info->LastAccessTime.QuadPart = full_info.LastAccessTime.QuadPart;
1474         info->LastWriteTime.QuadPart  = full_info.LastWriteTime.QuadPart;
1475         info->ChangeTime.QuadPart     = full_info.ChangeTime.QuadPart;
1476         info->FileAttributes          = full_info.FileAttributes;
1477     }
1478     return status;
1479 }
1480
1481
1482 /******************************************************************************
1483  *              FILE_GetDeviceInfo
1484  *
1485  * Implementation of the FileFsDeviceInformation query for NtQueryVolumeInformationFile.
1486  */
1487 NTSTATUS FILE_GetDeviceInfo( int fd, FILE_FS_DEVICE_INFORMATION *info )
1488 {
1489     struct stat st;
1490
1491     info->Characteristics = 0;
1492     if (fstat( fd, &st ) < 0) return FILE_GetNtStatus();
1493     if (S_ISCHR( st.st_mode ))
1494     {
1495         info->DeviceType = FILE_DEVICE_UNKNOWN;
1496 #ifdef linux
1497         switch(major(st.st_rdev))
1498         {
1499         case MEM_MAJOR:
1500             info->DeviceType = FILE_DEVICE_NULL;
1501             break;
1502         case TTY_MAJOR:
1503             info->DeviceType = FILE_DEVICE_SERIAL_PORT;
1504             break;
1505         case LP_MAJOR:
1506             info->DeviceType = FILE_DEVICE_PARALLEL_PORT;
1507             break;
1508         }
1509 #endif
1510     }
1511     else if (S_ISBLK( st.st_mode ))
1512     {
1513         info->DeviceType = FILE_DEVICE_DISK;
1514     }
1515     else if (S_ISFIFO( st.st_mode ) || S_ISSOCK( st.st_mode ))
1516     {
1517         info->DeviceType = FILE_DEVICE_NAMED_PIPE;
1518     }
1519     else  /* regular file or directory */
1520     {
1521 #if defined(linux) && defined(HAVE_FSTATFS)
1522         struct statfs stfs;
1523
1524         /* check for floppy disk */
1525         if (major(st.st_dev) == FLOPPY_MAJOR)
1526             info->Characteristics |= FILE_REMOVABLE_MEDIA;
1527
1528         if (fstatfs( fd, &stfs ) < 0) stfs.f_type = 0;
1529         switch (stfs.f_type)
1530         {
1531         case 0x9660:      /* iso9660 */
1532         case 0x15013346:  /* udf */
1533             info->DeviceType = FILE_DEVICE_CD_ROM_FILE_SYSTEM;
1534             info->Characteristics |= FILE_REMOVABLE_MEDIA|FILE_READ_ONLY_DEVICE;
1535             break;
1536         case 0x6969:  /* nfs */
1537         case 0x517B:  /* smbfs */
1538         case 0x564c:  /* ncpfs */
1539             info->DeviceType = FILE_DEVICE_NETWORK_FILE_SYSTEM;
1540             info->Characteristics |= FILE_REMOTE_DEVICE;
1541             break;
1542         case 0x01021994:  /* tmpfs */
1543         case 0x28cd3d45:  /* cramfs */
1544         case 0x1373:      /* devfs */
1545         case 0x9fa0:      /* procfs */
1546             info->DeviceType = FILE_DEVICE_VIRTUAL_DISK;
1547             break;
1548         default:
1549             info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1550             break;
1551         }
1552 #elif defined(__FreeBSD__)
1553         struct statfs stfs;
1554
1555         /* The proper way to do this in FreeBSD seems to be with the
1556          * name rather than the type, since their linux-compatible
1557          * fstatfs call converts the name to one of the Linux types.
1558          */
1559         if (fstatfs( fd, &stfs ) < 0)
1560             info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1561         else if (!strncmp("cd9660", stfs.f_fstypename,
1562                           sizeof(stfs.f_fstypename)))
1563         {
1564             info->DeviceType = FILE_DEVICE_CD_ROM_FILE_SYSTEM;
1565             /* Don't assume read-only, let the mount options set it
1566              * below
1567              */
1568             info->Characteristics |= FILE_REMOVABLE_MEDIA;
1569         }
1570         else if (!strncmp("nfs", stfs.f_fstypename,
1571                           sizeof(stfs.f_fstypename)))
1572         {
1573             info->DeviceType = FILE_DEVICE_NETWORK_FILE_SYSTEM;
1574             info->Characteristics |= FILE_REMOTE_DEVICE;
1575         }
1576         else if (!strncmp("nwfs", stfs.f_fstypename,
1577                           sizeof(stfs.f_fstypename)))
1578         {
1579             info->DeviceType = FILE_DEVICE_NETWORK_FILE_SYSTEM;
1580             info->Characteristics |= FILE_REMOTE_DEVICE;
1581         }
1582         else if (!strncmp("procfs", stfs.f_fstypename,
1583                           sizeof(stfs.f_fstypename)))
1584             info->DeviceType = FILE_DEVICE_VIRTUAL_DISK;
1585         else
1586             info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1587         if (stfs.f_flags & MNT_RDONLY)
1588             info->Characteristics |= FILE_READ_ONLY_DEVICE;
1589         if (!(stfs.f_flags & MNT_LOCAL))
1590         {
1591             info->DeviceType = FILE_DEVICE_NETWORK_FILE_SYSTEM;
1592             info->Characteristics |= FILE_REMOTE_DEVICE;
1593         }
1594 #elif defined (__APPLE__)
1595         struct statfs stfs;
1596         kern_return_t kernResult = KERN_FAILURE;
1597         mach_port_t masterPort;
1598         char bsdName[6]; /* disk#\0 */
1599         const char *name;
1600
1601         info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1602
1603         if (fstatfs( fd, &stfs ) < 0) return FILE_GetNtStatus();
1604
1605         /* stfs.f_type is reserved (always set to 0) so use IOKit */
1606         name = stfs.f_mntfromname + strlen(_PATH_DEV);
1607         memcpy( bsdName, name, min(strlen(name)+1,sizeof(bsdName)) );
1608         bsdName[sizeof(bsdName)-1] = 0;
1609
1610         kernResult = IOMasterPort(MACH_PORT_NULL, &masterPort);
1611
1612         if (kernResult == KERN_SUCCESS)
1613         {
1614             CFMutableDictionaryRef matching = IOBSDNameMatching(masterPort, 0, bsdName);
1615
1616             if (matching)
1617             {
1618                 CFStringRef type;
1619                 CFMutableDictionaryRef properties;
1620                 io_service_t devService = IOServiceGetMatchingService(masterPort, matching);
1621
1622                 if (IORegistryEntryCreateCFProperties(devService,
1623                                                       &properties,
1624                                                       kCFAllocatorDefault, 0) != KERN_SUCCESS)
1625                     return FILE_GetNtStatus();  /* FIXME */
1626                 if ( CFEqual(
1627                          CFDictionaryGetValue(properties, CFSTR("Removable")),
1628                          kCFBooleanTrue)
1629                     ) info->Characteristics |= FILE_REMOVABLE_MEDIA;
1630
1631                 if ( CFEqual(
1632                          CFDictionaryGetValue(properties, CFSTR("Writable")),
1633                          kCFBooleanFalse)
1634                     ) info->Characteristics |= FILE_READ_ONLY_DEVICE;
1635
1636                 /*
1637                   NB : mounted disk image (.img/.dmg) don't provide specific type
1638                 */
1639                 if ( (type = CFDictionaryGetValue(properties, CFSTR("Type"))) )
1640                 {
1641                     if ( CFStringCompare(type, CFSTR("CD-ROM"), 0) == kCFCompareEqualTo
1642                          || CFStringCompare(type, CFSTR("DVD-ROM"), 0) == kCFCompareEqualTo
1643                         )
1644                     {
1645                         info->DeviceType = FILE_DEVICE_CD_ROM_FILE_SYSTEM;
1646                     }
1647                 }
1648
1649                 if (properties)
1650                     CFRelease(properties);
1651             }
1652         }
1653 #elif defined(sun)
1654         /* Use dkio to work out device types */
1655         {
1656 # include <sys/dkio.h>
1657 # include <sys/vtoc.h>
1658             struct dk_cinfo dkinf;
1659             int retval = ioctl(fd, DKIOCINFO, &dkinf);
1660             if(retval==-1){
1661                 WARN("Unable to get disk device type information - assuming a disk like device\n");
1662                 info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1663             }
1664             switch (dkinf.dki_ctype)
1665             {
1666             case DKC_CDROM:
1667                 info->DeviceType = FILE_DEVICE_CD_ROM_FILE_SYSTEM;
1668                 info->Characteristics |= FILE_REMOVABLE_MEDIA|FILE_READ_ONLY_DEVICE;
1669                 break;
1670             case DKC_NCRFLOPPY:
1671             case DKC_SMSFLOPPY:
1672             case DKC_INTEL82072:
1673             case DKC_INTEL82077:
1674                 info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1675                 info->Characteristics |= FILE_REMOVABLE_MEDIA;
1676                 break;
1677             case DKC_MD:
1678                 info->DeviceType = FILE_DEVICE_VIRTUAL_DISK;
1679                 break;
1680             default:
1681                 info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1682             }
1683         }
1684 #else
1685         static int warned;
1686         if (!warned++) FIXME( "device info not properly supported on this platform\n" );
1687         info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1688 #endif
1689         info->Characteristics |= FILE_DEVICE_IS_MOUNTED;
1690     }
1691     return STATUS_SUCCESS;
1692 }
1693
1694
1695 /******************************************************************************
1696  *  NtQueryVolumeInformationFile                [NTDLL.@]
1697  *  ZwQueryVolumeInformationFile                [NTDLL.@]
1698  *
1699  * Get volume information for an open file handle.
1700  *
1701  * PARAMS
1702  *  handle      [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1703  *  io          [O] Receives information about the operation on return
1704  *  buffer      [O] Destination for volume information
1705  *  length      [I] Size of FsInformation
1706  *  info_class  [I] Type of volume information to set
1707  *
1708  * RETURNS
1709  *  Success: 0. io and buffer are updated.
1710  *  Failure: An NTSTATUS error code describing the error.
1711  */
1712 NTSTATUS WINAPI NtQueryVolumeInformationFile( HANDLE handle, PIO_STATUS_BLOCK io,
1713                                               PVOID buffer, ULONG length,
1714                                               FS_INFORMATION_CLASS info_class )
1715 {
1716     int fd;
1717     struct stat st;
1718
1719     if ((io->u.Status = wine_server_handle_to_fd( handle, 0, &fd, NULL )) != STATUS_SUCCESS)
1720         return io->u.Status;
1721
1722     io->u.Status = STATUS_NOT_IMPLEMENTED;
1723     io->Information = 0;
1724
1725     switch( info_class )
1726     {
1727     case FileFsVolumeInformation:
1728         FIXME( "%p: volume info not supported\n", handle );
1729         break;
1730     case FileFsLabelInformation:
1731         FIXME( "%p: label info not supported\n", handle );
1732         break;
1733     case FileFsSizeInformation:
1734         if (length < sizeof(FILE_FS_SIZE_INFORMATION))
1735             io->u.Status = STATUS_BUFFER_TOO_SMALL;
1736         else
1737         {
1738             FILE_FS_SIZE_INFORMATION *info = buffer;
1739
1740             if (fstat( fd, &st ) < 0)
1741             {
1742                 io->u.Status = FILE_GetNtStatus();
1743                 break;
1744             }
1745             if (!S_ISREG(st.st_mode) && !S_ISDIR(st.st_mode))
1746             {
1747                 io->u.Status = STATUS_INVALID_DEVICE_REQUEST;
1748             }
1749             else
1750             {
1751                 /* Linux's fstatvfs is buggy */
1752 #if !defined(linux) || !defined(HAVE_FSTATFS)
1753                 struct statvfs stfs;
1754
1755                 if (fstatvfs( fd, &stfs ) < 0)
1756                 {
1757                     io->u.Status = FILE_GetNtStatus();
1758                     break;
1759                 }
1760                 info->BytesPerSector = stfs.f_frsize;
1761 #else
1762                 struct statfs stfs;
1763                 if (fstatfs( fd, &stfs ) < 0)
1764                 {
1765                     io->u.Status = FILE_GetNtStatus();
1766                     break;
1767                 }
1768                 info->BytesPerSector = stfs.f_bsize;
1769 #endif
1770                 info->TotalAllocationUnits.QuadPart = stfs.f_blocks;
1771                 info->AvailableAllocationUnits.QuadPart = stfs.f_bavail;
1772                 info->SectorsPerAllocationUnit = 1;
1773                 io->Information = sizeof(*info);
1774                 io->u.Status = STATUS_SUCCESS;
1775             }
1776         }
1777         break;
1778     case FileFsDeviceInformation:
1779         if (length < sizeof(FILE_FS_DEVICE_INFORMATION))
1780             io->u.Status = STATUS_BUFFER_TOO_SMALL;
1781         else
1782         {
1783             FILE_FS_DEVICE_INFORMATION *info = buffer;
1784
1785             if ((io->u.Status = FILE_GetDeviceInfo( fd, info )) == STATUS_SUCCESS)
1786                 io->Information = sizeof(*info);
1787         }
1788         break;
1789     case FileFsAttributeInformation:
1790         FIXME( "%p: attribute info not supported\n", handle );
1791         break;
1792     case FileFsControlInformation:
1793         FIXME( "%p: control info not supported\n", handle );
1794         break;
1795     case FileFsFullSizeInformation:
1796         FIXME( "%p: full size info not supported\n", handle );
1797         break;
1798     case FileFsObjectIdInformation:
1799         FIXME( "%p: object id info not supported\n", handle );
1800         break;
1801     case FileFsMaximumInformation:
1802         FIXME( "%p: maximum info not supported\n", handle );
1803         break;
1804     default:
1805         io->u.Status = STATUS_INVALID_PARAMETER;
1806         break;
1807     }
1808     wine_server_release_fd( handle, fd );
1809     return io->u.Status;
1810 }
1811
1812
1813 /******************************************************************
1814  *              NtFlushBuffersFile  (NTDLL.@)
1815  *
1816  * Flush any buffered data on an open file handle.
1817  *
1818  * PARAMS
1819  *  FileHandle         [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1820  *  IoStatusBlock      [O] Receives information about the operation on return
1821  *
1822  * RETURNS
1823  *  Success: 0. IoStatusBlock is updated.
1824  *  Failure: An NTSTATUS error code describing the error.
1825  */
1826 NTSTATUS WINAPI NtFlushBuffersFile( HANDLE hFile, IO_STATUS_BLOCK* IoStatusBlock )
1827 {
1828     NTSTATUS ret;
1829     HANDLE hEvent = NULL;
1830
1831     SERVER_START_REQ( flush_file )
1832     {
1833         req->handle = hFile;
1834         ret = wine_server_call( req );
1835         hEvent = reply->event;
1836     }
1837     SERVER_END_REQ;
1838     if (!ret && hEvent)
1839     {
1840         ret = NtWaitForSingleObject( hEvent, FALSE, NULL );
1841         NtClose( hEvent );
1842     }
1843     return ret;
1844 }
1845
1846 /******************************************************************
1847  *              NtLockFile       (NTDLL.@)
1848  *
1849  *
1850  */
1851 NTSTATUS WINAPI NtLockFile( HANDLE hFile, HANDLE lock_granted_event,
1852                             PIO_APC_ROUTINE apc, void* apc_user,
1853                             PIO_STATUS_BLOCK io_status, PLARGE_INTEGER offset,
1854                             PLARGE_INTEGER count, ULONG* key, BOOLEAN dont_wait,
1855                             BOOLEAN exclusive )
1856 {
1857     NTSTATUS    ret;
1858     HANDLE      handle;
1859     BOOLEAN     async;
1860
1861     if (apc || io_status || key)
1862     {
1863         FIXME("Unimplemented yet parameter\n");
1864         return STATUS_NOT_IMPLEMENTED;
1865     }
1866
1867     for (;;)
1868     {
1869         SERVER_START_REQ( lock_file )
1870         {
1871             req->handle      = hFile;
1872             req->offset_low  = offset->u.LowPart;
1873             req->offset_high = offset->u.HighPart;
1874             req->count_low   = count->u.LowPart;
1875             req->count_high  = count->u.HighPart;
1876             req->shared      = !exclusive;
1877             req->wait        = !dont_wait;
1878             ret = wine_server_call( req );
1879             handle = reply->handle;
1880             async  = reply->overlapped;
1881         }
1882         SERVER_END_REQ;
1883         if (ret != STATUS_PENDING)
1884         {
1885             if (!ret && lock_granted_event) NtSetEvent(lock_granted_event, NULL);
1886             return ret;
1887         }
1888
1889         if (async)
1890         {
1891             FIXME( "Async I/O lock wait not implemented, might deadlock\n" );
1892             if (handle) NtClose( handle );
1893             return STATUS_PENDING;
1894         }
1895         if (handle)
1896         {
1897             NtWaitForSingleObject( handle, FALSE, NULL );
1898             NtClose( handle );
1899         }
1900         else
1901         {
1902             LARGE_INTEGER time;
1903     
1904             /* Unix lock conflict, sleep a bit and retry */
1905             time.QuadPart = 100 * (ULONGLONG)10000;
1906             time.QuadPart = -time.QuadPart;
1907             NtDelayExecution( FALSE, &time );
1908         }
1909     }
1910 }
1911
1912
1913 /******************************************************************
1914  *              NtUnlockFile    (NTDLL.@)
1915  *
1916  *
1917  */
1918 NTSTATUS WINAPI NtUnlockFile( HANDLE hFile, PIO_STATUS_BLOCK io_status,
1919                               PLARGE_INTEGER offset, PLARGE_INTEGER count,
1920                               PULONG key )
1921 {
1922     NTSTATUS status;
1923
1924     TRACE( "%p %lx%08lx %lx%08lx\n",
1925            hFile, offset->u.HighPart, offset->u.LowPart, count->u.HighPart, count->u.LowPart );
1926
1927     if (io_status || key)
1928     {
1929         FIXME("Unimplemented yet parameter\n");
1930         return STATUS_NOT_IMPLEMENTED;
1931     }
1932
1933     SERVER_START_REQ( unlock_file )
1934     {
1935         req->handle      = hFile;
1936         req->offset_low  = offset->u.LowPart;
1937         req->offset_high = offset->u.HighPart;
1938         req->count_low   = count->u.LowPart;
1939         req->count_high  = count->u.HighPart;
1940         status = wine_server_call( req );
1941     }
1942     SERVER_END_REQ;
1943     return status;
1944 }
1945
1946 /******************************************************************
1947  *              NtCreateNamedPipeFile    (NTDLL.@)
1948  *
1949  *
1950  */
1951 NTSTATUS WINAPI NtCreateNamedPipeFile( PHANDLE handle, ULONG access,
1952                                        POBJECT_ATTRIBUTES attr, PIO_STATUS_BLOCK iosb,
1953                                        ULONG sharing, ULONG dispo, ULONG options,
1954                                        ULONG pipe_type, ULONG read_mode, 
1955                                        ULONG completion_mode, ULONG max_inst,
1956                                        ULONG inbound_quota, ULONG outbound_quota,
1957                                        PLARGE_INTEGER timeout)
1958 {
1959     NTSTATUS    status;
1960     static const WCHAR leadin[] = {'\\','?','?','\\','P','I','P','E','\\'};
1961
1962     TRACE("(%p %lx %s %p %lx %ld %lx %ld %ld %ld %ld %ld %ld %p)\n",
1963           handle, access, debugstr_w(attr->ObjectName->Buffer), iosb, sharing, dispo,
1964           options, pipe_type, read_mode, completion_mode, max_inst, inbound_quota,
1965           outbound_quota, timeout);
1966
1967     if (attr->ObjectName->Length < sizeof(leadin) ||
1968         strncmpiW( attr->ObjectName->Buffer, 
1969                    leadin, sizeof(leadin)/sizeof(leadin[0]) ))
1970         return STATUS_OBJECT_NAME_INVALID;
1971     /* assume we only get relative timeout, and storable in a DWORD as ms */
1972     if (timeout->QuadPart > 0 || (timeout->QuadPart / -10000) >> 32)
1973         FIXME("Wrong time %s\n", wine_dbgstr_longlong(timeout->QuadPart));
1974
1975     SERVER_START_REQ( create_named_pipe )
1976     {
1977         req->access  = access;
1978         req->attributes = (attr) ? attr->Attributes : 0;
1979         req->rootdir = attr ? attr->RootDirectory : 0;
1980         req->options = options;
1981         req->flags = 
1982             (pipe_type) ? NAMED_PIPE_MESSAGE_STREAM_WRITE : 0 |
1983             (read_mode) ? NAMED_PIPE_MESSAGE_STREAM_READ  : 0 |
1984             (completion_mode) ? NAMED_PIPE_NONBLOCKING_MODE  : 0;
1985         req->maxinstances = max_inst;
1986         req->outsize = outbound_quota;
1987         req->insize  = inbound_quota;
1988         req->timeout = timeout->QuadPart / -10000;
1989         wine_server_add_data( req, attr->ObjectName->Buffer,
1990                               attr->ObjectName->Length );
1991         status = wine_server_call( req );
1992         if (!status) *handle = reply->handle;
1993     }
1994     SERVER_END_REQ;
1995     return status;
1996 }
1997
1998 /******************************************************************
1999  *              NtDeleteFile    (NTDLL.@)
2000  *
2001  *
2002  */
2003 NTSTATUS WINAPI NtDeleteFile( POBJECT_ATTRIBUTES ObjectAttributes )
2004 {
2005     NTSTATUS status;
2006     HANDLE hFile;
2007     IO_STATUS_BLOCK io;
2008
2009     TRACE("%p\n", ObjectAttributes);
2010     status = NtCreateFile( &hFile, GENERIC_READ | GENERIC_WRITE, ObjectAttributes, 
2011                            &io, NULL, 0,
2012                            FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE, 
2013                            FILE_OPEN, FILE_DELETE_ON_CLOSE, NULL, 0 );
2014     if (status == STATUS_SUCCESS) status = NtClose(hFile);
2015     return status;
2016 }
2017
2018 /******************************************************************
2019  *              NtCancelIoFile    (NTDLL.@)
2020  *
2021  *
2022  */
2023 NTSTATUS WINAPI NtCancelIoFile( HANDLE hFile, PIO_STATUS_BLOCK io_status )
2024 {
2025     LARGE_INTEGER timeout;
2026
2027     TRACE("%p %p\n", hFile, io_status );
2028
2029     SERVER_START_REQ( cancel_async )
2030     {
2031         req->handle = hFile;
2032         wine_server_call( req );
2033     }
2034     SERVER_END_REQ;
2035     /* Let some APC be run, so that we can run the remaining APCs on hFile
2036      * either the cancelation of the pending one, but also the execution
2037      * of the queued APC, but not yet run. This is needed to ensure proper
2038      * clean-up of allocated data.
2039      */
2040     timeout.u.LowPart = timeout.u.HighPart = 0;
2041     return io_status->u.Status = NtDelayExecution( TRUE, &timeout );
2042 }
2043
2044 /******************************************************************************
2045  *  NtCreateMailslotFile        [NTDLL.@]
2046  *  ZwCreateMailslotFile        [NTDLL.@]
2047  *
2048  * PARAMS
2049  *  pHandle          [O] pointer to receive the handle created
2050  *  DesiredAccess    [I] access mode (read, write, etc)
2051  *  ObjectAttributes [I] fully qualified NT path of the mailslot
2052  *  IoStatusBlock    [O] receives completion status and other info
2053  *  CreateOptions    [I]
2054  *  MailslotQuota    [I]
2055  *  MaxMessageSize   [I]
2056  *  TimeOut          [I]
2057  *
2058  * RETURNS
2059  *  An NT status code
2060  */
2061 NTSTATUS WINAPI NtCreateMailslotFile(PHANDLE pHandle, ULONG DesiredAccess,
2062      POBJECT_ATTRIBUTES attr, PIO_STATUS_BLOCK IoStatusBlock,
2063      ULONG CreateOptions, ULONG MailslotQuota, ULONG MaxMessageSize,
2064      PLARGE_INTEGER TimeOut)
2065 {
2066     static const WCHAR leadin[] = {
2067         '\\','?','?','\\','M','A','I','L','S','L','O','T','\\'};
2068     NTSTATUS ret;
2069
2070     TRACE("%p %08lx %p %p %08lx %08lx %08lx %p\n",
2071               pHandle, DesiredAccess, attr, IoStatusBlock,
2072               CreateOptions, MailslotQuota, MaxMessageSize, TimeOut);
2073
2074     if (attr->ObjectName->Length < sizeof(leadin) ||
2075         strncmpiW( attr->ObjectName->Buffer, 
2076                    leadin, sizeof(leadin)/sizeof(leadin[0]) ))
2077     {
2078         return STATUS_OBJECT_NAME_INVALID;
2079     }
2080
2081     SERVER_START_REQ( create_mailslot )
2082     {
2083         req->access = DesiredAccess;
2084         req->attributes = (attr) ? attr->Attributes : 0;
2085         req->rootdir = attr ? attr->RootDirectory : 0;
2086         req->max_msgsize = MaxMessageSize;
2087         req->read_timeout = (TimeOut->QuadPart <= 0) ? TimeOut->QuadPart / -10000 : -1;
2088         wine_server_add_data( req, attr->ObjectName->Buffer,
2089                               attr->ObjectName->Length );
2090         ret = wine_server_call( req );
2091         if( ret == STATUS_SUCCESS )
2092             *pHandle = reply->handle;
2093     }
2094     SERVER_END_REQ;
2095  
2096     return ret;
2097 }