diff options
| author | bala <balanatarajan@users.noreply.github.com> | 2001-05-03 19:59:15 +0000 |
|---|---|---|
| committer | bala <balanatarajan@users.noreply.github.com> | 2001-05-03 19:59:15 +0000 |
| commit | 65cf8ef9e9fb6a11dbbaba11dddc0e9dadbf0206 (patch) | |
| tree | f9b78eb5590da6b129227e850345f4148afb4b15 | |
| parent | 7e06af98f78132705e9de2c89614707a1eac4a1f (diff) | |
| download | ATCD-65cf8ef9e9fb6a11dbbaba11dddc0e9dadbf0206.tar.gz | |
ChangeLogTag: Thu May 3 14:56:13 2001 Balachandran Natarajan <bala@cs.wustl.edu>
| -rw-r--r-- | TAO/ChangeLogs/ChangeLog-02a | 10 | ||||
| -rw-r--r-- | TAO/tao/Asynch_Reply_Dispatcher.cpp | 2 | ||||
| -rw-r--r-- | TAO/tao/GIOP_Message_Generator_Parser_10.cpp | 4 | ||||
| -rw-r--r-- | TAO/tao/GIOP_Message_Generator_Parser_12.cpp | 4 | ||||
| -rw-r--r-- | TAO/tao/Synch_Reply_Dispatcher.cpp | 2 |
5 files changed, 16 insertions, 6 deletions
diff --git a/TAO/ChangeLogs/ChangeLog-02a b/TAO/ChangeLogs/ChangeLog-02a index d13ff491f98..97809c0f159 100644 --- a/TAO/ChangeLogs/ChangeLog-02a +++ b/TAO/ChangeLogs/ChangeLog-02a @@ -1,3 +1,13 @@ +Thu May 3 14:56:13 2001 Balachandran Natarajan <bala@cs.wustl.edu> + + * tao/Synch_Reply_Dispatcher.cpp (dispatch_reply): + * tao/Asynch_Reply_Dispatcher.cpp: + * tao/GIOP_Message_Generator_Parser_10.cpp: + * tao/GIOP_Message_Generator_Parser_12.cpp: Changed the call + steal_data () to exchange_data_blocks (). This should give us a + "release" free, malloc free and a lock free version of what we + want to achieve. + Thu May 3 11:55:42 2001 Pradeep Gore <pradeep@cs.wustl.edu> These are a set of changes for enabling lock free CDR input diff --git a/TAO/tao/Asynch_Reply_Dispatcher.cpp b/TAO/tao/Asynch_Reply_Dispatcher.cpp index 9140cd5104e..1c9df1a2461 100644 --- a/TAO/tao/Asynch_Reply_Dispatcher.cpp +++ b/TAO/tao/Asynch_Reply_Dispatcher.cpp @@ -113,7 +113,7 @@ TAO_Asynch_Reply_Dispatcher::dispatch_reply ( // this->message_state_ = message_state; // Steal the buffer so that no copying is done. - this->reply_cdr_.steal_data (params.input_cdr_); + this->reply_cdr_.exchange_data_blocks (params.input_cdr_); // Steal the buffer, that way we don't do any unnecesary copies of // this data. diff --git a/TAO/tao/GIOP_Message_Generator_Parser_10.cpp b/TAO/tao/GIOP_Message_Generator_Parser_10.cpp index 174f4beffba..6e733284895 100644 --- a/TAO/tao/GIOP_Message_Generator_Parser_10.cpp +++ b/TAO/tao/GIOP_Message_Generator_Parser_10.cpp @@ -430,7 +430,7 @@ TAO_GIOP_Message_Generator_Parser_10::parse_reply ( // Steal rest of the contents in to the reply params and loose // ownership of the data block. - params.input_cdr_.steal_data (cdr); + params.input_cdr_.exchange_data_blocks (cdr); return 0; } @@ -449,7 +449,7 @@ TAO_GIOP_Message_Generator_Parser_10::parse_locate_reply ( // Steal the contents in to the reply CDR and loose ownership of the // data block. - params.input_cdr_.steal_data (cdr); + params.input_cdr_.exchange_data_blocks (cdr); return 0; } diff --git a/TAO/tao/GIOP_Message_Generator_Parser_12.cpp b/TAO/tao/GIOP_Message_Generator_Parser_12.cpp index 28943d686c2..31a8df6986a 100644 --- a/TAO/tao/GIOP_Message_Generator_Parser_12.cpp +++ b/TAO/tao/GIOP_Message_Generator_Parser_12.cpp @@ -451,7 +451,7 @@ TAO_GIOP_Message_Generator_Parser_12::parse_reply ( // Steal the contents in to the reply CDR and loose ownership of the // data block. - params.input_cdr_.steal_data (cdr); + params.input_cdr_.exchange_data_blocks (cdr); return 0; } @@ -475,7 +475,7 @@ TAO_GIOP_Message_Generator_Parser_12::parse_locate_reply ( // Steal the contents in to the reply CDR and loose ownership of the // data block. - params.input_cdr_.steal_data (cdr); + params.input_cdr_.exchange_data_blocks (cdr); return 0; } diff --git a/TAO/tao/Synch_Reply_Dispatcher.cpp b/TAO/tao/Synch_Reply_Dispatcher.cpp index 9a59749967a..3d623992f38 100644 --- a/TAO/tao/Synch_Reply_Dispatcher.cpp +++ b/TAO/tao/Synch_Reply_Dispatcher.cpp @@ -59,7 +59,7 @@ TAO_Synch_Reply_Dispatcher::dispatch_reply ( //this->message_state_.reset (0); // Steal the buffer so that no copying is done. - this->reply_cdr_.steal_data (params.input_cdr_); + this->reply_cdr_.exchange_data_blocks (params.input_cdr_); /*if (&this->message_state_ != message_state) { |