5 #include <netinet/in.h>
6 #include <sys/socket.h>
11 static void dummy_log(void *log_priv, int priority, const char *format, ...) {}
13 psmb_ctx_t *psmb_new(void)
15 return psmb_new_mm(malloc, free, realloc);
18 psmb_ctx_t *psmb_new_mm(void *(*malloc)(size_t size),
19 void (*free)(void *ptr),
20 void *(*realloc)(void *ptr, size_t size))
22 psmb_ctx_t *ctx = (*malloc)(sizeof(psmb_ctx_t));
25 LOG(ctx, LOG_ERR, "failed to allocate psmb_ctx: %m");
31 .malloc = malloc, .free = free, .realloc = realloc,
33 .pmtu = PSMB_DEFAULT_PMTU,
34 .port = PSMB_DEFAULT_PORT};
38 psmb_result_t psmb_set_logf(psmb_ctx_t *ctx,
39 void (*logf)(void *log_priv, int priority, const char *format, ...),
44 ctx->log_priv = log_priv;
45 return (psmb_result_t){PSMB_OK};
47 LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
49 return (psmb_result_t){PSMB_ERROR};
53 psmb_result_t psmb_set_pmtu(psmb_ctx_t *ctx, unsigned int pmtu)
57 return (psmb_result_t){PSMB_OK};
59 LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
61 return (psmb_result_t){PSMB_ERROR};
65 psmb_result_t psmb_set_port(psmb_ctx_t *ctx, unsigned short port)
69 return (psmb_result_t){PSMB_OK};
71 LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
73 return (psmb_result_t){PSMB_ERROR};
77 psmb_result_t psmb_set_mgrp(psmb_ctx_t *ctx, struct in6_addr prefix,
78 unsigned char prefixlen)
82 ctx->prefixlen = prefixlen;
83 return (psmb_result_t){PSMB_OK};
85 LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
87 return (psmb_result_t){PSMB_ERROR};
91 psmb_result_t psmb_open(psmb_ctx_t *ctx)
94 struct sockaddr_in6 addr = (struct sockaddr_in6){
95 .sin6_family = AF_INET6,
96 .sin6_addr = in6addr_any,
97 .sin6_port = htons(ctx->port)
101 LOG(ctx, LOG_ERR, "redundant call to psmb_open()");
103 return (psmb_result_t){PSMB_ERROR};
105 ctx->fd = socket(AF_INET6, SOCK_DGRAM, IPPROTO_IPV6);
108 LOG(ctx, LOG_ERR, "socket: %m");
110 return (psmb_result_t){PSMB_ERROR};
112 if (setsockopt(ctx->fd, SOL_SOCKET, SO_REUSEADDR,
113 &on, sizeof(on)) < 0) {
115 LOG(ctx, LOG_ERR, "setsockopt(..., SO_REUSEADDR, ...): %m");
119 return (psmb_result_t){PSMB_ERROR};
121 if (setsockopt(ctx->fd, IPPROTO_IPV6, IPV6_PKTINFO,
122 &on, sizeof(on)) < 0) {
124 LOG(ctx, LOG_ERR, "setsockopt(..., IPV6_PKTINFO, ...): %m");
128 return (psmb_result_t){PSMB_ERROR};
130 if (bind(ctx->fd, (struct sockaddr *)&addr,
131 sizeof(struct sockaddr)) == -1) {
133 LOG(ctx, LOG_ERR, "bind(): %m");
137 return (psmb_result_t){PSMB_ERROR};
139 return (psmb_result_t){PSMB_OK};
142 void psmb_destroy(psmb_ctx_t *ctx)
145 LOG(ctx, LOG_ERR, "psmb_ctx is not open");
147 if (close(ctx->fd) == -1)
148 LOG(ctx, LOG_ERR, "close(): %m");
150 /* clean up the rest */