forked from tsee/ZeroMQ-Perl
-
Notifications
You must be signed in to change notification settings - Fork 1
/
ZeroMQ.xsp
175 lines (159 loc) · 4.24 KB
/
ZeroMQ.xsp
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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
%module{ZeroMQ};
// catch the error_t exceptions with a helpful message
%exception{ZMQException}{zmq::error_t}{stdmessage};
/////////////////////////////////////////////////////////////////////////
%name{ZeroMQ::Context}
class context_t
%catch{ZMQException}
{
%name{new} context_t(int io_threads);
~context_t();
};
/////////////////////////////////////////////////////////////////////////
%name{ZeroMQ::Socket}
class socket_t
%catch{ZMQException}
{
%name{new} socket_t(context_t& context, int type);
~socket_t();
%{
void
socket_t::getsockopt(option_name)
int option_name;
PPCODE:
dTARG;
size_t len = 0;
try {
switch (option_name) {
case ZMQ_RCVMORE:
case ZMQ_HWM:
case ZMQ_SWAP:
case ZMQ_AFFINITY:
{
int64_t rv;
THIS->getsockopt(option_name, (void*)&rv, &len);
XPUSHi((IV)rv);
}
case ZMQ_IDENTITY:
{
void* rv;
Newx(rv, 255, char);
THIS->getsockopt(option_name, (void*)&rv, &len);
XPUSHs(sv_2mortal(newSVpv((char*)rv, len)));
Safefree(rv);
}
case ZMQ_RATE:
case ZMQ_RECOVERY_IVL:
case ZMQ_MCAST_LOOP:
case ZMQ_SNDBUF:
case ZMQ_RCVBUF:
{
uint64_t rv;
THIS->getsockopt(option_name, (void*)&rv, &len);
XPUSHu((UV)rv);
}
default:
XPUSHs(&PL_sv_undef);
};
} /* end try */
catch (zmq::error_t& e) {
croak("Caught C++ exception of type or derived from 'zmq::error_t': %s", e.what());
}
catch (...) {
croak("Caught C++ exception of unknown type");
}
%}
void
setsockopt(int option_name, char* option_value, size_t %length{option_value})
%code{%
dTARG;
try {
switch (option_name) {
case ZMQ_HWM:
case ZMQ_SWAP:
case ZMQ_AFFINITY:
{
int64_t v = atoi(option_value);
THIS->setsockopt(option_name, (void*)&v, sizeof(int64_t));
}
case ZMQ_IDENTITY:
case ZMQ_SUBSCRIBE:
case ZMQ_UNSUBSCRIBE:
{
THIS->setsockopt(option_name, (void*)option_value, length(option_value));
}
case ZMQ_RATE:
case ZMQ_RECOVERY_IVL:
case ZMQ_MCAST_LOOP:
case ZMQ_SNDBUF:
case ZMQ_RCVBUF:
{
uint64_t v = atoi(option_value);
THIS->setsockopt(option_name, (void*)&v, sizeof(uint64_t));
}
//default:
/*throw zmq::error_t(); // reads errnum...*/
};
} /* end try */
catch (zmq::error_t& e) {
croak("Caught C++ exception of type or derived from 'zmq::error_t': %s", e.what());
}
catch (...) {
croak("Caught C++ exception of unknown type");
}
%};
//void socket_t::setsockopt(int option_name, const void *option_value, size_t option_len)
void bind(char* endpoint);
void connect(char* endpoint);
bool send(message_t& msg, int flags = 0);
//bool recv(message_t* msg, int flags = 0);
// FIXME needs exception handling...
{%
void
socket_t::recv(flags = 0)
int flags;
PPCODE:
message_t* rv = new message_t();
try {
if (!THIS->recv(rv, flags)) {
delete rv;
XPUSHs(&PL_sv_undef);
}
else {
XPUSHmortal;
sv_setref_pv(ST(0), "ZeroMQ::Message", (void*)rv);
}
}
catch (zmq::error_t& e) {
delete rv;
croak("Caught C++ exception of type or derived from 'zmq::error_t': %s", e.what());
}
catch (...) {
delete rv;
croak("Caught C++ exception of unknown type");
}
%}
};
/////////////////////////////////////////////////////////////////////////
%name{ZeroMQ::Message}
class message_t
%catch{ZMQException}
{
%name{new} message_t(char* data, size_t %length{data})
%code{%
/* Note: we need to copy data and provide a cleanup function */
RETVAL = new zmq::message_t(data, length(data), NULL);
%};
//%name{new} message_t();
//%name{new} message_t(size_t size_);
//%name{new} message_t(MsgData* data, size_t size_, free_fn *ffn_, void *hint_ = NULL);
~message_t();
size_t size();
//MsgData* data();
%{
void
message_t::data()
PPCODE:
XPUSHs(sv_2mortal(newSVpv((char*)THIS->data(), THIS->size())));
%}
};