diff options
Diffstat (limited to 'libguile/ports.c')
-rw-r--r-- | libguile/ports.c | 13 |
1 files changed, 12 insertions, 1 deletions
diff --git a/libguile/ports.c b/libguile/ports.c index 61bd57739..f4efce777 100644 --- a/libguile/ports.c +++ b/libguile/ports.c @@ -348,8 +348,15 @@ SCM_DEFINE (scm_i_port_property, "%port-property", 2, 0, 0, "Return the property of @var{port} associated with @var{key}.") #define FUNC_NAME s_scm_i_port_property { + scm_i_pthread_mutex_t *lock; + SCM result; + SCM_VALIDATE_OPPORT (1, port); - return scm_assq_ref (SCM_PORT_GET_INTERNAL (port)->alist, key); + scm_c_lock_port (port, &lock); + result = scm_assq_ref (SCM_PORT_GET_INTERNAL (port)->alist, key); + if (lock) + scm_i_pthread_mutex_unlock (lock); + return result; } #undef FUNC_NAME @@ -358,11 +365,15 @@ SCM_DEFINE (scm_i_set_port_property_x, "%set-port-property!", 3, 0, 0, "Set the property of @var{port} associated with @var{key} to @var{value}.") #define FUNC_NAME s_scm_i_set_port_property_x { + scm_i_pthread_mutex_t *lock; scm_t_port_internal *pti; SCM_VALIDATE_OPPORT (1, port); + scm_c_lock_port (port, &lock); pti = SCM_PORT_GET_INTERNAL (port); pti->alist = scm_assq_set_x (pti->alist, key, value); + if (lock) + scm_i_pthread_mutex_unlock (lock); return SCM_UNSPECIFIED; } #undef FUNC_NAME |