@@ -243,9 +243,7 @@ class Connection : public ObjectWrap {
243243 connecting_ = false ;
244244
245245 TRACE (" Initializing ev watchers" );
246- // ev_init(&read_watcher_, io_event);
247246 read_watcher_.data = this ;
248- // ev_init(&write_watcher_, io_event);
249247 write_watcher_.data = this ;
250248 }
251249
@@ -353,14 +351,10 @@ class Connection : public ObjectWrap {
353351
354352 PQsetNoticeProcessor (connection_, NoticeReceiver, this );
355353
354+ TRACE (" Setting watchers to socket" );
356355 uv_poll_init (uv_default_loop (), &read_watcher_, fd);
357356 uv_poll_init (uv_default_loop (), &write_watcher_, fd);
358357
359- TRACE (" Setting watchers to socket" );
360- // uv_poll_start(uv_poll_t* handle, int events, uv_poll_cb cb)
361- // ev_io_set(&read_watcher_, fd, EV_READ);
362- // ev_io_set(&write_watcher_, fd, EV_WRITE);
363-
364358 connecting_ = true ;
365359 StartWrite ();
366360
@@ -399,7 +393,7 @@ class Connection : public ObjectWrap {
399393 TRACE (" revents & EV_READ" );
400394 if (PQconsumeInput (connection_) == 0 ) {
401395 End ();
402- EmitLastError ();
396+ EmitLastError ();
403397 LOG (" Something happened, consume input is 0" );
404398 return ;
405399 }
@@ -623,28 +617,24 @@ class Connection : public ObjectWrap {
623617 void StopWrite ()
624618 {
625619 TRACE (" Stoping write watcher" );
626- // ev_io_stop(EV_DEFAULT_ &write_watcher_);
627620 uv_poll_stop (&write_watcher_);
628621 }
629622
630623 void StartWrite ()
631624 {
632625 TRACE (" Starting write watcher" );
633626 uv_poll_start (&write_watcher_, UV_WRITABLE, io_event);
634- // ev_io_start(EV_DEFAULT_ &write_watcher_);
635627 }
636628
637629 void StopRead ()
638630 {
639631 TRACE (" Stoping read watcher" );
640- // ev_io_stop(EV_DEFAULT_ &read_watcher_);
641632 uv_poll_stop (&read_watcher_);
642633 }
643634
644635 void StartRead ()
645636 {
646637 TRACE (" Starting read watcher" );
647- // ev_io_start(EV_DEFAULT_ &read_watcher_);
648638 uv_poll_start (&read_watcher_, UV_READABLE, io_event);
649639 }
650640 // Converts a v8 array to an array of cstrings
0 commit comments