A brief file description. More...
#include "libts.h"#include "I_Thread.h"#include "I_PriorityEventQueue.h"#include "I_ProtectedQueue.h"
Go to the source code of this file.
Data Structures | |
| class | EThread |
| Event System specific type of thread. More... | |
| class | ink_dummy_for_new |
| This is used so that we dont use up operator new(size_t, void *) which users might want to define for themselves. More... | |
Defines | |
| #define | PER_THREAD_DATA (1024*1024) |
| #define | MUTEX_RETRY_DELAY HRTIME_MSECONDS(20) |
| #define | MAX_ACCEPT_EVENTS 20 |
| Maximum number of accept events per thread. | |
| #define | ETHREAD_GET_PTR(thread, offset) ((void*)((char*)(thread)+(offset))) |
Enumerations | |
| enum | ThreadType { REGULAR = 0, MONITOR, DEDICATED } |
Functions | |
| void * | operator new (size_t, ink_dummy_for_new *p) |
| EThread * | this_ethread () |
Detailed Description
A brief file description.
License
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_EThread.h.
Define Documentation
| #define ETHREAD_GET_PTR | ( | thread, | ||
| offset | ||||
| ) | ((void*)((char*)(thread)+(offset))) |
Definition at line 342 of file I_EThread.h.
Referenced by get_NetHandler(), get_PollCont(), get_UDPNetHandler(), and get_UDPPollCont().
| #define MAX_ACCEPT_EVENTS 20 |
Maximum number of accept events per thread.
Definition at line 42 of file I_EThread.h.
| #define MUTEX_RETRY_DELAY HRTIME_MSECONDS(20) |
Definition at line 39 of file I_EThread.h.
Referenced by HostDBContinuation::dnsEvent(), HostDBProcessor::getSRVbyname_imm(), and HostDBProcessor::setby().
| #define PER_THREAD_DATA (1024*1024) |
Definition at line 35 of file I_EThread.h.
Referenced by EventProcessor::allocate(), and EThread::EThread().
Enumeration Type Documentation
| enum ThreadType |
Definition at line 51 of file I_EThread.h.
Function Documentation
| void* operator new | ( | size_t | , | |
| ink_dummy_for_new * | p | |||
| ) | [inline] |
Definition at line 338 of file I_EThread.h.
| EThread* this_ethread | ( | ) |
Definition at line 160 of file P_UnixEThread.h.
References this_thread().
Referenced by HttpSessionAccept::accept(), UnixNetProcessor::accept_internal(), NetAccept::acceptLoopEvent(), Log::access(), HttpSessionManager::acquire_session(), CongestionDB::addRecord(), agg_copy(), KeepAliveConnTable::append(), Vol::begin_read(), cache(), Cache_dir(), cache_lookup_ClusterFunction(), cache_op_ClusterFunction(), cache_op_result_ClusterFunction(), CacheProcessor::cacheInitialized(), HttpTransact::calculate_freshness_fuzz(), CacheContinuation::callback_user(), CacheVC::callcont(), CacheVC::calluser(), ChannelToCacheWriteVC(), InactivityCop::check_inactivity(), RegressionSM::child_done(), UpdateScheduler::ChildExitEventHandler(), Vol::close_read(), OpenDir::close_write(), clusterAPI_init(), ClusterMachine::ClusterMachine(), configuration_add_machine(), configuration_remove_machine(), ClusterProcessor::connect_local(), PluginVCCore::connect_re(), create_config(), dir_delete(), dir_insert(), dir_lookaside_cleanup(), dir_lookaside_fixup(), dir_lookaside_insert(), dir_lookaside_probe(), dir_lookaside_remove(), dir_overwrite(), dir_probe(), HostDBContinuation::dnsEvent(), HostDBContinuation::dnsPendingEvent(), UnixNetVConnection::do_io_close(), PluginVC::do_io_close(), CacheVC::do_io_close(), CacheContinuation::do_op(), ClusterHandler::do_open_local_requests(), CacheContinuation::do_remote_lookup(), ClusterState::doIO(), ProtectedQueue::enqueue(), CacheVC::evacuateDocDone(), Vol::evacuateDocReadDone(), CacheVC::evacuateReadHead(), ConfigUpdateCallback::event_handler(), ClusterVConnectionCacheEvent::eventHandler(), RecursiveHttpGet::ExitEventHandler(), FetchSM::ext_destroy(), FetchSM::ext_read_data(), FetchSM::ext_write_data(), CongestionEntry::failed_at(), flush_signals(), UnixNetVConnection::free(), SocksEntry::free(), PrefetchUrlBlaster::free(), free_CacheVC(), free_ClusterMachine(), CongestionDBCont::GC(), InkStaticPool_r< C >::get(), get_congest_entry(), CongestionDBCont::get_congest_entry(), get_congest_list(), CongestionDBCont::get_congest_list(), DNSProcessor::getby(), HostDBProcessor::getbyname_imm(), HostDBProcessor::getbyname_re(), UpdateConfigManager::GetConfigList(), UpdateConfigManager::GetConfigParams(), HostDBProcessor::getSRVbyname_imm(), HttpPagesHandler::handle_callback(), RangeTransform::handle_event(), NullTransform::handle_event(), TransformTerminus::handle_event(), PrefetchTransform::handle_event(), HttpPagesHandler::handle_smdetails(), HttpPagesHandler::handle_smlist(), CacheContinuation::handleDisposeEvent(), PrefetchBlaster::handleEvent(), BlasterUrlList::handleEvent(), CacheVC::handleRead(), CacheVC::handleReadDone(), UpdateSM::HandleSMEvent(), AtomicLock::HaveLock(), ICPConfiguration::icp_config_change_callback(), ICPProcessor::ICPQuery(), Vol::increment_generation(), SocksProxy::init(), SocksEntry::init(), KeepAliveLockHandler::init(), PrefetchUrlBlaster::init(), PrefetchBlaster::init(), PluginVCCore::init(), OneWayTunnel::init(), UDPReadContinuation::init_read(), ink_aio_read(), ink_aio_write(), HostDBContinuation::insert(), ClusterVConnectionCache::insert(), ClusterProcessor::internal_invoke_remote(), ClusterState::IOComplete(), HttpUpdateSM::kill_this_async_hook(), SSLNetVConnection::load_buffer_and_write(), AtomicLock::Lock(), LogBuffer::LogBuffer(), ClusterVConnectionCache::lookup(), HostDBContinuation::lookup_done(), ClusterHandler::machine_down(), MachineStatusSM::MachineStatusSMEvent(), ClusterHandler::mainClusterEvent(), UnixNetVConnection::mainEvent(), SocksProxy::mainEvent(), SocksEntry::mainEvent(), HttpClientSession::new_connection(), new_HdrHeap(), new_HdrStrHeap(), ObjectReloadCont::ObjectReloadEvent(), ClusterProcessor::open_local(), Vol::open_write(), Cache::open_write(), OpenDir::open_write(), CacheVC::openWriteCloseDataDone(), CacheVC::openWriteCloseDir(), CacheVC::openWriteOverwrite(), ICPPeerReadCont::PeerReadStateMachine(), RemapProcessor::perform_remap(), post_setchan_pin_ClusterFunction(), post_setchan_priority_ClusterFunction(), post_setchan_send_ClusterFunction(), probe(), HostDBContinuation::probeEvent(), ClusterHandler::protoZombieEvent(), HttpSessionManager::purge_keepalives(), RamCacheLRU::put(), RamCacheCLFUS::put(), InkStaticPool_r< C >::put(), raw_stat_get_tlp(), read_signal_and_update(), ClusterControl::real_alloc_data(), HttpTransact::State::record_transaction_stats(), UDPNetProcessor::recvfrom_re(), UnixNetVConnection::reenable(), PluginVC::reenable(), UnixNetVConnection::reenable_re(), PluginVC::reenable_re(), register_ShowHostDB(), HttpSessionManager::release_session(), CacheContinuation::remoteOpEvent(), Cache::remove(), CacheContinuation::remove_and_delete(), CongestionDB::removeAllRecords(), CacheVC::removeEvent(), CongestionDB::removeRecord(), OOB_callback::retry_OOB_send(), revalidateCongestionDB(), RegressionSM::run(), CacheTestSM::run(), Event::schedule_at(), Event::schedule_every(), Event::schedule_imm(), Event::schedule_in(), send_connection_event(), UnixNetVConnection::send_OOB(), send_plugin_event(), UDPNetProcessor::sendmsg_re(), UnixNetVConnection::set_active_timeout(), ClusterVConnectionBase::set_active_timeout(), set_channel_data_ClusterFunction(), UnixNetVConnection::set_enabled(), UnixNetVConnection::set_inactivity_timeout(), ClusterVConnectionBase::set_inactivity_timeout(), HostDBProcessor::setby(), CacheContinuation::setupVCdataRead(), ClusterAccept::ShutdownDelete(), ICPPeerReadCont::StaleCheck(), PrefetchProcessor::start(), Http2ClientSession::start(), HttpUpdateSM::start_scheduled_update(), PVCTestDriver::start_tests(), ClusterHandler::startClusterEvent(), SocksEntry::startEvent(), PluginVCCore::state_send_accept(), PluginVCCore::state_send_accept_failed(), TSAddClusterRPCFunction(), TSAddClusterStatusFunction(), TSDeleteClusterRPCFunction(), TSDeleteClusterStatusFunction(), TSdrandom(), TSHttpSsnReenable(), TSHttpTxnReenable(), TSMutexLock(), TSMutexLockTry(), TSMutexUnlock(), TSrandom(), TSThreadSelf(), TSVConnFdCreate(), AtomicLock::Unlock(), Log::va_error(), write_signal_and_update(), ClusterHandler::~ClusterHandler(), ICPProcessor::~ICPProcessor(), InkStaticPool_r< C >::~InkStaticPool_r(), LogBuffer::~LogBuffer(), and PrefetchTransform::~PrefetchTransform().
