@@ -243,9 +243,7 @@ class Connection : public ObjectWrap {
243
243
connecting_ = false ;
244
244
245
245
TRACE (" Initializing ev watchers" );
246
- // ev_init(&read_watcher_, io_event);
247
246
read_watcher_.data = this ;
248
- // ev_init(&write_watcher_, io_event);
249
247
write_watcher_.data = this ;
250
248
}
251
249
@@ -353,14 +351,10 @@ class Connection : public ObjectWrap {
353
351
354
352
PQsetNoticeProcessor (connection_, NoticeReceiver, this );
355
353
354
+ TRACE (" Setting watchers to socket" );
356
355
uv_poll_init (uv_default_loop (), &read_watcher_, fd);
357
356
uv_poll_init (uv_default_loop (), &write_watcher_, fd);
358
357
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
-
364
358
connecting_ = true ;
365
359
StartWrite ();
366
360
@@ -399,7 +393,7 @@ class Connection : public ObjectWrap {
399
393
TRACE (" revents & EV_READ" );
400
394
if (PQconsumeInput (connection_) == 0 ) {
401
395
End ();
402
- EmitLastError ();
396
+ EmitLastError ();
403
397
LOG (" Something happened, consume input is 0" );
404
398
return ;
405
399
}
@@ -623,28 +617,24 @@ class Connection : public ObjectWrap {
623
617
void StopWrite ()
624
618
{
625
619
TRACE (" Stoping write watcher" );
626
- // ev_io_stop(EV_DEFAULT_ &write_watcher_);
627
620
uv_poll_stop (&write_watcher_);
628
621
}
629
622
630
623
void StartWrite ()
631
624
{
632
625
TRACE (" Starting write watcher" );
633
626
uv_poll_start (&write_watcher_, UV_WRITABLE, io_event);
634
- // ev_io_start(EV_DEFAULT_ &write_watcher_);
635
627
}
636
628
637
629
void StopRead ()
638
630
{
639
631
TRACE (" Stoping read watcher" );
640
- // ev_io_stop(EV_DEFAULT_ &read_watcher_);
641
632
uv_poll_stop (&read_watcher_);
642
633
}
643
634
644
635
void StartRead ()
645
636
{
646
637
TRACE (" Starting read watcher" );
647
- // ev_io_start(EV_DEFAULT_ &read_watcher_);
648
638
uv_poll_start (&read_watcher_, UV_READABLE, io_event);
649
639
}
650
640
// Converts a v8 array to an array of cstrings
0 commit comments