Home
last modified time | relevance | path

Searched refs:head (Results 1 – 25 of 86) sorted by relevance

1234

/trafficserver/include/tscore/
H A DList.h162 C *head; member in SLL
217 C *head; member
267 if (head) in push()
277 if (!head) in remove()
367 if (!head) in pop()
401 head = q.head; in append()
417 head = q.head; in append()
642 head = new ConsCell<C, A>(a, head); in push()
647 head = new ConsCell<C, A>(head); in push()
681 head = t; in reverse()
[all …]
H A Dink_string++.h96 Str *head; member
150 head = tail = nullptr; in init()
224 for (s = head; ((s != nullptr) && i); s = s->next, i--) { in get_idx()
242 head = tail = str; in append()
256 str->next = head; in prepend()
260 head = tail = str; in prepend()
262 head->prev = str; in prepend()
263 head = str; in prepend()
290 if (head == str) { in detach()
291 head = str->next; in detach()
H A DAllocator.h84 free_void_bulk(void *head, void *tail, size_t num_item) in free_void_bulk() argument
86 ink_freelist_free_bulk(this->fl, head, tail, num_item); in free_void_bulk()
156 free_bulk(C *head, C *tail, size_t num_item) in free_bulk() argument
158 ink_freelist_free_bulk(this->fl, head, tail, num_item); in free_bulk()
192 free_void_bulk(void *head, void *tail, size_t num_item) in free_void_bulk() argument
194 free_bulk((C *)head, (C *)tail, num_item); in free_void_bulk()
H A Dink_queue.h168 head_p head; member
192 inkcoreapi void ink_freelist_free_bulk(InkFreeList *f, void *head, void *tail, size_t num_item);
199 head_p head{}; member
205 #define INK_ATOMICLIST_EMPTY(_x) (!(TO_PTR(FREELIST_POINTER((_x.head)))))
208 #define INK_ATOMICLIST_EMPTY(_x) (!((FREELIST_POINTER((_x.head)))))
/trafficserver/src/tscore/
H A Dink_queue.cc303 INK_QUEUE_LD(h, f->head); in freelist_free()
353 void *temp = head; in freelist_bulkfree()
364 INK_QUEUE_LD(h, f->head); in freelist_bulkfree()
383 void *item = head; in malloc_bulkfree()
527 head_p head; in ink_atomiclist_push() local
532 INK_QUEUE_LD(head, l->head); in ink_atomiclist_push()
538 result = ink_atomic_cas(&l->head.data, head.data, item_pair.data); in ink_atomiclist_push()
547 head_p head; in ink_atomiclist_remove() local
556 INK_QUEUE_LD(head, l->head); in ink_atomiclist_remove()
560 result = ink_atomic_cas(&l->head.data, head.data, next.data); in ink_atomiclist_remove()
[all …]
H A Dllqueue.cc81 new_val->head = new_val->tail = new_val->free = nullptr; in create_queue()
116 if (Q->head == nullptr) { in enqueue()
117 Q->head = Q->tail; in enqueue()
190 if (Q->head == nullptr) { in dequeue()
196 rec = Q->head; in dequeue()
198 Q->head = Q->head->next; in dequeue()
199 if (Q->head == nullptr) { in dequeue()
H A DIpMap.cc265 head() in head() function
267 return static_cast<N *>(_list.head()); in head()
323 N *n = static_cast<N *>(_list.head()); in clear()
365 n = this->head(); in fill()
551 } else if (nullptr != (n = this->head()) && // at least one node in tree. in mark()
670 _root = static_cast<N *>(_list.head()->setChild(n, N::LEFT)->rebalanceAfterInsert()); in prepend()
731 for ( Node* n = _list.head() ; n ; n = n->_next ) { in validate()
1270 x = _m4->head(); in begin()
1273 x = _m6->head(); in begin()
1286 x = _tree->_m6->head(); in operator ++()
[all …]
/trafficserver/example/plugins/c-api/thread_pool/
H A Dthread.c42 q->head = NULL; /* Pointer on head cell */ in init_queue()
62 TSAssert(q->head == NULL); in add_to_queue()
65 q->head = new_cell; in add_to_queue()
88 remove_cell = q->head; in remove_from_queue()
92 q->head = remove_cell->ptr_prev; in remove_from_queue()
93 if (q->head == NULL) { in remove_from_queue()
97 TSAssert(q->head->magic == MAGIC_ALIVE); in remove_from_queue()
98 q->head->ptr_next = NULL; in remove_from_queue()
/trafficserver/src/tscpp/util/unit_tests/
H A Dtest_IntrusiveDList.cc221 REQUIRE(list.head() == nullptr);
237 REQUIRE(list.tail() == list.head());
241 REQUIRE(list.head()->_payload == "two");
244 REQUIRE(list.head()->_payload == "one");
259 REQUIRE(list.head() != nullptr);
260 REQUIRE(list.head()->_payload == "middle");
263 list.erase(list.head());
265 REQUIRE(list.head() != nullptr);
266 REQUIRE(list.head()->_payload == "middle");
280 REQUIRE(list.head()->_payload == "one");
[all …]
/trafficserver/plugins/lua/
H A Dts_lua_coroutine.c22 ts_lua_async_push_item(ts_lua_async_item **head, ts_lua_async_item *node) in ts_lua_async_push_item() argument
24 node->next = *head; in ts_lua_async_push_item()
25 *head = node; in ts_lua_async_push_item()
39 ts_lua_async_destroy_chain(ts_lua_async_item **head) in ts_lua_async_destroy_chain() argument
43 node = *head; in ts_lua_async_destroy_chain()
/trafficserver/plugins/experimental/access_control/
H A Dutils.cc378 BIO *head, *b64, *bmem; local
382 head = b64 = BIO_new(BIO_f_base64());
387 head = BIO_push(b64, bmem);
389 BIO_write(head, in, inLen);
390 (void)BIO_flush(head);
392 BIO_get_mem_ptr(head, &bptr);
396 BIO_free_all(head);
417 BIO *head, *bmem, *b64; local
420 head = b64 = BIO_new(BIO_f_base64());
425 head = BIO_push(b64, bmem);
[all …]
/trafficserver/proxy/http3/
H A DHttp3FrameDispatcher.cc52 uint8_t head[16]; in on_read_ready() local
53 int64_t read_len = stream_io.peek(head, 16); in on_read_ready()
58 this->_reading_frame_type_len = QUICVariableInt::size(head); in on_read_ready()
68 … this->_reading_frame_length_len = QUICVariableInt::size(head + this->_reading_frame_type_len); in on_read_ready()
79 …QUICVariableInt::decode(this->_reading_frame_payload_len, dummy, head + this->_reading_frame_type_… in on_read_ready()
H A DHttp3Session.cc33 …for (HQTransaction *t = this->_transaction_list.head; t; t = static_cast<HQTransaction *>(t->link.… in ~HQSession()
49 …for (HQTransaction *t = this->_transaction_list.head; t; t = static_cast<HQTransaction *>(t->link.… in get_transaction()
/trafficserver/proxy/http/
H A DHttpTransactCache.cc89 for (Str *tag = tag_list.head; tag; tag = tag->next) { in do_strings_match_strongly()
125 for (Str *tag = tag_list.head; tag; tag = tag->next) { in do_strings_match_weakly()
521 Str *c_param = c_param_list.head; in calculate_quality_of_accept_match()
543 Str *a_param = a_param_list.head; in calculate_quality_of_accept_match()
659 if (a_param_list.head) { in calculate_quality_of_accept_charset_match()
661 a_charset_len = a_param_list.head->len; in calculate_quality_of_accept_charset_match()
762 if (a_param_list.head) { in match_content_encoding()
800 if (a_param_list.head) { in match_accept_content_encoding()
1024 if (a_param_list.head) { in match_accept_content_language()
1026 *a_range_length = a_param_list.head->len; in match_accept_content_language()
[all …]
H A DHttpTunnel.cc386 for (HttpTunnelConsumer *c = consumer_list.head; c; c = c->link.next) { in backlog()
732 for (c = p->consumer_list.head; c; c = c->link.next) { in producer_run()
740 for (c = p->consumer_list.head; c; c = c->link.next) { in producer_run()
816 for (c = p->consumer_list.head; c; c = c->link.next) { in producer_run()
906 for (c = p->consumer_list.head; c; c = c->link.next) { in producer_run()
1002 for (c = p->consumer_list.head; c; c = c->link.next) { in producer_handler_dechunked()
1142 for (c = p->consumer_list.head; c; c = c->link.next) { in producer_handler()
1182 for (c = p->consumer_list.head; c; c = c->link.next) { in producer_handler()
1382 HttpTunnelConsumer *c = p->consumer_list.head; in chain_abort_all()
1470 HttpTunnelConsumer *c = p->consumer_list.head; in finish_all_internal()
[all …]
/trafficserver/proxy/hdrs/
H A DHttpCompat.cc209 for (param = param_list->head; param != nullptr; param = param->next) { in lookup_param_in_strlist()
565 for (a_value = acpt_lang_list->head; a_value; a_value = a_value->next) { in match_accept_language()
577 if (!a_param_list.head) { in match_accept_language()
588 const char *atag_str = a_param_list.head->str; in match_accept_language()
589 int atag_len = static_cast<int>(a_param_list.head->len); in match_accept_language()
681 for (a_value = acpt_charset_list->head; a_value; a_value = a_value->next) { in match_accept_charset()
692 if (!a_param_list.head) { in match_accept_charset()
699 const char *atag_str = a_param_list.head->str; in match_accept_charset()
700 int atag_len = static_cast<int>(a_param_list.head->len); in match_accept_charset()
/trafficserver/iocore/net/
H A DSSLNextProtocolSet.cc58 for (ep = endpoints.head; ep != nullptr; ep = endpoints.next(ep)) { in create_npn_advertisement()
68 for (ep = endpoints.head; ep != nullptr; ep = endpoints.next(ep)) { in create_npn_advertisement()
105 …for (const NextProtocolEndpoint *ep = this->endpoints.head; ep != nullptr; ep = this->endpoints.ne… in findEndpoint()
H A DP_UDPNet.h139 return bucket[now_slot].head; in firstPacket()
208 while (!bucket[s].head && (t > delivery_time[s] + SLOT_TIME)) { in advanceNow()
265 if (bucket[s].head) { in earliest_timeout()
/trafficserver/iocore/eventsystem/
H A DProxyAllocator.cc44 void *head = l.freelist; in thread_freeup() local
57 a.free_void_bulk(head, tail, count); in thread_freeup()
H A DI_ProxyAllocator.h93 C *head = (C *)l.freelist; in thread_freeup() local
106 a.free_bulk(head, tail, count); in thread_freeup()
/trafficserver/iocore/net/quic/
H A DQUICStreamManager.cc246 for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next) { in _find_stream_vc()
360 for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next) { in total_reordered_bytes()
372 for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next) { in total_offset_received()
395 for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next) { in stream_count()
419 for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next) { in will_generate_frame()
444 for (QUICStreamVConnection *s = this->stream_list.head; s; s = s->link.next) { in generate_frame()
/trafficserver/plugins/certifier/
H A Dcertifier.cc117 SslData *head = nullptr; member in SslLRUList
195 if (head != data) { in prepend()
201 data->next = head; in prepend()
205 head = data; in prepend()
239 if (data->prev != nullptr || data->next != nullptr || head == data) { in remove_from_list()
246 if (head == data) { in remove_from_list()
247 head = data->next; in remove_from_list()
264 SslData *ret = head; in get_newest()
/trafficserver/iocore/cache/
H A DCacheDir.cc92 od->readers.head = nullptr; in open_write()
123 if (newly_delayed_readers.head) { in signal_readers()
140 if (!cont->od->writers.head) { in close_write()
159 if (d->writers.head->first_key == *key) { in open_read()
777 EvacuationBlock *b = d->lookaside[i].head; in dir_lookaside_probe()
819 EvacuationBlock *b = d->lookaside[i].head; in dir_lookaside_fixup()
843 EvacuationBlock *b = i.head; in dir_lookaside_cleanup()
866 EvacuationBlock *b = d->lookaside[i].head; in dir_lookaside_remove()
1265 ++head; in dir_check()
1317 printf(" Average Size: %" PRIu64 "\n", head ? (bytes_in_use / head) : 0); in dir_check()
[all …]
H A DRamCacheCLFUS.cc220 RamCacheCLFUSEntry *y = c->lru[0].head; in check_accounting()
226 y = c->lru[1].head; in check_accounting()
246 RamCacheCLFUSEntry *e = this->_bucket[i].head; in get()
422 this->_compressed = this->_lru[0].head; in compress_entries()
506 RamCacheCLFUSEntry *ee = this->_bucket[i].head; in compress_entries()
585 RamCacheCLFUSEntry *e = this->_bucket[i].head; in put()
634 if (!this->_lru[1].head) { // initial fill in put()
762 RamCacheCLFUSEntry *e = this->_bucket[i].head; in fixup()
H A DRamCacheLRU.cc128 RamCacheLRUEntry *e = bucket[i].head; in get()
178 RamCacheLRUEntry *e = bucket[i].head; in put()
225 RamCacheLRUEntry *e = bucket[i].head; in fixup()

Completed in 202 milliseconds

1234