]>
Commit | Line | Data |
---|---|---|
1 | /* | |
2 | * Copyright (C) 1996-2021 The Squid Software Foundation and contributors | |
3 | * | |
4 | * Squid software is distributed under GPLv2+ license and includes | |
5 | * contributions from numerous individuals and organizations. | |
6 | * Please see the COPYING and CONTRIBUTORS files for details. | |
7 | */ | |
8 | ||
9 | #ifndef __ASYNC_IO_H__ | |
10 | #define __ASYNC_IO_H__ | |
11 | ||
12 | #if HAVE_DISKIO_MODULE_AIO | |
13 | ||
14 | #if _SQUID_WINDOWS_ | |
15 | #include "DiskIO/AIO/aio_win32.h" | |
16 | #else | |
17 | #if HAVE_AIO_H | |
18 | #include <aio.h> | |
19 | #endif | |
20 | #endif | |
21 | ||
22 | #include "mem/forward.h" | |
23 | ||
24 | #define MAX_ASYNCOP 128 | |
25 | ||
26 | typedef enum { | |
27 | AQ_STATE_NONE, /* Not active/uninitialised */ | |
28 | AQ_STATE_SETUP /* Initialised */ | |
29 | } async_queue_state_t; | |
30 | ||
31 | typedef enum { | |
32 | AQ_ENTRY_FREE, | |
33 | AQ_ENTRY_USED | |
34 | } async_queue_entry_state_t; | |
35 | ||
36 | typedef enum { | |
37 | AQ_ENTRY_NONE, | |
38 | AQ_ENTRY_READ, | |
39 | AQ_ENTRY_WRITE | |
40 | } async_queue_entry_type_t; | |
41 | ||
42 | typedef struct _async_queue_entry async_queue_entry_t; | |
43 | ||
44 | typedef struct _async_queue async_queue_t; | |
45 | ||
46 | /* An async queue entry */ | |
47 | ||
48 | class AIODiskFile; | |
49 | ||
50 | struct _async_queue_entry { | |
51 | async_queue_entry_state_t aq_e_state; | |
52 | async_queue_entry_type_t aq_e_type; | |
53 | ||
54 | /* 64-bit environments with non-GCC complain about the type mismatch on Linux */ | |
55 | #if defined(__USE_FILE_OFFSET64) && !defined(__GNUC__) | |
56 | struct aiocb64 aq_e_aiocb; | |
57 | #else | |
58 | struct aiocb aq_e_aiocb; | |
59 | #endif | |
60 | AIODiskFile *theFile; | |
61 | void *aq_e_callback_data; | |
62 | FREE *aq_e_free; | |
63 | int aq_e_fd; | |
64 | void *aq_e_buf; | |
65 | }; | |
66 | ||
67 | /* An async queue */ | |
68 | ||
69 | struct _async_queue { | |
70 | async_queue_state_t aq_state; | |
71 | async_queue_entry_t aq_queue[MAX_ASYNCOP]; /* queued ops */ | |
72 | int aq_numpending; /* Num of pending ops */ | |
73 | }; | |
74 | ||
75 | #endif /* HAVE_DISKIO_MODULE_AIO */ | |
76 | #endif /* __ASYNC_IO_H_ */ | |
77 |