blob: 05cf46a8b7b599d8d9e7c0c004e4e0d53816e49d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
/*****************************************************************
|
| Neptune - Cocoa Message Queue
|
| (c) 2001-2008 Gilles Boccon-Gibod
| Author: Gilles Boccon-Gibod (bok@bok.net)
|
****************************************************************/
/*----------------------------------------------------------------------
| includes
+---------------------------------------------------------------------*/
#include "NptConfig.h"
#import <Foundation/Foundation.h>
#include "NptCocoaMessageQueue.h"
/*----------------------------------------------------------------------
| NPT_CocoaMessageWrapper
+---------------------------------------------------------------------*/
@interface NPT_CocoaMessageCapsule : NSObject
{
NPT_Message* message;
NPT_MessageHandler* handler;
NPT_MessageHandlerProxy* proxy;
}
-(id) initWithMessage: (NPT_Message*) message andHandler: (NPT_MessageHandler*) handler;
-(void) handle;
@end
@implementation NPT_CocoaMessageCapsule
-(id) initWithMessage: (NPT_Message*) aMessage andHandler: (NPT_MessageHandler*) aHandler
{
if ((self = [super init])) {
message = aMessage;
handler = aHandler;
proxy = NPT_DYNAMIC_CAST(NPT_MessageHandlerProxy, aHandler);
if (proxy) proxy->AddReference();
}
return self;
}
-(void) dealloc
{
delete message;
if (proxy) proxy->Release();
[super dealloc];
}
-(void) handle
{
if (handler && message) {
handler->HandleMessage(message);
}
}
@end
/*----------------------------------------------------------------------
| NPT_CocoaMessageQueue::NPT_CocoaMessageQueue
+---------------------------------------------------------------------*/
NPT_CocoaMessageQueue::NPT_CocoaMessageQueue()
{
}
/*----------------------------------------------------------------------
| NPT_CocoaMessageQueue::~NPT_CocoaMessageQueue
+---------------------------------------------------------------------*/
NPT_CocoaMessageQueue::~NPT_CocoaMessageQueue()
{
}
/*----------------------------------------------------------------------
| NPT_CocoaMessageQueue::PumpMessage
+---------------------------------------------------------------------*/
NPT_Result
NPT_CocoaMessageQueue::PumpMessage(NPT_Timeout)
{
// you cannot pump messages on this type of queue, since they will
// be pumped by the main application message loop
return NPT_ERROR_NOT_SUPPORTED;
}
/*----------------------------------------------------------------------
| NPT_CocoaMessageQueue::QueueMessage
+---------------------------------------------------------------------*/
NPT_Result
NPT_CocoaMessageQueue::QueueMessage(NPT_Message* message,
NPT_MessageHandler* handler)
{
// create a capsule to represent the message and handler
NPT_CocoaMessageCapsule* capsule = [NPT_CocoaMessageCapsule alloc];
[capsule initWithMessage: message andHandler: handler];
// trigger the handling of the message on the main thread
[capsule performSelectorOnMainThread: @selector(handle)
withObject: nil
waitUntilDone: FALSE];
// we no longer hold a reference to the capsule (it will be released
// by the receiving thread)
[capsule release];
return NPT_SUCCESS;
}
|
