|
@ -55,10 +55,12 @@ private: |
|
|
|
|
|
|
|
|
static void on_read (oi_socket *s, const void *buf, size_t len) { |
|
|
static void on_read (oi_socket *s, const void *buf, size_t len) { |
|
|
Connection *connection = static_cast<Connection*> (s->data); |
|
|
Connection *connection = static_cast<Connection*> (s->data); |
|
|
|
|
|
v8::V8::ResumeProfiler(); |
|
|
if (len == 0) |
|
|
if (len == 0) |
|
|
connection->OnEOF(); |
|
|
connection->OnEOF(); |
|
|
else |
|
|
else |
|
|
connection->OnReceive(buf, len); |
|
|
connection->OnReceive(buf, len); |
|
|
|
|
|
v8::V8::PauseProfiler(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
static void on_drain (oi_socket *s) { |
|
|
static void on_drain (oi_socket *s) { |
|
|