Home
last modified time | relevance | path

Searched refs:vstream_fileno (Results 1 – 25 of 87) sorted by relevance

1234

/dports/mail/postfix-current/postfix-3.7-20211107/src/postscreen/
H A Dpostscreen_starttls.c94 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 Dpostscreen_haproxy.c95 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 Dpostscreen_early.c115 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 Dpostscreen_send.c174 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 Dmulti_server.c326 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 Dmaster.c508 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 Devent_server.c358 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 Dtrigger_server.c303 && 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 Dsingle_server.c339 && 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 Dclnt_stream.c176 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 Dpost_mail.c338 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 Dmail_stream.c179 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 Dmbox_open.c170 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 Dscache_clnt.c141 || 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 Dabounce.c253 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 Dmail_copy.c159 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 Dedit_file.c238 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 Dvstream_tweak.c76 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 Dsafe_open.c117 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 Dsmtp-source.c439 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 Dflush.c355 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 Dbounce_append_service.c88 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 Dspawn.c308 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 Dsmtpd_haproxy.c106 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 Dtls_session.c122 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()

1234