diff options
| -rwxr-xr-x | signal/streamin~.c | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/signal/streamin~.c b/signal/streamin~.c index 437de67..28c0918 100755 --- a/signal/streamin~.c +++ b/signal/streamin~.c @@ -141,7 +141,14 @@ static void streamin_datapoll(t_streamin *x) n = x->nbytes;
if (x->nbytes == 0) { /* get the new tag */
ret = recv(x->x_socket, (char*) &x->frames[x->framein].tag,sizeof(t_tag),MSG_PEEK);
- if (ret != sizeof(t_tag)) return;
+ if (ret != sizeof(t_tag)) {
+#ifdef NT
+ sys_closesocket(x->x_socket);
+ sys_rmpollfn(x->x_socket);
+ x->x_socket = -1;
+#endif
+ return;
+ }
ret = recv(x->x_socket, (char*) &x->frames[x->framein].tag,sizeof(t_tag),0);
x->nbytes = n = x->frames[x->framein].tag.framesize;
|