| /mOS-networking-stack/core/src/ |
| H A D | tcp_rb.c | 56 if (walk->head > f->head) { in frags_insert()
226 new->head = et; in buf_try_resize()
240 new->head = eh; in buf_try_resize()
414 if (!rb || new > (rb->head + rb->len) || new < rb->head) in tcprb_setpile()
419 if (!cf || (cf->head != rb->head)) { in tcprb_setpile()
438 if (!cf || (cf->head != rb->head)) in tcprb_cflen()
459 if (!cf || (cf->head != rb->head)) in tcprb_ffhead()
474 cf->head += ff; in tcprb_ffhead()
477 rb->head += ff; in tcprb_ffhead()
499 if (!cf || (cf->head != rb->head)) in tcprb_fflen()
[all …]
|
| H A D | key_value_store.c | 99 kvs_bucket_head *head; in kvs_remove() local
101 head = &ht->kvs_table[key % ht->num_buckets]; in kvs_remove()
102 TAILQ_FOREACH(walk, head, link) { in kvs_remove()
104 TAILQ_REMOVE(head, walk, link); in kvs_remove()
125 kvs_bucket_head *head; in kvs_search() local
127 head = &ht->kvs_table[key % ht->num_buckets]; in kvs_search()
128 TAILQ_FOREACH(walk, head, link) { in kvs_search()
|
| H A D | fhash.c | 162 hash_bucket_head *head; in HTRemove() local
172 head = item->rcvvar->he_mybucket; in HTRemove()
173 assert(head); in HTRemove()
174 TAILQ_REMOVE(head, item, rcvvar->he_link); in HTRemove()
187 hash_bucket_head *head; in HTSearch() local
206 head = &ht->ht_table[idx]; in HTSearch()
208 TAILQ_FOREACH(walk, head, rcvvar->he_link) { in HTSearch()
|
| H A D | tcp_send_buffer.c | 81 buf->head = buf->data; in SBInit()
121 memmove(buf->data, buf->head, buf->len); in SBPut()
122 buf->head = buf->data; in SBPut()
124 memcpy(buf->head + buf->len, data, to_put); in SBPut()
147 buf->head = buf->data + buf->head_off; in SBRemove()
153 buf->head = buf->data; in SBRemove()
|
| H A D | mos_api.c | 295 if (*poff >= rcvbuf->head) { in mtcp_peek()
304 int missed = rcvbuf->head - *poff; in mtcp_peek()
305 *poff = rcvbuf->head; in mtcp_peek()
341 rcvbuf->head + seq_num - rcvbuf->head_seq, in ExtractPayloadFromFrags()
|
| H A D | tcp_stream.c | 92 out[*len].offset = walk->head; in GetFragInfo()
93 out[*len].len = walk->tail - walk->head; in GetFragInfo()
148 tbi->tcpbi_last_byte_received = (f ? f->tail : rcvbuf->head); in GetBufInfo()
|
| H A D | netmap_module.c | 188 ring->head = ring->cur = nm_ring_next(ring, i); in netmap_recv_pkts()
|
| H A D | tcp_in.c | 633 < rb->head + fflen) in ProcessTCPPayload()
640 < rb->head + fflen) in ProcessTCPPayload()
|
| H A D | tcp_out.c | 463 data = sndvar->sndbuf->head + in FlushTCPSendingBuffer()
|
| /mOS-networking-stack/core/src/include/ |
| H A D | tcp_stream.h | 32 #define SOCKQ_INIT(head) TAILQ_INIT(head) argument
33 #define SOCKQ_INSERT_TAIL(head, socket) \ argument
39 TAILQ_INSERT_TAIL(head, __s, link); \
42 #define SOCKQ_REMOVE(head, socket) \ argument
45 for (__walk = TAILQ_FIRST(head); __walk != NULL; __walk = __temp) { \
50 TAILQ_REMOVE(head, __walk, link); \
54 #define SOCKQ_FOREACH_START(var, head) \ argument
57 for (__walk = ((head)->tqh_first); \
61 #define SOCKQ_FOREACH_REVERSE(var, head) \ argument
64 for (__walk = (*(((struct mlist *)((head)->tqh_last))->tqh_last)); \
|
| H A D | tree.h | 23 qual type **head; \
116 (*(((scratch)->head)++))
119 for ((scratch)->head = (scratch)->tail = (scratch)->queue, \
126 : (scratch)->head != (scratch)->tail \
135 : (scratch)->head != (scratch)->tail \
141 for ((scratch)->head = (scratch)->tail = (scratch)->queue, \
148 : (scratch)->head != (scratch)->tail \
157 : (scratch)->head != (scratch)->tail \
|
| H A D | tcp_rb.h | 51 loff_t head; /* head of this fragment */ member
71 loff_t head; /* head of this window (inf space) */ member
|
| H A D | netmap_user.h | 136 return nm_ring_next(r, r->tail) != r->head; in nm_tx_pending()
831 D("TX%d %p h %d c %d t %d", i, r, r->head, r->cur, r->tail); in nm_open()
835 D("RX%d %p h %d c %d t %d", i, r, r->head, r->cur, r->tail); in nm_open()
941 ring->head = ring->cur = nm_ring_next(ring, i); in nm_inject()
980 ring->head = ring->cur = nm_ring_next(ring, i); in nm_dispatch()
1008 ring->head = ring->cur; in nm_nextpkt()
|
| H A D | tcp_send_buffer.h | 13 unsigned char *head; member
|
| H A D | mtcp.h | 138 #define TAILQ_FOREACH_SAFE(var, head, field, tvar) \ argument
139 for ((var) = TAILQ_FIRST((head)); \
|
| H A D | tcp_ring_buffer.h | 42 u_char* head; /* pointer to the head */ member
|
| H A D | netmap.h | 271 uint32_t head; /* (u) first user slot */ member
|
| /mOS-networking-stack/util/ |
| H A D | ring_buffer.c | 30 u_char* head; // pointer to the head member
43 r_buff->head = malloc(size); in InitBuffer()
44 r_buff->data = r_buff->head; in InitBuffer()
66 assert(r_buff->head <= r_buff->data); in GetRemainBufferSize()
68 int data_offset = r_buff->data - r_buff->head; in GetRemainBufferSize()
72 memmove(r_buff->head, r_buff->data, r_buff->data_size); in GetRemainBufferSize()
73 r_buff->data = r_buff->head; in GetRemainBufferSize()
112 r_buff->data = r_buff->head; in RemoveDataFromBuffer()
|
| /mOS-networking-stack/core/src/include/bpf/ |
| H A D | gencode.h | 248 struct block *head; member
|
| /mOS-networking-stack/samples/lighttpd-1.4.32/doc/outdated/ |
| H A D | cml.txt | 128 readfile("head.html");
147 output_include = { cwd .. "head.html",
|
| /mOS-networking-stack/core/src/bpf/ |
| H A D | sf_gencode.c | 354 p->head = p;
527 insert_compute_vloffsets(p->head);
540 root = p->head;
546 backpatch(b0, b1->head);
551 b1->head = b0->head;
558 backpatch(b0, b1->head);
561 b1->head = b0->head;
|
| /mOS-networking-stack/samples/lighttpd-1.4.32/src/ |
| H A D | lemon.c | 1529 char *ptr, *head; local
1532 head = b;
1534 head = a;
1543 head = ptr;
1558 return head;
|
| /mOS-networking-stack/samples/lighttpd-1.4.32/ |
| H A D | config.guess | 251 …ALPHA_CPU_TYPE=`/usr/sbin/psrinfo -v | sed -n -e 's/^ The alpha \(.*\) processor.*$/\1/p' | head …
|