Symbol: relay
sbin/ldattach/ldattach.c
319
relay(fd, master);
sbin/ldattach/ldattach.c
48
void relay(int, int);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
304
relay_reserve(log->relay.channel, log->vma->obj->base.size -
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
308
relay_flush(log->relay.channel);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
326
return relay_reserve(log->relay.channel, 0);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
396
mutex_lock(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
414
log->relay.full_count++;
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
489
mutex_unlock(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
495
container_of(work, struct intel_guc_log, relay.flush_work);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
502
lockdep_assert_held(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
512
log->relay.buf_in_use = true;
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
519
lockdep_assert_held(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
522
log->relay.buf_in_use = false;
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
530
drmm_mutex_init(&i915->drm, &log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
532
INIT_WORK(&log->relay.flush_work, copy_debug_logs_work);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
533
log->relay.started = false;
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
547
lockdep_assert_held(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
579
log->relay.channel = guc_log_relay_chan;
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
589
lockdep_assert_held(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
591
relay_close(log->relay.channel);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
592
log->relay.channel = NULL;
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
739
mutex_lock(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
764
mutex_unlock(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
771
mutex_unlock(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
778
if (log->relay.started)
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
786
queue_work(system_highpri_wq, &log->relay.flush_work);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
788
log->relay.started = true;
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
798
if (!log->relay.started)
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
805
flush_work(&log->relay.flush_work);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
824
if (!log->relay.started)
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
829
flush_work(&log->relay.flush_work);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
831
log->relay.started = false;
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
838
mutex_lock(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
842
mutex_unlock(&log->relay.lock);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
847
if (log->relay.started)
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
848
queue_work(system_highpri_wq, &log->relay.flush_work);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.c
886
drm_printf(p, "\tRelay full count: %u\n", log->relay.full_count);
sys/dev/pci/drm/i915/gt/uc/intel_guc_log.h
74
} relay;
usr.sbin/dhcrelay/dhcrelay.c
285
bootp_packet_handler = relay;
usr.sbin/dhcrelay/dhcrelay.c
66
void relay(struct interface_info *, struct dhcp_packet *, int,
usr.sbin/nsd/rdata.c
3681
struct dname_buffer relay;
usr.sbin/nsd/rdata.c
3715
if(!dname_make_from_packet_buffered(&relay, packet,
usr.sbin/nsd/rdata.c
3720
relay_length = relay.dname.name_size;
usr.sbin/nsd/rdata.c
3721
relay_rdata = dname_name((void*)&relay);
usr.sbin/relayctl/relayctl.c
349
struct relay *rlay;
usr.sbin/relayd/agentx_control.c
178
struct relay *agentxctl_relay_byidx(uint32_t, enum agentx_request_type);
usr.sbin/relayd/agentx_control.c
588
struct relay *
usr.sbin/relayd/agentx_control.c
591
struct relay *rly;
usr.sbin/relayd/agentx_control.c
613
struct relay *rly;
usr.sbin/relayd/ca.c
105
struct relay *rlay;
usr.sbin/relayd/config.c
1031
struct relay *rlay;
usr.sbin/relayd/config.c
1093
struct relay *rlay;
usr.sbin/relayd/config.c
1134
struct relay *rlay = NULL;
usr.sbin/relayd/config.c
147
struct relay *rlay;
usr.sbin/relayd/config.c
819
config_setrelay(struct relayd *env, struct relay *rlay)
usr.sbin/relayd/parse.y
113
static struct relay *rlay = NULL;
usr.sbin/relayd/parse.y
139
int relay_id(struct relay *);
usr.sbin/relayd/parse.y
140
struct relay *relay_inherit(struct relay *, struct relay *);
usr.sbin/relayd/parse.y
1809
relay : RELAY STRING {
usr.sbin/relayd/parse.y
1810
struct relay *r;
usr.sbin/relayd/parse.y
1851
struct relay *r;
usr.sbin/relayd/parse.y
1924
struct relay *r;
usr.sbin/relayd/parse.y
210
| grammar relay '\n'
usr.sbin/relayd/parse.y
3398
relay_id(struct relay *rl)
usr.sbin/relayd/parse.y
3408
struct relay *
usr.sbin/relayd/parse.y
3409
relay_inherit(struct relay *ra, struct relay *rb)
usr.sbin/relayd/pfe.c
257
struct relay *rlay;
usr.sbin/relayd/pfe.c
358
struct relay *rlay;
usr.sbin/relayd/relay.c
1111
struct relay *rlay = arg;
usr.sbin/relayd/relay.c
1293
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
1418
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
1443
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
1485
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
1533
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
1631
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
1744
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
1861
struct relay *rlay;
usr.sbin/relayd/relay.c
1995
struct relay *rlay;
usr.sbin/relayd/relay.c
2144
relay_tls_ctx_create(struct relay *rlay)
usr.sbin/relayd/relay.c
2321
relay_tls_inspect_create(struct relay *rlay, struct ctl_relay_event *cre)
usr.sbin/relayd/relay.c
2368
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
2417
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
268
relay_protodebug(struct relay *rlay)
usr.sbin/relayd/relay.c
2717
struct relay *rlay = b->se_relay;
usr.sbin/relayd/relay.c
307
relay_privinit(struct relay *rlay)
usr.sbin/relayd/relay.c
376
struct relay *rlay;
usr.sbin/relayd/relay.c
443
struct relay *rlay;
usr.sbin/relayd/relay.c
60
void relay_protodebug(struct relay *);
usr.sbin/relayd/relay.c
688
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
76
int relay_tls_ctx_create(struct relay *);
usr.sbin/relayd/relay.c
810
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay.c
938
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay_http.c
1058
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay_http.c
108
relay_http_init(struct relay *rlay)
usr.sbin/relayd/relay_http.c
1178
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay_http.c
187
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay_udp.c
181
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay_udp.c
215
struct relay *rlay = arg;
usr.sbin/relayd/relay_udp.c
401
relay_dns_validate(struct rsession *con, struct relay *rlay,
usr.sbin/relayd/relay_udp.c
458
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay_udp.c
514
struct relay *rlay = con->se_relay;
usr.sbin/relayd/relay_udp.c
53
struct relay *, struct sockaddr_storage *,
usr.sbin/relayd/relay_udp.c
61
relay_udp_privinit(struct relay *rlay)
usr.sbin/relayd/relay_udp.c
69
relay_udp_init(struct relayd *x_env, struct relay *rlay)
usr.sbin/relayd/relayd.c
1093
struct relay *
usr.sbin/relayd/relayd.c
1096
struct relay *rlay;
usr.sbin/relayd/relayd.c
1118
struct relay *rlay;
usr.sbin/relayd/relayd.c
1213
struct relay *
usr.sbin/relayd/relayd.c
1216
struct relay *rlay;
usr.sbin/relayd/relayd.c
1224
struct relay *
usr.sbin/relayd/relayd.c
1227
struct relay *rlay;
usr.sbin/relayd/relayd.c
1338
relay_load_certfiles(struct relayd *env, struct relay *rlay, const char *name)
usr.sbin/relayd/relayd.c
289
struct relay *rlay;
usr.sbin/relayd/relayd.c
565
purge_relay(struct relayd *env, struct relay *rlay)
usr.sbin/relayd/relayd.c
76
{ "relay", PROC_RELAY, parent_dispatch_relay, relay },
usr.sbin/relayd/relayd.h
1210
void relay(struct privsep *, struct privsep_proc *);
usr.sbin/relayd/relayd.h
1211
int relay_privinit(struct relay *);
usr.sbin/relayd/relayd.h
1254
void relay_http_init(struct relay *);
usr.sbin/relayd/relayd.h
1269
void relay_udp_privinit(struct relay *);
usr.sbin/relayd/relayd.h
1270
void relay_udp_init(struct relayd *, struct relay *);
usr.sbin/relayd/relayd.h
1315
struct relay *relay_find(struct relayd *, objid_t);
usr.sbin/relayd/relayd.h
1318
struct relay *relay_findbyname(struct relayd *, const char *);
usr.sbin/relayd/relayd.h
1319
struct relay *relay_findbyaddr(struct relayd *, struct relay_config *);
usr.sbin/relayd/relayd.h
1325
int relay_load_certfiles(struct relayd *, struct relay *,
usr.sbin/relayd/relayd.h
1332
void purge_relay(struct relayd *, struct relay *);
usr.sbin/relayd/relayd.h
1454
int config_setrelay(struct relayd *, struct relay *);
usr.sbin/relayd/relayd.h
585
struct relay *se_relay;
usr.sbin/relayd/relayd.h
758
void *(*validate)(struct rsession *, struct relay *,
usr.sbin/relayd/relayd.h
818
TAILQ_ENTRY(relay) rl_entry;
usr.sbin/relayd/relayd.h
850
TAILQ_HEAD(relaylist, relay);
usr.sbin/smtpd/mta.c
1009
mta_query_preference(struct mta_relay *relay)
usr.sbin/smtpd/mta.c
1011
if (relay->status & RELAY_WAIT_PREFERENCE)
usr.sbin/smtpd/mta.c
1015
mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
1017
tree_xset(&wait_preference, relay->id, relay);
usr.sbin/smtpd/mta.c
1018
relay->status |= RELAY_WAIT_PREFERENCE;
usr.sbin/smtpd/mta.c
1021
m_add_id(p_lka, relay->id);
usr.sbin/smtpd/mta.c
1022
m_add_string(p_lka, relay->domain->name);
usr.sbin/smtpd/mta.c
1023
m_add_string(p_lka, relay->backupname);
usr.sbin/smtpd/mta.c
1026
mta_relay_ref(relay);
usr.sbin/smtpd/mta.c
1030
mta_query_source(struct mta_relay *relay)
usr.sbin/smtpd/mta.c
1033
mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
1035
relay->sourceloop += 1;
usr.sbin/smtpd/mta.c
1037
if (relay->sourcetable == NULL) {
usr.sbin/smtpd/mta.c
1042
mta_relay_ref(relay);
usr.sbin/smtpd/mta.c
1043
mta_on_source(relay, mta_source(NULL));
usr.sbin/smtpd/mta.c
1048
m_add_id(p_lka, relay->id);
usr.sbin/smtpd/mta.c
1049
m_add_string(p_lka, relay->sourcetable);
usr.sbin/smtpd/mta.c
1052
tree_xset(&wait_source, relay->id, relay);
usr.sbin/smtpd/mta.c
1053
relay->status |= RELAY_WAIT_SOURCE;
usr.sbin/smtpd/mta.c
1054
mta_relay_ref(relay);
usr.sbin/smtpd/mta.c
1061
struct mta_relay *relay = arg;
usr.sbin/smtpd/mta.c
1064
tag, domain->name, mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
1070
relay->fail = IMSG_MTA_DELIVERY_TEMPFAIL;
usr.sbin/smtpd/mta.c
1071
relay->failstr = "Temporary failure in MX lookup";
usr.sbin/smtpd/mta.c
1074
relay->fail = IMSG_MTA_DELIVERY_PERMFAIL;
usr.sbin/smtpd/mta.c
1075
relay->failstr = "Invalid domain name";
usr.sbin/smtpd/mta.c
1078
relay->fail = IMSG_MTA_DELIVERY_PERMFAIL;
usr.sbin/smtpd/mta.c
1079
relay->failstr = "Domain does not exist";
usr.sbin/smtpd/mta.c
1082
relay->fail = IMSG_MTA_DELIVERY_TEMPFAIL;
usr.sbin/smtpd/mta.c
1083
if (relay->domain->as_host)
usr.sbin/smtpd/mta.c
1084
relay->failstr = "Host not found";
usr.sbin/smtpd/mta.c
1086
relay->failstr = "No MX found for domain";
usr.sbin/smtpd/mta.c
1089
relay->fail = IMSG_MTA_DELIVERY_PERMFAIL;
usr.sbin/smtpd/mta.c
1090
relay->failstr = "Domain does not accept mail";
usr.sbin/smtpd/mta.c
1099
mta_relay_to_text(relay), relay->failstr);
usr.sbin/smtpd/mta.c
1101
relay->status &= ~RELAY_WAIT_MX;
usr.sbin/smtpd/mta.c
1102
mta_drain(relay);
usr.sbin/smtpd/mta.c
1103
mta_relay_unref(relay); /* from mta_drain() */
usr.sbin/smtpd/mta.c
1107
mta_on_secret(struct mta_relay *relay, const char *secret)
usr.sbin/smtpd/mta.c
1110
mta_relay_to_text(relay), secret);
usr.sbin/smtpd/mta.c
1113
relay->secret = strdup(secret);
usr.sbin/smtpd/mta.c
1115
if (relay->secret == NULL) {
usr.sbin/smtpd/mta.c
1117
"for %s", mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
1118
relay->fail = IMSG_MTA_DELIVERY_TEMPFAIL;
usr.sbin/smtpd/mta.c
1119
relay->failstr = "Could not retrieve credentials";
usr.sbin/smtpd/mta.c
1122
relay->status &= ~RELAY_WAIT_SECRET;
usr.sbin/smtpd/mta.c
1123
mta_drain(relay);
usr.sbin/smtpd/mta.c
1124
mta_relay_unref(relay); /* from mta_query_secret() */
usr.sbin/smtpd/mta.c
1148
mta_on_preference(struct mta_relay *relay, int preference)
usr.sbin/smtpd/mta.c
1151
mta_relay_to_text(relay), preference);
usr.sbin/smtpd/mta.c
1153
relay->backuppref = preference;
usr.sbin/smtpd/mta.c
1155
relay->status &= ~RELAY_WAIT_PREFERENCE;
usr.sbin/smtpd/mta.c
1156
mta_drain(relay);
usr.sbin/smtpd/mta.c
1157
mta_relay_unref(relay); /* from mta_query_preference() */
usr.sbin/smtpd/mta.c
1161
mta_on_source(struct mta_relay *relay, struct mta_source *source)
usr.sbin/smtpd/mta.c
1168
mta_relay_to_text(relay), source ? mta_source_to_text(source) : "NULL");
usr.sbin/smtpd/mta.c
1170
relay->lastsource = time(NULL);
usr.sbin/smtpd/mta.c
1174
c = mta_connector(relay, source);
usr.sbin/smtpd/mta.c
1181
relay->sourceloop = 0;
usr.sbin/smtpd/mta.c
1188
mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
1191
if (tree_count(&relay->connectors) == 0) {
usr.sbin/smtpd/mta.c
1192
relay->fail = IMSG_MTA_DELIVERY_TEMPFAIL;
usr.sbin/smtpd/mta.c
1193
relay->failstr = "Could not retrieve source address";
usr.sbin/smtpd/mta.c
1195
if (tree_count(&relay->connectors) < relay->sourceloop) {
usr.sbin/smtpd/mta.c
1196
relay->fail = IMSG_MTA_DELIVERY_TEMPFAIL;
usr.sbin/smtpd/mta.c
1197
relay->failstr = "No valid route to remote MX";
usr.sbin/smtpd/mta.c
1201
while (tree_iter(&relay->connectors, &iter, NULL, (void **)&c))
usr.sbin/smtpd/mta.c
1205
relay->failstr = "Destination seem to reject all mails";
usr.sbin/smtpd/mta.c
1207
relay->failstr = "Network error on destination MXs";
usr.sbin/smtpd/mta.c
1209
relay->failstr = "No MX found for destination";
usr.sbin/smtpd/mta.c
1211
relay->failstr = "Address family mismatch on destination MXs";
usr.sbin/smtpd/mta.c
1213
relay->failstr = "All routes to destination blocked";
usr.sbin/smtpd/mta.c
1215
relay->failstr = "No valid route to destination";
usr.sbin/smtpd/mta.c
1218
relay->nextsource = relay->lastsource + delay;
usr.sbin/smtpd/mta.c
1219
relay->status &= ~RELAY_WAIT_SOURCE;
usr.sbin/smtpd/mta.c
1220
mta_drain(relay);
usr.sbin/smtpd/mta.c
1221
mta_relay_unref(relay); /* from mta_query_source() */
usr.sbin/smtpd/mta.c
1229
struct mta_limits *l = c->relay->limits;
usr.sbin/smtpd/mta.c
1234
if (mta_is_blocked(c->source, c->relay->domain->name))
usr.sbin/smtpd/mta.c
1256
if (c->relay->ntask == 0) {
usr.sbin/smtpd/mta.c
1262
if ((c->relay->nconn_ready >= c->relay->ntask) ||
usr.sbin/smtpd/mta.c
1263
(c->relay->nconn > 2 && c->relay->nconn >= c->relay->ntask / 2)) {
usr.sbin/smtpd/mta.c
1271
if (c->relay->domain->lastconn + l->conndelay_domain > nextconn) {
usr.sbin/smtpd/mta.c
1273
c->relay->domain->name,
usr.sbin/smtpd/mta.c
1274
(unsigned long long) c->relay->domain->lastconn + l->conndelay_domain - now);
usr.sbin/smtpd/mta.c
1275
nextconn = c->relay->domain->lastconn + l->conndelay_domain;
usr.sbin/smtpd/mta.c
1277
if (c->relay->domain->nconn >= l->maxconn_per_domain) {
usr.sbin/smtpd/mta.c
1304
if (c->relay->lastconn + l->conndelay_relay > nextconn) {
usr.sbin/smtpd/mta.c
1306
mta_relay_to_text(c->relay),
usr.sbin/smtpd/mta.c
1307
(unsigned long long) c->relay->lastconn + l->conndelay_relay - now);
usr.sbin/smtpd/mta.c
1308
nextconn = c->relay->lastconn + l->conndelay_relay;
usr.sbin/smtpd/mta.c
1310
if (c->relay->nconn >= l->maxconn_per_relay) {
usr.sbin/smtpd/mta.c
1353
c->relay->nconn += 1;
usr.sbin/smtpd/mta.c
1354
c->relay->lastconn = c->lastconn;
usr.sbin/smtpd/mta.c
1355
c->relay->domain->nconn += 1;
usr.sbin/smtpd/mta.c
1356
c->relay->domain->lastconn = c->lastconn;
usr.sbin/smtpd/mta.c
1364
mta_session(c->relay, route, mx->mxname); /* this never fails synchronously */
usr.sbin/smtpd/mta.c
1365
mta_relay_ref(c->relay);
usr.sbin/smtpd/mta.c
1374
struct mta_relay *relay = arg;
usr.sbin/smtpd/mta.c
1380
mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
1381
relay->status &= ~RELAY_WAIT_CONNECTOR;
usr.sbin/smtpd/mta.c
1382
mta_drain(relay);
usr.sbin/smtpd/mta.c
1383
mta_relay_unref(relay); /* from mta_drain() */
usr.sbin/smtpd/mta.c
1527
mta_flush(struct mta_relay *relay, int fail, const char *error)
usr.sbin/smtpd/mta.c
1537
mta_relay_to_text(relay), fail, error);
usr.sbin/smtpd/mta.c
1543
while ((task = TAILQ_FIRST(&relay->tasks))) {
usr.sbin/smtpd/mta.c
1544
TAILQ_REMOVE(&relay->tasks, task, entry);
usr.sbin/smtpd/mta.c
1557
while (tree_iter(&relay->connectors, &iter,
usr.sbin/smtpd/mta.c
1562
if (tree_count(&relay->connectors) == r)
usr.sbin/smtpd/mta.c
1566
mta_delivery_log(e, NULL, relay->domain->name, fail, error);
usr.sbin/smtpd/mta.c
1575
stat_decrement("mta.task", relay->ntask);
usr.sbin/smtpd/mta.c
1577
relay->ntask = 0;
usr.sbin/smtpd/mta.c
1580
if (relay->state & RELAY_HOLDQ) {
usr.sbin/smtpd/mta.c
1582
m_add_id(p_queue, relay->id);
usr.sbin/smtpd/mta.c
1596
struct mta_limits *l = c->relay->limits;
usr.sbin/smtpd/mta.c
1614
TAILQ_FOREACH(mx, &c->relay->domain->mxs, entry) {
usr.sbin/smtpd/mta.c
1638
if (c->relay->backuppref >= 0 &&
usr.sbin/smtpd/mta.c
1639
mx->preference >= c->relay->backuppref)
usr.sbin/smtpd/mta.c
175
struct mta_relay *relay;
usr.sbin/smtpd/mta.c
1782
const char *relay, const char *status)
usr.sbin/smtpd/mta.c
1793
relay,
usr.sbin/smtpd/mta.c
1878
mta_relay_unref(struct mta_relay *relay)
usr.sbin/smtpd/mta.c
1882
if (--relay->refcount)
usr.sbin/smtpd/mta.c
1886
if (relay->state & RELAY_HOLDQ) {
usr.sbin/smtpd/mta.c
1888
m_add_id(p_queue, relay->id);
usr.sbin/smtpd/mta.c
1893
log_debug("debug: mta: freeing %s", mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
1894
SPLAY_REMOVE(mta_relay_tree, &relays, relay);
usr.sbin/smtpd/mta.c
1896
while ((tree_poproot(&relay->connectors, NULL, (void**)&c)))
usr.sbin/smtpd/mta.c
1899
free(relay->authlabel);
usr.sbin/smtpd/mta.c
1900
free(relay->authtable);
usr.sbin/smtpd/mta.c
1901
free(relay->backupname);
usr.sbin/smtpd/mta.c
1902
free(relay->pki_name);
usr.sbin/smtpd/mta.c
1903
free(relay->ca_name);
usr.sbin/smtpd/mta.c
1904
free(relay->helotable);
usr.sbin/smtpd/mta.c
1905
free(relay->heloname);
usr.sbin/smtpd/mta.c
1906
free(relay->secret);
usr.sbin/smtpd/mta.c
1907
free(relay->sourcetable);
usr.sbin/smtpd/mta.c
1909
mta_domain_unref(relay->domain); /* from constructor */
usr.sbin/smtpd/mta.c
1910
free(relay);
usr.sbin/smtpd/mta.c
1915
mta_relay_to_text(struct mta_relay *relay)
usr.sbin/smtpd/mta.c
1921
(void)snprintf(buf, sizeof buf, "[relay:%s", relay->domain->name);
usr.sbin/smtpd/mta.c
1923
if (relay->port) {
usr.sbin/smtpd/mta.c
1925
(void)snprintf(tmp, sizeof tmp, "port=%d", (int)relay->port);
usr.sbin/smtpd/mta.c
1930
switch(relay->tls) {
usr.sbin/smtpd/mta.c
1941
if (relay->flags & RELAY_LMTP)
usr.sbin/smtpd/mta.c
1950
if (relay->flags & RELAY_AUTH) {
usr.sbin/smtpd/mta.c
1953
(void)strlcat(buf, relay->authtable, sizeof buf);
usr.sbin/smtpd/mta.c
1955
(void)strlcat(buf, relay->authlabel, sizeof buf);
usr.sbin/smtpd/mta.c
1958
if (relay->pki_name) {
usr.sbin/smtpd/mta.c
1961
(void)strlcat(buf, relay->pki_name, sizeof buf);
usr.sbin/smtpd/mta.c
1964
if (relay->domain->as_host) {
usr.sbin/smtpd/mta.c
1969
if (relay->backupname) {
usr.sbin/smtpd/mta.c
1972
(void)strlcat(buf, relay->backupname, sizeof buf);
usr.sbin/smtpd/mta.c
1975
if (relay->sourcetable) {
usr.sbin/smtpd/mta.c
1978
(void)strlcat(buf, relay->sourcetable, sizeof buf);
usr.sbin/smtpd/mta.c
1981
if (relay->helotable) {
usr.sbin/smtpd/mta.c
1984
(void)strlcat(buf, relay->helotable, sizeof buf);
usr.sbin/smtpd/mta.c
1987
if (relay->heloname) {
usr.sbin/smtpd/mta.c
1990
(void)strlcat(buf, relay->heloname, sizeof buf);
usr.sbin/smtpd/mta.c
214
relay = tree_xpop(&wait_secret, reqid);
usr.sbin/smtpd/mta.c
215
mta_on_secret(relay, secret[0] ? secret : NULL);
usr.sbin/smtpd/mta.c
226
relay = tree_xpop(&wait_source, reqid);
usr.sbin/smtpd/mta.c
227
mta_on_source(relay, (status == LKA_OK) ?
usr.sbin/smtpd/mta.c
2378
mta_connector(struct mta_relay *relay, struct mta_source *source)
usr.sbin/smtpd/mta.c
2382
c = tree_get(&relay->connectors, (uintptr_t)(source));
usr.sbin/smtpd/mta.c
2385
c->relay = relay;
usr.sbin/smtpd/mta.c
2389
tree_xset(&relay->connectors, (uintptr_t)(source), c);
usr.sbin/smtpd/mta.c
2421
mta_relay_to_text(c->relay),
usr.sbin/smtpd/mta.c
300
relay = tree_xpop(&wait_preference, reqid);
usr.sbin/smtpd/mta.c
304
mta_relay_to_text(relay), dnserror);
usr.sbin/smtpd/mta.c
307
mta_on_preference(relay, preference);
usr.sbin/smtpd/mta.c
360
SPLAY_FOREACH(relay, mta_relay_tree, &relays)
usr.sbin/smtpd/mta.c
361
mta_relay_show(relay, p, imsg->hdr.peerid, t);
usr.sbin/smtpd/mta.c
571
mta_source_error(struct mta_relay *relay, struct mta_route *route, const char *e)
usr.sbin/smtpd/mta.c
578
c = mta_connector(relay, route->src);
usr.sbin/smtpd/mta.c
586
mta_route_error(struct mta_relay *relay, struct mta_route *route)
usr.sbin/smtpd/mta.c
600
mta_route_ok(struct mta_relay *relay, struct mta_route *route)
usr.sbin/smtpd/mta.c
613
c = mta_connector(relay, route->src);
usr.sbin/smtpd/mta.c
618
mta_route_down(struct mta_relay *relay, struct mta_route *route)
usr.sbin/smtpd/mta.c
626
mta_route_collect(struct mta_relay *relay, struct mta_route *route)
usr.sbin/smtpd/mta.c
633
relay->nconn -= 1;
usr.sbin/smtpd/mta.c
634
relay->domain->nconn -= 1;
usr.sbin/smtpd/mta.c
644
c = mta_connector(relay, route->src);
usr.sbin/smtpd/mta.c
648
mta_relay_unref(relay); /* from mta_connect() */
usr.sbin/smtpd/mta.c
652
mta_route_next_task(struct mta_relay *relay, struct mta_route *route)
usr.sbin/smtpd/mta.c
656
if ((task = TAILQ_FIRST(&relay->tasks))) {
usr.sbin/smtpd/mta.c
657
TAILQ_REMOVE(&relay->tasks, task, entry);
usr.sbin/smtpd/mta.c
658
relay->ntask -= 1;
usr.sbin/smtpd/mta.c
659
task->relay = NULL;
usr.sbin/smtpd/mta.c
662
if (relay->ntask == (size_t)relay->limits->task_lowat) {
usr.sbin/smtpd/mta.c
663
if (relay->state & RELAY_ONHOLD) {
usr.sbin/smtpd/mta.c
665
mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
666
relay->state &= ~RELAY_ONHOLD;
usr.sbin/smtpd/mta.c
668
if (relay->state & RELAY_HOLDQ) {
usr.sbin/smtpd/mta.c
670
m_add_id(p_queue, relay->id);
usr.sbin/smtpd/mta.c
671
m_add_int(p_queue, relay->limits->task_release);
usr.sbin/smtpd/mta.c
675
else if (relay->ntask == 0 && relay->state & RELAY_HOLDQ) {
usr.sbin/smtpd/mta.c
677
m_add_id(p_queue, relay->id);
usr.sbin/smtpd/mta.c
689
struct mta_relay *relay;
usr.sbin/smtpd/mta.c
743
relay = mta_relay(evp, &relayh);
usr.sbin/smtpd/mta.c
745
if (relay->limits &&
usr.sbin/smtpd/mta.c
746
relay->ntask >= (size_t)relay->limits->task_hiwat) {
usr.sbin/smtpd/mta.c
747
if (!(relay->state & RELAY_ONHOLD)) {
usr.sbin/smtpd/mta.c
749
mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
750
relay->state |= RELAY_ONHOLD;
usr.sbin/smtpd/mta.c
758
if (relay->state & RELAY_ONHOLD) {
usr.sbin/smtpd/mta.c
759
relay->state |= RELAY_HOLDQ;
usr.sbin/smtpd/mta.c
762
m_add_id(p_queue, relay->id);
usr.sbin/smtpd/mta.c
764
mta_relay_unref(relay); /* from here */
usr.sbin/smtpd/mta.c
769
TAILQ_FOREACH(task, &relay->tasks, entry)
usr.sbin/smtpd/mta.c
776
task->relay = relay;
usr.sbin/smtpd/mta.c
777
relay->ntask += 1;
usr.sbin/smtpd/mta.c
778
TAILQ_INSERT_TAIL(&relay->tasks, task, entry);
usr.sbin/smtpd/mta.c
825
mta_drain(relay);
usr.sbin/smtpd/mta.c
826
mta_relay_unref(relay); /* from here */
usr.sbin/smtpd/mta.c
882
mta_delivery_log(struct mta_envelope *e, const char *source, const char *relay,
usr.sbin/smtpd/mta.c
886
mta_log(e, "Ok", source, relay, status);
usr.sbin/smtpd/mta.c
888
mta_log(e, "TempFail", source, relay, status);
usr.sbin/smtpd/mta.c
890
mta_log(e, "PermFail", source, relay, status);
usr.sbin/smtpd/mta.c
892
mta_log(e, "PermFail", source, relay, "Loop detected");
usr.sbin/smtpd/mta.c
918
mta_query_mx(struct mta_relay *relay)
usr.sbin/smtpd/mta.c
922
if (relay->status & RELAY_WAIT_MX)
usr.sbin/smtpd/mta.c
926
mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
928
if (waitq_wait(&relay->domain->mxs, mta_on_mx, relay)) {
usr.sbin/smtpd/mta.c
930
tree_xset(&wait_mx, id, relay->domain);
usr.sbin/smtpd/mta.c
931
if (relay->domain->as_host)
usr.sbin/smtpd/mta.c
936
m_add_string(p_lka, relay->domain->name);
usr.sbin/smtpd/mta.c
939
relay->status |= RELAY_WAIT_MX;
usr.sbin/smtpd/mta.c
940
mta_relay_ref(relay);
usr.sbin/smtpd/mta.c
944
mta_query_limits(struct mta_relay *relay)
usr.sbin/smtpd/mta.c
946
if (relay->status & RELAY_WAIT_LIMITS)
usr.sbin/smtpd/mta.c
949
relay->limits = dict_get(env->sc_limits_dict, relay->domain->name);
usr.sbin/smtpd/mta.c
950
if (relay->limits == NULL)
usr.sbin/smtpd/mta.c
951
relay->limits = dict_get(env->sc_limits_dict, "default");
usr.sbin/smtpd/mta.c
953
if (max_seen_conndelay_route < relay->limits->conndelay_route)
usr.sbin/smtpd/mta.c
954
max_seen_conndelay_route = relay->limits->conndelay_route;
usr.sbin/smtpd/mta.c
955
if (max_seen_discdelay_route < relay->limits->discdelay_route)
usr.sbin/smtpd/mta.c
956
max_seen_discdelay_route = relay->limits->discdelay_route;
usr.sbin/smtpd/mta.c
960
mta_query_secret(struct mta_relay *relay)
usr.sbin/smtpd/mta.c
962
if (relay->status & RELAY_WAIT_SECRET)
usr.sbin/smtpd/mta.c
966
mta_relay_to_text(relay));
usr.sbin/smtpd/mta.c
968
tree_xset(&wait_secret, relay->id, relay);
usr.sbin/smtpd/mta.c
969
relay->status |= RELAY_WAIT_SECRET;
usr.sbin/smtpd/mta.c
972
m_add_id(p_lka, relay->id);
usr.sbin/smtpd/mta.c
973
m_add_string(p_lka, relay->authtable);
usr.sbin/smtpd/mta.c
974
m_add_string(p_lka, relay->authlabel);
usr.sbin/smtpd/mta.c
977
mta_relay_ref(relay);
usr.sbin/smtpd/mta_session.c
1076
if (s->relay->limits->max_failures_per_session &&
usr.sbin/smtpd/mta_session.c
1077
s->failures == s->relay->limits->max_failures_per_session) {
usr.sbin/smtpd/mta_session.c
1160
if (s->relay->limits->sessdelay_transaction) {
usr.sbin/smtpd/mta_session.c
1162
(long long)s->relay->limits->sessdelay_transaction);
usr.sbin/smtpd/mta_session.c
1163
s->hangon = s->relay->limits->sessdelay_transaction -1;
usr.sbin/smtpd/mta_session.c
1166
s->relay->limits->sessdelay_transaction, s);
usr.sbin/smtpd/mta_session.c
1180
if (s->relay->limits->sessdelay_transaction) {
usr.sbin/smtpd/mta_session.c
1182
(long long)s->relay->limits->sessdelay_transaction);
usr.sbin/smtpd/mta_session.c
1183
s->hangon = s->relay->limits->sessdelay_transaction -1;
usr.sbin/smtpd/mta_session.c
1186
s->relay->limits->sessdelay_transaction, s);
usr.sbin/smtpd/mta_session.c
1230
if (s->relay->dispatcher->u.remote.tls_verify)
usr.sbin/smtpd/mta_session.c
1466
char relay[LINE_MAX];
usr.sbin/smtpd/mta_session.c
1473
(void)snprintf(relay, sizeof relay, "%s", mta_host_to_text(s->route->dst));
usr.sbin/smtpd/mta_session.c
1496
mta_delivery_log(e, NULL, relay, delivery, error);
usr.sbin/smtpd/mta_session.c
1499
relay, delivery, error);
usr.sbin/smtpd/mta_session.c
1559
mta_route_error(s->relay, s->route);
usr.sbin/smtpd/mta_session.c
1579
remote = &s->relay->dispatcher->u.remote;
usr.sbin/smtpd/mta_session.c
1702
m_add_string(p_lka, s->relay->dispatcher->u.remote.filtername);
usr.sbin/smtpd/mta_session.c
192
((s)->relay->dispatcher->u.remote.filtername)
usr.sbin/smtpd/mta_session.c
211
mta_session(struct mta_relay *relay, struct mta_route *route, const char *mxname)
usr.sbin/smtpd/mta_session.c
220
s->relay = relay;
usr.sbin/smtpd/mta_session.c
226
if (relay->flags & RELAY_LMTP)
usr.sbin/smtpd/mta_session.c
228
switch (relay->tls) {
usr.sbin/smtpd/mta_session.c
244
fatalx("bad value for relay->tls: %d", relay->tls);
usr.sbin/smtpd/mta_session.c
248
mta_relay_to_text(relay));
usr.sbin/smtpd/mta_session.c
340
mta_source_error(s->relay, s->route,
usr.sbin/smtpd/mta_session.c
371
struct mta_relay *relay;
usr.sbin/smtpd/mta_session.c
379
s->relay->nconn_ready -= 1;
usr.sbin/smtpd/mta_session.c
397
relay = s->relay;
usr.sbin/smtpd/mta_session.c
403
mta_route_collect(relay, route);
usr.sbin/smtpd/mta_session.c
457
if (s->relay->helotable && s->route->src->sa) {
usr.sbin/smtpd/mta_session.c
460
m_add_string(p_lka, s->relay->helotable);
usr.sbin/smtpd/mta_session.c
467
else if (s->relay->heloname)
usr.sbin/smtpd/mta_session.c
468
s->helo = xstrdup(s->relay->heloname);
usr.sbin/smtpd/mta_session.c
505
if (s->relay->port)
usr.sbin/smtpd/mta_session.c
506
portno = s->relay->port;
usr.sbin/smtpd/mta_session.c
544
mta_source_error(s->relay, s->route, io_error(s->io));
usr.sbin/smtpd/mta_session.c
619
if (s->relay->secret && s->flags & MTA_TLS) {
usr.sbin/smtpd/mta_session.c
637
else if (s->relay->secret) {
usr.sbin/smtpd/mta_session.c
649
if (base64_decode(s->relay->secret, (unsigned char *)ibuf,
usr.sbin/smtpd/mta_session.c
656
mta_send(s, "AUTH PLAIN %s", s->relay->secret);
usr.sbin/smtpd/mta_session.c
665
if (base64_decode(s->relay->secret, (unsigned char *)ibuf,
usr.sbin/smtpd/mta_session.c
683
if (base64_decode(s->relay->secret, (unsigned char *)ibuf,
usr.sbin/smtpd/mta_session.c
703
s->relay->nconn_ready += 1;
usr.sbin/smtpd/mta_session.c
704
mta_route_ok(s->relay, s->route);
usr.sbin/smtpd/mta_session.c
710
mta_route_down(s->relay, s->route);
usr.sbin/smtpd/mta_session.c
715
if (s->msgcount >= s->relay->limits->max_mail_per_session) {
usr.sbin/smtpd/mta_session.c
718
mta_relay_to_text(s->relay));
usr.sbin/smtpd/mta_session.c
733
s->task = mta_route_next_task(s->relay, s->route);
usr.sbin/smtpd/mta_session.c
736
s, mta_relay_to_text(s->relay));
usr.sbin/smtpd/mta_session.c
738
if (s->relay->nconn > 1 ||
usr.sbin/smtpd/mta_session.c
739
s->hangon >= s->relay->limits->sessdelay_keepalive) {
usr.sbin/smtpd/mta_session.c
745
(long long)(s->relay->limits->sessdelay_keepalive -
usr.sbin/smtpd/mta_session.c
753
mta_relay_to_text(s->relay));
usr.sbin/smtpd/mta_session.c
779
s->relay->srs &&
usr.sbin/smtpd/mta_session.c
88
struct mta_relay *relay;
usr.sbin/smtpd/mta_session.c
916
if ((s->relay->flags & RELAY_AUTH) ||
usr.sbin/smtpd/smtpd.h
717
struct mta_relay *relay;
usr.sbin/smtpd/smtpd.h
868
struct mta_relay *relay;
usr.sbin/smtpd/to.c
270
text_to_relayhost(struct relayhost *relay, const char *s)
usr.sbin/smtpd/to.c
317
relay->tls = schemas[i].tls;
usr.sbin/smtpd/to.c
318
relay->flags = schemas[i].flags;
usr.sbin/smtpd/to.c
319
relay->port = schemas[i].port;
usr.sbin/smtpd/to.c
324
if (strlcpy(relay->authlabel, p, sizeof (relay->authlabel))
usr.sbin/smtpd/to.c
325
>= sizeof (relay->authlabel))
usr.sbin/smtpd/to.c
346
if (len >= sizeof relay->hostname)
usr.sbin/smtpd/to.c
349
relay->hostname[i] = beg[i];
usr.sbin/smtpd/to.c
350
relay->hostname[i] = 0;
usr.sbin/smtpd/to.c
355
relay->port = strtonum(p+1, 1, IPPORT_HILASTAUTO, &errstr);
usr.sbin/smtpd/to.c
360
if (!valid_domainpart(relay->hostname))
usr.sbin/smtpd/to.c
362
if ((relay->flags & RELAY_LMTP) && (relay->port == 0))
usr.sbin/smtpd/to.c
364
if (relay->authlabel[0]) {
usr.sbin/smtpd/to.c
366
if (relay->tls != RELAY_TLS_STARTTLS &&
usr.sbin/smtpd/to.c
367
relay->tls != RELAY_TLS_SMTPS)
usr.sbin/smtpd/to.c
369
relay->flags |= RELAY_AUTH;