summaryrefslogtreecommitdiff
path: root/ace/TP_Reactor.cpp
diff options
context:
space:
mode:
authorirfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2000-01-14 03:59:16 +0000
committerirfan <irfan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2000-01-14 03:59:16 +0000
commit1b8beaa0d18fc9a79e066a7882d9f7cebcb1dfcd (patch)
tree15a532c70ed63e3f628c770704012d85ad1eafd4 /ace/TP_Reactor.cpp
parent5706e83c2b36ac762c65438ea12c820346b0584e (diff)
downloadATCD-1b8beaa0d18fc9a79e066a7882d9f7cebcb1dfcd.tar.gz
ChangeLogTag: Thu Jan 13 20:11:55 2000 Irfan Pyarali <irfan@cs.wustl.edu>
Diffstat (limited to 'ace/TP_Reactor.cpp')
-rw-r--r--ace/TP_Reactor.cpp20
1 files changed, 20 insertions, 0 deletions
diff --git a/ace/TP_Reactor.cpp b/ace/TP_Reactor.cpp
index f8b0bca927b..ef21a298a00 100644
--- a/ace/TP_Reactor.cpp
+++ b/ace/TP_Reactor.cpp
@@ -109,6 +109,26 @@ ACE_TP_Reactor::dispatch_io_set (int number_of_active_handles,
}
int
+ACE_TP_Reactor::work_pending (const ACE_Time_Value &timeout)
+{
+ ACE_MT (ACE_GUARD_RETURN (ACE_Select_Reactor_Token,
+ ace_mon, this->token_, -1));
+
+ u_long width = (u_long) this->handler_rep_.max_handlep1 ();
+
+ ACE_Select_Reactor_Handle_Set fd_set;
+ fd_set.rd_mask_ = this->wait_set_.rd_mask_;
+ fd_set.wr_mask_ = this->wait_set_.wr_mask_;
+ fd_set.ex_mask_ = this->wait_set_.ex_mask_;
+
+ return ACE_OS::select (int (width),
+ fd_set.rd_mask_,
+ fd_set.wr_mask_,
+ fd_set.ex_mask_,
+ timeout);
+}
+
+int
ACE_TP_Reactor::handle_events (ACE_Time_Value *max_wait_time)
{
ACE_TRACE ("ACE_TP_Reactor::handle_events");