masqmail: cd59a5b4d3dd src/pop3

masqmail

view src/pop3_in.c @ 120:cd59a5b4d3dd

added support for SMTP SIZE 0 (unlimited)

author	meillo@marmaro.de
date	Thu, 01 Jul 2010 13:30:30 +0200
parents	f671821d8222
children	2685e59f6f43

line source

2 *

3 * This program is free software; you can redistribute it and/or modify

4 * it under the terms of the GNU General Public License as published by

5 * the Free Software Foundation; either version 2 of the License, or

6 * (at your option) any later version.

7 *

8 * This program is distributed in the hope that it will be useful,

9 * but WITHOUT ANY WARRANTY; without even the implied warranty of

10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

11 * GNU General Public License for more details.

12 *

13 * You should have received a copy of the GNU General Public License

14 * along with this program; if not, write to the Free Software

15 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.

16 */

18 /* see RFC 1725 */

20 #include <sys/wait.h>

21 #include <sys/stat.h>

23 #include "masqmail.h"

24 #include "pop3_in.h"

25 #include "readsock.h"

27 #ifdef USE_LIB_CRYPTO

28 #include <openssl/md5.h>

29 #else

30 #include "md5/global.h"

31 #include "md5/md5.h"

32 #endif

34 #ifdef ENABLE_POP3

36 /* experimental feature */

37 #define DO_WRITE_UIDL_EARLY 1

39 static gchar*

40 MD5String(char *string)

41 {

42 MD5_CTX context;

43 unsigned char digest[16];

44 char str_digest[33];

45 int i;

47 #ifdef USE_LIB_CRYPTO

48 MD5(string, strlen(string), digest);

49 #else

50 MD5Init(&context);

51 MD5Update(&context, string, strlen(string));

52 MD5Final(digest, &context);

53 #endif

54 for (i = 0; i < 16; i++)

55 sprintf(str_digest + 2 * i, "%02x", digest[i]);

57 return g_strdup(str_digest);

58 }

60 static pop3_base*

61 create_pop3base(gint sock, guint flags)

62 {

63 gint dup_sock;

65 pop3_base *popb = (pop3_base *) g_malloc(sizeof(pop3_base));

66 if (popb) {

67 memset(popb, 0, sizeof(pop3_base));

69 popb->error = pop3_ok;

71 popb->buffer = (gchar *) g_malloc(POP3_BUF_LEN);

73 dup_sock = dup(sock);

74 popb->out = fdopen(sock, "w");

75 popb->in = fdopen(dup_sock, "r");

77 popb->flags = flags;

78 }

79 return popb;

80 }

82 static void

83 pop3_printf(FILE * out, gchar * fmt, ...)

84 {

85 va_list args;

86 va_start(args, fmt);

88 DEBUG(4) {

89 gchar buf[256];

90 va_list args_copy;

92 va_copy(args_copy, args);

93 vsnprintf(buf, 255, fmt, args_copy);

94 va_end(args_copy);

96 debugf(">>>%s", buf);

97 }

99 vfprintf(out, fmt, args);

100 fflush(out);

101

102 va_end(args);

103 }

104

105 static gboolean

106 find_uid(pop3_base * popb, gchar * str)

107 {

108 GList *node, *node_next;

109

110 for (node = popb->list_uid_old; node; node = node_next) {

111 gchar *uid = (gchar *) (node->data);

112 node_next = node->next;

113 if (strcmp(uid, str) == 0) {

114 #if 1

115 popb->list_uid_old = g_list_remove_link(popb->list_uid_old, node);

116 g_list_free_1(node);

117 g_free(uid);

118 #endif

119 return TRUE;

120 }

121 }

122 return FALSE;

123 }

124

125 static gboolean

126 write_uidl(pop3_base * popb, gchar * user)

