diff options
| author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1996-11-24 23:25:58 +0000 |
|---|---|---|
| committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1996-11-24 23:25:58 +0000 |
| commit | ae3742d1d6afe6974dfb95acab3b7b99776f30a4 (patch) | |
| tree | 12679470148b109564cc28a52fa7aeb5732f5b00 /ace/UPIPE_Acceptor.cpp | |
| parent | 1d68bf26a8df9cf5b878a2070ab7d82e966eabc9 (diff) | |
| download | ATCD-ae3742d1d6afe6974dfb95acab3b7b99776f30a4.tar.gz | |
Done
Diffstat (limited to 'ace/UPIPE_Acceptor.cpp')
| -rw-r--r-- | ace/UPIPE_Acceptor.cpp | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/ace/UPIPE_Acceptor.cpp b/ace/UPIPE_Acceptor.cpp index 9d3f97fcb77..2312869be0d 100644 --- a/ace/UPIPE_Acceptor.cpp +++ b/ace/UPIPE_Acceptor.cpp @@ -72,15 +72,19 @@ ACE_UPIPE_Acceptor::accept (ACE_UPIPE_Stream &new_stream, else { ACE_UPIPE_Stream *remote_stream = 0; - // Transfer address ownership. + + ACE_MT (ACE_GUARD_RETURN (ACE_Thread_Mutex, ace_mon, new_stream.lock_, -1)); + new_stream.set_handle (new_io.get_handle ()); + new_stream.reference_count_++; + // Transfer address ownership. new_io.get_local_addr (new_stream.local_addr_); new_io.get_remote_addr (new_stream.remote_addr_); - - // Now that we got the fd, we'll read the address of the + + // Now that we got the handle, we'll read the address of the // connector-side ACE_UPIPE_Stream out of the pipe and link that - // ACE_UPIPE_Stream to our ACE_UPIPE_Stream + // ACE_UPIPE_Stream to our ACE_UPIPE_Stream. if (ACE_OS::read (new_stream.get_handle (), (char *) &remote_stream, |