1 /*@ S-nail - a mail user agent derived from Berkeley Mail.
4 * Copyright (c) 2000-2004 Gunnar Ritter, Freiburg i. Br., Germany.
5 * Copyright (c) 2012 - 2014 Steffen (Daode) Nurpmeso <sdaoden@users.sf.net>.
8 * Copyright (c) 1980, 1993
9 * The Regents of the University of California. All rights reserved.
11 * Redistribution and use in source and binary forms, with or without
12 * modification, are permitted provided that the following conditions
14 * 1. Redistributions of source code must retain the above copyright
15 * notice, this list of conditions and the following disclaimer.
16 * 2. Redistributions in binary form must reproduce the above copyright
17 * notice, this list of conditions and the following disclaimer in the
18 * documentation and/or other materials provided with the distribution.
19 * 3. All advertising materials mentioning features or use of this software
20 * must display the following acknowledgement:
21 * This product includes software developed by the University of
22 * California, Berkeley and its contributors.
23 * 4. Neither the name of the University nor the names of its contributors
24 * may be used to endorse or promote products derived from this software
25 * without specific prior written permission.
27 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
28 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
29 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
30 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
31 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
32 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
33 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
34 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
35 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
36 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
40 #ifndef HAVE_AMALGAMATION
53 # include <sys/socket.h>
57 # include <netinet/in.h>
59 # ifdef HAVE_ARPA_INET_H
60 # include <arpa/inet.h>
65 # include <openssl/err.h>
66 # include <openssl/rand.h>
67 # include <openssl/ssl.h>
68 # include <openssl/x509v3.h>
69 # include <openssl/x509.h>
73 FILE *s_file
; /* File we were in. */
74 void *s_cond
; /* Saved state of conditional stack */
75 int s_loading
; /* Loading .mailrc, etc. */
78 static size_t _message_space
; /* Slots in ::message */
79 static struct fio_stack _fio_stack
[FIO_STACK_SIZE
];
80 static size_t _fio_stack_size
;
81 static FILE * _fio_input
;
83 /* Locate the user's mailbox file (where new, unread mail is queued) */
84 static void _findmail(char *buf
, size_t bufsize
, char const *user
,
87 /* Perform shell meta character expansion */
88 static char * _globname(char const *name
, enum fexp_mode fexpm
);
90 /* line is a buffer with the result of fgets(). Returns the first newline or
91 * the last character read */
92 static size_t _length_of_line(char const *line
, size_t linesize
);
94 /* Read a line, one character at a time */
95 static char * _fgetline_byone(char **line
, size_t *linesize
, size_t *llen
,
96 FILE *fp
, int appendnl
, size_t n SMALLOC_DEBUG_ARGS
);
98 /* Take the data out of the passed ghost file and toss it into a dynamically
99 * allocated message structure */
100 static void makemessage(void);
102 static enum okay
get_header(struct message
*mp
);
104 /* Write to socket fd, restarting on EINTR, unless anything is written */
106 static long xwrite(int fd
, char const *data
, size_t sz
);
110 _findmail(char *buf
, size_t bufsize
, char const *user
, bool_t force
)
115 if (!strcmp(user
, myname
) && !force
&& (cp
= ok_vlook(folder
)) != NULL
) {
116 switch (which_protocol(cp
)) {
118 if (strcmp(cp
, protbase(cp
)))
120 snprintf(buf
, bufsize
, "%s/INBOX", cp
);
127 if (force
|| (cp
= ok_vlook(MAIL
)) == NULL
)
128 snprintf(buf
, bufsize
, "%s/%s", MAILSPOOL
, user
);
131 n_strlcpy(buf
, cp
, bufsize
);
137 _globname(char const *name
, enum fexp_mode fexpm
)
146 /* Mac OS X Snow Leopard and Linux don't init fields on error, causing
147 * SIGSEGV in wordfree(3); so let's just always zero it ourselfs */
148 memset(&we
, 0, sizeof we
);
150 /* Some systems (notably Open UNIX 8.0.0) fork a shell for wordexp()
151 * and wait, which will fail if our SIGCHLD handler is active */
153 sigaddset(&nset
, SIGCHLD
);
154 sigprocmask(SIG_BLOCK
, &nset
, NULL
);
155 i
= wordexp(name
, &we
, 0);
156 sigprocmask(SIG_UNBLOCK
, &nset
, NULL
);
162 if (!(fexpm
& FEXP_SILENT
))
163 fprintf(stderr
, tr(83, "\"%s\": Expansion buffer overflow.\n"), name
);
168 if (!(fexpm
& FEXP_SILENT
))
169 fprintf(stderr
, tr(242, "Syntax error in \"%s\"\n"), name
);
173 switch (we
.we_wordc
) {
175 cp
= savestr(we
.we_wordv
[0]);
178 if (!(fexpm
& FEXP_SILENT
))
179 fprintf(stderr
, tr(82, "\"%s\": No match.\n"), name
);
182 if (fexpm
& FEXP_MULTIOK
) {
185 for (l
= 0, j
= 0; j
< we
.we_wordc
; ++j
)
186 l
+= strlen(we
.we_wordv
[j
]) + 1;
189 for (l
= 0, j
= 0; j
< we
.we_wordc
; ++j
) {
190 size_t x
= strlen(we
.we_wordv
[j
]);
191 memcpy(cp
+ l
, we
.we_wordv
[j
], x
);
196 } else if (!(fexpm
& FEXP_SILENT
))
197 fprintf(stderr
, tr(84, "\"%s\": Ambiguous.\n"), name
);
205 #else /* HAVE_WORDEXP */
207 char xname
[PATH_MAX
], cmdbuf
[PATH_MAX
], /* also used for files */
209 int pivec
[2], pid
, l
, waits
;
212 if (pipe(pivec
) < 0) {
216 snprintf(cmdbuf
, sizeof cmdbuf
, "echo %s", name
);
217 if ((shellp
= ok_vlook(SHELL
)) == NULL
)
218 shellp
= UNCONST(XSHELL
);
219 pid
= start_command(shellp
, 0, -1, pivec
[1], "-c", cmdbuf
, NULL
);
228 l
= read(pivec
[0], xname
, sizeof xname
);
237 if (!wait_child(pid
, &waits
) && WTERMSIG(waits
) != SIGPIPE
) {
238 if (!(fexpm
& FEXP_SILENT
))
239 fprintf(stderr
, tr(81, "\"%s\": Expansion failed.\n"), name
);
243 if (!(fexpm
& FEXP_SILENT
))
244 fprintf(stderr
, tr(82, "\"%s\": No match.\n"), name
);
247 if (l
== sizeof xname
) {
248 if (!(fexpm
& FEXP_SILENT
))
249 fprintf(stderr
, tr(83, "\"%s\": Expansion buffer overflow.\n"), name
);
253 for (cp
= &xname
[l
- 1]; *cp
== '\n' && cp
> xname
; --cp
)
256 if (!(fexpm
& FEXP_MULTIOK
) && strchr(xname
, ' ') != NULL
&&
257 stat(xname
, &sbuf
) < 0) {
258 if (!(fexpm
& FEXP_SILENT
))
259 fprintf(stderr
, tr(84, "\"%s\": Ambiguous.\n"), name
);
267 #endif /* !HAVE_WORDEXP */
271 _length_of_line(char const *line
, size_t linesize
)
276 /* Last character is always '\0' and was added by fgets() */
277 for (--linesize
, i
= 0; i
< linesize
; i
++)
280 i
= (i
< linesize
) ? i
+ 1 : linesize
;
286 _fgetline_byone(char **line
, size_t *linesize
, size_t *llen
, FILE *fp
,
287 int appendnl
, size_t n SMALLOC_DEBUG_ARGS
)
293 assert(*linesize
== 0 || *line
!= NULL
);
295 if (*linesize
<= LINESIZE
|| n
>= *linesize
- 128) {
296 *linesize
+= ((rv
== NULL
) ? LINESIZE
+ n
+ 1 : 256);
297 *line
= rv
= (srealloc
)(rv
, *linesize SMALLOC_DEBUG_ARGSCALL
);
330 message_append(NULL
);
332 message
[msgCount
].m_size
= 0;
333 message
[msgCount
].m_lines
= 0;
338 get_header(struct message
*mp
)
344 switch (mb
.mb_type
) {
351 rv
= pop3_header(mp
);
357 rv
= imap_header(mp
);
371 xwrite(int fd
, char const *data
, size_t sz
)
378 if ((wo
= write(fd
, data
+ wt
, sz
- wt
)) < 0) {
391 #endif /* HAVE_SOCKETS */
394 (fgetline
)(char **line
, size_t *linesize
, size_t *cnt
, size_t *llen
, FILE *fp
,
395 int appendnl SMALLOC_DEBUG_ARGS
)
402 /* Without count, we can't determine where the chars returned by fgets()
403 * end if there's no newline. We have to read one character by one */
404 rv
= _fgetline_byone(line
, linesize
, llen
, fp
, appendnl
, 0
405 SMALLOC_DEBUG_ARGSCALL
);
409 if ((rv
= *line
) == NULL
|| *linesize
< LINESIZE
)
410 *line
= rv
= (srealloc
)(rv
, *linesize
= LINESIZE SMALLOC_DEBUG_ARGSCALL
);
411 sz
= (*linesize
<= *cnt
) ? *linesize
: *cnt
+ 1;
412 if (sz
<= 1 || fgets(rv
, sz
, fp
) == NULL
) {
413 /* Leave llen untouched; it is used to determine whether the last line
414 * was \n-terminated in some callers */
419 i_llen
= _length_of_line(rv
, sz
);
421 while (rv
[i_llen
- 1] != '\n') {
422 *line
= rv
= (srealloc
)(rv
, *linesize
+= 256 SMALLOC_DEBUG_ARGSCALL
);
423 sz
= *linesize
- i_llen
;
424 sz
= (sz
<= *cnt
) ? sz
: *cnt
+ 1;
425 if (sz
<= 1 || fgets(rv
+ i_llen
, sz
, fp
) == NULL
) {
432 sz
= _length_of_line(rv
+ i_llen
, sz
);
444 (readline_restart
)(FILE *ibuf
, char **linebuf
, size_t *linesize
, size_t n
447 /* TODO readline_restart(): always *appends* LF just to strip it again;
448 * TODO should be configurable just as for fgetline(); ..or whatevr.. */
455 /* Interrupts will cause trouble if we are inside a stdio call. As this is
456 * only relevant if input is from tty, bypass it by read(), then */
457 if (fileno(ibuf
) == 0 && (options
& OPT_TTYIN
)) {
458 assert(*linesize
== 0 || *linebuf
!= NULL
);
460 if (*linesize
<= LINESIZE
|| n
>= *linesize
- 128) {
461 *linesize
+= ((*linebuf
== NULL
) ? LINESIZE
+ n
+ 1 : 256);
462 *linebuf
= (srealloc
)(*linebuf
, *linesize SMALLOC_DEBUG_ARGSCALL
);
465 sz
= read(0, *linebuf
+ n
, *linesize
- n
- 1);
468 (*linebuf
)[n
] = '\0';
469 if (n
> 0 && (*linebuf
)[n
- 1] == '\n')
472 if (sz
< 0 && errno
== EINTR
)
475 if ((*linebuf
)[n
- 1] != '\n') {
476 (*linebuf
)[n
++] = '\n';
477 (*linebuf
)[n
] = '\0';
485 /* Not reading from standard input or standard input not a terminal. We
486 * read one char at a time as it is the only way to get lines with
487 * embedded NUL characters in standard stdio */
488 if (_fgetline_byone(linebuf
, linesize
, &n
, ibuf
, 1, n
489 SMALLOC_DEBUG_ARGSCALL
) == NULL
)
492 if (n
> 0 && (*linebuf
)[n
- 1] == '\n')
493 (*linebuf
)[--n
] = '\0';
501 (readline_input
)(char const *prompt
, bool_t nl_escape
, char **linebuf
,
502 size_t *linesize
, char const *string SMALLOC_DEBUG_ARGS
)
504 /* TODO readline: linebuf pool! */
505 FILE *ifile
= (_fio_input
!= NULL
) ? _fio_input
: stdin
;
506 bool_t doprompt
, dotty
;
510 doprompt
= (!sourcing
&& (options
& OPT_INTERACTIVE
));
511 dotty
= (doprompt
&& !ok_blook(line_editor_disable
));
514 else if (prompt
== NULL
)
515 prompt
= getprompt();
519 assert(ifile
== stdin
);
520 if (string
!= NULL
&& (n
= (int)strlen(string
)) > 0) {
524 *linesize
= (size_t)n
+ LINESIZE
+1;
525 *linebuf
= (srealloc
)(*linebuf
, *linesize SMALLOC_DEBUG_ARGSCALL
);
526 memcpy(*linebuf
, string
, (size_t)n
+1);
529 n
= (tty_readline
)(prompt
, linebuf
, linesize
, n
530 SMALLOC_DEBUG_ARGSCALL
);
532 if (prompt
!= NULL
&& *prompt
!= '\0') {
533 fputs(prompt
, stdout
);
536 n
= (readline_restart
)(ifile
, linebuf
, linesize
, n
537 SMALLOC_DEBUG_ARGSCALL
);
542 * An unquoted <backslash> at the end of a command line shall
543 * be discarded and the next line shall continue the command */
544 if (nl_escape
&& (*linebuf
)[n
- 1] == '\\') {
545 (*linebuf
)[--n
] = '\0';
546 if (prompt
!= NULL
&& *prompt
!= '\0')
547 prompt
= ".. "; /* XXX PS2 .. */
557 readstr_input(char const *prompt
, char const *string
)
559 /* FIXME readstr_input: without linepool leaks on sigjmp */
561 char *linebuf
= NULL
, *rv
= NULL
;
565 n
= readline_input(prompt
, FAL0
, &linebuf
, &linesize
, string
);
567 rv
= savestrbuf(linebuf
, (size_t)n
+ 1);
576 setptr(FILE *ibuf
, off_t offset
)
579 char *cp
, *linebuf
= NULL
;
581 int c
, maybe
= 1, inhead
= 0, selfcnt
= 0;
582 size_t linesize
= 0, filesize
, cnt
;
585 memset(&self
, 0, sizeof self
);
586 self
.m_flag
= MUSED
| MNEW
| MNEWEST
;
587 filesize
= mailsize
- offset
;
588 offset
= ftell(mb
.mb_otf
);
591 if (fgetline(&linebuf
, &linesize
, &filesize
, &cnt
, ibuf
, 0) == NULL
) {
592 self
.m_xsize
= self
.m_size
;
593 self
.m_xlines
= self
.m_lines
;
594 self
.m_have
= HAVE_HEADER
| HAVE_BODY
;
596 message_append(&self
);
604 if (linebuf
[0] == '\0')
607 /* XXX Convert CRLF to LF; this should be rethought in that
608 * XXX CRLF input should possibly end as CRLF output? */
609 if (cnt
>= 2 && linebuf
[cnt
- 1] == '\n' && linebuf
[cnt
- 2] == '\r')
610 linebuf
[--cnt
- 1] = '\n';
611 fwrite(linebuf
, sizeof *linebuf
, cnt
, mb
.mb_otf
);
612 if (ferror(mb
.mb_otf
)) {
616 if (linebuf
[cnt
- 1] == '\n')
617 linebuf
[cnt
- 1] = '\0';
618 if (maybe
&& linebuf
[0] == 'F' && is_head(linebuf
, cnt
)) {
619 /* TODO char date[FROM_DATEBUF];
620 * TODO extract_date_from_from_(linebuf, cnt, date);
621 * TODO self.m_time = 10000; */
622 self
.m_xsize
= self
.m_size
;
623 self
.m_xlines
= self
.m_lines
;
624 self
.m_have
= HAVE_HEADER
| HAVE_BODY
;
626 message_append(&self
);
628 self
.m_flag
= MUSED
| MNEW
| MNEWEST
;
631 self
.m_block
= mailx_blockof(offset
);
632 self
.m_offset
= mailx_offsetof(offset
);
634 } else if (linebuf
[0] == 0) {
637 for (cp
= linebuf
, cp2
= "status";; ++cp
) {
638 if ((c
= *cp2
++) == 0) {
639 while (c
= *cp
++, whitechar(c
))
643 while ((c
= *cp
++) != '\0')
645 self
.m_flag
|= MREAD
;
647 self
.m_flag
&= ~MNEW
;
650 if (*cp
!= c
&& *cp
!= upperconv(c
))
653 for (cp
= linebuf
, cp2
= "x-status";; ++cp
) {
654 if ((c
= *cp2
++) == 0) {
655 while ((c
= *cp
++, whitechar(c
)))
659 while ((c
= *cp
++) != '\0')
661 self
.m_flag
|= MFLAGGED
;
663 self
.m_flag
|= MANSWERED
;
665 self
.m_flag
|= MDRAFTED
;
668 if (*cp
!= c
&& *cp
!= upperconv(c
))
675 maybe
= linebuf
[0] == 0;
681 putline(FILE *obuf
, char *linebuf
, size_t cnt
)
686 fwrite(linebuf
, sizeof *linebuf
, cnt
, obuf
);
695 setinput(struct mailbox
*mp
, struct message
*m
, enum needspec need
)
703 ok
= (m
->m_have
& HAVE_HEADER
) ? OKAY
: get_header(m
);
706 ok
= (m
->m_have
& HAVE_BODY
) ? OKAY
: get_body(m
);
716 if (fseek(mp
->mb_itf
, (long)mailx_positionof(m
->m_block
, m
->m_offset
),
719 panic(tr(77, "temporary file seek"));
731 if (message
!= NULL
) {
741 message_append(struct message
*mp
)
744 if (UICMP(z
, msgCount
+ 1, >=, _message_space
)) {
745 /* XXX remove _message_space magics (or use s_Vector) */
746 _message_space
= (_message_space
>= 128 && _message_space
<= 1000000)
747 ? _message_space
<< 1 : _message_space
+ 64;
748 message
= srealloc(message
, _message_space
* sizeof *message
);
752 message
[msgCount
- 1] = *mp
;
754 memset(message
+ msgCount
- 1, 0, sizeof *message
);
760 setdot(struct message
*mp
)
765 did_print_dot
= FAL0
;
780 if (stat(name
, &sb
) < 0)
782 else if (!S_ISREG(sb
.st_mode
))
797 rv
= (fstat(fileno(iob
), &sbuf
) < 0) ? 0 : sbuf
.st_size
;
803 fexpand(char const *name
, enum fexp_mode fexpm
)
805 char cbuf
[PATH_MAX
], *res
;
811 /* The order of evaluation is "%" and "#" expand into constants.
812 * "&" can expand into "+". "+" can expand into shell meta characters.
813 * Shell meta characters expand into constants.
814 * This way, we make no recursive expansion */
816 if (!(fexpm
& FEXP_NSHORTCUT
) && (sh
= get_shortcut(res
)) != NULL
)
819 if (fexpm
& FEXP_SHELL
) {
827 if (res
[1] == ':' && res
[2] != '\0') {
831 _findmail(cbuf
, sizeof cbuf
, (res
[1] != '\0' ? res
+ 1 : myname
),
832 (res
[1] != '\0' || (options
& OPT_u_FLAG
)));
838 if (prevfile
[0] == '\0') {
839 fprintf(stderr
, tr(80, "No previous file\n"));
846 if (res
[1] == '\0') {
847 if ((res
= ok_vlook(MBOX
)) == NULL
)
848 res
= UNCONST("~/mbox");
849 else if (res
[0] != '&' || res
[1] != '\0')
855 if (res
[0] == '@' && which_protocol(mailname
) == PROTO_IMAP
) {
856 res
= str_concat_csvl(&s
, protbase(mailname
), "/", res
+ 1, NULL
)->s
;
860 if (res
[0] == '+' && getfold(cbuf
, sizeof cbuf
)) {
861 size_t i
= strlen(cbuf
);
863 res
= str_concat_csvl(&s
, cbuf
,
864 ((i
> 0 && cbuf
[i
- 1] == '/') ? "" : "/"), res
+ 1, NULL
)->s
;
867 if (res
[0] == '%' && res
[1] == ':') {
873 /* Catch the most common shell meta character */
875 if (res
[0] == '~' && (res
[1] == '/' || res
[1] == '\0')) {
876 res
= str_concat_csvl(&s
, homedir
, res
+ 1, NULL
)->s
;
880 if (anyof(res
, "|&;<>~{}()[]*?$`'\"\\") &&
881 which_protocol(res
) == PROTO_FILE
) {
882 res
= _globname(res
, fexpm
);
888 if (fexpm
& FEXP_LOCAL
)
889 switch (which_protocol(res
)) {
894 fprintf(stderr
, tr(280,
895 "`%s': only a local file or directory may be used\n"), name
);
910 if (ok_blook(keep
) || rm(mailname
) < 0) {
911 int fd
= open(mailname
, O_WRONLY
| O_CREAT
| O_TRUNC
, 0600);
919 var_folder_updated(char const *name
, char **store
)
922 char *folder
, *unres
= NULL
, *res
= NULL
;
925 if ((folder
= UNCONST(name
)) == NULL
)
928 /* Expand the *folder*; skip `%:' prefix for simplicity of use */
929 /* XXX This *only* works because we do NOT
930 * XXX update environment variables via the "set" mechanism */
931 if (folder
[0] == '%' && folder
[1] == ':')
933 if ((folder
= fexpand(folder
, FEXP_FULL
)) == NULL
) /* XXX error? */
936 switch (which_protocol(folder
)) {
938 /* Ooops. This won't work */
939 fprintf(stderr
, tr(501,
940 "`folder' cannot be set to a flat, readonly POP3 account\n"));
944 /* Simply assign what we have, even including `%:' prefix */
949 /* Further expansion desired */
953 /* All non-absolute paths are relative to our home directory */
954 if (*folder
!= '/') {
955 size_t l1
= strlen(homedir
), l2
= strlen(folder
);
956 unres
= ac_alloc(l1
+ l2
+ 1 +1);
957 memcpy(unres
, homedir
, l1
);
959 memcpy(unres
+ l1
+ 1, folder
, l2
);
960 unres
[l1
+ 1 + l2
] = '\0';
964 /* Since lex.c:_update_mailname() uses realpath(3) if available to
965 * avoid that we loose track of our currently open folder in case we
966 * chdir away, but still checks the leading path portion against
967 * getfold() to be able to abbreviate to the +FOLDER syntax if
968 * possible, we need to realpath(3) the folder, too */
970 res
= ac_alloc(PATH_MAX
);
971 if (realpath(folder
, res
) == NULL
)
972 fprintf(stderr
, tr(151, "Can't canonicalize `%s'\n"), folder
);
978 *store
= sstrdup(folder
);
990 getfold(char *name
, size_t size
)
995 if ((folder
= ok_vlook(folder
)) != NULL
)
996 n_strlcpy(name
, folder
, size
);
998 return (folder
!= NULL
);
1002 getdeadletter(void) /* XXX should that be in auxlily.c? */
1007 if ((cp
= ok_vlook(DEAD
)) == NULL
|| (cp
= fexpand(cp
, FEXP_LOCAL
)) == NULL
)
1008 cp
= fexpand("~/dead.letter", FEXP_LOCAL
| FEXP_SHELL
);
1009 else if (*cp
!= '/') {
1010 size_t sz
= strlen(cp
) + 3;
1011 char *buf
= ac_alloc(sz
);
1013 snprintf(buf
, sz
, "~/%s", cp
);
1014 cp
= fexpand(buf
, FEXP_LOCAL
| FEXP_SHELL
);
1019 cp
= "dead.letter"; /* XXX magic -> nail.h (POSIX thing though) */
1025 get_body(struct message
*mp
)
1031 switch (mb
.mb_type
) {
1058 sclose(struct sock
*sp
)
1064 if (sp
->s_onclose
!= NULL
)
1066 # ifdef HAVE_OPENSSL
1067 if (sp
->s_use_ssl
) {
1068 void *s_ssl
= sp
->s_ssl
, *s_ctx
= sp
->s_ctx
;
1069 sp
->s_ssl
= sp
->s_ctx
= NULL
;
1071 assert(s_ssl
!= NULL
);
1072 while (!SSL_shutdown(s_ssl
)) /* XXX */
1075 SSL_CTX_free(s_ctx
);
1078 i
= close(sp
->s_fd
);
1090 swrite(struct sock
*sp
, char const *data
)
1095 rv
= swrite1(sp
, data
, strlen(data
), 0);
1101 swrite1(struct sock
*sp
, char const *data
, int sz
, int use_buffer
)
1103 enum okay rv
= STOP
;
1107 if (use_buffer
> 0) {
1110 if (sp
->s_wbuf
== NULL
) {
1111 sp
->s_wbufsize
= 4096;
1112 sp
->s_wbuf
= smalloc(sp
->s_wbufsize
);
1115 while (sp
->s_wbufpos
+ sz
> sp
->s_wbufsize
) {
1116 di
= sp
->s_wbufsize
- sp
->s_wbufpos
;
1118 if (sp
->s_wbufpos
> 0) {
1119 memcpy(&sp
->s_wbuf
[sp
->s_wbufpos
], data
, di
);
1120 rv
= swrite1(sp
, sp
->s_wbuf
, sp
->s_wbufsize
, -1);
1122 rv
= swrite1(sp
, data
, sp
->s_wbufsize
, -1);
1128 if (sz
== sp
->s_wbufsize
) {
1129 rv
= swrite1(sp
, data
, sp
->s_wbufsize
, -1);
1133 memcpy(&sp
->s_wbuf
[sp
->s_wbufpos
], data
, sz
);
1134 sp
->s_wbufpos
+= sz
;
1138 } else if (use_buffer
== 0 && sp
->s_wbuf
!= NULL
&& sp
->s_wbufpos
> 0) {
1141 if ((rv
= swrite1(sp
, sp
->s_wbuf
, x
, -1)) != OKAY
)
1149 # ifdef HAVE_OPENSSL
1150 if (sp
->s_use_ssl
) {
1152 x
= SSL_write(sp
->s_ssl
, data
, sz
);
1154 switch (SSL_get_error(sp
->s_ssl
, x
)) {
1155 case SSL_ERROR_WANT_READ
:
1156 case SSL_ERROR_WANT_WRITE
:
1163 x
= xwrite(sp
->s_fd
, data
, sz
);
1167 snprintf(o
, sizeof o
, "%s write error",
1168 (sp
->s_desc
? sp
->s_desc
: "socket"));
1169 # ifdef HAVE_OPENSSL
1170 sp
->s_use_ssl
? ssl_gen_err("%s", o
) : perror(o
);
1186 sopen(char const *xserver
, struct sock
*sp
, int use_ssl
, char const *uhp
,
1187 char const *portstr
)
1189 # ifdef HAVE_SO_SNDTIMEO
1192 # ifdef HAVE_SO_LINGER
1196 char hbuf
[NI_MAXHOST
];
1197 struct addrinfo hints
, *res0
, *res
;
1199 struct sockaddr_in servaddr
;
1200 struct in_addr
**pptr
;
1203 unsigned short port
= 0;
1206 char *cp
, *server
= UNCONST(xserver
);
1207 enum okay rv
= STOP
;
1212 if ((cp
= strchr(server
, ':')) != NULL
) { /* TODO URI parse! IPv6! */
1215 port
= strtol(portstr
, NULL
, 10);
1217 server
= salloc(cp
- xserver
+ 1);
1218 memcpy(server
, xserver
, cp
- xserver
);
1219 server
[cp
- xserver
] = '\0';
1222 /* Connect timeouts after 30 seconds */
1223 # ifdef HAVE_SO_SNDTIMEO
1229 if (options
& OPT_VERBOSE
)
1230 fprintf(stderr
, "Resolving host %s . . .", server
);
1231 memset(&hints
, 0, sizeof hints
);
1232 hints
.ai_socktype
= SOCK_STREAM
;
1233 if (getaddrinfo(server
, portstr
, &hints
, &res0
) != 0) {
1234 fprintf(stderr
, tr(252, " lookup of `%s' failed.\n"), server
);
1236 } else if (options
& OPT_VERBOSE
)
1237 fprintf(stderr
, tr(500, " done.\n"));
1240 for (res
= res0
; res
!= NULL
&& sockfd
< 0; res
= res
->ai_next
) {
1241 if (options
& OPT_VERBOSE
) {
1242 if (getnameinfo(res
->ai_addr
, res
->ai_addrlen
, hbuf
, sizeof hbuf
,
1243 NULL
, 0, NI_NUMERICHOST
) != 0)
1244 strcpy(hbuf
, "unknown host");
1245 fprintf(stderr
, tr(192, "%sConnecting to %s:%s . . ."),
1246 (res
== res0
? "" : "\n"), hbuf
, portstr
);
1248 sockfd
= socket(res
->ai_family
, res
->ai_socktype
, res
->ai_protocol
);
1250 # ifdef HAVE_SO_SNDTIMEO
1251 setsockopt(sockfd
, SOL_SOCKET
, SO_SNDTIMEO
, &tv
, sizeof tv
);
1253 if (connect(sockfd
, res
->ai_addr
, res
->ai_addrlen
) != 0) {
1260 perror(tr(254, " could not connect"));
1266 # else /* HAVE_IPV6 */
1268 if (!strcmp(portstr
, "smtp"))
1270 else if (!strcmp(portstr
, "smtps"))
1273 else if (!strcmp(portstr
, "imap"))
1275 else if (!strcmp(portstr
, "imaps"))
1279 else if (!strcmp(portstr
, "pop3"))
1281 else if (!strcmp(portstr
, "pop3s"))
1284 else if ((ep
= getservbyname(UNCONST(portstr
), "tcp")) != NULL
)
1287 fprintf(stderr
, tr(251, "Unknown service: %s\n"), portstr
);
1294 if (options
& OPT_VERBOSE
)
1295 fprintf(stderr
, "Resolving host %s . . .", server
);
1296 if ((hp
= gethostbyname(server
)) == NULL
) {
1297 fprintf(stderr
, tr(252, " lookup of `%s' failed.\n"), server
);
1299 } else if (options
& OPT_VERBOSE
)
1300 fprintf(stderr
, tr(500, " done.\n"));
1302 pptr
= (struct in_addr
**)hp
->h_addr_list
;
1303 if ((sockfd
= socket(AF_INET
, SOCK_STREAM
, 0)) == -1) {
1304 perror(tr(253, "could not create socket"));
1307 memset(&servaddr
, 0, sizeof servaddr
);
1308 servaddr
.sin_family
= AF_INET
;
1309 servaddr
.sin_port
= port
;
1310 memcpy(&servaddr
.sin_addr
, *pptr
, sizeof(struct in_addr
));
1311 if (options
& OPT_VERBOSE
)
1312 fprintf(stderr
, tr(192, "%sConnecting to %s:%d . . ."),
1313 "", inet_ntoa(**pptr
), ntohs(port
));
1315 # ifdef HAVE_SO_SNDTIMEO
1316 setsockopt(sockfd
, SOL_SOCKET
, SO_SNDTIMEO
, &tv
, sizeof tv
);
1318 if (connect(sockfd
, (struct sockaddr
*)&servaddr
, sizeof servaddr
) != 0) {
1319 perror(tr(254, " could not connect"));
1322 # endif /* !HAVE_IPV6 */
1323 if (options
& OPT_VERBOSE
)
1324 fputs(tr(193, " connected.\n"), stderr
);
1326 /* And the regular timeouts */
1327 # ifdef HAVE_SO_SNDTIMEO
1330 setsockopt(sockfd
, SOL_SOCKET
, SO_SNDTIMEO
, &tv
, sizeof tv
);
1331 setsockopt(sockfd
, SOL_SOCKET
, SO_RCVTIMEO
, &tv
, sizeof tv
);
1333 # ifdef HAVE_SO_LINGER
1336 setsockopt(sockfd
, SOL_SOCKET
, SO_LINGER
, &li
, sizeof li
);
1339 memset(sp
, 0, sizeof *sp
);
1342 if (use_ssl
&& ssl_open(server
, sp
, uhp
) != OKAY
) {
1354 (sgetline
)(char **line
, size_t *linesize
, size_t *linelen
, struct sock
*sp
1358 size_t lsize
= *linesize
;
1359 char *lp_base
= *line
, *lp
= lp_base
;
1362 if (sp
->s_rsz
< 0) {
1369 if (lp_base
== NULL
|| PTRCMP(lp
, >, lp_base
+ lsize
- 128)) {
1370 size_t diff
= PTR2SIZE(lp
- lp_base
);
1371 *linesize
= (lsize
+= 256); /* XXX magic */
1372 *line
= lp_base
= (srealloc
)(lp_base
, lsize SMALLOC_DEBUG_ARGSCALL
);
1373 lp
= lp_base
+ diff
;
1376 if (sp
->s_rbufptr
== NULL
||
1377 PTRCMP(sp
->s_rbufptr
, >=, sp
->s_rbuf
+ sp
->s_rsz
)) {
1378 # ifdef HAVE_OPENSSL
1379 if (sp
->s_use_ssl
) {
1381 sp
->s_rsz
= SSL_read(sp
->s_ssl
, sp
->s_rbuf
, sizeof sp
->s_rbuf
);
1382 if (sp
->s_rsz
<= 0) {
1383 if (sp
->s_rsz
< 0) {
1385 switch(SSL_get_error(sp
->s_ssl
, sp
->s_rsz
)) {
1386 case SSL_ERROR_WANT_READ
:
1387 case SSL_ERROR_WANT_WRITE
:
1390 snprintf(o
, sizeof o
, "%s",
1391 (sp
->s_desc
? sp
->s_desc
: "socket"));
1392 ssl_gen_err("%s", o
);
1400 sp
->s_rsz
= read(sp
->s_fd
, sp
->s_rbuf
, sizeof sp
->s_rbuf
);
1401 if (sp
->s_rsz
<= 0) {
1402 if (sp
->s_rsz
< 0) {
1406 snprintf(o
, sizeof o
, "%s",
1407 (sp
->s_desc
? sp
->s_desc
: "socket"));
1413 sp
->s_rbufptr
= sp
->s_rbuf
;
1415 } while ((*lp
++ = *sp
->s_rbufptr
++) != '\n');
1417 lsize
= PTR2SIZE(lp
- lp_base
);
1426 #endif /* HAVE_SOCKETS */
1429 load(char const *name
)
1434 if (name
== NULL
|| (in
= Fopen(name
, "r")) == NULL
)
1453 char **arglist
= v
, *cp
;
1457 if ((cp
= fexpand(*arglist
, FEXP_LOCAL
)) == NULL
)
1459 if ((fi
= Fopen(cp
, "r")) == NULL
) {
1464 if (_fio_stack_size
>= NELEM(_fio_stack
)) {
1465 fprintf(stderr
, tr(3, "Too much \"sourcing\" going on.\n"));
1470 _fio_stack
[_fio_stack_size
].s_file
= _fio_input
;
1471 _fio_stack
[_fio_stack_size
].s_cond
= condstack_release();
1472 _fio_stack
[_fio_stack_size
].s_loading
= loading
;
1489 if (_fio_stack_size
== 0) {
1490 fprintf(stderr
, tr(4, "\"Source\" stack over-pop.\n"));
1498 if (!condstack_take(_fio_stack
[_fio_stack_size
].s_cond
))
1499 fprintf(stderr
, tr(5, "Unmatched \"if\"\n"));
1500 loading
= _fio_stack
[_fio_stack_size
].s_loading
;
1501 _fio_input
= _fio_stack
[_fio_stack_size
].s_file
;
1502 if (_fio_stack_size
== 0)
1510 /* vim:set fenc=utf-8:s-it-mode */