forked from nodejs/node
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathreq_wrap.h
49 lines (37 loc) · 1.07 KB
/
req_wrap.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
#ifndef SRC_REQ_WRAP_H_
#define SRC_REQ_WRAP_H_
#include "async-wrap.h"
#include "async-wrap-inl.h"
#include "env.h"
#include "env-inl.h"
#include "queue.h"
#include "util.h"
namespace node {
template <typename T>
class ReqWrap : public AsyncWrap {
public:
ReqWrap(Environment* env,
v8::Handle<v8::Object> object,
AsyncWrap::ProviderType provider)
: AsyncWrap(env, object, provider) {
if (env->in_domain())
object->Set(env->domain_string(), env->domain_array()->Get(0));
QUEUE_INSERT_TAIL(env->req_wrap_queue(), &req_wrap_queue_);
}
~ReqWrap() override {
QUEUE_REMOVE(&req_wrap_queue_);
// Assert that someone has called Dispatched()
CHECK_EQ(req_.data, this);
CHECK_EQ(false, persistent().IsEmpty());
persistent().Reset();
}
// Call this after the req has been dispatched.
void Dispatched() {
req_.data = this;
}
// TODO(bnoordhuis) Make these private.
QUEUE req_wrap_queue_;
T req_; // *must* be last, GetActiveRequests() in node.cc depends on it
};
} // namespace node
#endif // SRC_REQ_WRAP_H_