advpack: Move file related functions to files.c.
[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, FILE_READ_DATA, &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, FILE_WRITE_DATA, &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     NTSTATUS    ret;
876
877     TRACE("(%p,%p,%p,%p,%p,0x%08lx,%p,0x%08lx,%p,0x%08lx)\n",
878           DeviceHandle, hEvent, UserApcRoutine, UserApcContext,
879           IoStatusBlock, IoControlCode, 
880           InputBuffer, InputBufferSize, OutputBuffer, OutputBufferSize);
881
882     if ((IoControlCode >> 16) == FILE_DEVICE_SERIAL_PORT)
883         ret = COMM_DeviceIoControl(DeviceHandle, hEvent,
884                                    UserApcRoutine, UserApcContext,
885                                    IoStatusBlock, IoControlCode,
886                                    InputBuffer, InputBufferSize,
887                                    OutputBuffer, OutputBufferSize);
888     else ret = CDROM_DeviceIoControl(DeviceHandle, hEvent,
889                                      UserApcRoutine, UserApcContext,
890                                      IoStatusBlock, IoControlCode,
891                                      InputBuffer, InputBufferSize,
892                                      OutputBuffer, OutputBufferSize);
893     if (ret == STATUS_NO_SUCH_DEVICE)
894     {
895         /* it wasn't a supported device (CDROM, COMM) */
896         FIXME("Unimplemented dwIoControlCode=%08lx\n", IoControlCode);
897         IoStatusBlock->u.Status = STATUS_NOT_IMPLEMENTED;
898         IoStatusBlock->Information = 0;
899         if (hEvent) NtSetEvent(hEvent, NULL);
900     }
901     return IoStatusBlock->u.Status;
902 }
903
904 /***********************************************************************
905  *           pipe_completion_wait   (Internal)
906  */
907 static void CALLBACK pipe_completion_wait(HANDLE event, PIO_STATUS_BLOCK iosb, ULONG status)
908 {
909     TRACE("for %p/%p, status=%08lx\n", event, iosb, status);
910
911     if (iosb)
912         iosb->u.Status = status;
913     NtSetEvent(event, NULL);
914     TRACE("done\n");
915 }
916
917 /**************************************************************************
918  *              NtFsControlFile                 [NTDLL.@]
919  *              ZwFsControlFile                 [NTDLL.@]
920  *
921  * Perform a file system control operation on an open file handle.
922  *
923  * PARAMS
924  *  DeviceHandle     [I] Handle returned from ZwOpenFile() or ZwCreateFile()
925  *  Event            [I] Event to signal upon completion (or NULL)
926  *  ApcRoutine       [I] Callback to call upon completion (or NULL)
927  *  ApcContext       [I] Context for ApcRoutine (or NULL)
928  *  IoStatusBlock    [O] Receives information about the operation on return
929  *  FsControlCode    [I] Control code for the operation to perform
930  *  InputBuffer      [I] Source for any input data required (or NULL)
931  *  InputBufferSize  [I] Size of InputBuffer
932  *  OutputBuffer     [O] Source for any output data returned (or NULL)
933  *  OutputBufferSize [I] Size of OutputBuffer
934  *
935  * RETURNS
936  *  Success: 0. IoStatusBlock is updated.
937  *  Failure: An NTSTATUS error code describing the error.
938  */
939 NTSTATUS WINAPI NtFsControlFile(HANDLE DeviceHandle, HANDLE Event OPTIONAL, PIO_APC_ROUTINE ApcRoutine,
940                                 PVOID ApcContext, PIO_STATUS_BLOCK IoStatusBlock, ULONG FsControlCode,
941                                 PVOID InputBuffer, ULONG InputBufferSize, PVOID OutputBuffer, ULONG OutputBufferSize)
942 {
943     NTSTATUS ret = STATUS_NOT_SUPPORTED;
944     HANDLE internal_event;
945
946     TRACE("(%p,%p,%p,%p,%p,0x%08lx,%p,0x%08lx,%p,0x%08lx)\n",
947     DeviceHandle,Event,ApcRoutine,ApcContext,IoStatusBlock,FsControlCode,
948     InputBuffer,InputBufferSize,OutputBuffer,OutputBufferSize);
949
950     if(!IoStatusBlock) return STATUS_INVALID_PARAMETER;
951
952     switch(FsControlCode)
953     {
954         case FSCTL_DISMOUNT_VOLUME:
955             ret = DIR_unmount_device( DeviceHandle );
956             break;
957
958         case FSCTL_PIPE_LISTEN :
959         case FSCTL_PIPE_WAIT :
960         {
961             OBJECT_ATTRIBUTES obj;
962
963             if(!Event)
964             {
965                 InitializeObjectAttributes(&obj, NULL, 0, 0, NULL);
966                 ret = NtCreateEvent(&internal_event, EVENT_ALL_ACCESS, &obj, FALSE, FALSE);
967                 if(ret != STATUS_SUCCESS) return ret;
968             }
969             switch(FsControlCode)
970             {
971                 case FSCTL_PIPE_LISTEN :
972                     SERVER_START_REQ(connect_named_pipe)
973                     {
974                         req->handle = DeviceHandle;
975                         req->event = Event ? Event : internal_event;
976                         req->func = pipe_completion_wait;
977                         ret = wine_server_call(req);
978                     }
979                     SERVER_END_REQ;
980                     break;
981                 case FSCTL_PIPE_WAIT :
982                 {
983                     FILE_PIPE_WAIT_FOR_BUFFER *buff = InputBuffer;
984
985                     SERVER_START_REQ(wait_named_pipe)
986                     {
987                         req->handle = DeviceHandle;
988                         req->timeout = buff->TimeoutSpecified ? buff->Timeout.QuadPart / -10000L
989                                                               : NMPWAIT_USE_DEFAULT_WAIT;
990                         req->event = Event ? Event : internal_event;
991                         req->func = pipe_completion_wait;
992                         wine_server_add_data( req, buff->Name, buff->NameLength );
993                         ret = wine_server_call( req );
994                     }
995                     SERVER_END_REQ;
996                     break;
997                 }
998             }
999             if(ret == STATUS_SUCCESS)
1000             {
1001                 if(Event)
1002                     ret = STATUS_PENDING;
1003                 else
1004                 {
1005                     do
1006                         ret = NtWaitForSingleObject(internal_event, TRUE, NULL);
1007                     while(ret == STATUS_USER_APC);
1008                     NtClose(internal_event);
1009                 }
1010             }
1011             break;
1012         }
1013         case FSCTL_PIPE_DISCONNECT :
1014             SERVER_START_REQ(disconnect_named_pipe)
1015             {
1016                 req->handle = DeviceHandle;
1017                 ret = wine_server_call(req);
1018                 if (!ret && reply->fd != -1) close(reply->fd);
1019             }
1020             SERVER_END_REQ;
1021             break;
1022         default :
1023             FIXME("Unsupported FsControlCode %lx\n", FsControlCode);
1024             break;
1025     }
1026     IoStatusBlock->u.Status = ret;
1027     return ret;
1028 }
1029
1030 /******************************************************************************
1031  *  NtSetVolumeInformationFile          [NTDLL.@]
1032  *  ZwSetVolumeInformationFile          [NTDLL.@]
1033  *
1034  * Set volume information for an open file handle.
1035  *
1036  * PARAMS
1037  *  FileHandle         [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1038  *  IoStatusBlock      [O] Receives information about the operation on return
1039  *  FsInformation      [I] Source for volume information
1040  *  Length             [I] Size of FsInformation
1041  *  FsInformationClass [I] Type of volume information to set
1042  *
1043  * RETURNS
1044  *  Success: 0. IoStatusBlock is updated.
1045  *  Failure: An NTSTATUS error code describing the error.
1046  */
1047 NTSTATUS WINAPI NtSetVolumeInformationFile(
1048         IN HANDLE FileHandle,
1049         PIO_STATUS_BLOCK IoStatusBlock,
1050         PVOID FsInformation,
1051         ULONG Length,
1052         FS_INFORMATION_CLASS FsInformationClass)
1053 {
1054         FIXME("(%p,%p,%p,0x%08lx,0x%08x) stub\n",
1055         FileHandle,IoStatusBlock,FsInformation,Length,FsInformationClass);
1056         return 0;
1057 }
1058
1059 /******************************************************************************
1060  *  NtQueryInformationFile              [NTDLL.@]
1061  *  ZwQueryInformationFile              [NTDLL.@]
1062  *
1063  * Get information about an open file handle.
1064  *
1065  * PARAMS
1066  *  hFile    [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1067  *  io       [O] Receives information about the operation on return
1068  *  ptr      [O] Destination for file information
1069  *  len      [I] Size of FileInformation
1070  *  class    [I] Type of file information to get
1071  *
1072  * RETURNS
1073  *  Success: 0. IoStatusBlock and FileInformation are updated.
1074  *  Failure: An NTSTATUS error code describing the error.
1075  */
1076 NTSTATUS WINAPI NtQueryInformationFile( HANDLE hFile, PIO_STATUS_BLOCK io,
1077                                         PVOID ptr, LONG len, FILE_INFORMATION_CLASS class )
1078 {
1079     static const size_t info_sizes[] =
1080     {
1081         0,
1082         sizeof(FILE_DIRECTORY_INFORMATION),            /* FileDirectoryInformation */
1083         sizeof(FILE_FULL_DIRECTORY_INFORMATION),       /* FileFullDirectoryInformation */
1084         sizeof(FILE_BOTH_DIRECTORY_INFORMATION),       /* FileBothDirectoryInformation */
1085         sizeof(FILE_BASIC_INFORMATION),                /* FileBasicInformation */
1086         sizeof(FILE_STANDARD_INFORMATION),             /* FileStandardInformation */
1087         sizeof(FILE_INTERNAL_INFORMATION),             /* FileInternalInformation */
1088         sizeof(FILE_EA_INFORMATION),                   /* FileEaInformation */
1089         sizeof(FILE_ACCESS_INFORMATION),               /* FileAccessInformation */
1090         sizeof(FILE_NAME_INFORMATION)-sizeof(WCHAR),   /* FileNameInformation */
1091         sizeof(FILE_RENAME_INFORMATION)-sizeof(WCHAR), /* FileRenameInformation */
1092         0,                                             /* FileLinkInformation */
1093         sizeof(FILE_NAMES_INFORMATION)-sizeof(WCHAR),  /* FileNamesInformation */
1094         sizeof(FILE_DISPOSITION_INFORMATION),          /* FileDispositionInformation */
1095         sizeof(FILE_POSITION_INFORMATION),             /* FilePositionInformation */
1096         sizeof(FILE_FULL_EA_INFORMATION),              /* FileFullEaInformation */
1097         sizeof(FILE_MODE_INFORMATION),                 /* FileModeInformation */
1098         sizeof(FILE_ALIGNMENT_INFORMATION),            /* FileAlignmentInformation */
1099         sizeof(FILE_ALL_INFORMATION)-sizeof(WCHAR),    /* FileAllInformation */
1100         sizeof(FILE_ALLOCATION_INFORMATION),           /* FileAllocationInformation */
1101         sizeof(FILE_END_OF_FILE_INFORMATION),          /* FileEndOfFileInformation */
1102         0,                                             /* FileAlternateNameInformation */
1103         sizeof(FILE_STREAM_INFORMATION)-sizeof(WCHAR), /* FileStreamInformation */
1104         0,                                             /* FilePipeInformation */
1105         0,                                             /* FilePipeLocalInformation */
1106         0,                                             /* FilePipeRemoteInformation */
1107         sizeof(FILE_MAILSLOT_QUERY_INFORMATION),       /* FileMailslotQueryInformation */
1108         0,                                             /* FileMailslotSetInformation */
1109         0,                                             /* FileCompressionInformation */
1110         0,                                             /* FileObjectIdInformation */
1111         0,                                             /* FileCompletionInformation */
1112         0,                                             /* FileMoveClusterInformation */
1113         0,                                             /* FileQuotaInformation */
1114         0,                                             /* FileReparsePointInformation */
1115         0,                                             /* FileNetworkOpenInformation */
1116         0,                                             /* FileAttributeTagInformation */
1117         0                                              /* FileTrackingInformation */
1118     };
1119
1120     struct stat st;
1121     int fd;
1122
1123     TRACE("(%p,%p,%p,0x%08lx,0x%08x)\n", hFile, io, ptr, len, class);
1124
1125     io->Information = 0;
1126
1127     if (class <= 0 || class >= FileMaximumInformation)
1128         return io->u.Status = STATUS_INVALID_INFO_CLASS;
1129     if (!info_sizes[class])
1130     {
1131         FIXME("Unsupported class (%d)\n", class);
1132         return io->u.Status = STATUS_NOT_IMPLEMENTED;
1133     }
1134     if (len < info_sizes[class])
1135         return io->u.Status = STATUS_INFO_LENGTH_MISMATCH;
1136
1137     if ((io->u.Status = wine_server_handle_to_fd( hFile, 0, &fd, NULL )))
1138         return io->u.Status;
1139
1140     switch (class)
1141     {
1142     case FileBasicInformation:
1143         {
1144             FILE_BASIC_INFORMATION *info = ptr;
1145
1146             if (fstat( fd, &st ) == -1)
1147                 io->u.Status = FILE_GetNtStatus();
1148             else if (!S_ISREG(st.st_mode) && !S_ISDIR(st.st_mode))
1149                 io->u.Status = STATUS_INVALID_INFO_CLASS;
1150             else
1151             {
1152                 if (S_ISDIR(st.st_mode)) info->FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
1153                 else info->FileAttributes = FILE_ATTRIBUTE_ARCHIVE;
1154                 if (!(st.st_mode & (S_IWUSR | S_IWGRP | S_IWOTH)))
1155                     info->FileAttributes |= FILE_ATTRIBUTE_READONLY;
1156                 RtlSecondsSince1970ToTime( st.st_mtime, &info->CreationTime);
1157                 RtlSecondsSince1970ToTime( st.st_mtime, &info->LastWriteTime);
1158                 RtlSecondsSince1970ToTime( st.st_ctime, &info->ChangeTime);
1159                 RtlSecondsSince1970ToTime( st.st_atime, &info->LastAccessTime);
1160             }
1161         }
1162         break;
1163     case FileStandardInformation:
1164         {
1165             FILE_STANDARD_INFORMATION *info = ptr;
1166
1167             if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1168             else
1169             {
1170                 if ((info->Directory = S_ISDIR(st.st_mode)))
1171                 {
1172                     info->AllocationSize.QuadPart = 0;
1173                     info->EndOfFile.QuadPart      = 0;
1174                     info->NumberOfLinks           = 1;
1175                     info->DeletePending           = FALSE;
1176                 }
1177                 else
1178                 {
1179                     info->AllocationSize.QuadPart = (ULONGLONG)st.st_blocks * 512;
1180                     info->EndOfFile.QuadPart      = st.st_size;
1181                     info->NumberOfLinks           = st.st_nlink;
1182                     info->DeletePending           = FALSE; /* FIXME */
1183                 }
1184             }
1185         }
1186         break;
1187     case FilePositionInformation:
1188         {
1189             FILE_POSITION_INFORMATION *info = ptr;
1190             off_t res = lseek( fd, 0, SEEK_CUR );
1191             if (res == (off_t)-1) io->u.Status = FILE_GetNtStatus();
1192             else info->CurrentByteOffset.QuadPart = res;
1193         }
1194         break;
1195     case FileInternalInformation:
1196         {
1197             FILE_INTERNAL_INFORMATION *info = ptr;
1198
1199             if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1200             else info->IndexNumber.QuadPart = st.st_ino;
1201         }
1202         break;
1203     case FileEaInformation:
1204         {
1205             FILE_EA_INFORMATION *info = ptr;
1206             info->EaSize = 0;
1207         }
1208         break;
1209     case FileEndOfFileInformation:
1210         {
1211             FILE_END_OF_FILE_INFORMATION *info = ptr;
1212
1213             if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1214             else info->EndOfFile.QuadPart = S_ISDIR(st.st_mode) ? 0 : st.st_size;
1215         }
1216         break;
1217     case FileAllInformation:
1218         {
1219             FILE_ALL_INFORMATION *info = ptr;
1220
1221             if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1222             else if (!S_ISREG(st.st_mode) && !S_ISDIR(st.st_mode))
1223                 io->u.Status = STATUS_INVALID_INFO_CLASS;
1224             else
1225             {
1226                 if ((info->StandardInformation.Directory = S_ISDIR(st.st_mode)))
1227                 {
1228                     info->BasicInformation.FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
1229                     info->StandardInformation.AllocationSize.QuadPart = 0;
1230                     info->StandardInformation.EndOfFile.QuadPart      = 0;
1231                     info->StandardInformation.NumberOfLinks           = 1;
1232                     info->StandardInformation.DeletePending           = FALSE;
1233                 }
1234                 else
1235                 {
1236                     info->BasicInformation.FileAttributes = FILE_ATTRIBUTE_ARCHIVE;
1237                     info->StandardInformation.AllocationSize.QuadPart = (ULONGLONG)st.st_blocks * 512;
1238                     info->StandardInformation.EndOfFile.QuadPart      = st.st_size;
1239                     info->StandardInformation.NumberOfLinks           = st.st_nlink;
1240                     info->StandardInformation.DeletePending           = FALSE; /* FIXME */
1241                 }
1242                 if (!(st.st_mode & (S_IWUSR | S_IWGRP | S_IWOTH)))
1243                     info->BasicInformation.FileAttributes |= FILE_ATTRIBUTE_READONLY;
1244                 RtlSecondsSince1970ToTime( st.st_mtime, &info->BasicInformation.CreationTime);
1245                 RtlSecondsSince1970ToTime( st.st_mtime, &info->BasicInformation.LastWriteTime);
1246                 RtlSecondsSince1970ToTime( st.st_ctime, &info->BasicInformation.ChangeTime);
1247                 RtlSecondsSince1970ToTime( st.st_atime, &info->BasicInformation.LastAccessTime);
1248                 info->InternalInformation.IndexNumber.QuadPart = st.st_ino;
1249                 info->EaInformation.EaSize = 0;
1250                 info->AccessInformation.AccessFlags = 0;  /* FIXME */
1251                 info->PositionInformation.CurrentByteOffset.QuadPart = lseek( fd, 0, SEEK_CUR );
1252                 info->ModeInformation.Mode = 0;  /* FIXME */
1253                 info->AlignmentInformation.AlignmentRequirement = 1;  /* FIXME */
1254                 info->NameInformation.FileNameLength = 0;
1255                 io->Information = sizeof(*info) - sizeof(WCHAR);
1256             }
1257         }
1258         break;
1259     case FileMailslotQueryInformation:
1260         {
1261             FILE_MAILSLOT_QUERY_INFORMATION *info = ptr;
1262
1263             SERVER_START_REQ( set_mailslot_info )
1264             {
1265                 req->handle = hFile;
1266                 req->flags = 0;
1267                 io->u.Status = wine_server_call( req );
1268                 if( io->u.Status == STATUS_SUCCESS )
1269                 {
1270                     info->MaximumMessageSize = reply->max_msgsize;
1271                     info->MailslotQuota = 0;
1272                     info->NextMessageSize = reply->next_msgsize;
1273                     info->MessagesAvailable = reply->msg_count;
1274                     info->ReadTimeout.QuadPart = reply->read_timeout * -10000;
1275                 }
1276             }
1277             SERVER_END_REQ;
1278         }
1279         break;
1280     default:
1281         FIXME("Unsupported class (%d)\n", class);
1282         io->u.Status = STATUS_NOT_IMPLEMENTED;
1283         break;
1284     }
1285     wine_server_release_fd( hFile, fd );
1286     if (io->u.Status == STATUS_SUCCESS && !io->Information) io->Information = info_sizes[class];
1287     return io->u.Status;
1288 }
1289
1290 /******************************************************************************
1291  *  NtSetInformationFile                [NTDLL.@]
1292  *  ZwSetInformationFile                [NTDLL.@]
1293  *
1294  * Set information about an open file handle.
1295  *
1296  * PARAMS
1297  *  handle  [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1298  *  io      [O] Receives information about the operation on return
1299  *  ptr     [I] Source for file information
1300  *  len     [I] Size of FileInformation
1301  *  class   [I] Type of file information to set
1302  *
1303  * RETURNS
1304  *  Success: 0. io is updated.
1305  *  Failure: An NTSTATUS error code describing the error.
1306  */
1307 NTSTATUS WINAPI NtSetInformationFile(HANDLE handle, PIO_STATUS_BLOCK io,
1308                                      PVOID ptr, ULONG len, FILE_INFORMATION_CLASS class)
1309 {
1310     int fd;
1311
1312     TRACE("(%p,%p,%p,0x%08lx,0x%08x)\n", handle, io, ptr, len, class);
1313
1314     if ((io->u.Status = wine_server_handle_to_fd( handle, 0, &fd, NULL )))
1315         return io->u.Status;
1316
1317     io->u.Status = STATUS_SUCCESS;
1318     switch (class)
1319     {
1320     case FileBasicInformation:
1321         if (len >= sizeof(FILE_BASIC_INFORMATION))
1322         {
1323             struct stat st;
1324             const FILE_BASIC_INFORMATION *info = ptr;
1325
1326             if (info->LastAccessTime.QuadPart || info->LastWriteTime.QuadPart)
1327             {
1328                 ULONGLONG sec, nsec;
1329                 struct timeval tv[2];
1330
1331                 if (!info->LastAccessTime.QuadPart || !info->LastWriteTime.QuadPart)
1332                 {
1333
1334                     tv[0].tv_sec = tv[0].tv_usec = 0;
1335                     tv[1].tv_sec = tv[1].tv_usec = 0;
1336                     if (!fstat( fd, &st ))
1337                     {
1338                         tv[0].tv_sec = st.st_atime;
1339                         tv[1].tv_sec = st.st_mtime;
1340                     }
1341                 }
1342                 if (info->LastAccessTime.QuadPart)
1343                 {
1344                     sec = RtlLargeIntegerDivide( info->LastAccessTime.QuadPart, 10000000, &nsec );
1345                     tv[0].tv_sec = sec - SECS_1601_TO_1970;
1346                     tv[0].tv_usec = (UINT)nsec / 10;
1347                 }
1348                 if (info->LastWriteTime.QuadPart)
1349                 {
1350                     sec = RtlLargeIntegerDivide( info->LastWriteTime.QuadPart, 10000000, &nsec );
1351                     tv[1].tv_sec = sec - SECS_1601_TO_1970;
1352                     tv[1].tv_usec = (UINT)nsec / 10;
1353                 }
1354                 if (futimes( fd, tv ) == -1) io->u.Status = FILE_GetNtStatus();
1355             }
1356
1357             if (io->u.Status == STATUS_SUCCESS && info->FileAttributes)
1358             {
1359                 if (fstat( fd, &st ) == -1) io->u.Status = FILE_GetNtStatus();
1360                 else
1361                 {
1362                     if (info->FileAttributes & FILE_ATTRIBUTE_READONLY)
1363                     {
1364                         if (S_ISDIR( st.st_mode))
1365                             WARN("FILE_ATTRIBUTE_READONLY ignored for directory.\n");
1366                         else
1367                             st.st_mode &= ~0222; /* clear write permission bits */
1368                     }
1369                     else
1370                     {
1371                         /* add write permission only where we already have read permission */
1372                         st.st_mode |= (0600 | ((st.st_mode & 044) >> 1)) & (~FILE_umask);
1373                     }
1374                     if (fchmod( fd, st.st_mode ) == -1) io->u.Status = FILE_GetNtStatus();
1375                 }
1376             }
1377         }
1378         else io->u.Status = STATUS_INVALID_PARAMETER_3;
1379         break;
1380
1381     case FilePositionInformation:
1382         if (len >= sizeof(FILE_POSITION_INFORMATION))
1383         {
1384             const FILE_POSITION_INFORMATION *info = ptr;
1385
1386             if (lseek( fd, info->CurrentByteOffset.QuadPart, SEEK_SET ) == (off_t)-1)
1387                 io->u.Status = FILE_GetNtStatus();
1388         }
1389         else io->u.Status = STATUS_INVALID_PARAMETER_3;
1390         break;
1391
1392     case FileEndOfFileInformation:
1393         if (len >= sizeof(FILE_END_OF_FILE_INFORMATION))
1394         {
1395             struct stat st;
1396             const FILE_END_OF_FILE_INFORMATION *info = ptr;
1397
1398             /* first try normal truncate */
1399             if (ftruncate( fd, (off_t)info->EndOfFile.QuadPart ) != -1) break;
1400
1401             /* now check for the need to extend the file */
1402             if (fstat( fd, &st ) != -1 && (off_t)info->EndOfFile.QuadPart > st.st_size)
1403             {
1404                 static const char zero;
1405
1406                 /* extend the file one byte beyond the requested size and then truncate it */
1407                 /* this should work around ftruncate implementations that can't extend files */
1408                 if (pwrite( fd, &zero, 1, (off_t)info->EndOfFile.QuadPart ) != -1 &&
1409                     ftruncate( fd, (off_t)info->EndOfFile.QuadPart ) != -1) break;
1410             }
1411             io->u.Status = FILE_GetNtStatus();
1412         }
1413         else io->u.Status = STATUS_INVALID_PARAMETER_3;
1414         break;
1415
1416     case FileMailslotSetInformation:
1417         {
1418             FILE_MAILSLOT_SET_INFORMATION *info = ptr;
1419
1420             SERVER_START_REQ( set_mailslot_info )
1421             {
1422                 req->handle = handle;
1423                 req->flags = MAILSLOT_SET_READ_TIMEOUT;
1424                 req->read_timeout = info->ReadTimeout.QuadPart / -10000;
1425                 io->u.Status = wine_server_call( req );
1426             }
1427             SERVER_END_REQ;
1428         }
1429         break;
1430
1431     default:
1432         FIXME("Unsupported class (%d)\n", class);
1433         io->u.Status = STATUS_NOT_IMPLEMENTED;
1434         break;
1435     }
1436     wine_server_release_fd( handle, fd );
1437     io->Information = 0;
1438     return io->u.Status;
1439 }
1440
1441
1442 /******************************************************************************
1443  *              NtQueryFullAttributesFile   (NTDLL.@)
1444  */
1445 NTSTATUS WINAPI NtQueryFullAttributesFile( const OBJECT_ATTRIBUTES *attr,
1446                                            FILE_NETWORK_OPEN_INFORMATION *info )
1447 {
1448     ANSI_STRING unix_name;
1449     NTSTATUS status;
1450
1451     if (!(status = wine_nt_to_unix_file_name( attr->ObjectName, &unix_name, FILE_OPEN,
1452                                               !(attr->Attributes & OBJ_CASE_INSENSITIVE) )))
1453     {
1454         struct stat st;
1455
1456         if (stat( unix_name.Buffer, &st ) == -1)
1457             status = FILE_GetNtStatus();
1458         else if (!S_ISREG(st.st_mode) && !S_ISDIR(st.st_mode))
1459             status = STATUS_INVALID_INFO_CLASS;
1460         else
1461         {
1462             if (S_ISDIR(st.st_mode))
1463             {
1464                 info->FileAttributes          = FILE_ATTRIBUTE_DIRECTORY;
1465                 info->AllocationSize.QuadPart = 0;
1466                 info->EndOfFile.QuadPart      = 0;
1467             }
1468             else
1469             {
1470                 info->FileAttributes          = FILE_ATTRIBUTE_ARCHIVE;
1471                 info->AllocationSize.QuadPart = (ULONGLONG)st.st_blocks * 512;
1472                 info->EndOfFile.QuadPart      = st.st_size;
1473             }
1474             if (!(st.st_mode & (S_IWUSR | S_IWGRP | S_IWOTH)))
1475                 info->FileAttributes |= FILE_ATTRIBUTE_READONLY;
1476             RtlSecondsSince1970ToTime( st.st_mtime, &info->CreationTime );
1477             RtlSecondsSince1970ToTime( st.st_mtime, &info->LastWriteTime );
1478             RtlSecondsSince1970ToTime( st.st_ctime, &info->ChangeTime );
1479             RtlSecondsSince1970ToTime( st.st_atime, &info->LastAccessTime );
1480             if (DIR_is_hidden_file( attr->ObjectName ))
1481                 info->FileAttributes |= FILE_ATTRIBUTE_HIDDEN;
1482         }
1483         RtlFreeAnsiString( &unix_name );
1484     }
1485     else WARN("%s not found (%lx)\n", debugstr_us(attr->ObjectName), status );
1486     return status;
1487 }
1488
1489
1490 /******************************************************************************
1491  *              NtQueryAttributesFile   (NTDLL.@)
1492  *              ZwQueryAttributesFile   (NTDLL.@)
1493  */
1494 NTSTATUS WINAPI NtQueryAttributesFile( const OBJECT_ATTRIBUTES *attr, FILE_BASIC_INFORMATION *info )
1495 {
1496     FILE_NETWORK_OPEN_INFORMATION full_info;
1497     NTSTATUS status;
1498
1499     if (!(status = NtQueryFullAttributesFile( attr, &full_info )))
1500     {
1501         info->CreationTime.QuadPart   = full_info.CreationTime.QuadPart;
1502         info->LastAccessTime.QuadPart = full_info.LastAccessTime.QuadPart;
1503         info->LastWriteTime.QuadPart  = full_info.LastWriteTime.QuadPart;
1504         info->ChangeTime.QuadPart     = full_info.ChangeTime.QuadPart;
1505         info->FileAttributes          = full_info.FileAttributes;
1506     }
1507     return status;
1508 }
1509
1510
1511 /******************************************************************************
1512  *              FILE_GetDeviceInfo
1513  *
1514  * Implementation of the FileFsDeviceInformation query for NtQueryVolumeInformationFile.
1515  */
1516 NTSTATUS FILE_GetDeviceInfo( int fd, FILE_FS_DEVICE_INFORMATION *info )
1517 {
1518     struct stat st;
1519
1520     info->Characteristics = 0;
1521     if (fstat( fd, &st ) < 0) return FILE_GetNtStatus();
1522     if (S_ISCHR( st.st_mode ))
1523     {
1524         info->DeviceType = FILE_DEVICE_UNKNOWN;
1525 #ifdef linux
1526         switch(major(st.st_rdev))
1527         {
1528         case MEM_MAJOR:
1529             info->DeviceType = FILE_DEVICE_NULL;
1530             break;
1531         case TTY_MAJOR:
1532             info->DeviceType = FILE_DEVICE_SERIAL_PORT;
1533             break;
1534         case LP_MAJOR:
1535             info->DeviceType = FILE_DEVICE_PARALLEL_PORT;
1536             break;
1537         }
1538 #endif
1539     }
1540     else if (S_ISBLK( st.st_mode ))
1541     {
1542         info->DeviceType = FILE_DEVICE_DISK;
1543     }
1544     else if (S_ISFIFO( st.st_mode ) || S_ISSOCK( st.st_mode ))
1545     {
1546         info->DeviceType = FILE_DEVICE_NAMED_PIPE;
1547     }
1548     else  /* regular file or directory */
1549     {
1550 #if defined(linux) && defined(HAVE_FSTATFS)
1551         struct statfs stfs;
1552
1553         /* check for floppy disk */
1554         if (major(st.st_dev) == FLOPPY_MAJOR)
1555             info->Characteristics |= FILE_REMOVABLE_MEDIA;
1556
1557         if (fstatfs( fd, &stfs ) < 0) stfs.f_type = 0;
1558         switch (stfs.f_type)
1559         {
1560         case 0x9660:      /* iso9660 */
1561         case 0x15013346:  /* udf */
1562             info->DeviceType = FILE_DEVICE_CD_ROM_FILE_SYSTEM;
1563             info->Characteristics |= FILE_REMOVABLE_MEDIA|FILE_READ_ONLY_DEVICE;
1564             break;
1565         case 0x6969:  /* nfs */
1566         case 0x517B:  /* smbfs */
1567         case 0x564c:  /* ncpfs */
1568             info->DeviceType = FILE_DEVICE_NETWORK_FILE_SYSTEM;
1569             info->Characteristics |= FILE_REMOTE_DEVICE;
1570             break;
1571         case 0x01021994:  /* tmpfs */
1572         case 0x28cd3d45:  /* cramfs */
1573         case 0x1373:      /* devfs */
1574         case 0x9fa0:      /* procfs */
1575             info->DeviceType = FILE_DEVICE_VIRTUAL_DISK;
1576             break;
1577         default:
1578             info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1579             break;
1580         }
1581 #elif defined(__FreeBSD__)
1582         struct statfs stfs;
1583
1584         /* The proper way to do this in FreeBSD seems to be with the
1585          * name rather than the type, since their linux-compatible
1586          * fstatfs call converts the name to one of the Linux types.
1587          */
1588         if (fstatfs( fd, &stfs ) < 0)
1589             info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1590         else if (!strncmp("cd9660", stfs.f_fstypename,
1591                           sizeof(stfs.f_fstypename)))
1592         {
1593             info->DeviceType = FILE_DEVICE_CD_ROM_FILE_SYSTEM;
1594             /* Don't assume read-only, let the mount options set it
1595              * below
1596              */
1597             info->Characteristics |= FILE_REMOVABLE_MEDIA;
1598         }
1599         else if (!strncmp("nfs", stfs.f_fstypename,
1600                           sizeof(stfs.f_fstypename)))
1601         {
1602             info->DeviceType = FILE_DEVICE_NETWORK_FILE_SYSTEM;
1603             info->Characteristics |= FILE_REMOTE_DEVICE;
1604         }
1605         else if (!strncmp("nwfs", stfs.f_fstypename,
1606                           sizeof(stfs.f_fstypename)))
1607         {
1608             info->DeviceType = FILE_DEVICE_NETWORK_FILE_SYSTEM;
1609             info->Characteristics |= FILE_REMOTE_DEVICE;
1610         }
1611         else if (!strncmp("procfs", stfs.f_fstypename,
1612                           sizeof(stfs.f_fstypename)))
1613             info->DeviceType = FILE_DEVICE_VIRTUAL_DISK;
1614         else
1615             info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1616         if (stfs.f_flags & MNT_RDONLY)
1617             info->Characteristics |= FILE_READ_ONLY_DEVICE;
1618         if (!(stfs.f_flags & MNT_LOCAL))
1619         {
1620             info->DeviceType = FILE_DEVICE_NETWORK_FILE_SYSTEM;
1621             info->Characteristics |= FILE_REMOTE_DEVICE;
1622         }
1623 #elif defined (__APPLE__)
1624         struct statfs stfs;
1625         kern_return_t kernResult = KERN_FAILURE;
1626         mach_port_t masterPort;
1627         char bsdName[6]; /* disk#\0 */
1628         const char *name;
1629
1630         info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1631
1632         if (fstatfs( fd, &stfs ) < 0) return FILE_GetNtStatus();
1633
1634         /* stfs.f_type is reserved (always set to 0) so use IOKit */
1635         name = stfs.f_mntfromname + strlen(_PATH_DEV);
1636         memcpy( bsdName, name, min(strlen(name)+1,sizeof(bsdName)) );
1637         bsdName[sizeof(bsdName)-1] = 0;
1638
1639         kernResult = IOMasterPort(MACH_PORT_NULL, &masterPort);
1640
1641         if (kernResult == KERN_SUCCESS)
1642         {
1643             CFMutableDictionaryRef matching = IOBSDNameMatching(masterPort, 0, bsdName);
1644
1645             if (matching)
1646             {
1647                 CFStringRef type;
1648                 CFMutableDictionaryRef properties;
1649                 io_service_t devService = IOServiceGetMatchingService(masterPort, matching);
1650
1651                 if (IORegistryEntryCreateCFProperties(devService,
1652                                                       &properties,
1653                                                       kCFAllocatorDefault, 0) != KERN_SUCCESS)
1654                     return FILE_GetNtStatus();  /* FIXME */
1655                 if ( CFEqual(
1656                          CFDictionaryGetValue(properties, CFSTR("Removable")),
1657                          kCFBooleanTrue)
1658                     ) info->Characteristics |= FILE_REMOVABLE_MEDIA;
1659
1660                 if ( CFEqual(
1661                          CFDictionaryGetValue(properties, CFSTR("Writable")),
1662                          kCFBooleanFalse)
1663                     ) info->Characteristics |= FILE_READ_ONLY_DEVICE;
1664
1665                 /*
1666                   NB : mounted disk image (.img/.dmg) don't provide specific type
1667                 */
1668                 if ( (type = CFDictionaryGetValue(properties, CFSTR("Type"))) )
1669                 {
1670                     if ( CFStringCompare(type, CFSTR("CD-ROM"), 0) == kCFCompareEqualTo
1671                          || CFStringCompare(type, CFSTR("DVD-ROM"), 0) == kCFCompareEqualTo
1672                         )
1673                     {
1674                         info->DeviceType = FILE_DEVICE_CD_ROM_FILE_SYSTEM;
1675                     }
1676                 }
1677
1678                 if (properties)
1679                     CFRelease(properties);
1680             }
1681         }
1682 #elif defined(sun)
1683         /* Use dkio to work out device types */
1684         {
1685 # include <sys/dkio.h>
1686 # include <sys/vtoc.h>
1687             struct dk_cinfo dkinf;
1688             int retval = ioctl(fd, DKIOCINFO, &dkinf);
1689             if(retval==-1){
1690                 WARN("Unable to get disk device type information - assuming a disk like device\n");
1691                 info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1692             }
1693             switch (dkinf.dki_ctype)
1694             {
1695             case DKC_CDROM:
1696                 info->DeviceType = FILE_DEVICE_CD_ROM_FILE_SYSTEM;
1697                 info->Characteristics |= FILE_REMOVABLE_MEDIA|FILE_READ_ONLY_DEVICE;
1698                 break;
1699             case DKC_NCRFLOPPY:
1700             case DKC_SMSFLOPPY:
1701             case DKC_INTEL82072:
1702             case DKC_INTEL82077:
1703                 info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1704                 info->Characteristics |= FILE_REMOVABLE_MEDIA;
1705                 break;
1706             case DKC_MD:
1707                 info->DeviceType = FILE_DEVICE_VIRTUAL_DISK;
1708                 break;
1709             default:
1710                 info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1711             }
1712         }
1713 #else
1714         static int warned;
1715         if (!warned++) FIXME( "device info not properly supported on this platform\n" );
1716         info->DeviceType = FILE_DEVICE_DISK_FILE_SYSTEM;
1717 #endif
1718         info->Characteristics |= FILE_DEVICE_IS_MOUNTED;
1719     }
1720     return STATUS_SUCCESS;
1721 }
1722
1723
1724 /******************************************************************************
1725  *  NtQueryVolumeInformationFile                [NTDLL.@]
1726  *  ZwQueryVolumeInformationFile                [NTDLL.@]
1727  *
1728  * Get volume information for an open file handle.
1729  *
1730  * PARAMS
1731  *  handle      [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1732  *  io          [O] Receives information about the operation on return
1733  *  buffer      [O] Destination for volume information
1734  *  length      [I] Size of FsInformation
1735  *  info_class  [I] Type of volume information to set
1736  *
1737  * RETURNS
1738  *  Success: 0. io and buffer are updated.
1739  *  Failure: An NTSTATUS error code describing the error.
1740  */
1741 NTSTATUS WINAPI NtQueryVolumeInformationFile( HANDLE handle, PIO_STATUS_BLOCK io,
1742                                               PVOID buffer, ULONG length,
1743                                               FS_INFORMATION_CLASS info_class )
1744 {
1745     int fd;
1746     struct stat st;
1747
1748     if ((io->u.Status = wine_server_handle_to_fd( handle, 0, &fd, NULL )) != STATUS_SUCCESS)
1749         return io->u.Status;
1750
1751     io->u.Status = STATUS_NOT_IMPLEMENTED;
1752     io->Information = 0;
1753
1754     switch( info_class )
1755     {
1756     case FileFsVolumeInformation:
1757         FIXME( "%p: volume info not supported\n", handle );
1758         break;
1759     case FileFsLabelInformation:
1760         FIXME( "%p: label info not supported\n", handle );
1761         break;
1762     case FileFsSizeInformation:
1763         if (length < sizeof(FILE_FS_SIZE_INFORMATION))
1764             io->u.Status = STATUS_BUFFER_TOO_SMALL;
1765         else
1766         {
1767             FILE_FS_SIZE_INFORMATION *info = buffer;
1768
1769             if (fstat( fd, &st ) < 0)
1770             {
1771                 io->u.Status = FILE_GetNtStatus();
1772                 break;
1773             }
1774             if (!S_ISREG(st.st_mode) && !S_ISDIR(st.st_mode))
1775             {
1776                 io->u.Status = STATUS_INVALID_DEVICE_REQUEST;
1777             }
1778             else
1779             {
1780                 /* Linux's fstatvfs is buggy */
1781 #if !defined(linux) || !defined(HAVE_FSTATFS)
1782                 struct statvfs stfs;
1783
1784                 if (fstatvfs( fd, &stfs ) < 0)
1785                 {
1786                     io->u.Status = FILE_GetNtStatus();
1787                     break;
1788                 }
1789                 info->BytesPerSector = stfs.f_frsize;
1790 #else
1791                 struct statfs stfs;
1792                 if (fstatfs( fd, &stfs ) < 0)
1793                 {
1794                     io->u.Status = FILE_GetNtStatus();
1795                     break;
1796                 }
1797                 info->BytesPerSector = stfs.f_bsize;
1798 #endif
1799                 info->TotalAllocationUnits.QuadPart = stfs.f_blocks;
1800                 info->AvailableAllocationUnits.QuadPart = stfs.f_bavail;
1801                 info->SectorsPerAllocationUnit = 1;
1802                 io->Information = sizeof(*info);
1803                 io->u.Status = STATUS_SUCCESS;
1804             }
1805         }
1806         break;
1807     case FileFsDeviceInformation:
1808         if (length < sizeof(FILE_FS_DEVICE_INFORMATION))
1809             io->u.Status = STATUS_BUFFER_TOO_SMALL;
1810         else
1811         {
1812             FILE_FS_DEVICE_INFORMATION *info = buffer;
1813
1814             if ((io->u.Status = FILE_GetDeviceInfo( fd, info )) == STATUS_SUCCESS)
1815                 io->Information = sizeof(*info);
1816         }
1817         break;
1818     case FileFsAttributeInformation:
1819         FIXME( "%p: attribute info not supported\n", handle );
1820         break;
1821     case FileFsControlInformation:
1822         FIXME( "%p: control info not supported\n", handle );
1823         break;
1824     case FileFsFullSizeInformation:
1825         FIXME( "%p: full size info not supported\n", handle );
1826         break;
1827     case FileFsObjectIdInformation:
1828         FIXME( "%p: object id info not supported\n", handle );
1829         break;
1830     case FileFsMaximumInformation:
1831         FIXME( "%p: maximum info not supported\n", handle );
1832         break;
1833     default:
1834         io->u.Status = STATUS_INVALID_PARAMETER;
1835         break;
1836     }
1837     wine_server_release_fd( handle, fd );
1838     return io->u.Status;
1839 }
1840
1841
1842 /******************************************************************
1843  *              NtFlushBuffersFile  (NTDLL.@)
1844  *
1845  * Flush any buffered data on an open file handle.
1846  *
1847  * PARAMS
1848  *  FileHandle         [I] Handle returned from ZwOpenFile() or ZwCreateFile()
1849  *  IoStatusBlock      [O] Receives information about the operation on return
1850  *
1851  * RETURNS
1852  *  Success: 0. IoStatusBlock is updated.
1853  *  Failure: An NTSTATUS error code describing the error.
1854  */
1855 NTSTATUS WINAPI NtFlushBuffersFile( HANDLE hFile, IO_STATUS_BLOCK* IoStatusBlock )
1856 {
1857     NTSTATUS ret;
1858     HANDLE hEvent = NULL;
1859
1860     SERVER_START_REQ( flush_file )
1861     {
1862         req->handle = hFile;
1863         ret = wine_server_call( req );
1864         hEvent = reply->event;
1865     }
1866     SERVER_END_REQ;
1867     if (!ret && hEvent)
1868     {
1869         ret = NtWaitForSingleObject( hEvent, FALSE, NULL );
1870         NtClose( hEvent );
1871     }
1872     return ret;
1873 }
1874
1875 /******************************************************************
1876  *              NtLockFile       (NTDLL.@)
1877  *
1878  *
1879  */
1880 NTSTATUS WINAPI NtLockFile( HANDLE hFile, HANDLE lock_granted_event,
1881                             PIO_APC_ROUTINE apc, void* apc_user,
1882                             PIO_STATUS_BLOCK io_status, PLARGE_INTEGER offset,
1883                             PLARGE_INTEGER count, ULONG* key, BOOLEAN dont_wait,
1884                             BOOLEAN exclusive )
1885 {
1886     NTSTATUS    ret;
1887     HANDLE      handle;
1888     BOOLEAN     async;
1889
1890     if (apc || io_status || key)
1891     {
1892         FIXME("Unimplemented yet parameter\n");
1893         return STATUS_NOT_IMPLEMENTED;
1894     }
1895
1896     for (;;)
1897     {
1898         SERVER_START_REQ( lock_file )
1899         {
1900             req->handle      = hFile;
1901             req->offset_low  = offset->u.LowPart;
1902             req->offset_high = offset->u.HighPart;
1903             req->count_low   = count->u.LowPart;
1904             req->count_high  = count->u.HighPart;
1905             req->shared      = !exclusive;
1906             req->wait        = !dont_wait;
1907             ret = wine_server_call( req );
1908             handle = reply->handle;
1909             async  = reply->overlapped;
1910         }
1911         SERVER_END_REQ;
1912         if (ret != STATUS_PENDING)
1913         {
1914             if (!ret && lock_granted_event) NtSetEvent(lock_granted_event, NULL);
1915             return ret;
1916         }
1917
1918         if (async)
1919         {
1920             FIXME( "Async I/O lock wait not implemented, might deadlock\n" );
1921             if (handle) NtClose( handle );
1922             return STATUS_PENDING;
1923         }
1924         if (handle)
1925         {
1926             NtWaitForSingleObject( handle, FALSE, NULL );
1927             NtClose( handle );
1928         }
1929         else
1930         {
1931             LARGE_INTEGER time;
1932     
1933             /* Unix lock conflict, sleep a bit and retry */
1934             time.QuadPart = 100 * (ULONGLONG)10000;
1935             time.QuadPart = -time.QuadPart;
1936             NtDelayExecution( FALSE, &time );
1937         }
1938     }
1939 }
1940
1941
1942 /******************************************************************
1943  *              NtUnlockFile    (NTDLL.@)
1944  *
1945  *
1946  */
1947 NTSTATUS WINAPI NtUnlockFile( HANDLE hFile, PIO_STATUS_BLOCK io_status,
1948                               PLARGE_INTEGER offset, PLARGE_INTEGER count,
1949                               PULONG key )
1950 {
1951     NTSTATUS status;
1952
1953     TRACE( "%p %lx%08lx %lx%08lx\n",
1954            hFile, offset->u.HighPart, offset->u.LowPart, count->u.HighPart, count->u.LowPart );
1955
1956     if (io_status || key)
1957     {
1958         FIXME("Unimplemented yet parameter\n");
1959         return STATUS_NOT_IMPLEMENTED;
1960     }
1961
1962     SERVER_START_REQ( unlock_file )
1963     {
1964         req->handle      = hFile;
1965         req->offset_low  = offset->u.LowPart;
1966         req->offset_high = offset->u.HighPart;
1967         req->count_low   = count->u.LowPart;
1968         req->count_high  = count->u.HighPart;
1969         status = wine_server_call( req );
1970     }
1971     SERVER_END_REQ;
1972     return status;
1973 }
1974
1975 /******************************************************************
1976  *              NtCreateNamedPipeFile    (NTDLL.@)
1977  *
1978  *
1979  */
1980 NTSTATUS WINAPI NtCreateNamedPipeFile( PHANDLE handle, ULONG access,
1981                                        POBJECT_ATTRIBUTES attr, PIO_STATUS_BLOCK iosb,
1982                                        ULONG sharing, ULONG dispo, ULONG options,
1983                                        ULONG pipe_type, ULONG read_mode, 
1984                                        ULONG completion_mode, ULONG max_inst,
1985                                        ULONG inbound_quota, ULONG outbound_quota,
1986                                        PLARGE_INTEGER timeout)
1987 {
1988     NTSTATUS    status;
1989     static const WCHAR leadin[] = {'\\','?','?','\\','P','I','P','E','\\'};
1990
1991     TRACE("(%p %lx %s %p %lx %ld %lx %ld %ld %ld %ld %ld %ld %p)\n",
1992           handle, access, debugstr_w(attr->ObjectName->Buffer), iosb, sharing, dispo,
1993           options, pipe_type, read_mode, completion_mode, max_inst, inbound_quota,
1994           outbound_quota, timeout);
1995
1996     if (attr->ObjectName->Length < sizeof(leadin) ||
1997         strncmpiW( attr->ObjectName->Buffer, 
1998                    leadin, sizeof(leadin)/sizeof(leadin[0]) ))
1999         return STATUS_OBJECT_NAME_INVALID;
2000     /* assume we only get relative timeout, and storable in a DWORD as ms */
2001     if (timeout->QuadPart > 0 || (timeout->QuadPart / -10000) >> 32)
2002         FIXME("Wrong time %s\n", wine_dbgstr_longlong(timeout->QuadPart));
2003
2004     SERVER_START_REQ( create_named_pipe )
2005     {
2006         req->access  = access;
2007         req->attributes = (attr) ? attr->Attributes : 0;
2008         req->rootdir = attr ? attr->RootDirectory : 0;
2009         req->options = options;
2010         req->flags = 
2011             (pipe_type) ? NAMED_PIPE_MESSAGE_STREAM_WRITE : 0 |
2012             (read_mode) ? NAMED_PIPE_MESSAGE_STREAM_READ  : 0 |
2013             (completion_mode) ? NAMED_PIPE_NONBLOCKING_MODE  : 0;
2014         req->maxinstances = max_inst;
2015         req->outsize = outbound_quota;
2016         req->insize  = inbound_quota;
2017         req->timeout = timeout->QuadPart / -10000;
2018         wine_server_add_data( req, attr->ObjectName->Buffer,
2019                               attr->ObjectName->Length );
2020         status = wine_server_call( req );
2021         if (!status) *handle = reply->handle;
2022     }
2023     SERVER_END_REQ;
2024     return status;
2025 }
2026
2027 /******************************************************************
2028  *              NtDeleteFile    (NTDLL.@)
2029  *
2030  *
2031  */
2032 NTSTATUS WINAPI NtDeleteFile( POBJECT_ATTRIBUTES ObjectAttributes )
2033 {
2034     NTSTATUS status;
2035     HANDLE hFile;
2036     IO_STATUS_BLOCK io;
2037
2038     TRACE("%p\n", ObjectAttributes);
2039     status = NtCreateFile( &hFile, GENERIC_READ | GENERIC_WRITE, ObjectAttributes, 
2040                            &io, NULL, 0,
2041                            FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE, 
2042                            FILE_OPEN, FILE_DELETE_ON_CLOSE, NULL, 0 );
2043     if (status == STATUS_SUCCESS) status = NtClose(hFile);
2044     return status;
2045 }
2046
2047 /******************************************************************
2048  *              NtCancelIoFile    (NTDLL.@)
2049  *
2050  *
2051  */
2052 NTSTATUS WINAPI NtCancelIoFile( HANDLE hFile, PIO_STATUS_BLOCK io_status )
2053 {
2054     LARGE_INTEGER timeout;
2055
2056     TRACE("%p %p\n", hFile, io_status );
2057
2058     SERVER_START_REQ( cancel_async )
2059     {
2060         req->handle = hFile;
2061         wine_server_call( req );
2062     }
2063     SERVER_END_REQ;
2064     /* Let some APC be run, so that we can run the remaining APCs on hFile
2065      * either the cancelation of the pending one, but also the execution
2066      * of the queued APC, but not yet run. This is needed to ensure proper
2067      * clean-up of allocated data.
2068      */
2069     timeout.u.LowPart = timeout.u.HighPart = 0;
2070     return io_status->u.Status = NtDelayExecution( TRUE, &timeout );
2071 }
2072
2073 /******************************************************************************
2074  *  NtCreateMailslotFile        [NTDLL.@]
2075  *  ZwCreateMailslotFile        [NTDLL.@]
2076  *
2077  * PARAMS
2078  *  pHandle          [O] pointer to receive the handle created
2079  *  DesiredAccess    [I] access mode (read, write, etc)
2080  *  ObjectAttributes [I] fully qualified NT path of the mailslot
2081  *  IoStatusBlock    [O] receives completion status and other info
2082  *  CreateOptions    [I]
2083  *  MailslotQuota    [I]
2084  *  MaxMessageSize   [I]
2085  *  TimeOut          [I]
2086  *
2087  * RETURNS
2088  *  An NT status code
2089  */
2090 NTSTATUS WINAPI NtCreateMailslotFile(PHANDLE pHandle, ULONG DesiredAccess,
2091      POBJECT_ATTRIBUTES attr, PIO_STATUS_BLOCK IoStatusBlock,
2092      ULONG CreateOptions, ULONG MailslotQuota, ULONG MaxMessageSize,
2093      PLARGE_INTEGER TimeOut)
2094 {
2095     static const WCHAR leadin[] = {
2096         '\\','?','?','\\','M','A','I','L','S','L','O','T','\\'};
2097     NTSTATUS ret;
2098
2099     TRACE("%p %08lx %p %p %08lx %08lx %08lx %p\n",
2100               pHandle, DesiredAccess, attr, IoStatusBlock,
2101               CreateOptions, MailslotQuota, MaxMessageSize, TimeOut);
2102
2103     if (attr->ObjectName->Length < sizeof(leadin) ||
2104         strncmpiW( attr->ObjectName->Buffer, 
2105                    leadin, sizeof(leadin)/sizeof(leadin[0]) ))
2106     {
2107         return STATUS_OBJECT_NAME_INVALID;
2108     }
2109
2110     SERVER_START_REQ( create_mailslot )
2111     {
2112         req->access = DesiredAccess;
2113         req->attributes = (attr) ? attr->Attributes : 0;
2114         req->rootdir = attr ? attr->RootDirectory : 0;
2115         req->max_msgsize = MaxMessageSize;
2116         req->read_timeout = (TimeOut->QuadPart <= 0) ? TimeOut->QuadPart / -10000 : -1;
2117         wine_server_add_data( req, attr->ObjectName->Buffer,
2118                               attr->ObjectName->Length );
2119         ret = wine_server_call( req );
2120         if( ret == STATUS_SUCCESS )
2121             *pHandle = reply->handle;
2122     }
2123     SERVER_END_REQ;
2124  
2125     return ret;
2126 }