3 * ===================================
4 * HARP | Host ATM Research Platform
5 * ===================================
8 * This Host ATM Research Platform ("HARP") file (the "Software") is
9 * made available by Network Computing Services, Inc. ("NetworkCS")
10 * "AS IS". NetworkCS does not provide maintenance, improvements or
11 * support of any kind.
13 * NETWORKCS MAKES NO WARRANTIES OR REPRESENTATIONS, EXPRESS OR IMPLIED,
14 * INCLUDING, BUT NOT LIMITED TO, IMPLIED WARRANTIES OF MERCHANTABILITY
15 * AND FITNESS FOR A PARTICULAR PURPOSE, AS TO ANY ELEMENT OF THE
16 * SOFTWARE OR ANY SUPPORT PROVIDED IN CONNECTION WITH THIS SOFTWARE.
17 * In no event shall NetworkCS be responsible for any damages, including
18 * but not limited to consequential damages, arising from or relating to
19 * any use of the Software or related support.
21 * Copyright 1994-1998 Network Computing Services, Inc.
23 * Copies of this Software may be made, however, the above copyright
24 * notice must be reproduced on all copies.
26 * @(#) $FreeBSD: src/sys/netatm/uni/unisig_if.c,v 1.8 2000/01/17 20:49:56 mks Exp $
27 * @(#) $DragonFly: src/sys/netproto/atm/uni/unisig_if.c,v 1.9 2006/12/20 18:14:43 dillon Exp $
31 * ATM Forum UNI 3.0/3.1 Signalling Manager
32 * ----------------------------------------
34 * System interface module
38 #include <netproto/atm/kern_include.h>
40 #include <netproto/atm/ipatm/ipatm_var.h>
41 #include <netproto/atm/ipatm/ipatm_serv.h>
42 #include "uniip_var.h"
45 #include "unisig_var.h"
46 #include "unisig_msg.h"
51 struct sp_info unisig_vcpool = {
52 "unisig vcc pool", /* si_name */
53 sizeof(struct unisig_vccb), /* si_blksiz */
58 struct sp_info unisig_msgpool = {
59 "unisig message pool", /* si_name */
60 sizeof(struct unisig_msg), /* si_blksiz */
65 struct sp_info unisig_iepool = {
66 "unisig ie pool", /* si_name */
67 sizeof(struct ie_generic), /* si_blksiz */
76 static int unisig_attach (struct sigmgr *, struct atm_pif *);
77 static int unisig_detach (struct atm_pif *);
78 static int unisig_setup (Atm_connvc *, int *);
79 static int unisig_release (struct vccb *, int *);
80 static int unisig_accept (struct vccb *, int *);
81 static int unisig_reject (struct vccb *, int *);
82 static int unisig_abort (struct vccb *);
83 static int unisig_ioctl (int, caddr_t, caddr_t);
89 static struct sigmgr unisig_mgr30 = {
103 static struct sigmgr unisig_mgr31 = {
119 * Initialize UNISIG processing
121 * This will be called during module loading. We'll just register
122 * the UNISIG protocol descriptor and wait for a UNISIG ATM interface
129 * 0 startup was successful
130 * errno startup failed - reason indicated
139 * Verify software version
141 if (atm_version != ATM_VERSION) {
142 log(LOG_ERR, "version mismatch: unisig=%d.%d kernel=%d.%d\n",
143 ATM_VERS_MAJ(ATM_VERSION),
144 ATM_VERS_MIN(ATM_VERSION),
145 ATM_VERS_MAJ(atm_version),
146 ATM_VERS_MIN(atm_version));
151 * Register ourselves with system
153 err = atm_sigmgr_register(&unisig_mgr30);
157 err = atm_sigmgr_register(&unisig_mgr31);
165 * Halt UNISIG processing
167 * This should be called just prior to unloading the module from
168 * memory. All UNISIG interfaces must be deregistered before the
169 * protocol can be shutdown.
175 * 0 startup was successful
176 * errno startup failed - reason indicated
187 * Any protocol instances still registered?
189 if ((unisig_mgr30.sm_prinst != NULL) ||
190 (unisig_mgr31.sm_prinst != NULL)) {
192 /* Yes, can't stop now */
198 * De-register from system
200 atm_sigmgr_deregister(&unisig_mgr30);
201 atm_sigmgr_deregister(&unisig_mgr31);
204 * Free up our storage pools
206 atm_release_pool(&unisig_vcpool);
207 atm_release_pool(&unisig_msgpool);
208 atm_release_pool(&unisig_iepool);
217 * Attach a UNISIG-controlled interface
219 * Each ATM physical interface must be attached with the signalling
220 * manager for the interface's signalling protocol (via the
221 * atm_sigmgr_attach function). This function will handle the
222 * attachment for UNISIG-controlled interfaces. A new UNISIG protocol
223 * instance will be created and then we'll just sit around waiting for
224 * status or connection requests.
226 * Function must be called from a critical section.
229 * smp pointer to UNISIG signalling manager control block
230 * pip pointer to ATM physical interface control block
233 * 0 attach successful
234 * errno attach failed - reason indicated
238 unisig_attach(struct sigmgr *smp, struct atm_pif *pip)
241 struct unisig *usp = NULL;
243 ATM_DEBUG2("unisig_attach: smp=%p, pip=%p\n", smp, pip);
246 * Allocate UNISIG protocol instance control block
248 usp = KM_ALLOC(sizeof(struct unisig), M_DEVBUF, M_INTWAIT | M_NULLOK);
253 KM_ZERO(usp, sizeof(struct unisig));
256 * Set state in UNISIG protocol instance control block
258 usp->us_state = UNISIG_NULL;
259 usp->us_proto = smp->sm_proto;
262 * Set initial call reference allocation value
267 * Link instance into manager's chain
269 LINK2TAIL((struct siginst *)usp, struct siginst, smp->sm_prinst,
277 pip->pif_sigmgr = smp;
278 pip->pif_siginst = (struct siginst *) usp;
282 * Clear our ATM address. The address will be set by user
283 * command or by registration via ILMI.
285 usp->us_addr.address_format = T_ATM_ABSENT;
286 usp->us_addr.address_length = 0;
287 usp->us_subaddr.address_format = T_ATM_ABSENT;
288 usp->us_subaddr.address_length = 0;
293 usp->us_ipserv = &uniip_ipserv;
296 * Kick-start the UNISIG protocol
298 UNISIG_TIMER(usp, 0);
301 * Log the fact that we've attached
303 log(LOG_INFO, "unisig: attached to interface %s%d\n",
304 pip->pif_name, pip->pif_unit);
308 * Reset our work if attach fails
313 UNLINK((struct siginst *)usp, struct siginst,
314 smp->sm_prinst, si_next);
315 KM_FREE(usp, sizeof(struct unisig), M_DEVBUF);
318 pip->pif_sigmgr = NULL;
319 pip->pif_siginst = NULL;
328 * Detach a UNISIG-controlled interface
330 * Each ATM physical interface may be detached from its signalling
331 * manager (via the atm_sigmgr_detach function). This function will
332 * handle the detachment for all UNISIG-controlled interfaces. All
333 * circuits will be immediately terminated.
335 * Function must be called from a critical section.
338 * pip pointer to ATM physical interface control block
341 * 0 detach successful
342 * errno detach failed - reason indicated
346 unisig_detach(struct atm_pif *pip)
351 ATM_DEBUG1("unisig_detach: pip=%p\n", pip);
354 * Get UNISIG protocol instance
356 usp = (struct unisig *)pip->pif_siginst;
359 * Return an error if we're already detaching
361 if (usp->us_state == UNISIG_DETACH) {
366 * Pass the detach event to the signalling manager
369 err = unisig_sigmgr_state(usp, UNISIG_SIGMGR_DETACH, NULL);
372 * Log the fact that we've detached
375 log(LOG_INFO, "unisig: detached from interface %s%d\n",
376 pip->pif_name, pip->pif_unit);
383 * Open a UNISIG ATM Connection
385 * All service user requests to open a VC connection (via
386 * atm_open_connection) over an ATM interface attached to the UNISIG
387 * signalling manager are handled here.
389 * Function will be called from a critical section.
392 * cvp pointer to user's requested connection parameters
393 * errp pointer to an int for extended error information
396 * CALL_PROCEEDING connection establishment is in progress
397 * CALL_FAILED connection establishment failed
398 * CALL_CONNECTED connection has been successfully established
402 unisig_setup(Atm_connvc *cvp, int *errp)
404 struct atm_pif *pip = cvp->cvc_attr.nif->nif_pif;
405 struct unisig *usp = (struct unisig *)pip->pif_siginst;
408 ATM_DEBUG1("unisig_setup: cvp=%p\n", cvp);
411 * Intialize the returned error code
416 * Open the connection
418 switch (cvp->cvc_attr.called.addr.address_format) {
423 *errp = unisig_open_vcc(usp, cvp);
424 rc = (*errp ? CALL_FAILED : CALL_CONNECTED);
427 case T_ATM_ENDSYS_ADDR:
428 case T_ATM_E164_ADDR:
433 *errp = unisig_open_vcc(usp, cvp);
434 rc = (*errp ? CALL_FAILED : CALL_PROCEEDING);
438 *errp = EPROTONOSUPPORT;
447 * Close a UNISIG ATM Connection
449 * All service user requests to terminate a previously open VC
450 * connection (via the atm_close_connection function), which is running
451 * over an interface attached to the UNISIG signalling manager, are
454 * Function will be called from a critical section.
457 * vcp pointer to connection's VC control block
458 * errp pointer to an int for extended error information
461 * CALL_PROCEEDING connection termination is in progress
462 * CALL_FAILED connection termination failed
463 * CALL_CLEARED connection has been successfully terminated
467 unisig_release(struct vccb *vcp, int *errp)
470 struct atm_pif *pip = vcp->vc_pif;
471 struct unisig *usp = (struct unisig *)pip->pif_siginst;
473 ATM_DEBUG1("unisig_release: vcp=%p\n", vcp);
476 * Initialize returned error code
481 * Validate the connection type (PVC or SVC)
483 if (!(vcp->vc_type & (VCC_PVC | VCC_SVC))) {
484 *errp = EPROTONOSUPPORT;
491 *errp = unisig_close_vcc(usp, (struct unisig_vccb *)vcp);
494 * Set the return code
498 } else if (vcp->vc_sstate == UNI_NULL ||
499 vcp->vc_sstate == UNI_FREE) {
502 rc = CALL_PROCEEDING;
510 * Accept a UNISIG Open from a remote host
512 * A user calls this routine (via the atm_accept_call function)
513 * after it is notified that an open request was received for it.
515 * Function will be called from a critical section.
518 * vcp pointer to user's VCCB
519 * errp pointer to an int for extended error information
522 * CALL_PROCEEDING connection establishment is in progress
523 * CALL_FAILED connection establishment failed
524 * CALL_CONNECTED connection has been successfully established
528 unisig_accept(struct vccb *vcp, int *errp)
530 struct unisig_vccb *uvp = (struct unisig_vccb *)vcp;
531 struct atm_pif *pip = uvp->uv_pif;
532 struct unisig *usp = (struct unisig *)pip->pif_siginst;
534 ATM_DEBUG1("unisig_accept: vcp=%p\n", vcp);
537 * Initialize the returned error code
542 * Return an error if we're detaching
544 if (usp->us_state == UNISIG_DETACH) {
550 * Return an error if we lost the connection
552 if (uvp->uv_sstate == UNI_FREE) {
558 * Pass the acceptance to the VC state machine
560 *errp = unisig_vc_state(usp, uvp, UNI_VC_ACCEPT_CALL,
561 (struct unisig_msg *) 0);
565 return(CALL_PROCEEDING);
569 * On error, free the VCCB and return CALL_FAILED
573 uvp->uv_sstate = UNI_FREE;
574 uvp->uv_ustate = VCCU_CLOSED;
575 DEQUEUE(uvp, struct unisig_vccb, uv_sigelem, usp->us_vccq);
576 unisig_free((struct vccb *)uvp);
583 * Reject a UNISIG Open from a remote host
585 * A user calls this routine (via the atm_reject_call function)
586 * after it is notified that an open request was received for it.
588 * Function will be called from a critical section.
591 * uvp pointer to user's VCCB
592 * errp pointer to an int for extended error information
595 * CALL_CLEARED call request rejected
596 * CALL_FAILED call rejection failed
600 unisig_reject(struct vccb *vcp, int *errp)
602 struct unisig_vccb *uvp = (struct unisig_vccb *)vcp;
603 struct atm_pif *pip = uvp->uv_pif;
604 struct unisig *usp = (struct unisig *)pip->pif_siginst;
606 ATM_DEBUG1("unisig_reject: uvp=%p\n", uvp);
609 * Initialize the returned error code
615 * Return an error if we're detaching
617 if (usp->us_state == UNISIG_DETACH) {
623 * Call the VC state machine
625 *errp = unisig_vc_state(usp, uvp, UNI_VC_REJECT_CALL,
626 (struct unisig_msg *) 0);
630 return(CALL_CLEARED);
634 * On error, free the VCCB and return CALL_FAILED
636 uvp->uv_sstate = UNI_FREE;
637 uvp->uv_ustate = VCCU_CLOSED;
638 DEQUEUE(uvp, struct unisig_vccb, uv_sigelem, usp->us_vccq);
639 unisig_free((struct vccb *)uvp);
645 * Abort a UNISIG ATM Connection
647 * All (non-user) requests to abort a previously open VC connection (via
648 * the atm_abort_connection function), which is running over an
649 * interface attached to the UNISIG signalling manager, are handled here.
650 * The VCC owner will be notified of the request, in order to initiate
651 * termination of the connection.
653 * Function will be called from a critical section.
656 * vcp pointer to connection's VC control block
659 * 0 connection release was successful
660 * errno connection release failed - reason indicated
664 unisig_abort(struct vccb *vcp)
667 ATM_DEBUG1("unisig_abort: vcp=%p\n", vcp);
672 if (vcp->vc_ustate == VCCU_ABORT) {
677 * Cancel any timer that might be running
679 UNISIG_VC_CANCEL(vcp);
682 * Set immediate timer to schedule connection termination
684 vcp->vc_ustate = VCCU_ABORT;
685 UNISIG_VC_TIMER(vcp, 0);
692 * Free UNISIG ATM connection resources
694 * All service user requests to free the resources of a closed VCC
695 * connection (via the atm_free_connection function), which is running
696 * over an interface attached to the UNISIG signalling manager, are
699 * Function will be called from a critical section.
702 * vcp pointer to connection's VC control block
705 * 0 connection free was successful
706 * errno connection free failed - reason indicated
710 unisig_free(struct vccb *vcp)
712 struct atm_pif *pip = vcp->vc_pif;
713 struct unisig *usp = (struct unisig *)pip->pif_siginst;
715 ATM_DEBUG1("unisig_free: vcp = %p\n", vcp);
718 * Make sure VCC has been closed
720 if ((vcp->vc_ustate != VCCU_CLOSED &&
721 vcp->vc_ustate != VCCU_ABORT) ||
722 vcp->vc_sstate != UNI_FREE) {
723 ATM_DEBUG2("unisig_free: bad state, sstate=%d, ustate=%d\n",
724 vcp->vc_sstate, vcp->vc_ustate);
729 * Remove VCCB from protocol queue
731 DEQUEUE(vcp, struct vccb, vc_sigelem, usp->us_vccq);
736 vcp->vc_ustate = VCCU_NULL;
737 vcp->vc_sstate = UNI_NULL;
738 atm_free((caddr_t)vcp);
741 * If we're detaching and this was the last VCC queued,
742 * get rid of the protocol instance
744 if ((usp->us_state == UNISIG_DETACH) &&
745 (Q_HEAD(usp->us_vccq, struct vccb) == NULL)) {
746 struct sigmgr *smp = pip->pif_sigmgr;
749 pip->pif_sigmgr = NULL;
750 pip->pif_siginst = NULL;
753 UNLINK((struct siginst *)usp, struct siginst,
754 smp->sm_prinst, si_next);
755 KM_FREE(usp, sizeof(struct unisig), M_DEVBUF);
763 * UNISIG IOCTL support
765 * Function will be called from a critical section.
768 * code PF_ATM sub-operation code
769 * data pointer to code specific parameter data area
770 * arg1 pointer to code specific argument
774 * errno error processing request - reason indicated
778 unisig_ioctl(int code, caddr_t data, caddr_t arg1)
780 struct atmdelreq *adp;
781 struct atminfreq *aip;
782 struct atmsetreq *asp;
784 struct unisig_vccb *uvp;
785 struct air_vcc_rsp rsp;
789 int err = 0, buf_len, i;
792 ATM_DEBUG1("unisig_ioctl: code=%d\n", code);
801 adp = (struct atmdelreq *)data;
802 usp = (struct unisig *)arg1;
805 * Don't let a user close the UNISIG signalling VC
807 vpi = adp->adr_pvc_vpi;
808 vci = adp->adr_pvc_vci;
809 if ((vpi == UNISIG_SIG_VPI && vci == UNISIG_SIG_VCI))
815 for (uvp = Q_HEAD(usp->us_vccq, struct unisig_vccb); uvp;
816 uvp = Q_NEXT(uvp, struct unisig_vccb, uv_sigelem)) {
817 if ((uvp->uv_vpi == vpi) && (uvp->uv_vci == vci))
828 if (!(uvp->uv_type & VCC_PVC)) {
833 if (!(uvp->uv_type & VCC_SVC)) {
840 * Schedule VCC termination
842 unisig_cause_attr_from_user(&uvp->uv_connvc->cvc_attr,
843 T_ATM_CAUSE_UNSPECIFIED_NORMAL);
844 err = unisig_abort((struct vccb *)uvp);
849 * Return VCC information
851 aip = (struct atminfreq *)data;
852 usp = (struct unisig *)arg1;
854 buf_addr = aip->air_buf_addr;
855 buf_len = aip->air_buf_len;
858 * Loop through the VCC queue
860 for (uvp = Q_HEAD(usp->us_vccq, struct unisig_vccb); uvp;
861 uvp = Q_NEXT(uvp, struct unisig_vccb, uv_sigelem)) {
863 * Make sure there's room in the user's buffer
865 if (buf_len < sizeof(rsp)) {
871 * Fill out the response struct for the VCC
873 ksnprintf(rsp.avp_intf,
874 sizeof(rsp.avp_intf), "%s%d",
875 usp->us_pif->pif_name,
876 usp->us_pif->pif_unit);
877 rsp.avp_vpi = uvp->uv_vpi;
878 rsp.avp_vci = uvp->uv_vci;
879 rsp.avp_type = uvp->uv_type;
880 rsp.avp_aal = uvp->uv_connvc->cvc_attr.aal.type;
881 rsp.avp_sig_proto = uvp->uv_proto;
882 cop = uvp->uv_connvc->cvc_conn;
884 rsp.avp_encaps = cop->co_mpx;
887 rsp.avp_state = uvp->uv_sstate;
888 if (uvp->uv_connvc->cvc_flags & CVCF_CALLER) {
889 rsp.avp_daddr = uvp->uv_connvc->cvc_attr.called.addr;
891 rsp.avp_daddr = uvp->uv_connvc->cvc_attr.calling.addr;
893 rsp.avp_dsubaddr.address_format = T_ATM_ABSENT;
894 rsp.avp_dsubaddr.address_length = 0;
895 rsp.avp_ipdus = uvp->uv_ipdus;
896 rsp.avp_opdus = uvp->uv_opdus;
897 rsp.avp_ibytes = uvp->uv_ibytes;
898 rsp.avp_obytes = uvp->uv_obytes;
899 rsp.avp_ierrors = uvp->uv_ierrors;
900 rsp.avp_oerrors = uvp->uv_oerrors;
901 rsp.avp_tstamp = uvp->uv_tstamp;
902 KM_ZERO(rsp.avp_owners,
903 sizeof(rsp.avp_owners));
904 for (i = 0; cop && i < sizeof(rsp.avp_owners);
906 i += T_ATM_APP_NAME_LEN+1) {
907 strncpy(&rsp.avp_owners[i],
908 cop->co_endpt->ep_getname(cop->co_toku),
913 * Copy the response into the user's buffer
915 if ((err = copyout((caddr_t)&rsp, buf_addr,
918 buf_addr += sizeof(rsp);
919 buf_len -= sizeof(rsp);
923 * Update the buffer pointer and length
925 aip->air_buf_addr = buf_addr;
926 aip->air_buf_len = buf_len;
933 * Get ARP table information or get/set ARP server address
935 err = uniarp_ioctl(code, data, arg1);
942 asp = (struct atmsetreq *)data;
943 usp = (struct unisig *)arg1;
945 if (usp->us_addr.address_format != T_ATM_ABSENT) {
946 if (KM_CMP(asp->asr_prf_pref, usp->us_addr.address,
947 sizeof(asp->asr_prf_pref)) != 0)
951 usp->us_addr.address_format = T_ATM_ENDSYS_ADDR;
952 usp->us_addr.address_length = sizeof(Atm_addr_nsap);
953 KM_COPY(&pip->pif_macaddr,
954 ((Atm_addr_nsap *)usp->us_addr.address)->aan_esi,
955 sizeof(pip->pif_macaddr));
956 KM_COPY((caddr_t) asp->asr_prf_pref,
957 &((Atm_addr_nsap *)usp->us_addr.address)->aan_afi,
958 sizeof(asp->asr_prf_pref));
959 log(LOG_INFO, "uni: set address %s on interface %s\n",
960 unisig_addr_print(&usp->us_addr),
964 * Pass event to signalling manager state machine
966 err = unisig_sigmgr_state(usp, UNISIG_SIGMGR_ADDR_SET,
970 * Clean up if there was an error
973 usp->us_addr.address_format = T_ATM_ABSENT;
974 usp->us_addr.address_length = 0;
979 * Inform ARP code of new address
981 uniarp_ifaddr((struct siginst *)usp);