ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/IO-AIO/AIO.xs
(Generate patch)

Comparing IO-AIO/AIO.xs (file contents):
Revision 1.13 by root, Fri Jul 22 08:25:22 2005 UTC vs.
Revision 1.16 by root, Sun Jul 31 18:20:07 2005 UTC

1#define _XOPEN_SOURCE 500
2
3#include "EXTERN.h" 1#include "EXTERN.h"
4#include "perl.h" 2#include "perl.h"
5#include "XSUB.h" 3#include "XSUB.h"
4
5#include "autoconf/config.h"
6 6
7#include <sys/types.h> 7#include <sys/types.h>
8#include <sys/stat.h> 8#include <sys/stat.h>
9 9
10#include <unistd.h> 10#include <unistd.h>
11#include <fcntl.h> 11#include <fcntl.h>
12#include <signal.h> 12#include <signal.h>
13#include <sched.h> 13#include <sched.h>
14#if __linux
15#include <sys/syscall.h>
16#endif
17 14
18#include <pthread.h> 15#include <pthread.h>
19 16
20typedef void *InputStream; /* hack, but 5.6.1 is simply toooo old ;) */ 17typedef void *InputStream; /* hack, but 5.6.1 is simply toooo old ;) */
21typedef void *OutputStream; /* hack, but 5.6.1 is simply toooo old ;) */ 18typedef void *OutputStream; /* hack, but 5.6.1 is simply toooo old ;) */
… …
267 264
268 type = req->type; 265 type = req->type;
269 266
270 switch (type) 267 switch (type)
271 { 268 {
269#if HAVE_PREADWRITE
272 case REQ_READ: req->result = pread (req->fd, req->dataptr, req->length, req->offset); break; 270 case REQ_READ: req->result = pread (req->fd, req->dataptr, req->length, req->offset); break;
273 case REQ_WRITE: req->result = pwrite (req->fd, req->dataptr, req->length, req->offset); break; 271 case REQ_WRITE: req->result = pwrite (req->fd, req->dataptr, req->length, req->offset); break;
274#if SYS_readahead 272#else
273# error "pread/pwrite cannot be emulated, fix your os"
274#endif
275
276#if HAVE_READAHEAD
275 case REQ_READAHEAD: req->result = readahead (req->fd, req->offset, req->length); break; 277 case REQ_READAHEAD: req->result = readahead (req->fd, req->offset, req->length); break;
276#else 278#else
279 // TODO: emulate
277 case REQ_READAHEAD: req->result = -1; errno = ENOSYS; break; 280 case REQ_READAHEAD: req->result = -1; errno = ENOSYS; break;
278#endif 281#endif
279 282
280 case REQ_STAT: req->result = stat (req->dataptr, req->statdata); break; 283 case REQ_STAT: req->result = stat (req->dataptr, req->statdata); break;
281 case REQ_LSTAT: req->result = lstat (req->dataptr, req->statdata); break; 284 case REQ_LSTAT: req->result = lstat (req->dataptr, req->statdata); break;
… …
283 286
284 case REQ_OPEN: req->result = open (req->dataptr, req->fd, req->mode); break; 287 case REQ_OPEN: req->result = open (req->dataptr, req->fd, req->mode); break;
285 case REQ_CLOSE: req->result = close (req->fd); break; 288 case REQ_CLOSE: req->result = close (req->fd); break;
286 case REQ_UNLINK: req->result = unlink (req->dataptr); break; 289 case REQ_UNLINK: req->result = unlink (req->dataptr); break;
287 290
291 case REQ_FDATASYNC:
292#if HAVE_FDATASYNC
293 req->result = fdatasync (req->fd); break;
294#endif
288 case REQ_FSYNC: req->result = fsync (req->fd); break; 295 case REQ_FSYNC: req->result = fsync (req->fd); break;
289 case REQ_FDATASYNC: req->result = fdatasync (req->fd); break;
290 296
291 case REQ_QUIT: 297 case REQ_QUIT:
292 break; 298 break;
293 299
294 default: 300 default:

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines