| /openbsd/usr.sbin/lpd/ |
| H A D | frontend_lpr.c | 110 if ((conn = calloc(1, sizeof(*conn))) == NULL) { in lpr_conn()
117 conn->ifd = -1; in lpr_conn()
121 free(conn); in lpr_conn()
127 io_set_callback(conn->io, lpr_io_dispatch, conn); in lpr_conn()
196 strlcpy(conn->hostname, hostname, sizeof(conn->hostname)); in lpr_on_allowedhost()
338 if (conn->recvcf && conn->state == STATE_READ_COMMAND) { in lpr_io_dispatch()
611 free(conn); in lpr_free()
631 if (conn->ai) in lpr_close()
714 if (!conn->ai_done || conn->ifd == -1) in lpr_forward()
732 io_set_callback(conn->iofwd, lpr_iofwd_dispatch, conn); in lpr_forward()
[all …]
|
| H A D | frontend.c | 42 struct conn { struct
48 static int conn_cmp(struct conn *, struct conn *); argument
57 conn_cmp(struct conn *a, struct conn *b) in conn_cmp()
119 struct conn key, *conn; in frontend_conn_closed() local
123 if (conn == NULL) in frontend_conn_closed()
133 free(conn); in frontend_conn_closed()
197 struct conn *conn; in frontend_accept() local
206 conn = calloc(1, sizeof(*conn)); in frontend_accept()
207 if (conn == NULL) in frontend_accept()
219 free(conn); in frontend_accept()
[all …]
|
| /openbsd/sbin/isakmpd/ |
| H A D | connection.c | 101 conn = TAILQ_NEXT(conn, link)) { in connection_init()
134 conn = TAILQ_NEXT(conn, link)) in connection_init()
174 for (conn = TAILQ_FIRST(&connections); conn; in connection_lookup()
175 conn = TAILQ_NEXT(conn, link)) in connection_lookup()
195 conn = TAILQ_NEXT(conn, link)) in connection_passive_lookup_by_name()
224 conn = TAILQ_NEXT(conn, link)) { in connection_passive_lookup_by_ids()
248 conn = TAILQ_NEXT(conn, link)) { in connection_passive_lookup_by_ids()
282 conn = calloc(1, sizeof *conn); in connection_setup()
332 conn = calloc(1, sizeof *conn); in connection_record_passive()
413 conn = TAILQ_NEXT(conn, link)) in connection_report()
[all …]
|
| /openbsd/usr.sbin/rpki-client/ |
| H A D | http.c | 796 memmove(conn->buf, conn->buf + bsz, conn->bufpos); in http_inflate_advance()
854 if (http_resolv(&conn->res0, conn->host, conn->port) == -1) { in http_new()
1017 conn->res = conn->res0; in http_connect()
1020 for (; conn->res != NULL; conn->res = conn->res->ai_next) { in http_connect()
1529 s = tls_read(conn->tls, conn->buf + conn->bufpos, in http_read()
1640 conn->bufpos -= conn->iosz; in http_read()
1643 conn->iosz -= conn->bufpos; in http_read()
1718 s = tls_write(conn->tls, conn->buf + conn->bufpos, in http_write()
1753 s = read(conn->fd, conn->buf + conn->bufpos, in proxy_read()
1814 s = write(conn->fd, conn->buf + conn->bufpos, in proxy_write()
[all …]
|
| /openbsd/usr.sbin/ldapd/ |
| H A D | conn.c | 50 conn_close(struct conn *conn) in conn_close() argument
91 conn_disconnect(struct conn *conn) in conn_disconnect() argument
141 conn_dispatch(struct conn *conn) in conn_dispatch() argument
155 req->conn = conn; in conn_dispatch()
195 struct conn *conn = data; in conn_read() local
216 struct conn *conn = data; in conn_write() local
238 struct conn *conn = data; in conn_err() local
256 struct conn *conn; in conn_accept() local
339 struct conn *conn; in conn_by_fd() local
351 struct conn *conn; in conn_close_any() local
[all …]
|
| H A D | auth.c | 35 aci_matches(struct aci *aci, struct conn *conn, struct namespace *ns, in aci_matches() argument
92 if (conn->binddn == NULL) in aci_matches()
114 authorized(struct conn *conn, struct namespace *ns, int rights, char *dn, in authorized() argument
139 conn->binddn ? conn->binddn : "any", in authorized()
289 free(req->conn->binddn); in ldap_auth_sasl()
290 req->conn->binddn = NULL; in ldap_auth_sasl()
361 free(req->conn->binddn); in ldap_auth_simple()
368 req->conn->binddn); in ldap_auth_simple()
381 ldap_bind_continue(struct conn *conn, int ok) in ldap_bind_continue() argument
387 conn->binddn = conn->pending_binddn; in ldap_bind_continue()
[all …]
|
| H A D | ldapd.h | 59 struct conn;
89 struct conn *conn; member
180 struct conn *conn; member
215 struct conn { struct
346 void conn_close(struct conn *conn);
348 void conn_disconnect(struct conn *conn);
359 void send_ldap_result(struct conn *conn, int msgid,
399 void namespace_cancel_conn(struct conn *conn);
400 int namespace_conn_queue_count(struct conn *conn);
452 void ldap_bind_continue(struct conn *conn, int ok);
[all …]
|
| H A D | ldape.c | 44 void send_ldap_extended_response(struct conn *conn,
72 send_ldap_extended_response(struct conn *conn, int msgid, unsigned int type, in send_ldap_extended_response() argument
101 ober_get_writebuf(&conn->ber, &buf); in send_ldap_extended_response()
192 send_ldap_result(struct conn *conn, int msgid, unsigned int type, in send_ldap_result() argument
233 req->conn->binddn == NULL ? "" : req->conn->binddn); in ldap_unbind()
234 conn_disconnect(req->conn); in ldap_unbind()
292 req->conn->s_flags |= F_STARTTLS; in ldap_starttls()
527 struct conn *conn; in ldape_auth_result() local
532 conn = conn_by_fd(ares->fd); in ldape_auth_result()
533 if (conn->bind_req != NULL && conn->bind_req->msgid == ares->msgid) in ldape_auth_result()
[all …]
|
| H A D | search.c | 101 struct conn *conn = search->conn; in search_result() local
149 "sending search entry on fd %d", conn->fd); in search_result()
151 rc = ober_write_elements(&conn->ber, root); in search_result()
159 ober_get_writebuf(&conn->ber, &buf); in search_result()
300 struct conn *conn; in conn_search() local
304 conn = search->conn; in conn_search()
457 search->conn->fd, search->req->msgid, in conn_search()
469 search->conn->fd, search->req->msgid, in conn_search()
481 send_ldap_result(conn, search->req->msgid, in conn_search()
867 search->conn = req->conn; in ldap_search()
[all …]
|
| H A D | namespace.c | 212 struct conn *conn; in namespace_close() local
229 TAILQ_FOREACH(conn, &conn_list, next) { in namespace_close()
230 for (search = TAILQ_FIRST(&conn->searches); search != NULL; in namespace_close()
527 namespace_cancel_conn(struct conn *conn) in namespace_cancel_conn() argument
537 if (req->conn == conn) { in namespace_cancel_conn()
546 namespace_conn_queue_count(struct conn *conn) in namespace_conn_queue_count() argument
554 if (req->conn == conn) in namespace_conn_queue_count()
|
| H A D | modify.c | 58 if (!authorized(req->conn, ns, ACI_WRITE, dn, NULL, LDAP_SCOPE_BASE)) in ldap_delete()
106 !authorized(req->conn, ns, ACI_WRITE, dn, s, in ldap_delete()
154 if (!authorized(req->conn, ns, ACI_WRITE, dn, NULL, LDAP_SCOPE_BASE)) in ldap_add()
163 if (!authorized(req->conn, ns, ACI_WRITE, dn, s, in ldap_add()
195 if (ober_add_string(set, req->conn->binddn ? req->conn->binddn : "") == NULL) in ldap_add()
271 if (!authorized(req->conn, ns, ACI_WRITE, dn, attr, in ldap_modify()
368 ober_add_string(set, req->conn->binddn ? req->conn->binddn : ""); in ldap_modify()
|
| /openbsd/usr.bin/ssh/ |
| H A D | sftp-client.c | 160 conn->limit_kbps > 0 ? &conn->bwlimit_out : NULL) != in send_msg()
178 conn->limit_kbps > 0 ? &conn->bwlimit_in : NULL) != 4) { in get_msg_extended()
197 conn->limit_kbps > 0 ? &conn->bwlimit_in : NULL) in get_msg_extended()
225 send_msg(conn, msg); in send_string_request()
244 send_msg(conn, msg); in send_string_attrs_request()
260 get_msg(conn, msg); in get_status()
299 get_msg(conn, msg); in get_handle()
338 get_msg(conn, msg); in get_decode_stat()
388 get_msg(conn, msg); in get_decode_statvfs()
624 get_msg(conn, msg); in sftp_get_limits()
[all …]
|
| H A D | sftp-glob.c | 41 struct sftp_conn *conn; member
51 if (sftp_readdir(cur.conn, path, &r->dir)) { in fudge_opendir()
88 if (sftp_lstat(cur.conn, path, 1, &a) != 0) in fudge_lstat()
101 if (sftp_stat(cur.conn, path, 1, &a) != 0) in fudge_stat()
110 sftp_glob(struct sftp_conn *conn, const char *pattern, int flags, in sftp_glob() argument
125 cur.conn = conn; in sftp_glob()
|
| H A D | sftp.c | 90 struct sftp_conn *conn; member
955 if ((r = sftp_glob(conn, path, in do_globbed_ls()
1577 err = sftp_copy(conn, path1, path2); in parse_dispatch_command()
1600 err = sftp_rm(conn, g.gl_pathv[i]); in parse_dispatch_command()
1614 err = sftp_rmdir(conn, path1); in parse_dispatch_command()
2208 complete_ctx.conn = conn; in interactive_loop()
2238 free(conn); in interactive_loop()
2252 free(conn); in interactive_loop()
2317 free(conn); in interactive_loop()
2402 struct sftp_conn *conn; in main() local
[all …]
|
| H A D | sftp-usergroup.c | 101 lookup_and_record(struct sftp_conn *conn, in lookup_and_record() argument
108 if ((r = sftp_get_users_groups_by_id(conn, uids, nuids, gids, ngids, in lookup_and_record()
174 get_remote_user_groups_from_glob(struct sftp_conn *conn, glob_t *g) in get_remote_user_groups_from_glob() argument
178 if (!sftp_can_get_users_groups_by_id(conn)) in get_remote_user_groups_from_glob()
183 lookup_and_record(conn, uids, nuids, gids, ngids); in get_remote_user_groups_from_glob()
213 get_remote_user_groups_from_dirents(struct sftp_conn *conn, SFTP_DIRENT **d) in get_remote_user_groups_from_dirents() argument
217 if (!sftp_can_get_users_groups_by_id(conn)) in get_remote_user_groups_from_dirents()
222 lookup_and_record(conn, uids, nuids, gids, ngids); in get_remote_user_groups_from_dirents()
|
| H A D | sftp-client.h | 105 int sftp_lsetstat(struct sftp_conn *conn, const char *path, Attrib *a);
132 int sftp_fsync(struct sftp_conn *conn, u_char *, u_int);
182 int sftp_can_get_users_groups_by_id(struct sftp_conn *conn);
183 int sftp_get_users_groups_by_id(struct sftp_conn *conn,
196 int sftp_remote_is_dir(struct sftp_conn *conn, const char *path);
|
| /openbsd/usr.sbin/snmpd/ |
| H A D | application_agentx.c | 202 if ((conn = malloc(sizeof(*conn))) == NULL) { in appl_agentx_accept()
207 conn->conn_backend = 0; in appl_agentx_accept()
222 event_set(&(conn->conn_wev), fd, EV_WRITE, appl_agentx_send, conn); in appl_agentx_accept()
228 free(conn); in appl_agentx_accept()
236 if ((conn = malloc(sizeof(*conn))) == NULL) in appl_agentx_backend()
252 event_set(&(conn->conn_wev), fd, EV_WRITE, appl_agentx_send, conn); in appl_agentx_backend()
278 conn->conn_id); in appl_agentx_free()
279 free(conn); in appl_agentx_free()
500 conn->conn_id); in appl_agentx_open()
534 conn->conn_id); in appl_agentx_open()
[all …]
|
| /openbsd/usr.sbin/vmd/ |
| H A D | vm_agentx.c | 33 struct conn { struct
263 static struct conn *conn; in vm_agentx_configure() local
280 conn = NULL; in vm_agentx_configure()
291 conn = NULL; in vm_agentx_configure()
297 if ((conn = malloc(sizeof(*conn))) == NULL) in vm_agentx_configure()
300 evtimer_set(&conn->ev, vm_agentx_tryconnect, conn); in vm_agentx_configure()
373 struct conn *conn = cookie; in vm_agentx_nofd() local
378 free(conn); in vm_agentx_nofd()
388 struct conn *conn = cookie; in vm_agentx_tryconnect() local
408 evtimer_set(&conn->ev, vm_agentx_tryconnect, conn); in vm_agentx_tryconnect()
[all …]
|
| /openbsd/regress/sbin/pfctl/ |
| H A D | pf89.in | 12 keep state (max-src-conn 10, max-src-conn-rate 3/99)
15 (max-src-conn 10)
18 (max-src-conn-rate 3/99)
21 (max-src-conn 100, max-src-conn-rate 10/5, overload <bad> flush)
24 (max-src-conn 1000, max-src-conn-rate 1000/5, overload <bad> \
|
| H A D | pf89.ok | 7 …0.0.1 port = 22 flags S/SA keep state (source-track rule, max-src-conn 10, max-src-conn-rate 3/99,…
8 …proto tcp from any to 10.0.0.2 port = 22 flags S/SA keep state (source-track rule, max-src-conn 10)
9 …y to 10.0.0.3 port = 22 flags S/SA keep state (source-track rule, max-src-conn-rate 3/99, src.trac…
10 … port = 80 flags S/SA modulate state (source-track rule, max-src-conn 100, max-src-conn-rate 10/5,…
11 …ort = 8080 flags S/SA synproxy state (source-track rule, max-src-conn 1000, max-src-conn-rate 1000…
|
| H A D | pf89.loaded | 21 …0.0.1 port = 22 flags S/SA keep state (source-track rule, max-src-conn 10, max-src-conn-rate 3/99,…
25 …proto tcp from any to 10.0.0.2 port = 22 flags S/SA keep state (source-track rule, max-src-conn 10)
29 …y to 10.0.0.3 port = 22 flags S/SA keep state (source-track rule, max-src-conn-rate 3/99, src.trac…
33 … port = 80 flags S/SA modulate state (source-track rule, max-src-conn 100, max-src-conn-rate 10/5,…
37 …ort = 8080 flags S/SA synproxy state (source-track rule, max-src-conn 1000, max-src-conn-rate 1000…
|
| H A D | pf89.optimized | 21 …0.0.1 port = 22 flags S/SA keep state (source-track rule, max-src-conn 10, max-src-conn-rate 3/99,…
25 …proto tcp from any to 10.0.0.2 port = 22 flags S/SA keep state (source-track rule, max-src-conn 10)
29 …y to 10.0.0.3 port = 22 flags S/SA keep state (source-track rule, max-src-conn-rate 3/99, src.trac…
33 … port = 80 flags S/SA modulate state (source-track rule, max-src-conn 100, max-src-conn-rate 10/5,…
37 …ort = 8080 flags S/SA synproxy state (source-track rule, max-src-conn 1000, max-src-conn-rate 1000…
|
| /openbsd/gnu/usr.bin/gcc/gcc/testsuite/gcc.c-torture/execute/ |
| H A D | 20021111-1.c | 6 int aim_callhandler(int sess, int conn, unsigned short family, unsigned short type);
8 int aim_callhandler(int sess, int conn, unsigned short family, unsigned short type) in aim_callhandler() argument
12 if (!conn) in aim_callhandler()
24 return aim_callhandler(sess, conn, family, (unsigned short) 0xffff); in aim_callhandler()
|
| /openbsd/sys/dev/pci/drm/amd/display/modules/hdcp/ |
| H A D | hdcp1_transition.c | 34 struct mod_hdcp_connection *conn = &hdcp->connection; in mod_hdcp_hdcp1_transition() local
81 } else if (!conn->is_repeater && input->encryption != PASS) { in mod_hdcp_hdcp1_transition()
85 if (conn->is_repeater) { in mod_hdcp_hdcp1_transition()
157 struct mod_hdcp_connection *conn = &hdcp->connection; in mod_hdcp_hdcp1_dp_transition() local
229 } else if ((!conn->is_repeater && input->encryption != PASS) || in mod_hdcp_hdcp1_dp_transition()
230 (!conn->is_repeater && is_dp_mst_hdcp(hdcp) && input->stream_encryption_dp != PASS)) { in mod_hdcp_hdcp1_dp_transition()
233 } else if (conn->hdcp1_retry_count < conn->link.adjust.hdcp1.min_auth_retries_wa) { in mod_hdcp_hdcp1_dp_transition()
237 if (conn->is_repeater) { in mod_hdcp_hdcp1_dp_transition()
|
| /openbsd/usr.sbin/smtpd/ |
| H A D | mail.lmtp.c | 57 int conn; in main() local
110 conn = lmtp_connect(destination); in main()
111 lmtp_engine(conn, &session); in main()
314 stream_file(FILE *conn) in stream_file() argument
322 fprintf(conn, "."); in stream_file()
323 fprintf(conn, "%s\r\n", line); in stream_file()
|