blob: cd20e7908c3d45743098cdae9a647db2fab0d24c (
plain)
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
#include "Node.h"
namespace uS {
// this should be Node
void NodeData::asyncCallback(Async *async)
{
NodeData *nodeData = (NodeData *) async->getData();
nodeData->asyncMutex->lock();
for (Poll *p : nodeData->transferQueue) {
Socket *s = (Socket *) p;
TransferData *transferData = (TransferData *) s->getUserData();
s->reInit(nodeData->loop, transferData->fd);
s->setCb(transferData->pollCb);
s->start(nodeData->loop, s, s->setPoll(transferData->pollEvents));
s->nodeData = transferData->destination;
s->setUserData(transferData->userData);
auto *transferCb = transferData->transferCb;
delete transferData;
transferCb(s);
}
for (Poll *p : nodeData->changePollQueue) {
Socket *s = (Socket *) p;
s->change(s->nodeData->loop, s, s->getPoll());
}
nodeData->changePollQueue.clear();
nodeData->transferQueue.clear();
nodeData->asyncMutex->unlock();
}
Node::Node(int recvLength, int prePadding, int postPadding, bool useDefaultLoop) {
nodeData = new NodeData;
nodeData->recvBufferMemoryBlock = new char[recvLength];
nodeData->recvBuffer = nodeData->recvBufferMemoryBlock + prePadding;
nodeData->recvLength = recvLength - prePadding - postPadding;
nodeData->tid = pthread_self();
loop = Loop::createLoop(useDefaultLoop);
// each node has a context
nodeData->netContext = new Context();
nodeData->loop = loop;
nodeData->asyncMutex = &asyncMutex;
int indices = NodeData::getMemoryBlockIndex(NodeData::preAllocMaxSize) + 1;
nodeData->preAlloc = new char*[indices];
for (int i = 0; i < indices; i++) {
nodeData->preAlloc[i] = nullptr;
}
nodeData->clientContext = SSL_CTX_new(SSLv23_client_method());
SSL_CTX_set_options(nodeData->clientContext, SSL_OP_NO_SSLv3);
}
void Node::run() {
nodeData->tid = pthread_self();
loop->run();
}
Node::~Node() {
delete [] nodeData->recvBufferMemoryBlock;
SSL_CTX_free(nodeData->clientContext);
int indices = NodeData::getMemoryBlockIndex(NodeData::preAllocMaxSize) + 1;
for (int i = 0; i < indices; i++) {
if (nodeData->preAlloc[i]) {
delete [] nodeData->preAlloc[i];
}
}
delete [] nodeData->preAlloc;
delete nodeData->netContext;
delete nodeData;
loop->destroy();
}
}
|
