Home
last modified time | relevance | path

Searched refs:lock (Results 1 – 24 of 24) sorted by relevance

/libevent-2.1.12/
H A Devthread.c118 target->lock == cbs->lock && in evthread_set_lock_callbacks()
224 original_lock_fns_.free(lock->lock, in debug_lock_free()
227 lock->lock = NULL; in debug_lock_free()
259 res = original_lock_fns_.lock(mode, lock->lock); in debug_lock_lock()
292 res = original_lock_fns_.unlock(mode, lock->lock); in debug_lock_unlock()
362 return lock->lock; in evthread_debug_get_real_lock_()
393 lock->lock = lock_; in evthread_setup_global_lock_()
408 if (!lock->lock) { in evthread_setup_global_lock_()
409 lock->lock = original_lock_fns_.alloc( in evthread_setup_global_lock_()
411 if (!lock->lock) { in evthread_setup_global_lock_()
[all …]
H A Devthread-internal.h96 evthread_lock_fns_.lock(mode, lockvar); \
129 #define EVLOCK_ASSERT_LOCKED(lock) \ argument
140 EVLOCK_TRY_LOCK_(void *lock) in EVLOCK_TRY_LOCK_() argument
142 if (lock && evthread_lock_fns_.lock) { in EVLOCK_TRY_LOCK_()
143 int r = evthread_lock_fns_.lock(EVTHREAD_TRY, lock); in EVLOCK_TRY_LOCK_()
174 #define EVTHREAD_COND_WAIT(cond, lock) \ argument
183 (evthread_lock_fns_.lock != NULL)
252 #define EVLOCK_ASSERT_LOCKED(lock) \ argument
263 EVLOCK_TRY_LOCK_(void *lock) in EVLOCK_TRY_LOCK_() argument
265 if (lock) { in EVLOCK_TRY_LOCK_()
[all …]
H A Devthread_win32.c54 if (!lock) in evthread_win32_lock_create()
57 mm_free(lock); in evthread_win32_lock_create()
60 return lock; in evthread_win32_lock_create()
66 CRITICAL_SECTION *lock = lock_; in evthread_win32_lock_free() local
67 DeleteCriticalSection(lock); in evthread_win32_lock_free()
68 mm_free(lock); in evthread_win32_lock_free()
78 EnterCriticalSection(lock); in evthread_win32_lock()
87 LeaveCriticalSection(lock); in evthread_win32_unlock()
183 CRITICAL_SECTION lock; member
249 LeaveCriticalSection(lock); in evthread_win32_cond_wait()
[all …]
H A Devthread_pthread.c49 if (!lock) in evthread_posix_lock_alloc()
54 mm_free(lock); in evthread_posix_lock_alloc()
57 return lock; in evthread_posix_lock_alloc()
63 pthread_mutex_t *lock = lock_; in evthread_posix_lock_free() local
64 pthread_mutex_destroy(lock); in evthread_posix_lock_free()
65 mm_free(lock); in evthread_posix_lock_free()
71 pthread_mutex_t *lock = lock_; in evthread_posix_lock() local
75 return pthread_mutex_lock(lock); in evthread_posix_lock()
81 pthread_mutex_t *lock = lock_; in evthread_posix_unlock() local
82 return pthread_mutex_unlock(lock); in evthread_posix_unlock()
[all …]
H A Devbuffer-internal.h113 void *lock; member
236 void *lock; /**< lock prevent concurrent access to refcnt */ member
283 EVLOCK_ASSERT_LOCKED((buffer)->lock)
287 EVLOCK_LOCK((buffer)->lock, 0); \
291 EVLOCK_UNLOCK((buffer)->lock, 0); \
295 EVLOCK_LOCK2((buffer1)->lock, (buffer2)->lock, 0, 0); \
299 EVLOCK_UNLOCK2((buffer1)->lock, (buffer2)->lock, 0, 0); \
H A Devent_iocp.c79 EnterCriticalSection(&port->lock); in loop()
84 LeaveCriticalSection(&port->lock); in loop()
87 LeaveCriticalSection(&port->lock); in loop()
95 EnterCriticalSection(&port->lock); in loop()
98 LeaveCriticalSection(&port->lock); in loop()
212 InitializeCriticalSectionAndSpinCount(&port->lock, 1000); in event_iocp_port_launch_()
229 DeleteCriticalSection(&port->lock); in event_iocp_port_unlock_and_free_()
255 EnterCriticalSection(&port->lock); in event_iocp_shutdown_()
257 LeaveCriticalSection(&port->lock); in event_iocp_shutdown_()
264 EnterCriticalSection(&port->lock); in event_iocp_shutdown_()
[all …]
H A Dlistener.c78 void *lock; member
460 CRITICAL_SECTION lock; member
537 LeaveCriticalSection(&as->lock); in free_and_unlock_accepting_socket()
538 DeleteCriticalSection(&as->lock); in free_and_unlock_accepting_socket()
623 EnterCriticalSection(&as->lock); in accepted_socket_invoke_user_cb()
653 LeaveCriticalSection(&as->lock); in accepted_socket_invoke_user_cb()
667 EnterCriticalSection(&as->lock); in accepted_socket_invoke_user_cb()
669 LeaveCriticalSection(&as->lock); in accepted_socket_invoke_user_cb()
679 EnterCriticalSection(&as->lock); in accepted_socket_cb()
685 LeaveCriticalSection(&as->lock); in accepted_socket_cb()
[all …]
H A Dbufferevent.c694 if (d->lock != r->lock)
778 EVTHREAD_FREE_LOCK(bufev_private->lock, in bufferevent_finalize_cb_()
836 if (BEV_UPCAST(bufev)->lock) in bufferevent_enable_locking_()
840 if (!lock && underlying && BEV_UPCAST(underlying)->lock) { in bufferevent_enable_locking_()
841 lock = BEV_UPCAST(underlying)->lock; in bufferevent_enable_locking_()
842 BEV_UPCAST(bufev)->lock = lock; in bufferevent_enable_locking_()
844 } else if (!lock) { in bufferevent_enable_locking_()
846 if (!lock) in bufferevent_enable_locking_()
848 BEV_UPCAST(bufev)->lock = lock; in bufferevent_enable_locking_()
851 BEV_UPCAST(bufev)->lock = lock; in bufferevent_enable_locking_()
[all …]
H A Dbufferevent-internal.h126 void *lock; member
207 void *lock; member
366 int bufferevent_enable_locking_(struct bufferevent *bufev, void *lock);
487 EVLOCK_LOCK(locking->lock, 0); \
493 EVLOCK_UNLOCK(locking->lock, 0); \
H A Dbufferevent_ratelim.c185 #define LOCK_GROUP(g) EVLOCK_LOCK((g)->lock, 0)
186 #define UNLOCK_GROUP(g) EVLOCK_UNLOCK((g)->lock, 0)
364 if (EVLOCK_TRY_LOCK_(bev->lock)) { in bev_group_suspend_reading_()
367 EVLOCK_UNLOCK(bev->lock, 0); in bev_group_suspend_reading_()
382 if (EVLOCK_TRY_LOCK_(bev->lock)) { in bev_group_suspend_writing_()
385 EVLOCK_UNLOCK(bev->lock, 0); in bev_group_suspend_writing_()
495 if (EVLOCK_TRY_LOCK_(bev->lock)) { in bev_group_unsuspend_reading_()
498 EVLOCK_UNLOCK(bev->lock, 0); in bev_group_unsuspend_reading_()
514 if (EVLOCK_TRY_LOCK_(bev->lock)) { in bev_group_unsuspend_writing_()
517 EVLOCK_UNLOCK(bev->lock, 0); in bev_group_unsuspend_writing_()
[all …]
H A Dbuffer.c429 if (buf->lock) in evbuffer_enable_locking()
432 if (!lock) { in evbuffer_enable_locking()
434 if (!lock) in evbuffer_enable_locking()
436 buf->lock = lock; in evbuffer_enable_locking()
439 buf->lock = lock; in evbuffer_enable_locking()
3158 EVLOCK_LOCK(seg->lock, 0); in evbuffer_file_segment_free()
3160 EVLOCK_UNLOCK(seg->lock, 0); in evbuffer_file_segment_free()
3202 EVLOCK_LOCK(seg->lock, 0); in evbuffer_add_file_segment()
3214 EVLOCK_UNLOCK(seg->lock, 0); in evbuffer_add_file_segment()
3277 EVLOCK_LOCK(seg->lock, 0); in evbuffer_add_file_segment()
[all …]
H A Diocp-internal.h79 CRITICAL_SECTION lock; member
H A Devdns.c258 void *lock; member
363 void *lock; member
429 EVLOCK_LOCK((base)->lock, 0)
431 EVLOCK_UNLOCK((base)->lock, 0)
433 EVLOCK_ASSERT_LOCKED((base)->lock)
1749 EVTHREAD_ALLOC_LOCK(port->lock, EVTHREAD_LOCKTYPE_RECURSIVE); in evdns_add_server_port_with_base()
2092 int i, rc=1, lock=0; in server_request_free() local
2101 lock=1; in server_request_free()
2128 if (lock) in server_request_free()
2147 EVTHREAD_FREE_LOCK(port->lock, EVTHREAD_LOCKTYPE_RECURSIVE); in server_port_free()
[all …]
H A Dbufferevent_pair.c135 bufferevent_enable_locking_(downcast(bufev2), bufev1->bev.lock); in bufferevent_pair_new()
H A DChangeLog155 o evdns: fix lock/unlock mismatch in evdns_close_server_port() (54103883 zhuizhuhaomeng)
436 o event_free_debug_globals_locks(): disable lock debugging (e5c87d1 Azat Khuzhin)
441 …o evthread: fix evthread_setup_global_lock_() for debug-lock with a real-lock case (e4556fc Azat K…
461 o Fix lock leak in be_pair_flush() if flush type is BEV_NORMAL (f45d39d Bill Vaughan)
467 o be_pair: release shared lock with the latest of bufferevent_pair (92a359e Azat Khuzhin)
594 o be_pair/regress: cover use of shared lock (lock/unlock/free) (a558fcd Azat Khuzhin)
623 o evthread: add evthread_get_{lock,condition}_callbacks() helpers (c0b34f6 Azat Khuzhin)
1042 o Missed lock acquire/release in event_base_cancel_single_callback_()
1163 Bugfixes (resource leaks/lock errors on error, from 2.0)
1403 BUGFIXES (resource leaks/lock errors on error)
[all …]
H A Dwhatsnew-2.1.txt192 But now suppose that the data structure is protected by a lock, and we
196 lock(connection);
203 another thread? Let's say that the other thread gets the lock
206 the lock on the connection. Since each threads is waiting for the
H A Dwhatsnew-2.0.txt234 lock. You can prevent a single event_base from being built with a lock
236 event_config. If an event_base is created with a lock, it is safe to call
H A DChangeLog-2.0584 o On windows, make lock/thread function tables static (5de2bcb)
624 o Make defer-internal.h use lock macros, not direct calls to lock fns (5218d2a)
848 o Remove redundant checks for lock!=NULL before calling EVLOCK_LOCK (50ec59f)
869 o Improved optional lock debugging. (0cd3bb9)
906 o Fix two use-after-free bugs in unit tests spoted by lock debugging (d84d838)
908 o Fix an evdns lock violation. (2df1f82 Zhuang Yuyao)
911 o Fix regress_iocp.c usage of old lock allocation macros. (31687b4 unknown)
988 o New EVTHREAD_TRY_LOCK function to try to grab a lock. (689fc09)
/libevent-2.1.12/test/
H A Dregress_thread.c70 void *lock; member
78 EVLOCK_LOCK(cw->lock, 0); in wake_all_timeout()
80 EVLOCK_UNLOCK(cw->lock, 0); in wake_all_timeout()
88 EVLOCK_LOCK(cw->lock, 0); in wake_one_timeout()
90 EVLOCK_UNLOCK(cw->lock, 0); in wake_one_timeout()
106 EVTHREAD_ALLOC_LOCK(cw.lock, 0); in basic_thread()
108 assert(cw.lock); in basic_thread()
118 EVLOCK_LOCK(cw.lock, 0); in basic_thread()
124 EVLOCK_UNLOCK(cw.lock, 0); in basic_thread()
137 EVTHREAD_FREE_LOCK(cw.lock, 0); in basic_thread()
[all …]
H A Dregress_iocp.c115 void *lock; member
127 EVLOCK_LOCK(d_o->lock, 0); in dummy_cb()
133 EVLOCK_UNLOCK(d_o->lock, 0); in dummy_cb()
143 EVLOCK_LOCK(o->lock, 0); in pair_is_in()
150 EVLOCK_UNLOCK(o->lock, 0); in pair_is_in()
164 EVTHREAD_ALLOC_LOCK(o1.lock, EVTHREAD_LOCKTYPE_RECURSIVE); in test_iocp_port()
165 EVTHREAD_ALLOC_LOCK(o2.lock, EVTHREAD_LOCKTYPE_RECURSIVE); in test_iocp_port()
167 tt_assert(o1.lock); in test_iocp_port()
168 tt_assert(o2.lock); in test_iocp_port()
206 EVTHREAD_FREE_LOCK(o1.lock, EVTHREAD_LOCKTYPE_RECURSIVE); in test_iocp_port()
[all …]
H A Dregress_bufferevent.c226 void *lock; member
248 if (lock->lock == lock_) in lu_find()
249 return lock; in lu_find()
256 void *lock; in trace_lock_alloc() local
262 return lock; in trace_lock_alloc()
267 if (!lock || lock->status == FREE || lock->locked) { in trace_lock_free()
270 lock->status = FREE; in trace_lock_free()
277 if (!lock || lock->status == FREE) { in trace_lock_lock()
281 ++lock->locked; in trace_lock_lock()
288 if (!lock || lock->status == FREE || !lock->locked) { in trace_lock_unlock()
[all …]
H A Dregress_dns.c2210 void *lock; member
2234 EVLOCK_LOCK(rp->lock, 0); in race_busywait_run()
2237 EVLOCK_UNLOCK(rp->lock, 0); in race_busywait_run()
2249 EVLOCK_LOCK(rp->lock, 0); in race_gai_cb()
2251 EVLOCK_UNLOCK(rp->lock, 0); in race_gai_cb()
2293 EVTHREAD_ALLOC_LOCK(rp.lock, 0); in getaddrinfo_race_gotresolve_test()
2296 tt_assert(rp.lock); in getaddrinfo_race_gotresolve_test()
2310 EVLOCK_LOCK(rp.lock, 0); in getaddrinfo_race_gotresolve_test()
2336 EVLOCK_UNLOCK(rp.lock, 0); in getaddrinfo_race_gotresolve_test()
2345 EVLOCK_UNLOCK(rp.lock, 0); in getaddrinfo_race_gotresolve_test()
[all …]
/libevent-2.1.12/include/event2/
H A Dthread.h112 void (*free)(void *lock, unsigned locktype);
115 int (*lock)(unsigned mode, void *lock); member
118 int (*unlock)(unsigned mode, void *lock);
168 int (*wait_condition)(void *cond, void *lock,
H A Dbuffer.h174 int evbuffer_enable_locking(struct evbuffer *buf, void *lock);