Lines Matching refs:udp_fd
85 int udp_fd;
359 int udp_fd = -1;
372 udp_fd = ff_socket(res->ai_family, SOCK_DGRAM, IPPROTO_UDPLITE, h);
374 udp_fd = ff_socket(res->ai_family, SOCK_DGRAM, 0, h);
375 if (udp_fd != -1) break;
379 if (udp_fd < 0)
387 return udp_fd;
390 if (udp_fd >= 0)
391 closesocket(udp_fd);
448 if (connect(s->udp_fd, (struct sockaddr *) &s->dest_addr,
480 return s->udp_fd;
492 if (ff_socket_nonblock(s->udp_fd, 0) < 0) {
507 len = recvfrom(s->udp_fd, s->tmp+4, sizeof(s->tmp)-4, 0, (struct sockaddr *)&addr, &addr_len);
557 if (ff_socket_nonblock(s->udp_fd, 0) < 0) {
613 ret = sendto (s->udp_fd, p, len, 0,
617 ret = send(s->udp_fd, p, len, 0);
648 int port, udp_fd = -1, tmp, bind_ret = -1, dscp = -1;
780 udp_fd = udp_socket_create(h, &my_addr, &len, s->localaddr);
781 if (udp_fd < 0) {
793 if (setsockopt (udp_fd, SOL_SOCKET, SO_REUSEADDR, &(s->reuse_socket), sizeof(s->reuse_socket)) != 0) {
801 if (setsockopt (udp_fd, SOL_SOCKET, SO_BROADCAST, &(s->is_broadcast), sizeof(s->is_broadcast)) != 0) {
816 if (setsockopt (udp_fd, IPPROTO_UDPLITE, UDPLITE_SEND_CSCOV, &(s->udplite_coverage), sizeof(s->udplite_coverage)) != 0)
819 if (setsockopt (udp_fd, IPPROTO_UDPLITE, UDPLITE_RECV_CSCOV, &(s->udplite_coverage), sizeof(s->udplite_coverage)) != 0)
825 if (setsockopt (udp_fd, IPPROTO_IP, IP_TOS, &dscp, sizeof(dscp)) != 0) {
836 bind_ret = bind(udp_fd,(struct sockaddr *)&s->dest_addr, len);
841 if (bind_ret < 0 && bind(udp_fd,(struct sockaddr *)&my_addr, len) < 0) {
848 getsockname(udp_fd, (struct sockaddr *)&my_addr, &len);
854 if ((ret = udp_set_multicast_ttl(udp_fd, s->ttl, (struct sockaddr *)&s->dest_addr, h)) < 0)
860 if ((ret = udp_set_multicast_sources(h, udp_fd,
867 if ((ret = udp_join_multicast_group(udp_fd, (struct sockaddr *)&s->dest_addr,
872 if ((ret = udp_set_multicast_sources(h, udp_fd,
885 if (setsockopt(udp_fd, SOL_SOCKET, SO_SNDBUF, &tmp, sizeof(tmp)) < 0) {
893 if (setsockopt(udp_fd, SOL_SOCKET, SO_RCVBUF, &tmp, sizeof(tmp)) < 0) {
897 if (getsockopt(udp_fd, SOL_SOCKET, SO_RCVBUF, &tmp, &len) < 0) {
906 ff_socket_nonblock(udp_fd, 1);
909 if (connect(udp_fd, (struct sockaddr *) &s->dest_addr, s->dest_addr_len)) {
916 s->udp_fd = udp_fd;
967 if (udp_fd >= 0)
968 closesocket(udp_fd);
1036 ret = ff_network_wait_fd(s->udp_fd, 0);
1040 ret = recvfrom(s->udp_fd, buf, size, 0, (struct sockaddr *)&addr, &addr_len);
1083 ret = ff_network_wait_fd(s->udp_fd, 1);
1089 ret = sendto (s->udp_fd, buf, size, 0,
1093 ret = send(s->udp_fd, buf, size, 0);
1113 udp_leave_multicast_group(s->udp_fd, (struct sockaddr *)&s->dest_addr,
1124 shutdown(s->udp_fd, SD_RECEIVE);
1125 CancelIoEx((HANDLE)(SOCKET)s->udp_fd, NULL);
1137 closesocket(s->udp_fd);