diff options
| author | Benny Prijono <bennylp@teluu.com> | 2005-11-01 21:46:17 +0000 |
|---|---|---|
| committer | Benny Prijono <bennylp@teluu.com> | 2005-11-01 21:46:17 +0000 |
| commit | 2659094addd65fee3d26bc2fe21f4b42d825bdfb (patch) | |
| tree | 373c7a58cefb6d06b9bdcb842628c3cfec2fafbe /pjlib/src/pj/os_core_win32.c | |
| parent | 7520eb2058c85109a0b137b0d0f0487a149c9a0c (diff) | |
Changed atomic interface and fixed bugs in echo test client
git-svn-id: http://svn.pjsip.org/repos/pjproject/main@5 74dad513-b988-da41-8d7b-12977e46ad98
Diffstat (limited to 'pjlib/src/pj/os_core_win32.c')
| -rw-r--r-- | pjlib/src/pj/os_core_win32.c | 26 |
1 files changed, 16 insertions, 10 deletions
diff --git a/pjlib/src/pj/os_core_win32.c b/pjlib/src/pj/os_core_win32.c index ad69799d..6ba87493 100644 --- a/pjlib/src/pj/os_core_win32.c +++ b/pjlib/src/pj/os_core_win32.c @@ -495,18 +495,17 @@ PJ_DEF(pj_status_t) pj_atomic_destroy( pj_atomic_t *var ) /* * pj_atomic_set() */ -PJ_DEF(long) pj_atomic_set(pj_atomic_t *atomic_var, long value) +PJ_DEF(void) pj_atomic_set( pj_atomic_t *atomic_var, pj_atomic_value_t value) { PJ_CHECK_STACK(); - PJ_ASSERT_RETURN(atomic_var, 0); - return InterlockedExchange(&atomic_var->value, value); + InterlockedExchange(&atomic_var->value, value); } /* * pj_atomic_get() */ -PJ_DEF(long) pj_atomic_get(pj_atomic_t *atomic_var) +PJ_DEF(pj_atomic_value_t) pj_atomic_get(pj_atomic_t *atomic_var) { PJ_CHECK_STACK(); PJ_ASSERT_RETURN(atomic_var, 0); @@ -517,13 +516,12 @@ PJ_DEF(long) pj_atomic_get(pj_atomic_t *atomic_var) /* * pj_atomic_inc() */ -PJ_DEF(long) pj_atomic_inc(pj_atomic_t *atomic_var) +PJ_DEF(void) pj_atomic_inc(pj_atomic_t *atomic_var) { PJ_CHECK_STACK(); - PJ_ASSERT_RETURN(atomic_var, 0); #if defined(PJ_WIN32_WINNT) && PJ_WIN32_WINNT >= 0x0400 - return InterlockedIncrement(&atomic_var->value); + InterlockedIncrement(&atomic_var->value); #else # error Fix Me #endif @@ -532,19 +530,27 @@ PJ_DEF(long) pj_atomic_inc(pj_atomic_t *atomic_var) /* * pj_atomic_dec() */ -PJ_DEF(long) pj_atomic_dec(pj_atomic_t *atomic_var) +PJ_DEF(void) pj_atomic_dec(pj_atomic_t *atomic_var) { PJ_CHECK_STACK(); - PJ_ASSERT_RETURN(atomic_var, 0); #if defined(PJ_WIN32_WINNT) && PJ_WIN32_WINNT >= 0x0400 - return InterlockedDecrement(&atomic_var->value); + InterlockedDecrement(&atomic_var->value); #else # error Fix me #endif } +/* + * pj_atomic_add() + */ +PJ_DEF(void) pj_atomic_add( pj_atomic_t *atomic_var, + pj_atomic_value_t value ) +{ + InterlockedExchangeAdd( &atomic_var->value, value ); +} + /////////////////////////////////////////////////////////////////////////////// /* * pj_thread_local_alloc() |