diff options
| author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1998-03-11 01:33:47 +0000 |
|---|---|---|
| committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1998-03-11 01:33:47 +0000 |
| commit | e490e03b4ee5ce8cb1404be0a9b97f34bdca24ee (patch) | |
| tree | a02fc4d47216d6b8a9c0eb204fd3eade58b9fc3b /ace/Module.cpp | |
| parent | 165cb450d56b6f2ee83632d51e90636e8e75159f (diff) | |
| download | ATCD-e490e03b4ee5ce8cb1404be0a9b97f34bdca24ee.tar.gz | |
*** empty log message ***
Diffstat (limited to 'ace/Module.cpp')
| -rw-r--r-- | ace/Module.cpp | 16 |
1 files changed, 13 insertions, 3 deletions
diff --git a/ace/Module.cpp b/ace/Module.cpp index 93fe1d8b84a..a65efe1e2e2 100644 --- a/ace/Module.cpp +++ b/ace/Module.cpp @@ -30,9 +30,14 @@ ACE_Module<ACE_SYNCH_USE>::writer (ACE_Task<ACE_SYNCH_USE> *q, this->close_i (1, flags); this->q_pair_[1] = q; + if (q != 0) - ACE_CLR_BITS (q->flags_, ACE_Task_Flags::ACE_READER); - + { + ACE_CLR_BITS (q->flags_, ACE_Task_Flags::ACE_READER); + // Set the q's module pointer to point to us. + q->mod_ = this; + } + // Don't allow the caller to change the reader status. ACE_SET_BITS (flags_, (flags & M_DELETE_WRITER)); } @@ -47,8 +52,13 @@ ACE_Module<ACE_SYNCH_USE>::reader (ACE_Task<ACE_SYNCH_USE> *q, this->close_i (0, flags); this->q_pair_[0] = q; + if (q != 0) - ACE_SET_BITS (q->flags_, ACE_Task_Flags::ACE_READER); + { + ACE_SET_BITS (q->flags_, ACE_Task_Flags::ACE_READER); + // Set the q's module pointer to point to us. + q->mod_ = this; + } // don't allow the caller to change the reader status ACE_SET_BITS (flags_, (flags & M_DELETE_READER)); |