← Back to branch summary

~ubuntu-branches/ubuntu/breezy/ace/breezy

« back to all changes in this revision

Viewing changes to TAO/tests/LongUpcalls/AMI_Manager.cpp

  • Committer: Bazaar Package Importer
  • Author(s): Adam Conrad, Benjamin Montgomery, Adam Conrad
  • Date: 2005-09-18 22:51:38 UTC
  • mfrom: (1.2.1 upstream) (2.1.1 sarge) (0.1.2 woody)
  • Revision ID: james.westby@ubuntu.com-20050918225138-seav22q6fyylb536
Tags: 5.4.7-3ubuntu1
[ Benjamin Montgomery ]
* Added a patch for amd64 and powerpc that disables the compiler
  option -fvisibility-inlines-hidden

[ Adam Conrad ]
* Added DPATCH_OPTION_CPP=1 to debian/patches/00options to make
  Benjamin's above changes work correctly with dpatch.

Show diffs side-by-side

added added

removed removed

Lines of Context:
TAO/tests/LongUpcalls/AMI_Manager.cpp
1
 
//
2
 
// AMI_Manager.cpp,v 1.7 2002/06/28 20:29:26 coryan Exp
3
 
//
4
 
 
5
 
#include "AMI_Manager.h"
6
 
 
7
 
ACE_RCSID(LongUpcalls, AMI_Manager, "AMI_Manager.cpp,v 1.7 2002/06/28 20:29:26 coryan Exp")
8
 
 
9
 
static void
10
 
validate_connection(Test::Controller_ptr controller
11
 
                    ACE_ENV_ARG_DECL)
12
 
  ACE_THROW_SPEC (())
13
 
{
14
 
  ACE_TRY
15
 
    {
16
 
#if (TAO_HAS_MESSAGING == 1)
17
 
      CORBA::PolicyList_var unused;
18
 
      controller->validate_connection(unused
19
 
                                      ACE_ENV_ARG_PARAMETER);
20
 
      ACE_TRY_CHECK;
21
 
#else
22
 
      controller->_is_a("Not_an_IDL_Type"
23
 
                        ACE_ENV_ARG_PARAMETER);
24
 
      ACE_TRY_CHECK;
25
 
#endif
26
 
    }
27
 
  ACE_CATCHANY
28
 
    {
29
 
    }
30
 
  ACE_ENDTRY;
31
 
}
32
 
 
33
 
AMI_Manager::AMI_Manager (CORBA::ORB_ptr orb)
34
 
  : orb_ (CORBA::ORB::_duplicate (orb))
35
 
{
36
 
}
37
 
 
38
 
void
39
 
AMI_Manager::start_workers (CORBA::Short worker_count,
40
 
                            CORBA::Long milliseconds,
41
 
                            Test::Controller_ptr controller
42
 
                            ACE_ENV_ARG_DECL)
43
 
  ACE_THROW_SPEC ((CORBA::SystemException))
44
 
{
45
 
  ACE_Thread_Manager thread_manager;
46
 
 
47
 
  validate_connection(controller
48
 
                      ACE_ENV_ARG_PARAMETER);
49
 
  ACE_CHECK;
50
 
 
51
 
  // ACE_DEBUG ((LM_DEBUG, "Starting %d workers\n", worker_count));
52
 
  Worker worker (&thread_manager,
53
 
                 controller, milliseconds,
54
 
                 this->orb_.in ());
55
 
 
56
 
  worker.activate (THR_NEW_LWP | THR_JOINABLE, worker_count);
57
 
 
58
 
  thread_manager.wait ();
59
 
}
60
 
 
61
 
void
62
 
AMI_Manager::shutdown (ACE_ENV_SINGLE_ARG_DECL)
63
 
  ACE_THROW_SPEC ((CORBA::SystemException))
64
 
{
65
 
  this->orb_->shutdown (0 ACE_ENV_ARG_PARAMETER);
66
 
}
67
 
 
68
 
// ****************************************************************
69
 
 
70
 
Worker::Worker (ACE_Thread_Manager *thr_mgr,
71
 
                Test::Controller_ptr controller,
72
 
                CORBA::Long milliseconds,
73
 
                CORBA::ORB_ptr orb)
74
 
  :  ACE_Task_Base (thr_mgr)
75
 
  ,  controller_ (Test::Controller::_duplicate (controller))
76
 
  ,  milliseconds_ (milliseconds)
77
 
  ,  orb_ (CORBA::ORB::_duplicate (orb))
78
 
{
79
 
}
80
 
 
81
 
int
82
 
Worker::svc (void)
83
 
