Mercurial > projects > hoofbaby
comparison deps/Platinum/ThirdParty/Neptune/Source/Core/NptSimpleMessageQueue.cpp @ 0:3425707ddbf6
Initial import (hopefully this mercurial stuff works...)
author | fraserofthenight |
---|---|
date | Mon, 06 Jul 2009 08:06:28 -0700 |
parents | |
children |
comparison
equal
deleted
inserted
replaced
-1:000000000000 | 0:3425707ddbf6 |
---|---|
1 /***************************************************************** | |
2 | | |
3 | Neptune - Simple Message Queue | |
4 | | |
5 | Copyright (c) 2002-2008, Axiomatic Systems, LLC. | |
6 | All rights reserved. | |
7 | | |
8 | Redistribution and use in source and binary forms, with or without | |
9 | modification, are permitted provided that the following conditions are met: | |
10 | * Redistributions of source code must retain the above copyright | |
11 | notice, this list of conditions and the following disclaimer. | |
12 | * Redistributions in binary form must reproduce the above copyright | |
13 | notice, this list of conditions and the following disclaimer in the | |
14 | documentation and/or other materials provided with the distribution. | |
15 | * Neither the name of Axiomatic Systems nor the | |
16 | names of its contributors may be used to endorse or promote products | |
17 | derived from this software without specific prior written permission. | |
18 | | |
19 | THIS SOFTWARE IS PROVIDED BY AXIOMATIC SYSTEMS ''AS IS'' AND ANY | |
20 | EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | |
21 | WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | |
22 | DISCLAIMED. IN NO EVENT SHALL AXIOMATIC SYSTEMS BE LIABLE FOR ANY | |
23 | DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | |
24 | (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | |
25 | LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | |
26 | ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | |
27 | (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS | |
28 | SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
29 | | |
30 ****************************************************************/ | |
31 | |
32 /*---------------------------------------------------------------------- | |
33 | includes | |
34 +---------------------------------------------------------------------*/ | |
35 #include "NptSimpleMessageQueue.h" | |
36 #include "NptDebug.h" | |
37 | |
38 /*---------------------------------------------------------------------- | |
39 | NPT_SimpleMessageCapsule | |
40 +---------------------------------------------------------------------*/ | |
41 struct NPT_SimpleMessageCapsule | |
42 { | |
43 NPT_SimpleMessageCapsule(NPT_Message* message, | |
44 NPT_MessageHandler* handler) : | |
45 m_Message(message), m_Handler(handler) {} | |
46 NPT_Message* m_Message; | |
47 NPT_MessageHandler* m_Handler; | |
48 }; | |
49 | |
50 /*---------------------------------------------------------------------- | |
51 | NPT_SimpleMessageQueue::NPT_SimpleMessageQueue | |
52 +---------------------------------------------------------------------*/ | |
53 NPT_SimpleMessageQueue::NPT_SimpleMessageQueue() | |
54 { | |
55 } | |
56 | |
57 /*---------------------------------------------------------------------- | |
58 | NPT_SimpleMessageQueue::~NPT_SimpleMessageQueue | |
59 +---------------------------------------------------------------------*/ | |
60 NPT_SimpleMessageQueue::~NPT_SimpleMessageQueue() | |
61 { | |
62 // empty the queue | |
63 // TBD | |
64 } | |
65 | |
66 /*---------------------------------------------------------------------- | |
67 | NPT_SimpleMessageQueue::QueueMessage | |
68 +---------------------------------------------------------------------*/ | |
69 NPT_Result | |
70 NPT_SimpleMessageQueue::QueueMessage(NPT_Message* message, | |
71 NPT_MessageHandler* handler) | |
72 { | |
73 // push the message on the queue, with the handler reference | |
74 return m_Queue.Push(new NPT_SimpleMessageCapsule(message, handler)); | |
75 } | |
76 | |
77 /*---------------------------------------------------------------------- | |
78 | NPT_SimpleMessageQueue::PumpMessage | |
79 +---------------------------------------------------------------------*/ | |
80 NPT_Result | |
81 NPT_SimpleMessageQueue::PumpMessage(NPT_Timeout timeout /* = NPT_TIMEOUT_INFINITE */) | |
82 { | |
83 NPT_SimpleMessageCapsule* capsule; | |
84 NPT_Result result = m_Queue.Pop(capsule, timeout); | |
85 if (NPT_SUCCEEDED(result) && capsule) { | |
86 if (capsule->m_Handler && capsule->m_Message) { | |
87 result = capsule->m_Handler->HandleMessage(capsule->m_Message); | |
88 } | |
89 delete capsule->m_Message; | |
90 delete capsule; | |
91 } | |
92 | |
93 return result; | |
94 } |