Lines Matching +full:endpoint +full:- +full:base
1 // SPDX-License-Identifier: GPL-2.0-or-later
3 * Copyright (c) 1999-2000 Cisco, Inc.
4 * Copyright (c) 1999-2001 Motorola, Inc.
5 * Copyright (c) 2001-2002 International Business Machines, Corp.
12 * This abstraction represents an SCTP endpoint.
16 * lksctp developers <linux-sctp@vger.kernel.org>
39 * Initialize the base fields of the endpoint structure.
48 ep->digest = kzalloc(SCTP_SIGNATURE_SIZE, gfp); in sctp_endpoint_init()
49 if (!ep->digest) in sctp_endpoint_init()
52 ep->asconf_enable = net->sctp.addip_enable; in sctp_endpoint_init()
53 ep->auth_enable = net->sctp.auth_enable; in sctp_endpoint_init()
54 if (ep->auth_enable) { in sctp_endpoint_init()
57 if (ep->asconf_enable) { in sctp_endpoint_init()
63 /* Initialize the base structure. */ in sctp_endpoint_init()
64 /* What type of endpoint are we? */ in sctp_endpoint_init()
65 ep->base.type = SCTP_EP_TYPE_SOCKET; in sctp_endpoint_init()
68 refcount_set(&ep->base.refcnt, 1); in sctp_endpoint_init()
69 ep->base.dead = false; in sctp_endpoint_init()
72 sctp_inq_init(&ep->base.inqueue); in sctp_endpoint_init()
74 /* Set its top-half handler */ in sctp_endpoint_init()
75 sctp_inq_set_th_handler(&ep->base.inqueue, sctp_endpoint_bh_rcv); in sctp_endpoint_init()
78 sctp_bind_addr_init(&ep->base.bind_addr, 0); in sctp_endpoint_init()
81 INIT_LIST_HEAD(&ep->asocs); in sctp_endpoint_init()
84 ep->sndbuf_policy = net->sctp.sndbuf_policy; in sctp_endpoint_init()
86 sk->sk_data_ready = sctp_data_ready; in sctp_endpoint_init()
87 sk->sk_write_space = sctp_write_space; in sctp_endpoint_init()
90 /* Get the receive buffer policy for this endpoint */ in sctp_endpoint_init()
91 ep->rcvbuf_policy = net->sctp.rcvbuf_policy; in sctp_endpoint_init()
94 get_random_bytes(ep->secret_key, sizeof(ep->secret_key)); in sctp_endpoint_init()
96 /* SCTP-AUTH extensions*/ in sctp_endpoint_init()
97 INIT_LIST_HEAD(&ep->endpoint_shared_keys); in sctp_endpoint_init()
102 list_add(&null_key->key_list, &ep->endpoint_shared_keys); in sctp_endpoint_init()
104 /* Add the null key to the endpoint shared keys list and in sctp_endpoint_init()
107 ep->prsctp_enable = net->sctp.prsctp_enable; in sctp_endpoint_init()
108 ep->reconf_enable = net->sctp.reconf_enable; in sctp_endpoint_init()
109 ep->ecn_enable = net->sctp.ecn_enable; in sctp_endpoint_init()
112 ep->base.sk = sk; in sctp_endpoint_init()
113 ep->base.net = sock_net(sk); in sctp_endpoint_init()
114 sock_hold(ep->base.sk); in sctp_endpoint_init()
121 kfree(ep->digest); in sctp_endpoint_init()
133 /* Build a local endpoint. */ in sctp_endpoint_new()
150 /* Add an association to an endpoint. */
154 struct sock *sk = ep->base.sk; in sctp_endpoint_add_asoc()
160 if (asoc->temp) in sctp_endpoint_add_asoc()
164 list_add_tail(&asoc->asocs, &ep->asocs); in sctp_endpoint_add_asoc()
166 /* Increment the backlog value for a TCP-style listening socket. */ in sctp_endpoint_add_asoc()
171 /* Free the endpoint structure. Delay cleanup until
176 ep->base.dead = true; in sctp_endpoint_free()
178 inet_sk_set_state(ep->base.sk, SCTP_SS_CLOSED); in sctp_endpoint_free()
180 /* Unlink this endpoint, so we can't find it again! */ in sctp_endpoint_free()
186 /* Final destructor for endpoint. */
190 struct sock *sk = ep->base.sk; in sctp_endpoint_destroy_rcu()
192 sctp_sk(sk)->ep = NULL; in sctp_endpoint_destroy_rcu()
203 if (unlikely(!ep->base.dead)) { in sctp_endpoint_destroy()
204 WARN(1, "Attempt to destroy undead endpoint %p!\n", ep); in sctp_endpoint_destroy()
209 kfree(ep->digest); in sctp_endpoint_destroy()
211 /* SCTP-AUTH: Free up AUTH releated data such as shared keys in sctp_endpoint_destroy()
214 sctp_auth_destroy_keys(&ep->endpoint_shared_keys); in sctp_endpoint_destroy()
218 sctp_inq_free(&ep->base.inqueue); in sctp_endpoint_destroy()
219 sctp_bind_addr_free(&ep->base.bind_addr); in sctp_endpoint_destroy()
221 memset(ep->secret_key, 0, sizeof(ep->secret_key)); in sctp_endpoint_destroy()
223 sk = ep->base.sk; in sctp_endpoint_destroy()
225 if (sctp_sk(sk)->bind_hash) in sctp_endpoint_destroy()
228 call_rcu(&ep->rcu, sctp_endpoint_destroy_rcu); in sctp_endpoint_destroy()
231 /* Hold a reference to an endpoint. */
234 return refcount_inc_not_zero(&ep->base.refcnt); in sctp_endpoint_hold()
237 /* Release a reference to an endpoint and clean up if there are
242 if (refcount_dec_and_test(&ep->base.refcnt)) in sctp_endpoint_put()
246 /* Is this the endpoint we are looking for? */
252 int bound_dev_if = READ_ONCE(ep->base.sk->sk_bound_dev_if); in sctp_endpoint_is_match()
255 if (net_eq(ep->base.net, net) && in sctp_endpoint_is_match()
257 (htons(ep->base.bind_addr.port) == laddr->v4.sin_port)) { in sctp_endpoint_is_match()
258 if (sctp_bind_addr_match(&ep->base.bind_addr, laddr, in sctp_endpoint_is_match()
259 sctp_sk(ep->base.sk))) in sctp_endpoint_is_match()
268 * through t->assoc.
281 * on this endpoint. in sctp_endpoint_lookup_assoc()
283 if (!ep->base.bind_addr.port) in sctp_endpoint_lookup_assoc()
292 asoc = t->asoc; in sctp_endpoint_lookup_assoc()
298 /* Look for any peeled off association from the endpoint that matches the
304 int bound_dev_if = READ_ONCE(ep->base.sk->sk_bound_dev_if); in sctp_endpoint_is_peeled_off()
306 struct net *net = ep->base.net; in sctp_endpoint_is_peeled_off()
309 bp = &ep->base.bind_addr; in sctp_endpoint_is_peeled_off()
313 list_for_each_entry(addr, &bp->address_list, list) { in sctp_endpoint_is_peeled_off()
314 if (sctp_has_association(net, &addr->a, paddr, in sctp_endpoint_is_peeled_off()
329 base.inqueue.immediate); in sctp_endpoint_bh_rcv()
341 if (ep->base.dead) in sctp_endpoint_bh_rcv()
345 inqueue = &ep->base.inqueue; in sctp_endpoint_bh_rcv()
346 sk = ep->base.sk; in sctp_endpoint_bh_rcv()
350 subtype = SCTP_ST_CHUNK(chunk->chunk_hdr->type); in sctp_endpoint_bh_rcv()
353 * processing specified in Section 6.3 of SCTP-AUTH spec in sctp_endpoint_bh_rcv()
362 /* If the next chunk is COOKIE-ECHO, skip the AUTH in sctp_endpoint_bh_rcv()
364 * Authentication later (during cookie-echo in sctp_endpoint_bh_rcv()
367 if (next_hdr->type == SCTP_CID_COOKIE_ECHO) { in sctp_endpoint_bh_rcv()
368 chunk->auth_chunk = skb_clone(chunk->skb, in sctp_endpoint_bh_rcv()
370 chunk->auth = 1; in sctp_endpoint_bh_rcv()
379 * COOKIE-ECHO chunk. in sctp_endpoint_bh_rcv()
381 if (NULL == chunk->asoc) { in sctp_endpoint_bh_rcv()
385 chunk->asoc = asoc; in sctp_endpoint_bh_rcv()
386 chunk->transport = transport; in sctp_endpoint_bh_rcv()
389 state = asoc ? asoc->state : SCTP_STATE_CLOSED; in sctp_endpoint_bh_rcv()
390 if (sctp_auth_recv_cid(subtype.chunk, asoc) && !chunk->auth) in sctp_endpoint_bh_rcv()
397 asoc->peer.last_data_from = chunk->transport; in sctp_endpoint_bh_rcv()
399 SCTP_INC_STATS(ep->base.net, SCTP_MIB_INCTRLCHUNKS); in sctp_endpoint_bh_rcv()
401 asoc->stats.ictrlchunks++; in sctp_endpoint_bh_rcv()
404 if (chunk->transport) in sctp_endpoint_bh_rcv()
405 chunk->transport->last_time_heard = ktime_get(); in sctp_endpoint_bh_rcv()
411 chunk->pdiscard = 1; in sctp_endpoint_bh_rcv()
413 /* Check to see if the endpoint is freed in response to in sctp_endpoint_bh_rcv()
416 if (!sctp_sk(sk)->ep) in sctp_endpoint_bh_rcv()