Home
last modified time | relevance | path

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

12

/external/libevent/
Devthread.c220 EVUTIL_ASSERT(lock->count == 0); in debug_lock_free()
221 EVUTIL_ASSERT(locktype == lock->locktype); in debug_lock_free()
222 EVUTIL_ASSERT(DEBUG_LOCK_SIG == lock->signature); in debug_lock_free()
236 EVUTIL_ASSERT(DEBUG_LOCK_SIG == lock->signature); in evthread_debug_lock_mark_locked()
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()
255 EVUTIL_ASSERT(mode & (EVTHREAD_READ|EVTHREAD_WRITE)); in debug_lock_lock()
257 EVUTIL_ASSERT((mode & (EVTHREAD_READ|EVTHREAD_WRITE)) == 0); in debug_lock_lock()
269 EVUTIL_ASSERT(DEBUG_LOCK_SIG == lock->signature); in evthread_debug_lock_mark_unlocked()
271 EVUTIL_ASSERT(mode & (EVTHREAD_READ|EVTHREAD_WRITE)); in evthread_debug_lock_mark_unlocked()
[all …]
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);
757 EVUTIL_ASSERT(changelist->changes_size >= changelist->n_changes);
761 EVUTIL_ASSERT(c->fd >= 0);
763 EVUTIL_ASSERT(f);
[all …]
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 …]
Devrpc.c102 EVUTIL_ASSERT(r == 0); in evrpc_free()
110 EVUTIL_ASSERT(r); in evrpc_free()
114 EVUTIL_ASSERT(r); in evrpc_free()
136 EVUTIL_ASSERT(hook_type == EVRPC_INPUT || hook_type == EVRPC_OUTPUT); in evrpc_add_hook()
140 EVUTIL_ASSERT(hook != NULL); in evrpc_add_hook()
181 EVUTIL_ASSERT(hook_type == EVRPC_INPUT || hook_type == EVRPC_OUTPUT); in evrpc_remove_hook()
271 EVUTIL_ASSERT(r == 0); in evrpc_unregister_rpc()
322 EVUTIL_ASSERT(hook_res == EVRPC_TERMINATE || in evrpc_request_cb()
345 EVUTIL_ASSERT(rpc_state); in evrpc_request_cb_closure()
385 EVUTIL_ASSERT(rpc_state != NULL); in evrpc_reqstate_free_()
[all …]
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_()
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()
Devent.c385 EVUTIL_ASSERT(flags & O_NONBLOCK); in event_debug_assert_socket_nonblocking_()
494 EVUTIL_ASSERT((evcb->evcb_flags & EVLIST_INIT)); in event_callback_to_event()
769 EVUTIL_ASSERT(rv >= 0); in event_base_stop_iocp_()
928 EVUTIL_ASSERT(TAILQ_EMPTY(&base->activequeues[i])); in event_base_free_()
930 EVUTIL_ASSERT(min_heap_empty_(&base->timeheap)); in event_base_free_()
1510 EVUTIL_ASSERT(is_common_timeout(&ctl->duration, base)); in event_base_init_common_timeout()
1554 EVUTIL_ASSERT(is_common_timeout(result, base)); in event_base_init_common_timeout()
1579 EVUTIL_ASSERT(is_same_common_timeout(&ev->ev_timeout, in event_persist_closure()
1641 EVUTIL_ASSERT(activeq != NULL); in event_process_active_single_queue()
1677 EVUTIL_ASSERT(ev != NULL); in event_process_active_single_queue()
[all …]
Dbuffer.c198 EVUTIL_ASSERT(chain->refcnt > 0); in evbuffer_chain_free()
245 EVUTIL_ASSERT(info->source != NULL); in evbuffer_chain_free()
246 EVUTIL_ASSERT(info->parent != NULL); in evbuffer_chain_free()
298 EVUTIL_ASSERT(evbuffer_chains_all_empty(*ch)); in evbuffer_free_trailing_empty_chains()
315 EVUTIL_ASSERT(buf->last_with_datap == &buf->first); in evbuffer_chain_insert()
316 EVUTIL_ASSERT(buf->first == NULL); in evbuffer_chain_insert()
342 EVUTIL_ASSERT((chain->flags & flag) == 0); in evbuffer_chain_pin_()
349 EVUTIL_ASSERT((chain->flags & flag) != 0); in evbuffer_chain_unpin_()
566 EVUTIL_ASSERT(buffer->refcnt > 0); in evbuffer_decref_and_unlock_()
688 EVUTIL_ASSERT(size<0 || (size_t)vec[0].iov_len >= (size_t)size); in evbuffer_reserve_space()
[all …]
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()
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_()
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()
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()
Devdns.c133 EVUTIL_ASSERT((req)->handle && (req)->handle->current_req == (req))
551 EVUTIL_ASSERT(req->ns->requests_inflight > 0); in request_swap_ns()
580 EVUTIL_ASSERT(base->global_good_nameservers >= 0); in nameserver_failed()
689 EVUTIL_ASSERT(req->handle->current_req == req); in request_finished()
753 EVUTIL_ASSERT(base->req_waiting_head); in evdns_requests_pump_waiting_queue()
823 EVUTIL_ASSERT(0); in reply_run_callback()
1061 EVUTIL_ASSERT(req->base == base); in reply_parse()
1376 EVUTIL_ASSERT(base->global_good_nameservers == 0); in nameserver_pick()
1466 EVUTIL_ASSERT(req != port->pending_replies); in server_port_flush()
2138 EVUTIL_ASSERT(port); in server_port_free()
[all …]
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()
1203 EVUTIL_ASSERT(evcon->state == EVCON_WRITING); in evhttp_write_connectioncb()
1287 EVUTIL_ASSERT(evcon->state == EVCON_DISCONNECTED); in evhttp_connection_set_local_address()
1298 EVUTIL_ASSERT(evcon->state == EVCON_DISCONNECTED); in evhttp_connection_set_local_port()
1311 EVUTIL_ASSERT(req->kind == EVHTTP_REQUEST); in evhttp_request_dispatch()
1317 EVUTIL_ASSERT(evcon->state == EVCON_IDLE); in evhttp_request_dispatch()
1363 EVUTIL_ASSERT(!err && "setfd"); in evhttp_connection_reset_()
1368 EVUTIL_ASSERT(!err && "drain output"); in evhttp_connection_reset_()
[all …]
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()
Dselect.c257 EVUTIL_ASSERT((events & EV_SIGNAL) == 0); in select_add()
304 EVUTIL_ASSERT((events & EV_SIGNAL) == 0); in select_del()
Devthread-internal.h132 EVUTIL_ASSERT(evthread_is_debug_lock_held_(lock)); \
255 EVUTIL_ASSERT(evthread_is_debug_lock_held_(lock)); \
Dsignal.c285 EVUTIL_ASSERT(evsignal >= 0 && evsignal < NSIG); in evsig_add()
365 EVUTIL_ASSERT(evsignal >= 0 && evsignal < NSIG); in evsig_del()
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()
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()
Depoll.c280 EVUTIL_ASSERT(op == 0); in epoll_apply_one_change()
479 EVUTIL_ASSERT(res <= epollop->nevents); in epoll_dispatch()
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()
Dbufferevent_pair.c62 EVUTIL_ASSERT(BEV_IS_PAIR(&bev_p->bev.bev)); in upcast()
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()
Dlistener.c429 EVUTIL_ASSERT(freed); in listener_read_cb()
620 EVUTIL_ASSERT(ext->GetAcceptExSockaddrs); in accepted_socket_invoke_user_cb()

12