* Append new socket option to flowopt queue.
*
* \param fo The flowopt queue to append to.
- * \param lev Level at which \opt resides.
+ * \param lev Level at which \a opt resides.
* \param opt New option to add.
* \param name Stringified name of \a opt.
* \param val The value to set \a opt to.
/**
* Resolve IPv4/IPv6 address and create a ready-to-use active or passive socket.
*
- * \param l3type The layer-3 type (\p AF_INET, \p AF_INET6, \p AF_UNSPEC).
* \param l4type The layer-4 type (\p IPPROTO_xxx).
* \param passive Whether this is a passive (1) or active (0) socket.
* \param host Remote or local hostname or IPv/6 address string.
struct addrinfo *local = NULL, *src,
*remote = NULL, *dst, hints;
unsigned int l3type = AF_UNSPEC;
- int rc, sockfd = -1,
+ int rc, on = 1, sockfd = -1,
socktype = sock_type(l4type);
char port[6]; /* port number has at most 5 digits */
if (sockfd < 0)
goto get_next_dst;
+ /*
+ * Reuse the address on passive sockets to avoid failure on
+ * restart (protocols using listen()) and when creating
+ * multiple listener instances (UDP multicast).
+ */
+ if (passive && setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR,
+ &on, sizeof(on)) == -1) {
+ rc = errno;
+ close(sockfd);
+ PARA_ERROR_LOG("can not set SO_REUSEADDR: %s\n",
+ strerror(rc));
+ return -ERRNO_TO_PARA_ERROR(rc);
+ }
flowopt_setopts(sockfd, fo);
if (src) {
*/
int para_listen(unsigned l4type, uint16_t port, struct flowopts *fo)
{
- int fd, ret;
-
- if (fo == NULL)
- fo = flowopt_new();
-
- /* Reuse the address to avoid failure on restart. */
- OPT_ENABLE(fo, SOL_SOCKET, SO_REUSEADDR);
+ int ret, fd = makesock(l4type, 1, NULL, port, fo);
- fd = makesock(l4type, 1, NULL, port, fo);
if (fd > 0) {
ret = listen(fd, BACKLOG);
if (ret < 0) {
}
/**
- * Probe the list of DCCP CCIDs supported locally by the host.
- * \param ccids Array to be filled in.
- * \param nccids Length of \a ccids.
- * \return Pointer to \a ccids, NULL on failure.
+ * Probe the list of DCCP CCIDs configured on this host.
+ * \param ccid_array Pointer to return statically allocated array in.
+ * \return Number of elements returned in \a ccid_array or error.
*
* NB: This feature is only available on Linux > 2.6.30; on older kernels
* ENOPROTOOPT ("Protocol not available") will be returned.
*/
-const uint8_t *dccp_available_ccids(uint8_t *ccids, uint8_t *nccids)
+int dccp_available_ccids(uint8_t **ccid_array)
{
- int fd = makesock(IPPROTO_DCCP, 1, NULL, 0, NULL);
+ static uint8_t ccids[DCCP_MAX_HOST_CCIDS];
+ socklen_t nccids = sizeof(ccids);
+ int ret, fd;
- if (fd < 0)
- return NULL;
+ ret = fd = makesock(IPPROTO_DCCP, 1, NULL, 0, NULL);
+ if (ret < 0)
+ return ret;
if (getsockopt(fd, SOL_DCCP, DCCP_SOCKOPT_AVAILABLE_CCIDS,
- ccids, (socklen_t *)nccids) < 0) {
+ ccids, &nccids) < 0) {
+ ret = errno;
+ close(fd);
PARA_ERROR_LOG("No DCCP_SOCKOPT_AVAILABLE_CCIDS: %s\n",
- strerror(errno));
- *nccids = 0;
+ strerror(ret));
+ return -ERRNO_TO_PARA_ERROR(ret);
}
- close(fd);
- return *nccids ? ccids : NULL;
+ close(fd);
+ *ccid_array = ccids;
+ return nccids;
}
/**