remove unnecessary comments
This commit is contained in:
parent
4d482e451b
commit
d7b9f64b02
@ -243,9 +243,7 @@ public:
|
|||||||
connecting_ = false;
|
connecting_ = false;
|
||||||
|
|
||||||
TRACE("Initializing ev watchers");
|
TRACE("Initializing ev watchers");
|
||||||
//ev_init(&read_watcher_, io_event);
|
|
||||||
read_watcher_.data = this;
|
read_watcher_.data = this;
|
||||||
//ev_init(&write_watcher_, io_event);
|
|
||||||
write_watcher_.data = this;
|
write_watcher_.data = this;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -353,14 +351,10 @@ protected:
|
|||||||
|
|
||||||
PQsetNoticeProcessor(connection_, NoticeReceiver, this);
|
PQsetNoticeProcessor(connection_, NoticeReceiver, this);
|
||||||
|
|
||||||
|
TRACE("Setting watchers to socket");
|
||||||
uv_poll_init(uv_default_loop(), &read_watcher_, fd);
|
uv_poll_init(uv_default_loop(), &read_watcher_, fd);
|
||||||
uv_poll_init(uv_default_loop(), &write_watcher_, fd);
|
uv_poll_init(uv_default_loop(), &write_watcher_, fd);
|
||||||
|
|
||||||
TRACE("Setting watchers to socket");
|
|
||||||
//uv_poll_start(uv_poll_t* handle, int events, uv_poll_cb cb)
|
|
||||||
//ev_io_set(&read_watcher_, fd, EV_READ);
|
|
||||||
//ev_io_set(&write_watcher_, fd, EV_WRITE);
|
|
||||||
|
|
||||||
connecting_ = true;
|
connecting_ = true;
|
||||||
StartWrite();
|
StartWrite();
|
||||||
|
|
||||||
@ -399,7 +393,7 @@ protected:
|
|||||||
TRACE("revents & EV_READ");
|
TRACE("revents & EV_READ");
|
||||||
if(PQconsumeInput(connection_) == 0) {
|
if(PQconsumeInput(connection_) == 0) {
|
||||||
End();
|
End();
|
||||||
EmitLastError();
|
EmitLastError();
|
||||||
LOG("Something happened, consume input is 0");
|
LOG("Something happened, consume input is 0");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@ -623,7 +617,6 @@ private:
|
|||||||
void StopWrite()
|
void StopWrite()
|
||||||
{
|
{
|
||||||
TRACE("Stoping write watcher");
|
TRACE("Stoping write watcher");
|
||||||
//ev_io_stop(EV_DEFAULT_ &write_watcher_);
|
|
||||||
uv_poll_stop(&write_watcher_);
|
uv_poll_stop(&write_watcher_);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -631,20 +624,17 @@ private:
|
|||||||
{
|
{
|
||||||
TRACE("Starting write watcher");
|
TRACE("Starting write watcher");
|
||||||
uv_poll_start(&write_watcher_, UV_WRITABLE, io_event);
|
uv_poll_start(&write_watcher_, UV_WRITABLE, io_event);
|
||||||
//ev_io_start(EV_DEFAULT_ &write_watcher_);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void StopRead()
|
void StopRead()
|
||||||
{
|
{
|
||||||
TRACE("Stoping read watcher");
|
TRACE("Stoping read watcher");
|
||||||
//ev_io_stop(EV_DEFAULT_ &read_watcher_);
|
|
||||||
uv_poll_stop(&read_watcher_);
|
uv_poll_stop(&read_watcher_);
|
||||||
}
|
}
|
||||||
|
|
||||||
void StartRead()
|
void StartRead()
|
||||||
{
|
{
|
||||||
TRACE("Starting read watcher");
|
TRACE("Starting read watcher");
|
||||||
//ev_io_start(EV_DEFAULT_ &read_watcher_);
|
|
||||||
uv_poll_start(&read_watcher_, UV_READABLE, io_event);
|
uv_poll_start(&read_watcher_, UV_READABLE, io_event);
|
||||||
}
|
}
|
||||||
//Converts a v8 array to an array of cstrings
|
//Converts a v8 array to an array of cstrings
|
||||||
|
Loading…
Reference in New Issue
Block a user