Sha256: d80a7fe55fc640c2bbc6179e8939ff5960210bd774c0853f05e1b494b7a9272b

Contents?: true

Size: 1.9 KB

Versions: 9

Compression:

Stored size: 1.9 KB

Contents

/**
* hdr_thread.c
* Written by Philip Orwig and released to the public domain,
* as explained at http://creativecommons.org/publicdomain/zero/1.0/
*/

#include <stdlib.h>
#include "hdr_thread.h"

#ifndef HDR_MALLOC_INCLUDE
#define HDR_MALLOC_INCLUDE "hdr_malloc.h"
#endif

#include HDR_MALLOC_INCLUDE

struct hdr_mutex* hdr_mutex_alloc(void)
{
    return hdr_malloc(sizeof(hdr_mutex));
}

void hdr_mutex_free(struct hdr_mutex* mutex)
{
    hdr_free(mutex);
}

#if defined(_WIN32) || defined(_WIN64) || defined(__CYGWIN__)

#if !defined(WIN32_LEAN_AND_MEAN)
#define WIN32_LEAN_AND_MEAN
#endif

#include <windows.h>
#include <WinSock2.h>

int hdr_mutex_init(struct hdr_mutex* mutex)
{
    InitializeCriticalSection((CRITICAL_SECTION*)(mutex->_critical_section));
    return 0;
}

void hdr_mutex_destroy(struct hdr_mutex* mutex)
{
    DeleteCriticalSection((CRITICAL_SECTION*)(mutex->_critical_section));
}

void hdr_mutex_lock(struct hdr_mutex* mutex)
{
    EnterCriticalSection((CRITICAL_SECTION*)(mutex->_critical_section));
}

void hdr_mutex_unlock(struct hdr_mutex* mutex)
{
    LeaveCriticalSection((CRITICAL_SECTION*)(mutex->_critical_section));
}

void hdr_yield()
{
    Sleep(0);
}

int hdr_usleep(unsigned int useconds)
{
    struct timeval tv;

    tv.tv_sec = (long)useconds / 1000000;
    tv.tv_usec = useconds % 1000000;
    select(0, NULL, NULL, NULL, &tv);

    return 0;
}


#else
#include <pthread.h>
#include <unistd.h>

int hdr_mutex_init(struct hdr_mutex* mutex)
{
    return pthread_mutex_init(&mutex->_mutex, NULL);
}

void hdr_mutex_destroy(struct hdr_mutex* mutex)
{
    pthread_mutex_destroy(&mutex->_mutex);
}

void hdr_mutex_lock(struct hdr_mutex* mutex)
{
    pthread_mutex_lock(&mutex->_mutex);
}

void hdr_mutex_unlock(struct hdr_mutex* mutex)
{
    pthread_mutex_unlock(&mutex->_mutex);
}

void hdr_yield()
{
    sched_yield();
}

int hdr_usleep(unsigned int useconds)
{
    return usleep(useconds);
}


#endif

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
couchbase-3.4.5 ext/couchbase/third_party/hdr_histogram_c/src/hdr_thread.c
couchbase-3.4.4 ext/couchbase/third_party/hdr_histogram_c/src/hdr_thread.c
couchbase-3.4.3 ext/couchbase/third_party/hdr_histogram_c/src/hdr_thread.c
couchbase-3.4.2 ext/couchbase/third_party/hdr_histogram_c/src/hdr_thread.c
couchbase-3.4.1 ext/couchbase/third_party/hdr_histogram_c/src/hdr_thread.c
couchbase-3.4.0 ext/couchbase/third_party/hdr_histogram_c/src/hdr_thread.c
couchbase-3.3.0 ext/couchbase/third_party/hdr_histogram_c/src/hdr_thread.c
couchbase-3.2.0-universal-darwin-20 ext/third_party/hdr_histogram_c/src/hdr_thread.c
couchbase-3.2.0 ext/third_party/hdr_histogram_c/src/hdr_thread.c