blob: 87500e8ff82106809f4a38321126c02a041f690f (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
// -*- C++ -*-
#include "tao/PI_Server/PICurrent_Guard.h"
#if TAO_HAS_INTERCEPTORS == 1
#include "tao/ORB_Core.h"
#include "tao/TAO_Server_Request.h"
#include "tao/PI/PICurrent.h"
#include "tao/PI/PICurrent_Impl.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
TAO::PICurrent_Guard::PICurrent_Guard (TAO_ServerRequest &server_request,
bool tsc_to_rsc)
: src_ (0),
dest_ (0)
{
// This constructor is used on the server side.
// Retrieve the thread scope current (no TSS access incurred yet).
CORBA::Object_ptr pi_current_obj =
server_request.orb_core ()->pi_current ();
TAO::PICurrent *pi_current =
dynamic_cast <TAO::PICurrent*> (pi_current_obj);
// If the slot count is zero, there is nothing to copy. Prevent any
// copying (and hence TSS accesses) from occurring.
if (pi_current != 0 && pi_current->slot_count () != 0)
{
// Retrieve the request scope current.
PICurrent_Impl * rsc = server_request.rs_pi_current ();
// Retrieve the thread scope current.
PICurrent_Impl * tsc = pi_current->tsc ();
if (tsc_to_rsc)
{
// TSC to RSC copy.
// Occurs after receive_request() interception point and
// upcall.
this->src_ = tsc;
this->dest_ = rsc;
}
else
{
// RSC to TSC copy.
// Occurs after receive_request_service_contexts()
// interception point.
this->src_ = rsc;
this->dest_ = tsc;
}
}
}
TAO::PICurrent_Guard::~PICurrent_Guard (void)
{
if (this->src_ != 0 && this->dest_ != 0
&& this->src_ != this->dest_)
{
this->dest_->take_lazy_copy (this->src_);
}
}
TAO_END_VERSIONED_NAMESPACE_DECL
#endif /* TAO_HAS_INTERCEPTORS == 1 */
|