127 {

128 gboolean ok = FALSE;

129 GList *node;

130 gchar *filename = g_strdup_printf("%s/popuidl/%s@%s", conf.spool_dir, user, popb->remote_host);

131 gchar *tmpname = g_strdup_printf("%s.tmp", filename);

132 FILE *fptr = fopen(tmpname, "wt");

133

134 if (fptr) {

135 foreach(popb->drop_list, node) {

136 msg_info *info = (msg_info *) (node->data);

137 if (info->is_fetched || info->is_in_uidl)

138 fprintf(fptr, "%s\n", info->uid);

139 }

140 fclose(fptr);

141 ok = (rename(tmpname, filename) != -1);

142 }

143

144 g_free(tmpname);

145 g_free(filename);

146 return ok;

147 }

148

149 static gboolean

150 read_uidl_fname(pop3_base * popb, gchar * filename)

151 {

152 gboolean ok = FALSE;

153 FILE *fptr = fopen(filename, "rt");

154 gchar buf[256];

155

156 if (fptr) {

157 popb->list_uid_old = NULL;

158 while (fgets(buf, 255, fptr)) {

159 if (buf[strlen(buf) - 1] == '\n') {

160 g_strchomp(buf);

161 popb->list_uid_old = g_list_append(popb->list_uid_old, g_strdup(buf));

162 } else {

163 logwrite(LOG_ALERT, "broken uid: %s\n", buf);

164 break;

165 }

166 }

167 fclose(fptr);

168 ok = TRUE;

169 } else

170 logwrite(LOG_ALERT, "opening of %s failed: %s", filename, strerror(errno));

171 return ok;

172 }

173

174 static gboolean

175 read_uidl(pop3_base * popb, gchar * user)

176 {

177 gboolean ok = FALSE;

178 struct stat statbuf;

179 gchar *filename = g_strdup_printf("%s/popuidl/%s@%s", conf.spool_dir, user, popb->remote_host);

180

181 if (stat(filename, &statbuf) == 0) {

182 ok = read_uidl_fname(popb, filename);

183 if (ok) {

184 GList *drop_node;

185 foreach(popb->drop_list, drop_node) {

186 msg_info *info = (msg_info *) (drop_node->data);

187 if (find_uid(popb, info->uid)) {

188 DEBUG(5) debugf("msg with uid '%s' already known\n", info->uid);

189 info->is_in_uidl = TRUE;

190 popb->uidl_known_cnt++;

191 } else

192 DEBUG(5) debugf("msg with uid '%s' not known\n", info->uid);

193 }

194 }

195 } else {

196 logwrite(LOG_DEBUG, "no uidl file '%s' found\n", filename);

197 ok = TRUE;

198 }

199

200 g_free(filename);

201 return ok; /* return code is irrelevant, do not check... */

202 }

203

204 static gboolean

205 read_response(pop3_base * popb, int timeout)

206 {

207 gint len;

208

209 len = read_sockline(popb->in, popb->buffer, POP3_BUF_LEN, timeout, READSOCKL_CHUG);

210

211 if (len == -3) {

212 popb->error = pop3_timeout;

213 return FALSE;

214 } else if (len == -2) {

215 popb->error = pop3_syntax;

216 return FALSE;

217 } else if (len == -1) {

218 popb->error = pop3_eof;

219 return FALSE;

220 }

221

222 return TRUE;

223 }

224

225 static gboolean

226 check_response(pop3_base * popb)

227 {

228 char c = popb->buffer[0];

229

230 if (c == '+') {

231 popb->error = pop3_ok;

232 return TRUE;

233 } else if (c == '-')

234 popb->error = pop3_fail;

235 else

236 popb->error = pop3_syntax;

237 return FALSE;

238 }

239

240 static gboolean

241 strtoi(gchar * p, gchar ** pend, gint * val)

242 {

243 gchar buf[12];

244 gint i = 0;

245

246 while (*p && isspace(*p))

247 p++;

248 if (*p) {

249 while ((i < 11) && isdigit(*p))

250 buf[i++] = *(p++);

251 buf[i] = 0;

252 *val = atoi(buf);

253 *pend = p;

254 return TRUE;

255 }

256 return FALSE;

257 }

