Lines Matching refs:udp_entry
65 static struct udp_entry udp_socket_list[FCE_MAX_UDP_SOCKS];
104 struct udp_entry *udp_entry = udp_socket_list + i;
107 if (udp_entry->sock != -1)
108 close(udp_entry->sock);
110 if ((rv = getaddrinfo(udp_entry->addr, udp_entry->port, &hints, &servinfo)) != 0) {
112 udp_entry->addr, udp_entry->port, gai_strerror(rv));
118 if ((udp_entry->sock = socket(p->ai_family, p->ai_socktype, p->ai_protocol)) == -1) {
120 udp_entry->addr, udp_entry->port, strerror(errno));
128 udp_entry->addr, udp_entry->port);
130 udp_entry->addrinfo = *p;
131 memcpy(&udp_entry->addrinfo, p, sizeof(struct addrinfo));
132 memcpy(&udp_entry->sockaddr, p->ai_addr, sizeof(struct sockaddr_storage));
146 struct udp_entry *udp_entry = udp_socket_list + i;
149 if (udp_entry->sock != -1)
151 close( udp_entry->sock );
152 udp_entry->sock = -1;
262 struct udp_entry *udp_entry = udp_socket_list + i;
265 if (udp_entry->sock == -1)
268 if (now < udp_entry->next_try_on_error)
272 udp_entry->sock = socket(udp_entry->addrinfo.ai_family,
273 udp_entry->addrinfo.ai_socktype,
274 udp_entry->addrinfo.ai_protocol);
276 if (udp_entry->sock == -1) {
280 udp_entry->next_try_on_error = now + FCE_SOCKET_RETRY_DELAY_S;
284 udp_entry->next_try_on_error = 0;
290 sendto(udp_entry->sock,
294 (struct sockaddr *)&udp_entry->sockaddr,
295 udp_entry->addrinfo.ai_addrlen);
302 sent_data = sendto(udp_entry->sock,
306 (struct sockaddr *)&udp_entry->sockaddr,
307 udp_entry->addrinfo.ai_addrlen);
313 udp_entry->addr, udp_entry->port, sent_data, data_len, strerror(errno));
315 close( udp_entry->sock );
316 udp_entry->sock = -1;
317 udp_entry->next_try_on_error = now + FCE_SOCKET_RETRY_DELAY_S;