|
 |
ce4a2db |
Description: systemd-like socket activation support for libmilter
|
|
|
ce4a2db |
Author: Mikhail Gusarov
|
|
|
ce4a2db |
diff --git a/libmilter/docs/smfi_setconn.html b/libmilter/docs/smfi_setconn.html
|
|
|
ce4a2db |
index eba7c5b..5b272a0 100644
|
|
|
ce4a2db |
--- a/libmilter/docs/smfi_setconn.html
|
|
|
ce4a2db |
+++ b/libmilter/docs/smfi_setconn.html
|
|
|
ce4a2db |
@@ -43,6 +43,7 @@ Set the socket through which this filter should communicate with sendmail.
|
|
|
ce4a2db |
{unix|local}:/path/to/file -- A named pipe.
|
|
|
ce4a2db |
inet:port@{hostname|ip-address} -- An IPV4 socket.
|
|
|
ce4a2db |
inet6:port@{hostname|ip-address} -- An IPV6 socket.
|
|
|
ce4a2db |
+ fd:number -- Pre-opened file descriptor.
|
|
|
ce4a2db |
|
|
|
ce4a2db |
|
|
|
ce4a2db |
|
|
|
ce4a2db |
diff --git a/libmilter/listener.c b/libmilter/listener.c
|
|
|
ce4a2db |
index 11d92bb..2ab533d 100644
|
|
|
ce4a2db |
--- a/libmilter/listener.c
|
|
|
ce4a2db |
+++ b/libmilter/listener.c
|
|
|
ce4a2db |
@@ -197,6 +197,11 @@ mi_milteropen(conn, backlog, rmsocket, name)
|
|
|
ce4a2db |
L_socksize = sizeof addr.sin6;
|
|
|
ce4a2db |
}
|
|
|
ce4a2db |
#endif /* NETINET6 */
|
|
|
ce4a2db |
+ else if (strcasecmp(p, "fd") == 0)
|
|
|
ce4a2db |
+ {
|
|
|
ce4a2db |
+ addr.sa.sa_family = AF_UNSPEC;
|
|
|
ce4a2db |
+ L_socksize = sizeof (_SOCK_ADDR);
|
|
|
ce4a2db |
+ }
|
|
|
ce4a2db |
else
|
|
|
ce4a2db |
{
|
|
|
ce4a2db |
smi_log(SMI_LOG_ERR, "%s: unknown socket type %s",
|
|
|
ce4a2db |
@@ -443,7 +448,21 @@ mi_milteropen(conn, backlog, rmsocket, name)
|
|
|
ce4a2db |
}
|
|
|
ce4a2db |
#endif /* NETINET || NETINET6 */
|
|
|
ce4a2db |
|
|
|
ce4a2db |
- sock = socket(addr.sa.sa_family, SOCK_STREAM, 0);
|
|
|
ce4a2db |
+ if (addr.sa.sa_family == AF_UNSPEC)
|
|
|
ce4a2db |
+ {
|
|
|
ce4a2db |
+ char *end;
|
|
|
ce4a2db |
+ sock = strtol(colon, &end, 10);
|
|
|
ce4a2db |
+ if (*end != '\0' || sock < 0)
|
|
|
ce4a2db |
+ {
|
|
|
ce4a2db |
+ smi_log(SMI_LOG_ERR, "%s: expected positive integer as fd, got %s", name, colon);
|
|
|
ce4a2db |
+ return INVALID_SOCKET;
|
|
|
ce4a2db |
+ }
|
|
|
ce4a2db |
+ }
|
|
|
ce4a2db |
+ else
|
|
|
ce4a2db |
+ {
|
|
|
ce4a2db |
+ sock = socket(addr.sa.sa_family, SOCK_STREAM, 0);
|
|
|
ce4a2db |
+ }
|
|
|
ce4a2db |
+
|
|
|
ce4a2db |
if (!ValidSocket(sock))
|
|
|
ce4a2db |
{
|
|
|
ce4a2db |
smi_log(SMI_LOG_ERR,
|
|
|
ce4a2db |
@@ -466,6 +485,7 @@ mi_milteropen(conn, backlog, rmsocket, name)
|
|
|
ce4a2db |
#if NETUNIX
|
|
|
ce4a2db |
addr.sa.sa_family != AF_UNIX &&
|
|
|
ce4a2db |
#endif /* NETUNIX */
|
|
|
ce4a2db |
+ addr.sa.sa_family != AF_UNSPEC &&
|
|
|
ce4a2db |
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (void *) &sockopt,
|
|
|
ce4a2db |
sizeof(sockopt)) == -1)
|
|
|
ce4a2db |
{
|
|
|
ce4a2db |
@@ -511,7 +531,8 @@ mi_milteropen(conn, backlog, rmsocket, name)
|
|
|
ce4a2db |
}
|
|
|
ce4a2db |
#endif /* NETUNIX */
|
|
|
ce4a2db |
|
|
|
ce4a2db |
- if (bind(sock, &addr.sa, L_socksize) < 0)
|
|
|
ce4a2db |
+ if (addr.sa.sa_family != AF_UNSPEC &&
|
|
|
ce4a2db |
+ bind(sock, &addr.sa, L_socksize) < 0)
|
|
|
ce4a2db |
{
|
|
|
ce4a2db |
smi_log(SMI_LOG_ERR,
|
|
|
ce4a2db |
"%s: Unable to bind to port %s: %s",
|
|
|
ce4a2db |
@@ -818,7 +839,7 @@ mi_listener(conn, dbg, smfi, timeout, backlog)
|
|
|
ce4a2db |
# ifdef BSD4_4_SOCKADDR
|
|
|
ce4a2db |
cliaddr.sa.sa_len == 0 ||
|
|
|
ce4a2db |
# endif /* BSD4_4_SOCKADDR */
|
|
|
ce4a2db |
- cliaddr.sa.sa_family != L_family))
|
|
|
ce4a2db |
+ (L_family != AF_UNSPEC && cliaddr.sa.sa_family != L_family)))
|
|
|
ce4a2db |
{
|
|
|
ce4a2db |
(void) closesocket(connfd);
|
|
|
ce4a2db |
connfd = INVALID_SOCKET;
|