{
84
 
  // ACE_DEBUG ((LM_DEBUG, "Worker starts\n"));
85
 
  ACE_DECLARE_NEW_CORBA_ENV;
86
 
  ACE_TRY
87
 
    {
88
 
      TAO_SYNCH_MUTEX mutex;
89
 
      int pending_requests = 2;
90
 
      Test::AMI_ControllerHandler_var handler;
91
 
 
92
 
      {
93
 
        Controller_Handler *handler_impl;
94
 
        ACE_NEW_RETURN (handler_impl,
95
 
                        Controller_Handler (&mutex,
96
 
                                            &pending_requests),
97
 
                        -1);
98
 
 
99
 
        PortableServer::ServantBase_var auto_destroy (handler_impl);
100
 
        handler = handler_impl->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
101
 
        ACE_TRY_CHECK;
102
 
      }
103
 
 
104
 
      validate_connection(this->controller_.in()
105
 
                          ACE_ENV_ARG_PARAMETER);
106
 
      ACE_TRY_CHECK;
107
 
 
108
 
      this->controller_->sendc_worker_started (handler.in ()
109
 
                                               ACE_ENV_ARG_PARAMETER);
110
 
      ACE_TRY_CHECK;
111
 
 
112
 
      // ACE_DEBUG ((LM_DEBUG, "Worker start reported\n"));
113
 
 
114
 
      ACE_Time_Value tv (0, 1000 * this->milliseconds_);
115
 
      ACE_OS::sleep (tv);
116
 
 
117
 
      this->controller_->sendc_worker_finished (handler.in ()
118
 
                                                ACE_ENV_ARG_PARAMETER);
119
 
      ACE_TRY_CHECK;
120
 
 
121
 
      // ACE_DEBUG ((LM_DEBUG, "Worker completion reported\n"));
122
 
 
123
 
      for (;;)
124
 
        {
125
 
          ACE_Time_Value tv (0, 1000 * this->milliseconds_);
126
 
          this->orb_->run (tv ACE_ENV_ARG_PARAMETER);
127
 
          ACE_TRY_CHECK;
128
 
 
129
 
          ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, mutex, -1);
130
 
          if (pending_requests == 0)
131
 
            break;
132
 
        }
133
 
    }
134
 
  ACE_CATCHANY
135
 
    {
136
 
      ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
137
 
                           "Exception in svc() method\n");
138
 
    }
139
 
  ACE_ENDTRY;
140
 
  return 0;
141
 
}
142
 
 
143
 
// ****************************************************************
144
 
 
145
 
Controller_Handler::Controller_Handler (TAO_SYNCH_MUTEX *mutex,
146
 
                                        int *pending_replies)
147
 
  :  mutex_ (mutex)
148
 
  ,  pending_replies_ (pending_replies)
149
 
{
150
 
}
151
 
 
152
 
void
153
 
Controller_Handler::worker_started (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
154
 
  ACE_THROW_SPEC ((CORBA::SystemException))
155
 
{
156
 
  ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, *this->mutex_);
157
 
  (*this->pending_replies_)--;
158
 
}
159
 
 
160
 
void
161
 
Controller_Handler::worker_started_excep
162
 
    (Test::AMI_ControllerExceptionHolder* h
163
 
     ACE_ENV_ARG_DECL)
164
 
  ACE_THROW_SPEC ((CORBA::SystemException))
165
 
{
166
 
  ACE_TRY
167
 
    {
168
 
      h->raise_worker_started (ACE_ENV_SINGLE_ARG_PARAMETER);
169
 
      ACE_TRY_CHECK;
170
 
    }
171
 
  ACE_CATCHANY
172
 
    {
173
 
      ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
174
 
                           "Controller_Handler exception raised in"
175
 
                           " worker_started");
176
 
    }
177
 
  ACE_ENDTRY;
178
 
}
179
 
 
180
 
void
181
 
Controller_Handler::worker_finished (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
182
 
  ACE_THROW_SPEC ((CORBA::SystemException))
183
 
{
184
 
  ACE_GUARD (TAO_SYNCH_MUTEX, ace_mon, *this->mutex_);
185
 
  (*this->pending_replies_)--;
186
 
}
187
 
 
188
 
void
189
 
Controller_Handler::worker_finished_excep
190
 
    (Test::AMI_ControllerExceptionHolder *h
191
 
     ACE_ENV_ARG_DECL)
192
 
  ACE_THROW_SPEC ((CORBA::SystemException))
193
 
{
194
 
  ACE_TRY
195
 
    {
196
 
      h->raise_worker_finished (ACE_ENV_SINGLE_ARG_PARAMETER);
197
 
      ACE_TRY_CHECK;
198
 
    }
199
 
  ACE_CATCHANY
200
 
    {
201
 
      ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
202
 
                           "Controller_Handler exception raised in"
203
 
                           " worker_finished");
204
 
    }
205
 
  ACE_ENDTRY;
206
 
}