File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -56,8 +56,10 @@ s_self_destroy (self_t **self_p)
56
56
self_t * self = * self_p ;
57
57
zframe_destroy (& self -> transmit );
58
58
zframe_destroy (& self -> filter );
59
- if (self -> udpsock ) // don't close STDIN
59
+ if (self -> udpsock != INVALID_SOCKET )
60
60
zsys_udp_close (self -> udpsock );
61
+ if (self -> udpsock_send != INVALID_SOCKET )
62
+ zsys_udp_close (self -> udpsock_send );
61
63
freen (self );
62
64
* self_p = NULL ;
63
65
}
@@ -69,6 +71,8 @@ s_self_new (zsock_t *pipe)
69
71
self_t * self = (self_t * ) zmalloc (sizeof (self_t ));
70
72
assert (self );
71
73
self -> pipe = pipe ;
74
+ self -> udpsock = INVALID_SOCKET ;
75
+ self -> udpsock_send = INVALID_SOCKET ;
72
76
return self ;
73
77
}
74
78
@@ -80,9 +84,9 @@ static void
80
84
s_self_prepare_udp (self_t * self )
81
85
{
82
86
// Create our UDP socket
83
- if (self -> udpsock )
87
+ if (self -> udpsock != INVALID_SOCKET )
84
88
zsys_udp_close (self -> udpsock );
85
- if (self -> udpsock_send )
89
+ if (self -> udpsock_send != INVALID_SOCKET )
86
90
zsys_udp_close (self -> udpsock_send );
87
91
88
92
self -> hostname [0 ] = 0 ;
You can’t perform that action at this time.
0 commit comments