Home
last modified time | relevance | path

Searched refs:EVUTIL_ASSERT (Results 1 – 25 of 30) sorted by relevance

12

/libevent-2.1.12/
H A Devthread.c220 EVUTIL_ASSERT(lock->count == 0); in debug_lock_free()
221 EVUTIL_ASSERT(locktype == lock->locktype); in debug_lock_free()
239 EVUTIL_ASSERT(lock->count == 1); in evthread_debug_lock_mark_locked()
244 EVUTIL_ASSERT(lock->held_by == me); in evthread_debug_lock_mark_locked()
277 EVUTIL_ASSERT(lock->held_by == me); in evthread_debug_lock_mark_unlocked()
282 EVUTIL_ASSERT(lock->count >= 0); in evthread_debug_lock_mark_unlocked()
301 EVUTIL_ASSERT(lock); in debug_cond_wait()
376 EVUTIL_ASSERT(lock_ == NULL); in evthread_setup_global_lock_()
381 EVUTIL_ASSERT(lock_ != NULL); in evthread_setup_global_lock_()
400 EVUTIL_ASSERT(lock_ == NULL); in evthread_setup_global_lock_()
[all …]
H A Devmap.c282 EVUTIL_ASSERT(fd == ev->ev_fd); in evmap_io_add_()
365 EVUTIL_ASSERT(fd == ev->ev_fd); in evmap_io_del_()
388 EVUTIL_ASSERT(nread >= 0); in evmap_io_del_()
393 EVUTIL_ASSERT(nwrite >= 0); in evmap_io_del_()
398 EVUTIL_ASSERT(nclose >= 0); in evmap_io_del_()
615 EVUTIL_ASSERT(ctx);
745 EVUTIL_ASSERT(c->fd == fd);
761 EVUTIL_ASSERT(c->fd >= 0);
763 EVUTIL_ASSERT(f);
860 EVUTIL_ASSERT(change->fd == fd);
[all …]
H A Devrpc.c102 EVUTIL_ASSERT(r == 0); in evrpc_free()
110 EVUTIL_ASSERT(r); in evrpc_free()
114 EVUTIL_ASSERT(r); in evrpc_free()
140 EVUTIL_ASSERT(hook != NULL); in evrpc_add_hook()
271 EVUTIL_ASSERT(r == 0); in evrpc_unregister_rpc()
345 EVUTIL_ASSERT(rpc_state); in evrpc_request_cb_closure()
409 EVUTIL_ASSERT(rpc_state); in evrpc_request_done()
478 EVUTIL_ASSERT(rpc_state); in evrpc_request_done_closure()
563 EVUTIL_ASSERT(r); in evrpc_pool_free()
568 EVUTIL_ASSERT(r); in evrpc_pool_free()
[all …]
H A Dutil-internal.h189 EVUTIL_ASSERT(elm1 != elm2); \
194 EVUTIL_ASSERT(elm1 != elm2); \
202 EVUTIL_ASSERT(*nextp == elm1); \
203 EVUTIL_ASSERT(nextp == elm1->field.le_prev); \
225 EVUTIL_ASSERT(elm1 != elm2); \
230 EVUTIL_ASSERT(elm1 != elm2); \
238 EVUTIL_ASSERT(*nextp == elm1); \
239 EVUTIL_ASSERT(nextp == elm1->field.tqe_prev); \
243 EVUTIL_ASSERT(nextp == (tailq)->tqh_last); \
360 #define EVUTIL_ASSERT(cond) EVUTIL_NIL_CONDITION_(cond) macro
[all …]
H A Dbuffer_iocp.c90 EVUTIL_ASSERT(chain); in pin_release()
106 EVUTIL_ASSERT(buf->read_in_progress && !buf->write_in_progress); in evbuffer_commit_read_()
107 EVUTIL_ASSERT(nBytes >= 0); /* XXXX Can this be false? */ in evbuffer_commit_read_()
116 EVUTIL_ASSERT(*chainp); in evbuffer_commit_read_()
144 EVUTIL_ASSERT(buf->write_in_progress && !buf->read_in_progress); in evbuffer_commit_write_()
187 EVUTIL_ASSERT(!buf_o->read_in_progress); in evbuffer_launch_write_()
261 EVUTIL_ASSERT(!buf_o->write_in_progress); in evbuffer_launch_read_()
289 EVUTIL_ASSERT(npin == nvecs); in evbuffer_launch_read_()
H A Dpoll.c124 EVUTIL_ASSERT(pop->event_set[idx].fd == i); in poll_check_ok()
128 EVUTIL_ASSERT(pop->idxplus1_by_fd[pfd->fd] == i+1); in poll_check_ok()
237 EVUTIL_ASSERT((events & EV_SIGNAL) == 0); in poll_add()
300 EVUTIL_ASSERT((events & EV_SIGNAL) == 0); in poll_del()
334 EVUTIL_ASSERT(idx); in poll_del()
335 EVUTIL_ASSERT(idx->idxplus1 == pop->nfds + 1); in poll_del()
H A Devent.c769 EVUTIL_ASSERT(rv >= 0); in event_base_stop_iocp_()
1677 EVUTIL_ASSERT(ev != NULL); in event_process_active_single_queue()
1681 EVUTIL_ASSERT(ev != NULL); in event_process_active_single_queue()
1687 EVUTIL_ASSERT(ev != NULL); in event_process_active_single_queue()
1724 EVUTIL_ASSERT(0); in event_process_active_single_queue()
1823 EVUTIL_ASSERT(base); in event_base_get_method()
2184 EVUTIL_ASSERT(r == 0); in event_set()
2937 EVUTIL_ASSERT(0); in event_active_nolock_()
3016 EVUTIL_ASSERT(0); in event_callback_activate_nolock_()
3082 EVUTIL_ASSERT(0); in event_callback_cancel_nolock_()
[all …]
H A Dbuffer.c198 EVUTIL_ASSERT(chain->refcnt > 0); in evbuffer_chain_free()
1243 EVUTIL_ASSERT(chain); in evbuffer_copyout_from()
1379 EVUTIL_ASSERT(remaining >= 0); in evbuffer_pullup()
2042 EVUTIL_ASSERT(result); in evbuffer_expand_singlechain()
2058 EVUTIL_ASSERT(n >= 2); in evbuffer_expand_fast_()
2104 EVUTIL_ASSERT(chain == NULL); in evbuffer_expand_fast_()
2241 EVUTIL_ASSERT(*firstchainp); in evbuffer_read_setup_vecs_()
2247 EVUTIL_ASSERT(chain); in evbuffer_read_setup_vecs_()
2551 EVUTIL_ASSERT(p || !howmuch); in evbuffer_write_atmost()
2555 EVUTIL_ASSERT(p || !howmuch); in evbuffer_write_atmost()
[all …]
H A Dbufferevent_filter.c125 EVUTIL_ASSERT(BEV_IS_FILTER(&bev_f->bev.bev)); in upcast()
232 EVUTIL_ASSERT(bevf); in be_filter_unlink()
261 EVUTIL_ASSERT(bevf); in be_filter_destruct()
448 EVUTIL_ASSERT(bufev_private->refcnt >= 0); in be_filter_read_nolock_()
539 EVUTIL_ASSERT(bufev_private->refcnt >= 0); in be_filter_writecb()
560 EVUTIL_ASSERT(bufev_private->refcnt >= 0); in be_filter_eventcb()
578 EVUTIL_ASSERT(bevf); in be_filter_flush()
H A Dbufferevent_async.c140 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); in upcast_connect()
149 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); in upcast_read()
158 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); in upcast_write()
399 EVUTIL_ASSERT(!upcast(bev)->write_in_progress && in be_async_destruct()
442 EVUTIL_ASSERT(bev_a->bev.connecting); in connect_complete()
469 EVUTIL_ASSERT(bev_a->read_in_progress); in read_complete()
509 EVUTIL_ASSERT(bev_a->write_in_progress); in write_complete()
628 EVUTIL_ASSERT(ext && ext->ConnectEx && fd >= 0 && sa != NULL); in bufferevent_async_connect_()
H A Devport.c204 EVUTIL_ASSERT(evpd); in check_evportop()
205 EVUTIL_ASSERT(evpd->ed_port > 0); in check_evportop()
220 EVUTIL_ASSERT(pevt->portev_source == PORT_SOURCE_FD); in check_event()
425 EVUTIL_ASSERT(evpd->ed_pending[i] == fd); in evport_del()
H A Dkqueue.c199 EVUTIL_ASSERT(change & EV_CHANGE_DEL); in kq_setup_kevent()
282 EVUTIL_ASSERT(kqop->changes); in kq_dispatch()
320 EVUTIL_ASSERT(kqop->changes == NULL); in kq_dispatch()
461 EVUTIL_ASSERT(nsignal >= 0 && nsignal < NSIG); in kq_sig_add()
495 EVUTIL_ASSERT(nsignal >= 0 && nsignal < NSIG); in kq_sig_del()
H A Devdns.c823 EVUTIL_ASSERT(0); in reply_run_callback()
2138 EVUTIL_ASSERT(port); in server_port_free()
2139 EVUTIL_ASSERT(!port->refcnt); in server_port_free()
2680 EVUTIL_ASSERT(base); in evdns_base_nameserver_sockaddr_add()
2736 EVUTIL_ASSERT(found); in evdns_request_remove()
2738 EVUTIL_ASSERT(req->next); in evdns_request_remove()
2992 EVUTIL_ASSERT(in); in evdns_base_resolve_reverse()
3028 EVUTIL_ASSERT(in); in evdns_base_resolve_reverse_ipv6()
3235 EVUTIL_ASSERT(0); in search_make_new()
3436 EVUTIL_ASSERT(n_heads > 0); in evdns_base_set_max_requests_inflight()
[all …]
H A Dhttp.c217 EVUTIL_ASSERT(strlen(del) == 1); in strsep()
743 EVUTIL_ASSERT(req != NULL); in evhttp_connection_fail_()
1201 EVUTIL_ASSERT(req != NULL); in evhttp_write_connectioncb()
1363 EVUTIL_ASSERT(!err && "setfd"); in evhttp_connection_reset_()
2487 EVUTIL_ASSERT(evcon->base == NULL); in evhttp_connection_set_base()
2669 EVUTIL_ASSERT(req->evcon == NULL); in evhttp_make_request()
3241 EVUTIL_ASSERT(n >= 0); in evhttp_uridecode()
4513 EVUTIL_ASSERT(eos >= s); in scheme_ok()
4630 EVUTIL_ASSERT(eos); in parse_authority()
4668 EVUTIL_ASSERT(eos >= cp); in parse_authority()
[all …]
H A Dbufferevent_ratelim.c456 EVUTIL_ASSERT(! LIST_EMPTY(&group->members)); in bev_group_random_element_()
608 EVUTIL_ASSERT(event_initialized(&rlim->refill_bucket_event)); in bufferevent_set_rate_limit()
727 EVUTIL_ASSERT(0 == g->n_members); in bufferevent_rate_limit_group_free()
976 EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg); in bufferevent_decrement_read_limit()
1005 EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg); in bufferevent_decrement_write_limit()
1068 EVUTIL_ASSERT(grp != NULL); in bufferevent_rate_limit_group_get_totals()
H A Dselect.c257 EVUTIL_ASSERT((events & EV_SIGNAL) == 0); in select_add()
304 EVUTIL_ASSERT((events & EV_SIGNAL) == 0); in select_del()
H A Devthread-internal.h132 EVUTIL_ASSERT(evthread_is_debug_lock_held_(lock)); \
255 EVUTIL_ASSERT(evthread_is_debug_lock_held_(lock)); \
H A Dbufferevent_sock.c124 EVUTIL_ASSERT(addrlen <= sizeof(bev_p->conn_address)); in bufferevent_socket_set_conn_address_()
600 EVUTIL_ASSERT(BEV_IS_SOCKET(bufev)); in be_socket_destruct()
624 EVUTIL_ASSERT(BEV_IS_SOCKET(bufev)); in be_socket_setfd()
H A Dsignal.c285 EVUTIL_ASSERT(evsignal >= 0 && evsignal < NSIG); in evsig_add()
365 EVUTIL_ASSERT(evsignal >= 0 && evsignal < NSIG); in evsig_del()
H A Dwin32select.c108 EVUTIL_ASSERT(new_num_fds >= op->readset_in->fd_count && in grow_fd_sets()
110 EVUTIL_ASSERT(new_num_fds >= 1); in grow_fd_sets()
H A Depoll.c280 EVUTIL_ASSERT(op == 0); in epoll_apply_one_change()
479 EVUTIL_ASSERT(res <= epollop->nevents); in epoll_dispatch()
H A Devutil.c154 EVUTIL_ASSERT(content_out); in evutil_read_file_()
155 EVUTIL_ASSERT(len_out); in evutil_read_file_()
187 EVUTIL_ASSERT(read_so_far < (size_t)st.st_size); in evutil_read_file_()
786 EVUTIL_ASSERT(r); in evutil_check_interfaces()
792 EVUTIL_ASSERT(r); in evutil_check_interfaces()
836 EVUTIL_ASSERT(hints); in evutil_new_addrinfo_()
1461 EVUTIL_ASSERT((ALL_NONNATIVE_AI_FLAGS & ALL_NATIVE_AI_FLAGS) == 0); in evutil_getaddrinfo()
H A Dbufferevent_openssl.c184 EVUTIL_ASSERT(inlen > 0); in bio_bufferevent_write()
362 EVUTIL_ASSERT(BEV_IS_OPENSSL(&bev_o->bev.bev)); in upcast()
1026 EVUTIL_ASSERT(0); in do_handshake()
H A Dbufferevent_pair.c62 EVUTIL_ASSERT(BEV_IS_PAIR(&bev_p->bev.bev)); in upcast()
H A Dlistener.c429 EVUTIL_ASSERT(freed); in listener_read_cb()
620 EVUTIL_ASSERT(ext->GetAcceptExSockaddrs); in accepted_socket_invoke_user_cb()

12