A brief file description. More...
#include "libts.h"
#include "I_EventSystem.h"
#include "I_RecProcess.h"
Go to the source code of this file.
A brief file description.
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Definition in file I_AIO.h.
#define AIO_CALLBACK_THREAD_AIO ((EThread*)-1) |
Definition at line 95 of file I_AIO.h.
Referenced by aio_thread_main().
#define AIO_CALLBACK_THREAD_ANY ((EThread*)0) |
Definition at line 94 of file I_AIO.h.
Referenced by aio_thread_main(), and CacheVC::handleRead().
#define AIO_EVENT_DONE (AIO_EVENT_EVENTS_START+0) |
Definition at line 44 of file I_AIO.h.
Referenced by Vol::aggWrite(), Vol::aggWriteDone(), aio_thread_main(), CacheDisk::clearDone(), Cache::deref(), CacheVC::derefRead(), CacheVC::evacuateDocDone(), Vol::evacuateDocReadDone(), CacheVC::evacuateReadHead(), CacheTestSM::event_handler(), Vol::handle_dir_clear(), Vol::handle_dir_read(), Vol::handle_header_read(), Vol::handle_recover_from_data(), CacheVC::handleReadDone(), CacheVC::handleWrite(), CacheVC::handleWriteLock(), ink_aio_read(), ink_aio_write(), AIOCallbackInternal::io_complete(), CacheVC::linkWrite(), CacheSync::mainEvent(), Cache::open_read(), CacheVC::openReadClose(), CacheVC::openReadMain(), CacheVC::openReadReadDone(), CacheVC::openReadStartEarliest(), CacheVC::openReadStartHead(), CacheDisk::openStart(), CacheVC::openWriteClose(), CacheVC::openWriteCloseDataDone(), CacheVC::openWriteCloseHeadDone(), CacheVC::openWriteOverwrite(), CacheVC::openWriteWriteDone(), CacheVC::scanOpenWrite(), and CacheDisk::syncDone().
#define AIO_LOWEST_PRIORITY 0 |
Definition at line 97 of file I_AIO.h.
Referenced by aio_insert(), and CacheVC::set_disk_io_priority().
#define AIO_MODULE_VERSION |
Definition at line 40 of file I_AIO.h.
Referenced by ink_aio_init().
#define LIO_READ 0x1 |
Definition at line 57 of file I_AIO.h.
Referenced by cache_op().
#define LIO_WRITE 0x2 |
Definition at line 58 of file I_AIO.h.
Referenced by aio_thread_main().
typedef struct ink_aiocb ink_aiocb_t |
void ink_aio_init | ( | ModuleVersion | version | ) |
Definition at line 147 of file AIO.cc.
References AIO_MODULE_VERSION, AIO_STAT_COUNT, AIO_STAT_KB_READ_PER_SEC, AIO_STAT_KB_WRITE_PER_SEC, AIO_STAT_READ_PER_SEC, AIO_STAT_WRITE_PER_SEC, aio_stats_cb(), cache_config_threads_per_disk, checkModuleVersion(), ink_mutex_init(), ink_release_assert, insert_mutex, MAX_DISKS_POSSIBLE, REC_ReadConfigInteger, RecAllocateRawStatBlock(), RECD_FLOAT, RECP_PERSISTENT, RecRegisterRawStat, and RECT_PROCESS.
Referenced by main().
int ink_aio_read | ( | AIOCallback * | op, | |
int | fromAPI = 0 | |||
) |
Definition at line 428 of file AIO.cc.
References AIOCallback::action, AIO_EVENT_DONE, ink_aiocb::aio_lio_opcode, aio_queue_req(), AIOCallback::aiocb, cache_op(), Action::continuation, Continuation::handleEvent(), ink_assert, this_ethread(), AIOCallback::thread, and Warning.
Referenced by Vol::evac_range(), Vol::handle_header_read(), Vol::handle_recover_from_data(), CacheVC::handleRead(), Vol::init(), CacheDisk::open(), CacheVC::scanObject(), and TSAIORead().
int ink_aio_readv | ( | AIOCallback * | op, | |
int | fromAPI = 0 | |||
) |
Referenced by Vol::init().
void ink_aio_set_callback | ( | Continuation * | error_callback | ) |
Definition at line 141 of file AIO.cc.
Referenced by CacheProcessor::start_internal().
int ink_aio_start | ( | ) |
Definition at line 170 of file AIO.cc.
References ET_CALL, eventProcessor, HRTIME_MSECONDS, and EventProcessor::schedule_in().
bool ink_aio_thread_num_set | ( | int | thread_num | ) |
Definition at line 474 of file AIO.cc.
References api_config_threads_per_disk, and thread_is_created.
Referenced by TSAIOThreadNumSet().
int ink_aio_write | ( | AIOCallback * | op, | |
int | fromAPI = 0 | |||
) |
Definition at line 451 of file AIO.cc.
References AIOCallback::action, AIO_EVENT_DONE, ink_aiocb::aio_lio_opcode, aio_queue_req(), AIOCallback::aiocb, cache_op(), Action::continuation, Continuation::handleEvent(), ink_assert, this_ethread(), AIOCallback::thread, and Warning.
Referenced by Vol::aggWrite(), CacheSync::aio_write(), Vol::clear_dir(), CacheDisk::clearDisk(), Vol::handle_dir_clear(), Vol::handle_recover_from_data(), CacheDisk::sync(), and TSAIOWrite().
int ink_aio_writev | ( | AIOCallback * | op, | |
int | fromAPI = 0 | |||
) |
Referenced by Vol::handle_recover_from_data().
AIOCallback* new_AIOCallback | ( | void | ) |
Definition at line 135 of file AIO.cc.
Referenced by TSAIORead(), and TSAIOWrite().