@@ -44,17 +44,20 @@ determine_socket( const char *bind)
44
44
if (zrex_eq (rex , bind , "^(.+)://.*" ) )
45
45
{
46
46
const char * transport = zrex_hit (rex , 1 );
47
- if ( streq (transport , "udp" ) )
48
- retsock = zsock_new_dgram (bind );
49
47
48
+ if ( streq (transport , "ipc" ) )
49
+ retsock = zsock_new_pull ( bind );
50
+ #ifdef ZMQ_DGRAM
51
+ else if ( streq (transport , "udp ") )
52
+ retsock = zsock_new_dgram (bind );
53
+ #endif
54
+ #ifdef ZMQ_STREAM
50
55
else if ( streq (transport , "tcp ") )
51
56
{
52
57
retsock = zsock_new (ZMQ_STREAM );
53
- zsock_bind (retsock , bind );
58
+ zsock_bind (retsock , "%s" , bind );
54
59
}
55
-
56
- else if ( streq (transport , "ipc" ) )
57
- retsock = zsock_new_pull ( bind );
60
+ #endif
58
61
59
62
else
60
63
zsys_error ("Not a valid transport in %s" , transport );
@@ -70,6 +73,7 @@ determine_socket( const char *bind)
70
73
return NULL ;
71
74
}
72
75
76
+
73
77
void
74
78
recv_dgram (zmsg_t * msg )
75
79
{
@@ -173,12 +177,16 @@ main (int argc, char *argv [])
173
177
174
178
switch ( zsock_type (which ) )
175
179
{
180
+ #ifdef ZMQ_DGRAM
176
181
case ZMQ_DGRAM :
177
182
recv_dgram (msg );
178
183
break ;
184
+ #endif
185
+ #ifdef ZMQ_STREAM
179
186
case ZMQ_STREAM :
180
187
recv_stream (msg );
181
188
break ;
189
+ #endif
182
190
default :
183
191
zsys_error ("Unsupported socket type" );
184
192
break ;
@@ -188,11 +196,11 @@ main (int argc, char *argv [])
188
196
}
189
197
190
198
zpoller_destroy (& poller );
191
- zsock_t * sock = zlist_first (sockets );
199
+ zsock_t * sock = ( zsock_t * ) zlist_first (sockets );
192
200
while (sock )
193
201
{
194
202
zsock_destroy (& sock );
195
- sock = zlist_next (sockets );
203
+ sock = ( zsock_t * ) zlist_next (sockets );
196
204
}
197
205
198
206
return ret ;
0 commit comments