equal
deleted
inserted
replaced
136 { |
136 { |
137 guint8 buffer[GST_NET_TIME_PACKET_SIZE]; |
137 guint8 buffer[GST_NET_TIME_PACKET_SIZE]; |
138 gint ret; |
138 gint ret; |
139 |
139 |
140 while (TRUE) { |
140 while (TRUE) { |
141 #ifdef G_OS_WIN32 |
|
142 ret = recvfrom (fd, (char *) buffer, GST_NET_TIME_PACKET_SIZE, |
|
143 #else |
|
144 ret = recvfrom (fd, buffer, GST_NET_TIME_PACKET_SIZE, |
141 ret = recvfrom (fd, buffer, GST_NET_TIME_PACKET_SIZE, |
145 #endif |
|
146 0, (struct sockaddr *) addr, len); |
142 0, (struct sockaddr *) addr, len); |
147 if (ret < 0) { |
143 if (ret < 0) { |
148 if (errno != EAGAIN && errno != EINTR) |
144 if (errno != EAGAIN && errno != EINTR) |
149 goto receive_error; |
145 goto receive_error; |
150 else |
146 else |
215 |
211 |
216 buffer = gst_net_time_packet_serialize (packet); |
212 buffer = gst_net_time_packet_serialize (packet); |
217 |
213 |
218 #ifdef G_OS_WIN32 |
214 #ifdef G_OS_WIN32 |
219 ioctlsocket (fd, FIONBIO, &flags); /* Set nonblocking mode */ |
215 ioctlsocket (fd, FIONBIO, &flags); /* Set nonblocking mode */ |
220 ret = |
216 #endif |
221 sendto (fd, (char *) buffer, GST_NET_TIME_PACKET_SIZE, send_flags, addr, |
217 |
222 len); |
|
223 #else |
|
224 ret = sendto (fd, buffer, GST_NET_TIME_PACKET_SIZE, send_flags, addr, len); |
218 ret = sendto (fd, buffer, GST_NET_TIME_PACKET_SIZE, send_flags, addr, len); |
225 #endif |
|
226 |
219 |
227 #ifdef __CYGWIN__ |
220 #ifdef __CYGWIN__ |
228 fcntl (fd, F_SETFL, fdflags); |
221 fcntl (fd, F_SETFL, fdflags); |
229 #endif |
222 #endif |
230 |
223 |