OpenCores
URL https://opencores.org/ocsvn/or1k/or1k/trunk

Subversion Repositories or1k

[/] [or1k/] [trunk/] [linux/] [linux-2.4/] [net/] [x25/] [x25_dev.c] - Diff between revs 1275 and 1765

Only display areas with differences | Details | Blame | View Log

Rev 1275 Rev 1765
/*
/*
 *      X.25 Packet Layer release 002
 *      X.25 Packet Layer release 002
 *
 *
 *      This is ALPHA test software. This code may break your machine, randomly fail to work with new
 *      This is ALPHA test software. This code may break your machine, randomly fail to work with new
 *      releases, misbehave and/or generally screw up. It might even work.
 *      releases, misbehave and/or generally screw up. It might even work.
 *
 *
 *      This code REQUIRES 2.1.15 or higher
 *      This code REQUIRES 2.1.15 or higher
 *
 *
 *      This module:
 *      This module:
 *              This module is free software; you can redistribute it and/or
 *              This module is free software; you can redistribute it and/or
 *              modify it under the terms of the GNU General Public License
 *              modify it under the terms of the GNU General Public License
 *              as published by the Free Software Foundation; either version
 *              as published by the Free Software Foundation; either version
 *              2 of the License, or (at your option) any later version.
 *              2 of the License, or (at your option) any later version.
 *
 *
 *      History
 *      History
 *      X.25 001        Jonathan Naylor Started coding.
 *      X.25 001        Jonathan Naylor Started coding.
 *      2000-09-04      Henner Eisen    Prevent freeing a dangling skb.
 *      2000-09-04      Henner Eisen    Prevent freeing a dangling skb.
 */
 */
 
 
