Home
last modified time | relevance | path

Searched refs:len (Results 1 – 25 of 89) sorted by relevance

1234

/mOS-networking-stack/core/src/
H A Dtcp_rb.c158 assert(len % UNITBUFSIZE == 0 || len < 2); in buf_try_resize()
160 int segdiff = (len - rb->len) / UNITBUFSIZE; in buf_try_resize()
172 rb->len = len; in buf_try_resize()
290 #define MEMCPY_FOR_read(a, b, len) memcpy(a, b, len) argument
291 #define MEMCPY_FOR_write(a, b, len) memcpy(b, a, len) argument
359 if (len % UNITBUFSIZE || len < 2) in tcprb_new()
384 rb->len = rb->metalen = len; in tcprb_new()
490 else if (len == 0 || off + len < rb->pile) in tcprb_fflen()
592 else if (len == rb->len) in tcprb_resize()
595 if ((diff = rb->len - len) > 0 && /* shrinking */ in tcprb_resize()
[all …]
H A Dtcp_send_buffer.c84 buf->len = buf->cum_len = 0; in SBInit()
106 if (len <= 0) in SBPut()
110 to_put = MIN(len, buf->size - buf->len); in SBPut()
121 memmove(buf->data, buf->head, buf->len); in SBPut()
124 memcpy(buf->head + buf->len, data, to_put); in SBPut()
125 buf->tail_off = buf->len + to_put; in SBPut()
127 buf->len += to_put; in SBPut()
138 if (len <= 0) in SBRemove()
141 to_remove = MIN(len, buf->len); in SBRemove()
149 buf->len -= to_remove; in SBRemove()
[all …]
H A Dtcp_util.c16 uint32_t cur_ts, uint8_t *tcpopt, int len) in ParseTCPOptions() argument
21 for (i = 0; i < len; ) { in ParseTCPOptions()
31 if (i + optlen - 2 > len) { in ParseTCPOptions()
68 for (i = 0; i < len; ) { in ParseTCPTimestamp()
77 if (i + optlen - 2 > len) { in ParseTCPTimestamp()
103 for (i = 0; i < len; ) { in ParseSACKOption()
112 if (i + optlen - 2 > len) { in ParseSACKOption()
165 nleft = len; in TCPCalcChecksum()
181 sum += htons(len); in TCPCalcChecksum()
198 for (i = 0; i < len; i++) { in PrintTCPOptions()
[all …]
H A Dutil.c171 int len = strlen(str); in StrToArgs() local
172 for (i = 0; i < len; i++) { in StrToArgs()
432 const BYTE* bEnd = p + len; in XXH32_endian_align()
439 len=0; in XXH32_endian_align()
444 if (len>=16) in XXH32_endian_align()
480 h32 += (U32) len; in XXH32_endian_align()
512 XXH32_update(&state, input, len); in XXH32()
537 const BYTE* bEnd = p + len; in XXH64_endian_align()
544 len=0; in XXH64_endian_align()
549 if (len>=32) in XXH64_endian_align()
[all …]
H A Dicmp.c35 ICMPChecksum(uint16_t *icmph, int len) in ICMPChecksum() argument
37 assert(len >= 0); in ICMPChecksum()
43 while (len > 1) { in ICMPChecksum()
45 len -= 2; in ICMPChecksum()
48 if (len == 1) { in ICMPChecksum()
63 uint8_t *icmpd, uint16_t len) in ICMPOutput() argument
69 uint32_t pktlen = sizeof(struct iphdr) + sizeof(struct icmphdr) + len; in ICMPOutput()
128 if(len > 0) in ICMPOutput()
129 memcpy((void *) (icmph + 1), icmpd, len); in ICMPOutput()
144 uint8_t *icmpd, uint16_t len) in RequestICMP() argument
[all …]
H A Deth_in.c29 uint32_t cur_ts, unsigned char *pkt_data, int len) in ProcessPacket() argument
39 DumpPacket(mtcp, (char *)pkt_data, len, "IN", ifidx); in ProcessPacket()
44 mtcp->nstat.rx_bytes[ifidx] += len + ETHER_OVR; in ProcessPacket()
54 FillInPacketEthContext(&pctx, cur_ts, ifidx, index, ethh, len); in ProcessPacket()
65 ret = ProcessARPPacket(mtcp, cur_ts, ifidx, pkt_data, len); in ProcessPacket()
70 DumpPacket(mtcp, (char *)pkt_data, len, "??", ifidx); in ProcessPacket()
72 mtcp->iom->release_pkt(mtcp->ctx, ifidx, pkt_data, len); in ProcessPacket()
H A Dconfig.c97 for (i = 0; i < len; i++) { in DetectWord()
109 if (i == len) in DetectWord()
301 line++, len--; in FeedArpConfLine()
334 line++, len--; in FeedRouteConfLine()
366 line++, len--; in FeedNICFwdConfLine()
956 int len = strlen(raw); in PreprocessConf() local
1032 if (len == strlen(walk->name) && strncmp(walk->name, name, len) == 0) { in AllocateBlock()
1078 for (len = 0; &buf[len] < end; len++) { in DetectBlock()
1079 if (buf[len] == '{') in DetectBlock()
1098 nblk->len = len; in DetectBlock()
[all …]
H A Ddpdk_module.c205 dpc->wmbufs[j].len = 0; in dpdk_init_handle()
241 int cnt = dpc->wmbufs[nif].len; in dpdk_send_pkts()
280 dpc->wmbufs[nif].len = 0; in dpdk_send_pkts()
302 len_of_mbuf = dpc->wmbufs[nif].len; in dpdk_get_wptr()
316 dpc->wmbufs[nif].len = len_of_mbuf + 1; in dpdk_get_wptr()
357 for (i = 0; i < len; i++) { in free_pkts()
379 if (dpc->rmbufs[ifidx].len != 0) { in dpdk_recv_pkts()
381 dpc->rmbufs[ifidx].len = 0; in dpdk_recv_pkts()
389 dpc->rmbufs[ifidx].len = ret; in dpdk_recv_pkts()
409 *len = m->pkt_len; in dpdk_get_rptr()
[all …]
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dhttp_chunk.c24 size_t i, olen = len, j; in http_chunk_append_len()
29 if (len == 0) { in http_chunk_append_len()
32 for (i = 0; i < 8 && len; i++) { in http_chunk_append_len()
33 len >>= 4; in http_chunk_append_len()
39 for (j = i-1, len = olen; j+1 > 0; j--) { in http_chunk_append_len()
40 b->ptr[j] = (len & 0xf) + (((len & 0xf) <= 9) ? '0' : 'a' - 10); in http_chunk_append_len()
41 len >>= 4; in http_chunk_append_len()
62 http_chunk_append_len(srv, con, len); in http_chunk_append_file()
101 if (len == 0) { in http_chunk_append_mem()
111 http_chunk_append_len(srv, con, len - 1); in http_chunk_append_mem()
[all …]
H A Dstatus_counter.c19 data_integer *status_counter_get_counter(server *srv, const char *s, size_t len) { in status_counter_get_counter() argument
28 buffer_copy_string_len(di->key, s, len); in status_counter_get_counter()
38 int status_counter_inc(server *srv, const char *s, size_t len) { in status_counter_inc() argument
39 data_integer *di = status_counter_get_counter(srv, s, len); in status_counter_inc()
46 int status_counter_dec(server *srv, const char *s, size_t len) { in status_counter_dec() argument
47 data_integer *di = status_counter_get_counter(srv, s, len); in status_counter_dec()
54 int status_counter_set(server *srv, const char *s, size_t len, int val) { in status_counter_set() argument
55 data_integer *di = status_counter_get_counter(srv, s, len); in status_counter_set()
H A Dmod_evhost.c15 size_t len; member
53 for (j = 0; j < s->len; j++) { in FREE_FUNC()
82 s->path_pieces[s->len] = buffer_init(); in mod_evhost_parse_pattern()
90 s->len += 2; in mod_evhost_parse_pattern()
96 s->path_pieces[s->len] = buffer_init(); in mod_evhost_parse_pattern()
100 s->len += 1; in mod_evhost_parse_pattern()
139 s->len = 0; in SETDEFAULTS_FUNC()
233 PATCH(len); in mod_evhost_patch_connection()
249 PATCH(len); in mod_evhost_patch_connection()
273 if (0 == p->conf.len) { in mod_evhost_uri_handler()
[all …]
H A Dchunk.c166 if (len == 0) return 0; in chunkqueue_append_file()
174 c->file.length = len; in chunkqueue_append_file()
230 if (len == 0) return 0; in chunkqueue_append_mem()
235 buffer_copy_string_len(c->mem, mem, len - 1); in chunkqueue_append_mem()
324 off_t len = 0; in chunkqueue_length() local
330 len += c->mem->used ? c->mem->used - 1 : 0; in chunkqueue_length()
333 len += c->file.length; in chunkqueue_length()
340 return len; in chunkqueue_length()
344 off_t len = 0; in chunkqueue_written() local
351 len += c->offset; in chunkqueue_written()
[all …]
H A Dbuffer.c290 int len = 1; in LI_ltostr() local
293 len++; in LI_ltostr()
305 len += end - buf; in LI_ltostr()
316 return len; in LI_ltostr()
342 int len = 1; in buffer_append_off_t() local
352 len++; in buffer_append_off_t()
364 len += end - start; in buffer_append_off_t()
375 b->used += len; in buffer_append_off_t()
598 if (len == 0) return 1; in buffer_is_equal_right_len()
604 if (b1->used - 1 < len || b1->used - 1 < len) return 0; in buffer_is_equal_right_len()
[all …]
H A Dstatus_counter.h9 data_integer *status_counter_get_counter(server *srv, const char *s, size_t len);
10 int status_counter_inc(server *srv, const char *s, size_t len);
11 int status_counter_dec(server *srv, const char *s, size_t len);
12 int status_counter_set(server *srv, const char *s, size_t len, int val);
H A Dconnections.c185 if (len % 16 != 0) {
218 if (len < 4*1024) len = 4*1024; /* always alloc >= 4k buffer */
236 if (len > 0) {
238 b->used += len;
243 count += len;
248 if (len < 0) {
337 int len; local
387 if (len < 0) {
419 b->used += len;
1284 int len; local
[all …]
/mOS-networking-stack/core/src/bpf/
H A Dsf_bpf_filter.c134 len = MLEN(m); \
136 (_k) -= len; \
140 len = MLEN(m); \
148 register int len; local
154 if (len - k >= 4)
164 switch (len - k)
185 register int len; local
191 if (len - k >= 2)
225 int merr, len; local
551 int len;
[all …]
/mOS-networking-stack/util/include/
H A Dhttp_parsing.h16 int find_http_header(char *data, int len);
17 int is_http_response(char *data, int len);
18 int is_http_request(char *data, int len);
23 char* http_get_http_version_resp(char* data, int len, char* value, int value_len);
26 int http_get_maxage(char *cache_ctl, int len);
28 time_t http_header_date(const char* data, const char* field, int len);
31 int http_parse_first_resp_line(const char* data, int len, int* scode, int* ver);
/mOS-networking-stack/util/
H A Dhttp_parsing.c15 find_http_header(char *data, int len) in find_http_header() argument
19 char ch = data[len]; /* remember it */ in find_http_header()
22 data[len] = 0; in find_http_header()
27 else if (len > 0 && *temp == '\r' && *(temp + 1) == '\n') in find_http_header()
30 data[len] = ch; /* put it back */ in find_http_header()
79 long int len; in http_header_long_val() local
86 len = strtol(temp, NULL, 10); in http_header_long_val()
90 return len; in http_header_long_val()
H A Dring_buffer.c127 int CopyData(ring_buffer *dest_buff, ring_buffer *src_buff, int len) in CopyData() argument
138 to_cpy = MIN(to_cpy, len); in CopyData()
149 int MoveToREPData(ring_buffer *dest_buff, ring_buffer *src_buff, int len) in MoveToREPData() argument
157 if (len > 0) in MoveToREPData()
158 data_size = MIN(data_size, len); in MoveToREPData()
195 int MoveData(ring_buffer *dest_buff, ring_buffer *src_buff, int len) in MoveData() argument
203 if (len > 0) in MoveData()
204 to_move = MIN(to_move, len); in MoveData()
/mOS-networking-stack/core/src/include/
H A Dtcp_rb.h69 int len; member
81 tcprb_new(mem_pool_t mp, int len, unsigned buf_mgmt);
93 tcprb_resize_meta(tcprb_t *rb, int len);
96 tcprb_resize(tcprb_t *rb, int len);
99 tcprb_ffhead(tcprb_t *rb, int len);
102 tcprb_fflen(tcprb_t *rb, uint8_t *buf, int len, loff_t off);
105 tcprb_ppeek(tcprb_t *rb, uint8_t *buf, int len, loff_t off);
108 tcprb_pwrite(tcprb_t *rb, uint8_t *buf, int len, loff_t off);
H A Dtcp_util.h14 uint32_t cur_ts, uint8_t *tcpopt, int len);
18 struct tcp_timestamp *ts, uint8_t *tcpopt, int len);
23 uint32_t ack_seq, uint8_t *tcpopt, int len);
27 TCPCalcChecksum(uint16_t *buf, uint16_t len, uint32_t saddr, uint32_t daddr);
30 PrintTCPOptions(uint8_t *tcpopt, int len);
H A Dtcp_ring_buffer.h34 uint32_t len : 31, member
76 uint32_t len, uint32_t seq);
77 size_t RBGet(rb_manager_t rbm, struct tcp_ring_buffer* buff, size_t len);
79 size_t len, int option, uint8_t buffer_mgmt);
83 uint32_t cur_seq, uint32_t len);
/mOS-networking-stack/samples/common/
H A Dapplib.c111 int len = strlen(vlist[i].name); in LoadConfig() local
112 if (strncmp(vlist[i].name, p, len)) in LoadConfig()
115 if (!isspace(p[len])) in LoadConfig()
124 if ((len = strlen(p)) > CONF_VALUE_LEN) in LoadConfig()
127 strncpy(vlist[i].value, p, len); in LoadConfig()
128 vlist[i].value[len] = '\0'; in LoadConfig()
/mOS-networking-stack/samples/epserver/
H A Depserver-mp.c124 int len; in SendUntilAvailable() local
134 if (len <= 0) { in SendUntilAvailable()
138 fcache[sv->fidx].file + sv->total_sent, len); in SendUntilAvailable()
142 "try: %d, sent: %d\n", sockid, len, ret); in SendUntilAvailable()
185 int len; in HandleReadEvent() local
247 len = strlen(response); in HandleReadEvent()
250 if (sent < len) { in HandleReadEvent()
252 "try: %d, sent: %d\n", sockid, len, sent); in HandleReadEvent()
256 sockid, len, sent); in HandleReadEvent()
257 assert(sent == len); in HandleReadEvent()
[all …]
H A Depserver.c125 int len; in SendUntilAvailable() local
135 if (len <= 0) { in SendUntilAvailable()
139 fcache[sv->fidx].file + sv->total_sent, len); in SendUntilAvailable()
143 "try: %d, sent: %d\n", sockid, len, ret); in SendUntilAvailable()
186 int len; in HandleReadEvent() local
248 len = strlen(response); in HandleReadEvent()
251 if (sent < len) { in HandleReadEvent()
253 "try: %d, sent: %d\n", sockid, len, sent); in HandleReadEvent()
257 sockid, len, sent); in HandleReadEvent()
258 assert(sent == len); in HandleReadEvent()
[all …]

1234