xnu-1228.tar.gz

[apple/xnu.git] / bsd / netat / ddp_aarp.c

diff --git a/bsd/netat/ddp_aarp.c b/bsd/netat/ddp_aarp.c
index 6b38aa40e0c5b796fa75a654044ac8059813dba0..09e1fc460308fd0c488acd3ac0f6a7166eb1fb73 100644 (file)
--- a/bsd/netat/ddp_aarp.c
+++ b/bsd/netat/ddp_aarp.c
@@ -1,14 +1,19 @@
 /*
  * Copyright (c) 2000 Apple Computer, Inc. All rights reserved.
  *
 /*
  * Copyright (c) 2000 Apple Computer, Inc. All rights reserved.
  *

- * @APPLE_LICENSE_HEADER_START@
+ * @APPLE_OSREFERENCE_LICENSE_HEADER_START@

  * 
  * This file contains Original Code and/or Modifications of Original Code
  * as defined in and that are subject to the Apple Public Source License
  * Version 2.0 (the 'License'). You may not use this file except in
  * 
  * This file contains Original Code and/or Modifications of Original Code
  * as defined in and that are subject to the Apple Public Source License
  * Version 2.0 (the 'License'). You may not use this file except in

- * compliance with the License. Please obtain a copy of the License at
- * http://www.opensource.apple.com/apsl/ and read it before using this
- * file.
+ * compliance with the License. The rights granted to you under the License
+ * may not be used to create, or enable the creation or redistribution of,
+ * unlawful or unlicensed copies of an Apple operating system, or to
+ * circumvent, violate, or enable the circumvention or violation of, any
+ * terms of an Apple operating system software license agreement.
+ * 
+ * Please obtain a copy of the License at
+ * http://www.opensource.apple.com/apsl/ and read it before using this file.

  * 
  * The Original Code and all software distributed under the License are
  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
  * 
  * The Original Code and all software distributed under the License are
  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER


@@ -18,7 +23,7 @@
  * Please see the License for the specific language governing rights and
  * limitations under the License.
  * 
  * Please see the License for the specific language governing rights and
  * limitations under the License.
  * 

- * @APPLE_LICENSE_HEADER_END@
+ * @APPLE_OSREFERENCE_LICENSE_HEADER_END@

  */
 /*     Copyright (c) 1988, 1989, 1997, 1998 Apple Computer, Inc. 
  *
  */
 /*     Copyright (c) 1988, 1989, 1997, 1998 Apple Computer, Inc. 
  *


@@ -57,6 +62,7 @@
 #include <netat/at_pcb.h>
 #include <netat/at_var.h>
 #include <netat/at_aarp.h>
 #include <netat/at_pcb.h>
 #include <netat/at_var.h>
 #include <netat/at_aarp.h>

+#include <netat/at_pat.h>

 #include <netat/debug.h>
 
 #include <sys/kern_event.h>
 #include <netat/debug.h>
 
 #include <sys/kern_event.h>


@@ -77,27 +83,21 @@ struct      etalk_addr      et_zeroaddr = {
 aarp_amt_t             probe_cb;
 aarp_amt_array *aarp_table[IF_TOTAL_MAX];
 
 aarp_amt_t             probe_cb;
 aarp_amt_array *aarp_table[IF_TOTAL_MAX];
 

-int aarp_init1(), aarp_init2();
-int aarp_send_data();
-
-StaticProc int aarp_req_cmd_in();
-StaticProc int aarp_resp_cmd_in();
-StaticProc int aarp_probe_cmd_in();
-StaticProc int aarp_send_resp();
-StaticProc int aarp_send_req();
-StaticProc int aarp_send_probe();
-StaticProc aarp_amt_t *aarp_lru_entry();
-StaticProc int aarp_glean_info();
-StaticProc int aarp_delete_amt_info();
-StaticProc void aarp_build_pkt();
-StaticProc void aarp_sched_req(void *);
-StaticProc int aarp_get_rand_node();
-StaticProc int aarp_get_next_node();
-StaticProc int aarp_get_rand_net();
-atlock_t arpinp_lock;

 
 

-extern void AARPwakeup(aarp_amt_t *);
-extern int pat_output(at_ifaddr_t *, gbuf_t *, unsigned char *, int);
+StaticProc int aarp_req_cmd_in(aarp_pkt_t *, at_ifaddr_t*);
+StaticProc int aarp_resp_cmd_in(aarp_pkt_t *, at_ifaddr_t*);
+StaticProc int aarp_probe_cmd_in(aarp_pkt_t *, at_ifaddr_t*);
+StaticProc int aarp_send_resp(at_ifaddr_t *, aarp_pkt_t *);
+StaticProc int aarp_send_req(aarp_amt_t *);
+StaticProc int aarp_send_probe(void);
+StaticProc aarp_amt_t *aarp_lru_entry(aarp_amt_t *);
+StaticProc int aarp_glean_info(aarp_pkt_t *, at_ifaddr_t*);
+StaticProc int aarp_delete_amt_info(aarp_amt_t *);
+StaticProc void aarp_build_pkt(aarp_pkt_t *, at_ifaddr_t*);
+StaticProc void aarp_sched_req(void *);
+StaticProc int aarp_get_rand_node(at_ifaddr_t  *);
+StaticProc int aarp_get_next_node(at_ifaddr_t  *);
+StaticProc int aarp_get_rand_net(at_ifaddr_t *);

 
 /****************************************************************************
  * aarp_init()
 
 /****************************************************************************
  * aarp_init()


@@ -182,7 +182,7 @@ int aarp_rcv_pkt(pkt, elapp)
      aarp_pkt_t *pkt;
      at_ifaddr_t *elapp;
 {
      aarp_pkt_t *pkt;
      at_ifaddr_t *elapp;
 {

-       switch (pkt->aarp_cmd) {
+       switch (ntohs(pkt->aarp_cmd)) {

        case AARP_REQ_CMD:
                return (aarp_req_cmd_in (pkt, elapp));
        case AARP_RESP_CMD:
        case AARP_REQ_CMD:
                return (aarp_req_cmd_in (pkt, elapp));
        case AARP_RESP_CMD:


@@ -282,7 +282,7 @@ StaticProc int aarp_resp_cmd_in (pkt, elapp)
                break;
 
        case PROBE_DONE :
                break;
 
        case PROBE_DONE :

-               AMT_LOOK(amt_ptr, pkt->src_at_addr, elapp);
+               AMT_LOOK(amt_ptr, pkt->src_at_addr, elapp)

                if (amt_ptr == NULL)
                        return(-1);
                if (amt_ptr->tmo) {
                if (amt_ptr == NULL)
                        return(-1);
                if (amt_ptr->tmo) {


@@ -301,7 +301,7 @@ StaticProc int aarp_resp_cmd_in (pkt, elapp)
                }
                amt_ptr->dest_addr = pkt->src_addr;
                if (FDDI_OR_TOKENRING(elapp->aa_ifp->if_type))
                }
                amt_ptr->dest_addr = pkt->src_addr;
                if (FDDI_OR_TOKENRING(elapp->aa_ifp->if_type))

-                       ddp_bit_reverse(&amt_ptr->dest_addr);
+                       ddp_bit_reverse((unsigned char *)&amt_ptr->dest_addr);

                m = amt_ptr->m;
                amt_ptr->m = NULL;
                pat_output(amt_ptr->elapp, m,
                m = amt_ptr->m;
                amt_ptr->m = NULL;
                pat_output(amt_ptr->elapp, m,


@@ -423,18 +423,18 @@ int aarp_chk_addr(ddp_hdrp, elapp)
  *     will ALWAYS be removed.  If the message is dropped,
  *     it's not an "error".
  *
  *     will ALWAYS be removed.  If the message is dropped,
  *     it's not an "error".
  *

+ *  Parameter dest_at_addr must have the net # in network byte order

  ****************************************************************************/
 
 int    aarp_send_data(m, elapp, dest_at_addr, loop)
      register gbuf_t   *m;
      register at_ifaddr_t  *elapp;
  ****************************************************************************/
 
 int    aarp_send_data(m, elapp, dest_at_addr, loop)
      register gbuf_t   *m;
      register at_ifaddr_t  *elapp;

