| /libevent-2.1.12/ |
| H A D | event_tagging.c | 214 evbuf, len < sizeof(number) + 1 ? len : sizeof(number) + 1); in decode_tag_internal() 315 len += encode_int_internal(data + len, tv->tv_usec); in evtag_marshal_timeval() 408 int res, len; in evtag_peek_length() local 411 if (len == -1) in evtag_peek_length() 426 int res, len; in evtag_payload_length() local 429 if (len == -1) in evtag_payload_length() 454 return (len); in evtag_unmarshal_header() 460 int len; in evtag_consume() local 473 int len; in evtag_unmarshal() local 483 return (len); in evtag_unmarshal() [all …]
|
| H A D | arc4random.c | 179 size_t len, n; in arc4_seed_getrandom() local 185 for (len = 0; len < sizeof(buf); len += n) { in arc4_seed_getrandom() 186 n = sizeof(buf) - len; in arc4_seed_getrandom() 188 if (0 == getrandom(&buf[len], n, 0)) in arc4_seed_getrandom() 216 size_t len, n; in arc4_seed_sysctl_bsd() local 221 len = sizeof(buf); in arc4_seed_sysctl_bsd() 222 if (sysctl(mib, 2, buf, &len, NULL, 0) == -1) { in arc4_seed_sysctl_bsd() 223 for (len = 0; len < sizeof(buf); len += sizeof(unsigned)) { in arc4_seed_sysctl_bsd() 225 if (n + len > sizeof(buf)) in arc4_seed_sysctl_bsd() 226 n = len - sizeof(buf); in arc4_seed_sysctl_bsd() [all …]
|
| H A D | buffer_iocp.c | 102 size_t remaining, len; in evbuffer_commit_read_() local 117 len = buf->buffers[i].len; in evbuffer_commit_read_() 118 if (remaining < len) in evbuffer_commit_read_() 119 len = remaining; in evbuffer_commit_read_() 120 (*chainp)->off += len; in evbuffer_commit_read_() 122 remaining -= len; in evbuffer_commit_read_() 215 b->len = (unsigned long)chain->off; in evbuffer_launch_write_() 218 b->len = (unsigned long)at_most; in evbuffer_launch_write_()
|
| H A D | log.c | 190 size_t len; in event_logv_() local 201 len = strlen(buf); in event_logv_() 202 if (len < sizeof(buf) - 3) { in event_logv_() 203 evutil_snprintf(buf + len, sizeof(buf) - len, ": %s", errstr); in event_logv_()
|
| H A D | buffer.c | 1119 len = old_len; in evbuffer_drain() 1127 if (len >= old_len) in evbuffer_drain() 1128 len = old_len; in evbuffer_drain() 1131 remaining = len; in evbuffer_drain() 1503 s_end = s+len; in find_eol_char() 2491 return (len); in evbuffer_write_sendfile() 2497 return (len); in evbuffer_write_sendfile() 2700 n_comparable = len; in evbuffer_ptr_memcmp() 2742 if (!len || len > EV_SSIZE_MAX) in evbuffer_search_range() 2824 if (len >= 0 && len_so_far >= len) in evbuffer_peek() [all …]
|
| H A D | evutil.c | 1688 size_t len; in chomp() local 1689 if (s && (len = strlen (s)) > 0 && s[len - 1] == '\n') { in chomp() 1690 s[--len] = 0; in chomp() 1691 if (len > 0 && s[len - 1] == '\r') in chomp() 1692 s[--len] = 0; in chomp() 1777 size_t len = 50; in evutil_socket_error_to_string() local 1938 if (strlen(buf) > len) in evutil_inet_ntop() 1980 if (strlen(buf) > len) in evutil_inet_ntop() 1982 strlcpy(dst, buf, len); in evutil_inet_ntop() 2156 size_t len; in evutil_parse_sockaddr_port() local [all …]
|
| H A D | http.c | 297 p += len; in evhttp_htmlescape() 519 char len[22]; in evhttp_maybe_add_content_length_header() local 520 evutil_snprintf(len, sizeof(len), EV_SIZE_FMT, in evhttp_maybe_add_content_length_header() 1720 char *eos = line + len; in evhttp_parse_request_line() 1732 --len; in evhttp_parse_request_line() 2030 size_t len; in evhttp_parse_firstline_() local 2103 size_t len; in evhttp_parse_headers_() local 3120 if (len >= 0) { in evhttp_uriencode() 3125 end = uri + len; in evhttp_uriencode() 4150 size_t len; in evhttp_request_get_host() local [all …]
|
| /libevent-2.1.12/sample/ |
| H A D | event-read-fifo.c | 37 int len; in fifo_read() local 46 len = ReadFile((HANDLE)fd, buf, sizeof(buf) - 1, &dwBytesRead, NULL); in fifo_read() 49 if (len && dwBytesRead == 0) { in fifo_read() 57 len = read(fd, buf, sizeof(buf) - 1); in fifo_read() 59 if (len <= 0) { in fifo_read() 60 if (len == -1) in fifo_read() 62 else if (len == 0) in fifo_read() 69 buf[len] = '\0'; in fifo_read()
|
| H A D | http-connect.c | 60 ev_ssize_t len; in get_cb() local 66 len = evbuffer_get_length(evbuf); in get_cb() 67 fwrite(evbuffer_pullup(evbuf, len), len, 1, stdout); in get_cb() 68 evbuffer_drain(evbuf, len); in get_cb()
|
| H A D | le-proxy.c | 57 size_t len; in readcb() local 59 len = evbuffer_get_length(src); in readcb() 61 evbuffer_drain(src, len); in readcb()
|
| H A D | http-server.c | 191 size_t len; in send_document_cb() local 225 len = strlen(decoded_path)+strlen(o->docroot)+2; in send_document_cb() 226 if (!(whole_path = malloc(len))) { in send_document_cb() 230 evutil_snprintf(whole_path, len, "%s/%s", o->docroot, decoded_path); in send_document_cb()
|
| /libevent-2.1.12/test/ |
| H A D | test-weof.c | 63 int len; in write_cb() local 65 len = send(fd, test, (int)strlen(test) + 1, 0); in write_cb() 68 len, len ? "" : " - means EOF"); in write_cb() 70 if (len > 0) { in write_cb()
|
| H A D | test-eof.c | 60 int len; in read_cb() local 67 len = recv(fd, buf, sizeof(buf), 0); in read_cb() 70 len, len ? "" : " - means EOF"); in read_cb() 72 if (len) { in read_cb()
|
| H A D | regress.c | 110 int len; in simple_read_cb() local 114 if (len) { in simple_read_cb() 129 int len; in basic_read_cb() local 167 int len; in simple_write_cb() local 180 int len; in multiple_write_cb() local 182 len = 128; in multiple_write_cb() 186 len = write(fd, wbuf + woff, len); in multiple_write_cb() 213 int len; in multiple_read_cb() local 247 int len; in combined_read_cb() local 265 int len; in combined_write_cb() local [all …]
|
| H A D | regress_et.c | 66 int len; in read_cb() local 68 len = recv(fd, &buf, sizeof(buf), 0); in read_cb() 74 if (!len) in read_cb()
|
| H A D | regress_buffer.c | 950 int len; in test_evbuffer_add2() local 964 tt_assert(len == data_len+2); in test_evbuffer_add2() 966 tt_assert(str[len-3] == 'P'); in test_evbuffer_add2() 967 tt_assert(str[len-2] == '2'); in test_evbuffer_add2() 968 tt_assert(str[len-1] == '3'); in test_evbuffer_add2() 1035 int len; in test_evbuffer_reference2() local 1049 tt_assert(len == data_len+2); in test_evbuffer_reference2() 2542 size_t orig_length, len; in test_evbuffer_freeze() local 2601 FREEZE_EQ(r, len, -1); in test_evbuffer_freeze() 2632 FREEZE_EQ(r, -1, len); in test_evbuffer_freeze() [all …]
|
| H A D | tinytest_macros.h | 188 #define tt_mem_op(expr1, op, expr2, len) \ argument 191 (val1_ && val2_ && memcmp(val1_, val2_, len) op 0), \ 193 { print_ = tinytest_format_hex_(value_, (len)); }, \
|
| H A D | regress_util.c | 300 int len = sizeof(ss); in regress_sockaddr_port_parse() local 302 r = evutil_parse_sockaddr_port(ent->parse, (struct sockaddr*)&ss, &len); in regress_sockaddr_port_parse() 324 } else if (len != sizeof(sin)) { in regress_sockaddr_port_parse() 340 } else if (len != sizeof(sin6)) { in regress_sockaddr_port_parse() 352 int len; in regress_sockaddr_port_format() local 357 len = sizeof(ss); in regress_sockaddr_port_format() 359 (struct sockaddr*)&ss, &len); in regress_sockaddr_port_format() 366 len = sizeof(ss); in regress_sockaddr_port_format() 368 (struct sockaddr*)&ss, &len); in regress_sockaddr_port_format() 411 int len = sizeof(ss); in test_evutil_sockaddr_predicates() local [all …]
|
| H A D | tinytest.c | 593 tinytest_format_hex_(const void *val_, unsigned long len) argument 601 if (!(result = malloc(len*2+1))) 604 for (i=0;i<len;++i) {
|
| H A D | regress_bufferevent.c | 370 int len = (int)evbuffer_get_length(bev->input); in wm_readcb() local 373 assert(len >= 10 && len <= 20); in wm_readcb() 380 nread += len; in wm_readcb() 1107 size_t low, high, len; in trigger_readcb() local 1116 len = evbuffer_get_length(bufferevent_get_input(bev)); in trigger_readcb() 1118 bufferevent_setwatermark(bev, EV_READ, len + 1, 0); in trigger_readcb()
|
| /libevent-2.1.12/include/event2/ |
| H A D | buffer.h | 692 int evbuffer_drain(struct evbuffer *buf, size_t len); 749 struct evbuffer_ptr evbuffer_search(struct evbuffer *buffer, const char *what, size_t len, const st… 766 struct evbuffer_ptr evbuffer_search_range(struct evbuffer *buffer, const char *what, size_t len, co… 854 int evbuffer_peek(struct evbuffer *buffer, ev_ssize_t len,
|
| H A D | tag.h | 76 ev_uint32_t len); 132 void *data, size_t len);
|
| H A D | dns.h | 378 const struct sockaddr *sa, ev_socklen_t len, unsigned flags); 745 struct sockaddr *sa, ev_socklen_t len);
|
| H A D | buffer_compat.h | 108 unsigned char *evbuffer_find(struct evbuffer *buffer, const unsigned char *what, size_t len);
|
| H A D | rpc.h | 102 #define EVTAG_ASSIGN_WITH_LEN(msg, member, value, len) \ argument 103 (*(msg)->base->member##_assign)((msg), (value), (len))
|