258

259 static gboolean

260 check_response_int_int(pop3_base * popb, gint * arg0, gint * arg1)

261 {

262 if (check_response(popb)) {

263 gchar *p = &(popb->buffer[3]);

264 gchar *pe;

265

266 if (strtoi(p, &pe, arg0)) {

267 DEBUG(5) debugf("arg0 = %d\n", *arg0);

268 p = pe;

269 if (strtoi(p, &pe, arg1))

270 DEBUG(5) debugf("arg1 = %d\n", *arg1);

271 return TRUE;

272 /* FIXME: Paolo's code has the return stmt

273 inside the if block right above it. What

274 is correct? */

275 }

276 popb->error = pop3_syntax;

277 }

278 return FALSE;

279 }

280

281 static gboolean

282 get_drop_listing(pop3_base * popb)

283 {

284 gchar buf[64];

285

286 DEBUG(5) debugf("get_drop_listing() entered\n");

287

288 while (1) {

289 gint len = read_sockline(popb->in, buf, 64, POP3_CMD_TIMEOUT, READSOCKL_CHUG);

290 if (len > 0) {

291 if (buf[0] == '.')

292 return TRUE;

293 else {

294 gint number, msg_size;

295 gchar *p = buf, *pe;

296 if (strtoi(p, &pe, &number)) {

297 p = pe;

298 if (strtoi(p, &pe, &msg_size)) {

299 msg_info *info = g_malloc(sizeof(msg_info));

300 info->number = number;

301 info->size = msg_size;

302

303 DEBUG(5) debugf ("get_drop_listing(), number = %d, msg_size = %d\n", number, msg_size);

304

305 info->uid = NULL;

306 info->is_fetched = FALSE;

307 info->is_in_uidl = FALSE;

308 popb->drop_list = g_list_append(popb->drop_list, info);

309 } else {

310 popb->error = pop3_syntax;

311 break;

312 }

313 } else {

314 popb->error = pop3_syntax;

315 break;

316 }

317 }

318 } else {

319 popb->error = (len == -1) ? pop3_eof : pop3_timeout;

320 return FALSE;

321 }

322 }

323 return FALSE;

324 }

325

326 static gboolean

327 get_uid_listing(pop3_base * popb)

328 {

329 gchar buf[64];

330

331 while (1) {

332 gint len = read_sockline(popb->in, buf, 64, POP3_CMD_TIMEOUT, READSOCKL_CHUG);

333 if (len > 0) {

334 if (buf[0] == '.')

335 return TRUE;

336 else {

337 gint number;

338 gchar *p = buf, *pe;

339 if (strtoi(p, &pe, &number)) {

340 msg_info *info = NULL;

341 GList *drop_node;

342

343 p = pe;

344 while (*p && isspace(*p))

345 p++;

346

347 foreach(popb->drop_list, drop_node) {

348 msg_info *curr_info = (msg_info *) (drop_node->data);

349 if (curr_info->number == number) {

350 info = curr_info;

351 break;

352 }

353 }

354 if (info) {

355 info->uid = g_strdup(p);

356 g_strchomp(info->uid);

357 }

358

359 } else {

360 popb->error = pop3_syntax;

361 break;

362 }

363 }

364 }

365 }

366 return FALSE;

367 }

368

369 static gboolean

370 check_init_response(pop3_base * popb)

371 {

372 if (check_response(popb)) {

373 gchar buf[256];

374 gchar *p = popb->buffer;

375 gint i = 0;

376 if (*p) {

377 while (*p && (*p != '<'))

378 p++;

379 while (*p && (*p != '>') && (i < 254))

380 buf[i++] = *(p++);

381 buf[i++] = '>';

382 buf[i] = '\0';

383

384 popb->timestamp = g_strdup(buf);

385

386 return TRUE;

387 }

388 }

389 return FALSE;

390 }

