1 mday 1.3 <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
2 <html lang="en"><head>
|
3 mday 1.4 <META http-equiv="Content-Type" content="text/html;
4 charset=ISO-8859-1"><meta http-equiv="Content-Type"
5 content="text/html;
6 charset=ISO-8859-1"><title>Pegasus
7 Meta Dispatcher </title><style type="text/css">
|
8 mday 1.3
9 body {
10 margin: 2em 1em 2em;
11 font-family: sans-serif;
12 color: black;
13 background: white;
14 background-position: top left;
15 background-attachment: fixed;
16 background-repeat: no-repeat;
17 }
18 :link { color: #00C; background: transparent }
19 :visited { color: #609; background: transparent }
20 :active { color: #C00; background: transparent }
21
22 th, td { /* ns 4 */
23 font-family: sans-serif;
24 }
25
26 h1, h2, h3, h4, h5, h6 { text-align: left }
27 /* background should be transparent, but WebTV has a bug */
28 h1, h2, h3 { color: #005A9C; background: white }
29 mday 1.3 h1 { font: 170% sans-serif }
30 h2 { font: 140% sans-serif }
31 h3 { font: 120% sans-serif }
32 h4 { font: bold 100% sans-serif }
33 h5 { font: italic 100% sans-serif }
34 h6 { font: small-caps 100% sans-serif }
35
36 .hide { display: none }
37
38 div.head { margin-bottom: 1em }
39 div.head h1 { margin-top: 2em; clear: both }
40 div.head table { margin-left: 2em; margin-top: 2em }
41 div.head img { color: white; border: none } /* remove border from top image */
42
43 p.copyright { font-size: small }
44 p.copyright small { font-size: small }
45
46 pre { margin-left: 2em }
|
47 mday 1.4
|
48 mday 1.3 p {
49 margin-top: 0.6em;
50 margin-bottom: 0.6em;
51 }
|
52 mday 1.4
|
53 mday 1.3 dt, dd { margin-top: 0; margin-bottom: 0 } /* opera 3.50 */
54 dt { font-weight: bold }
55
56 pre, code { font-family: monospace } /* navigator 4 requires this */
57
58 ul.toc {
59 list-style: disc; /* Mac NS has problem with 'none' */
60 list-style: none;
61 }
62
|
63 mday 1.4 code { font-family: monospace; }
64 var {font-family: monospace; font-style: normal; font-weight: bold;}
|
65 mday 1.3 div.constraint,
66 div.issue,
67 div.note,
68 div.notice { margin-left: 2em; }
69
|
70 mday 1.4 li p { margin-top: 0.8em;
71 margin-bottom: 0.8em; }
|
72 mday 1.3
|
73 mday 1.4 li {margin-top: 0.4em; margin-bottom: 0.4em;}
74
|
75 mday 1.3 div.exampleInner pre { margin-left: 1em;
76 margin-top: 0em; margin-bottom: 0em}
77 div.exampleOuter {border: 4px double gray;
78 margin: 0em; padding: 0em}
79 div.exampleInner { background-color: #d5dee3;
80 border-top-width: 4px;
81 border-top-style: double;
82 border-top-color: #d3d3d3;
83 border-bottom-width: 4px;
84 border-bottom-style: double;
85 border-bottom-color: #d3d3d3;
86 padding: 4px; margin: 0em }
87 div.exampleWrapper { margin: 4px }
88 div.exampleHeader { font-weight: bold;
89 margin: 4px}
90
91 table { background-color: #d5dee3;
92 width: 85% ;
93 border-style: double;
94 border-width: 4px;
95 border-color: #d3d3d3;
96 mday 1.3 }
97 </style>
98
|
99 mday 1.1 <html>
100 <head>
101 <title>Pegasus Meta Dispatcher</title>
102 </head>
103
104 <body>
|
105 mday 1.3
|
106 mday 1.1 <h1>Pegasus Meta Dispatcher</h1>
107 <p>
108 The Pegasus Meta Dispatcher is a set of classes that extend the
109 existing MessageQueue messaging system to be dynamic,
110 asynchronous, and multithreaded. The primary classes consist of the
111 folowing:
112 </p>
|
113 mday 1.3 <table>
114 <tr align="left"><th>Class</th><th>Derived from</th><th>Source file</th></tr>
115 <tr><td><div class="exampleInner">cimom</div></td><td>MessageQueue</td><td>Pegasus/Common/Cimom.h</td></tr>
116 <tr><td>MessageQueueService</td><td>MessageQueue</td><td>Pegasus/Common/MessageQueueServices.h</td></tr>
117 <tr><td>CimomMessage</td><td>Message</td><td>Pegasus/Common/CimomMessage.h</td></tr>
|
118 mday 1.1 <tr><td>AsyncOpNode</td><td>n/a</td><td>Pegasus/Common/AsyncOpNode.h</td></tr>
|
119 mday 1.3 <tr><td>AsyncDQueue</td><td>unlocked_dq</td><td>Pegasus/Common/DQueue.h</td></tr>
120 <tr><td>IPC classes</td><td>n/a</td><td>Pegasus/Common/IPC.h</td></tr>
121 <tr><td>Threading classes</td><td>n/a</td><td>Pegasus/Common/Thread.h</td></tr>
122
123 </table>
124
125 <br>
126 <br>
|
127 mday 1.1
|
128 mday 1.4 <a href = "#non-blocking">Jump to the non-blocking message interface.</a>
129
|
130 mday 1.1 <h2>Purposes of Meta Dispatcher</h2>
131 <p>
|
132 mday 1.4 The Meta Dispatcher has three primary goals:
|
133 mday 1.1 <ol>
134 <li>Provide for orderly asynchronous message-based communication
135 among a dynamic set of Pegasus Services.</li>
136 <li>Preserve the existing message-passing architecture of
137 Pegasus.</li>
138 <li>Allow Pluggable Services such as repositories, provider
139 managers, and others.</li>
140 </ol>
141 <br>
142 <br>
143 Most of the purposes listed above revolve around maintaining the
144 integrity of data and control flow in an asynchronous
145 multithreaded environment.
146 </p>
147
148 <h2>Terms</h2>
149 <p>
150 <dl>
151 <dt><b>Meta Dispatcher</b></dt><dd>The central message broker, or
152 router, that provides the asynchronous communications within
153 Pegasus. Derived from the <b>MessageQueue</b> class. <br>
154 mday 1.1 </dd>
155 <dt><b>Service</b></dt><dd>A Pegasus module that sends and
156 receives messages to other modules through the meta
157 dispatcher; A module that has enhanced privileges within
158 Pegasus and which provides one or more functions necessary to
159 the operation of Pegasus. Derived from the
160 <b>MessageQueue</b>class.<dt>
161 <dt><b>Asynchronous Message</b></dt><dd>A <b>pair</b> of
162 messages, consisting of a <b>request</b> and a <b>response</b>
163 that are treated as a single operation by Services. An
164 asynchronous message may be fronted by a synchronous
165 programming interface. Derived from the <b>Message</b> class.</dd>
166 <dt><b>AsyncOpNode</b></dt><dd>A control object that manages the
167 lifetime of an <b>Asynchronous Message</b>.The AsyncOpNode uses
168 many of the IPC object classes. A Service manages the lifetime
169 of an AsyncOpNode during the processing of the
170 message. However, it necessarily cedes control of the
171 AsyncOpNode to the <b>Meta Dispatcher</b> while the
172 Asynchronous Message is being processed.</dd>
173 </dl>
174
175 mday 1.1 </p>
176
177 <h2>Meta Dispatcher Design</h2>
178 <p>
179 Three points are necessary to avoid deadlocks and to
180 provide pluggable services in Pegaus. The first thing is
181 <b>independent execution paths</b> of service modules. i.e.,
182 each service must have its own thread(s), which must not intersect
183 with the thread(s) of other services. Intersection of execution
184 paths can occur indirectly through IPC objects such as mutexes,
185 conditions, and semaphores.
186 </p>
187 <p>
188 The second point that is necessary is <b>interface
189 abstraction</b>, which the Meta Dispatcher provides through
190 C++ polymorphism. This allows pluggable services. i.e., one
191 service can replace another and the system will continue to
192 function (hopefully in an improved manner).
193 </p>
194 <p>
195 The third point that is neccesary is a <b>central
196 mday 1.1 message broker</b> that isolates services from each other,
197 thereby preventing deadlocks. The central message broker also
198 provides message responses for services that are paused,
199 stopped, or not present (plugged in).
200 </p>
201
202
203 <h3>Central Hub</h3>
204 <p>
205 The Meta Dispatcher therefore acts as a central message
206 hub. Services communicate with each other <i>via</i> the Meta
207 Dispatcher.
|
208 mday 1.3 <div class="exampleOuter"><div class="exampleInner">
|
209 martin 1.5 <pre> Service A--Message----1----> (block on semaphore)
|
210 mday 1.1 |
211 |
212 Meta Dispatcher|
213 |
214 Message----2->Service B
215 |
216 |
217 (Signal Semaphore) <---Response---3-- +
218 |
219 Service A <--Response--4---+
220
221 </pre>
222
|
223 mday 1.3 </div></div>
|
224 mday 1.1 The numbered steps above are as follows:
225 <ol>
226 <li><b>Service A</b> creates a new <code>AsyncMessage</code> and
227 <code>AsyncOpNode</code>and sends that message to <b>Service
228 B</b> by calling
229 <code>MessageQueueService::SendWait</code>. The calling thread
230 blocks on the <b>client emaphore</b> until the response is ready.</li><br>
231
232 <li>The Meta Dispatcher's routing thread picks up the message
233 and inserts it into <b>Service B's</b> incoming message
234 queue. The routing thread returns to the Meta Dispatcher to
235 route the next message in the system.</li><br>
236
237 <li><b>Service B's</b>incoming thread picks up the message and
238 calls the its message handler. Message handlers are virtual,
239 so a class derived from <b>MessageQueueService</b>can define
240 its own message handlers to override the default
241 handlers. When the message handler has constructed an
242 <b>AsyncReply</b> that reply gets linked to the
243 <b>AsyncOpNode</b>. The MessageQueueService then signals the
244 <b>client semaphore</b> within the op node.</li><br>
245 mday 1.1
246 <li><b>Service A</b> awakens when the <b>client semaphore</b> is
247 signalled. It pulls the <b>AsyncResponse</b> message from the
248 <b>AsyncOpNode</b> and processes the result. Service A is
249 responsible for discarding the request, response, and
250 AsyncOpNode objects. The existing classes have mechanisms for
251 caching these objects to avoid too frequent
252 construction/destruction of them.
253 </ol>
254 </p>
255
256 <h2>Test Program</h2>
257 <p>
258 The concepts explained below are all contained in the test
259 program for the Meta Dispatcher, which is located in
260 <code>$PEGASUS_HOME/src/Pegasus/Common/tests/MessageQueueService/</code>
261
262 </p>
263
264 <h2>Service Registration and Deregistration</h2>
265 <p>
266 mday 1.1 Services (classes derived from
267 <code>MessageQueueService</code>must register their presence
268 with the Meta Dispatcher. This is done as follows (taken from
269 the test program):
270
271 <ol>
272 <li><b>Define the Service Class</b></li>
|
273 martin 1.5 <pre>// Define our service class
|
274 mday 1.1
275 class MessageQueueClient : public MessageQueueService
276 {
277
278 public:
279 typedef MessageQueueService Base;
280
281 MessageQueueClient(char *name)
282 : Base(name, MessageQueue::getNextQueueId(), 0,
283 message_mask::type_cimom |
284 message_mask::type_service |
285 message_mask::ha_request |
286 message_mask::ha_reply |
287 message_mask::ha_async ),
288 client_xid(1)
289 {
290 _client_capabilities = Base::_capabilities;
291 _client_mask = Base::_mask;
292 }
293
294 virtual ~MessageQueueClient(void)
295 mday 1.1 {
296 }
297
298 // method to indicate acceptance of message to
299 // Meta Dispatcher
300 virtual Boolean messageOK(const Message *msg);
301
302 // function to send a request to another service
303 void send_test_request(char *greeting, Uint32 qid);
304 Uint32 get_qid(void);
305
306 Uint32 _client_capabilities;
307 Uint32 _client_mask;
308
309 // method to receive messages from the Meta Dispatcher,
310 // MUST be defined
311 virtual void _handle_async_request(AsyncRequest *req);
312
313 AtomicInt client_xid;
314 };
315
316 mday 1.1 </pre>
317 <li><b>Construct the Service</b></li>
|
318 martin 1.5 <pre>// Create our Service
|
319 mday 1.1 MessageQueueClient *q_client =
320 new MessageQueueClient("test client");
321
322 </pre>
323 <li><b>Register the Service</b></li>
|
324 martin 1.5 <pre>// Register our service with the Meta Dispatcher
|
325 mday 1.1 q_client->register_service("test client",
326 q_client->_client_capabilities,
327 q_client->_client_mask);
328 cout << " client registered " << endl;
329 </pre>
330
331 </ol>
332
333 The example above hides many of the details which are handled by
334 the MessageQueueService's constructor, such as creating the
335 background thread, finding the Meta Dispatcher, and constructing
336 the queues. But a derived class as the example shows does not
337 need to worry about those details.
338 </p>
339
340 <h2>Finding Other Services</h2>
341 <p>
342 The MessageQueueService class has an api for finding other
343 services. This api is built using messages that are defined in
344 <code>CimomMessage.h</code>. Here is an example from the test
345 program:
346 mday 1.1
347 <pre>
|
348 mday 1.2 Array<Uint32>; services;
|
349 mday 1.1
350 while( services.size() == 0 )
351 {
|
352 mday 1.2 q_client->find_services(String("test server"), 0, 0, &services);
|
353 mday 1.1 pegasus_yield();
354 }
355
|
356 mday 1.2 cout << "found server at " << services[0] << endl;
|
357 mday 1.1
358
359 </pre>
360
361 The code sample above shows how to find services by their
362 name. The api also allows finding services by their capabilities
363 or the messages they support. Note that the return is an array
364 of Queue IDs. It is possible, for example, to find multiple
365 services.
366 </p>
367
368 <h2>Sending an Asynchronous Message to Another Service</h2>
369 <p>
370 The "handle" for a services is its Queue ID. Once you have the
371 Queue ID you can send a message to that service. The example
372 above shows one way to get a service's Queue ID. Here is an
373 example that shows how to send that service a message.
374
375 <ol>
376 <li><b>Define the Request and Response Message Pair by Inheriting from AsyncMessage.</b></li>
377 <pre>
378 mday 1.1 class test_request : public AsyncRequest
379 {
380
381 public:
382 typedef AsyncRequest Base;
383
384 test_request(Uint32 routing,
385 AsyncOpNode *op,
386 Uint32 destination,
387 Uint32 response,
388 char *message)
389 : Base(0x04100000,
390 Message::getNextKey(),
391 routing,
392 0,
393 op,
394 destination,
395 response,
396 true),
397 greeting(message)
398 {
399 mday 1.1
400 }
401
402 virtual ~test_request(void)
403 {
404
405
406 }
407
408 String greeting;
409 };
410
411
412 class test_response : public AsyncReply
413 {
414 public:
415 typedef AsyncReply Base;
416
417
418 test_response(Uint32 key,
419 Uint32 routing,
420 mday 1.1 AsyncOpNode *op,
421 Uint32 result,
422 Uint32 destination,
423 char *message)
424 : Base(0x04200000,
425 key,
426 routing,
427 0,
428 op,
429 result,
430 destination,
431 true),
432 greeting(message)
433 {
434
435 }
436
437 virtual ~test_response(void)
438 {
439
440 }
441 mday 1.1
442 String greeting;
443 };
444
445 </pre>
446
447 The function <code>send_test_request</code> shows everything
448 that is necessary to send a message to another service and
449 process the reply.
450
451 <pre>
452 void MessageQueueClient::send_test_request(char *greeting, Uint32 qid)
453 {
454
455 </pre>
456 <li><b>Construct the Request</b></li>
457
|
458 martin 1.5 <pre> test_request *req =
|
459 mday 1.1 new test_request(Base::get_next_xid(),
460 0,
461 qid, // destination queue ID
462 _queueId, // my own queue ID
463 greeting); // message parameter
464
465 </pre>
466
467 <li><b>Send the message using <code>MessageQueueService::SendWait</code></b></li>
468
|
469 martin 1.5 <pre> AsyncMessage *response = SendWait(req);
|
470 mday 1.1
471 </pre>
472
473 <li><b>Process the Response.</b></i>
|
474 martin 1.5 <pre> if( response != 0 )
|
475 mday 1.1 {
476 msg_count++;
477 delete response;
478 cout << " test message " << msg_count.value() << endl;
479
480 }
481 delete req;
482 }
483
484 </pre>
485
486 <li><b>Delete the Request and the Response. The
487 <code>SendWait</code> interface creates and disposes of
488 everything else.</b></li>
489
490 </ol>
491 </p>
492
493
494 <h2>Handling an Incoming Message </h2>
495
496 mday 1.1 <p>
497 To handle messages the service needs to implement the
498 following methods.
499
500 <ol>
501
502 <li><b><code>virtual Boolean MessageOK(const Message
503 *)</code></b></li>
504
505 This method allows the Service to accept or reject the
506 message. The Meta Dispatcher will always call this method
507 before inserting the request on the Service's queue.
508
509 <pre>
510 Boolean MessageQueueServer::messageOK(const Message *msg)
511 {
512 if(msg->getMask() & message_mask::ha_async)
513 {
514 if( msg->getType() == 0x04100000 ||
515 msg->getType() == async_messages::CIMSERVICE_STOP ||
516 msg->getType() == async_messages::CIMSERVICE_PAUSE ||
517 mday 1.1 msg->getType() == async_messages::CIMSERVICE_RESUME )
518 return true;
519 }
520 return false;
521 }
522
523 </pre>
524
525 <li><b><code>virtual Boolean accept_async(AsyncOpNode
526 *operation)</code> (optional) </b></li>
527
528 This method executes on the Meta Dispatcher's thread and links
529 the incoming message to the Service's queue. <br><br>
530
531
532
533 <li><b><code>virtual void _handle_incoming_operation(AsyncOpNode
534 *)</code></b></li><br>
535
536
537 This method is called by the Service's background thread. Here is an
538 mday 1.1 example implementation that just does some sanity checking on
539 the message.
540
541 <pre>
542 void MessageQueueServer::_handle_incoming_operation(AsyncOpNode *op)
543 {
544 if ( operation != 0 )
545 {
546 Message *rq = operation->get_request();
547 PEGASUS_ASSERT(rq != 0 );
548 PEGASUS_ASSERT(rq->getMask() & message_mask::ha_async );
549 PEGASUS_ASSERT(rq->getMask() & message_mask::ha_request);
550 _handle_async_request(static_cast<AsyncRequest *>(rq));
551 }
552
553 return;
554
555 }
556
557
558 </pre>
559 mday 1.1
560 <li><b><code>virtual void _handle_async_request(AsyncRequest *)</code></b></li><br>
561 <br>
562
563 This method handles the request. The Service must implement
564 this method. <b>If the Service does not handle the Request it
565 must pass the Request to the Base class by calling <code>Base::_handle_async_request(req)</code></b>
566
|
567 martin 1.5 <pre>void MessageQueueServer::_handle_async_request(AsyncRequest *req)
|
568 mday 1.1 {
569 if (req->getType() == 0x04100000 )
570 {
571 req->op->processing();
572 handle_test_request(req); // Message Handler
573 }
574 else if ( req->getType() == async_messages::CIMSERVICE_STOP )
575 {
576 req->op->processing();
577 handle_CimServiceStop(static_cast<CimServiceStop *>(req));
578 }
579
580 else
581 Base::_handle_async_request(req); // Give it to the Base !!
582 }
583
584 </pre>
585
586 <li><b>Specific Message Handlers</b>
587
588 Each Message handler will be defined by the format of the
589 mday 1.1 Request/Response pair. Here is an example from the test
590 program.
591
|
592 martin 1.5 <pre>
|
593 mday 1.1 if( msg->getType() == 0x04100000 )
594 {
595
596 </pre>
597 <ol>
598 <li><b>Construct the Reply</b></li>
599 <pre>
600 test_response *resp =
601 new test_response(msg->getKey(),
602 msg->getRouting(),
603 msg->op,
604 async_results::OK,
605 msg->dest,
606 "i am a test response");
607
608
609 </pre>
610 <li><b>Complete the Reply</b> by calling the following
611 helper routine in the Base class</li>
612
|
613 martin 1.5 <pre> _completeAsyncResponse(msg, resp, ASYNC_OPSTATE_COMPLETE, 0);
|
614 mday 1.1
615 }
616 </pre>
617
618 </ol>
619 </p>
620
|
621 mday 1.2 <h2>Handling CIMMessage and Other Pre-existing Message Classes</h2>
622 <p>
623 Existing Messages, including all of the <code>CIMMessage</code>
624 derivitives, are not configured to be asynchronous
625 request/reply pairs. They are designed to travel through
626 Pegasus as events that trigger other processing events,
627 which is the end of their lifetime. This is not an optimal
628 use model for asynchronous operation because the
629 originator of the event does not require nor receive any
630 completion notification. Further, there is not a
631 one-to-one correspondence of "event messages" to replies.
632 </p>
633
634 <h3>AsyncLegacyOperationStart Message</h3>
635 <p>
636 The AsyncLegacyOperationStart message is an envelope that
637 allows a <code>MessageQueueService</code>-based service to
638 send, receive, and process pre-existing "legacy"
639 messages.
640 </p>
641 <p>
642 mday 1.2 The <code>AsyncLegacyOperationStart</code> Message allows
643 an asynchronous service to create, package, and send a
644 "legacy" message to another service or, indirectly,
645 enqueue it to a non-asynchronous message queue. The code
646 example below shows how this works:
647 </p>
648
649 <pre>
650 cout << " sending LEGACY to test server" << endl;
651
652 Message *legacy = new Message(0x11100011,
653 Message::getNextKey());
654
655 AsyncLegacyOperationStart *req =
656 new AsyncLegacyOperationStart(q_client->get_next_xid(),
657 0,
658 services[0],
659 legacy,
660 q_client->getQueueId());
661 reply = q_client->SendWait(req);
662 delete req;
663 mday 1.2 delete reply;
664
665 </pre>
666 <p>
667 The code sample above shows a <code>Message</code> object
668 being embedded inside an
669 <code>AsyncLegacyOperationStart</code> message and sent
670 using the <code>SendWait</code>API.
671 </p>
672
673 <h3>Default Handler for Legacy Messages</h3>
674 <p>
675 The <code>MessageQueueService</code> class has a default
676 handler for legacy messages that extracts the
677 <code>Message</code> out of its asynchronous "envelope"
678 and dispatches it using the pre-existing synchronous
679 interface, as shown below.
680 </p>
681
682 <pre>
683 void MessageQueueService::handle_AsyncLegacyOperationStart(
684 mday 1.2 AsyncLegacyOperationStart *req)
685 {
686 // remove the legacy message from the request and enqueue it to its destination
687 Uint32 result = async_results::CIM_NAK;
688
689 Message *legacy = req->act;
690 if ( legacy != 0 )
691 {
692 MessageQueue* queue = MessageQueue::lookup(req->legacy_destination);
693 if( queue != 0 )
694 {
695 // Enqueue the response:
696 queue->enqueue(legacy);
697 result = async_results::OK;
698 }
699 }
700 _make_response(req, result);
701 }
702
703 </pre>
704
705 mday 1.2 <p>
706 The default handler shown above extracts the legacy
707 message and attempts to <code>enqueue</code> that message
708 syncrhonously using the pre-existing interface.
709 </p>
710
711 <h3>Example of Custom Handler for Legacy Messages</h3>
712 <p>
713 By implementing the virtual
714 <code>_handle_async_request</code> method,
715 a service can choose to implement its own handler for
716 Legacy messages, as the code below shows:
717 </p>
718
719 <ol>
720
721 <li><b>Implement the virtual <code>_handle_async_request</code> method.</b></li>
722 <pre>
723 void MessageQueueServer::_handle_async_request(AsyncRequest *req)
724 {
725 if (req->getType() == 0x04100000 )
726 mday 1.2 {
727 req->op->processing();
728 handle_test_request(req);
729 }
730 else if ( req->getType() == async_messages::CIMSERVICE_STOP )
731 {
732 req->op->processing();
733 handle_CimServiceStop(static_cast<CimServiceStop *>(req));
734 }
735 </pre>
736 <li><b>Implement a dispatcher for <code>ASYNC_LEGACY_OP_START</code></b></li>
|
737 martin 1.5 <pre> else if ( req->getType() == async_messages::ASYNC_LEGACY_OP_START )
|
738 mday 1.2 {
739 req->op->processing();
740 handle_LegacyOpStart(static_cast<AsyncLegacyOperationStart *>(req));
741 }
742
743 else
744 Base::_handle_async_request(req);
745 }
746
747 </pre>
748 <li><b>Implement a dispatcher for <code>ASYNC_LEGACY_OP_START</code></b></li>
749 <pre>
750 void MessageQueueServer::handle_LegacyOpStart(AsyncLegacyOperationStart *req)
751 {
752
753 Message *legacy = req->act;
754 cout << " ### handling legacy messages " << endl;
755
756
757 AsyncReply *resp =
758 new AsyncReply(async_messages::REPLY,
759 mday 1.2 req->getKey(),
760 req->getRouting(),
761 0,
762 req->op,
763 async_results::OK,
764 req->resp,
765 req->block);
766 _completeAsyncResponse(req, resp, ASYNC_OPSTATE_COMPLETE, 0 );
767
768 if (legacy != 0 )
769 cout << " legacy msg type: " << legacy->getType() << endl;
770
771 }
772
773 </pre>
774
775
776 </ol>
|
777 mday 1.1
778 <hr>
|
779 mday 1.3
780
|
781 mday 1.4 <a name="non-blocking"><h2>Sending Messages without Blocking (Async with Callback)</h2></a>
|
782 mday 1.3
783 <p>
784 Whenever there is a possibility that the processing of
785 one message may generate a nested message (message
786 generated within the handler of a message) it is
787 necessary to send messages without blocking, and to
788 receive responses via callback routines. The diagram
789 below shows the (more complicated) flow of
790 non-blocking messages.
791 </p>
792 <br>
793 <div class="exampleOuter"><div class="exampleInner">
|
794 martin 1.5 <pre> Service A--Message----1---->
|
795 mday 1.3 |
796 . <-----------(return)-+----->-(loop)--->-+
797 . | Meta Dispatcher |
798 . +----<-----<---<---+
799 . Message---2-->Service B
800 . |
801 . <--Response--3------+
802 . |
803 . +--<--<-----<-----+--(return)---->
804 . | Meta Dispatcher |
805 Service A <--Callback--4---+--->-(loop)-->---+
806 | ^
807 +-------+
808 </pre>
809 </div></div>
810
811 <h3>Test Program</h3>
812
813 <p>
814 There is a test program that sends and receives
815 non-blocking messages in
816 mday 1.3 <code>$(PEGASUS_ROOT)/src/Pegasus/Common/tests/async_callback/</code>
817 </p>
818
819 <h3>SendAsync method</h3>
820
821 <p>
822 The <code>MessageQueueService</code> class sends
823 non-blocking messages using the <code>SendAsync</code>
824 method from <code>MessageQueueService.h</code>.
|
825 mday 1.4 </p><br>
|
826 mday 1.3
|
827 mday 1.1
|
828 mday 1.4 <div class="exampleOuter"><div class="exampleInner">
|
829 mday 1.1 <pre>
|
830 mday 1.4 Boolean <b><font color=#000000>SendAsync</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>op<font color=#990000>,</font>
831 Uint32 destination<font color=#990000>,</font>
832 <font color=#009900>void</font> <font color=#990000>(</font><font color=#990000>*</font>callback<font color=#990000>)</font><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font><font color=#990000>,</font> MessageQueue <font color=#990000>*</font><font color=#990000>,</font> <font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>,</font>
833 MessageQueue <font color=#990000>*</font>callback_q<font color=#990000>,</font>
834 <font color=#009900>void</font> <font
835 color=#990000>*</font>callback_ptr<font color=#990000>)</font><font color=#990000>;</font>
836 </pre>
837 <br>
838 <div class="note">
839 <var>AsyncOpNode *op (In)</var> is the shared data
840 structure that controls the message flow and
841 consolidates the response data. This data structure is
842 also passed to the callback function as the first
843 parameter. The caller must
844 allocate and free this data structure. <br>
845 <br>
846 <var>Uint32 destination (In)</var> is the queue ID of
847 the service which will receive the asynchronous
848 request message.</var><br>
849 <br>
850 <var>void (*callback)(AsyncOpNode *, MessageQueue *,
851 mday 1.4 void *) (In)</var> is the static class method that
852 will be called when the request/response pair is complete.<br>
853 <br>
854 The callback is always passed <var>op</var> as the
855 first parameter. The second parameter is the
856 <var>MessageQueue *</var> object instance that is
857 executing the callback function. Because callback
858 functions must be static class methods, the callback
859 can use the <var>MessageQueue *</var> parameter as a
860 pseudo <var>this</var> pointer. <br>
861 <br>
862 <var>MessageQueue *callback_q (In)</var> is the
863 queue pointer that will be passed to the callback
864 routine as the second parameter. It also controls
865 which queue instance receives the callback.
866 <br>
867 <br>
868 <var>void *callback_ptr (In)</var> is a pointer that will
869 be passed to the callback function.
870
871 </div>
872 mday 1.4 </div></div>
|
873 mday 1.1
|
874 mday 1.4 <br>
|
875 mday 1.1
|
876 mday 1.4 <h3>How the Meta Dispatcher Processes Non-Blocking Messages</h3>
877 <p>
878 The focus of processing non-blocking messages is to
879 remove the possibility of deadlock. Therefore, all
880 message processing is performed by background
881 threads. All access by services to shared data
882 structures is discrete in the sense that one service
883 never calls into another service. For example,
884 callback routines are executed by the background
885 thread of the receiving service. (As opposed to the
886 sending service making a callback <i>into</i> the
887 receiving service.)
888 </p>
|
889 mday 1.1
|
890 mday 1.4 <ol>
891 <li>The requesting service creates a request, an
892 <code>AsyncOpNode</code> and calls
893 <code>MessageQueueService::SendAsync(...)</code>.</li>
894 <li><code>SendAsync</code> marks the
895 <code>AsyncOpNode</code> as
896 <code>ASYNC_OPFLAGS_CALLBACK</code> with the
897 <code>ASYNC_OPSTATE_COMPLETE</code> bit
898 <i>clear</i>.</li> <li>The Meta Dispatcher routes
899 the <code>AsyncOpNode</code> to the responding
900 service.</li> <li>The responding service's
901 background thread pulls the message off its
902 internal queue and processes the request. This
903 will frequently entail creating and inserting a
904 response message into the <code>AsyncOpNode</code>
905 by calling
906 <code>AsyncOpNode::put_response(AsyncMessage
907 *)</code>.</li> <li>The responding service
908 completes the response by calling
909 <code>MessageQueueService::_complete_op_node(AsyncOpNode
910 *, Uint32, Uint32, Uint32)</code>.</li>
911 mday 1.4 <li><code>_complete_op_node</code> passes the
912 operation back to the Meta Dispatcher, which
913 routes it <i>back</i> to the requesting
914 service.</li> <li>The requesting service's
915 background thread pulls the
916 <code>AsyncOpNode</code> off its internal queue
917 and calls
918 <code>AsyncOpNode::_async_callback</code>, which
919 is a function pointer that holds the address of the
920 requesting service's static callback method..</li>
921 <li>The requesting service deallocates the op
922 node, the request message, and the response message.</li>
923 </ol>
|
924 mday 1.1
|
925 mday 1.4 <h3>Virtual Methods for Non-Blocking Messages</h3>
926 <p>
927 To use non-blocking messages, a service should
928 implement the following virtual method from
929 <code>MessageQueueService</code>, plus a static class
930 callback function.
931 </p>
932 <div class="exampleOuter"><div class="exampleInner">
|
933 martin 1.5 <pre><b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>_handle_async_request</font></b><font color=#990000>(</font>AsyncRequest <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
|
934 mday 1.4 </pre>
935 <div class="note">
936 <var>AsyncRequest *req (In)</var> is the incoming
937 request. <code>req->op</code> is the
938 <code>AsyncOpNode</code> that is controlling this
939 operation.
940 <br><br>
941 This method is called by the service's background
942 thread whenever an <code>AsyncRequest</code>
943 message is sent to the service. <i>This includes
944 both blocking and non-blocking request messages.</i><p>
945 <p>
946 Within <code>_handle_async_request</code> you
947 can determine whether the message is blocking or
948 non-blocking by using the following code
949 segment:
950 <pre><code>
951
952 if(req->op->read_flags() & ASYNC_OPFLAGS_CALLBACK )
953 {
954
955 mday 1.4 // let everyone know you are working on the request
956 req->op->processing();
957
958 // this request is part of a callback (non-blocking) operation
959 AsyncResponse *response = new AsyncResponse(...);
960
961 // initialize the response message however is appropriate
|
962 mday 1.1
|
963 mday 1.4 // put the response to the op node
964 req->op->put_response(response);
|
965 mday 1.1
|
966 mday 1.4 // complete the operation
967 _complete_op_node(req->op, 0, 0, async_results::OK);
|
968 mday 1.1
|
969 mday 1.4 return;
970 }
971 </code></pre>
972 </div>
973 </div>
974 </div>
975 <br>
976
977
978 <div class="exampleOuter"><div class = "exampleInner">
979
980 <pre>
981 <b><font color=#0000FF>static</font></b> <font color=#009900>void</font> <b><font color=#000000>async_callback_function</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>op<font color=#990000>,</font> MessageQueue <font color=#990000>*</font><font color=#990000>,</font> <font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>;</font>
982
983 </pre>
984 <div class="note">
985 <var>AsyncOpNode *op (In)</var> is the
986 incoming shared object that is controlling this
987 completing operation.<br>
988 <br>
989 <var>MessageQueue *q (In)</var> is a pointer to
990 mday 1.4 the class that has received the complete
991 <var>op</var>. This parameter is meant to be used
992 as a <code>this</code> pointer because the
993 callback is a static class method.
994 <br>
995 <br>
996 <var>void *parm (In)</var> is a pointer that the
997 class passed to <code>SendAsync</code>. It can be
998 used as a convenience for the class.<br>
999 <br>
1000
1001 This method is <i>only</i> called when a
1002 non-blocking operation is complete, meaning that
1003 the responding service has added a response
1004 message to the <var>op</var> and set the
1005 <code>ASYNC_OPSTATE_COMPLETE</code> bit. <br><br>
1006 <pre>
1007 void my_class::async_callback_function(AsyncOpNode *op,
1008 MessageQueue *q,
1009 void *parm)
1010 {
1011 mday 1.4
1012 my_class *myself = static_cast<my_class *>(q);
1013 AsyncRequest *request = op->get_request();
1014 AsyncResponse *response = op->get_response();
1015
1016 // process response
1017
1018 delete request;
1019 delete response;
1020 myself->put_op(op);
1021 return;
1022 }
|
1023 mday 1.1
|
1024 mday 1.4 </div>
1025 </div>
1026 </div>
|
1027 mday 1.1
|
1028 mday 1.4 <h3>Strategies for Handling Non-Blocking Responses</h3>
1029 <p>
|
1030 martin 1.5 All of the legacy message handling code in Pegasus is syncrhonous, meaning that a service can send a request
|
1031 mday 1.4 and receive the response in two adjacent lines of
1032 code. Non-blocking messages are different because the
1033 timing and existence of a response message is
|
1034 martin 1.5 undetermined. </p>
|
1035 mday 1.4 <p>
1036 There are couple of possible strategies for handing
|
1037 martin 1.5 non-blocking response messages. <ol>
|
1038 mday 1.4 <li>Seperate the request creation and sending code
1039 from the response handling code into distinct methods.</li>
1040 <li>Handle request creation and sending and response
1041 handling in the same method using different code blocks.
1042 </ol>
1043 </p>
|
1044 mday 1.1
|
1045 mday 1.4 <h4>Separate Request and Response Handling Methods</h4>
1046 <div class="exampleOuter">
1047 <div class="exampleInner">
1048 <ol>
1049 <li>Write the request generation method.
1050 <pre>
1051 void my_class::generate_request(Uint32 destination)
1052 {
1053 AsyncOpNode *op = get_op();
1054 my_request *req = new my_request(...);
1055 op->put_request(req);
1056
1057 SendAsync(op, destination, my_callback, this, (void *)0);
1058 return;
1059 }
1060 </pre>
1061 </li>
1062 <li> Write the request handling method.
1063 <pre>
1064 void my_class::handle_response(AsyncOpNode *op)
|
1065 mday 1.1 {
|
1066 mday 1.4 my_response *res = op->get_response();
1067 if(res != 0 )
1068 {
1069 // handle response
1070 delete response;
1071 }
1072 put_op(op);
1073 return;
1074 }
1075 </pre>
1076 </li>
1077 <li> Have your callback method call your response
1078 method.
1079 <pre>
1080 void my_class:my_callback(AsyncOpNode *op, MessageQueue *queue, void *parm)
1081 {
1082 my_class *myself = static_cast<queue>
|
1083 mday 1.1
|
1084 mday 1.4 myself->handle_response(op);
1085 return;
1086 }
1087 </pre>
1088 </li>
1089 </ol>
1090 </div>
1091 </div>
|
1092 mday 1.1
|
1093 mday 1.4
1094 <h4>Singe Request and Response Handling Method</h4>
1095 <p>
1096 This strategy requires two separate code blocks within
1097 the request/response method, and conditional execution
|
1098 martin 1.5 depending on the status of the operation. </p>
|
1099 mday 1.4 <p>
1100 I think the advantage of this strategy is that it
1101 matches more closely the current<br>
1102 <code>handleEnqueue(Message *msg)</code> code
|
1103 martin 1.5 convention that is in Pegasus. </p>
|
1104 mday 1.1
|
1105 mday 1.4 <div class="exampleOuter">
1106 <div class="exampleInner">
1107 <ol>
1108 <li>Write the request generation block.
1109 <pre>
1110 void my_class::handle_operation(AsyncOpNode *op)
|
1111 mday 1.1 {
|
1112 mday 1.4 if(op == NULL)
1113 {
1114 AsyncOpNode *op = get_op();
1115 my_request *req = new my_request(...);
1116 op->put_request(req);
1117
1118 SendAsync(op, destination, my_callback, this, (void *)0);
|
1119 mday 1.1
|
1120 mday 1.4 }
1121 else
1122 {
|
1123 mday 1.1
|
1124 mday 1.4 }
1125 return;
1126 }
1127 </pre>
1128 </li>
1129 <li> Write the request handling block.
1130 <pre>
1131 void my_class::handle_operation(AsyncOpNode *op)
|
1132 mday 1.1 {
|
1133 mday 1.4 if(op == NULL)
1134 {
1135 AsyncOpNode *op = get_op();
1136 my_request *req = new my_request(...);
1137 op->put_request(req);
1138
1139 SendAsync(op, destination, my_callback, this, (void *)0);
1140
1141 }
1142 else
1143 {
1144 my_response *res = op->get_response();
1145 if(res != 0 )
|
1146 mday 1.1 {
|
1147 mday 1.4 // handle response
1148 delete response;
|
1149 mday 1.1 }
|
1150 mday 1.4 put_op(op);
1151 }
1152 return;
1153 }
|
1154 mday 1.1
|
1155 mday 1.4 </pre>
1156 </li>
1157 <li> Have your callback method call your handler
1158 method.
1159 <pre>
1160 void my_class:my_callback(AsyncOpNode *op, MessageQueue *queue, void *parm)
|
1161 mday 1.1 {
|
1162 mday 1.4 my_class *myself = static_cast<queue>
|
1163 mday 1.1
|
1164 mday 1.4 myself->handle_operation(op);
1165 return;
|
1166 mday 1.1 }
|
1167 mday 1.4 </pre>
1168 </li>
1169 </ol>
1170 </div>
1171 </div>
|
1172 mday 1.1
|
1173 mday 1.4 <hr><hr>
|
1174 mday 1.1
|
1175 mday 1.4 <h2>Class Definitions</h2>
|
1176 mday 1.1
|
1177 mday 1.4 <h3>cimom (Meta Dispatcher)</h3>
|
1178 mday 1.1
|
1179 martin 1.5 <pre><tt>
|
1180 martin 1.6 <i><font color=#9A1900>//%LICENSE////////////////////////////////////////////////////////////////</font></i>
|
1181 mday 1.4 <i><font color=#9A1900>//</font></i>
|
1182 martin 1.6 <i><font color=#9A1900>// Licensed to The Open Group (TOG) under one or more contributor license</font></i>
1183 <i><font color=#9A1900>// agreements. Refer to the OpenPegasusNOTICE.txt file distributed with</font></i>
1184 <i><font color=#9A1900>// this work for additional information regarding copyright ownership.</font></i>
1185 <i><font color=#9A1900>// Each contributor licenses this file to you under the OpenPegasus Open</font></i>
1186 <i><font color=#9A1900>// Source License; you may not use this file except in compliance with the</font></i>
1187 <i><font color=#9A1900>// License.</font></i>
1188 <i><font color=#9A1900>//</font></i>
1189 <i><font color=#9A1900>// Permission is hereby granted, free of charge, to any person obtaining a</font></i>
1190 <i><font color=#9A1900>// copy of this software and associated documentation files (the "Software"),</font></i>
1191 <i><font color=#9A1900>// to deal in the Software without restriction, including without limitation</font></i>
1192 <i><font color=#9A1900>// the rights to use, copy, modify, merge, publish, distribute, sublicense,</font></i>
1193 <i><font color=#9A1900>// and/or sell copies of the Software, and to permit persons to whom the</font></i>
1194 <i><font color=#9A1900>// Software is furnished to do so, subject to the following conditions:</font></i>
1195 <i><font color=#9A1900>//</font></i>
1196 <i><font color=#9A1900>// The above copyright notice and this permission notice shall be included</font></i>
1197 <i><font color=#9A1900>// in all copies or substantial portions of the Software.</font></i>
1198 <i><font color=#9A1900>//</font></i>
1199 <i><font color=#9A1900>// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS</font></i>
1200 <i><font color=#9A1900>// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF</font></i>
1201 <i><font color=#9A1900>// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.</font></i>
1202 <i><font color=#9A1900>// IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY</font></i>
1203 martin 1.6 <i><font color=#9A1900>// CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,</font></i>
1204 <i><font color=#9A1900>// TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE</font></i>
1205 <i><font color=#9A1900>// SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.</font></i>
|
1206 mday 1.4 <i><font color=#9A1900>//</font></i>
|
1207 martin 1.6 <i><font color=#9A1900>//////////////////////////////////////////////////////////////////////////</font></i>
|
1208 mday 1.4 <i><font color=#9A1900>//</font></i>
1209 <i><font color=#9A1900>// Author: Mike Day (mdday@us.ibm.com</font></i>
1210 <i><font color=#9A1900>//</font></i>
1211 <i><font color=#9A1900>// Modified By: </font></i>
1212 <i><font color=#9A1900>//</font></i>
|
1213 martin 1.6 <i><font color=#9A1900>//////////////////////////////////////////////////////////////////////////</font></i>
|
1214 mday 1.4
1215 <b><font color=#000080>#ifndef</font></b> CIMOM_include
1216 <b><font color=#000080>#define</font></b> CIMOM_include
1217
1218 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Config.h></font>
1219 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Exception.h></font>
1220 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/MessageQueue.h></font>
1221 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/DQueue.h></font>
1222 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Thread.h></font>
1223 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Array.h></font>
1224 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/AsyncOpNode.h></font>
1225 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/CimomMessage.h></font>
1226 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/MessageQueueService.h></font>
1227
1228 PEGASUS_NAMESPACE_BEGIN
1229
1230 <b><font color=#0000FF>extern</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIMOM_Q_ID<font color=#990000>;</font>
1231
1232 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE module_capabilities
1233 <font color=#FF0000>{</font>
1234 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1235 mday 1.4 <b><font color=#0000FF>static</font></b> Uint32 async<font color=#990000>;</font>
1236 <b><font color=#0000FF>static</font></b> Uint32 remote<font color=#990000>;</font>
1237 <b><font color=#0000FF>static</font></b> Uint32 trusted<font color=#990000>;</font>
1238 <b><font color=#0000FF>static</font></b> Uint32 paused<font color=#990000>;</font>
1239 <b><font color=#0000FF>static</font></b> Uint32 stopped<font color=#990000>;</font>
1240 <font color=#FF0000>}</font> <font color=#990000>;</font>
1241
1242 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE cimom<font color=#990000>;</font>
1243
1244 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE message_module
1245 <font color=#FF0000>{</font>
1246 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1247 <b><font color=#000000>message_module</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1248 <font color=#990000>:</font> <b><font color=#000000>_name</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>,</font> <b><font color=#000000>_capabilities</font></b><font color=#990000>(</font><font color=#993399>0</font><font color=#990000>)</font><font color=#990000>,</font>
1249 <b><font color=#000000>_mask</font></b><font color=#990000>(</font><font color=#993399>0</font><font color=#990000>)</font><font color=#990000>,</font> <b><font color=#000000>_q_id</font></b><font color=#990000>(</font><font color=#993399>0</font><font color=#990000>)</font> <font color=#FF0000>{</font> <font color=#FF0000>}</font>
1250
1251 <b><font color=#000000>message_module</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> String <font color=#990000>&</font> name<font color=#990000>,</font>
1252 Uint32 capabilities<font color=#990000>,</font>
1253 Uint32 mask<font color=#990000>,</font>
1254 Uint32 queue<font color=#990000>)</font>
1255 <font color=#990000>:</font> <b><font color=#000000>_name</font></b><font color=#990000>(</font>name<font color=#990000>)</font><font color=#990000>,</font> <b><font color=#000000>_capabilities</font></b><font color=#990000>(</font>capabilities<font color=#990000>)</font><font color=#990000>,</font>
1256 mday 1.4 <b><font color=#000000>_mask</font></b><font color=#990000>(</font>mask<font color=#990000>)</font><font color=#990000>,</font> <b><font color=#000000>_q_id</font></b><font color=#990000>(</font>queue<font color=#990000>)</font> <font color=#FF0000>{</font> <font color=#FF0000>}</font>
1257
1258 Boolean <b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font><b><font color=#0000FF>const</font></b> message_module <font color=#990000>*</font>mm<font color=#990000>)</font> <b><font color=#0000FF>const</font></b><font color=#990000>;</font>
1259 Boolean <b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font><b><font color=#0000FF>const</font></b> String <font color=#990000>&</font> name <font color=#990000>)</font> <b><font color=#0000FF>const</font></b> <font color=#990000>;</font>
1260 Boolean <b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font><b><font color=#0000FF>const</font></b> message_module <font color=#990000>&</font> mm <font color=#990000>)</font> <b><font color=#0000FF>const</font></b> <font color=#990000>;</font>
1261 Boolean <b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font><b><font color=#0000FF>const</font></b> <font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font> <b><font color=#0000FF>const</font></b><font color=#990000>;</font>
1262 Boolean <b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font>Uint32<font color=#990000>)</font> <b><font color=#0000FF>const</font></b><font color=#990000>;</font>
1263
1264 <b><font color=#0000FF>const</font></b> String <font color=#990000>&</font> <b><font color=#000000>get_name</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>const</font></b> <font color=#990000>;</font>
1265 Uint32 <b><font color=#000000>get_capabilities</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>const</font></b> <font color=#990000>;</font>
1266 Uint32 <b><font color=#000000>get_mask</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>const</font></b> <font color=#990000>;</font>
1267 Uint32 <b><font color=#000000>get_queue</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>const</font></b> <font color=#990000>;</font>
1268
1269 <font color=#009900>void</font> <b><font color=#000000>put_name</font></b><font color=#990000>(</font>String <font color=#990000>&</font> name<font color=#990000>)</font><font color=#990000>;</font>
1270 <font color=#009900>void</font> <b><font color=#000000>put_capabilities</font></b><font color=#990000>(</font>Uint32 capabilities<font color=#990000>)</font><font color=#990000>;</font>
1271 <font color=#009900>void</font> <b><font color=#000000>put_mask</font></b><font color=#990000>(</font>Uint32 mask<font color=#990000>)</font><font color=#990000>;</font>
1272 <font color=#009900>void</font> <b><font color=#000000>put_queue</font></b><font color=#990000>(</font>Uint32 queue<font color=#990000>)</font> <font color=#990000>;</font>
1273
1274 <b><font color=#0000FF>private</font></b><font color=#990000>:</font>
1275 String _name<font color=#990000>;</font>
1276 Uint32 _capabilities<font color=#990000>;</font>
1277 mday 1.4 Uint32 _mask<font color=#990000>;</font>
1278 <b><font color=#0000FF>struct</font></b> timeval _heartbeat<font color=#990000>;</font>
1279
1280
1281 Uint32 _q_id<font color=#990000>;</font>
1282 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> cimom<font color=#990000>;</font>
1283 <font color=#FF0000>}</font><font color=#990000>;</font>
1284
1285 <b><font color=#0000FF>class</font></b> MessageQueueService<font color=#990000>;</font>
1286
1287
1288 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE cimom <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> MessageQueue
1289 <font color=#FF0000>{</font>
1290 <b><font color=#0000FF>public</font></b> <font color=#990000>:</font>
1291 <b><font color=#000000>cimom</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
|
1292 mday 1.1
|
1293 mday 1.4 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>cimom</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>;</font>
|
1294 mday 1.1
|
1295 mday 1.4 Boolean <b><font color=#000000>moduleChange</font></b><font color=#990000>(</font><b><font color=#0000FF>struct</font></b> timeval last<font color=#990000>)</font><font color=#990000>;</font>
|
1296 mday 1.1
|
1297 mday 1.4 Uint32 <b><font color=#000000>getModuleCount</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
1298 Uint32 <b><font color=#000000>getModuleIDs</font></b><font color=#990000>(</font>Uint32 <font color=#990000>*</font>ids<font color=#990000>,</font> Uint32 count<font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
|
1299 mday 1.1
|
1300 mday 1.4 AsyncOpNode <font color=#990000>*</font><b><font color=#000000>get_cached_op</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
1301 <font color=#009900>void</font> <b><font color=#000000>cache_op</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>op<font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
1302
1303 <font color=#009900>void</font> <b><font color=#000000>set_default_op_timeout</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> <b><font color=#0000FF>struct</font></b> timeval <font color=#990000>*</font>buffer<font color=#990000>)</font><font color=#990000>;</font>
1304 <font color=#009900>void</font> <b><font color=#000000>get_default_op_timeout</font></b><font color=#990000>(</font><b><font color=#0000FF>struct</font></b> timeval <font color=#990000>*</font>timeout<font color=#990000>)</font> <b><font color=#0000FF>const</font></b> <font color=#990000>;</font>
|
1305 mday 1.1
|
1306 mday 1.4 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handleEnqueue</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
1307 <font color=#009900>void</font> <b><font color=#000000>register_module</font></b><font color=#990000>(</font>RegisterCimService <font color=#990000>*</font>msg<font color=#990000>)</font><font color=#990000>;</font>
1308 <font color=#009900>void</font> <b><font color=#000000>deregister_module</font></b><font color=#990000>(</font>Uint32 quid<font color=#990000>)</font><font color=#990000>;</font>
1309 <font color=#009900>void</font> <b><font color=#000000>update_module</font></b><font color=#990000>(</font>UpdateCimService <font color=#990000>*</font>msg <font color=#990000>)</font><font color=#990000>;</font>
1310 <font color=#009900>void</font> <b><font color=#000000>ioctl</font></b><font color=#990000>(</font>AsyncIoctl <font color=#990000>*</font>msg <font color=#990000>)</font><font color=#990000>;</font>
1311
1312 <font color=#009900>void</font> <b><font color=#000000>find_service_q</font></b><font color=#990000>(</font>FindServiceQueue <font color=#990000>*</font>msg <font color=#990000>)</font><font color=#990000>;</font>
1313 <font color=#009900>void</font> <b><font color=#000000>enumerate_service</font></b><font color=#990000>(</font>EnumerateService <font color=#990000>*</font>msg <font color=#990000>)</font><font color=#990000>;</font>
1314 Boolean <b><font color=#000000>route_async</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>)</font><font color=#990000>;</font>
1315 <font color=#009900>void</font> <b><font color=#000000>_shutdown_routed_queue</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
|
1316 mday 1.1
|
1317 mday 1.4
1318 <b><font color=#0000FF>protected</font></b><font color=#990000>:</font>
1319 Uint32 <b><font color=#000000>get_module_q</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> String <font color=#990000>&</font> name<font color=#990000>)</font><font color=#990000>;</font>
1320 <b><font color=#0000FF>static</font></b> <font color=#009900>void</font> <b><font color=#000000>_make_response</font></b><font color=#990000>(</font>Message <font color=#990000>*</font>req<font color=#990000>,</font> Uint32 code<font color=#990000>)</font><font color=#990000>;</font>
1321 <b><font color=#0000FF>static</font></b> <font color=#009900>void</font> <b><font color=#000000>_completeAsyncResponse</font></b><font color=#990000>(</font>AsyncRequest <font color=#990000>*</font>request<font color=#990000>,</font>
1322 AsyncReply <font color=#990000>*</font>reply<font color=#990000>,</font>
1323 Uint32 state<font color=#990000>,</font>
1324 Uint32 flag<font color=#990000>)</font><font color=#990000>;</font>
1325 <b><font color=#0000FF>static</font></b> <font color=#009900>void</font> <b><font color=#000000>_complete_op_node</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>op<font color=#990000>,</font> Uint32 state<font color=#990000>,</font> Uint32 flag<font color=#990000>,</font> Uint32 code<font color=#990000>)</font><font color=#990000>;</font>
1326 <b><font color=#0000FF>static</font></b> <font color=#009900>void</font> <b><font color=#000000>_default_callback</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font><font color=#990000>,</font> MessageQueue <font color=#990000>*</font><font color=#990000>,</font> <font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>;</font>
|
1327 mday 1.1
|
1328 mday 1.4 <b><font color=#0000FF>private</font></b><font color=#990000>:</font>
1329 <b><font color=#0000FF>struct</font></b> timeval _default_op_timeout<font color=#990000>;</font>
1330 <b><font color=#0000FF>struct</font></b> timeval _last_module_change<font color=#990000>;</font>
1331 DQueue<font color=#FF0000><message_module></font> _modules<font color=#990000>;</font>
|
1332 mday 1.1
|
1333 mday 1.4 DQueue<font color=#FF0000><AsyncOpNode></font> _recycle<font color=#990000>;</font>
|
1334 mday 1.1
|
1335 mday 1.4 AsyncDQueue<font color=#FF0000><AsyncOpNode></font> _routed_ops<font color=#990000>;</font>
1336 DQueue<font color=#FF0000><AsyncOpNode></font> _internal_ops<font color=#990000>;</font>
|
1337 mday 1.1
|
1338 mday 1.4 <b><font color=#0000FF>static</font></b> PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL <b><font color=#000000>_routing_proc</font></b><font color=#990000>(</font><font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>;</font>
|
1339 mday 1.1
|
1340 mday 1.4 Thread _routing_thread<font color=#990000>;</font>
|
1341 mday 1.1
|
1342 mday 1.4 <b><font color=#0000FF>static</font></b> Uint32 <b><font color=#000000>get_xid</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
1343 <font color=#009900>void</font> <b><font color=#000000>_handle_cimom_op</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>op<font color=#990000>,</font> Thread <font color=#990000>*</font>thread<font color=#990000>,</font> MessageQueue <font color=#990000>*</font>queue<font color=#990000>)</font><font color=#990000>;</font>
1344 Uint32 <b><font color=#000000>_ioctl</font></b><font color=#990000>(</font>Uint32<font color=#990000>,</font> Uint32<font color=#990000>,</font> <font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>;</font>
|
1345 mday 1.1
1346
|
1347 mday 1.4 AtomicInt _die<font color=#990000>;</font>
1348 AtomicInt _routed_queue_shutdown<font color=#990000>;</font>
|
1349 mday 1.1
|
1350 mday 1.4 <b><font color=#0000FF>static</font></b> AtomicInt _xid<font color=#990000>;</font>
1351 <b><font color=#0000FF>static</font></b> cimom <font color=#990000>*</font>_global_this<font color=#990000>;</font>
|
1352 mday 1.1
|
1353 mday 1.4 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> MessageQueueService<font color=#990000>;</font>
|
1354 mday 1.1
|
1355 mday 1.4 <font color=#FF0000>}</font><font color=#990000>;</font>
1356
1357 PEGASUS_NAMESPACE_END
|
1358 mday 1.1
|
1359 mday 1.4 <b><font color=#000080>#endif</font></b> <i><font color=#9A1900>// CIMOM_include</font></i>
1360 </tt>
1361 </pre>
|
1362 mday 1.1
|
1363 mday 1.4 <h3>MessageQueueService</h3>
|
1364 mday 1.1
|
1365 martin 1.5 <pre><tt>
|
1366 martin 1.6 <i><font color=#9A1900>//%LICENSE////////////////////////////////////////////////////////////////</font></i>
|
1367 mday 1.4 <i><font color=#9A1900>//</font></i>
|
1368 martin 1.6 <i><font color=#9A1900>// Licensed to The Open Group (TOG) under one or more contributor license</font></i>
1369 <i><font color=#9A1900>// agreements. Refer to the OpenPegasusNOTICE.txt file distributed with</font></i>
1370 <i><font color=#9A1900>// this work for additional information regarding copyright ownership.</font></i>
1371 <i><font color=#9A1900>// Each contributor licenses this file to you under the OpenPegasus Open</font></i>
1372 <i><font color=#9A1900>// Source License; you may not use this file except in compliance with the</font></i>
1373 <i><font color=#9A1900>// License.</font></i>
1374 <i><font color=#9A1900>//</font></i>
1375 <i><font color=#9A1900>// Permission is hereby granted, free of charge, to any person obtaining a</font></i>
1376 <i><font color=#9A1900>// copy of this software and associated documentation files (the "Software"),</font></i>
1377 <i><font color=#9A1900>// to deal in the Software without restriction, including without limitation</font></i>
1378 <i><font color=#9A1900>// the rights to use, copy, modify, merge, publish, distribute, sublicense,</font></i>
1379 <i><font color=#9A1900>// and/or sell copies of the Software, and to permit persons to whom the</font></i>
1380 <i><font color=#9A1900>// Software is furnished to do so, subject to the following conditions:</font></i>
1381 <i><font color=#9A1900>//</font></i>
1382 <i><font color=#9A1900>// The above copyright notice and this permission notice shall be included</font></i>
1383 <i><font color=#9A1900>// in all copies or substantial portions of the Software.</font></i>
1384 <i><font color=#9A1900>//</font></i>
1385 <i><font color=#9A1900>// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS</font></i>
1386 <i><font color=#9A1900>// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF</font></i>
1387 <i><font color=#9A1900>// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.</font></i>
1388 <i><font color=#9A1900>// IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY</font></i>
1389 martin 1.6 <i><font color=#9A1900>// CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,</font></i>
1390 <i><font color=#9A1900>// TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE</font></i>
1391 <i><font color=#9A1900>// SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.</font></i>
|
1392 mday 1.4 <i><font color=#9A1900>//</font></i>
|
1393 martin 1.6 <i><font color=#9A1900>//////////////////////////////////////////////////////////////////////////</font></i>
|
1394 mday 1.4 <i><font color=#9A1900>//</font></i>
|
1395 martin 1.6 <i><font color=#9A1900>// Author: Mike Day (mdday@us.ibm.com</font></i>
|
1396 mday 1.4 <i><font color=#9A1900>//</font></i>
|
1397 martin 1.6 <i><font color=#9A1900>// Modified By: </font></i>
|
1398 mday 1.4 <i><font color=#9A1900>//</font></i>
|
1399 martin 1.6 <i><font color=#9A1900>//////////////////////////////////////////////////////////////////////////</font></i>
|
1400 mday 1.4
1401 <b><font color=#000080>#ifndef</font></b> Pegasus_MessageQueue_Service_h
1402 <b><font color=#000080>#define</font></b> Pegasus_MessageQueue_Service_h
1403
1404 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Config.h></font>
1405 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Message.h></font>
1406 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Exception.h></font>
1407 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/IPC.h></font>
1408 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Thread.h></font>
1409 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/AsyncOpNode.h></font>
1410 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Cimom.h></font>
1411 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/CimomMessage.h></font>
1412
1413 PEGASUS_NAMESPACE_BEGIN
1414
1415 <b><font color=#0000FF>extern</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIMOM_Q_ID<font color=#990000>;</font>
1416
1417 <b><font color=#0000FF>class</font></b> message_module<font color=#990000>;</font>
1418
1419 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE MessageQueueService <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> MessageQueue
1420 <font color=#FF0000>{</font>
1421 mday 1.4 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1422
1423 <b><font color=#0000FF>typedef</font></b> MessageQueue Base<font color=#990000>;</font>
1424
1425 <b><font color=#000000>MessageQueueService</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> <font color=#009900>char</font> <font color=#990000>*</font>name<font color=#990000>,</font> Uint32 queueID<font color=#990000>,</font>
1426 Uint32 capabilities <font color=#990000>=</font> <font color=#993399>0</font><font color=#990000>,</font>
1427 Uint32 mask <font color=#990000>=</font> message_mask<font color=#990000>:</font><font color=#990000>:</font>type_cimom <font color=#990000>|</font>
1428 message_mask<font color=#990000>:</font><font color=#990000>:</font>type_service <font color=#990000>|</font>
1429 message_mask<font color=#990000>:</font><font color=#990000>:</font>ha_request <font color=#990000>|</font>
1430 message_mask<font color=#990000>:</font><font color=#990000>:</font>ha_reply <font color=#990000>|</font>
1431 message_mask<font color=#990000>:</font><font color=#990000>:</font>ha_async <font color=#990000>)</font> <font color=#990000>;</font>
1432
1433 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>MessageQueueService</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
1434
1435 <b><font color=#0000FF>virtual</font></b> Boolean <b><font color=#000000>isAsync</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#FF0000>{</font> <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>true</font></b><font color=#990000>;</font> <font color=#FF0000>}</font>
1436
1437 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>enqueue</font></b><font color=#990000>(</font>Message <font color=#990000>*</font><font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
|
1438 mday 1.1
|
1439 mday 1.4 AsyncReply <font color=#990000>*</font><b><font color=#000000>SendWait</font></b><font color=#990000>(</font>AsyncRequest <font color=#990000>*</font>request<font color=#990000>)</font><font color=#990000>;</font>
1440 Boolean <b><font color=#000000>SendAsync</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>op<font color=#990000>,</font>
1441 Uint32 destination<font color=#990000>,</font>
1442 <font color=#009900>void</font> <font color=#990000>(</font><font color=#990000>*</font>callback<font color=#990000>)</font><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font><font color=#990000>,</font> MessageQueue <font color=#990000>*</font><font color=#990000>,</font> <font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>,</font>
1443 MessageQueue <font color=#990000>*</font>callback_q<font color=#990000>,</font>
1444 <font color=#009900>void</font> <font color=#990000>*</font>callback_ptr<font color=#990000>)</font><font color=#990000>;</font>
1445 Boolean <b><font color=#000000>SendForget</font></b><font color=#990000>(</font>Message <font color=#990000>*</font>msg<font color=#990000>)</font><font color=#990000>;</font>
1446 Boolean <b><font color=#000000>ForwardOp</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font><font color=#990000>,</font> Uint32 destination<font color=#990000>)</font><font color=#990000>;</font>
1447
1448
1449 Boolean <b><font color=#000000>register_service</font></b><font color=#990000>(</font>String name<font color=#990000>,</font> Uint32 capabilities<font color=#990000>,</font> Uint32 mask<font color=#990000>)</font><font color=#990000>;</font>
1450 Boolean <b><font color=#000000>update_service</font></b><font color=#990000>(</font>Uint32 capabilities<font color=#990000>,</font> Uint32 mask<font color=#990000>)</font><font color=#990000>;</font>
1451 Boolean <b><font color=#000000>deregister_service</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
1452 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>_shutdown_incoming_queue</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
1453
1454 <font color=#009900>void</font> <b><font color=#000000>find_services</font></b><font color=#990000>(</font>String name<font color=#990000>,</font>
1455 Uint32 capabilities<font color=#990000>,</font>
1456 Uint32 mask<font color=#990000>,</font>
1457 Array<font color=#FF0000><Uint32></font> <font color=#990000>*</font>results<font color=#990000>)</font><font color=#990000>;</font>
1458 <font color=#009900>void</font> <b><font color=#000000>enumerate_service</font></b><font color=#990000>(</font>Uint32 queue<font color=#990000>,</font> message_module <font color=#990000>*</font>result<font color=#990000>)</font><font color=#990000>;</font>
1459 Uint32 <b><font color=#000000>get_next_xid</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
1460 mday 1.4 AsyncOpNode <font color=#990000>*</font><b><font color=#000000>get_op</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
1461 <font color=#009900>void</font> <b><font color=#000000>return_op</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>op<font color=#990000>)</font><font color=#990000>;</font>
1462
1463 Uint32 _mask<font color=#990000>;</font>
1464 AtomicInt _die<font color=#990000>;</font>
1465 <b><font color=#0000FF>protected</font></b><font color=#990000>:</font>
1466 <b><font color=#0000FF>virtual</font></b> Boolean <b><font color=#000000>accept_async</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>op<font color=#990000>)</font><font color=#990000>;</font>
1467 <b><font color=#0000FF>virtual</font></b> Boolean <b><font color=#000000>messageOK</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> Message <font color=#990000>*</font>msg<font color=#990000>)</font> <font color=#990000>;</font>
1468 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handleEnqueue</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>=</font> <font color=#993399>0</font><font color=#990000>;</font>
1469 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handleEnqueue</font></b><font color=#990000>(</font>Message <font color=#990000>*</font><font color=#990000>)</font> <font color=#990000>=</font> <font color=#993399>0</font><font color=#990000>;</font>
1470 Boolean <b><font color=#000000>_enqueueResponse</font></b><font color=#990000>(</font>Message <font color=#990000>*</font><font color=#990000>,</font> Message <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>;</font>
1471 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>_handle_incoming_operation</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>;</font>
1472
1473 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>_handle_async_request</font></b><font color=#990000>(</font>AsyncRequest <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
1474 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>_handle_async_callback</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>)</font><font color=#990000>;</font>
1475 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>_make_response</font></b><font color=#990000>(</font>Message <font color=#990000>*</font>req<font color=#990000>,</font> Uint32 code<font color=#990000>)</font><font color=#990000>;</font>
1476
1477
1478 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_heartbeat_request</font></b><font color=#990000>(</font>AsyncRequest <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
1479 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_heartbeat_reply</font></b><font color=#990000>(</font>AsyncReply <font color=#990000>*</font>rep<font color=#990000>)</font><font color=#990000>;</font>
1480
1481 mday 1.4 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_AsyncIoctl</font></b><font color=#990000>(</font>AsyncIoctl <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
1482 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_CimServiceStart</font></b><font color=#990000>(</font>CimServiceStart <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
1483 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_CimServiceStop</font></b><font color=#990000>(</font>CimServiceStop <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
1484 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_CimServicePause</font></b><font color=#990000>(</font>CimServicePause <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
1485 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_CimServiceResume</font></b><font color=#990000>(</font>CimServiceResume <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
1486
1487 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_AsyncOperationStart</font></b><font color=#990000>(</font>AsyncOperationStart <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
1488 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_AsyncOperationResult</font></b><font color=#990000>(</font>AsyncOperationResult <font color=#990000>*</font>rep<font color=#990000>)</font><font color=#990000>;</font>
1489 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_AsyncLegacyOperationStart</font></b><font color=#990000>(</font>AsyncLegacyOperationStart <font color=#990000>*</font>req<font color=#990000>)</font><font color=#990000>;</font>
1490 <b><font color=#0000FF>virtual</font></b> <font color=#009900>void</font> <b><font color=#000000>handle_AsyncLegacyOperationResult</font></b><font color=#990000>(</font>AsyncLegacyOperationResult <font color=#990000>*</font>rep<font color=#990000>)</font><font color=#990000>;</font>
1491
1492 <font color=#009900>void</font> <b><font color=#000000>_completeAsyncResponse</font></b><font color=#990000>(</font>AsyncRequest <font color=#990000>*</font>request<font color=#990000>,</font>
1493 AsyncReply <font color=#990000>*</font>reply<font color=#990000>,</font>
1494 Uint32 state<font color=#990000>,</font>
1495 Uint32 flag<font color=#990000>)</font><font color=#990000>;</font>
1496 <font color=#009900>void</font> <b><font color=#000000>_complete_op_node</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font><font color=#990000>,</font> Uint32<font color=#990000>,</font> Uint32<font color=#990000>,</font> Uint32<font color=#990000>)</font><font color=#990000>;</font>
1497
1498
1499 <b><font color=#0000FF>static</font></b> cimom <font color=#990000>*</font>_meta_dispatcher<font color=#990000>;</font>
1500 <b><font color=#0000FF>static</font></b> AtomicInt _service_count<font color=#990000>;</font>
1501 <b><font color=#0000FF>static</font></b> Mutex _meta_dispatcher_mutex<font color=#990000>;</font>
1502 mday 1.4
1503 <b><font color=#0000FF>private</font></b><font color=#990000>:</font>
1504
1505 DQueue<font color=#FF0000><AsyncOpNode></font> _pending<font color=#990000>;</font>
1506 AsyncDQueue<font color=#FF0000><AsyncOpNode></font> _incoming<font color=#990000>;</font>
1507 AsyncDQueue<font color=#FF0000><AsyncOpNode></font> _callback<font color=#990000>;</font>
1508
1509 <b><font color=#0000FF>static</font></b> PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL <b><font color=#000000>_req_proc</font></b><font color=#990000>(</font><font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>;</font>
1510 <b><font color=#0000FF>static</font></b> <font color=#009900>void</font> <b><font color=#000000>_sendwait_callback</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font><font color=#990000>,</font> MessageQueue <font color=#990000>*</font><font color=#990000>,</font> <font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>;</font>
1511 AtomicInt _incoming_queue_shutdown<font color=#990000>;</font>
1512 Thread _req_thread<font color=#990000>;</font>
1513 <b><font color=#0000FF>struct</font></b> timeval _default_op_timeout<font color=#990000>;</font>
1514 <b><font color=#0000FF>static</font></b> AtomicInt _xid<font color=#990000>;</font>
1515 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> cimom<font color=#990000>;</font>
1516 <font color=#FF0000>}</font><font color=#990000>;</font>
|
1517 mday 1.1
|
1518 mday 1.4 PEGASUS_NAMESPACE_END
|
1519 mday 1.1
|
1520 mday 1.4 <b><font color=#000080>#endif</font></b> <i><font color=#9A1900>/* Pegasus_MessageQueue_Service_h */</font></i>
1521 </tt>
1522 </pre>
|
1523 mday 1.1
|
1524 mday 1.4 <h3>Asynchronous Messages</h3>
|
1525 mday 1.1
|
1526 martin 1.5 <pre><tt>
|
1527 martin 1.6 <i><font color=#9A1900>//%LICENSE////////////////////////////////////////////////////////////////</font></i>
1528 <i><font color=#9A1900>//</font></i>
1529 <i><font color=#9A1900>// Licensed to The Open Group (TOG) under one or more contributor license</font></i>
1530 <i><font color=#9A1900>// agreements. Refer to the OpenPegasusNOTICE.txt file distributed with</font></i>
1531 <i><font color=#9A1900>// this work for additional information regarding copyright ownership.</font></i>
1532 <i><font color=#9A1900>// Each contributor licenses this file to you under the OpenPegasus Open</font></i>
1533 <i><font color=#9A1900>// Source License; you may not use this file except in compliance with the</font></i>
1534 <i><font color=#9A1900>// License.</font></i>
1535 <i><font color=#9A1900>//</font></i>
1536 <i><font color=#9A1900>// Permission is hereby granted, free of charge, to any person obtaining a</font></i>
1537 <i><font color=#9A1900>// copy of this software and associated documentation files (the "Software"),</font></i>
1538 <i><font color=#9A1900>// to deal in the Software without restriction, including without limitation</font></i>
1539 <i><font color=#9A1900>// the rights to use, copy, modify, merge, publish, distribute, sublicense,</font></i>
1540 <i><font color=#9A1900>// and/or sell copies of the Software, and to permit persons to whom the</font></i>
1541 <i><font color=#9A1900>// Software is furnished to do so, subject to the following conditions:</font></i>
1542 <i><font color=#9A1900>//</font></i>
1543 <i><font color=#9A1900>// The above copyright notice and this permission notice shall be included</font></i>
1544 <i><font color=#9A1900>// in all copies or substantial portions of the Software.</font></i>
1545 <i><font color=#9A1900>//</font></i>
1546 <i><font color=#9A1900>// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS</font></i>
1547 <i><font color=#9A1900>// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF</font></i>
1548 martin 1.6 <i><font color=#9A1900>// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.</font></i>
1549 <i><font color=#9A1900>// IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY</font></i>
1550 <i><font color=#9A1900>// CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,</font></i>
1551 <i><font color=#9A1900>// TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE</font></i>
1552 <i><font color=#9A1900>// SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.</font></i>
|
1553 mday 1.4 <i><font color=#9A1900>//</font></i>
|
1554 martin 1.6 <i><font color=#9A1900>//////////////////////////////////////////////////////////////////////////</font></i>
|
1555 mday 1.4 <i><font color=#9A1900>//</font></i>
|
1556 martin 1.6 <i><font color=#9A1900>// Author: Mike Day (mdday@us.ibm.com</font></i>
1557 <i><font color=#9A1900>//</font></i>
1558 <i><font color=#9A1900>// Modified By: </font></i>
1559 <i><font color=#9A1900>//</font></i>
1560 <i><font color=#9A1900>//////////////////////////////////////////////////////////////////////////</font></i>
|
1561 mday 1.4
1562 <b><font color=#000080>#ifndef</font></b> Pegasus_CimomMessage_h
1563 <b><font color=#000080>#define</font></b> Pegasus_CimomMessage_h
1564
1565 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Config.h></font>
1566 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Exception.h></font>
1567 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/MessageQueue.h></font>
1568 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/AsyncOpNode.h></font>
1569
1570 PEGASUS_NAMESPACE_BEGIN
1571 <i><font color=#9A1900>//</font></i>
1572 <i><font color=#9A1900>// This identifier is the queue id for CIMOM queue. It is initialized in</font></i>
1573 <i><font color=#9A1900>// CimomMessage.cpp by calling MessageQueue::getNextQueueId(). Note that</font></i>
1574 <i><font color=#9A1900>// this value is passed in the constructor for the CIMOM queue.</font></i>
1575 <i><font color=#9A1900>//</font></i>
1576 <b><font color=#0000FF>extern</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIMOM_Q_ID<font color=#990000>;</font>
1577
1578 <b><font color=#0000FF>class</font></b> AsyncOpNode<font color=#990000>;</font>
1579
1580 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE async_results
1581 <font color=#FF0000>{</font>
1582 mday 1.4 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1583 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 OK<font color=#990000>;</font>
1584 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 PARAMETER_ERROR<font color=#990000>;</font>
1585 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 MODULE_ALREADY_REGISTERED<font color=#990000>;</font>
1586 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 MODULE_NOT_FOUND<font color=#990000>;</font>
1587 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 INTERNAL_ERROR<font color=#990000>;</font>
1588
1589 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_STARTED<font color=#990000>;</font>
1590 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_PROCESSING<font color=#990000>;</font>
1591 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_COMPLETE<font color=#990000>;</font>
1592 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_CANCELLED<font color=#990000>;</font>
1593 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_PAUSED<font color=#990000>;</font>
1594 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_RESUMED<font color=#990000>;</font>
1595
1596 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIM_SERVICE_STARTED<font color=#990000>;</font>
1597 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIM_SERVICE_STOPPED<font color=#990000>;</font>
1598 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIM_SERVICE_PAUSED<font color=#990000>;</font>
1599
1600 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIM_SERVICE_RESUMED<font color=#990000>;</font>
1601 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIM_NAK<font color=#990000>;</font>
1602
1603 mday 1.4 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_PHASE_COMPLETE<font color=#990000>;</font>
1604 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_CHILD_COMPLETE<font color=#990000>;</font>
1605 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_PHASE_STARTED<font color=#990000>;</font>
1606 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_CHILD_STARTED<font color=#990000>;</font>
1607 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIM_PAUSED<font color=#990000>;</font>
1608 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIM_STOPPED<font color=#990000>;</font>
1609
1610 <font color=#FF0000>}</font><font color=#990000>;</font>
1611
1612
1613 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE async_messages
1614 <font color=#FF0000>{</font>
1615 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1616 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 HEARTBEAT<font color=#990000>;</font>
1617 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 REPLY<font color=#990000>;</font>
1618 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 REGISTER_CIM_SERVICE<font color=#990000>;</font>
1619 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 DEREGISTER_CIM_SERVICE<font color=#990000>;</font>
1620 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 UPDATE_CIM_SERVICE<font color=#990000>;</font>
1621 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 IOCTL<font color=#990000>;</font>
1622 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIMSERVICE_START<font color=#990000>;</font>
1623 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIMSERVICE_STOP<font color=#990000>;</font>
1624 mday 1.4 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIMSERVICE_PAUSE<font color=#990000>;</font>
1625 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 CIMSERVICE_RESUME<font color=#990000>;</font>
1626
1627 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_OP_START<font color=#990000>;</font>
1628 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_OP_RESULT<font color=#990000>;</font>
1629 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_LEGACY_OP_START<font color=#990000>;</font>
1630 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ASYNC_LEGACY_OP_RESULT<font color=#990000>;</font>
1631
1632 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 FIND_SERVICE_Q<font color=#990000>;</font>
1633 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 FIND_SERVICE_Q_RESULT<font color=#990000>;</font>
1634 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ENUMERATE_SERVICE<font color=#990000>;</font>
1635 <b><font color=#0000FF>static</font></b> <b><font color=#0000FF>const</font></b> Uint32 ENUMERATE_SERVICE_RESULT<font color=#990000>;</font>
1636 <font color=#FF0000>}</font><font color=#990000>;</font>
1637
1638
1639 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE AsyncMessage <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> Message
1640 <font color=#FF0000>{</font>
1641 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1642 <b><font color=#000000>AsyncMessage</font></b><font color=#990000>(</font>Uint32 type<font color=#990000>,</font>
1643 Uint32 destination<font color=#990000>,</font>
1644 Uint32 key<font color=#990000>,</font>
1645 mday 1.4 Uint32 routing<font color=#990000>,</font>
1646 Uint32 mask<font color=#990000>,</font>
1647 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>)</font><font color=#990000>;</font>
1648
1649 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>AsyncMessage</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1650 <font color=#FF0000>{</font>
1651
1652 <font color=#FF0000>}</font>
|
1653 mday 1.1
|
1654 mday 1.4 Boolean <b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font><font color=#990000>(</font><b><font color=#0000FF>const</font></b> <font color=#009900>void</font> <font color=#990000>*</font>key<font color=#990000>)</font><font color=#990000>;</font>
1655 Boolean <b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font><font color=#990000>(</font><b><font color=#0000FF>const</font></b> AsyncMessage<font color=#990000>&</font> msg<font color=#990000>)</font><font color=#990000>;</font>
|
1656 mday 1.1
|
1657 mday 1.4 AsyncOpNode <font color=#990000>*</font>op<font color=#990000>;</font>
1658 <font color=#FF0000>}</font><font color=#990000>;</font>
|
1659 mday 1.1
1660
|
1661 mday 1.4 <b><font color=#0000FF>inline</font></b> Boolean AsyncMessage<font color=#990000>:</font><font color=#990000>:</font><b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font><font color=#990000>(</font><b><font color=#0000FF>const</font></b> <font color=#009900>void</font> <font color=#990000>*</font>key<font color=#990000>)</font>
1662 <font color=#FF0000>{</font>
1663 <b><font color=#0000FF>if</font></b><font color=#990000>(</font> key <font color=#990000>=</font><font color=#990000>=</font> <b><font color=#0000FF>reinterpret_cast</font></b><font color=#990000><</font><font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>></font><font color=#990000>(</font><b><font color=#0000FF>this</font></b><font color=#990000>)</font><font color=#990000>)</font>
1664 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>true</font></b><font color=#990000>;</font>
1665 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>false</font></b><font color=#990000>;</font>
1666 <font color=#FF0000>}</font>
|
1667 mday 1.1
|
1668 mday 1.4 <b><font color=#0000FF>inline</font></b> Boolean AsyncMessage<font color=#990000>:</font><font color=#990000>:</font><b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font><font color=#990000>(</font><b><font color=#0000FF>const</font></b> AsyncMessage<font color=#990000>&</font> msg<font color=#990000>)</font>
1669 <font color=#FF0000>{</font>
1670 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>this</font></b><font color=#990000>-</font><font color=#990000>></font><b><font color=#0000FF>operator</font></b><font color=#990000>=</font><font color=#990000>=</font><font color=#990000>(</font><b><font color=#0000FF>reinterpret_cast</font></b><font color=#990000><</font><font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>></font><font color=#990000>(</font><b><font color=#0000FF>const_cast</font></b><font color=#990000><</font>AsyncMessage <font color=#990000>*</font><font color=#990000>></font><font color=#990000>(</font><font color=#990000>&</font>msg<font color=#990000>)</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
1671 <font color=#FF0000>}</font>
|
1672 mday 1.1
1673
|
1674 mday 1.4 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE AsyncRequest <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncMessage
1675 <font color=#FF0000>{</font>
1676 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1677 <b><font color=#000000>AsyncRequest</font></b><font color=#990000>(</font>Uint32 type<font color=#990000>,</font>
1678 Uint32 key<font color=#990000>,</font>
1679 Uint32 routing<font color=#990000>,</font>
1680 Uint32 mask<font color=#990000>,</font>
1681 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1682 Uint32 destination<font color=#990000>,</font>
1683 Uint32 response<font color=#990000>,</font>
1684 Boolean blocking<font color=#990000>)</font><font color=#990000>;</font>
|
1685 mday 1.1
1686
|
1687 mday 1.4 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>AsyncRequest</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1688 <font color=#FF0000>{</font>
|
1689 mday 1.1
|
1690 mday 1.4 <font color=#FF0000>}</font>
1691
1692 Uint32 resp<font color=#990000>;</font>
1693 Boolean block<font color=#990000>;</font>
1694 <font color=#FF0000>}</font><font color=#990000>;</font>
1695
1696 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE AsyncReply <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncMessage
1697 <font color=#FF0000>{</font>
1698 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1699 <b><font color=#000000>AsyncReply</font></b><font color=#990000>(</font>Uint32 type<font color=#990000>,</font>
1700 Uint32 key<font color=#990000>,</font>
1701 Uint32 routing<font color=#990000>,</font>
1702 Uint32 mask<font color=#990000>,</font>
1703 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1704 Uint32 result_code<font color=#990000>,</font>
1705 Uint32 destination<font color=#990000>,</font>
1706 Boolean blocking<font color=#990000>)</font><font color=#990000>;</font>
|
1707 mday 1.1
1708
|
1709 mday 1.4 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>AsyncReply</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1710 <font color=#FF0000>{</font>
1711
1712 <font color=#FF0000>}</font>
1713
1714 Uint32 result<font color=#990000>;</font>
1715 Boolean block<font color=#990000>;</font>
1716 <font color=#FF0000>}</font><font color=#990000>;</font>
1717
1718
1719
1720 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE RegisterCimService <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1721 <font color=#FF0000>{</font>
1722 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1723 <b><font color=#000000>RegisterCimService</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1724 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1725 Boolean blocking<font color=#990000>,</font>
1726 String service_name<font color=#990000>,</font>
1727 Uint32 service_capabilities<font color=#990000>,</font>
1728 Uint32 service_mask<font color=#990000>,</font>
1729 Uint32 service_queue<font color=#990000>)</font><font color=#990000>;</font>
1730 mday 1.4
1731 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>RegisterCimService</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1732 <font color=#FF0000>{</font>
1733
1734 <font color=#FF0000>}</font>
1735
1736 String name<font color=#990000>;</font>
1737 Uint32 capabilities<font color=#990000>;</font>
1738 Uint32 mask<font color=#990000>;</font>
1739 Uint32 queue<font color=#990000>;</font>
1740 <font color=#FF0000>}</font><font color=#990000>;</font>
1741
1742 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE DeRegisterCimService <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1743 <font color=#FF0000>{</font>
1744 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1745 <b><font color=#000000>DeRegisterCimService</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1746 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1747 Boolean blocking<font color=#990000>,</font>
1748 Uint32 service_queue<font color=#990000>)</font><font color=#990000>;</font>
1749
1750
1751 mday 1.4 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>DeRegisterCimService</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1752 <font color=#FF0000>{</font>
1753
1754 <font color=#FF0000>}</font>
1755
1756 Uint32 queue<font color=#990000>;</font>
1757 <font color=#FF0000>}</font> <font color=#990000>;</font>
1758
1759 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE UpdateCimService <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1760 <font color=#FF0000>{</font>
1761 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1762 <b><font color=#000000>UpdateCimService</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1763 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1764 Boolean blocking<font color=#990000>,</font>
1765 Uint32 service_queue<font color=#990000>,</font>
1766 Uint32 service_capabilities<font color=#990000>,</font>
1767 Uint32 service_mask<font color=#990000>)</font><font color=#990000>;</font>
1768
1769 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>UpdateCimService</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1770 <font color=#FF0000>{</font>
1771
1772 mday 1.4 <font color=#FF0000>}</font>
1773
1774 Uint32 queue<font color=#990000>;</font>
1775 Uint32 capabilities<font color=#990000>;</font>
1776 Uint32 mask<font color=#990000>;</font>
1777 <font color=#FF0000>}</font><font color=#990000>;</font>
1778
1779
1780 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE AsyncIoctl <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1781 <font color=#FF0000>{</font>
1782 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1783 <b><font color=#000000>AsyncIoctl</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1784 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1785 Uint32 destination<font color=#990000>,</font>
1786 Uint32 response<font color=#990000>,</font>
1787 Boolean blocking<font color=#990000>,</font>
1788 Uint32 code<font color=#990000>,</font>
1789 Uint32 int_param<font color=#990000>,</font>
1790 <font color=#009900>void</font> <font color=#990000>*</font>p_param<font color=#990000>)</font><font color=#990000>;</font>
1791
1792 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>AsyncIoctl</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1793 mday 1.4 <font color=#FF0000>{</font>
1794
1795 <font color=#FF0000>}</font>
1796
1797 <b><font color=#0000FF>enum</font></b>
1798 <font color=#FF0000>{</font>
1799 IO_CLOSE<font color=#990000>,</font>
1800 IO_OPEN<font color=#990000>,</font>
1801 IO_SOURCE_QUENCH<font color=#990000>,</font>
1802 IO_SERVICE_DEFINED
1803 <font color=#FF0000>}</font><font color=#990000>;</font>
|
1804 mday 1.1
1805
1806
|
1807 mday 1.4 Uint32 ctl<font color=#990000>;</font>
1808 Uint32 intp<font color=#990000>;</font>
1809 <font color=#009900>void</font> <font color=#990000>*</font>voidp<font color=#990000>;</font>
|
1810 mday 1.1
|
1811 mday 1.4 <font color=#FF0000>}</font><font color=#990000>;</font>
|
1812 mday 1.1
|
1813 mday 1.4 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE CimServiceStart <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1814 <font color=#FF0000>{</font>
1815 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1816 <b><font color=#000000>CimServiceStart</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1817 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1818 Uint32 destination<font color=#990000>,</font>
1819 Uint32 response<font color=#990000>,</font>
1820 Boolean blocking<font color=#990000>)</font><font color=#990000>;</font>
1821
1822 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>CimServiceStart</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1823 <font color=#FF0000>{</font>
1824
1825 <font color=#FF0000>}</font>
1826 <font color=#FF0000>}</font><font color=#990000>;</font>
|
1827 mday 1.1
1828
|
1829 mday 1.4 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE CimServiceStop <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1830 <font color=#FF0000>{</font>
1831 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1832 <b><font color=#000000>CimServiceStop</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1833 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1834 Uint32 destination<font color=#990000>,</font>
1835 Uint32 response<font color=#990000>,</font>
1836 Boolean blocking<font color=#990000>)</font><font color=#990000>;</font>
1837
1838 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>CimServiceStop</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1839 <font color=#FF0000>{</font>
|
1840 mday 1.1
|
1841 mday 1.4 <font color=#FF0000>}</font>
1842 <font color=#FF0000>}</font><font color=#990000>;</font>
|
1843 mday 1.1
|
1844 mday 1.4 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE CimServicePause <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1845 <font color=#FF0000>{</font>
1846 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1847 <b><font color=#000000>CimServicePause</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1848 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1849 Uint32 destination<font color=#990000>,</font>
1850 Uint32 response<font color=#990000>,</font>
1851 Boolean blocking<font color=#990000>)</font><font color=#990000>;</font>
1852
1853
1854 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>CimServicePause</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1855 <font color=#FF0000>{</font>
1856
1857 <font color=#FF0000>}</font>
1858 <font color=#FF0000>}</font><font color=#990000>;</font>
1859
1860 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE CimServiceResume <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1861 <font color=#FF0000>{</font>
1862 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1863 <b><font color=#000000>CimServiceResume</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1864 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1865 mday 1.4 Uint32 destination<font color=#990000>,</font>
1866 Uint32 response<font color=#990000>,</font>
1867 Boolean blocking<font color=#990000>)</font><font color=#990000>;</font>
1868
1869
1870 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>CimServiceResume</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1871 <font color=#FF0000>{</font>
1872
1873 <font color=#FF0000>}</font>
1874 <font color=#FF0000>}</font><font color=#990000>;</font>
1875
1876 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE AsyncOperationStart <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1877 <font color=#FF0000>{</font>
1878 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1879 <b><font color=#000000>AsyncOperationStart</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1880 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1881 Uint32 destination<font color=#990000>,</font>
1882 Uint32 response<font color=#990000>,</font>
1883 Boolean blocking<font color=#990000>,</font>
1884 Message <font color=#990000>*</font>action<font color=#990000>)</font><font color=#990000>;</font>
1885
1886 mday 1.4
1887 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>AsyncOperationStart</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1888 <font color=#FF0000>{</font>
1889 <b><font color=#0000FF>delete</font></b> _act<font color=#990000>;</font>
1890 <font color=#FF0000>}</font>
1891
1892
1893 Message <font color=#990000>*</font><b><font color=#000000>get_action</font></b><font color=#990000>(</font><font color=#009900>void</font> <font color=#990000>)</font> <font color=#990000>;</font>
1894
1895
1896 <b><font color=#0000FF>private</font></b><font color=#990000>:</font>
1897 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> MessageQueueService<font color=#990000>;</font>
1898 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> cimom<font color=#990000>;</font>
1899 Message <font color=#990000>*</font>_act<font color=#990000>;</font>
1900 <font color=#FF0000>}</font><font color=#990000>;</font>
1901
1902 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE AsyncOperationResult <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncReply
1903 <font color=#FF0000>{</font>
1904 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1905 <b><font color=#000000>AsyncOperationResult</font></b><font color=#990000>(</font>Uint32 key<font color=#990000>,</font>
1906 Uint32 routing<font color=#990000>,</font>
1907 mday 1.4 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1908 Uint32 result_code<font color=#990000>,</font>
1909 Uint32 destination<font color=#990000>,</font>
1910 Uint32 blocking<font color=#990000>)</font><font color=#990000>;</font>
1911
1912
1913 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>AsyncOperationResult</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1914 <font color=#FF0000>{</font>
1915
1916 <font color=#FF0000>}</font>
1917 <font color=#FF0000>}</font><font color=#990000>;</font>
1918
1919
1920 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE AsyncLegacyOperationStart <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1921 <font color=#FF0000>{</font>
1922 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1923 <b><font color=#000000>AsyncLegacyOperationStart</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1924 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1925 Uint32 destination<font color=#990000>,</font>
1926 Message <font color=#990000>*</font>action<font color=#990000>,</font>
1927 Uint32 action_destination<font color=#990000>)</font><font color=#990000>;</font>
1928 mday 1.4
1929
1930 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>AsyncLegacyOperationStart</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1931 <font color=#FF0000>{</font>
1932 <b><font color=#0000FF>delete</font></b> _act<font color=#990000>;</font>
1933 <font color=#FF0000>}</font>
1934
1935 Message <font color=#990000>*</font><b><font color=#000000>get_action</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
1936
1937 <b><font color=#0000FF>private</font></b><font color=#990000>:</font>
1938 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> MessageQueueService<font color=#990000>;</font>
1939 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> cimom<font color=#990000>;</font>
1940 Message <font color=#990000>*</font>_act<font color=#990000>;</font>
1941 Uint32 _legacy_destination<font color=#990000>;</font>
1942
1943 <font color=#FF0000>}</font><font color=#990000>;</font>
1944
1945 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE AsyncLegacyOperationResult <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncReply
1946 <font color=#FF0000>{</font>
1947 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1948 <b><font color=#000000>AsyncLegacyOperationResult</font></b><font color=#990000>(</font>Uint32 key<font color=#990000>,</font>
1949 mday 1.4 Uint32 routing<font color=#990000>,</font>
1950 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1951 Message <font color=#990000>*</font>result<font color=#990000>)</font><font color=#990000>;</font>
1952
1953 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>AsyncLegacyOperationResult</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1954 <font color=#FF0000>{</font>
1955 <b><font color=#0000FF>delete</font></b> _res<font color=#990000>;</font>
1956 <font color=#FF0000>}</font>
1957
1958 Message <font color=#990000>*</font><b><font color=#000000>get_result</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
1959
1960
1961 <b><font color=#0000FF>private</font></b><font color=#990000>:</font>
1962 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> MessageQueueService<font color=#990000>;</font>
1963 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> cimom<font color=#990000>;</font>
1964 Message <font color=#990000>*</font>_res<font color=#990000>;</font>
1965 <font color=#FF0000>}</font><font color=#990000>;</font>
1966
1967
1968 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE FindServiceQueue <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
1969 <font color=#FF0000>{</font>
1970 mday 1.4 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1971 <b><font color=#000000>FindServiceQueue</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
1972 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1973 Uint32 response<font color=#990000>,</font>
1974 Boolean blocking<font color=#990000>,</font>
1975 String service_name<font color=#990000>,</font>
1976 Uint32 service_capabilities<font color=#990000>,</font>
1977 Uint32 service_mask<font color=#990000>)</font><font color=#990000>;</font>
1978
1979 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>FindServiceQueue</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
1980 <font color=#FF0000>{</font>
1981
1982 <font color=#FF0000>}</font>
1983
1984 String name<font color=#990000>;</font>
1985 Uint32 capabilities<font color=#990000>;</font>
1986 Uint32 mask<font color=#990000>;</font>
1987 <font color=#FF0000>}</font> <font color=#990000>;</font>
1988
1989 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE FindServiceQueueResult <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncReply
1990 <font color=#FF0000>{</font>
1991 mday 1.4 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
1992 <b><font color=#000000>FindServiceQueueResult</font></b><font color=#990000>(</font>Uint32 key<font color=#990000>,</font>
1993 Uint32 routing<font color=#990000>,</font>
1994 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
1995 Uint32 result_code<font color=#990000>,</font>
1996 Uint32 destination<font color=#990000>,</font>
1997 Boolean blocking<font color=#990000>,</font>
1998 Array<font color=#FF0000><Uint32></font> queue_ids<font color=#990000>)</font><font color=#990000>;</font>
1999
2000
2001 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>FindServiceQueueResult</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2002 <font color=#FF0000>{</font>
2003
2004 <font color=#FF0000>}</font>
2005
2006 Array<font color=#FF0000><Uint32></font> qids<font color=#990000>;</font>
2007 <font color=#FF0000>}</font> <font color=#990000>;</font>
2008
2009 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE EnumerateService <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncRequest
2010 <font color=#FF0000>{</font>
2011 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
2012 mday 1.4 <b><font color=#000000>EnumerateService</font></b><font color=#990000>(</font>Uint32 routing<font color=#990000>,</font>
2013 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
2014 Uint32 response<font color=#990000>,</font>
2015 Boolean blocking<font color=#990000>,</font>
2016 Uint32 queue_id<font color=#990000>)</font><font color=#990000>;</font>
2017
2018
2019 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>EnumerateService</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2020 <font color=#FF0000>{</font>
2021
2022 <font color=#FF0000>}</font>
2023
2024 Uint32 qid<font color=#990000>;</font>
2025 <font color=#FF0000>}</font><font color=#990000>;</font>
2026
2027 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE EnumerateServiceResponse <font color=#990000>:</font> <b><font color=#0000FF>public</font></b> AsyncReply
2028 <font color=#FF0000>{</font>
2029 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
2030 <b><font color=#000000>EnumerateServiceResponse</font></b><font color=#990000>(</font>Uint32 key<font color=#990000>,</font>
2031 Uint32 routing<font color=#990000>,</font>
2032 AsyncOpNode <font color=#990000>*</font>operation<font color=#990000>,</font>
2033 mday 1.4 Uint32 result_code<font color=#990000>,</font>
2034 Uint32 response<font color=#990000>,</font>
2035 Boolean blocking<font color=#990000>,</font>
2036 String service_name<font color=#990000>,</font>
2037 Uint32 service_capabilities<font color=#990000>,</font>
2038 Uint32 service_mask<font color=#990000>,</font>
2039 Uint32 service_qid<font color=#990000>)</font><font color=#990000>;</font>
2040
2041
2042 <b><font color=#0000FF>virtual</font></b> <font color=#990000>~</font><b><font color=#000000>EnumerateServiceResponse</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2043 <font color=#FF0000>{</font>
2044
2045 <font color=#FF0000>}</font>
2046
2047 String name<font color=#990000>;</font>
2048 Uint32 capabilities<font color=#990000>;</font>
2049 Uint32 mask<font color=#990000>;</font>
2050 Uint32 qid<font color=#990000>;</font>
2051 <font color=#FF0000>}</font><font color=#990000>;</font>
2052
2053
2054 mday 1.4 PEGASUS_NAMESPACE_END
2055
2056 <b><font color=#000080>#endif</font></b> <i><font color=#9A1900>// CIMOM_MESSAGE_include</font></i>
2057 </tt>
2058 </pre>
2059
2060
2061 <h3>AsyncOpNode</h3>
2062
|
2063 martin 1.5 <pre><tt>
|
2064 martin 1.6 <i><font color=#9A1900>//%LICENSE////////////////////////////////////////////////////////////////</font></i>
|
2065 mday 1.4 <i><font color=#9A1900>//</font></i>
|
2066 martin 1.6 <i><font color=#9A1900>// Licensed to The Open Group (TOG) under one or more contributor license</font></i>
2067 <i><font color=#9A1900>// agreements. Refer to the OpenPegasusNOTICE.txt file distributed with</font></i>
2068 <i><font color=#9A1900>// this work for additional information regarding copyright ownership.</font></i>
2069 <i><font color=#9A1900>// Each contributor licenses this file to you under the OpenPegasus Open</font></i>
2070 <i><font color=#9A1900>// Source License; you may not use this file except in compliance with the</font></i>
2071 <i><font color=#9A1900>// License.</font></i>
2072 <i><font color=#9A1900>//</font></i>
2073 <i><font color=#9A1900>// Permission is hereby granted, free of charge, to any person obtaining a</font></i>
2074 <i><font color=#9A1900>// copy of this software and associated documentation files (the "Software"),</font></i>
2075 <i><font color=#9A1900>// to deal in the Software without restriction, including without limitation</font></i>
2076 <i><font color=#9A1900>// the rights to use, copy, modify, merge, publish, distribute, sublicense,</font></i>
2077 <i><font color=#9A1900>// and/or sell copies of the Software, and to permit persons to whom the</font></i>
2078 <i><font color=#9A1900>// Software is furnished to do so, subject to the following conditions:</font></i>
2079 <i><font color=#9A1900>//</font></i>
2080 <i><font color=#9A1900>// The above copyright notice and this permission notice shall be included</font></i>
2081 <i><font color=#9A1900>// in all copies or substantial portions of the Software.</font></i>
2082 <i><font color=#9A1900>//</font></i>
2083 <i><font color=#9A1900>// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS</font></i>
2084 <i><font color=#9A1900>// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF</font></i>
2085 <i><font color=#9A1900>// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.</font></i>
2086 <i><font color=#9A1900>// IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY</font></i>
2087 martin 1.6 <i><font color=#9A1900>// CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,</font></i>
2088 <i><font color=#9A1900>// TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE</font></i>
2089 <i><font color=#9A1900>// SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.</font></i>
|
2090 mday 1.4 <i><font color=#9A1900>//</font></i>
|
2091 martin 1.6 <i><font color=#9A1900>//////////////////////////////////////////////////////////////////////////</font></i>
|
2092 mday 1.4 <i><font color=#9A1900>//</font></i>
|
2093 martin 1.6 <i><font color=#9A1900>// Author: Mike Day (mdday@us.ibm.com</font></i>
|
2094 mday 1.4 <i><font color=#9A1900>//</font></i>
2095 <i><font color=#9A1900>// Modified By: </font></i>
2096 <i><font color=#9A1900>//</font></i>
|
2097 martin 1.6 <i><font color=#9A1900>//////////////////////////////////////////////////////////////////////////</font></i>
|
2098 mday 1.4
2099
2100 <b><font color=#000080>#ifndef</font></b> Pegasus_AsyncOpNode_h
2101 <b><font color=#000080>#define</font></b> Pegasus_AsyncOpNode_h
2102
2103 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Config.h></font>
2104 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/Message.h></font>
2105 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/OperationContext.h></font>
2106 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/internal_dq.h></font>
2107 <b><font color=#000080>#include</font></b> <font color=#FF0000><Pegasus/Common/IPC.h></font>
2108
2109 PEGASUS_NAMESPACE_BEGIN
2110
2111 <i><font color=#9A1900>// ATTN usage of flags and state is inconsistent</font></i>
2112 <i><font color=#9A1900>// << Wed Jan 16 17:41:57 2002 mdd >></font></i>
2113 <i><font color=#9A1900>// resolved mdd </font></i>
2114
2115
2116 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_UNKNOWN <font color=#993399>0x00000000</font>
2117 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_INTERVAL_REPEAT <font color=#993399>0x00000010</font>
2118 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_INDICATION <font color=#993399>0x00000020</font>
2119 mday 1.4 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_REMOTE <font color=#993399>0x00000040</font>
2120 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_LOCAL_OUT_OF_PROC <font color=#993399>0x00000080</font>
2121 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_PHASED <font color=#993399>0x00000001</font>
2122 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_PARTIAL <font color=#993399>0x00000002</font>
2123 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_NORMAL <font color=#993399>0x00000000</font>
2124 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_SINGLE <font color=#993399>0x00000008</font>
2125 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_MULTIPLE <font color=#993399>0x00000010</font>
2126 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_TOTAL <font color=#993399>0x00000020</font>
2127 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_META_DISPATCHER <font color=#993399>0x00000040</font>
2128 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_FIRE_AND_FORGET <font color=#993399>0x00000080</font>
2129 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_SIMPLE_STATUS <font color=#993399>0x00000100</font>
2130 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_CALLBACK <font color=#993399>0x00000200</font>
2131 <b><font color=#000080>#define</font></b> ASYNC_OPFLAGS_FORWARD <font color=#993399>0x00000400</font>
2132
2133 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_UNKNOWN <font color=#993399>0x00000000</font>
2134 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_OFFERED <font color=#993399>0x00000001</font>
2135 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_DECLINED <font color=#993399>0x00000002</font>
2136 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_STARTED <font color=#993399>0x00000004</font>
2137 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_PROCESSING <font color=#993399>0x00000008</font>
2138 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_DELIVER <font color=#993399>0x00000010</font>
2139 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_RESERVE <font color=#993399>0x00000020</font>
2140 mday 1.4 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_COMPLETE <font color=#993399>0x00000040</font>
2141 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_TIMEOUT <font color=#993399>0x00000080</font>
2142 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_CANCELLED <font color=#993399>0x00000100</font>
2143 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_PAUSED <font color=#993399>0x00000200</font>
2144 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_SUSPENDED <font color=#993399>0x00000400</font>
2145 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_RESUMED <font color=#993399>0x00000800</font>
2146 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_ORPHANED <font color=#993399>0x00001000</font>
2147 <b><font color=#000080>#define</font></b> ASYNC_OPSTATE_RELEASED <font color=#993399>0x00002000</font>
2148
2149 <b><font color=#0000FF>class</font></b> Cimom<font color=#990000>;</font>
2150 <b><font color=#0000FF>class</font></b> Thread<font color=#990000>;</font>
2151
2152 <b><font color=#0000FF>class</font></b> PEGASUS_COMMON_LINKAGE AsyncOpNode
2153 <font color=#FF0000>{</font>
2154 <b><font color=#0000FF>public</font></b><font color=#990000>:</font>
|
2155 mday 1.1
|
2156 mday 1.4 <b><font color=#000000>AsyncOpNode</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
2157 <font color=#990000>~</font><b><font color=#000000>AsyncOpNode</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
2158
2159 Boolean <b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font><b><font color=#0000FF>const</font></b> <font color=#009900>void</font> <font color=#990000>*</font>key<font color=#990000>)</font> <b><font color=#0000FF>const</font></b><font color=#990000>;</font>
2160 Boolean <b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font><b><font color=#0000FF>const</font></b> AsyncOpNode <font color=#990000>&</font> node<font color=#990000>)</font> <b><font color=#0000FF>const</font></b><font color=#990000>;</font>
|
2161 mday 1.1
|
2162 mday 1.4 <font color=#009900>void</font> <b><font color=#000000>get_timeout_interval</font></b><font color=#990000>(</font><b><font color=#0000FF>struct</font></b> timeval <font color=#990000>*</font>buffer<font color=#990000>)</font> <font color=#990000>;</font>
2163 <font color=#009900>void</font> <b><font color=#000000>set_timeout_interval</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> <b><font color=#0000FF>struct</font></b> timeval <font color=#990000>*</font>interval<font color=#990000>)</font><font color=#990000>;</font>
|
2164 mday 1.1
|
2165 mday 1.4 Boolean <b><font color=#000000>timeout</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>;</font>
|
2166 mday 1.1
|
2167 mday 1.4 OperationContext <font color=#990000>&</font> <b><font color=#000000>get_context</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>;</font>
2168
2169 <font color=#009900>void</font> <b><font color=#000000>put_request</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> Message <font color=#990000>*</font>request<font color=#990000>)</font> <font color=#990000>;</font>
2170 Message <font color=#990000>*</font><b><font color=#000000>get_request</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>;</font>
2171
2172 <font color=#009900>void</font> <b><font color=#000000>put_response</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> Message <font color=#990000>*</font>response<font color=#990000>)</font> <font color=#990000>;</font>
2173 Message <font color=#990000>*</font><b><font color=#000000>get_response</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>;</font>
2174
2175 Uint32 <b><font color=#000000>read_state</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>;</font>
2176 <font color=#009900>void</font> <b><font color=#000000>write_state</font></b><font color=#990000>(</font>Uint32<font color=#990000>)</font> <font color=#990000>;</font>
2177
2178 Uint32 <b><font color=#000000>read_flags</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
2179 <font color=#009900>void</font> <b><font color=#000000>write_flags</font></b><font color=#990000>(</font>Uint32<font color=#990000>)</font><font color=#990000>;</font>
2180
2181 <font color=#009900>void</font> <b><font color=#000000>lock</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
2182 <font color=#009900>void</font> <b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
2183 <font color=#009900>void</font> <b><font color=#000000>udpate</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
2184 <font color=#009900>void</font> <b><font color=#000000>deliver</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> Uint32 count<font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
2185 <font color=#009900>void</font> <b><font color=#000000>reserve</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> Uint32 size<font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
2186 <font color=#009900>void</font> <b><font color=#000000>processing</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font> <font color=#990000>;</font>
2187 <font color=#009900>void</font> <b><font color=#000000>processing</font></b><font color=#990000>(</font>OperationContext <font color=#990000>*</font>context<font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
2188 mday 1.4 <font color=#009900>void</font> <b><font color=#000000>complete</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font> <font color=#990000>;</font>
2189 <font color=#009900>void</font> <b><font color=#000000>complete</font></b><font color=#990000>(</font>OperationContext <font color=#990000>*</font>context<font color=#990000>)</font> <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font><font color=#990000>;</font>
2190 <font color=#009900>void</font> <b><font color=#000000>release</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
2191 <font color=#009900>void</font> <b><font color=#000000>wait</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font><font color=#990000>;</font>
2192
2193
2194 <b><font color=#0000FF>private</font></b><font color=#990000>:</font>
2195 Semaphore _client_sem<font color=#990000>;</font>
2196 Mutex _mut<font color=#990000>;</font>
2197 unlocked_dq<font color=#FF0000><Message></font> _request<font color=#990000>;</font>
2198 unlocked_dq<font color=#FF0000><Message></font> _response<font color=#990000>;</font>
2199
2200 OperationContext _operation_list<font color=#990000>;</font>
2201 Uint32 _state<font color=#990000>;</font>
2202 Uint32 _flags<font color=#990000>;</font>
2203 Uint32 _offered_count<font color=#990000>;</font>
2204 Uint32 _total_ops<font color=#990000>;</font>
2205 Uint32 _completed_ops<font color=#990000>;</font>
2206 Uint32 _user_data<font color=#990000>;</font>
2207 Uint32 _completion_code<font color=#990000>;</font>
2208 MessageQueue <font color=#990000>*</font>_op_dest<font color=#990000>;</font>
2209 mday 1.4
2210 <b><font color=#0000FF>struct</font></b> timeval _start<font color=#990000>;</font>
2211 <b><font color=#0000FF>struct</font></b> timeval _lifetime<font color=#990000>;</font>
2212 <b><font color=#0000FF>struct</font></b> timeval _updated<font color=#990000>;</font>
2213 <b><font color=#0000FF>struct</font></b> timeval _timeout_interval<font color=#990000>;</font>
2214
2215 AsyncOpNode <font color=#990000>*</font>_parent<font color=#990000>;</font>
2216 unlocked_dq<font color=#FF0000><AsyncOpNode></font> _children<font color=#990000>;</font>
2217
2218 <font color=#009900>void</font> <b><font color=#000000>_reset</font></b><font color=#990000>(</font>unlocked_dq<font color=#FF0000><AsyncOpNode></font> <font color=#990000>*</font>dst_q<font color=#990000>)</font><font color=#990000>;</font>
2219
2220 <i><font color=#9A1900>// the lifetime member is for cache management by the cimom</font></i>
2221 <font color=#009900>void</font> <b><font color=#000000>_set_lifetime</font></b><font color=#990000>(</font><b><font color=#0000FF>struct</font></b> timeval <font color=#990000>*</font>lifetime<font color=#990000>)</font> <font color=#990000>;</font>
2222 Boolean <b><font color=#000000>_check_lifetime</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>;</font>
2223
2224 Boolean <b><font color=#000000>_is_child</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>;</font>
2225 Uint32 <b><font color=#000000>_is_parent</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font> <font color=#990000>;</font>
2226 Boolean <b><font color=#000000>_is_my_child</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> AsyncOpNode <font color=#990000>&</font> caller<font color=#990000>)</font> <b><font color=#0000FF>const</font></b><font color=#990000>;</font>
2227 <font color=#009900>void</font> <b><font color=#000000>_make_orphan</font></b><font color=#990000>(</font> AsyncOpNode <font color=#990000>&</font> parent<font color=#990000>)</font> <font color=#990000>;</font>
2228 <font color=#009900>void</font> <b><font color=#000000>_adopt_child</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>child<font color=#990000>)</font> <font color=#990000>;</font>
2229 <font color=#009900>void</font> <b><font color=#000000>_disown_child</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>child<font color=#990000>)</font> <font color=#990000>;</font>
2230 mday 1.4 <font color=#009900>void</font> <font color=#990000>(</font><font color=#990000>*</font>_async_callback<font color=#990000>)</font><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font><font color=#990000>,</font>
2231 MessageQueue <font color=#990000>*</font><font color=#990000>,</font>
2232 <font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>;</font>
2233 <i><font color=#9A1900>// << Tue Mar 12 14:44:51 2002 mdd >></font></i>
2234 <i><font color=#9A1900>// pointers for async callbacks - don't use </font></i>
2235 AsyncOpNode <font color=#990000>*</font>_callback_node<font color=#990000>;</font>
2236 MessageQueue <font color=#990000>*</font>_callback_response_q<font color=#990000>;</font>
2237 <font color=#009900>void</font> <font color=#990000>*</font>_callback_ptr<font color=#990000>;</font>
2238 MessageQueue <font color=#990000>*</font>_callback_request_q<font color=#990000>;</font>
2239 <i><font color=#9A1900>// << Tue Mar 12 14:44:53 2002 mdd >></font></i>
2240 <i><font color=#9A1900>// pointers to help static class message handlers - don't use </font></i>
2241 MessageQueue <font color=#990000>*</font>_service_ptr<font color=#990000>;</font>
2242 Thread <font color=#990000>*</font>_thread_ptr<font color=#990000>;</font>
2243
2244 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> cimom<font color=#990000>;</font>
2245 <b><font color=#0000FF>friend</font></b> <b><font color=#0000FF>class</font></b> MessageQueueService<font color=#990000>;</font>
|
2246 mday 1.1
|
2247 mday 1.4 <font color=#FF0000>}</font><font color=#990000>;</font>
|
2248 mday 1.1
2249
|
2250 mday 1.4 <b><font color=#0000FF>inline</font></b> Boolean AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font><b><font color=#0000FF>const</font></b> <font color=#009900>void</font> <font color=#990000>*</font>key<font color=#990000>)</font> <b><font color=#0000FF>const</font></b>
2251 <font color=#FF0000>{</font>
2252 <b><font color=#0000FF>if</font></b> <font color=#990000>(</font>key <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font><font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><b><font color=#0000FF>this</font></b><font color=#990000>)</font>
2253 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>true</font></b><font color=#990000>;</font>
2254 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>false</font></b><font color=#990000>;</font>
2255 <font color=#FF0000>}</font>
2256
2257 <b><font color=#0000FF>inline</font></b> Boolean AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#0000FF>operator</font></b> <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>(</font><b><font color=#0000FF>const</font></b> AsyncOpNode <font color=#990000>&</font> node<font color=#990000>)</font> <b><font color=#0000FF>const</font></b>
2258 <font color=#FF0000>{</font>
2259 <b><font color=#0000FF>return</font></b> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#0000FF>operator</font></b><font color=#990000>=</font><font color=#990000>=</font><font color=#990000>(</font><font color=#990000>(</font><b><font color=#0000FF>const</font></b> <font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>)</font><font color=#990000>&</font>node<font color=#990000>)</font><font color=#990000>;</font>
2260 <font color=#FF0000>}</font>
2261
2262
2263 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>get_timeout_interval</font></b><font color=#990000>(</font><b><font color=#0000FF>struct</font></b> timeval <font color=#990000>*</font>buffer<font color=#990000>)</font>
2264 <font color=#FF0000>{</font>
2265 <b><font color=#0000FF>if</font></b><font color=#990000>(</font>buffer <font color=#990000>!</font><font color=#990000>=</font> <font color=#993399>0</font><font color=#990000>)</font>
2266 <font color=#FF0000>{</font>
2267 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font> <b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font> <font color=#990000>)</font><font color=#990000>;</font>
2268 buffer<font color=#990000>-</font><font color=#990000>></font>tv_sec <font color=#990000>=</font> _timeout_interval<font color=#990000>.</font>tv_sec<font color=#990000>;</font>
2269 buffer<font color=#990000>-</font><font color=#990000>></font>tv_usec <font color=#990000>=</font> _timeout_interval<font color=#990000>.</font>tv_usec<font color=#990000>;</font>
2270 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2271 mday 1.4 <font color=#FF0000>}</font>
2272 <b><font color=#0000FF>return</font></b><font color=#990000>;</font>
2273 <font color=#FF0000>}</font>
2274
2275 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>set_timeout_interval</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> <b><font color=#0000FF>struct</font></b> timeval <font color=#990000>*</font>interval<font color=#990000>)</font>
2276 <font color=#FF0000>{</font>
2277 <b><font color=#0000FF>if</font></b><font color=#990000>(</font>interval <font color=#990000>!</font><font color=#990000>=</font> <font color=#993399>0</font><font color=#990000>)</font>
2278 <font color=#FF0000>{</font>
2279 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2280 _timeout_interval<font color=#990000>.</font>tv_sec <font color=#990000>=</font> interval<font color=#990000>-</font><font color=#990000>></font>tv_sec<font color=#990000>;</font>
2281 _timeout_interval<font color=#990000>.</font>tv_usec <font color=#990000>=</font> interval<font color=#990000>-</font><font color=#990000>></font>tv_usec<font color=#990000>;</font>
2282 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2283 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2284 <font color=#FF0000>}</font>
2285 <font color=#FF0000>}</font>
2286
2287
2288 <b><font color=#0000FF>inline</font></b> Boolean AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>timeout</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2289 <font color=#FF0000>{</font>
2290 <b><font color=#0000FF>struct</font></b> timeval now<font color=#990000>;</font>
2291 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>now<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2292 mday 1.4 Boolean ret <font color=#990000>=</font> <b><font color=#0000FF>false</font></b><font color=#990000>;</font>
2293 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2294 <b><font color=#0000FF>if</font></b><font color=#990000>(</font><font color=#990000>(</font>_updated<font color=#990000>.</font>tv_sec <font color=#990000>+</font> _timeout_interval<font color=#990000>.</font>tv_sec <font color=#990000>)</font> <font color=#990000><</font> now<font color=#990000>.</font>tv_sec<font color=#990000>)</font>
2295 <b><font color=#0000FF>if</font></b><font color=#990000>(</font><font color=#990000>(</font>_updated<font color=#990000>.</font>tv_usec <font color=#990000>+</font> _timeout_interval<font color=#990000>.</font>tv_usec <font color=#990000>)</font> <font color=#990000><</font> now<font color=#990000>.</font>tv_usec<font color=#990000>)</font>
2296 ret <font color=#990000>=</font> <b><font color=#0000FF>true</font></b><font color=#990000>;</font>
2297 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2298 <b><font color=#0000FF>return</font></b> ret<font color=#990000>;</font>
2299 <font color=#FF0000>}</font>
2300
2301 <i><font color=#9A1900>// context is now a locked list</font></i>
2302 <b><font color=#0000FF>inline</font></b> OperationContext <font color=#990000>&</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>get_context</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2303 <font color=#FF0000>{</font>
2304 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2305 <b><font color=#0000FF>return</font></b> _operation_list<font color=#990000>;</font>
2306 <font color=#FF0000>}</font>
2307
2308
2309 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>put_request</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> Message <font color=#990000>*</font>request<font color=#990000>)</font>
2310 <font color=#FF0000>{</font>
2311 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2312 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2313 mday 1.4 <b><font color=#0000FF>if</font></b><font color=#990000>(</font> <b><font color=#0000FF>false</font></b> <font color=#990000>=</font><font color=#990000>=</font> _request<font color=#990000>.</font><b><font color=#000000>exists</font></b><font color=#990000>(</font><b><font color=#0000FF>reinterpret_cast</font></b><font color=#990000><</font><font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>></font><font color=#990000>(</font><b><font color=#0000FF>const_cast</font></b><font color=#990000><</font>Message <font color=#990000>*</font><font color=#990000>></font><font color=#990000>(</font>request<font color=#990000>)</font><font color=#990000>)</font><font color=#990000>)</font> <font color=#990000>)</font>
2314 _request<font color=#990000>.</font><b><font color=#000000>insert_last</font></b><font color=#990000>(</font> <b><font color=#0000FF>const_cast</font></b><font color=#990000><</font>Message <font color=#990000>*</font><font color=#990000>></font><font color=#990000>(</font>request<font color=#990000>)</font> <font color=#990000>)</font> <font color=#990000>;</font>
|
2315 mday 1.1
|
2316 mday 1.4 <i><font color=#9A1900>// _request = const_cast<Message *>(request);</font></i>
2317
2318 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2319 <font color=#FF0000>}</font>
|
2320 mday 1.1
|
2321 mday 1.4 <b><font color=#0000FF>inline</font></b> Message <font color=#990000>*</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>get_request</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2322 <font color=#FF0000>{</font>
2323 Message <font color=#990000>*</font>ret<font color=#990000>;</font>
2324 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2325 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2326 ret <font color=#990000>=</font> _request<font color=#990000>.</font><b><font color=#000000>remove_first</font></b><font color=#990000>(</font><font color=#990000>)</font> <font color=#990000>;</font>
2327 <i><font color=#9A1900>// ret = _request;</font></i>
2328
2329 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2330 <b><font color=#0000FF>return</font></b> ret<font color=#990000>;</font>
2331 <font color=#FF0000>}</font>
2332
2333 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>put_response</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> Message <font color=#990000>*</font>response<font color=#990000>)</font>
2334 <font color=#FF0000>{</font>
2335 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2336 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2337 <b><font color=#0000FF>if</font></b> <font color=#990000>(</font><b><font color=#0000FF>false</font></b> <font color=#990000>=</font><font color=#990000>=</font> _response<font color=#990000>.</font><b><font color=#000000>exists</font></b><font color=#990000>(</font><b><font color=#0000FF>reinterpret_cast</font></b><font color=#990000><</font><font color=#009900>void</font> <font color=#990000>*</font><font color=#990000>></font><font color=#990000>(</font><b><font color=#0000FF>const_cast</font></b><font color=#990000><</font>Message <font color=#990000>*</font><font color=#990000>></font><font color=#990000>(</font>response<font color=#990000>)</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>)</font>
2338 _response<font color=#990000>.</font><b><font color=#000000>insert_last</font></b><font color=#990000>(</font> <b><font color=#0000FF>const_cast</font></b><font color=#990000><</font>Message <font color=#990000>*</font><font color=#990000>></font><font color=#990000>(</font>response<font color=#990000>)</font> <font color=#990000>)</font><font color=#990000>;</font>
|
2339 mday 1.1
|
2340 mday 1.4 <i><font color=#9A1900>// _response = const_cast<Message *>(response);</font></i>
2341
2342 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2343 <font color=#FF0000>}</font>
|
2344 mday 1.1
|
2345 mday 1.4 <b><font color=#0000FF>inline</font></b> Message <font color=#990000>*</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>get_response</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2346 <font color=#FF0000>{</font>
2347 Message <font color=#990000>*</font>ret<font color=#990000>;</font>
2348
2349 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2350 <i><font color=#9A1900>// gettimeofday(&_updated, NULL);</font></i>
2351 ret <font color=#990000>=</font> _response<font color=#990000>.</font><b><font color=#000000>remove_first</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2352 <i><font color=#9A1900>// ret = _response;</font></i>
2353
2354 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2355 <b><font color=#0000FF>return</font></b> ret<font color=#990000>;</font>
2356 <font color=#FF0000>}</font>
2357
2358 <b><font color=#0000FF>inline</font></b> Uint32 AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>read_state</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2359 <font color=#FF0000>{</font>
2360 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2361 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2362 Uint32 ret <font color=#990000>=</font> _state<font color=#990000>;</font>
2363 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2364 <b><font color=#0000FF>return</font></b> ret<font color=#990000>;</font>
2365
2366 mday 1.4 <font color=#FF0000>}</font>
|
2367 mday 1.1
|
2368 mday 1.4 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>write_state</font></b><font color=#990000>(</font>Uint32 state<font color=#990000>)</font>
2369 <font color=#FF0000>{</font>
2370 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2371 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2372 _state <font color=#990000>=</font> state<font color=#990000>;</font>
2373 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2374 <font color=#FF0000>}</font>
2375
2376 <b><font color=#0000FF>inline</font></b> Uint32 AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>read_flags</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2377 <font color=#FF0000>{</font>
2378 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2379 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2380 Uint32 ret <font color=#990000>=</font> _flags<font color=#990000>;</font>
2381 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2382 <b><font color=#0000FF>return</font></b> ret<font color=#990000>;</font>
2383 <font color=#FF0000>}</font>
2384
2385 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>write_flags</font></b><font color=#990000>(</font>Uint32 flags<font color=#990000>)</font>
2386 <font color=#FF0000>{</font>
2387 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2388 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2389 mday 1.4 _flags <font color=#990000>=</font> flags<font color=#990000>;</font>
2390 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2391 <font color=#FF0000>}</font>
2392
2393
2394 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2395 <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font>
2396 <font color=#FF0000>{</font>
2397 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2398 <font color=#FF0000>}</font>
2399
2400 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2401 <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font>
2402 <font color=#FF0000>{</font>
2403 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2404 <font color=#FF0000>}</font>
2405
2406 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>udpate</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2407 <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font>
2408 <font color=#FF0000>{</font>
2409 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2410 mday 1.4 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2411 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2412 <b><font color=#0000FF>return</font></b><font color=#990000>;</font>
2413 <font color=#FF0000>}</font>
2414
2415 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>deliver</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> Uint32 count<font color=#990000>)</font>
2416 <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font>
2417 <font color=#FF0000>{</font>
2418 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2419 _completed_ops <font color=#990000>=</font> count<font color=#990000>;</font>
2420 _state <font color=#990000>|</font><font color=#990000>=</font> ASYNC_OPSTATE_DELIVER<font color=#990000>;</font>
2421 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2422 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2423 <b><font color=#0000FF>return</font></b><font color=#990000>;</font>
2424 <font color=#FF0000>}</font>
2425
2426 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>reserve</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> Uint32 size<font color=#990000>)</font>
2427 <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font>
2428 <font color=#FF0000>{</font>
2429 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2430 _total_ops <font color=#990000>=</font> size<font color=#990000>;</font>
2431 mday 1.4 _state <font color=#990000>|</font><font color=#990000>=</font> ASYNC_OPSTATE_RESERVE<font color=#990000>;</font>
2432 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2433 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2434 <b><font color=#0000FF>return</font></b><font color=#990000>;</font>
2435 <font color=#FF0000>}</font>
2436
2437 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>processing</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2438 <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font>
2439 <font color=#FF0000>{</font>
2440 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2441 _state <font color=#990000>|</font><font color=#990000>=</font> ASYNC_OPSTATE_PROCESSING<font color=#990000>;</font>
2442 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2443 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2444 <b><font color=#0000FF>return</font></b><font color=#990000>;</font>
2445 <font color=#FF0000>}</font>
2446
2447 <i><font color=#9A1900>// con will be empty upon return of this member function</font></i>
2448 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>processing</font></b><font color=#990000>(</font>OperationContext <font color=#990000>*</font>con<font color=#990000>)</font>
2449 <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font>
2450 <font color=#FF0000>{</font>
2451 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2452 mday 1.4 _state <font color=#990000>|</font><font color=#990000>=</font> ASYNC_OPSTATE_PROCESSING<font color=#990000>;</font>
2453 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2454
2455 context <font color=#990000>*</font>c <font color=#990000>=</font> con<font color=#990000>-</font><font color=#990000>></font><b><font color=#000000>remove_context</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2456 <b><font color=#0000FF>while</font></b><font color=#990000>(</font>c <font color=#990000>!</font><font color=#990000>=</font> <font color=#993399>0</font><font color=#990000>)</font>
2457 <font color=#FF0000>{</font>
2458 _operation_list<font color=#990000>.</font><b><font color=#000000>add_context</font></b><font color=#990000>(</font>c<font color=#990000>)</font><font color=#990000>;</font>
2459 c <font color=#990000>=</font> con<font color=#990000>-</font><font color=#990000>></font><b><font color=#000000>remove_context</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2460 <font color=#FF0000>}</font>
2461 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2462 <b><font color=#0000FF>return</font></b><font color=#990000>;</font>
2463 <font color=#FF0000>}</font>
2464
2465 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>complete</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2466 <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font>
2467 <font color=#FF0000>{</font>
2468 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2469 _state <font color=#990000>|</font><font color=#990000>=</font> ASYNC_OPSTATE_COMPLETE<font color=#990000>;</font>
2470 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2471 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2472
2473 mday 1.4 <b><font color=#0000FF>return</font></b><font color=#990000>;</font>
2474 <font color=#FF0000>}</font>
2475
2476 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>complete</font></b><font color=#990000>(</font>OperationContext <font color=#990000>*</font>con<font color=#990000>)</font>
2477 <b><font color=#0000FF>throw</font></b><font color=#990000>(</font>IPCException<font color=#990000>)</font>
2478 <font color=#FF0000>{</font>
2479 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2480 _state <font color=#990000>|</font><font color=#990000>=</font> ASYNC_OPSTATE_COMPLETE<font color=#990000>;</font>
2481 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>_updated<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2482 context <font color=#990000>*</font>c <font color=#990000>=</font> con<font color=#990000>-</font><font color=#990000>></font><b><font color=#000000>remove_context</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2483 <b><font color=#0000FF>while</font></b><font color=#990000>(</font>c <font color=#990000>!</font><font color=#990000>=</font> <font color=#993399>0</font><font color=#990000>)</font>
2484 <font color=#FF0000>{</font>
2485 _operation_list<font color=#990000>.</font><b><font color=#000000>add_context</font></b><font color=#990000>(</font>c<font color=#990000>)</font><font color=#990000>;</font>
2486 c <font color=#990000>=</font> con<font color=#990000>-</font><font color=#990000>></font><b><font color=#000000>remove_context</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2487 <font color=#FF0000>}</font>
2488 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2489 <font color=#FF0000>}</font>
2490
2491 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>wait</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2492 <font color=#FF0000>{</font>
2493 _client_sem<font color=#990000>.</font><b><font color=#000000>wait</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2494 mday 1.4 <font color=#FF0000>}</font>
2495
2496 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>release</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2497 <font color=#FF0000>{</font>
2498 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2499 _state <font color=#990000>|</font><font color=#990000>=</font> ASYNC_OPSTATE_RELEASED<font color=#990000>;</font>
2500 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2501 <font color=#FF0000>}</font>
2502
2503 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>_set_lifetime</font></b><font color=#990000>(</font><b><font color=#0000FF>struct</font></b> timeval <font color=#990000>*</font>lifetime<font color=#990000>)</font>
2504 <font color=#FF0000>{</font>
2505 _mut<font color=#990000>.</font><b><font color=#000000>lock</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2506 _lifetime<font color=#990000>.</font>tv_sec <font color=#990000>=</font> lifetime<font color=#990000>-</font><font color=#990000>></font>tv_sec<font color=#990000>;</font>
2507 _lifetime<font color=#990000>.</font>tv_usec <font color=#990000>=</font> lifetime<font color=#990000>-</font><font color=#990000>></font>tv_usec<font color=#990000>;</font>
2508 _mut<font color=#990000>.</font><b><font color=#000000>unlock</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2509 <font color=#FF0000>}</font>
2510
2511 <b><font color=#0000FF>inline</font></b> Boolean AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>_check_lifetime</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2512 <font color=#FF0000>{</font>
2513 <b><font color=#0000FF>struct</font></b> timeval now<font color=#990000>;</font>
2514
2515 mday 1.4 <b><font color=#000000>gettimeofday</font></b><font color=#990000>(</font><font color=#990000>&</font>now<font color=#990000>,</font> NULL<font color=#990000>)</font><font color=#990000>;</font>
2516 <b><font color=#0000FF>if</font></b><font color=#990000>(</font><font color=#990000>(</font>_start<font color=#990000>.</font>tv_sec <font color=#990000>+</font> _lifetime<font color=#990000>.</font>tv_sec <font color=#990000>)</font> <font color=#990000>></font><font color=#990000>=</font> now<font color=#990000>.</font>tv_sec<font color=#990000>)</font>
2517 <b><font color=#0000FF>if</font></b><font color=#990000>(</font><font color=#990000>(</font>_start<font color=#990000>.</font>tv_usec <font color=#990000>+</font> _lifetime<font color=#990000>.</font>tv_usec <font color=#990000>)</font> <font color=#990000>></font><font color=#990000>=</font> now<font color=#990000>.</font>tv_usec<font color=#990000>)</font>
2518 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>true</font></b><font color=#990000>;</font>
2519 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>false</font></b><font color=#990000>;</font>
2520 <font color=#FF0000>}</font>
2521
2522 <b><font color=#0000FF>inline</font></b> Boolean AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>_is_child</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2523 <font color=#FF0000>{</font>
2524 <b><font color=#0000FF>if</font></b> <font color=#990000>(</font>_parent <font color=#990000>!</font><font color=#990000>=</font> <font color=#993399>0</font><font color=#990000>)</font>
2525 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>true</font></b><font color=#990000>;</font>
2526 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>false</font></b><font color=#990000>;</font>
2527 <font color=#FF0000>}</font>
2528
2529 <b><font color=#0000FF>inline</font></b> Uint32 AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>_is_parent</font></b><font color=#990000>(</font><font color=#009900>void</font><font color=#990000>)</font>
2530 <font color=#FF0000>{</font>
2531 <b><font color=#0000FF>return</font></b> _children<font color=#990000>.</font><b><font color=#000000>count</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2532 <font color=#FF0000>}</font>
2533
2534 <b><font color=#0000FF>inline</font></b> Boolean AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>_is_my_child</font></b><font color=#990000>(</font><b><font color=#0000FF>const</font></b> AsyncOpNode <font color=#990000>&</font> caller<font color=#990000>)</font> <b><font color=#0000FF>const</font></b>
2535 <font color=#FF0000>{</font>
2536 mday 1.4 <b><font color=#0000FF>if</font></b> <font color=#990000>(</font> _parent <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>&</font>caller <font color=#990000>)</font>
2537 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>true</font></b><font color=#990000>;</font>
2538 <b><font color=#0000FF>return</font></b> <b><font color=#0000FF>false</font></b><font color=#990000>;</font>
2539 <font color=#FF0000>}</font>
2540
2541 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>_make_orphan</font></b><font color=#990000>(</font> AsyncOpNode <font color=#990000>&</font> parent<font color=#990000>)</font>
2542 <font color=#FF0000>{</font>
2543 <b><font color=#0000FF>if</font></b><font color=#990000>(</font> _parent <font color=#990000>=</font><font color=#990000>=</font> <font color=#990000>&</font>parent <font color=#990000>)</font>
2544 <font color=#FF0000>{</font>
2545 _parent <font color=#990000>=</font> NULL<font color=#990000>;</font>
2546 parent<font color=#990000>.</font>_children<font color=#990000>.</font><b><font color=#000000>remove</font></b><font color=#990000>(</font><b><font color=#0000FF>this</font></b><font color=#990000>)</font><font color=#990000>;</font>
2547 <font color=#FF0000>}</font>
2548 <b><font color=#0000FF>else</font></b>
2549 <b><font color=#0000FF>throw</font></b> <b><font color=#000000>Permission</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2550 <font color=#FF0000>}</font>
2551
2552 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>_adopt_child</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>child<font color=#990000>)</font>
2553 <font color=#FF0000>{</font>
2554 <b><font color=#0000FF>if</font></b><font color=#990000>(</font>child <font color=#990000>=</font><font color=#990000>=</font> NULL<font color=#990000>)</font>
2555 <b><font color=#0000FF>throw</font></b> <b><font color=#000000>NullPointer</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2556 <b><font color=#0000FF>if</font></b><font color=#990000>(</font><b><font color=#0000FF>true</font></b> <font color=#990000>=</font><font color=#990000>=</font> child<font color=#990000>-</font><font color=#990000>></font><b><font color=#000000>_is_child</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font>
2557 mday 1.4 <b><font color=#0000FF>throw</font></b> <b><font color=#000000>Permission</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2558 child<font color=#990000>-</font><font color=#990000>></font>_parent <font color=#990000>=</font> <b><font color=#0000FF>this</font></b><font color=#990000>;</font>
2559 _children<font color=#990000>.</font><b><font color=#000000>insert_last</font></b><font color=#990000>(</font>child<font color=#990000>)</font><font color=#990000>;</font>
2560 <font color=#FF0000>}</font>
2561
2562 <b><font color=#0000FF>inline</font></b> <font color=#009900>void</font> AsyncOpNode<font color=#990000>:</font><font color=#990000>:</font><b><font color=#000000>_disown_child</font></b><font color=#990000>(</font>AsyncOpNode <font color=#990000>*</font>child<font color=#990000>)</font>
2563 <font color=#FF0000>{</font>
2564 <b><font color=#0000FF>if</font></b><font color=#990000>(</font>child <font color=#990000>=</font><font color=#990000>=</font> NULL<font color=#990000>)</font>
2565 <b><font color=#0000FF>throw</font></b> <b><font color=#000000>NullPointer</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>;</font>
2566 <b><font color=#0000FF>if</font></b><font color=#990000>(</font> <b><font color=#0000FF>false</font></b> <font color=#990000>=</font><font color=#990000>=</font> child<font color=#990000>-</font><font color=#990000>></font><b><font color=#000000>_is_child</font></b><font color=#990000>(</font><font color=#990000>)</font> <font color=#990000>|</font><font color=#990000>|</font> <b><font color=#0000FF>false</font></b> <font color=#990000>=</font><font color=#990000>=</font> child<font color=#990000>-</font><font color=#990000>></font><b><font color=#000000>_is_my_child</font></b><font color=#990000>(</font> <font color=#990000>*</font><b><font color=#0000FF>this</font></b> <font color=#990000>)</font><font color=#990000>)</font>
2567 <b><font color=#0000FF>throw</font></b> <b><font color=#000000>Permission</font></b><font color=#990000>(</font><b><font color=#000000>pegasus_thread_self</font></b><font color=#990000>(</font><font color=#990000>)</font><font color=#990000>)</font><font color=#990000>;</font>
2568 child<font color=#990000>-</font><font color=#990000>></font><b><font color=#000000>_make_orphan</font></b><font color=#990000>(</font> <font color=#990000>*</font><b><font color=#0000FF>this</font></b> <font color=#990000>)</font><font color=#990000>;</font>
2569 _children<font color=#990000>.</font><b><font color=#000000>remove</font></b><font color=#990000>(</font>child<font color=#990000>)</font><font color=#990000>;</font>
2570 <font color=#FF0000>}</font>
|
2571 mday 1.1
|
2572 mday 1.4 PEGASUS_NAMESPACE_END
|
2573 mday 1.1
|
2574 mday 1.4 <b><font color=#000080>#endif</font></b> <i><font color=#9A1900>//Pegasus_AsyncOpNode_h</font></i>
2575 </tt>
|
2576 mday 1.1 </pre>
2577
|
2578 mday 1.4
|
2579 mday 1.1 <hr>
2580 <address><a href="mailto:mdday@us.ibm.com">Michael Day</a></address>
2581 <!-- Created: Tue Feb 5 13:21:55 EST 2002 -->
2582 <!-- hhmts start -->
|
2583 mday 1.4 Last modified: Wed Mar 13 12:26:56 EST 2002
|
2584 mday 1.1 <!-- hhmts end -->
|
2585 martin 1.6 </body></html>
|