-     struct  atalk_addr           *dest_at_addr;
+     struct  atalk_addr           *dest_at_addr;       /* net# in network byte order */

      int               loop;                   /* if true, loopback broadcasts */
 {
        register aarp_amt_t     *amt_ptr;
        register at_ddp_t       *ddp_hdrp;
        int                     error;
      int               loop;                   /* if true, loopback broadcasts */
 {
        register aarp_amt_t     *amt_ptr;
        register at_ddp_t       *ddp_hdrp;
        int                     error;

-       int s;

        struct timeval timenow;
        getmicrouptime(&timenow);
 
        struct timeval timenow;
        getmicrouptime(&timenow);
 


@@ -452,22 +452,19 @@ int       aarp_send_data(m, elapp, dest_at_addr, loop)
                ddp_input(m, elapp);
                return(0);
        }
                ddp_input(m, elapp);
                return(0);
        }

-       ATDISABLE(s, arpinp_lock);

        AMT_LOOK(amt_ptr, *dest_at_addr, elapp);
 
 
        if (amt_ptr) {
        AMT_LOOK(amt_ptr, *dest_at_addr, elapp);
 
 
        if (amt_ptr) {

-               if (amt_ptr->m) {
+           if (amt_ptr->m) {

                        /*
                         * there's already a packet awaiting transmission, so
                         * drop this one and let the upper layer retransmit
                         * later.
                         */
                        /*
                         * there's already a packet awaiting transmission, so
                         * drop this one and let the upper layer retransmit
                         * later.
                         */

-                       ATENABLE(s, arpinp_lock);

                        gbuf_freel(m);
                        return (0);
                }
                        gbuf_freel(m);
                        return (0);
                }

-               ATENABLE(s, arpinp_lock);

                return (pat_output(elapp, m,
                                   (unsigned char *)&amt_ptr->dest_addr, 0));
         }
                return (pat_output(elapp, m,
                                   (unsigned char *)&amt_ptr->dest_addr, 0));
         }


