6 #include <netinet/in.h>
7 #include <sys/socket.h>
10 #include "psmb_priv.h"
12 static void dummy_log(void *log_priv, int priority, const char *format, ...) {}
14 psmb_ctx_t *psmb_new(void)
16 return psmb_new_mm(malloc, free, realloc);
19 psmb_ctx_t *psmb_new_mm(void *(*malloc)(size_t size),
20 void (*free)(void *ptr),
21 void *(*realloc)(void *ptr, size_t size))
23 psmb_ctx_t *ctx = (*malloc)(sizeof(psmb_ctx_t));
26 LOG(ctx, LOG_ERR, "failed to allocate psmb_ctx: %m");
32 .malloc = malloc, .free = free, .realloc = realloc,
34 .pmtu = PSMB_DEFAULT_PMTU,
35 .port = PSMB_DEFAULT_PORT};
39 psmb_result_t psmb_set_logf(psmb_ctx_t *ctx,
40 void (*logf)(void *log_priv, int priority, const char *format, ...),
45 ctx->log_priv = log_priv;
46 return (psmb_result_t){PSMB_OK};
48 LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
50 return (psmb_result_t){PSMB_ERROR};
54 psmb_result_t psmb_set_pmtu(psmb_ctx_t *ctx, unsigned int pmtu)
58 return (psmb_result_t){PSMB_OK};
60 LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
62 return (psmb_result_t){PSMB_ERROR};
66 psmb_result_t psmb_set_port(psmb_ctx_t *ctx, unsigned short port)
70 return (psmb_result_t){PSMB_OK};
72 LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
74 return (psmb_result_t){PSMB_ERROR};
78 psmb_result_t psmb_set_mgrp(psmb_ctx_t *ctx, struct in6_addr prefix,
79 unsigned char prefixlen)
83 ctx->prefixlen = prefixlen;
84 return (psmb_result_t){PSMB_OK};
86 LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
88 return (psmb_result_t){PSMB_ERROR};
92 psmb_result_t psmb_open(psmb_ctx_t *ctx)
95 struct sockaddr_in6 addr = (struct sockaddr_in6){
96 .sin6_family = AF_INET6,
97 .sin6_addr = in6addr_any,
98 .sin6_port = htons(ctx->port)
102 LOG(ctx, LOG_ERR, "redundant call to psmb_open()");
104 return (psmb_result_t){PSMB_ERROR};
106 ctx->fd = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP);
109 LOG(ctx, LOG_ERR, "socket: %m");
111 return (psmb_result_t){PSMB_ERROR};
113 if (setsockopt(ctx->fd, SOL_SOCKET, SO_REUSEADDR,
114 &on, sizeof(on)) < 0) {
116 LOG(ctx, LOG_ERR, "setsockopt(..., SO_REUSEADDR, ...): %m");
120 return (psmb_result_t){PSMB_ERROR};
122 if (setsockopt(ctx->fd, IPPROTO_IPV6, IPV6_RECVPKTINFO,
123 &on, sizeof(on)) < 0) {
125 LOG(ctx, LOG_ERR, "setsockopt(..., IPV6_PKTINFO, ...): %m");
129 return (psmb_result_t){PSMB_ERROR};
131 if (bind(ctx->fd, (struct sockaddr *)&addr,
132 sizeof(struct sockaddr_in6)) == -1) {
134 LOG(ctx, LOG_ERR, "bind(): %m");
138 return (psmb_result_t){PSMB_ERROR};
140 return (psmb_result_t){PSMB_OK};
143 void psmb_destroy(psmb_ctx_t *ctx)
146 LOG(ctx, LOG_ERR, "psmb_ctx is not open");
148 if (close(ctx->fd) == -1)
149 LOG(ctx, LOG_ERR, "close(): %m");
151 /* clean up the rest */