From 98481e87960208c54ffb420e9055a280d4612029 Mon Sep 17 00:00:00 2001 From: sharath Date: Sat, 3 Mar 2001 00:05:40 +0000 Subject: ChangeLogTag: Fri Mar 02 17:50:40 2001 Sharath R. Cholleti --- ace/QtReactor.cpp | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) (limited to 'ace/QtReactor.cpp') diff --git a/ace/QtReactor.cpp b/ace/QtReactor.cpp index 15d6a7d3acc..1f1cec7d25e 100644 --- a/ace/QtReactor.cpp +++ b/ace/QtReactor.cpp @@ -28,6 +28,11 @@ ACE_QtReactor::ACE_QtReactor (QApplication *qapp, #if defined (ACE_MT_SAFE) && (ACE_MT_SAFE != 0) this->notify_handler_->close (); + + // Patch for MS Windows: close and open doesn't clear the read + // fd_set, so reset it manually + this->wait_set_.rd_mask_.reset (); + this->notify_handler_->open (this, 0); #endif /* ACE_MT_SAFE */ } @@ -94,7 +99,7 @@ ACE_QtReactor::read_event (int handle) // Send read event ACE_Select_Reactor_Handle_Set dispatch_set; - dispatch_set.rd_mask_.set_bit (handle); + dispatch_set.rd_mask_.set_bit (ACE_HANDLE(handle)); this->dispatch (1, dispatch_set); } @@ -104,7 +109,7 @@ ACE_QtReactor::write_event (int handle) // Send write event ACE_Select_Reactor_Handle_Set dispatch_set; - dispatch_set.wr_mask_.set_bit (handle); + dispatch_set.wr_mask_.set_bit (ACE_HANDLE(handle)); this->dispatch (1, dispatch_set); } @@ -114,7 +119,7 @@ ACE_QtReactor::exception_event (int handle) // Send exception event ACE_Select_Reactor_Handle_Set dispatch_set; - dispatch_set.ex_mask_.set_bit(handle); + dispatch_set.ex_mask_.set_bit(ACE_HANDLE(handle)); dispatch (1, dispatch_set); } @@ -183,7 +188,7 @@ ACE_QtReactor::register_handler_i (ACE_HANDLE handle , } ACE_NEW_RETURN (qsock_read_notifier, - QSocketNotifier (handle, QSocketNotifier::Read), + QSocketNotifier (int(handle), QSocketNotifier::Read), -1); this->read_notifier_.bind (handle, @@ -217,7 +222,7 @@ ACE_QtReactor::register_handler_i (ACE_HANDLE handle , } ACE_NEW_RETURN (qsock_write_notifier, - QSocketNotifier (handle, QSocketNotifier::Write), + QSocketNotifier (int(handle), QSocketNotifier::Write), -1); this->write_notifier_.bind (handle, @@ -250,7 +255,7 @@ ACE_QtReactor::register_handler_i (ACE_HANDLE handle , } ACE_NEW_RETURN (qsock_excpt_notifier, - QSocketNotifier (handle, QSocketNotifier::Exception), + QSocketNotifier (int(handle), QSocketNotifier::Exception), -1); this->exception_notifier_.bind (handle, -- cgit v1.2.1