A brief file description. More...
#include "libts.h"
#include "api/ts/InkAPIPrivateIOCore.h"
#include "I_EventSystem.h"
#include "I_Net.h"
#include "I_Cache.h"
#include "I_HostDB.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 InkIOCoreAPI.cc.
#define sdk_assert | ( | EX | ) | ( (void)((EX) ? (void)0 : _TSReleaseAssert(#EX, __FILE__, __LINE__)) ) |
Definition at line 46 of file InkIOCoreAPI.cc.
Referenced by INKUDPBind(), INKUDPPacketBufferBlockGet(), INKUDPPacketConnGet(), INKUDPPacketDestroy(), INKUDPPacketFromAddressGet(), INKUDPPacketFromPortGet(), INKUDPRecvFrom(), INKUDPSendTo(), TSIOBufferBlockDataSizeGet(), TSIOBufferBlockDestroy(), TSIOBufferBlockNext(), TSIOBufferBlockReadAvail(), TSIOBufferBlockReadStart(), TSIOBufferBlockWriteAvail(), TSIOBufferBlockWriteStart(), TSIOBufferCopy(), TSIOBufferCreate(), TSIOBufferDestroy(), TSIOBufferProduce(), TSIOBufferReaderAlloc(), TSIOBufferReaderAvail(), TSIOBufferReaderClone(), TSIOBufferReaderConsume(), TSIOBufferReaderFree(), TSIOBufferReaderStart(), TSIOBufferSizedCreate(), TSIOBufferStart(), TSIOBufferWaterMarkGet(), TSIOBufferWaterMarkSet(), TSIOBufferWrite(), TSMutexCreate(), TSMutexCreateInternal(), TSMutexLock(), TSMutexLockTry(), TSMutexUnlock(), TSThreadDestroy(), TSVIOBufferGet(), TSVIOContGet(), TSVIOMutexGet(), TSVIONBytesGet(), TSVIONBytesSet(), TSVIONDoneGet(), TSVIONDoneSet(), TSVIONTodoGet(), TSVIOReaderGet(), TSVIOReenable(), and TSVIOVConnGet().
static void* ink_thread_trampoline | ( | void * | data | ) | [static] |
Definition at line 107 of file InkIOCoreAPI.cc.
References INKThreadInternal::data, INKThreadInternal::func, and Thread::set_specific().
Referenced by TSThreadCreate().
ink_hrtime INKBasedTimeGet | ( | ) |
Definition at line 348 of file InkIOCoreAPI.cc.
References ink_get_based_hrtime().
Definition at line 356 of file InkIOCoreAPI.cc.
References ats_ip4_set(), ats_ip_sa_cast(), FORCE_PLUGIN_MUTEX, INK_ETHERNET_MTU_SIZE, sdk_assert, sdk_sanity_check_continuation(), TS_SUCCESS, UDPNetProcessor::UDPBind(), and udpNet.
Referenced by UDPClientTestInit(), and UDPTestInit().
int INKUDPConnFdGet | ( | INKUDPConn | udp | ) |
Definition at line 410 of file InkIOCoreAPI.cc.
References UDPConnection::getFd().
TSIOBufferBlock INKUDPPacketBufferBlockGet | ( | INKUDPPacket | packet | ) |
Definition at line 425 of file InkIOCoreAPI.cc.
References UDPPacket::getIOBlockChain(), sdk_assert, sdk_sanity_check_null_ptr(), and TS_SUCCESS.
Referenced by handle_callbacks(), and UDPClient_handle_callbacks().
INKUDPConn INKUDPPacketConnGet | ( | INKUDPPacket | packet | ) |
Definition at line 452 of file InkIOCoreAPI.cc.
References UDPPacket::getConnection(), sdk_assert, sdk_sanity_check_null_ptr(), and TS_SUCCESS.
Referenced by handle_callbacks().
INKUDPPacket INKUDPPacketCreate | ( | ) |
Definition at line 418 of file InkIOCoreAPI.cc.
References new_UDPPacket().
void INKUDPPacketDestroy | ( | INKUDPPacket | packet | ) |
Definition at line 461 of file InkIOCoreAPI.cc.
References UDPPacket::free(), sdk_assert, sdk_sanity_check_null_ptr(), and TS_SUCCESS.
Referenced by handle_callbacks(), and UDPClient_handle_callbacks().
unsigned int INKUDPPacketFromAddressGet | ( | INKUDPPacket | packet | ) |
Definition at line 434 of file InkIOCoreAPI.cc.
References ats_ip4_addr_cast(), UDPPacket::from, sdk_assert, sdk_sanity_check_null_ptr(), and TS_SUCCESS.
Referenced by handle_callbacks().
int INKUDPPacketFromPortGet | ( | INKUDPPacket | packet | ) |
Definition at line 443 of file InkIOCoreAPI.cc.
References ats_ip_port_host_order(), UDPPacket::from, sdk_assert, sdk_sanity_check_null_ptr(), and TS_SUCCESS.
Referenced by handle_callbacks().
INKUDPPacket INKUDPPacketGet | ( | INKUDPacketQueue | queuep | ) |
Definition at line 472 of file InkIOCoreAPI.cc.
References Queue< C, L >::pop().
Referenced by handle_callbacks(), and UDPClient_handle_callbacks().
TSAction INKUDPRecvFrom | ( | TSCont | contp, | |
INKUDPConn | udp | |||
) |
Definition at line 400 of file InkIOCoreAPI.cc.
References FORCE_PLUGIN_MUTEX, UDPConnection::recv(), sdk_assert, sdk_sanity_check_continuation(), and TS_SUCCESS.
Referenced by handle_callbacks(), and UDPClient_handle_callbacks().
TSAction INKUDPSendTo | ( | TSCont | contp, | |
INKUDPConn | udp, | |||
unsigned int | ip, | |||
int | port, | |||
char * | data, | |||
int64_t | len | |||
) |
Definition at line 369 of file InkIOCoreAPI.cc.
References IOBufferBlock::alloc(), UDPPacket::append_block(), ats_ip4_set(), BUFFER_SIZE_INDEX_32K, IOBufferBlock::fill(), FORCE_PLUGIN_MUTEX, index_to_buffer_size(), memcpy, new_IOBufferBlock, new_UDPPacket(), sdk_assert, sdk_sanity_check_continuation(), UDPConnection::send(), IOBufferBlock::start(), UDPPacket::to, and TS_SUCCESS.
TSReturnCode sdk_sanity_check_continuation | ( | TSCont | cont | ) |
Definition at line 572 of file InkAPI.cc.
References INKCONT_INTERN_MAGIC_DEAD.
Referenced by INKUDPBind(), INKUDPRecvFrom(), INKUDPSendTo(), TSFetchCreate(), TSFetchUrl(), TSHostLookup(), TSHttpHookAdd(), TSHttpSsnHookAdd(), TSHttpTxnHookAdd(), TSHttpTxnIntercept(), TSHttpTxnServerIntercept(), TSICPCachedReqGet(), TSICPCachedRespGet(), TSLifecycleHookAdd(), TSNetAccept(), TSNetConnect(), and TSNetConnectTransparent().
TSReturnCode sdk_sanity_check_hostlookup_structure | ( | TSHostLookupResult | data | ) |
Definition at line 69 of file InkIOCoreAPI.cc.
Referenced by TSHostLookupResultAddrGet().
TSReturnCode sdk_sanity_check_iocore_structure | ( | void * | data | ) |
Definition at line 78 of file InkIOCoreAPI.cc.
Referenced by TSAIORead(), TSAIOWrite(), TSCacheKeyDigestSet(), TSCacheRead(), TSCacheRemove(), TSCacheScan(), TSCacheWrite(), TSContDataGet(), TSContDataSet(), TSContDestroy(), TSContMutexGet(), TSContSchedule(), TSContScheduleEvery(), TSHttpHdrPrint(), TSHttpSchedule(), TSIOBufferBlockDataSizeGet(), TSIOBufferBlockDestroy(), TSIOBufferBlockNext(), TSIOBufferBlockReadAvail(), TSIOBufferBlockReadStart(), TSIOBufferBlockWriteAvail(), TSIOBufferBlockWriteStart(), TSIOBufferCopy(), TSIOBufferCreate(), TSIOBufferDestroy(), TSIOBufferProduce(), TSIOBufferReaderAlloc(), TSIOBufferReaderAvail(), TSIOBufferReaderClone(), TSIOBufferReaderConsume(), TSIOBufferReaderFree(), TSIOBufferReaderStart(), TSIOBufferSizedCreate(), TSIOBufferStart(), TSIOBufferWaterMarkGet(), TSIOBufferWaterMarkSet(), TSIOBufferWrite(), TSMgmtUpdateRegister(), TSMimeHdrPrint(), TSNetVConnLocalAddrGet(), TSNetVConnRemoteAddrGet(), TSTextLogObjectDestroy(), TSTextLogObjectFlush(), TSTextLogObjectHeaderSet(), TSTextLogObjectRollingEnabledSet(), TSTextLogObjectRollingIntervalSecSet(), TSTextLogObjectRollingOffsetHrSet(), TSTextLogObjectWrite(), TSThreadDestroy(), TSTransformOutputVConnGet(), TSUrlPrint(), TSVConnAbort(), TSVConnActiveTimeoutCancel(), TSVConnActiveTimeoutSet(), TSVConnCacheHttpInfoSet(), TSVConnCacheObjectSizeGet(), TSVConnClose(), TSVConnClosedGet(), TSVConnInactivityTimeoutCancel(), TSVConnInactivityTimeoutSet(), TSVConnRead(), TSVConnReadVIOGet(), TSVConnShutdown(), TSVConnWrite(), TSVConnWriteVIOGet(), TSVIOBufferGet(), TSVIOContGet(), TSVIOMutexGet(), TSVIONBytesGet(), TSVIONBytesSet(), TSVIONDoneGet(), TSVIONDoneSet(), TSVIONTodoGet(), TSVIOReaderGet(), TSVIOReenable(), and TSVIOVConnGet().
TSReturnCode sdk_sanity_check_mutex | ( | TSMutex | mutex | ) |
Definition at line 52 of file InkIOCoreAPI.cc.
References RefCountObj::m_refcount, and ProxyMutex::nthread_holding.
Referenced by TSContCreate(), TSMutexCreate(), TSMutexCreateInternal(), TSMutexLock(), TSMutexLockTry(), TSMutexUnlock(), and TSVConnCreate().
TSReturnCode sdk_sanity_check_null_ptr | ( | void * | ptr | ) |
Definition at line 647 of file InkAPI.cc.
Referenced by INKUDPPacketBufferBlockGet(), INKUDPPacketConnGet(), INKUDPPacketDestroy(), INKUDPPacketFromAddressGet(), INKUDPPacketFromPortGet(), sdk_alloc_field_handle(), TSAIOWrite(), TSBase64Decode(), TSBase64Encode(), TSCacheDataTypeReady(), TSCacheKeyHostNameSet(), TSCacheReady(), TSFetchPageRespGet(), TSFetchRespGet(), TSHostLookup(), TSHttpArgIndexLookup(), TSHttpArgIndexNameLookup(), TSHttpArgIndexReserve(), TSHttpHdrMethodGet(), TSHttpHdrMethodSet(), TSHttpHdrParseReq(), TSHttpHdrParseResp(), TSHttpHdrReasonGet(), TSHttpHdrReasonSet(), TSHttpSsnClientFdGet(), TSHttpSsnSSLConnectionGet(), TSHttpTxnCachedReqGet(), TSHttpTxnCachedRespGet(), TSHttpTxnCachedRespModifiableGet(), TSHttpTxnCacheLookupCountGet(), TSHttpTxnCacheLookupStatusGet(), TSHttpTxnClientFdGet(), TSHttpTxnClientReqGet(), TSHttpTxnClientRespGet(), TSHttpTxnConfigFind(), TSHttpTxnConfigFloatGet(), TSHttpTxnConfigIntGet(), TSHttpTxnConfigStringGet(), TSHttpTxnEffectiveUrlStringGet(), TSHttpTxnIntercept(), TSHttpTxnMilestoneGet(), TSHttpTxnParentProxySet(), TSHttpTxnPristineUrlGet(), TSHttpTxnRedirectUrlSet(), TSHttpTxnServerIntercept(), TSHttpTxnServerReqGet(), TSHttpTxnServerRespGet(), TSICPCachedReqGet(), TSICPCachedRespGet(), TSIOBufferReaderAlloc(), TSIOBufferStart(), TSIOBufferWrite(), TSMatcherExtractIPRange(), TSMatcherLineDestroy(), TSMatcherLineName(), TSMatcherLineValue(), TSMatcherParseSrcIPConfigLine(), TSMatcherReadIntoBuffer(), TSMatcherTokLine(), TSMgmtUpdateRegister(), TSMimeHdrClone(), TSMimeHdrCreate(), TSMimeHdrFieldClone(), TSMimeHdrFieldCreate(), TSMimeHdrFieldCreateNamed(), TSMimeHdrFieldFind(), TSMimeHdrFieldNameGet(), TSMimeHdrFieldNameSet(), TSMimeHdrFieldValueAppend(), TSMimeHdrFieldValueStringGet(), TSMimeHdrFieldValueStringInsert(), TSMimeHdrFieldValueStringSet(), TSMimeHdrParse(), TSPluginRegister(), TSRedirectUrlSet(), TSStatCreate(), TSStatFindName(), TSStringPercentDecode(), TSStringPercentEncode(), TSTextLogObjectCreate(), TSTextLogObjectWrite(), TSUrlClone(), TSUrlCreate(), TSUrlParse(), TSUrlStringGet(), TSVConnCreate(), and URLPartGet().
int64_t TSIOBufferBlockDataSizeGet | ( | TSIOBufferBlock | blockp | ) |
Definition at line 598 of file InkIOCoreAPI.cc.
References IOBufferBlock::read_avail(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
void TSIOBufferBlockDestroy | ( | TSIOBufferBlock | blockp | ) |
Definition at line 579 of file InkIOCoreAPI.cc.
References IOBufferBlock::free(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
TSIOBufferBlock TSIOBufferBlockNext | ( | TSIOBufferBlock | blockp | ) |
Definition at line 588 of file InkIOCoreAPI.cc.
References IOBufferBlock::next, sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by FetchSM::ext_read_data(), SDK_API_TSIOBufferBlockNext(), spdy_recv_callback(), synclient_txn_read_response(), and synserver_txn_read_request().
int64_t TSIOBufferBlockReadAvail | ( | TSIOBufferBlock | blockp, | |
TSIOBufferReader | readerp | |||
) |
Definition at line 634 of file InkIOCoreAPI.cc.
References IOBufferReader::block, IOBufferBlock::read_avail(), sdk_assert, sdk_sanity_check_iocore_structure(), IOBufferReader::start_offset, and TS_SUCCESS.
Referenced by SDK_API_TSIOBufferBlockReadAvail().
const char* TSIOBufferBlockReadStart | ( | TSIOBufferBlock | blockp, | |
TSIOBufferReader | readerp, | |||
int64_t * | avail | |||
) |
Definition at line 607 of file InkIOCoreAPI.cc.
References IOBufferReader::block, IOBufferBlock::read_avail(), sdk_assert, sdk_sanity_check_iocore_structure(), IOBufferBlock::start(), IOBufferReader::start_offset, and TS_SUCCESS.
Referenced by convert_http_hdr_to_string(), convert_mime_hdr_to_string(), FetchSM::ext_read_data(), handle_callbacks(), SDK_API_TSHttpHdr(), SDK_API_TSIOBufferBlockReadAvail(), spdy_recv_callback(), synclient_txn_read_response(), synserver_txn_read_request(), test_url_print(), and UDPClient_handle_callbacks().
int64_t TSIOBufferBlockWriteAvail | ( | TSIOBufferBlock | blockp | ) |
Definition at line 668 of file InkIOCoreAPI.cc.
References sdk_assert, sdk_sanity_check_iocore_structure(), TS_SUCCESS, and IOBufferBlock::write_avail().
Referenced by SDK_API_TSIOBufferBlockReadAvail().
char* TSIOBufferBlockWriteStart | ( | TSIOBufferBlock | blockp, | |
int64_t * | avail | |||
) |
Definition at line 656 of file InkIOCoreAPI.cc.
References IOBufferBlock::end(), sdk_assert, sdk_sanity_check_iocore_structure(), TS_SUCCESS, and IOBufferBlock::write_avail().
Referenced by cache_handler(), load(), SDK_API_TSIOBufferBlockReadAvail(), synclient_txn_write_request(), and synserver_txn_write_response().
int64_t TSIOBufferCopy | ( | TSIOBuffer | bufp, | |
TSIOBufferReader | readerp, | |||
int64_t | length, | |||
int64_t | offset | |||
) |
Definition at line 536 of file InkIOCoreAPI.cc.
References sdk_assert, sdk_sanity_check_iocore_structure(), TS_SUCCESS, and MIOBuffer::write().
Referenced by handle_transform(), and SDK_API_TSIOBufferCopy().
TSIOBuffer TSIOBufferCreate | ( | void | ) |
Definition at line 489 of file InkIOCoreAPI.cc.
References new_empty_MIOBuffer, sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by PrefetchBlaster::blastObject(), cache_handler(), convert_http_hdr_to_string(), convert_mime_hdr_to_string(), handle_callbacks(), handle_transform(), load(), SDK_API_TSHttpHdr(), SDK_API_TSIOBufferBlockNext(), SDK_API_TSIOBufferBlockReadAvail(), SDK_API_TSIOBufferCreate(), server_handler(), spdy_cs_create(), synclient_txn_connect_handler(), synserver_accept_handler(), test_url_print(), and UDPClient_handle_callbacks().
void TSIOBufferDestroy | ( | TSIOBuffer | bufp | ) |
Definition at line 511 of file InkIOCoreAPI.cc.
References free_MIOBuffer(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), SpdyClientSession::clear(), convert_http_hdr_to_string(), convert_mime_hdr_to_string(), handle_callbacks(), my_data_destroy(), SDK_API_TSHttpHdr(), SDK_API_TSIOBufferCreate(), synclient_txn_close(), synserver_txn_close(), test_url_print(), UDPClient_handle_callbacks(), and SDK_NetVConn_Params::~SDK_NetVConn_Params().
void TSIOBufferProduce | ( | TSIOBuffer | bufp, | |
int64_t | nbytes | |||
) |
Definition at line 568 of file InkIOCoreAPI.cc.
References MIOBuffer::fill(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), load(), SDK_API_TSIOBufferProduce(), SDK_API_TSIOBufferReaderClone(), SDK_API_TSIOBufferReaderConsume(), synclient_txn_write_request(), and synserver_txn_write_response().
TSIOBufferReader TSIOBufferReaderAlloc | ( | TSIOBuffer | bufp | ) |
Definition at line 696 of file InkIOCoreAPI.cc.
References MIOBuffer::alloc_reader(), sdk_assert, sdk_sanity_check_iocore_structure(), sdk_sanity_check_null_ptr(), and TS_SUCCESS.
Referenced by PrefetchBlaster::blastObject(), cache_handler(), convert_http_hdr_to_string(), convert_mime_hdr_to_string(), handle_callbacks(), handle_transform(), load(), SDK_API_TSHttpHdr(), SDK_API_TSIOBufferBlockNext(), SDK_API_TSIOBufferBlockReadAvail(), SDK_API_TSIOBufferCopy(), SDK_API_TSIOBufferProduce(), SDK_API_TSIOBufferReaderClone(), SDK_API_TSIOBufferReaderConsume(), SDK_API_TSIOBufferStart(), spdy_cs_create(), synclient_txn_connect_handler(), synserver_accept_handler(), test_url_print(), and UDPClient_handle_callbacks().
int64_t TSIOBufferReaderAvail | ( | TSIOBufferReader | readerp | ) |
Definition at line 749 of file InkIOCoreAPI.cc.
References IOBufferReader::read_avail(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), convert_http_hdr_to_string(), convert_mime_hdr_to_string(), handle_transform(), load(), SDK_API_TSHttpHdr(), SDK_API_TSIOBufferProduce(), SDK_API_TSIOBufferReaderClone(), SDK_API_TSIOBufferReaderConsume(), spdy_process_write(), synclient_txn_read_response_handler(), synserver_txn_read_request_handler(), and test_url_print().
TSIOBufferReader TSIOBufferReaderClone | ( | TSIOBufferReader | readerp | ) |
Definition at line 709 of file InkIOCoreAPI.cc.
References IOBufferReader::clone(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by SDK_API_TSIOBufferReaderClone().
void TSIOBufferReaderConsume | ( | TSIOBufferReader | readerp, | |
int64_t | nbytes | |||
) |
Definition at line 739 of file InkIOCoreAPI.cc.
References IOBufferReader::consume(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), convert_http_hdr_to_string(), convert_mime_hdr_to_string(), FetchSM::ext_read_data(), handle_callbacks(), handle_transform(), SDK_API_TSHttpHdr(), SDK_API_TSIOBufferReaderClone(), SDK_API_TSIOBufferReaderConsume(), spdy_recv_callback(), synclient_txn_read_response_handler(), synserver_txn_read_request_handler(), test_url_print(), and UDPClient_handle_callbacks().
void TSIOBufferReaderCopy | ( | TSIOBufferReader | readerp, | |
const void * | buf, | |||
int64_t | length | |||
) |
Definition at line 561 of file InkIOCoreAPI.cc.
References IOBufferReader::memcpy().
Referenced by SDK_API_TSIOBufferCopy().
void TSIOBufferReaderFree | ( | TSIOBufferReader | readerp | ) |
Definition at line 718 of file InkIOCoreAPI.cc.
References MIOBuffer::dealloc_reader(), IOBufferReader::mbuf, sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by SpdyClientSession::clear(), convert_http_hdr_to_string(), convert_mime_hdr_to_string(), handle_callbacks(), SDK_API_TSHttpHdr(), test_url_print(), and UDPClient_handle_callbacks().
TSIOBufferBlock TSIOBufferReaderStart | ( | TSIOBufferReader | readerp | ) |
Definition at line 727 of file InkIOCoreAPI.cc.
References IOBufferReader::block, IOBufferReader::get_current_block(), sdk_assert, sdk_sanity_check_iocore_structure(), IOBufferReader::skip_empty_blocks(), and TS_SUCCESS.
Referenced by convert_http_hdr_to_string(), convert_mime_hdr_to_string(), FetchSM::ext_read_data(), SDK_API_TSHttpHdr(), SDK_API_TSIOBufferBlockNext(), SDK_API_TSIOBufferStart(), spdy_recv_callback(), synclient_txn_read_response(), synserver_txn_read_request(), and test_url_print().
TSIOBuffer TSIOBufferSizedCreate | ( | TSIOBufferSizeIndex | index | ) |
Creates a new TSIOBuffer of the specified size.
With this function, you can create smaller buffers than the 32K buffer created by TSIOBufferCreate(). In some situations using smaller buffers can improve performance.
index | size of the new TSIOBuffer to be created. | |
new | TSIOBuffer of the specified size. |
Definition at line 499 of file InkIOCoreAPI.cc.
References new_MIOBuffer, sdk_assert, sdk_sanity_check_iocore_structure(), TS_IOBUFFER_SIZE_INDEX_128, TS_IOBUFFER_SIZE_INDEX_32K, and TS_SUCCESS.
Referenced by SDK_API_TSIOBufferCopy(), SDK_API_TSIOBufferProduce(), SDK_API_TSIOBufferReaderClone(), SDK_API_TSIOBufferReaderConsume(), and SDK_API_TSIOBufferStart().
TSIOBufferBlock TSIOBufferStart | ( | TSIOBuffer | bufp | ) |
Definition at line 518 of file InkIOCoreAPI.cc.
References MIOBuffer::add_block(), MIOBuffer::get_current_block(), sdk_assert, sdk_sanity_check_iocore_structure(), sdk_sanity_check_null_ptr(), TS_SUCCESS, and IOBufferBlock::write_avail().
Referenced by cache_handler(), load(), SDK_API_TSIOBufferBlockReadAvail(), SDK_API_TSIOBufferStart(), synclient_txn_write_request(), and synserver_txn_write_response().
int64_t TSIOBufferWaterMarkGet | ( | TSIOBuffer | bufp | ) |
The watermark of an TSIOBuffer is the minimum number of bytes of data that have to be in the buffer before calling back any continuation that has initiated a read operation on this buffer.
TSIOBufferWaterMarkGet() will provide the size of the watermark, in bytes, for a specified TSIOBuffer.
bufp | buffer whose watermark the function gets. |
Definition at line 677 of file InkIOCoreAPI.cc.
References sdk_assert, sdk_sanity_check_iocore_structure(), TS_SUCCESS, and MIOBuffer::water_mark.
Referenced by SDK_API_TSIOBufferCreate().
void TSIOBufferWaterMarkSet | ( | TSIOBuffer | bufp, | |
int64_t | water_mark | |||
) |
The watermark of an TSIOBuffer is the minimum number of bytes of data that have to be in the buffer before calling back any continuation that has initiated a read operation on this buffer.
As a writer feeds data into the TSIOBuffer, no readers are called back until the amount of data reaches the watermark. Setting a watermark can improve performance because it avoids frequent callbacks to read small amounts of data. TSIOBufferWaterMarkSet() assigns a watermark to a particular TSIOBuffer.
bufp | buffer whose water mark the function sets. | |
water_mark | watermark setting, as a number of bytes. |
Definition at line 686 of file InkIOCoreAPI.cc.
References sdk_assert, sdk_sanity_check_iocore_structure(), TS_SUCCESS, and MIOBuffer::water_mark.
Referenced by SDK_API_TSIOBufferCreate().
int64_t TSIOBufferWrite | ( | TSIOBuffer | bufp, | |
const void * | buf, | |||
int64_t | length | |||
) |
Writes length bytes of data contained in the string buf to the TSIOBuffer bufp.
Returns the number of bytes of data successfully written to the TSIOBuffer.
bufp | is the TSIOBuffer to write into. | |
buf | string to write into the TSIOBuffer. | |
length | of the string buf. |
Definition at line 549 of file InkIOCoreAPI.cc.
References sdk_assert, sdk_sanity_check_iocore_structure(), sdk_sanity_check_null_ptr(), TS_SUCCESS, and MIOBuffer::write().
Referenced by SDK_API_TSIOBufferBlockNext(), SDK_API_TSIOBufferBlockReadAvail(), SDK_API_TSIOBufferCopy(), and spdy_send_callback().
int TSMutexCheck | ( | TSMutex | mutex | ) |
Definition at line 209 of file InkIOCoreAPI.cc.
References RefCountObj::m_refcount, and ProxyMutex::nthread_holding.
TSMutex TSMutexCreate | ( | void | ) |
Definition at line 182 of file InkIOCoreAPI.cc.
References new_ProxyMutex(), sdk_assert, sdk_sanity_check_mutex(), and TS_SUCCESS.
Referenced by SDK_API_HttpAltInfo(), SDK_API_HttpHookAdd(), SDK_API_HttpSsn(), SDK_API_HttpTxnCache(), SDK_API_HttpTxnTransform(), SDK_API_TSActionCancel(), SDK_API_TSCache(), SDK_API_TSContCreate(), SDK_API_TSContDataGet(), SDK_API_TSContMutexGet(), SDK_API_TSContSchedule(), SDK_API_TSHttpConnectIntercept(), SDK_API_TSHttpConnectServerIntercept(), SDK_API_TSMutexCreate(), SDK_API_TSNetVConn(), SDK_API_TSPortDescriptor(), SDK_API_TSTextLog(), synclient_txn_send_request(), synclient_txn_send_request_to_vc(), synserver_accept_handler(), synserver_create(), UDPClientTestInit(), and UDPTestInit().
TSMutex TSMutexCreateInternal | ( | void | ) |
Definition at line 197 of file InkIOCoreAPI.cc.
References new_ProxyMutex(), sdk_assert, sdk_sanity_check_mutex(), and TS_SUCCESS.
void TSMutexLock | ( | TSMutex | mutexp | ) |
Definition at line 221 of file InkIOCoreAPI.cc.
References MUTEX_TAKE_LOCK, sdk_assert, sdk_sanity_check_mutex(), this_ethread(), and TS_SUCCESS.
Referenced by SDK_API_TSActionCancel(), and SDK_API_TSMutexCreate().
TSReturnCode TSMutexLockTry | ( | TSMutex | mutexp | ) |
Definition at line 229 of file InkIOCoreAPI.cc.
References MUTEX_TAKE_TRY_LOCK, sdk_assert, sdk_sanity_check_mutex(), this_ethread(), TS_ERROR, and TS_SUCCESS.
Referenced by SDK_API_TSContCreate(), and SDK_API_TSMutexCreate().
void TSMutexUnlock | ( | TSMutex | mutexp | ) |
Definition at line 236 of file InkIOCoreAPI.cc.
References MUTEX_UNTAKE_LOCK, sdk_assert, sdk_sanity_check_mutex(), this_ethread(), and TS_SUCCESS.
Referenced by SDK_API_TSActionCancel(), SDK_API_TSContCreate(), and SDK_API_TSMutexCreate().
TSThread TSThreadCreate | ( | TSThreadFunc | func, | |
void * | data | |||
) |
Definition at line 124 of file InkIOCoreAPI.cc.
References INKThreadInternal::data, EThread::event_types, INKThreadInternal::func, ink_assert, ink_thread_create(), and ink_thread_trampoline().
Referenced by SDK_API_TSThread().
void TSThreadDestroy | ( | TSThread | thread | ) |
Definition at line 160 of file InkIOCoreAPI.cc.
References sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by pthread_start_func().
TSThread TSThreadInit | ( | void | ) |
Definition at line 143 of file InkIOCoreAPI.cc.
References Thread::set_specific().
Referenced by pthread_start_func().
TSThread TSThreadSelf | ( | void | ) |
Definition at line 169 of file InkIOCoreAPI.cc.
References this_ethread().
Referenced by SDK_API_TSThread(), and thread_create_handler().
TSIOBuffer TSVIOBufferGet | ( | TSVIO | viop | ) |
Definition at line 254 of file InkIOCoreAPI.cc.
References VIO::get_writer(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), and handle_transform().
Definition at line 319 of file InkIOCoreAPI.cc.
References VIO::_cont, sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), handle_transform(), and transformtest_transform().
Definition at line 337 of file InkIOCoreAPI.cc.
References VIO::mutex, sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler().
int64_t TSVIONBytesGet | ( | TSVIO | viop | ) |
Definition at line 272 of file InkIOCoreAPI.cc.
References VIO::nbytes, sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), and handle_transform().
void TSVIONBytesSet | ( | TSVIO | viop, | |
int64_t | nbytes | |||
) |
Definition at line 281 of file InkIOCoreAPI.cc.
References VIO::nbytes, sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), and handle_transform().
int64_t TSVIONDoneGet | ( | TSVIO | viop | ) |
Definition at line 291 of file InkIOCoreAPI.cc.
References VIO::ndone, sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), handle_transform(), and spdy_process_write().
void TSVIONDoneSet | ( | TSVIO | viop, | |
int64_t | ndone | |||
) |
Definition at line 300 of file InkIOCoreAPI.cc.
References VIO::ndone, sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), and handle_transform().
int64_t TSVIONTodoGet | ( | TSVIO | viop | ) |
Definition at line 310 of file InkIOCoreAPI.cc.
References VIO::ntodo(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), and handle_transform().
TSIOBufferReader TSVIOReaderGet | ( | TSVIO | viop | ) |
Definition at line 263 of file InkIOCoreAPI.cc.
References VIO::get_reader(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), and handle_transform().
void TSVIOReenable | ( | TSVIO | viop | ) |
Definition at line 245 of file InkIOCoreAPI.cc.
References VIO::reenable(), sdk_assert, sdk_sanity_check_iocore_structure(), and TS_SUCCESS.
Referenced by cache_handler(), handle_transform(), spdy_on_ctrl_recv_callback(), spdy_on_data_recv_callback(), spdy_on_data_send_callback(), spdy_prepare_status_response_and_clean_request(), spdy_process_fetch_body(), spdy_process_fetch_header(), spdy_process_write(), spdy_read_fetch_body_callback(), spdy_recv_callback(), synclient_txn_read_response_handler(), synclient_txn_write_request_handler(), synserver_txn_read_request_handler(), and synserver_txn_write_response_handler().
Definition at line 328 of file InkIOCoreAPI.cc.
References sdk_assert, sdk_sanity_check_iocore_structure(), TS_SUCCESS, and VIO::vc_server.
Referenced by cache_handler().