@@ -479,7 +476,6 @@ int aarp_send_data(m, elapp, dest_at_addr, loop)
                gbuf_t               *newm = 0;
                struct  etalk_addr   *dest_addr;
 
                gbuf_t               *newm = 0;
                struct  etalk_addr   *dest_addr;
 

-               ATENABLE(s, arpinp_lock);

                dest_addr =  &elapp->cable_multicast_addr;
                if (loop)
                        newm = (gbuf_t *)gbuf_dupm(m);
                dest_addr =  &elapp->cable_multicast_addr;
                if (loop)
                        newm = (gbuf_t *)gbuf_dupm(m);


@@ -502,7 +498,7 @@ int aarp_send_data(m, elapp, dest_at_addr, loop)
                }
                return (error);
        }
                }
                return (error);
        }

-       NEW_AMT(amt_ptr, *dest_at_addr,elapp);
+       NEW_AMT(amt_ptr, *dest_at_addr, elapp)

 
         if (amt_ptr->m) {
                /*
 
         if (amt_ptr->m) {
                /*


@@ -510,7 +506,6 @@ int aarp_send_data(m, elapp, dest_at_addr, loop)
                 * drop this one and let the upper layer retransmit
                 * later.
                 */
                 * drop this one and let the upper layer retransmit
                 * later.
                 */

-               ATENABLE(s, arpinp_lock);

                gbuf_freel(m);
                return (0);
        }
                gbuf_freel(m);
                return (0);
        }


@@ -522,7 +517,6 @@ int aarp_send_data(m, elapp, dest_at_addr, loop)
        amt_ptr->m = m;
        amt_ptr->elapp = elapp;
        amt_ptr->no_of_retries = 0;
        amt_ptr->m = m;
        amt_ptr->elapp = elapp;
        amt_ptr->no_of_retries = 0;

