summaryrefslogtreecommitdiff
path: root/src/qmail-qmqpc.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/qmail-qmqpc.c')
-rw-r--r--src/qmail-qmqpc.c163
1 files changed, 98 insertions, 65 deletions
diff --git a/src/qmail-qmqpc.c b/src/qmail-qmqpc.c
index c92e072..2bbfdfe 100644
--- a/src/qmail-qmqpc.c
+++ b/src/qmail-qmqpc.c
@@ -1,61 +1,94 @@
-#include <unistd.h>
-#include <sys/types.h>
-#include <sys/socket.h>
-#include <netinet/in.h>
#include <arpa/inet.h>
+#include <netinet/in.h>
+#include <sys/socket.h>
+#include <sys/types.h>
+#include <unistd.h>
+
#include "buffer.h"
-#include "getln.h"
#include "exit.h"
-#include "stralloc.h"
-#include "readclose.h"
-#include "timeoutconn.h"
+#include "fmt.h"
+#include "getln.h"
+#include "ip.h"
#include "logmsg.h"
-#include "str.h"
+#include "readclose.h"
#include "sig.h"
-#include "ip.h"
+#include "socket_if.h"
+#include "str.h"
+#include "stralloc.h"
#include "timeout.h"
+#include "timeoutconn.h"
+#include "uint_t.h"
+
#include "auto_qmail.h"
#include "control.h"
-#include "fmt.h"
-#include "uint_t.h"
-#include "socket_if.h"
#define PORT_QMQP 628
-void die_success() { _exit(0); }
-void die_perm() { _exit(31); }
-void nomem() { _exit(51); }
-void die_read() { if (errno == ENOMEM) nomem(); _exit(54); }
-void die_control() { _exit(55); }
-void die_socket() { _exit(56); }
-void die_home() { _exit(61); }
-void die_temp() { _exit(71); }
-void die_conn() { _exit(74); }
-void die_format() { _exit(91); }
+void die_success()
+{
+ _exit(0);
+}
+void die_perm()
+{
+ _exit(31);
+}
+void nomem()
+{
+ _exit(51);
+}
+void die_read()
+{
+ if (errno == ENOMEM) nomem();
+ _exit(54);
+}
+void die_control()
+{
+ _exit(55);
+}
+void die_socket()
+{
+ _exit(56);
+}
+void die_home()
+{
+ _exit(61);
+}
+void die_temp()
+{
+ _exit(71);
+}
+void die_conn()
+{
+ _exit(74);
+}
+void die_format()
+{
+ _exit(91);
+}
int lasterror = 55;
int qmqpfd;
-ssize_t saferead(int fd,char *buf,int len)
+ssize_t saferead(int fd, char *buf, int len)
{
int r;
- r = timeoutread(60,qmqpfd,buf,len);
+ r = timeoutread(60, qmqpfd, buf, len);
if (r <= 0) die_conn();
return r;
}
-ssize_t safewrite(int fd,char *buf,int len)
+ssize_t safewrite(int fd, char *buf, int len)
{
int r;
- r = timeoutwrite(60,qmqpfd,buf,len);
+ r = timeoutwrite(60, qmqpfd, buf, len);
if (r <= 0) die_conn();
return r;
}
char buf[1024];
-buffer bo = BUFFER_INIT(safewrite,-1,buf,sizeof(buf));
-buffer bi = BUFFER_INIT(saferead,-1,buf,sizeof(buf));
-buffer be = BUFFER_INIT(read,1,buf,sizeof(buf)); // envelope
+buffer bo = BUFFER_INIT(safewrite, -1, buf, sizeof(buf));
+buffer bi = BUFFER_INIT(saferead, -1, buf, sizeof(buf));
+buffer be = BUFFER_INIT(read, 1, buf, sizeof(buf)); // envelope
/* WARNING: can use only one of these at a time! */
stralloc beforemessage = {0};
@@ -69,35 +102,35 @@ void getmess()
{
int match;
- if (readclose_append(0,&message,1024) == -1) die_read();
+ if (readclose_append(0, &message, 1024) == -1) die_read();
- strnum[fmt_ulong(strnum,(unsigned long) message.len)] = 0;
- if (!stralloc_copys(&beforemessage,strnum)) nomem();
- if (!stralloc_cats(&beforemessage,":")) nomem();
- if (!stralloc_copys(&aftermessage,",")) nomem();
+ strnum[fmt_ulong(strnum, (unsigned long)message.len)] = 0;
+ if (!stralloc_copys(&beforemessage, strnum)) nomem();
+ if (!stralloc_cats(&beforemessage, ":")) nomem();
+ if (!stralloc_copys(&aftermessage, ",")) nomem();
- if (getln(&be,&line,&match,'\0') == -1) die_read();
+ if (getln(&be, &line, &match, '\0') == -1) die_read();
if (!match) die_format();
if (line.len < 2) die_format();
if (line.s[0] != 'F') die_format();
- strnum[fmt_ulong(strnum,(unsigned long) line.len - 2)] = 0;
- if (!stralloc_cats(&aftermessage,strnum)) nomem();
- if (!stralloc_cats(&aftermessage,":")) nomem();
- if (!stralloc_catb(&aftermessage,line.s + 1,line.len - 2)) nomem();
- if (!stralloc_cats(&aftermessage,",")) nomem();
+ strnum[fmt_ulong(strnum, (unsigned long)line.len - 2)] = 0;
+ if (!stralloc_cats(&aftermessage, strnum)) nomem();
+ if (!stralloc_cats(&aftermessage, ":")) nomem();
+ if (!stralloc_catb(&aftermessage, line.s + 1, line.len - 2)) nomem();
+ if (!stralloc_cats(&aftermessage, ",")) nomem();
for (;;) {
- if (getln(&be,&line,&match,'\0') == -1) die_read();
+ if (getln(&be, &line, &match, '\0') == -1) die_read();
if (!match) die_format();
if (line.len < 2) break;
if (line.s[0] != 'T') die_format();
- strnum[fmt_ulong(strnum,(unsigned long) line.len - 2)] = 0;
- if (!stralloc_cats(&aftermessage,strnum)) nomem();
- if (!stralloc_cats(&aftermessage,":")) nomem();
- if (!stralloc_catb(&aftermessage,line.s + 1,line.len - 2)) nomem();
- if (!stralloc_cats(&aftermessage,",")) nomem();
+ strnum[fmt_ulong(strnum, (unsigned long)line.len - 2)] = 0;
+ if (!stralloc_cats(&aftermessage, strnum)) nomem();
+ if (!stralloc_cats(&aftermessage, ":")) nomem();
+ if (!stralloc_catb(&aftermessage, line.s + 1, line.len - 2)) nomem();
+ if (!stralloc_cats(&aftermessage, ",")) nomem();
}
}
@@ -110,23 +143,23 @@ void doit(char *server)
char ch;
int i, j, r;
- i = str_chr(server,':');
+ i = str_chr(server, ':');
if (server[i] == ':') {
- j = str_chr(server,'%'); /* IF index */
+ j = str_chr(server, '%'); /* IF index */
if (server[j] == '%') {
server[j] = 0;
netif = &server[j + 1];
ifidx = socket_getifidx(netif);
- }
- if (!ip6_scan(server,(char *)&ip6s.d)) return;
- qmqpfd = socket(AF_INET6,SOCK_STREAM,0);
+ }
+ if (!ip6_scan(server, (char *)&ip6s.d)) return;
+ qmqpfd = socket(AF_INET6, SOCK_STREAM, 0);
if (qmqpfd == -1) die_socket();
- r = timeoutconn6(qmqpfd,(char *)&ip6s.d,PORT_QMQP,10,ifidx);
+ r = timeoutconn6(qmqpfd, (char *)&ip6s.d, PORT_QMQP, 10, ifidx);
} else {
- if (!ip4_scan(server,(char *)&ip4s.d)) return;
- qmqpfd = socket(AF_INET,SOCK_STREAM,0);
+ if (!ip4_scan(server, (char *)&ip4s.d)) return;
+ qmqpfd = socket(AF_INET, SOCK_STREAM, 0);
if (qmqpfd == -1) die_socket();
- r = timeoutconn4(qmqpfd,(char *)&ip4s.d,PORT_QMQP,10);
+ r = timeoutconn4(qmqpfd, (char *)&ip4s.d, PORT_QMQP, 10);
}
if (r != 0) {
lasterror = 73;
@@ -135,17 +168,17 @@ void doit(char *server)
return;
}
- strnum[fmt_ulong(strnum,(unsigned long) (beforemessage.len + message.len + aftermessage.len))] = 0;
- buffer_puts(&bo,strnum);
- buffer_puts(&bo,":");
- buffer_put(&bo,beforemessage.s,beforemessage.len);
- buffer_put(&bo,message.s,message.len);
- buffer_put(&bo,aftermessage.s,aftermessage.len);
- buffer_puts(&bo,",");
+ strnum[fmt_ulong(strnum, (unsigned long)(beforemessage.len + message.len + aftermessage.len))] = 0;
+ buffer_puts(&bo, strnum);
+ buffer_puts(&bo, ":");
+ buffer_put(&bo, beforemessage.s, beforemessage.len);
+ buffer_put(&bo, message.s, message.len);
+ buffer_put(&bo, aftermessage.s, aftermessage.len);
+ buffer_puts(&bo, ",");
buffer_flush(&bo);
for (;;) {
- buffer_get(&bi,&ch,1);
+ buffer_get(&bi, &ch, 1);
if (ch == 'K') die_success();
if (ch == 'Z') die_temp();
if (ch == 'D') die_perm();
@@ -163,7 +196,7 @@ int main()
if (chdir(auto_qmail) == -1) die_home();
if (control_init() == -1) die_control();
- if (control_readfile(&servers,"control/qmqpservers",0) != 1) die_control();
+ if (control_readfile(&servers, "control/qmqpservers", 0) != 1) die_control();
getmess();
generated by cgit v1.2.3 (git 2.39.1) at 2024-12-23 07:49:21 +0000