#include <linux/config.h>
#include <linux/config.h>
#include <linux/errno.h>
#include <linux/errno.h>
#include <linux/types.h>
#include <linux/types.h>
#include <linux/socket.h>
#include <linux/socket.h>
#include <linux/in.h>
#include <linux/in.h>
#include <linux/kernel.h>
#include <linux/kernel.h>
#include <linux/sched.h>
#include <linux/sched.h>
#include <linux/timer.h>
#include <linux/timer.h>
#include <linux/string.h>
#include <linux/string.h>
#include <linux/sockios.h>
#include <linux/sockios.h>
#include <linux/net.h>
#include <linux/net.h>
#include <linux/stat.h>
#include <linux/stat.h>
#include <linux/inet.h>
#include <linux/inet.h>
#include <linux/netdevice.h>
#include <linux/netdevice.h>
#include <linux/skbuff.h>
#include <linux/skbuff.h>
#include <net/sock.h>
#include <net/sock.h>
#include <asm/segment.h>
#include <asm/segment.h>
#include <asm/system.h>
#include <asm/system.h>
#include <asm/uaccess.h>
#include <asm/uaccess.h>
#include <linux/fcntl.h>
#include <linux/fcntl.h>
#include <linux/termios.h>      /* For TIOCINQ/OUTQ */
#include <linux/termios.h>      /* For TIOCINQ/OUTQ */
#include <linux/mm.h>
#include <linux/mm.h>
#include <linux/interrupt.h>
#include <linux/interrupt.h>
#include <linux/notifier.h>
#include <linux/notifier.h>
#include <linux/proc_fs.h>
#include <linux/proc_fs.h>
#include <linux/if_arp.h>
#include <linux/if_arp.h>
#include <net/x25.h>
#include <net/x25.h>
 
 
static int x25_receive_data(struct sk_buff *skb, struct x25_neigh *neigh)
static int x25_receive_data(struct sk_buff *skb, struct x25_neigh *neigh)
{
{
        struct sock *sk;
        struct sock *sk;
        unsigned short frametype;
        unsigned short frametype;
        unsigned int lci;
        unsigned int lci;
 
 
        frametype = skb->data[2];
        frametype = skb->data[2];
        lci = ((skb->data[0] << 8) & 0xF00) + ((skb->data[1] << 0) & 0x0FF);
        lci = ((skb->data[0] << 8) & 0xF00) + ((skb->data[1] << 0) & 0x0FF);
 
 
        /*
        /*
         *      LCI of zero is always for us, and its always a link control
         *      LCI of zero is always for us, and its always a link control
         *      frame.
         *      frame.
         */
         */
        if (lci == 0) {
        if (lci == 0) {
                x25_link_control(skb, neigh, frametype);
                x25_link_control(skb, neigh, frametype);
                return 0;
                return 0;
        }
        }
 
 
        /*
        /*
         *      Find an existing socket.
         *      Find an existing socket.
         */
         */
        if ((sk = x25_find_socket(lci, neigh)) != NULL) {
        if ((sk = x25_find_socket(lci, neigh)) != NULL) {
                int queued = 1;
                int queued = 1;
 
 
                skb->h.raw = skb->data;
                skb->h.raw = skb->data;
                bh_lock_sock(sk);
                bh_lock_sock(sk);
                if (!sk->lock.users) {
                if (!sk->lock.users) {
                        queued = x25_process_rx_frame(sk, skb);
                        queued = x25_process_rx_frame(sk, skb);
                } else {
                } else {
                        sk_add_backlog(sk, skb);
                        sk_add_backlog(sk, skb);
                }
                }
                bh_unlock_sock(sk);
                bh_unlock_sock(sk);
                return queued;
                return queued;
        }
        }
 
 
        /*
        /*
         *      Is is a Call Request ? if so process it.
         *      Is is a Call Request ? if so process it.
         */
         */
        if (frametype == X25_CALL_REQUEST)
        if (frametype == X25_CALL_REQUEST)
                return x25_rx_call_request(skb, neigh, lci);
                return x25_rx_call_request(skb, neigh, lci);
 
 
        /*
        /*
         *      Its not a Call Request, nor is it a control frame.
         *      Its not a Call Request, nor is it a control frame.
         *      Let caller throw it away.
         *      Let caller throw it away.
         */
         */
/*
/*
        x25_transmit_clear_request(neigh, lci, 0x0D);
        x25_transmit_clear_request(neigh, lci, 0x0D);
*/
*/
        printk(KERN_DEBUG "x25_receive_data(): unknown frame type %2x\n",frametype);
        printk(KERN_DEBUG "x25_receive_data(): unknown frame type %2x\n",frametype);
 
 
        return 0;
        return 0;
}
}
 
 
int x25_lapb_receive_frame(struct sk_buff *skb, struct net_device *dev, struct packet_type *ptype)
int x25_lapb_receive_frame(struct sk_buff *skb, struct net_device *dev, struct packet_type *ptype)
{
{
        struct x25_neigh *neigh;
        struct x25_neigh *neigh;
        int queued;
        int queued;
 
 
        skb->sk = NULL;
        skb->sk = NULL;
 
 
        /*
        /*
         *      Packet received from unrecognised device, throw it away.
         *      Packet received from unrecognised device, throw it away.
         */
         */
        if ((neigh = x25_get_neigh(dev)) == NULL) {
        if ((neigh = x25_get_neigh(dev)) == NULL) {
                printk(KERN_DEBUG "X.25: unknown neighbour - %s\n", dev->name);
                printk(KERN_DEBUG "X.25: unknown neighbour - %s\n", dev->name);
                kfree_skb(skb);
                kfree_skb(skb);
                return 0;
                return 0;
        }
        }
 
 
        switch (skb->data[0]) {
        switch (skb->data[0]) {
                case 0x00:
                case 0x00:
                        skb_pull(skb, 1);
                        skb_pull(skb, 1);
                        queued = x25_receive_data(skb, neigh);
                        queued = x25_receive_data(skb, neigh);
                        if( ! queued )
                        if( ! queued )
                                /* We need to free the skb ourselves because
                                /* We need to free the skb ourselves because
                                 * net_bh() won't care about our return code.
                                 * net_bh() won't care about our return code.
                                 */
                                 */
                                kfree_skb(skb);
                                kfree_skb(skb);
                        return 0;
                        return 0;
 
 
                case 0x01:
                case 0x01:
                        x25_link_established(neigh);
                        x25_link_established(neigh);
                        kfree_skb(skb);
                        kfree_skb(skb);
                        return 0;
                        return 0;
 
 
                case 0x02:
                case 0x02:
                        x25_link_terminated(neigh);
                        x25_link_terminated(neigh);
                        kfree_skb(skb);
                        kfree_skb(skb);
                        return 0;
                        return 0;
 
 
                case 0x03:
                case 0x03:
                        kfree_skb(skb);
                        kfree_skb(skb);
                        return 0;
                        return 0;
 
 
                default:
                default:
                        kfree_skb(skb);
                        kfree_skb(skb);
                        return 0;
                        return 0;
        }
        }
}
}
 
 
int x25_llc_receive_frame(struct sk_buff *skb, struct net_device *dev, struct packet_type *ptype)
int x25_llc_receive_frame(struct sk_buff *skb, struct net_device *dev, struct packet_type *ptype)
{
{
        struct x25_neigh *neigh;
        struct x25_neigh *neigh;
 
 
        skb->sk = NULL;
        skb->sk = NULL;
 
 
        /*
        /*
         *      Packet received from unrecognised device, throw it away.
         *      Packet received from unrecognised device, throw it away.
         */
         */
        if ((neigh = x25_get_neigh(dev)) == NULL) {
        if ((neigh = x25_get_neigh(dev)) == NULL) {
                printk(KERN_DEBUG "X.25: unknown_neighbour - %s\n", dev->name);
                printk(KERN_DEBUG "X.25: unknown_neighbour - %s\n", dev->name);
                kfree_skb(skb);
                kfree_skb(skb);
                return 0;
                return 0;
        }
        }
 
 
        return x25_receive_data(skb, neigh);
        return x25_receive_data(skb, neigh);
}
}
 
 
void x25_establish_link(struct x25_neigh *neigh)
void x25_establish_link(struct x25_neigh *neigh)
{
{
        struct sk_buff *skb;
        struct sk_buff *skb;
        unsigned char *ptr;
        unsigned char *ptr;
 
 
        switch (neigh->dev->type) {
        switch (neigh->dev->type) {
                case ARPHRD_X25:
                case ARPHRD_X25:
                        if ((skb = alloc_skb(1, GFP_ATOMIC)) == NULL) {
                        if ((skb = alloc_skb(1, GFP_ATOMIC)) == NULL) {
                                printk(KERN_ERR "x25_dev: out of memory\n");
                                printk(KERN_ERR "x25_dev: out of memory\n");
                                return;
                                return;
                        }
                        }
                        ptr  = skb_put(skb, 1);
                        ptr  = skb_put(skb, 1);
                        *ptr = 0x01;
                        *ptr = 0x01;
                        break;
                        break;
 
 
#if defined(CONFIG_LLC) || defined(CONFIG_LLC_MODULE)
#if defined(CONFIG_LLC) || defined(CONFIG_LLC_MODULE)
                case ARPHRD_ETHER:
                case ARPHRD_ETHER:
                        return;
                        return;
#endif
#endif
                default:
                default:
                        return;
                        return;
        }
        }
 
 
        skb->protocol = htons(ETH_P_X25);
        skb->protocol = htons(ETH_P_X25);
        skb->dev      = neigh->dev;
        skb->dev      = neigh->dev;
 
 
        dev_queue_xmit(skb);
        dev_queue_xmit(skb);
}
}
 
 
void x25_terminate_link(struct x25_neigh *neigh)
void x25_terminate_link(struct x25_neigh *neigh)
{
{
        struct sk_buff *skb;
        struct sk_buff *skb;
        unsigned char *ptr;
        unsigned char *ptr;
 
 
        switch (neigh->dev->type) {
        switch (neigh->dev->type) {
                case ARPHRD_X25:
                case ARPHRD_X25:
                        if ((skb = alloc_skb(1, GFP_ATOMIC)) == NULL) {
                        if ((skb = alloc_skb(1, GFP_ATOMIC)) == NULL) {
                                printk(KERN_ERR "x25_dev: out of memory\n");
                                printk(KERN_ERR "x25_dev: out of memory\n");
                                return;
                                return;
                        }
                        }
                        ptr  = skb_put(skb, 1);
                        ptr  = skb_put(skb, 1);
                        *ptr = 0x02;
                        *ptr = 0x02;
                        break;
                        break;
 
 
#if defined(CONFIG_LLC) || defined(CONFIG_LLC_MODULE)
#if defined(CONFIG_LLC) || defined(CONFIG_LLC_MODULE)
                case ARPHRD_ETHER:
                case ARPHRD_ETHER:
                        return;
                        return;
#endif
#endif
                default:
                default:
                        return;
                        return;
        }
        }
 
 
        skb->protocol = htons(ETH_P_X25);
        skb->protocol = htons(ETH_P_X25);
        skb->dev      = neigh->dev;
        skb->dev      = neigh->dev;
 
 
        dev_queue_xmit(skb);
        dev_queue_xmit(skb);
}
}
 
 
void x25_send_frame(struct sk_buff *skb, struct x25_neigh *neigh)
void x25_send_frame(struct sk_buff *skb, struct x25_neigh *neigh)
{
{
        unsigned char *dptr;
        unsigned char *dptr;
 
 
        skb->nh.raw = skb->data;
        skb->nh.raw = skb->data;
 
 
        switch (neigh->dev->type) {
        switch (neigh->dev->type) {
                case ARPHRD_X25:
                case ARPHRD_X25:
                        dptr  = skb_push(skb, 1);
                        dptr  = skb_push(skb, 1);
                        *dptr = 0x00;
                        *dptr = 0x00;
                        break;
                        break;
 
 
#if defined(CONFIG_LLC) || defined(CONFIG_LLC_MODULE)
#if defined(CONFIG_LLC) || defined(CONFIG_LLC_MODULE)
                case ARPHRD_ETHER:
                case ARPHRD_ETHER:
                        kfree_skb(skb);
                        kfree_skb(skb);
                        return;
                        return;
#endif
#endif
                default:
                default:
                        kfree_skb(skb);
                        kfree_skb(skb);
                        return;
                        return;
        }
        }
 
 
        skb->protocol = htons(ETH_P_X25);
        skb->protocol = htons(ETH_P_X25);
        skb->dev      = neigh->dev;
        skb->dev      = neigh->dev;
 
 
        dev_queue_xmit(skb);
        dev_queue_xmit(skb);
}
}
 
 

powered by: WebSVN 2.1.0

© copyright 1999-2024 OpenCores.org, equivalent to Oliscience, all rights reserved. OpenCores®, registered trademark.