Skip to content

workers: initial implementation #2133

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
petkaantonov wants to merge 10 commits into from
Closed

workers: initial implementation #2133

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
22020dc
Add lock free message queue
petkaantonov Feb 13, 2016
682fc68
add worker tests
petkaantonov Feb 13, 2016
3910d0d
Extract ContextifyScript to a header
petkaantonov Feb 13, 2016
19db86a
Cleanup when environment exits
petkaantonov Feb 13, 2016
1365538
Add RAII locking
petkaantonov Feb 13, 2016
3b54e70
Heap allocated jsstring char* conversion
petkaantonov Feb 13, 2016
1a20880
add static assert
petkaantonov Feb 13, 2016
67d7af5
Clear errors on return
petkaantonov Feb 13, 2016
2dd7f77
Protect global APIs with locks
petkaantonov Feb 13, 2016
7ece8d7
workers: initial implementation
petkaantonov Feb 13, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Add RAII locking
  • Loading branch information
@petkaantonov
petkaantonov committed Feb 13, 2016
commit 136553844043fffcd6f541f14fe0ff5d77a8657d
74 changes: 74 additions & 0 deletions src/util-inl.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
#define SRC_UTIL_INL_H_

#include "util.h"
#include "uv.h"

namespace node {

Expand Down Expand Up @@ -214,6 +215,79 @@ void SwapBytes(uint16_t* dst, const uint16_t* src, size_t buflen) {



class ScopedLock {
public:
class Mutex {
public:
explicit Mutex(uv_mutex_t* lock) : lock_(lock) {
if (lock_ != nullptr)
uv_mutex_lock(lock_);
}

void unlock() {
if (!unlocked_ && lock_ != nullptr) {
uv_mutex_unlock(lock_);
unlocked_ = true;
}
}

~Mutex() {
unlock();
}

private:
uv_mutex_t* lock_;
bool unlocked_ = false;
DISALLOW_COPY_AND_ASSIGN(Mutex);
};

class Read {
public:
explicit Read(uv_rwlock_t* lock) : lock_(lock) {
if (lock_ != nullptr)
uv_rwlock_rdlock(lock_);
}

void unlock() {
if (!unlocked_ && lock_ != nullptr) {
uv_rwlock_rdunlock(lock_);
unlocked_ = true;
}
}

~Read() {
unlock();
}
private:
uv_rwlock_t* lock_;
bool unlocked_ = false;
DISALLOW_COPY_AND_ASSIGN(Read);
};

class Write {
public:
explicit Write(uv_rwlock_t* lock) : lock_(lock) {
if (lock_ != nullptr)
uv_rwlock_wrlock(lock_);
}

void unlock() {
if (!unlocked_ && lock_ != nullptr) {
uv_rwlock_wrunlock(lock_);
unlocked_ = true;
}
}

~Write() {
unlock();
}
private:
uv_rwlock_t* lock_;
bool unlocked_ = false;
DISALLOW_COPY_AND_ASSIGN(Write);
};
};

} // namespace node

#endif // SRC_UTIL_INL_H_