src/xcalls/x_pthread_mutex_unlock.c

Go to the documentation of this file.

#include <pthread.h>
#include <core/tx.h>
#include <core/config.h>
#include <core/txdesc.h>
#include <misc/debug.h>
#include <misc/errno.h>
#include <xcalls/xcalls.h>

typedef struct x_commit_args_s x_commit_args_t;

struct x_commit_args_s {
        pthread_mutex_t *mutex;
};

static
void
x_pthread_mutex_unlock_commit(void *args, int *result)
{
        x_commit_args_t *args_commit = (x_commit_args_t *) args;
        int             local_result = 0;
        int             ret;

        if ((ret = pthread_mutex_unlock(args_commit->mutex)) != 0) {
                local_result = ret;
        }
        if (result) {
                *result = local_result;
        }       
}


int
XCALL_DEF(x_pthread_mutex_unlock)(pthread_mutex_t *mutex, int *result) 
{
        txc_tx_t        *txd;
        int             ret;
        x_commit_args_t *args_commit; 
        int             local_result = 0;

        txd = txc_tx_get_txd();

        switch(txc_tx_get_xactstate(txd)) {
                case TXC_XACTSTATE_TRANSACTIONAL_RETRYABLE:
                        args_commit = (x_commit_args_t *)
                                    txc_buffer_linear_malloc(txd->buffer_linear, 
                                                             sizeof(x_commit_args_t));
                        if (args_commit == NULL) {
                                TXC_INTERNALERROR("Allocation failed. Linear buffer out of space.\n");
                        }
                        args_commit->mutex = mutex;
                        txc_tx_register_commit_action(txd, x_pthread_mutex_unlock_commit, 
                                                      (void *) args_commit, result,
                                                      TXC_TX_REGULAR_COMMIT_ACTION_ORDER);
                        ret = 0;
                        break;
                case TXC_XACTSTATE_TRANSACTIONAL_IRREVOCABLE:
                case TXC_XACTSTATE_NONTRANSACTIONAL:
                        if ((ret = pthread_mutex_unlock(mutex)) != 0) { 
                                local_result = ret;
                                goto done;
                        }
        }
done:
        if (result) {
                *result = local_result;
        }
        return ret;
}

---