2 * Copyright (C) 1996-2015 The Squid Software Foundation and contributors
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.
12 * Internal declarations for the DiskThreads routines
15 #ifndef __DISKTHREADS_H__
16 #define __DISKTHREADS_H__
21 /* this non-standard-conformant include is needed in order to have stat(2) and struct stat
22 properly defined on some systems (e.g. OpenBSD 5.4) */
28 #define NUMTHREADS AUFS_IO_THREADS
30 #define NUMTHREADS (Config.cacheSwap.n_configured*16)
33 /* Queue limit where swapouts are deferred (load calculation) */
34 #define MAGIC1 (NUMTHREADS*Config.cacheSwap.n_configured*5)
35 /* Queue limit where swapins are deferred (open/create fails) */
36 #define MAGIC2 (NUMTHREADS*Config.cacheSwap.n_configured*20)
38 /* Which operations to run async */
41 #define ASYNC_CREATE 1
45 enum _squidaio_request_type
{
55 typedef enum _squidaio_request_type squidaio_request_type
;
57 typedef void AIOCB(int fd
, void *cbdata
, const char *buf
, int aio_return
, int aio_errno
);
59 struct squidaio_result_t
{
62 enum _squidaio_request_type result_type
;
63 void *_data
; /* Internal housekeeping */
64 void *data
; /* Available to the caller */
67 struct squidaio_ctrl_t
{
69 struct squidaio_ctrl_t
*next
;
73 void *done_handler_data
;
74 squidaio_result_t result
;
81 void squidaio_init(void);
82 void squidaio_shutdown(void);
83 int squidaio_cancel(squidaio_result_t
*);
84 int squidaio_open(const char *, int, mode_t
, squidaio_result_t
*);
85 int squidaio_read(int, char *, size_t, off_t
, int, squidaio_result_t
*);
86 int squidaio_write(int, char *, size_t, off_t
, int, squidaio_result_t
*);
87 int squidaio_close(int, squidaio_result_t
*);
89 int squidaio_stat(const char *, struct stat
*, squidaio_result_t
*);
90 int squidaio_unlink(const char *, squidaio_result_t
*);
91 int squidaio_opendir(const char *, squidaio_result_t
*);
92 squidaio_result_t
*squidaio_poll_done(void);
93 int squidaio_operations_pending(void);
94 int squidaio_sync(void);
95 int squidaio_get_queue_len(void);
96 void *squidaio_xmalloc(int size
);
97 void squidaio_xfree(void *p
, int size
);
98 void squidaio_stats(StoreEntry
*);
103 void aioOpen(const char *, int, mode_t
, AIOCB
*, void *);
105 void aioWrite(int, off_t offset
, char *, size_t size
, AIOCB
*, void *, FREE
*);
106 void aioRead(int, off_t offset
, size_t size
, AIOCB
*, void *);
108 void aioStat(char *, struct stat
*, AIOCB
*, void *);
109 void aioUnlink(const char *, AIOCB
*, void *);
110 int aioQueueSize(void);
112 #include "DiskIO/DiskFile.h"
114 class DiskThreadsIOStrategy
;
118 uint64_t open_finish
;
119 uint64_t close_start
;
120 uint64_t close_finish
;
122 uint64_t write_start
;
123 uint64_t write_finish
;
125 uint64_t read_finish
;
127 uint64_t stat_finish
;
128 uint64_t unlink_start
;
129 uint64_t unlink_finish
;
130 uint64_t check_callback
;
133 extern AIOCounts squidaio_counts
;
134 extern dlink_list used_list
;