391

392 void

393 pop3_in_close(pop3_base * popb)

394 {

395 GList *node;

396

397 fclose(popb->in);

398 fclose(popb->out);

399

400 close(popb->sock);

401

402 foreach(popb->list_uid_old, node) {

403 gchar *uid = (gchar *) (node->data);

404 g_free(uid);

405 }

406 g_list_free(popb->list_uid_old);

407

408 foreach(popb->drop_list, node) {

409 msg_info *info = (msg_info *) (node->data);

410 if (info->uid)

411 g_free(info->uid);

412 g_free(info);

413 }

414 g_list_free(popb->drop_list);

415

416 if (popb->buffer)

417 g_free(popb->buffer);

418 if (popb->timestamp)

419 g_free(popb->timestamp);

420 }

421

422 pop3_base*

423 pop3_in_open(gchar * host, gint port, GList * resolve_list, guint flags)

424 {

425 pop3_base *popb;

426 gint sock;

427 mxip_addr *addr;

428

429 DEBUG(5) debugf("pop3_in_open entered, host = %s\n", host);

430

431 if ((addr = connect_resolvelist(&sock, host, port, resolve_list))) {

432 /* create structure to hold status data: */

433 popb = create_pop3base(sock, flags);

434 popb->remote_host = addr->name;

435

436 DEBUG(5) {

437 struct sockaddr_in name;

438 int len;

439 getsockname(sock, (struct sockaddr *) (&name), &len);

440 debugf("socket: name.sin_addr = %s\n", inet_ntoa(name.sin_addr));

441 }

442 return popb;

443 }

444 return NULL;

445 }

446

447 pop3_base*

448 pop3_in_open_child(gchar * cmd, guint flags)

449 {

450 pop3_base *popb;

451 gint sock;

452

453 DEBUG(5) debugf("pop3_in_open_child entered, cmd = %s\n", cmd);

454 sock = child(cmd);

455 if (sock > 0) {

456 popb = create_pop3base(sock, flags);

457 popb->remote_host = NULL;

458 return popb;

459 }

460 logwrite(LOG_ALERT, "child failed (sock = %d): %s\n", sock, strerror(errno));

461

462 return NULL;

463 }

464

465 gboolean

466 pop3_in_init(pop3_base * popb)

467 {

468 gboolean ok;

469

470 if ((ok = read_response(popb, POP3_INITIAL_TIMEOUT))) {

471 ok = check_init_response(popb);

472 }

473 if (!ok)

474 /* pop3_in_log_failure(popb, NULL); */

475 logwrite(LOG_ALERT, "pop3 failed\n");

476 return ok;

477 }

478

479 gboolean

480 pop3_in_login(pop3_base * popb, gchar * user, gchar * pass)

481 {

482 if (popb->flags & POP3_FLAG_APOP) {

483

484 gchar *string = g_strdup_printf("%s%s", popb->timestamp, pass);

485 gchar *digest = MD5String(string);

486 pop3_printf(popb->out, "APOP %s %s\r\n", user, digest);

487 g_free(string);

488 g_free(digest);

489 if (read_response(popb, POP3_CMD_TIMEOUT)) {

490 if (check_response(popb))

491 return TRUE;

492 else

493 popb->error = pop3_login_failure;

494 }

495

496 } else {

497

498 pop3_printf(popb->out, "USER %s\r\n", user);

499 if (read_response(popb, POP3_CMD_TIMEOUT)) {

500 if (check_response(popb)) {

501 pop3_printf(popb->out, "PASS %s\r\n", pass);

502 if (read_response(popb, POP3_CMD_TIMEOUT)) {

503 if (check_response(popb))

504 return TRUE;

505 else

506 popb->error = pop3_login_failure;

507 }

508 } else {

509 popb->error = pop3_login_failure;

510 }

511 }

512 }

513 return FALSE;

514 }

