Home
last modified time | relevance | path

Searched refs:data (Results 1 – 25 of 663) sorted by relevance

12345678910>>...27

/trafficserver/plugins/experimental/metalink/
H A Dmetalink.cc552 TSHandleMLocRelease(data->resp_bufp, data->hdr_loc, data->location_loc); in cache_open_read_failed()
577 …TSMimeHdrFieldValueStringInsert(data->resp_bufp, data->hdr_loc, data->location_loc, -1, data->valu… in rewrite_handler()
591 TSHandleMLocRelease(data->resp_bufp, data->hdr_loc, data->location_loc); in rewrite_handler()
626 TSHandleMLocRelease(data->resp_bufp, data->hdr_loc, data->location_loc); in vconn_read_ready()
641 TSHandleMLocRelease(data->resp_bufp, data->hdr_loc, data->location_loc); in vconn_read_ready()
719 TSHandleMLocRelease(data->resp_bufp, data->hdr_loc, data->digest_loc); in location_handler()
735 TSHandleMLocRelease(data->resp_bufp, data->hdr_loc, data->digest_loc); in location_handler()
740 TSHandleMLocRelease(data->resp_bufp, data->hdr_loc, data->location_loc); in location_handler()
834 for (data->idx = 0; data->idx < count; data->idx += 1) { in http_send_response_hdr()
854 TSHandleMLocRelease(data->resp_bufp, data->hdr_loc, data->digest_loc); in http_send_response_hdr()
[all …]
/trafficserver/example/plugins/c-api/server_transform/
H A Dserver_transform.c89 TransformData *data; in transform_create() local
117 if (data != NULL) { in transform_destroy()
134 TSfree(data); in transform_destroy()
154 data->content_length = htonl(data->content_length); in transform_connect()
207data->server_vio = TSVConnWrite(data->server_vc, contp, TSIOBufferReaderClone(data->input_reader),… in transform_write()
220 data->output_reader = TSIOBufferReaderAlloc(data->output_buf); in transform_read_status()
222 data->server_vio = TSVConnRead(data->server_vc, contp, data->output_buf, sizeof(int)); in transform_read_status()
239 data->server_vio = TSVConnRead(data->server_vc, contp, data->output_buf, data->content_length); in transform_read()
244data->output_vio = TSVConnWrite(data->output_vc, contp, data->output_reader, data->content_length)… in transform_read()
275data->output_vio = TSVConnWrite(data->output_vc, contp, data->input_reader, TSIOBufferReaderAvail( in transform_bypass()
[all …]
/trafficserver/plugins/experimental/slice/
H A Dserver.cc35 delete data; in shutdown()
74 data->m_bail = true; in handleFirstServerHeader()
101 data->m_req_range.m_end += data->m_contentlen; in handleFirstServerHeader()
102 data->m_req_range.m_beg += data->m_contentlen; in handleFirstServerHeader()
106 data->m_req_range.m_end = std::min(data->m_contentlen, data->m_req_range.m_end); in handleFirstServerHeader()
128 data->m_etaglen = sizeof(data->m_etag) - 1; in handleFirstServerHeader()
130 data->m_lastmodifiedlen = sizeof(data->m_lastmodified) - 1; in handleFirstServerHeader()
228 ContentRange const crange(data->m_req_range.m_beg, data->m_req_range.m_end, data->m_contentlen); in logSliceError()
364data->m_resp_hdrmgr.populateFrom(data->m_http_parser, data->m_upstream.m_read.m_reader, TSHttpHdrP… in handle_server_resp()
392data->m_blockskip = data->m_req_range.skipBytesForBlock(data->m_config->m_blockbytes, data->m_bloc… in handle_server_resp()
[all …]
H A Dclient.cc29 delete data; in shutdown()
37 int64_t const blockbeg = (data->m_config->m_blockbytes * data->m_blocknum); in requestBlock()
48 HttpHeader header(data->m_req_hdrmgr.m_buffer, data->m_req_hdrmgr.m_lochdr); in requestBlock()
101data->m_req_hdrmgr.populateFrom(data->m_http_parser, data->m_dnstream.m_read.m_reader, TSHttpHdrPa… in handle_client_req()
106 HttpHeader header(data->m_req_hdrmgr.m_buffer, data->m_req_hdrmgr.m_lochdr); in handle_client_req()
109 header.setUrl(data->m_urlbuf, data->m_urlloc); in handle_client_req()
146 data->m_blocknum = rangebe.firstBlockFor(data->m_config->m_blockbytes); in handle_client_req()
179 if (data->m_bytestosend <= data->m_bytessent) { in handle_client_resp()
197 if (data->m_bail) { in handle_client_resp()
203 if (data->m_iseos) { in handle_client_resp()
[all …]
H A Dtransfer.cc27 if (!data->m_dnstream.m_write.isOpen()) { in transfer_content_bytes()
29 if (data->m_upstream.m_read.isOpen()) { in transfer_content_bytes()
36 if (data->m_upstream.m_read.isOpen()) { in transfer_content_bytes()
44 data->m_blockskip -= toskip; in transfer_content_bytes()
50 int64_t const bytesleft = (data->m_bytestosend - data->m_bytessent); in transfer_content_bytes()
54 …int64_t const copied(TSIOBufferCopy(data->m_dnstream.m_write.m_iobuf, data->m_upstream.m_read.m_re… in transfer_content_bytes()
56 data->m_bytessent += copied; in transfer_content_bytes()
66 if (0 < avail && data->m_bytestosend <= data->m_bytessent) { in transfer_content_bytes()
79 data->m_blockconsumed += consumed; in transfer_content_bytes()
87 transfer_all_bytes(Data *const data) in transfer_all_bytes() argument
[all …]
H A Dintercept.cc32 if (nullptr == data) { in intercept_hook()
44 data->m_dnstream.setupConnection(downvc); in intercept_hook()
45 data->m_dnstream.setupVioRead(contp); in intercept_hook()
51 delete data; in intercept_hook()
57 if (data->m_dnstream.m_read.isOpen() && edata == data->m_dnstream.m_read.m_vio) { in intercept_hook()
58 if (handle_client_req(contp, event, data)) { in intercept_hook()
65 else if (data->m_upstream.m_write.isOpen() && edata == data->m_upstream.m_write.m_vio) { in intercept_hook()
70 else if (data->m_upstream.m_read.isOpen() && edata == data->m_upstream.m_read.m_vio) { in intercept_hook()
71 handle_server_resp(contp, event, data); in intercept_hook()
74 else if (data->m_dnstream.m_write.isOpen() && edata == data->m_dnstream.m_write.m_vio) { in intercept_hook()
[all …]
/trafficserver/example/plugins/c-api/thread_pool/
H A Dpsi.c120 ContData *data; in cont_data_alloc() local
139 return data; in cont_data_alloc()
156 if (data) { in cont_data_destroy()
175 TSfree(data); in cont_data_destroy()
345 ContData *data; in parse_data() local
450 ContData *data; in psi_include() local
462 data->psi_reader = TSIOBufferReaderAlloc(data->psi_buffer); in psi_include()
552 TSVIONBytesSet(data->output_vio, data->transform_bytes); in wake_up_streams()
602 TSVIONBytesSet(data->output_vio, data->transform_bytes); in handle_transform()
825 transform_handler(data->contp, data->event, NULL); in trylock_handler()
[all …]
/trafficserver/plugins/compress/
H A Dcompress.cc74 Data *data; in data_alloc() local
131 return data; in data_alloc()
152 TSfree(data); in data_destroy()
359 … &data->bstrm.avail_out, &data->bstrm.next_out, &data->bstrm.total_out); in brotli_compress_operation()
503 log_compression_ratio(data->bstrm.total_in, data->downstream_length); in brotli_transform_finish()
529 Data *data; in compress_transform_do() local
544 TSVIONBytesSet(data->downstream_vio, data->downstream_length); in compress_transform_do()
576 TSVIONBytesSet(data->downstream_vio, data->downstream_length); in compress_transform_do()
769 Data *data; in compress_transform_add() local
784 data->txn = txnp; in compress_transform_add()
[all …]
/trafficserver/example/plugins/c-api/bnull_transform/
H A Dbnull_transform.c58 MyData *data; in my_data_alloc() local
62 data->output_vio = NULL; in my_data_alloc()
66 return data; in my_data_alloc()
72 if (data) { in my_data_destroy()
76 TSfree(data); in my_data_destroy()
96 data->output_reader = TSIOBufferReaderAlloc(data->output_buffer); in handle_buffering()
161 if (!data->output_vio) { in handle_output()
167data->output_vio = TSVConnWrite(output_conn, contp, data->output_reader, TSIOBufferReaderAvail(dat… in handle_output()
177 MyData *data; in handle_transform() local
186 if (!data) { in handle_transform()
[all …]
/trafficserver/plugins/xdebug/
H A Dxdebug_transforms.cc56 if (data->wrote_body && data->hdr_ready && !data->wrote_postbody.test_and_set()) { in writePostBody()
59 TSIOBufferWrite(data->output_buffer.get(), postbody.data(), postbody.length()); in writePostBody()
61 TSVIONBytesSet(data->output_vio, data->nbytes); in writePostBody()
70 BodyBuilder *data = AuxDataMgr::data(txn).body_builder.get(); in body_transform() local
71 if (!data) { in body_transform()
97 data->output_reader.reset(TSIOBufferReaderAlloc(data->output_buffer.get())); in body_transform()
105 data->wrote_prebody = true; in body_transform()
113 data->wrote_body = true; in body_transform()
114 writePostBody(txn, data); in body_transform()
135 data->wrote_body = true; in body_transform()
[all …]
/trafficserver/doc/developer-guide/plugins/continuations/
H A Dwriting-handler-functions.en.rst35 pointer to some data (this data is passed to the continuation by the
36 caller - do not confuse this data with the continuation's own data,
82 :data:`TS_EVENT_HTTP_READ_REQUEST_HDR` :data:`TS_HTTP_READ_REQUEST_HDR_HOOK` :type:`TSH…
83 :data:`TS_EVENT_HTTP_PRE_REMAP` :data:`TS_HTTP_PRE_REMAP_HOOK` :type:`TSH…
84 :data:`TS_EVENT_HTTP_OS_DNS` :data:`TS_HTTP_OS_DNS_HOOK` :type:`TSH…
94 :data:`TS_EVENT_NONE`
101 :data:`TS_EVENT_IMMEDIATE` :data:`TS_HTTP_REQUEST_TRANSFORM_HOOK`
102 :data:`TS_EVENT_IMMEDIATE` :data:`TS_HTTP_RESPONSE_TRANSFORM_HOOK`
119 :data:`TS_EVENT_ERROR`
127 :data:`TS_EVENT_HTTP_CONTINUE`
[all …]
/trafficserver/example/plugins/c-api/append_transform/
H A Dappend_transform.c64 MyData *data; in my_data_alloc() local
67 TSReleaseAssert(data); in my_data_alloc()
69 data->output_vio = NULL; in my_data_alloc()
70 data->output_buffer = NULL; in my_data_alloc()
72 data->append_needed = 1; in my_data_alloc()
74 return data; in my_data_alloc()
80 if (data) { in my_data_destroy()
84 TSfree(data); in my_data_destroy()
93 MyData *data; in handle_transform() local
110 if (!data) { in handle_transform()
[all …]
/trafficserver/mgmt/utils/
H A DMgmtMarshall.cc128 if (data->len) { in socket_write_buffer()
129 nwrite = socket_write_bytes(fd, data->ptr, data->len); in socket_write_buffer()
146 ink_zero(*data); in socket_read_buffer()
153 if (data->len) { in socket_read_buffer()
154 data->ptr = ats_malloc(data->len); in socket_read_buffer()
155 nread = socket_read_bytes(fd, data->ptr, data->len); in socket_read_buffer()
165 ink_zero(*data); in socket_read_buffer()
172 ink_zero(*data); in buffer_read_buffer()
186 if (data->len) { in buffer_read_buffer()
187 data->ptr = ats_malloc(data->len); in buffer_read_buffer()
[all …]
/trafficserver/tests/tools/plugins/
H A Dnull_transform.c41 MyData *data; in my_data_alloc() local
44 data->output_vio = NULL; in my_data_alloc()
45 data->output_buffer = NULL; in my_data_alloc()
46 data->output_reader = NULL; in my_data_alloc()
48 return data; in my_data_alloc()
52 my_data_destroy(MyData *data) in my_data_destroy() argument
54 if (data) { in my_data_destroy()
58 TSfree(data); in my_data_destroy()
68 MyData *data; in handle_transform() local
91 if (!data) { in handle_transform()
[all …]
/trafficserver/example/plugins/c-api/null_transform/
H A Dnull_transform.c41 MyData *data; in my_data_alloc() local
44 data->output_vio = NULL; in my_data_alloc()
45 data->output_buffer = NULL; in my_data_alloc()
46 data->output_reader = NULL; in my_data_alloc()
48 return data; in my_data_alloc()
52 my_data_destroy(MyData *data) in my_data_destroy() argument
54 if (data) { in my_data_destroy()
58 TSfree(data); in my_data_destroy()
68 MyData *data; in handle_transform() local
90 if (!data) { in handle_transform()
[all …]
/trafficserver/plugins/prefetch/
H A Dplugin.cc376 data->_status = status; in shortcutResponse()
377 data->_body.assign(body); in shortcutResponse()
466 if (data->frontend() && data->secondPass()) { in contHandleFetch()
476 if (data->frontend()) { in contHandleFetch()
481 data->_fetchable = state->acquire(data->_cachekey); in contHandleFetch()
489 if (data->frontend()) { in contHandleFetch()
493 data->_fetchable = state->acquire(data->_cachekey); in contHandleFetch()
494 data->_fetchable = data->_fetchable && state->uniqueAcquire(data->_cachekey); in contHandleFetch()
525 if (data->frontend()) { in contHandleFetch()
560 …if ((data->backend() && data->firstPass()) || (data->frontend() && data->secondPass() && !data->_b… in contHandleFetch()
[all …]
/trafficserver/plugins/esi/lib/
H A DUtils.cc56 if (data[curr_pos] == ' ') { in getAttribute()
59 if (data[curr_pos] == '=') { in getAttribute()
78 if (data[i] == '"') { in getAttribute()
81 } else if (data[i] == ' ') { in getAttribute()
89 const char *data_start_ptr = data.data(); in getAttribute()
96 *term_pos = data.find(terminator, i); in getAttribute()
146 if (!data || (data_len <= 0)) { in parseAttributes()
160 attr.name = data + i; in parseAttributes()
189 attr.name = data + i; in parseAttributes()
192 } else if (data[i] == '"') { in parseAttributes()
[all …]
H A DEsiParser.cc113 if (!data.size()) { in _completeParse()
119 (data.size() ? data.data() : "(null)")); in _completeParse()
129 const char *data_ptr = data.data() + start_pos; in _searchData()
268 const char *const data_start_ptr = data.data(); in _parse()
454 node.data = data.data() + curr_pos; in _processSpecialIncludeTag()
482 const char *data_start_ptr = data.data() + term_pos; in _processWhenTag()
497 const char *data_start_ptr = data.data() + curr_pos; in _processTryTag()
552 const char *data_start_ptr = data.data() + curr_pos; in _processChooseTag()
609 node_iter->data = ext_data_ptr + (node_iter->data - int_data_start); in _adjustPointers()
628 string data; in parse() local
[all …]
H A DEsiParser.h43 bool parseChunk(const char *data, EsiLib::DocNodeList &node_list, int data_len = -1);
47 parseChunk(const std::string &data, EsiLib::DocNodeList &node_list) in parseChunk() argument
49 return parseChunk(data.data(), node_list, data.size()); in parseChunk()
58 completeParse(EsiLib::DocNodeList &node_list, const char *data = nullptr, int data_len = -1) in completeParse() argument
60 …return _completeParse(_data, _parse_start_pos, _orig_output_list_size, node_list, data, data_len); in completeParse()
65 completeParse(EsiLib::DocNodeList &node_list, const std::string &data) in completeParse() argument
67 return completeParse(node_list, data.data(), data.size()); in completeParse()
78 return parse(node_list, ext_data.data(), ext_data.size()); in parse()
118 MATCH_TYPE _compareData(const std::string &data, size_t pos, const char *str, int str_len) const;
128 inline bool _isWhitespace(const char *data, int data_len) const;
[all …]
H A Dgzip.cc36 append(string &out, T data) in append() argument
39 out += static_cast<char>(data & 0xff); in append()
40 data = data >> 8; in append()
46 extract(const char *in, T &data) in extract() argument
48 data = 0; in extract()
50 data = data << 8; in extract()
51 data = data | static_cast<unsigned char>(*(in + i)); in extract()
133 if ((data[0] != MAGIC_BYTE_1) || (data[1] != MAGIC_BYTE_2) || (data[2] != Z_DEFLATED)) { in gunzip()
137 data += GZIP_HEADER_SIZE; in gunzip()
195 extract(data + data_len, orig_crc); in gunzip()
[all …]
H A DUtils.h53 getAttribute(const std::string &data, const char *attr, Attribute &attr_info) in getAttribute() argument
55 return getAttribute(data, std::string(attr), 0, data.size(), attr_info); in getAttribute()
61 trimWhiteSpace(const char *&data, int &data_len) in trimWhiteSpace() argument
63 if (!data) { in trimWhiteSpace()
67 data_len = strlen(data); in trimWhiteSpace()
70 for (i = 0; ((i < data_len) && isspace(data[i])); ++i) in trimWhiteSpace()
72 for (j = (data_len - 1); ((j > i) && isspace(data[j])); --j) in trimWhiteSpace()
74 data += i; in trimWhiteSpace()
92 return areEqual(str1, str1_len, str2.data(), static_cast<int>(str2.size())); in areEqual()
99 …parseAttributes(const std::string &data, AttributeList &attr_list, const char *pair_separators = "… in parseAttributes() argument
[all …]
/trafficserver/src/tscore/unit_tests/
H A Dtest_MT_hashtable.cc46 long data = htable->lookup_entry(i); variable
48 if (data != i) {
68 long data = htable->lookup_entry(i); variable
69 if (i % 2 == 1 && data == 0) {
72 if (data != 0 && data != i) {
83 while (data > 0) {
101 while (data > 0) {
104 data = htable->next_entry(j, &it);
105 if (data != htable->lookup_entry(data)) {
124 while (data > 0) {
[all …]
/trafficserver/iocore/net/quic/test/
H A Dtest_QUICTransportParameters.cc52 const uint8_t *data = nullptr; variable
56 CHECK(memcmp(data, "\x11\x22\x33\x44", 4) == 0);
60 CHECK(memcmp(data, "\x12\x34\x56\x78", 4) == 0);
64 CHECK(memcmp(data, "\x0a\x0b", 2) == 0);
68 CHECK(memcmp(data, "\x05\x67", 2) == 0);
72 CHECK(data == nullptr);
152 const uint8_t *data = nullptr; variable
164 CHECK(memcmp(data, "\x51\x23", 2) == 0);
168 CHECK(memcmp(data, buf + 12, 16) == 0);
194 const uint8_t *data = nullptr; variable
[all …]
H A Dtest_QUICFrameRetransmitter.cc75 memcpy(block->start(), data, sizeof(data));
76 block->fill(sizeof(data));
100 memcpy(block->start(), data, sizeof(data));
101 block->fill(sizeof(data));
120 CHECK(memcmp(stream_frame->data()->start(), data, sizeof(data)) == 0);
136 memcpy(block->start(), data, sizeof(data));
137 block->fill(sizeof(data));
157 CHECK(memcmp(stream_frame->data()->start(), data, stream_frame->data_length()) == 0);
193 memcpy(block->start(), data, sizeof(data));
194 block->fill(sizeof(data));
[all …]
/trafficserver/iocore/cache/
H A DP_CacheArray.h47 T *data; member
72 if (data) { in ~CacheArray()
81 return data;
86 return data;
91 return data[idx]; in operator []()
118 return data[idx]; in operator ()()
127 d = data; in detach()
128 data = nullptr; in detach()
144 if (data) { in clear()
148 data = nullptr; in clear()
[all …]

Completed in 293 milliseconds

12345678910>>...27