/dports/mail/postfix-current/postfix-3.7-20211107/src/postscreen/ |
H A D | postscreen_starttls.c | 94 event_disable_readwrite(vstream_fileno(tlsproxy_stream)); \ 120 myname, vstream_fileno(tlsproxy_stream), in psc_starttls_finish() 121 vstream_fileno(smtp_state->smtp_client_stream), in psc_starttls_finish() 159 else if (LOCAL_SEND_FD(vstream_fileno(tlsproxy_stream), in psc_starttls_finish() 160 vstream_fileno(smtp_state->smtp_client_stream)) < 0) { in psc_starttls_finish() 210 myname, vstream_fileno(tlsproxy_stream), in psc_starttls_first() 211 vstream_fileno(smtp_state->smtp_client_stream), in psc_starttls_first() 267 PSC_READ_EVENT_REQUEST(vstream_fileno(tlsproxy_stream), psc_starttls_finish, in psc_starttls_first() 299 myname, fd, vstream_fileno(smtp_state->smtp_client_stream), in psc_starttls_open() 315 PSC_READ_EVENT_REQUEST(vstream_fileno(tlsproxy_stream), psc_starttls_first, in psc_starttls_open()
|
H A D | postscreen_haproxy.c | 95 status = haproxy_srvr_receive(vstream_fileno(state->stream), &non_proxy, in psc_endpt_haproxy_event() 103 PSC_CLEAR_EVENT_REQUEST(vstream_fileno(state->stream), in psc_endpt_haproxy_event() 135 PSC_READ_EVENT_REQUEST(vstream_fileno(stream), psc_endpt_haproxy_event, in psc_endpt_haproxy_lookup()
|
H A D | postscreen_early.c | 115 event, vstream_fileno(state->smtp_client_stream), in psc_early_event() 119 PSC_CLEAR_EVENT_REQUEST(vstream_fileno(state->smtp_client_stream), in psc_early_event() 231 if ((read_count = recv(vstream_fileno(state->smtp_client_stream), in psc_early_event() 362 PSC_READ_EVENT_REQUEST(vstream_fileno(state->smtp_client_stream), in psc_early_tests()
|
H A D | postscreen_send.c | 174 ret = write(vstream_fileno(state->smtp_client_stream), in psc_send_reply() 223 vstream_fileno(state->smtp_client_stream), in psc_send_socket() 258 vstream_fileno(state->smtp_client_stream)) < 0 in psc_send_socket()
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/master/ |
H A D | multi_server.c | 326 msg_info("connection closed fd %d", vstream_fileno(stream)); in multi_server_disconnect() 329 event_disable_readwrite(vstream_fileno(stream)); in multi_server_disconnect() 346 && myflock(vstream_fileno(multi_server_lock), INTERNAL_LOCK, in multi_server_execute() 355 if (peekfd(vstream_fileno(stream)) > 0) { in multi_server_execute() 372 event_enable_read(vstream_fileno(stream), multi_server_execute, (void *) stream); in multi_server_enable_read() 446 && myflock(vstream_fileno(multi_server_lock), INTERNAL_LOCK, in multi_server_accept_local() 484 && myflock(vstream_fileno(multi_server_lock), INTERNAL_LOCK, in multi_server_accept_pass() 521 && myflock(vstream_fileno(multi_server_lock), INTERNAL_LOCK, in multi_server_accept_inet() 849 close_on_exec(vstream_fileno(multi_server_lock), CLOSE_ON_EXEC); in multi_server_main() 922 if (myflock(vstream_fileno(multi_server_lock), INTERNAL_LOCK, in multi_server_main()
|
H A D | master.c | 508 close_on_exec(vstream_fileno(lock_fp), CLOSE_ON_EXEC); in main() 525 close_on_exec(vstream_fileno(data_lock_fp), CLOSE_ON_EXEC); in main() 573 if (myflock(vstream_fileno(lock_fp), INTERNAL_LOCK, in main() 576 if (myflock(vstream_fileno(data_lock_fp), INTERNAL_LOCK, in main()
|
H A D | event_server.c | 358 msg_info("connection closed fd %d", vstream_fileno(stream)); in event_server_disconnect() 378 && myflock(vstream_fileno(event_server_lock), INTERNAL_LOCK, in event_server_execute() 462 && myflock(vstream_fileno(event_server_lock), INTERNAL_LOCK, in event_server_accept_local() 500 && myflock(vstream_fileno(event_server_lock), INTERNAL_LOCK, in event_server_accept_pass() 537 && myflock(vstream_fileno(event_server_lock), INTERNAL_LOCK, in event_server_accept_inet() 883 close_on_exec(vstream_fileno(event_server_lock), CLOSE_ON_EXEC); in event_server_main() 959 if (myflock(vstream_fileno(event_server_lock), INTERNAL_LOCK, in event_server_main()
|
H A D | trigger_server.c | 303 && myflock(vstream_fileno(trigger_server_lock), INTERNAL_LOCK, in trigger_server_accept_fifo() 345 && myflock(vstream_fileno(trigger_server_lock), INTERNAL_LOCK, in trigger_server_accept_local() 391 && myflock(vstream_fileno(trigger_server_lock), INTERNAL_LOCK, in trigger_server_accept_pass() 730 close_on_exec(vstream_fileno(trigger_server_lock), CLOSE_ON_EXEC); in trigger_server_main() 768 if ((len = read(vstream_fileno(stream), buf, sizeof(buf))) <= 0) in trigger_server_main() 800 if (myflock(vstream_fileno(trigger_server_lock), INTERNAL_LOCK, in trigger_server_main()
|
H A D | single_server.c | 339 && myflock(vstream_fileno(single_server_lock), INTERNAL_LOCK, in single_server_accept_local() 376 && myflock(vstream_fileno(single_server_lock), INTERNAL_LOCK, in single_server_accept_pass() 412 && myflock(vstream_fileno(single_server_lock), INTERNAL_LOCK, in single_server_accept_inet() 739 close_on_exec(vstream_fileno(single_server_lock), CLOSE_ON_EXEC); in single_server_main() 813 if (myflock(vstream_fileno(single_server_lock), INTERNAL_LOCK, in single_server_main()
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/global/ |
H A D | clnt_stream.c | 176 close_on_exec(vstream_fileno(clnt_stream->vstream), CLOSE_ON_EXEC); in clnt_stream_open() 177 event_enable_read(vstream_fileno(clnt_stream->vstream), clnt_stream_event, in clnt_stream_open() 201 event_disable_readwrite(vstream_fileno(clnt_stream->vstream)); in clnt_stream_close() 234 } else if (readable(vstream_fileno(clnt_stream->vstream))) { in clnt_stream_access()
|
H A D | post_mail.c | 338 event_disable_readwrite(vstream_fileno(state->stream)); in post_mail_open_event() 339 non_blocking(vstream_fileno(state->stream), BLOCKING); in post_mail_open_event() 357 event_disable_readwrite(vstream_fileno(state->stream)); in post_mail_open_event() 374 event_disable_readwrite(vstream_fileno(state->stream)); in post_mail_open_event() 418 event_enable_read(vstream_fileno(stream), post_mail_open_event, in post_mail_fopen_async() 518 event_disable_readwrite(vstream_fileno(state->stream)); in post_mail_fclose_event() 564 event_enable_read(vstream_fileno(stream), post_mail_fclose_event, in post_mail_fclose_async()
|
H A D | mail_stream.c | 179 return (futimesat(vstream_fileno(fp), (char *) 0, tv)); in stamp_stream() 181 return (futimesat(vstream_fileno(fp), (char *) 0, (struct timeval *) 0)); in stamp_stream() 197 return (futimes(vstream_fileno(fp), tv)); in stamp_stream() 199 return (futimes(vstream_fileno(fp), (struct timeval *) 0)); in stamp_stream() 302 || fchmod(vstream_fileno(info->stream), 0700 | info->mode) in mail_stream_finish_file() 304 || fsync(vstream_fileno(info->stream)) in mail_stream_finish_file() 307 && fstat(vstream_fileno(info->stream), &st) < 0) in mail_stream_finish_file()
|
H A D | mbox_open.c | 170 close_on_exec(vstream_fileno(fp), CLOSE_ON_EXEC); in mbox_open() 179 || deliver_flock(vstream_fileno(fp), (myflock_style), why->reason) == 0) in mbox_open() 206 && (fstat(vstream_fileno(fp), st) < 0 || st->st_nlink != 1)) { in mbox_open()
|
H A D | scache_clnt.c | 141 || LOCAL_SEND_FD(vstream_fileno(stream), fd) < 0 in scache_clnt_save_endp() 214 || read_wait(vstream_fileno(stream), in scache_clnt_find_endp() 217 (fd = LOCAL_RECV_FD(vstream_fileno(stream))) < 0) { in scache_clnt_find_endp() 358 || read_wait(vstream_fileno(stream), in scache_clnt_find_dest() 361 (fd = LOCAL_RECV_FD(vstream_fileno(stream))) < 0) { in scache_clnt_find_dest()
|
H A D | abounce.c | 253 event_disable_readwrite(vstream_fileno(ap->fp)); in abounce_done() 303 non_blocking(vstream_fileno(ap->fp), BLOCKING); in abounce_send() 311 ABOUNCE_EVENT_ENABLE(vstream_fileno(ap->fp), abounce_receive, in abounce_send() 383 ABOUNCE_EVENT_ENABLE(vstream_fileno(ap->fp), abounce_send, in abounce_connect()
|
H A D | mail_copy.c | 159 if (fstat(vstream_fileno(src), &st) < 0) in mail_copy() 275 write_error |= fsync(vstream_fileno(dst)); in mail_copy() 289 (void) ftruncate(vstream_fileno(dst), orig_length); in mail_copy()
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/util/ |
H A D | edit_file.c | 238 if (myflock(vstream_fileno(ep->tmp_fp), INTERNAL_LOCK, in edit_file_open() 247 if (fstat(vstream_fileno(ep->tmp_fp), &before_lock) < 0) in edit_file_open() 297 if (ftruncate(vstream_fileno(ep->tmp_fp), 0) < 0) in edit_file_open() 323 int fd = vstream_fileno(fp); in edit_file_close()
|
H A D | vstream_tweak.c | 76 if ((ret = getsockname(vstream_fileno(fp), sa, &sa_length)) >= 0) { in vstream_tweak_sock() 113 if ((err = getsockopt(vstream_fileno(fp), IPPROTO_TCP, TCP_MAXSEG, in vstream_tweak_tcp() 161 if ((err = setsockopt(vstream_fileno(fp), IPPROTO_TCP, TCP_NODELAY, in vstream_tweak_tcp()
|
H A D | safe_open.c | 117 if (fstat(vstream_fileno(fp), fstat_st) < 0) { in safe_open_exist() 212 if (st != 0 && fstat(vstream_fileno(fp), st) < 0) in safe_open_create() 223 && fchown(vstream_fileno(fp), user, group) < 0) { in safe_open_create()
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/smtpstone/ |
H A D | smtp-source.c | 439 event_disable_readwrite(vstream_fileno(session->stream)); in fail_connect() 485 int fd = vstream_fileno(session->stream); in connect_done() 561 event_enable_read(vstream_fileno(session->stream), helo_done, (void *) session); in send_helo() 611 event_enable_read(vstream_fileno(session->stream), mail_done, (void *) session); in send_mail() 670 event_enable_read(vstream_fileno(session->stream), rcpt_done, (void *) session); in send_rcpt() 771 mypid, vstream_fileno(session->stream), message_count, var_myhostname); in data_done() 813 event_enable_read(vstream_fileno(session->stream), dot_done, (void *) session); in data_done() 850 event_disable_readwrite(vstream_fileno(session->stream)); in dot_done() 896 event_disable_readwrite(vstream_fileno(session->stream)); in rset_done() 916 event_disable_readwrite(vstream_fileno(session->stream)); in quit_done() [all …]
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/flush/ |
H A D | flush.c | 355 if (myflock(vstream_fileno(log), INTERNAL_LOCK, MYFLOCK_OP_EXCLUSIVE) < 0) in flush_add_path() 371 if (myflock(vstream_fileno(log), INTERNAL_LOCK, MYFLOCK_OP_NONE) < 0) in flush_add_path() 467 if (fchmod(vstream_fileno(fp), st.st_mode | MAIL_QUEUE_STAT_UNTHROTTLE) < 0) in flush_one_file() 527 if (myflock(vstream_fileno(log), INTERNAL_LOCK, MYFLOCK_OP_EXCLUSIVE) < 0) in flush_send_path() 595 if (count > 0 && ftruncate(vstream_fileno(log), (off_t) 0) < 0) in flush_send_path() 606 if (myflock(vstream_fileno(log), INTERNAL_LOCK, MYFLOCK_OP_NONE) < 0) in flush_send_path() 713 if (read_wait(vstream_fileno(client_stream), var_ipc_timeout) < 0) { in flush_request_receive() 718 if ((count = peekfd(vstream_fileno(client_stream))) < 0) { in flush_request_receive()
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/bounce/ |
H A D | bounce_append_service.c | 88 if (deliver_flock(vstream_fileno(log), INTERNAL_LOCK, (VSTRING *) 0) < 0) in bounce_append_service() 149 if (vstream_fflush(log) != 0 || fsync(vstream_fileno(log)) < 0) { in bounce_append_service() 151 if (ftruncate(vstream_fileno(log), (off_t) orig_length) < 0) in bounce_append_service()
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/spawn/ |
H A D | spawn.c | 308 status = spawn_command(CA_SPAWN_CMD_STDIN(vstream_fileno(client_stream)), in spawn_service() 309 CA_SPAWN_CMD_STDOUT(vstream_fileno(client_stream)), in spawn_service() 310 CA_SPAWN_CMD_STDERR(vstream_fileno(client_stream)), in spawn_service()
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/smtpd/ |
H A D | smtpd_haproxy.c | 106 if (read_wait(vstream_fileno(state->client), var_smtpd_uproxy_tmout) < 0) { in smtpd_peer_from_haproxy() 110 if (haproxy_srvr_receive(vstream_fileno(state->client), &non_proxy, in smtpd_peer_from_haproxy()
|
/dports/mail/postfix-current/postfix-3.7-20211107/src/tls/ |
H A D | tls_session.c | 122 retval = tls_bio_shutdown(vstream_fileno(stream), timeout, TLScontext); in tls_session_stop() 124 tls_bio_shutdown(vstream_fileno(stream), timeout, TLScontext); in tls_session_stop()
|