515

516 gboolean

517 pop3_in_stat(pop3_base * popb)

518 {

519 pop3_printf(popb->out, "STAT\r\n");

520 if (read_response(popb, POP3_CMD_TIMEOUT)) {

521 gint msg_cnt, mbox_size;

522 if (check_response_int_int(popb, &msg_cnt, &mbox_size)) {

523 popb->msg_cnt = msg_cnt;

524 popb->mbox_size = mbox_size;

525

526 return TRUE;

527 }

528 }

529 return FALSE;

530 }

531

532 gboolean

533 pop3_in_list(pop3_base * popb)

534 {

535 pop3_printf(popb->out, "LIST\r\n");

536 if (read_response(popb, POP3_CMD_TIMEOUT)) {

537 if (get_drop_listing(popb)) {

538 return TRUE;

539 }

540 }

541 return FALSE;

542 }

543

544 gboolean

545 pop3_in_dele(pop3_base * popb, gint number)

546 {

547 pop3_printf(popb->out, "DELE %d\r\n", number);

548 if (read_response(popb, POP3_CMD_TIMEOUT)) {

549 return TRUE;

550 }

551 return FALSE;

552 }

553

554 message*

555 pop3_in_retr(pop3_base * popb, gint number, address * rcpt)

556 {

557 accept_error err;

558

559 pop3_printf(popb->out, "RETR %d\r\n", number);

560 if (read_response(popb, POP3_CMD_TIMEOUT)) {

561 message *msg = create_message();

562 msg->received_host = popb->remote_host;

563 msg->received_prot = (popb->flags & POP3_FLAG_APOP) ? PROT_APOP : PROT_POP3;

564 msg->transfer_id = (popb->next_id)++;

565 msg->rcpt_list = g_list_append(NULL, copy_address(rcpt));

566

567 if ((err = accept_message(popb->in, msg, ACC_MAIL_FROM_HEAD

568 | (conf.do_save_envelope_to ? ACC_SAVE_ENVELOPE_TO : 0)))

569 == AERR_OK)

570 return msg;

571

572 destroy_message(msg);

573 }

574 return NULL;

575 }

576

577 gboolean

578 pop3_in_uidl(pop3_base * popb)

579 {

580 pop3_printf(popb->out, "UIDL\r\n");

581 if (read_response(popb, POP3_CMD_TIMEOUT)) {

582 if (get_uid_listing(popb)) {

583 return TRUE;

584 }

585 }

586 return FALSE;

587 }

588

589 gboolean

590 pop3_in_quit(pop3_base * popb)

591 {

592 pop3_printf(popb->out, "QUIT\r\n");

593 DEBUG(4) debugf("QUIT\n");

594 signal(SIGALRM, SIG_DFL);

595 return TRUE;

596 }

597

598 /* Send a DELE command for each message in (the old) uid listing.

599 This is to prevent mail from to be kept on server, if a previous

600 transaction was interupted. */

601 gboolean

602 pop3_in_uidl_dele(pop3_base * popb)

603 {

604 GList *drop_node;

605

606 foreach(popb->drop_list, drop_node) {

607 msg_info *info = (msg_info *) (drop_node->data);

608 /* if(find_uid(popb, info->uid)){ */

609 if (info->is_in_uidl) {

610 if (!pop3_in_dele(popb, info->number))

611 return FALSE;

612 /* TODO: it probably makes sense to also delete this uid from the listing */

613 }

614 }

615 return TRUE;

616 }

617

618 gboolean

619 pop3_get(pop3_base * popb, gchar * user, gchar * pass, address * rcpt, address * return_path,

620 gint max_count, gint max_size, gboolean max_size_delete)

