#include <stdlib.h>
#include <errno.h>
#include <unistd.h>
+#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <psmb.h>
#include "psmb_priv.h"
+static void dummy_log(void *log_priv, int priority, const char *format, ...) {}
+
psmb_ctx_t *psmb_new(void)
{
return psmb_new_mm(malloc, free, realloc);
void *(*realloc)(void *ptr, size_t size))
{
psmb_ctx_t *ctx = (*malloc)(sizeof(psmb_ctx_t));
- if (!ctx)
+ if (!ctx) {
+ int sverr = errno;
+ LOG(ctx, LOG_ERR, "failed to allocate psmb_ctx: %m");
+ errno = sverr;
return NULL;
+ }
*ctx = (psmb_ctx_t){
.fd = -1,
.malloc = malloc, .free = free, .realloc = realloc,
- .pmtu = PSMB_DEFAULT_PMTU, .port = PSMB_DEFAULT_PORT};
+ .logf = dummy_log,
+ .prefix = (struct in6_addr){{{ 0xff, 0xff, 0x01, 0x05,
+ 0xb0, 0x55, 0xff, 0xe7,
+ 0x00, 0x00, 0x00, 0x00,
+ 0x00, 0x00, 0x00, 0x00 }}},
+ .prefixlen = 64,
+ .pmtu = PSMB_DEFAULT_PMTU,
+ .port = PSMB_DEFAULT_PORT};
return ctx;
}
+psmb_result_t psmb_set_logf(psmb_ctx_t *ctx,
+ void (*logf)(void *log_priv, int priority, const char *format, ...),
+ void *log_priv)
+{
+ if (ctx->fd == -1) {
+ ctx->logf = logf;
+ ctx->log_priv = log_priv;
+ return (psmb_result_t){PSMB_OK};
+ } else {
+ LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
+ errno = EBUSY;
+ return (psmb_result_t){PSMB_ERROR};
+ }
+}
+
psmb_result_t psmb_set_pmtu(psmb_ctx_t *ctx, unsigned int pmtu)
{
if (ctx->fd == -1) {
ctx->pmtu = pmtu;
return (psmb_result_t){PSMB_OK};
} else {
+ LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
errno = EBUSY;
return (psmb_result_t){PSMB_ERROR};
}
ctx->port = port;
return (psmb_result_t){PSMB_OK};
} else {
+ LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
+ errno = EBUSY;
+ return (psmb_result_t){PSMB_ERROR};
+ }
+}
+
+psmb_result_t psmb_set_mgrp(psmb_ctx_t *ctx, struct in6_addr prefix,
+ unsigned char prefixlen)
+{
+ if (ctx->fd == -1) {
+ ctx->prefix = prefix;
+ ctx->prefixlen = prefixlen;
+ return (psmb_result_t){PSMB_OK};
+ } else {
+ LOG(ctx, LOG_ERR, "psmb_set_...() used after psmb_open()");
errno = EBUSY;
return (psmb_result_t){PSMB_ERROR};
}
};
if (ctx->fd != -1) {
+ LOG(ctx, LOG_ERR, "redundant call to psmb_open()");
errno = EBUSY;
return (psmb_result_t){PSMB_ERROR};
}
- ctx->fd = socket(AF_INET6, SOCK_DGRAM, IPPROTO_IPV6);
+ ctx->fd = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP);
if (ctx->fd == -1) {
+ int sverr = errno;
+ LOG(ctx, LOG_ERR, "socket: %m");
+ errno = sverr;
return (psmb_result_t){PSMB_ERROR};
}
if (setsockopt(ctx->fd, SOL_SOCKET, SO_REUSEADDR,
&on, sizeof(on)) < 0) {
+ int sverr = errno;
+ LOG(ctx, LOG_ERR, "setsockopt(..., SO_REUSEADDR, ...): %m");
close(ctx->fd);
ctx->fd = -1;
+ errno = sverr;
return (psmb_result_t){PSMB_ERROR};
}
- if (setsockopt(ctx->fd, IPPROTO_IPV6, IPV6_PKTINFO,
+ if (setsockopt(ctx->fd, IPPROTO_IPV6, IPV6_RECVPKTINFO,
&on, sizeof(on)) < 0) {
+ int sverr = errno;
+ LOG(ctx, LOG_ERR, "setsockopt(..., IPV6_PKTINFO, ...): %m");
close(ctx->fd);
ctx->fd = -1;
+ errno = sverr;
return (psmb_result_t){PSMB_ERROR};
}
if (bind(ctx->fd, (struct sockaddr *)&addr,
- sizeof(struct sockaddr)) == -1) {
+ sizeof(struct sockaddr_in6)) == -1) {
+ int sverr = errno;
+ LOG(ctx, LOG_ERR, "bind(): %m");
close(ctx->fd);
ctx->fd = -1;
+ errno = sverr;
return (psmb_result_t){PSMB_ERROR};
}
return (psmb_result_t){PSMB_OK};
}
+
+static psmb_result_t psmb_sub_unsub(psmb_ctx_t *ctx, char *channel, int option)
+{
+ struct ipv6_mreq mreq = { 0 };
+
+ if (ctx->fd == -1) {
+ LOG(ctx, LOG_ERR, "subscribe: psmb is not open");
+ errno = EINVAL;
+ return (psmb_result_t){PSMB_ERROR};
+ }
+ mreq.ipv6mr_multiaddr = ctx->prefix; /* use hash of the channel */
+ mreq.ipv6mr_interface = 0; /* how to use this??? */
+ if (setsockopt(ctx->fd, IPPROTO_IPV6, option,
+ (void *)&mreq, sizeof(mreq)) == -1) {
+ int sverr = errno;
+ LOG(ctx, LOG_ERR, "add_membership(): %m");
+ errno = sverr;
+ return (psmb_result_t){PSMB_ERROR};
+ }
+ return (psmb_result_t){PSMB_OK};
+}
+
+psmb_result_t psmb_subscribe(psmb_ctx_t *ctx, char *channel) {
+ return psmb_sub_unsub(ctx, channel, IPV6_ADD_MEMBERSHIP);
+}
+
+psmb_result_t psmb_unsubscribe(psmb_ctx_t *ctx, char *channel) {
+ return psmb_sub_unsub(ctx, channel, IPV6_DROP_MEMBERSHIP);
+}
+
+bool psmb_success(psmb_result_t result)
+{
+ return !(result.code & PSMB_ERROR);
+}
+
+bool psmb_message_waiting(psmb_result_t result)
+{
+ return !!(result.code & PSMB_MESSAGE);
+}
+
+bool psmb_need_write_wait(psmb_result_t result)
+{
+ return !!(result.code & PSMB_NEED_WRITE);
+}
+
+void psmb_destroy(psmb_ctx_t *ctx)
+{
+ if (ctx->fd == -1) {
+ LOG(ctx, LOG_ERR, "psmb_ctx is not open");
+ } else {
+ if (close(ctx->fd) == -1)
+ LOG(ctx, LOG_ERR, "close(): %m");
+ }
+ /* clean up the rest */
+ (*ctx->free)(ctx);
+}