Searched refs:peer (Results 1 - 25 of 130) sorted by relevance

123456

/openbsd-current/usr.sbin/bgpd/
H A Drde_peer.c42 peer_has_as4byte(struct rde_peer *peer) argument
44 return (peer->capa.as4byte);
52 peer_has_add_path(struct rde_peer *peer, uint8_t aid, int mode) argument
56 return (peer->capa.add_path[aid] & mode);
60 peer_accept_no_as_set(struct rde_peer *peer) argument
62 return (peer->flags & PEERFLAG_NO_AS_SET);
88 * Traverse all peers calling callback for each peer.
93 struct rde_peer *peer, *np; local
95 RB_FOREACH_SAFE(peer, peer_tree, &peertable, np)
96 callback(peer, ar
119 struct rde_peer *peer; local
138 struct rde_peer *peer; local
188 peer_apply_out_filter(struct rde_peer *peer, struct filter_head *rules) argument
226 peer_generate_update(struct rde_peer *peer, struct rib_entry *re, struct prefix *newpath, struct prefix *oldpath, enum eval_mode mode) argument
273 struct rde_peer *peer; local
305 struct rde_peer *peer; member in struct:peer_flush
312 struct rde_peer *peer = ((struct peer_flush *)arg)->peer; local
370 struct rde_peer *peer = ptr; local
381 struct rde_peer *peer = ptr; local
394 struct rde_peer *peer = ptr; local
406 peer_up(struct rde_peer *peer, struct session_up *sup) argument
455 peer_down(struct rde_peer *peer, void *bula) argument
488 peer_flush(struct rde_peer *peer, uint8_t aid, time_t staletime) argument
513 peer_stale(struct rde_peer *peer, uint8_t aid, int flushall) argument
551 peer_dump(struct rde_peer *peer, uint8_t aid) argument
581 peer_begin_rrefresh(struct rde_peer *peer, uint8_t aid) argument
610 peer_imsg_push(struct rde_peer *peer, struct imsg *imsg) argument
626 peer_imsg_pop(struct rde_peer *peer, struct imsg *imsg) argument
656 peer_imsg_flush(struct rde_peer *peer) argument
[all...]
H A Dlogmsg.c32 log_fmt_peer(const struct peer_config *peer) argument
37 ip = log_addr(&peer->remote_addr);
38 if ((peer->remote_addr.aid == AID_INET && peer->remote_masklen != 32) ||
39 (peer->remote_addr.aid == AID_INET6 &&
40 peer->remote_masklen != 128)) {
41 if (asprintf(&p, "%s/%u", ip, peer->remote_masklen) == -1)
48 if (peer->descr[0]) {
49 if (asprintf(&pfmt, "neighbor %s (%s)", p, peer->descr) ==
61 log_peer_info(const struct peer_config *peer, cons argument
77 log_peer_warn(const struct peer_config *peer, const char *emsg, ...) argument
98 log_peer_warnx(const struct peer_config *peer, const char *emsg, ...) argument
114 log_statechange(struct peer *peer, enum session_state nstate, enum session_events event) argument
135 log_notification(const struct peer *peer, uint8_t errcode, uint8_t subcode, const struct ibuf *data, const char *dir) argument
248 log_conn_attempt(const struct peer *peer, struct sockaddr *sa, socklen_t len) argument
[all...]
H A Dsession.c59 void init_peer(struct peer *);
60 void start_timer_holdtime(struct peer *);
61 void start_timer_sendholdtime(struct peer *);
62 void start_timer_keepalive(struct peer *);
63 void session_close_connection(struct peer *);
64 void change_state(struct peer *, enum session_state, enum session_events);
65 int session_setup_socket(struct peer *);
67 int session_connect(struct peer *);
68 void session_tcp_established(struct peer *);
73 int session_sendmsg(struct bgp_msg *, struct peer *);
594 bgp_fsm(struct peer *peer, enum session_events event) argument
829 start_timer_holdtime(struct peer *peer) argument
838 start_timer_sendholdtime(struct peer *peer) argument
852 start_timer_keepalive(struct peer *peer) argument
861 session_close_connection(struct peer *peer) argument
871 change_state(struct peer *peer, enum session_state state, enum session_events event) argument
1064 session_connect(struct peer *peer) argument
1319 session_tcp_established(struct peer *peer) argument
2064 parse_header(struct peer *peer, u_char *data, uint16_t *len, uint8_t *type) argument
2157 parse_open(struct peer *peer) argument
2352 parse_update(struct peer *peer) argument
2378 parse_rrefresh(struct peer *peer) argument
2473 parse_notification(struct peer *peer) argument
2525 parse_capabilities(struct peer *peer, struct ibuf *buf, uint32_t *as) argument
3490 session_down(struct peer *peer) argument
3595 session_stop(struct peer *peer, uint8_t subcode, const char *reason) argument
[all...]
H A Drde_update.c57 up_test_update(struct rde_peer *peer, struct prefix *p) argument
72 if (peer == frompeer)
76 if (!frompeer->conf.ebgp && !peer->conf.ebgp) {
86 peer->conf.reflector_client == 0 &&
95 if (peer->conf.ebgp) {
107 up_enforce_open_policy(struct rde_peer *peer, struct filterstate *state, argument
116 * local role is peer, customer or rs-client.
118 if (peer->role == ROLE_PEER || peer->role == ROLE_CUSTOMER ||
119 peer
153 up_process_prefix(struct rde_peer *peer, struct prefix *new, struct prefix *p) argument
210 up_generate_updates(struct rde_peer *peer, struct rib_entry *re) argument
248 up_generate_addpath(struct rde_peer *peer, struct rib_entry *re) argument
335 up_generate_addpath_all(struct rde_peer *peer, struct rib_entry *re, struct prefix *new, struct prefix *old) argument
399 up_generate_default(struct rde_peer *peer, uint8_t aid) argument
455 up_get_nexthop(struct rde_peer *peer, struct filterstate *state, uint8_t aid) argument
541 up_prep_adjout(struct rde_peer *peer, struct filterstate *state, uint8_t aid) argument
568 up_generate_attr(struct ibuf *buf, struct rde_peer *peer, struct rde_aspath *asp, struct rde_community *comm, struct nexthop *nh, uint8_t aid) argument
792 up_is_eor(struct rde_peer *peer, uint8_t aid) argument
814 up_prefix_free(struct prefix_tree *prefix_head, struct prefix *p, struct rde_peer *peer, int withdraw) argument
836 up_dump_prefix(struct ibuf *buf, struct prefix_tree *prefix_head, struct rde_peer *peer, int withdraw) argument
868 up_generate_mp_reach(struct ibuf *buf, struct rde_peer *peer, struct nexthop *nh, uint8_t aid) argument
987 up_dump_withdraws(struct ibuf *buf, struct rde_peer *peer, uint8_t aid) argument
1050 up_dump_update(struct ibuf *buf, struct rde_peer *peer, uint8_t aid) argument
[all...]
H A Dsession.h190 struct peer { struct
193 RB_ENTRY(peer) entry;
196 struct capabilities peer; member in struct:peer::__anon46
212 struct peer *template;
262 void log_statechange(struct peer *, enum session_state,
264 void log_notification(const struct peer *, uint8_t, uint8_t,
266 void log_conn_attempt(const struct peer *, struct sockaddr *,
271 struct peer *, enum msg_type);
273 struct peer *);
279 int pfkey_establish(struct peer *);
[all...]
H A Dmrt.c45 static int mrt_dump_hdr_se(struct ibuf **, struct peer *, uint16_t,
140 struct peer *peer, enum msg_type msgtype, int in)
145 if (peer->capa.neg.as4byte)
160 if (peer->capa.neg.add_path[0] & mask) {
163 (peer->capa.neg.add_path[aid] & mask)) {
164 if (peer->capa.neg.as4byte)
176 struct peer *peer, enum msg_type msgtype)
186 subtype = mrt_bgp_msg_subtype(mrt, pkg, pkglen, peer, msgtyp
139 mrt_bgp_msg_subtype(struct mrt *mrt, void *pkg, uint16_t pkglen, struct peer *peer, enum msg_type msgtype, int in) argument
175 mrt_dump_bgp_msg(struct mrt *mrt, void *pkg, uint16_t pkglen, struct peer *peer, enum msg_type msgtype) argument
204 mrt_dump_state(struct mrt *mrt, uint16_t old_state, uint16_t new_state, struct peer *peer) argument
364 mrt_dump_entry_mp(struct mrt *mrt, struct prefix *p, uint16_t snum, struct rde_peer *peer) argument
533 mrt_dump_entry(struct mrt *mrt, struct prefix *p, uint16_t snum, struct rde_peer *peer) argument
800 mrt_dump_v2_hdr_peer(struct rde_peer *peer, void *arg) argument
866 mrt_dump_peer(struct ibuf *buf, struct rde_peer *peer) argument
946 mrt_dump_hdr_se(struct ibuf ** bp, struct peer *peer, uint16_t type, uint16_t subtype, uint32_t len, int swap) argument
[all...]
H A Drde_filter.c35 rde_apply_set(struct filter_set_head *sh, struct rde_peer *peer, argument
109 prep_as = peer->conf.local_as;
149 &set->action.community, peer);
153 &set->action.community, peer);
213 rde_filter_match(struct filter_rule *f, struct rde_peer *peer, argument
220 if (f->peer.ebgp && !peer->conf.ebgp)
222 if (f->peer.ibgp && peer->conf.ebgp)
237 peer
323 rde_filter_skip_rule(struct rde_peer *peer, struct filter_rule *f) argument
826 rde_filter(struct filter_head *rules, struct rde_peer *peer, struct rde_peer *from, struct bgpd_addr *prefix, uint8_t plen, struct filterstate *state) argument
[all...]
H A Drde_community.c30 apply_flag(uint32_t in, uint8_t flag, struct rde_peer *peer, uint32_t *out, argument
41 if (peer == NULL)
43 *out = peer->conf.remote_as;
46 if (peer == NULL)
48 *out = peer->conf.local_as;
60 fc2c(struct community *fc, struct rde_peer *peer, struct community *c, argument
74 if (apply_flag(fc->data1, fc->flags >> 8, peer,
77 if (apply_flag(fc->data2, fc->flags >> 16, peer,
86 if (apply_flag(fc->data1, fc->flags >> 8, peer,
89 if (apply_flag(fc->data2, fc->flags >> 16, peer,
270 community_match(struct rde_community *comm, struct community *fc, struct rde_peer *peer) argument
337 community_set(struct rde_community *comm, struct community *fc, struct rde_peer *peer) argument
376 community_delete(struct rde_community *comm, struct community *fc, struct rde_peer *peer) argument
[all...]
/openbsd-current/regress/usr.sbin/bgpd/unittests/
H A Drde_community_test.h1 struct rde_peer peer = { variable in typeref:struct:rde_peer
596 struct rde_peer *peer; member in struct:testfilter
738 .peer = &peer,
745 .peer = &peer,
751 .peer = &peer_l4,
757 .peer = &peer_r4,
763 .peer = &peer_b4,
769 .peer
[all...]
H A Drde_decide_test.c106 .p = { .entry.list.re = &dummy_re, .aspath = &asp[0], .peer = &peer1, .nhflags = NEXTHOP_VALID, .lastchange = T1, } },
109 .p = { .entry.list.re = &dummy_re, .aspath = &asp[1], .peer = &peer1, .nhflags = NEXTHOP_VALID, .lastchange = T1, } },
112 .p = { .entry.list.re = &dummy_re, .aspath = &asp[2], .peer = &peer1, .nhflags = NEXTHOP_VALID, .lastchange = T1, } },
115 .p = { .entry.list.re = &dummy_re, .aspath = &asp[0], .peer = &peer1, .nhflags = 0, .lastchange = T1, } },
118 .p = { .entry.list.re = &dummy_re, .aspath = &asp[3], .peer = &peer1, .nhflags = NEXTHOP_VALID, .lastchange = T1, } },
121 .p = { .entry.list.re = &dummy_re, .aspath = &asp[4], .peer = &peer1, .nhflags = NEXTHOP_VALID, .lastchange = T1, } },
124 .p = { .entry.list.re = &dummy_re, .aspath = &asp[5], .peer = &peer1, .nhflags = NEXTHOP_VALID, .lastchange = T1, } },
126 .p = { .entry.list.re = &dummy_re, .aspath = &asp[6], .peer = &peer1, .nhflags = NEXTHOP_VALID, .lastchange = T1, } },
129 .p = { .entry.list.re = &dummy_re, .aspath = &asp[7], .peer = &peer1, .nhflags = NEXTHOP_VALID, .lastchange = T1, } },
132 .p = { .entry.list.re = &dummy_re, .aspath = &asp[0], .peer
[all...]
/openbsd-current/usr.bin/tmux/
H A Dproc.c75 struct tmuxpeer *peer = arg; local
79 if (!(peer->flags & PEER_BAD) && (events & EV_READ)) {
80 if (((n = imsg_read(&peer->ibuf)) == -1 && errno != EAGAIN) ||
82 peer->dispatchcb(NULL, peer->arg);
86 if ((n = imsg_get(&peer->ibuf, &imsg)) == -1) {
87 peer->dispatchcb(NULL, peer->arg);
92 log_debug("peer %p message %d", peer, ims
131 peer_check_version(struct tmuxpeer *peer, struct imsg *imsg) argument
148 proc_update_event(struct tmuxpeer *peer) argument
163 proc_send(struct tmuxpeer *peer, enum msgtype type, int fd, const void *buf, size_t len) argument
218 struct tmuxpeer *peer; local
300 struct tmuxpeer *peer; local
323 proc_remove_peer(struct tmuxpeer *peer) argument
336 proc_kill_peer(struct tmuxpeer *peer) argument
342 proc_flush_peer(struct tmuxpeer *peer) argument
378 proc_get_peer_uid(struct tmuxpeer *peer) argument
[all...]
/openbsd-current/sys/net/
H A Dif_wg.c391 struct wg_peer *peer; local
399 if ((peer = pool_get(&wg_peer_pool, PR_NOWAIT)) == NULL)
402 peer->p_id = peer_counter++;
403 peer->p_sc = sc;
405 noise_remote_init(&peer->p_remote, public, &sc->sc_local);
406 cookie_maker_init(&peer->p_cookie, public);
407 wg_timers_init(&peer->p_timers);
409 mtx_init(&peer->p_counters_mtx, IPL_NET);
410 peer->p_counters_tx = 0;
411 peer
459 struct wg_peer *peer; local
478 wg_peer_destroy(struct wg_peer *peer) argument
539 wg_peer_set_endpoint_from_tag(struct wg_peer *peer, struct wg_tag *t) argument
551 wg_peer_set_sockaddr(struct wg_peer *peer, struct sockaddr *remote) argument
561 wg_peer_get_sockaddr(struct wg_peer *peer, struct sockaddr *remote) argument
576 wg_peer_clear_src(struct wg_peer *peer) argument
584 wg_peer_get_endpoint(struct wg_peer *peer, struct wg_endpoint *endpoint) argument
592 wg_peer_counters_add(struct wg_peer *peer, uint64_t tx, uint64_t rx) argument
601 wg_aip_add(struct wg_softc *sc, struct wg_peer *peer, struct wg_aip_io *d) argument
653 wg_aip_remove(struct wg_softc *sc, struct wg_peer *peer, struct wg_aip_io *d) argument
1131 struct wg_peer *peer = CONTAINER_OF(t, struct wg_peer, p_timers); local
1142 struct wg_peer *peer = CONTAINER_OF(t, struct wg_peer, p_timers); local
1173 struct wg_peer *peer = CONTAINER_OF(t, struct wg_peer, p_timers); local
1186 struct wg_peer *peer = CONTAINER_OF(t, struct wg_peer, p_timers); local
1200 struct wg_peer *peer = CONTAINER_OF(t, struct wg_peer, p_timers); local
1210 struct wg_peer *peer = CONTAINER_OF(t, struct wg_peer, p_timers); local
1217 wg_peer_send_buf(struct wg_peer *peer, uint8_t *buf, size_t len) argument
1231 struct wg_peer *peer = _peer; local
1251 wg_send_response(struct wg_peer *peer) argument
1291 struct wg_peer *peer = _peer; local
1328 struct wg_peer *peer = _peer; local
1339 struct wg_peer *peer; local
1502 struct wg_peer *peer; local
1587 struct wg_peer *peer, *allowed_peer; local
1720 struct wg_peer *peer = _peer; local
1759 struct wg_peer *peer = _peer; local
1807 wg_queue_in(struct wg_softc *sc, struct wg_peer *peer, struct mbuf *m) argument
1839 wg_queue_out(struct wg_softc *sc, struct wg_peer *peer) argument
1922 struct wg_peer *peer; local
1932 struct wg_peer *peer; local
1987 struct wg_peer *peer = NULL; local
2095 struct wg_peer *peer; local
2132 struct wg_peer *peer; local
2219 struct wg_peer *peer, *tpeer; local
2382 struct wg_peer *peer; local
2526 struct wg_peer *peer; local
2565 struct wg_peer *peer; local
2725 struct wg_peer *peer, *tpeer; local
[all...]
/openbsd-current/regress/usr.sbin/syslogd/
H A Dargs-selector-syslog.pl16 [qw{ start .*accepted .*close .*accepted .*peer exiting.* }],
18 [qw{ start .*accepted .*close .*accepted .*peer exiting.* }],
19 "syslog.info" => [qw{ start .*peer exiting.* }],
20 "syslog.notice" => [qw{ .*peer exiting.* }],
/openbsd-current/lib/libcrypto/bio/
H A Dbss_dgram.c108 } peer; member in struct:bio_dgram_data_st
264 } peer; member in struct:__anon38
267 sa.len = sizeof(sa.peer);
271 memset(&sa.peer, 0, sizeof(sa.peer));
273 ret = recvfrom(b->num, out, outl, 0, &sa.peer.sa, &sa.len);
276 BIO_ctrl(b, BIO_CTRL_DGRAM_SET_PEER, 0, &sa.peer);
301 int peerlen = sizeof(data->peer);
303 if (data->peer.sa.sa_family == AF_INET)
304 peerlen = sizeof(data->peer
[all...]
H A Dbss_bio.c57 * of this kind, handled by the same thread (i.e. the "peer" is actually
118 BIO *peer; /* NULL if buf == NULL. member in struct:bio_bio_st
119 * If peer != NULL, then peer->ptr is also a bio_bio_st,
120 * and its "peer" member points back to us.
121 * peer != NULL iff init != 0 in the BIO. */
123 /* This is for what we write (i.e. reading uses peer's struct): */
124 int closed; /* valid iff peer != NULL */
125 size_t len; /* valid iff buf != NULL; 0 if peer == NULL */
130 size_t request; /* valid iff peer !
[all...]
/openbsd-current/lib/libc/yp/
H A Dxdr_ypresp_master.c39 return xdr_peername(xdrs, (peername *)&objp->peer);
/openbsd-current/usr.bin/openssl/
H A Ds_cb.c804 } peer; local
811 /* Read peer information */
812 (void) BIO_dgram_get_peer(SSL_get_rbio(ssl), &peer); local
814 /* Create buffer with peer's address and port */
816 switch (peer.sa.sa_family) {
819 length += sizeof(peer.s4.sin_port);
823 length += sizeof(peer.s6.sin6_port);
835 switch (peer.sa.sa_family) {
837 memcpy(buffer, &peer.s4.sin_port, sizeof(peer
872 } peer; local
879 (void) BIO_dgram_get_peer(SSL_get_rbio(ssl), &peer); local
[all...]
H A Dsess_id.c157 X509 *peer = NULL; local
180 peer = SSL_SESSION_get0_peer(x);
212 if (peer == NULL)
215 X509_print(out, peer);
232 } else if (!cfg.noout && (peer != NULL)) {
235 i = (int) i2d_X509_bio(out, peer);
237 i = PEM_write_bio_X509(out, peer);
/openbsd-current/regress/sys/kern/sosplice/loop/
H A Dloop.pl70 my ($as, $peer);
72 ($as, $peer) = $ls->accept()
76 $peer = $cs->sockname();
77 $as->connect($peer)
81 my ($err, $peerhost, $peerservice) = getnameinfo($peer,
H A Dbcast.pl65 my $peer = $cs->sockname();
66 $as->connect($peer)
69 my ($err, $peerhost, $peerservice) = getnameinfo($peer,
/openbsd-current/usr.sbin/sasyncd/
H A Dconf.y174 struct syncpeer *peer;
177 for (peer = LIST_FIRST(&cfgstate.peerlist); peer;
178 peer = LIST_NEXT(peer, link))
179 if (strcmp($2, peer->name) == 0) {
186 peer = calloc(1, sizeof *peer);
187 if (!peer) {
189 "failed", sizeof *peer);
[all...]
/openbsd-current/usr.bin/tftp/
H A Dtftp.c130 struct sockaddr_storage from, peer; local
146 memcpy(&peer, &peeraddr, peeraddr.ss_len);
156 nak(errno + 100, (struct sockaddr *)&peer);
174 (struct sockaddr *)&peer,
175 peer.ss_len) != size + 4) {
219 peer = from;
276 struct sockaddr_storage from, peer; local
295 memcpy(&peer, &peeraddr, peeraddr.ss_len);
322 (struct sockaddr *)&peer,
323 peer
481 nak(int error, struct sockaddr *peer) argument
633 struct sockaddr_storage peer; local
[all...]
/openbsd-current/regress/usr.sbin/bgpd/integrationtests/
H A Dbgpd.op.master.conf15 role peer
/openbsd-current/lib/libcrypto/evp/
H A Dpmeth_fn.c269 EVP_PKEY_derive_set_peer(EVP_PKEY_CTX *ctx, EVP_PKEY *peer) argument
286 ret = ctx->pmeth->ctrl(ctx, EVP_PKEY_CTRL_PEER_KEY, 0, peer);
299 if (ctx->pkey->type != peer->type) {
304 /* ran@cryptocom.ru: For clarity. The error is if parameters in peer are
309 if (!EVP_PKEY_missing_parameters(peer) &&
310 !EVP_PKEY_cmp_parameters(ctx->pkey, peer)) {
316 ctx->peerkey = peer;
318 ret = ctx->pmeth->ctrl(ctx, EVP_PKEY_CTRL_PEER_KEY, 1, peer);
325 CRYPTO_add(&peer->references, 1, CRYPTO_LOCK_EVP_PKEY);
/openbsd-current/usr.sbin/radiusd/
H A Dradiusd_radius.c407 struct sockaddr *peer; local
409 peer = (struct sockaddr *)&server->addr;
415 addrport_tostring(peer, peer->sa_len, buf, sizeof(buf)));
422 addrport_tostring(peer, peer->sa_len, buf, sizeof(buf)));
433 addrport_tostring(peer, peer->sa_len, buf, sizeof(buf)),
444 addrport_tostring(peer, peer
504 struct sockaddr *peer; local
[all...]

Completed in 198 milliseconds

123456