621 {

622 gboolean ok = FALSE;

623 gint num_children = 0;

624

625 DEBUG(5) debugf("rcpt = %s@%s\n", rcpt->local_part, rcpt->domain);

626

627 signal(SIGCHLD, SIG_DFL);

628

629 if (pop3_in_init(popb)) {

630 if (pop3_in_login(popb, user, pass)) {

631 if (pop3_in_stat(popb)) {

632 if (popb->msg_cnt > 0) {

633

634 logwrite(LOG_NOTICE | LOG_VERBOSE, "%d message(s) for user %s at %s\n",

635 popb->msg_cnt, user, popb->remote_host);

636

637 if (pop3_in_list(popb)) {

638 gboolean do_get = !(popb->flags & POP3_FLAG_UIDL);

639 if (!do_get)

640 do_get = pop3_in_uidl(popb);

641 if (do_get) {

642 gint count = 0;

643 GList *drop_node;

644

645 if (popb->flags & POP3_FLAG_UIDL) {

646 read_uidl(popb, user);

647 logwrite(LOG_VERBOSE | LOG_NOTICE, "%d message(s) already in uidl.\n", popb->uidl_known_cnt);

648 }

649 if ((popb->flags & POP3_FLAG_UIDL) && (popb->flags & POP3_FLAG_UIDL_DELE))

650 pop3_in_uidl_dele(popb);

651

652 foreach(popb->drop_list, drop_node) {

653

654 msg_info *info = (msg_info *) (drop_node->data);

655 gboolean do_get_this = !(popb->flags & POP3_FLAG_UIDL);

656 /* if(!do_get_this) do_get_this = !find_uid(popb, info->uid); */

657 if (!do_get_this)

658 do_get_this = !(info->is_in_uidl);

659 if (do_get_this) {

660

661 if ((info->size < max_size) || (max_size == 0)) {

662 message *msg;

663

664 logwrite(LOG_VERBOSE | LOG_NOTICE, "receiving message %d\n", info->number);

665 msg = pop3_in_retr(popb, info->number, rcpt);

666

667 if (msg) {

668 if (return_path)

669 msg->return_path = copy_address(return_path);

670 if (spool_write(msg, TRUE)) {

671 pid_t pid;

672 logwrite(LOG_NOTICE, "%s <= %s host=%s with %s\n", msg->uid,

673 addr_string(msg->return_path), popb->remote_host,

674 (popb->flags & POP3_FLAG_APOP) ? prot_names [PROT_APOP] : prot_names [PROT_POP3]);

675 info->is_fetched = TRUE;

676 count++;

677 #if DO_WRITE_UIDL_EARLY

678 if (popb->flags & POP3_FLAG_UIDL)

679 write_uidl(popb, user);

680 #endif

681 if (!conf.do_queue) {

682

683 /* wait for child processes. If there are too many, we wait blocking, before we fork another one */

684 while (num_children > 0) {

685 int status, options = WNOHANG;

686 pid_t pid;

687

688 if (num_children >= POP3_MAX_CHILDREN) {

689 logwrite(LOG_NOTICE, "too many children - waiting\n");

690 options = 0;

691 }

692 if ((pid = waitpid(0, &status, options)) > 0) {

693 num_children--;

694 if (WEXITSTATUS(status) != EXIT_SUCCESS)

695 logwrite(LOG_WARNING, "delivery process with pid %d returned %d\n", pid, WEXITSTATUS (status));

696 if (WIFSIGNALED(status))

697 logwrite(LOG_WARNING, "delivery process with pid %d got signal: %d\n", pid, WTERMSIG (status));

698 } else if (pid < 0) {

699 logwrite(LOG_WARNING, "wait got error: %s\n", strerror(errno));

700 }

701 }

702

703 if ((pid = fork()) == 0) {

704 deliver(msg);

705 _exit(EXIT_SUCCESS);

706 } else if (pid < 0) {

707 logwrite(LOG_ALERT | LOG_VERBOSE, "could not fork for delivery, id = %s: %s\n", msg->uid, strerror(errno));

708 } else

709 num_children++;

710 } else {

711 DEBUG(1) debugf("queuing forced by configuration or option.\n");

712 }

713 if (popb->flags & POP3_FLAG_DELETE)

714 pop3_in_dele(popb, info->number);

715

716 destroy_message(msg);

717 } /* if(spool_write(msg, TRUE)) */

718 } else {

719 logwrite(LOG_ALERT, "retrieving of message %d failed: %d\n", info->number, popb->error);

720 }

721 } /* if((info->size > max_size) ... */

722 else {

723 logwrite(LOG_NOTICE | LOG_VERBOSE, "size of message #%d (%d) > max_size (%d)\n", info->number, info->size, max_size);

724 if (max_size_delete)

725 if (popb->flags & POP3_FLAG_DELETE)

726 pop3_in_dele(popb, info->number);

727 }

728 } /* if(do_get_this) ... */

729 else {

730 if (popb->flags & POP3_FLAG_UIDL) {

731 info->is_fetched = TRUE; /* obsolete? */

732 logwrite(LOG_VERBOSE, "message %d already known\n", info->number);

733 DEBUG(1) debugf("message %d (uid = %s) not fetched\n", info->number, info->uid);

734 #if 0

735 #if DO_WRITE_UIDL_EARLY

736 write_uidl(popb, user); /* obsolete? */

737 #endif

738 #endif

739 }

740 }

741 if ((max_count != 0) && (count >= max_count))

742 break;

743 } /* foreach() */

744 #if DO_WRITE_UIDL_EARLY

745 #else

746 if (popb->flags & POP3_FLAG_UIDL)

747 write_uidl(popb, user);

748 #endif

749 } /* if(pop3_in_uidl(popb) ... */

750 } /* if(pop3_in_list(popb)) */

751 } /* if(popb->msg_cnt > 0) */

752 else {

753 logwrite(LOG_NOTICE | LOG_VERBOSE, "no messages for user %s at %s\n", user, popb->remote_host);

754 }

755 ok = TRUE;

756 }

757 pop3_in_quit(popb);

758 } else {

759 logwrite(LOG_ALERT | LOG_VERBOSE, "pop3 login failed for user %s, host = %s\n", user, popb->remote_host);

760 }

761 }

762 if (!ok) {

763 logwrite(LOG_ALERT | LOG_VERBOSE, "pop3 failed, error = %d\n", popb->error);

764 }

765

766 while (num_children > 0) {

767 int status;

768 pid_t pid;

769 if ((pid = wait(&status)) > 0) {

770 num_children--;

771 if (WEXITSTATUS(status) != EXIT_SUCCESS)

772 logwrite(LOG_WARNING, "delivery process with pid %d returned %d\n", pid, WEXITSTATUS(status));

773 if (WIFSIGNALED(status))

774 logwrite(LOG_WARNING, "delivery process with pid %d got signal: %d\n", pid, WTERMSIG(status));

775 } else {

776 logwrite(LOG_WARNING, "wait got error: %s\n", strerror(errno));

777 }

778 }

779

780 return ok;

781 }

782

783 /* function just to log into a pop server,

784 for pop_before_smtp (or is it smtp_after_pop?)

785 */

786

787 gboolean

788 pop3_login(gchar * host, gint port, GList * resolve_list, gchar * user, gchar * pass, guint flags)

789 {

790 gboolean ok = FALSE;

791 pop3_base *popb;

792

793 signal(SIGCHLD, SIG_IGN);

794

795 if ((popb = pop3_in_open(host, port, resolve_list, flags))) {

796 if (pop3_in_init(popb)) {

797 if (pop3_in_login(popb, user, pass))

798 ok = TRUE;

799 else

800 logwrite(LOG_ALERT | LOG_VERBOSE, "pop3 login failed for user %s, host = %s\n", user, host);

801 }

802 pop3_in_close(popb);

803 }

804 return ok;

805 }

806

807 #endif