-       ATENABLE(s, arpinp_lock);

 
        if ((error = aarp_send_req(amt_ptr))) {
                aarp_delete_amt_info(amt_ptr);
 
        if ((error = aarp_send_req(amt_ptr))) {
                aarp_delete_amt_info(amt_ptr);


@@ -558,7 +552,7 @@ StaticProc   int    aarp_send_resp(elapp, pkt)
        new_pkt = (aarp_pkt_t *)gbuf_rptr(m);
        aarp_build_pkt(new_pkt, elapp);
 
        new_pkt = (aarp_pkt_t *)gbuf_rptr(m);
        aarp_build_pkt(new_pkt, elapp);
 

-       new_pkt->aarp_cmd = AARP_RESP_CMD;
+       new_pkt->aarp_cmd = htons(AARP_RESP_CMD);

        new_pkt->dest_addr =  pkt->src_addr;
 
        new_pkt->dest_at_addr = pkt->src_at_addr;
        new_pkt->dest_addr =  pkt->src_addr;
 
        new_pkt->dest_at_addr = pkt->src_at_addr;


@@ -569,7 +563,7 @@ StaticProc   int    aarp_send_resp(elapp, pkt)
 
        gbuf_winc(m,sizeof(aarp_pkt_t));
        if (FDDI_OR_TOKENRING(elapp->aa_ifp->if_type))
 
        gbuf_winc(m,sizeof(aarp_pkt_t));
        if (FDDI_OR_TOKENRING(elapp->aa_ifp->if_type))

-               ddp_bit_reverse(&new_pkt->dest_addr);
+               ddp_bit_reverse((unsigned char *)&new_pkt->dest_addr);

 
        if (pat_output(elapp, m, (unsigned char *)&new_pkt->dest_addr,
                       AARP_AT_TYPE))
 
        if (pat_output(elapp, m, (unsigned char *)&new_pkt->dest_addr,
                       AARP_AT_TYPE))


@@ -600,7 +594,7 @@ register aarp_amt_t         *amt_ptr;
        pkt = (aarp_pkt_t *)gbuf_rptr(m);
        aarp_build_pkt(pkt, amt_ptr->elapp);
 
        pkt = (aarp_pkt_t *)gbuf_rptr(m);
        aarp_build_pkt(pkt, amt_ptr->elapp);
 

-       pkt->aarp_cmd = AARP_REQ_CMD;
+       pkt->aarp_cmd = htons(AARP_REQ_CMD);

        pkt->dest_addr = et_zeroaddr;
        pkt->dest_at_addr = amt_ptr->dest_at_addr;
        pkt->dest_at_addr.atalk_unused = 0;
        pkt->dest_addr = et_zeroaddr;
        pkt->dest_at_addr = amt_ptr->dest_at_addr;
        pkt->dest_at_addr.atalk_unused = 0;


@@ -629,7 +623,7 @@ register aarp_amt_t         *amt_ptr;
  * aarp_send_probe()
  *
  ****************************************************************************/
  * aarp_send_probe()
  *
  ****************************************************************************/

-StaticProc  int        aarp_send_probe()
+StaticProc  int        aarp_send_probe(void)

 {
        register aarp_pkt_t  *pkt;
        register gbuf_t      *m;
 {
        register aarp_pkt_t  *pkt;
        register gbuf_t      *m;


@@ -643,7 +637,7 @@ StaticProc  int     aarp_send_probe()
        pkt = (aarp_pkt_t *)gbuf_rptr(m);
        aarp_build_pkt(pkt, probe_cb.elapp);
 
        pkt = (aarp_pkt_t *)gbuf_rptr(m);
        aarp_build_pkt(pkt, probe_cb.elapp);
 

-       pkt->aarp_cmd = AARP_PROBE_CMD;
+       pkt->aarp_cmd = htons(AARP_PROBE_CMD);

        pkt->dest_addr = et_zeroaddr;
 
        ATALK_ASSIGN(pkt->src_at_addr, probe_cb.elapp->initial_addr.s_net,
        pkt->dest_addr = et_zeroaddr;
 
        ATALK_ASSIGN(pkt->src_at_addr, probe_cb.elapp->initial_addr.s_net,


@@ -701,9 +695,7 @@ register aarp_pkt_t *pkt;
 at_ifaddr_t    *elapp;
 {
     register aarp_amt_t   *amt_ptr;
 at_ifaddr_t    *elapp;
 {
     register aarp_amt_t   *amt_ptr;

-       int s;

 
 

-       ATDISABLE(s, arpinp_lock);

        AMT_LOOK(amt_ptr, pkt->src_at_addr, elapp);
 
        if (amt_ptr == NULL) {
        AMT_LOOK(amt_ptr, pkt->src_at_addr, elapp);
 
        if (amt_ptr == NULL) {


@@ -713,10 +705,7 @@ at_ifaddr_t        *elapp;
                NEW_AMT(amt_ptr, pkt->src_at_addr,elapp); 
 
                if (amt_ptr->m)
                NEW_AMT(amt_ptr, pkt->src_at_addr,elapp); 
 
                if (amt_ptr->m)

-               {
-               ATENABLE(s, arpinp_lock);
-                       return(0);     /* no non-busy slots available in the cache */
-               }
+                       return(0);     /* no non-busy slots available in the cache */

                amt_ptr->dest_at_addr = pkt->src_at_addr;
                amt_ptr->dest_at_addr.atalk_unused = 0;
 
                amt_ptr->dest_at_addr = pkt->src_at_addr;
                amt_ptr->dest_at_addr.atalk_unused = 0;
 


@@ -728,8 +717,7 @@ at_ifaddr_t *elapp;
         */
        amt_ptr->dest_addr = pkt->src_addr;
        if (FDDI_OR_TOKENRING(elapp->aa_ifp->if_type))
         */
        amt_ptr->dest_addr = pkt->src_addr;
        if (FDDI_OR_TOKENRING(elapp->aa_ifp->if_type))

-               ddp_bit_reverse(&amt_ptr->dest_addr);
-       ATENABLE(s, arpinp_lock);
+               ddp_bit_reverse((unsigned char *)&amt_ptr->dest_addr);

        return(1);
 }
 
        return(1);
 }
 


@@ -742,9 +730,7 @@ at_ifaddr_t *elapp;
 StaticProc   int       aarp_delete_amt_info(amt_ptr)
 register aarp_amt_t    *amt_ptr;
 {
 StaticProc   int       aarp_delete_amt_info(amt_ptr)
 register aarp_amt_t    *amt_ptr;
 {

-       register s;

        register gbuf_t         *m;
        register gbuf_t         *m;

-       ATDISABLE(s, arpinp_lock);

        amt_ptr->last_time = 0;
        ATALK_ASSIGN(amt_ptr->dest_at_addr, 0, 0, 0);
        amt_ptr->no_of_retries = 0;
        amt_ptr->last_time = 0;
        ATALK_ASSIGN(amt_ptr->dest_at_addr, 0, 0, 0);
        amt_ptr->no_of_retries = 0;


@@ -752,11 +738,8 @@ register aarp_amt_t        *amt_ptr;
        if (amt_ptr->m) {
            m = amt_ptr->m;
            amt_ptr->m = NULL;    
        if (amt_ptr->m) {
            m = amt_ptr->m;
            amt_ptr->m = NULL;    

-           ATENABLE(s, arpinp_lock);

            gbuf_freel(m);
            gbuf_freel(m);

-        }
-       else
-               ATENABLE(s, arpinp_lock);
+    }

        return(0);
 }
 
        return(0);
 }
 


@@ -767,7 +750,7 @@ register aarp_amt_t *amt_ptr;
  *
  ****************************************************************************/
 
  *
  ****************************************************************************/
 

-void  aarp_sched_probe(void *arg)
+void  aarp_sched_probe(__unused void *arg)

 {
 
        atalk_lock();
 {
 
        atalk_lock();


@@ -795,8 +778,8 @@ StaticProc void aarp_build_pkt(pkt, elapp)
      register aarp_pkt_t *pkt;
      at_ifaddr_t *elapp;
 {
      register aarp_pkt_t *pkt;
      at_ifaddr_t *elapp;
 {

-       pkt->hardware_type = AARP_ETHER_HW_TYPE;
-       pkt->stack_type = AARP_AT_PROTO;
+       pkt->hardware_type = htons(AARP_ETHER_HW_TYPE);
+       pkt->stack_type = htons(AARP_AT_PROTO);

        pkt->hw_addr_len = ETHERNET_ADDR_LEN;
        pkt->stack_addr_len = AARP_AT_ADDR_LEN;
        bcopy(elapp->xaddr, pkt->src_addr.etalk_addr_octet, sizeof(elapp->xaddr));
        pkt->hw_addr_len = ETHERNET_ADDR_LEN;
        pkt->stack_addr_len = AARP_AT_ADDR_LEN;
        bcopy(elapp->xaddr, pkt->src_addr.etalk_addr_octet, sizeof(elapp->xaddr));


@@ -812,7 +795,7 @@ StaticProc void aarp_build_pkt(pkt, elapp)
 StaticProc void        aarp_sched_req(arg)
      void *arg;
 {
 StaticProc void        aarp_sched_req(arg)
      void *arg;
 {

-       int s, i;
+       int i;

        aarp_amt_t *amt_ptr = (aarp_amt_t *)arg;
 
        atalk_lock();
        aarp_amt_t *amt_ptr = (aarp_amt_t *)arg;
 
        atalk_lock();


@@ -830,21 +813,16 @@ StaticProc void   aarp_sched_req(arg)
            /*
             * found match - pointer is valid
             */
            /*
             * found match - pointer is valid
             */

-           ATDISABLE(s, arpinp_lock);

            if (amt_ptr->tmo == 0) {
            if (amt_ptr->tmo == 0) {

-               ATENABLE(s, arpinp_lock);

                        atalk_unlock();
                return;
            }
            if (amt_ptr->no_of_retries < AARP_MAX_REQ_RETRIES) {
                        atalk_unlock();
                return;
            }
            if (amt_ptr->no_of_retries < AARP_MAX_REQ_RETRIES) {

-               ATENABLE(s, arpinp_lock);

                if (aarp_send_req(amt_ptr) == 0) {
                                atalk_unlock();
                    return;
                }
                if (aarp_send_req(amt_ptr) == 0) {
                                atalk_unlock();
                    return;
                }

-               ATDISABLE(s, arpinp_lock);

            }
            }

-           ATENABLE(s, arpinp_lock);

            aarp_delete_amt_info(amt_ptr);
            break;
        }       
            aarp_delete_amt_info(amt_ptr);
            break;
        }       


@@ -945,8 +923,8 @@ register at_ifaddr_t        *elapp;
 }
 
 
 }
 
 

-int getAarpTableSize(elapId)
-     int       elapId;                 /* elap_specifics array index (should be
+int getAarpTableSize(__unused int elapId)
+                       /* elap_specifics array index (should be

                                         * changed when we add a non-ethernet type
                                         * of I/F to the mix. Unused for now.
                                         */
                                         * changed when we add a non-ethernet type
                                         * of I/F to the mix. Unused for now.
                                         */


@@ -954,8 +932,8 @@ int getAarpTableSize(elapId)
        return(AMTSIZE);
 }
 
        return(AMTSIZE);
 }
 

-int getPhysAddrSize(elapId)
-     int       elapId;                 /* elap_specifics array index (should be
+int getPhysAddrSize(__unused int elapId)
+                       /* elap_specifics array index (should be

                                         * changed when we add a non-ethernet type
                                         * of I/F to the mix. Unused for now.
                                         */
                                         * changed when we add a non-ethernet type
                                         * of I/F to the mix. Unused for now.
                                         */


@@ -978,6 +956,8 @@ snmpAarpEnt_t *getAarp(elapId)
        aarp_amt_t *amtp;
        static snmpAarpEnt_t  snmp[AMTSIZE];
        snmpAarpEnt_t  *snmpp;
        aarp_amt_t *amtp;
        static snmpAarpEnt_t  snmp[AMTSIZE];
        snmpAarpEnt_t  *snmpp;

+       struct atalk_addr addr;
+       u_short  tmp_net;

 
 
        if (*elapId <0 || *elapId >= IF_TOTAL_MAX)
 
 
        if (*elapId <0 || *elapId >= IF_TOTAL_MAX)


@@ -994,7 +974,11 @@ snmpAarpEnt_t *getAarp(elapId)
                                 * & etalk_addr positions in the aarp_amt_t struct
                                 * has not changed and copy both at once
                                 */
                                 * & etalk_addr positions in the aarp_amt_t struct
                                 * has not changed and copy both at once
                                 */

-                       bcopy(&amtp->dest_at_addr, &snmpp->ap_ddpAddr, ENTRY_SIZE);
+                       addr.atalk_unused = 0;          
+                       tmp_net = UAS_VALUE(amtp->dest_at_addr.atalk_net);
+                       NET_ASSIGN(addr.atalk_net, tmp_net);
+                       addr.atalk_node = amtp->dest_at_addr.atalk_node;
+                       bcopy(&addr, &snmpp->ap_ddpAddr, ENTRY_SIZE);

                        snmpp++;
                        cnt++;
                        
                        snmpp++;
                        cnt++;