Home
last modified time | relevance | path

Searched refs:buf (Results 1 – 25 of 43) sorted by relevance

12

/libevent-2.1.12/test/
H A Dregress_buffer.c85 if (buf->last_with_datap == &buf->first) in evbuffer_validate_()
115 tt_assert(buf->last_with_datap == &buf->first); in evbuffer_validate_()
311 evbuffer_add(dst, buf, sizeof(buf)); in test_evbuffer_remove_buffer_with_empty()
454 if (buf) in test_evbuffer_pullup_with_empty()
788 if (buf) in test_evbuffer_reserve_with_empty()
823 if (buf) in test_evbuffer_reserve_invalid_last_with_datap()
847 tt_assert(buf->first == buf->last); in test_evbuffer_expand()
869 tt_assert(buf->first == buf->last); in test_evbuffer_expand()
871 evbuffer_drain(buf, buf->first->off - 1); in test_evbuffer_expand()
877 tt_assert(buf->first == buf->last); in test_evbuffer_expand()
[all …]
H A Dregress_util.c447 char buf[16]; in test_evutil_snprintf() local
454 r = evutil_snprintf(buf, sizeof(buf), "%d %d", 50, 100); in test_evutil_snprintf()
618 char buf[128]; in test_evutil_log() local
663 evutil_snprintf(buf, sizeof(buf), in test_evutil_log()
669 evutil_snprintf(buf, sizeof(buf), in test_evutil_log()
678 evutil_snprintf(buf, sizeof(buf), in test_evutil_log()
683 evutil_snprintf(buf, sizeof(buf), in test_evutil_log()
708 char buf[8]; in test_evutil_strlcpy() local
711 tt_int_op(5, ==, strlcpy(buf, "Hello", sizeof(buf))); in test_evutil_strlcpy()
719 tt_int_op(8, ==, strlcpy(buf, "overlong", sizeof(buf))); in test_evutil_strlcpy()
[all …]
H A Dregress_iocp.c241 struct evbuffer *buf=NULL; in test_iocp_evbuffer() local
269 buf = evbuffer_new(); in test_iocp_evbuffer()
270 tt_assert(buf != NULL); in test_iocp_evbuffer()
273 evbuffer_add_buffer(buf, rbuf); in test_iocp_evbuffer()
274 tt_int_op(evbuffer_get_length(buf), ==, sizeof(junk)); in test_iocp_evbuffer()
275 for (chain = buf->first; chain; chain = chain->next) in test_iocp_evbuffer()
291 if (buf) evbuffer_free(buf); in test_iocp_evbuffer()
310 char buf[128]; in test_iocp_bufferevent_async() local
333 n = bufferevent_read(bea2, buf, sizeof(buf)-1); in test_iocp_bufferevent_async()
334 buf[n]='\0'; in test_iocp_bufferevent_async()
[all …]
H A Dregress_dns.c546 char buf[64]; in dns_search_test_impl() local
660 char buf[64]; in dns_search_cancel_test() local
735 char buf[64]; in dns_retry_test_impl() local
909 char buf[64]; in dns_inflight_test_impl() local
973 char buf[64]; in dns_disable_when_inactive_no_ns_test() local
1266 char buf[128]; in test_bufferevent_connect_hostname() local
1434 char buf[128]; in test_getaddrinfo_async() local
1603 evutil_snprintf(buf, sizeof(buf), "127.0.0.1:%d", dns_port); in test_getaddrinfo_async()
2127 char buf[64]; in dns_client_fail_requests_test() local
2175 char buf[64]; in dns_client_fail_requests_getaddrinfo_test() local
[all …]
H A Dtest-eof.c59 char buf[256]; in read_cb() local
67 len = recv(fd, buf, sizeof(buf), 0); in read_cb()
H A Dregress.c95 #define write(fd,buf,len) send((fd),(buf),(int)(len),0) argument
96 #define read(fd,buf,len) recv((fd),(buf),(int)(len),0) argument
112 len = read(fd, buf, sizeof(buf)); in simple_read_cb()
132 len = read(fd, buf, sizeof(buf)); in basic_read_cb()
249 len = read(fd, buf, sizeof(buf)); in combined_read_cb()
400 memset(buf, 99, sizeof(buf)); in test_simpleclose_rw()
417 int r = write(pair2[1], buf, sizeof(buf)); in test_simpleclose_rw()
885 len = read(fd, buf, sizeof(buf)); in simple_child_read_cb()
1845 while ((n = read(fd, buf, sizeof(buf))) > 0) in read_and_drain_cb()
2151 n_read = read(fd, buf, sizeof(buf)); in re_add_read_cb()
[all …]
H A Dregress_et.c65 char buf; in read_cb() local
68 len = recv(fd, &buf, sizeof(buf), 0); in read_cb()
H A Dtest-ratelim.c132 char buf[1024]; in loud_writecb() local
134 memset(buf, r, sizeof(buf)); in loud_writecb()
136 evbuffer_add(output, buf, sizeof(buf)); in loud_writecb()
137 cs->queued += sizeof(buf); in loud_writecb()
/libevent-2.1.12/
H A Darc4random.c167 arc4_addrandom(buf, sizeof(buf)); in arc4_seed_win32()
168 evutil_memclear_(buf, sizeof(buf)); in arc4_seed_win32()
183 memset(buf, 0, sizeof(buf)); in arc4_seed_getrandom()
198 arc4_addrandom(buf, sizeof(buf)); in arc4_seed_getrandom()
199 evutil_memclear_(buf, sizeof(buf)); in arc4_seed_getrandom()
219 memset(buf, 0, sizeof(buf)); in arc4_seed_sysctl_bsd()
238 arc4_addrandom(buf, sizeof(buf)); in arc4_seed_sysctl_bsd()
239 evutil_memclear_(buf, sizeof(buf)); in arc4_seed_sysctl_bsd()
262 n = read(fd, buf, sizeof(buf)); in arc4_seed_proc_sys_kernel_random_uuid()
284 evutil_memclear_(buf, sizeof(buf)); in arc4_seed_proc_sys_kernel_random_uuid()
[all …]
H A Dbuffer_iocp.c77 if (!buf || !buf->is_overlapped) in upcast_evbuffer()
106 EVUTIL_ASSERT(buf->read_in_progress && !buf->write_in_progress); in evbuffer_commit_read_()
144 EVUTIL_ASSERT(buf->write_in_progress && !buf->read_in_progress); in evbuffer_commit_write_()
181 if (!buf) { in evbuffer_launch_write_()
186 EVBUFFER_LOCK(buf); in evbuffer_launch_write_()
190 if (!buf->total_len) { in evbuffer_launch_write_()
241 EVBUFFER_UNLOCK(buf); in evbuffer_launch_write_()
260 EVBUFFER_LOCK(buf); in evbuffer_launch_read_()
307 EVBUFFER_UNLOCK(buf); in evbuffer_launch_read_()
322 EVBUFFER_LOCK(buf); in evbuffer_overlapped_set_fd_()
[all …]
H A Dbuffer.c317 buf->first = buf->last = chain; in evbuffer_chain_insert()
796 return (buf->last && CHAIN_PINNED_R(buf->last)); in HAS_PINNED_R()
1139 buf->last_with_datap = &buf->first; in evbuffer_drain()
1142 buf->last_with_datap = &buf->first; in evbuffer_drain()
1448 buf->last_with_datap = &buf->first; in evbuffer_pullup()
1450 if (buf->first->next && buf->first->next->off) in evbuffer_pullup()
1451 buf->last_with_datap = &buf->first->next; in evbuffer_pullup()
1453 buf->last_with_datap = &buf->first; in evbuffer_pullup()
2143 buf->last = *buf->last_with_datap; in evbuffer_expand_fast_()
2150 buf->first = buf->last = tmp; in evbuffer_expand_fast_()
[all …]
H A Devutil_rand.c72 ev_arc4random_buf(void *buf, size_t n) in ev_arc4random_buf() argument
75 arc4random_buf(buf, n); in ev_arc4random_buf()
78 unsigned char *b = buf; in ev_arc4random_buf()
91 arc4random_buf(buf, n); in ev_arc4random_buf()
180 ev_arc4random_buf(void *buf, size_t n) in ev_arc4random_buf() argument
182 arc4random_buf(buf, n); in ev_arc4random_buf()
188 evutil_secure_rng_get_bytes(void *buf, size_t n) in evutil_secure_rng_get_bytes() argument
190 ev_arc4random_buf(buf, n); in evutil_secure_rng_get_bytes()
195 evutil_secure_rng_add_bytes(const char *buf, size_t n) in evutil_secure_rng_add_bytes() argument
197 arc4random_addrandom((unsigned char*)buf, in evutil_secure_rng_add_bytes()
H A Dlog.c189 char buf[1024]; in event_logv_() local
196 evutil_vsnprintf(buf, sizeof(buf), fmt, ap); in event_logv_()
198 buf[0] = '\0'; in event_logv_()
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_()
207 event_log(severity, buf); in event_logv_()
H A Devbuffer-internal.h303 void evbuffer_incref_(struct evbuffer *buf);
305 void evbuffer_incref_and_lock_(struct evbuffer *buf);
325 int evbuffer_read_setup_vecs_(struct evbuffer *buf, ev_ssize_t howmuch,
331 (i)->buf = (ei)->iov_base; \
338 void evbuffer_set_parent_(struct evbuffer *buf, struct bufferevent *bev);
340 void evbuffer_invoke_callbacks_(struct evbuffer *buf);
H A Devent_rpcgen.py671 def CodeMarshal(buf, tag_name, var_name, var_len): argument
743 def CodeMarshal(self, buf, tag_name, var_name, _var_len): argument
746 % (self._marshal_type, buf, tag_name, var_name)
839 {"buf": buf, "tag": tag_name, "var": var_name}
844 def CodeMarshal(buf, tag_name, var_name, _var_len): argument
1018 {"buf": buf, "tag": tag_name, "var": var_name}
1022 def CodeMarshal(self, buf, tag_name, var_name, _var_len): argument
1148 def CodeMarshal(buf, tag_name, var_name, var_len): argument
1356 "buf": buf,
1374 buf,
[all …]
H A Devutil.c1503 char buf[2048]; in evutil_getaddrinfo()
1506 r = gethostbyname_r(nodename, &hostent, buf, sizeof(buf), &ent, in evutil_getaddrinfo()
1509 char buf[2048]; in evutil_getaddrinfo()
1511 ent = gethostbyname_r(nodename, &hostent, buf, sizeof(buf), in evutil_getaddrinfo()
1930 evutil_snprintf(buf, sizeof(buf), "::%d.%d.%d.%d", in evutil_inet_ntop()
1962 cp = buf; in evutil_inet_ntop()
1973 sizeof(buf)-(cp-buf), "%x", (unsigned)words[i]); in evutil_inet_ntop()
2143 char buf[128]; in evutil_parse_sockaddr_port() local
2165 buf[len] = '\0'; in evutil_parse_sockaddr_port()
2166 addr_part = buf; in evutil_parse_sockaddr_port()
[all …]
H A Diocp-internal.h121 evutil_socket_t evbuffer_overlapped_get_fd_(struct evbuffer *buf);
123 void evbuffer_overlapped_set_fd_(struct evbuffer *buf, evutil_socket_t fd);
138 int evbuffer_launch_read_(struct evbuffer *buf, size_t n, struct event_overlapped *ol);
153 int evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t n, struct event_overlapped *ol);
H A Devdns.c459 evutil_vsnprintf(buf, sizeof(buf), fmt, args); in evdns_log_()
1674 if (!j || buf[j-1]) buf[j++] = 0; in dnsname_to_labels()
1869 char buf[32]; in evdns_server_request_add_ptr_reply() local
2988 char buf[32]; in evdns_base_resolve_reverse() local
3023 char buf[73]; in evdns_base_resolve_reverse_ipv6() local
3029 cp = buf; in evdns_base_resolve_reverse_ipv6()
3037 EVUTIL_ASSERT(cp + strlen("ip6.arpa") < buf+sizeof(buf)); in evdns_base_resolve_reverse_ipv6()
3737 char *buf; in evdns_nameserver_ip_add_line() local
3789 fixed = buf; in load_nameservers_with_getnetworkparams()
3834 if (buf) in load_nameservers_with_getnetworkparams()
[all …]
H A Dhttp.c1471 evbuffer_drain(buf, evbuffer_get_length(buf)); in evhttp_connection_read_on_write_error()
2811 if (buf == NULL) { in evhttp_send_error()
2826 evbuffer_free(buf); in evhttp_send_error()
3116 if (!buf) { in evhttp_uriencode()
3155 evbuffer_remove(buf, result, evbuffer_get_length(buf)); in evhttp_uriencode()
3158 if (buf) in evhttp_uriencode()
3159 evbuffer_free(buf); in evhttp_uriencode()
3534 evbuffer_free(buf); in evhttp_handle_request()
4615 char buf[64]; in bracket_addr_ok() local
4621 buf[n_chars]='\0'; in bracket_addr_ok()
[all …]
H A Dbufferevent_async.c307 be_async_outbuf_callback(struct evbuffer *buf, in be_async_outbuf_callback() argument
326 be_async_inbuf_callback(struct evbuffer *buf, in be_async_inbuf_callback() argument
345 be_async_enable(struct bufferevent *buf, short what) in be_async_enable() argument
347 struct bufferevent_async *bev_async = upcast(buf); in be_async_enable()
358 BEV_RESET_GENERIC_READ_TIMEOUT(buf); in be_async_enable()
360 BEV_RESET_GENERIC_WRITE_TIMEOUT(buf); in be_async_enable()
/libevent-2.1.12/include/event2/
H A Dbuffer.h159 void evbuffer_free(struct evbuffer *buf);
174 int evbuffer_enable_locking(struct evbuffer *buf, void *lock);
181 void evbuffer_lock(struct evbuffer *buf);
188 void evbuffer_unlock(struct evbuffer *buf);
234 size_t evbuffer_get_length(const struct evbuffer *buf);
262 int evbuffer_expand(struct evbuffer *buf, size_t datlen);
324 int evbuffer_commit_space(struct evbuffer *buf,
646 int evbuffer_add_file_segment(struct evbuffer *buf,
692 int evbuffer_drain(struct evbuffer *buf, size_t len);
1034 int evbuffer_freeze(struct evbuffer *buf, int at_front);
[all …]
/libevent-2.1.12/sample/
H A Devent-read-fifo.c36 char buf[255]; in fifo_read() local
46 len = ReadFile((HANDLE)fd, buf, sizeof(buf) - 1, &dwBytesRead, NULL); in fifo_read()
55 buf[dwBytesRead] = '\0'; in fifo_read()
57 len = read(fd, buf, sizeof(buf) - 1); in fifo_read()
69 buf[len] = '\0'; in fifo_read()
71 fprintf(stdout, "Read: %s\n", buf); in fifo_read()
H A Ddns-example.c48 static char buf[32]; in debug_ntoa() local
50 evutil_snprintf(buf, sizeof(buf), "%d.%d.%d.%d", in debug_ntoa()
55 return buf; in debug_ntoa()
89 char buf[128]; in gai_callback() local
93 evutil_inet_ntop(AF_INET, &sin->sin_addr, buf, in gai_callback()
94 sizeof(buf)); in gai_callback()
95 printf("[%d] %s: %s\n",i,name,buf); in gai_callback()
99 evutil_inet_ntop(AF_INET6, &sin6->sin6_addr, buf, in gai_callback()
100 sizeof(buf)); in gai_callback()
101 printf("[%d] %s: %s\n",i,name,buf); in gai_callback()
H A Dhttps-client.c480 char buf[1024]; in main() local
490 while ((s = fread(buf, 1, sizeof(buf), f)) > 0) { in main()
491 evbuffer_add(output_buffer, buf, s); in main()
494 evutil_snprintf(buf, sizeof(buf)-1, "%lu", (unsigned long)bytes); in main()
495 evhttp_add_header(output_headers, "Content-Length", buf); in main()
/libevent-2.1.12/cmake/
H A DCheckWorkingKqueue.cmake20 char buf[80000];
27 while ((n = write(fd[1], buf, sizeof(buf))) == sizeof(buf))
41 read(fd[0], buf, sizeof(buf));

12