URL https://opencores.org/ocsvn/or1k/or1k/trunk
Subversion Repositories or1k

[/] [or1k/] [trunk/] [linux/] [linux-2.4/] [drivers/] [s390/] [net/] [netiucv.c] - Blame information for rev 1275

Go to most recent revision | Details | Compare with Previous | View Log

/*
 * $Id: netiucv.c,v 1.1.1.1 2004-04-15 02:05:58 phoenix Exp $
 *
 * IUCV network driver
 *
 * Copyright (C) 2001 IBM Deutschland Entwicklung GmbH, IBM Corporation
 * Author(s): Fritz Elfert (elfert@de.ibm.com, felfert@millenux.com)
 *
 * Documentation used:
 *  the source of the original IUCV driver by:
 *    Stefan Hegewald <hegewald@de.ibm.com>
 *    Hartmut Penner <hpenner@de.ibm.com>
 *    Denis Joseph Barrow (djbarrow@de.ibm.com,barrow_dj@yahoo.com)
 *    Martin Schwidefsky (schwidefsky@de.ibm.com)
 *    Alan Altmark (Alan_Altmark@us.ibm.com)  Sept. 2000
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2, or (at your option)
 * any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 *
 * RELEASE-TAG: IUCV network driver $Revision: 1.1.1.1 $
 *
 */
 
#include <linux/version.h>
#include <linux/module.h>
#include <linux/init.h>
#include <linux/kernel.h>
#include <linux/slab.h>
#include <linux/errno.h>
#include <linux/types.h>
#include <linux/interrupt.h>
#include <linux/timer.h>
#include <linux/sched.h>
 
#include <linux/signal.h>
#include <linux/string.h>
#include <linux/proc_fs.h>
 
#include <linux/ip.h>
#include <linux/if_arp.h>
#include <linux/tcp.h>
#include <linux/skbuff.h>
#include <linux/ctype.h>
#include <net/dst.h>
 
#include <asm/io.h>
#include <asm/bitops.h>
#include <asm/uaccess.h>
 
#include "iucv.h"
#include "fsm.h"
 
#undef DEBUG
 
#ifdef MODULE
MODULE_AUTHOR
    ("(C) 2001 IBM Corporation by Fritz Elfert (felfert@millenux.com)");
MODULE_DESCRIPTION ("Linux for S/390 IUCV network driver");
MODULE_PARM (iucv, "1s");
MODULE_PARM_DESC (iucv,
                  "Specify the initial remote userids for iucv0 .. iucvn:\n"
                  "iucv=userid0:userid1:...:useridN");
#endif
 
static char *iucv = "";
 
/**
 * compatibility stuff
 */
#if (LINUX_VERSION_CODE >= KERNEL_VERSION(2,3,0))
typedef struct net_device net_device;
#else
typedef struct device net_device;
#endif
 
 
/**
 * Per connection profiling data
 */
typedef struct connection_profile_t {
        unsigned long maxmulti;
        unsigned long maxcqueue;
        unsigned long doios_single;
        unsigned long doios_multi;
        unsigned long txlen;
        unsigned long tx_time;
        struct timeval send_stamp;
        unsigned long tx_pending;
        unsigned long tx_max_pending;
} connection_profile;
 
/**
 * Representation of one iucv connection
 */
typedef struct iucv_connection_t {
        struct iucv_connection_t *next;
        iucv_handle_t            handle;
        __u16                    pathid;
        struct sk_buff           *rx_buff;
        struct sk_buff           *tx_buff;
        struct sk_buff_head      collect_queue;
        struct sk_buff_head      commit_queue;
        spinlock_t               collect_lock;
        int                      collect_len;
        int                      max_buffsize;
        int                      flags;
        fsm_timer                timer;
        int                      retry;
        fsm_instance             *fsm;
        net_device               *netdev;
        connection_profile       prof;
        char                     userid[9];
} iucv_connection;
 
#define CONN_FLAGS_BUFSIZE_CHANGED 1
 
/**
 * Linked list of all connection structs.
 */
iucv_connection *connections;
 
/**
 * Representation of event-data for the
 * connection state machine.
 */
typedef struct iucv_event_t {
        iucv_connection *conn;
        void            *data;
} iucv_event;
 
/**
 * Private part of the network device structure
 */
typedef struct netiucv_priv_t {
        struct net_device_stats stats;
#if LINUX_VERSION_CODE >= 0x02032D
        unsigned long           tbusy;
#endif
        fsm_instance            *fsm;
        iucv_connection         *conn;
        struct proc_dir_entry   *proc_dentry;
        struct proc_dir_entry   *proc_stat_entry;
        struct proc_dir_entry   *proc_buffer_entry;
        struct proc_dir_entry   *proc_user_entry;
        int                     proc_registered;
} netiucv_priv;
 
/**
 * Link level header for a packet.
 */
typedef struct ll_header_t {
        __u16 next;
} ll_header;
 
#define NETIUCV_HDRLEN           (sizeof(ll_header))
#define NETIUCV_BUFSIZE_MAX      32768
#define NETIUCV_BUFSIZE_DEFAULT  NETIUCV_BUFSIZE_MAX
#define NETIUCV_MTU_MAX          (NETIUCV_BUFSIZE_MAX - NETIUCV_HDRLEN)
#define NETIUCV_MTU_DEFAULT      9216
#define NETIUCV_QUEUELEN_DEFAULT 50
#define NETIUCV_TIMEOUT_5SEC     5000
 
/**
 * Compatibility macros for busy handling
 * of network devices.
 */
#if LINUX_VERSION_CODE < 0x02032D
static __inline__ void netiucv_clear_busy(net_device *dev)
{
        clear_bit(0 ,(void *)&dev->tbusy);
        mark_bh(NET_BH);
}
 
static __inline__ int netiucv_test_and_set_busy(net_device *dev)
{
        return(test_and_set_bit(0, (void *)&dev->tbusy));
}
 
#define SET_DEVICE_START(device, value) dev->start = value
#else
static __inline__ void netiucv_clear_busy(net_device *dev)
{
        clear_bit(0, &(((netiucv_priv *)dev->priv)->tbusy));
        netif_wake_queue(dev);
}
 
static __inline__ int netiucv_test_and_set_busy(net_device *dev)
{
        netif_stop_queue(dev);
        return test_and_set_bit(0, &((netiucv_priv *)dev->priv)->tbusy);
}
 
#define SET_DEVICE_START(device, value)
#endif
 
#if LINUX_VERSION_CODE < 0x020400
#  define dev_kfree_skb_irq(a) dev_kfree_skb(a)
#endif
 
__u8 iucv_host[8] = { 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00 };
__u8 iucvMagic[16] = {
        0xF0, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40,
        0xF0, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40
};
 
/**
 * This mask means the 16-byte IUCV "magic" and the origin userid must
 * match exactly as specified in order to give connection_pending()
 * control.
 */
__u8 mask[] = {
        0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff,
        0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff,
        0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff, 0xff
};
 
/**
 * Convert an iucv userId to its printable
 * form (strip whitespace at end).
 *
 * @param An iucv userId
 *
 * @returns The printable string (static data!!)
 */
static __inline__ char *
netiucv_printname(char *name)
{
        static char tmp[9];
        char *p = tmp;
        memcpy(tmp, name, 8);
        tmp[8] = '\0';
        while (*p && (!isspace(*p)))
                p++;
        *p = '\0';
        return tmp;
}
 
/**
 * States of the interface statemachine.
 */
enum dev_states {
        DEV_STATE_STOPPED,
        DEV_STATE_STARTWAIT,
        DEV_STATE_STOPWAIT,
        DEV_STATE_RUNNING,
        /**
         * MUST be always the last element!!
         */
        NR_DEV_STATES
};
 
static const char *dev_state_names[] = {
        "Stopped",
        "StartWait",
        "StopWait",
        "Running",
};
 
/**
 * Events of the interface statemachine.
 */
enum dev_events {
        DEV_EVENT_START,
        DEV_EVENT_STOP,
        DEV_EVENT_CONUP,
        DEV_EVENT_CONDOWN,
        /**
         * MUST be always the last element!!
         */
        NR_DEV_EVENTS
};
 
static const char *dev_event_names[] = {
        "Start",
        "Stop",
        "Connection up",
        "Connection down",
};
 
/**
 * Events of the connection statemachine
 */
enum conn_events {
        /**
         * Events, representing callbacks from
         * lowlevel iucv layer)
         */
        CONN_EVENT_CONN_REQ,
        CONN_EVENT_CONN_ACK,
        CONN_EVENT_CONN_REJ,
        CONN_EVENT_CONN_SUS,
        CONN_EVENT_CONN_RES,
        CONN_EVENT_RX,
        CONN_EVENT_TXDONE,
 
        /**
         * Events, representing errors return codes from
         * calls to lowlevel iucv layer
         */
 
        /**
         * Event, representing timer expiry.
         */
        CONN_EVENT_TIMER,
 
        /**
         * Events, representing commands from upper levels.
         */
        CONN_EVENT_START,
        CONN_EVENT_STOP,
 
        /**
         * MUST be always the last element!!
         */
        NR_CONN_EVENTS,
};
 
static const char *conn_event_names[] = {
        "Remote connection request",
        "Remote connection acknowledge",
        "Remote connection reject",
        "Connection suspended",
        "Connection resumed",
        "Data received",
        "Data sent",
 
        "Timer",
 
        "Start",
        "Stop",
};
 
/**
 * States of the connection statemachine.
 */
enum conn_states {
        /**
         * Connection not assigned to any device,
         * initial state, invalid
         */
        CONN_STATE_INVALID,
 
        /**
         * Userid assigned but not operating
         */
        CONN_STATE_STOPPED,
 
        /**
         * Connection registered,
         * no connection request sent yet,
         * no connection request received
         */
        CONN_STATE_STARTWAIT,
 
        /**
         * Connection registered and connection request sent,
         * no acknowledge and no connection request received yet.
         */
        CONN_STATE_SETUPWAIT,
 
        /**
         * Connection up and running idle
         */
        CONN_STATE_IDLE,
 
        /**
         * Data sent, awaiting CONN_EVENT_TXDONE
         */
        CONN_STATE_TX,
 
        /**
         * Terminating
         */
        CONN_STATE_TERM,
 
        /**
         * Error during registration.
         */
        CONN_STATE_REGERR,
 
        /**
         * Error during registration.
         */
        CONN_STATE_CONNERR,
 
        /**
         * MUST be always the last element!!
         */
        NR_CONN_STATES,
};
 
static const char *conn_state_names[] = {
        "Invalid",
        "Stopped",
        "StartWait",
        "SetupWait",
        "Idle",
        "TX",
        "Terminating",
        "Registration error",
        "Connect error",
};
 
 
/**
 * Callback-wrappers, called from lowlevel iucv layer.
 *****************************************************************************/
 
static void
netiucv_callback_rx(iucv_MessagePending *eib, void *pgm_data)
{
        iucv_connection *conn = (iucv_connection *)pgm_data;
        iucv_event ev;
 
        ev.conn = conn;
        ev.data = (void *)eib;
 
        fsm_event(conn->fsm, CONN_EVENT_RX, &ev);
}
 
static void
netiucv_callback_txdone(iucv_MessageComplete *eib, void *pgm_data)
{
        iucv_connection *conn = (iucv_connection *)pgm_data;
        iucv_event ev;
 
        ev.conn = conn;
        ev.data = (void *)eib;
        fsm_event(conn->fsm, CONN_EVENT_TXDONE, &ev);
}
 
static void
netiucv_callback_connack(iucv_ConnectionComplete *eib, void *pgm_data)
{
        iucv_connection *conn = (iucv_connection *)pgm_data;
        iucv_event ev;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
 
        ev.conn = conn;
        ev.data = (void *)eib;
        fsm_event(conn->fsm, CONN_EVENT_CONN_ACK, &ev);
}
 
static void
netiucv_callback_connreq(iucv_ConnectionPending *eib, void *pgm_data)
{
        iucv_connection *conn = (iucv_connection *)pgm_data;
        iucv_event ev;
 
        ev.conn = conn;
        ev.data = (void *)eib;
        fsm_event(conn->fsm, CONN_EVENT_CONN_REQ, &ev);
}
 
static void
netiucv_callback_connrej(iucv_ConnectionSevered *eib, void *pgm_data)
{
        iucv_connection *conn = (iucv_connection *)pgm_data;
        iucv_event ev;
 
        ev.conn = conn;
        ev.data = (void *)eib;
        fsm_event(conn->fsm, CONN_EVENT_CONN_REJ, &ev);
}
 
static void
netiucv_callback_connsusp(iucv_ConnectionQuiesced *eib, void *pgm_data)
{
        iucv_connection *conn = (iucv_connection *)pgm_data;
        iucv_event ev;
 
        ev.conn = conn;
        ev.data = (void *)eib;
        fsm_event(conn->fsm, CONN_EVENT_CONN_SUS, &ev);
}
 
static void
netiucv_callback_connres(iucv_ConnectionResumed *eib, void *pgm_data)
{
        iucv_connection *conn = (iucv_connection *)pgm_data;
        iucv_event ev;
 
        ev.conn = conn;
        ev.data = (void *)eib;
        fsm_event(conn->fsm, CONN_EVENT_CONN_RES, &ev);
}
 
static iucv_interrupt_ops_t netiucv_ops = {
        ConnectionPending:  netiucv_callback_connreq,
        ConnectionComplete: netiucv_callback_connack,
        ConnectionSevered:  netiucv_callback_connrej,
        ConnectionQuiesced: netiucv_callback_connsusp,
        ConnectionResumed:  netiucv_callback_connres,
        MessagePending:     netiucv_callback_rx,
        MessageComplete:    netiucv_callback_txdone
};
 
/**
 * Dummy NOP action for all statemachines
 */
static void
fsm_action_nop(fsm_instance *fi, int event, void *arg)
{
}
 
/**
 * Actions of the connection statemachine
 *****************************************************************************/
 
/**
 * Helper function for conn_action_rx()
 * Unpack a just received skb and hand it over to
 * upper layers.
 *
 * @param conn The connection where this skb has been received.
 * @param pskb The received skb.
 */
//static __inline__ void
static void
netiucv_unpack_skb(iucv_connection *conn, struct sk_buff *pskb)
{
        net_device     *dev = conn->netdev;
        netiucv_priv   *privptr = (netiucv_priv *)dev->priv;
        __u16          offset = 0;
 
        skb_put(pskb, NETIUCV_HDRLEN);
        pskb->dev = dev;
        pskb->ip_summed = CHECKSUM_NONE;
        pskb->protocol = ntohs(ETH_P_IP);
 
        while (1) {
                struct sk_buff *skb;
                ll_header *header = (ll_header *)pskb->data;
 
                if (header->next == 0)
                        break;
 
                skb_pull(pskb, NETIUCV_HDRLEN);
                header->next -= offset;
                offset += header->next;
                header->next -= NETIUCV_HDRLEN;
                if (skb_tailroom(pskb) < header->next) {
                        printk(KERN_WARNING
                               "%s: Illegal next field in iucv header: %d > %d\n",
                               dev->name, header->next, skb_tailroom(pskb));
                        return;
                }
                skb_put(pskb, header->next);
                pskb->mac.raw = pskb->data;
                skb = dev_alloc_skb(pskb->len);
                if (!skb) {
                        printk(KERN_WARNING
                               "%s Out of memory in netiucv_unpack_skb\n",
                               dev->name);
                        privptr->stats.rx_dropped++;
                        return;
                }
                memcpy(skb_put(skb, pskb->len), pskb->data, pskb->len);
                skb->mac.raw = skb->data;
                skb->dev = pskb->dev;
                skb->protocol = pskb->protocol;
                pskb->ip_summed = CHECKSUM_UNNECESSARY;
                netif_rx(skb);
                privptr->stats.rx_packets++;
                privptr->stats.rx_bytes += skb->len;
                skb_pull(pskb, header->next);
                skb_put(pskb, NETIUCV_HDRLEN);
        }
}
 
static void
conn_action_rx(fsm_instance *fi, int event, void *arg)
{
        iucv_event *ev = (iucv_event *)arg;
        iucv_connection *conn = ev->conn;
        iucv_MessagePending *eib = (iucv_MessagePending *)ev->data;
        netiucv_priv *privptr = (netiucv_priv *)conn->netdev->priv;
 
        __u16 msglen = eib->ln1msg2.ipbfln1f;
        int rc;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        if (!conn->netdev) {
                /* FRITZ: How to tell iucv LL to drop the msg? */
                printk(KERN_WARNING
                       "Received data for unlinked connection\n");
                return;
        }
        if (msglen > conn->max_buffsize) {
                /* FRITZ: How to tell iucv LL to drop the msg? */
                privptr->stats.rx_dropped++;
                return;
        }
        conn->rx_buff->data = conn->rx_buff->tail = conn->rx_buff->head;
        conn->rx_buff->len = 0;
        rc = iucv_receive(conn->pathid, eib->ipmsgid, eib->iptrgcls,
                          conn->rx_buff->data, msglen, NULL, NULL, NULL);
        if (rc != 0 || msglen < 5) {
                privptr->stats.rx_errors++;
                return;
        }
        netiucv_unpack_skb(conn, conn->rx_buff);
}
 
static void
conn_action_txdone(fsm_instance *fi, int event, void *arg)
{
        iucv_event *ev = (iucv_event *)arg;
        iucv_connection *conn = ev->conn;
        iucv_MessageComplete *eib = (iucv_MessageComplete *)ev->data;
        netiucv_priv *privptr = NULL;
                                 /* Shut up, gcc! skb is always below 2G. */
        __u32 single_flag = eib->ipmsgtag;
        __u32 txbytes = 0;
        __u32 txpackets = 0;
        __u32 stat_maxcq = 0;
        struct sk_buff *skb;
        unsigned long saveflags;
        ll_header header;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        fsm_deltimer(&conn->timer);
        if (conn && conn->netdev && conn->netdev->priv)
                privptr = (netiucv_priv *)conn->netdev->priv;
        conn->prof.tx_pending--;
        if (single_flag) {
                if ((skb = skb_dequeue(&conn->commit_queue))) {
                        atomic_dec(&skb->users);
                        dev_kfree_skb_any(skb);
                }
                if (privptr) {
                        privptr->stats.tx_packets++;
                        privptr->stats.tx_bytes +=
                                (skb->len - NETIUCV_HDRLEN - NETIUCV_HDRLEN);
                }
        }
        conn->tx_buff->data = conn->tx_buff->tail = conn->tx_buff->head;
        conn->tx_buff->len = 0;
        spin_lock_irqsave(&conn->collect_lock, saveflags);
        while ((skb = skb_dequeue(&conn->collect_queue))) {
                header.next = conn->tx_buff->len + skb->len + NETIUCV_HDRLEN;
                memcpy(skb_put(conn->tx_buff, NETIUCV_HDRLEN), &header,
                       NETIUCV_HDRLEN);
                memcpy(skb_put(conn->tx_buff, skb->len), skb->data, skb->len);
                txbytes += skb->len;
                txpackets++;
                stat_maxcq++;
                atomic_dec(&skb->users);
                dev_kfree_skb_any(skb);
        }
        if (conn->collect_len > conn->prof.maxmulti)
                conn->prof.maxmulti = conn->collect_len;
        conn->collect_len = 0;
        spin_unlock_irqrestore(&conn->collect_lock, saveflags);
        if (conn->tx_buff->len) {
                int rc;
 
                header.next = 0;
                memcpy(skb_put(conn->tx_buff, NETIUCV_HDRLEN), &header,
                       NETIUCV_HDRLEN);
 
                fsm_addtimer(&conn->timer, NETIUCV_TIMEOUT_5SEC,
                             CONN_EVENT_TIMER, conn);
                conn->prof.send_stamp = xtime;
                rc = iucv_send(conn->pathid, NULL, 0, 0, 0, 0,
                               conn->tx_buff->data, conn->tx_buff->len);
                conn->prof.doios_multi++;
                conn->prof.txlen += conn->tx_buff->len;
                conn->prof.tx_pending++;
                if (conn->prof.tx_pending > conn->prof.tx_max_pending)
                        conn->prof.tx_max_pending = conn->prof.tx_pending;
                if (rc != 0) {
                        fsm_deltimer(&conn->timer);
                        conn->prof.tx_pending--;
                        fsm_newstate(fi, CONN_STATE_IDLE);
                        if (privptr)
                                privptr->stats.tx_errors += txpackets;
                        printk(KERN_DEBUG "iucv_send returned %08x\n",
                               rc);
                } else {
                        if (privptr) {
                                privptr->stats.tx_packets += txpackets;
                                privptr->stats.tx_bytes += txbytes;
                        }
                        if (stat_maxcq > conn->prof.maxcqueue)
                                conn->prof.maxcqueue = stat_maxcq;
                }
        } else
                fsm_newstate(fi, CONN_STATE_IDLE);
}
 
static void
conn_action_connaccept(fsm_instance *fi, int event, void *arg)
{
        iucv_event *ev = (iucv_event *)arg;
        iucv_connection *conn = ev->conn;
        iucv_ConnectionPending *eib = (iucv_ConnectionPending *)ev->data;
        net_device *netdev = conn->netdev;
        netiucv_priv *privptr = (netiucv_priv *)netdev->priv;
        int rc;
        __u16 msglimit;
        __u8 udata[16];
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        rc = iucv_accept(eib->ippathid, NETIUCV_QUEUELEN_DEFAULT, udata, 0,
                         conn->handle, conn, NULL, &msglimit);
        if (rc != 0) {
                printk(KERN_WARNING
                       "%s: IUCV accept failed with error %d\n",
                       netdev->name, rc);
                return;
        }
        fsm_newstate(fi, CONN_STATE_IDLE);
        conn->pathid = eib->ippathid;
        netdev->tx_queue_len = msglimit;
        fsm_event(privptr->fsm, DEV_EVENT_CONUP, netdev);
}
 
static void
conn_action_connreject(fsm_instance *fi, int event, void *arg)
{
        iucv_event *ev = (iucv_event *)arg;
        // iucv_connection *conn = ev->conn;
        iucv_ConnectionPending *eib = (iucv_ConnectionPending *)ev->data;
        __u8 udata[16];
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        iucv_sever(eib->ippathid, udata);
}
 
static void
conn_action_connack(fsm_instance *fi, int event, void *arg)
{
        iucv_event *ev = (iucv_event *)arg;
        iucv_connection *conn = ev->conn;
        iucv_ConnectionComplete *eib = (iucv_ConnectionComplete *)ev->data;
        net_device *netdev = conn->netdev;
        netiucv_priv *privptr = (netiucv_priv *)netdev->priv;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        fsm_newstate(fi, CONN_STATE_IDLE);
        conn->pathid = eib->ippathid;
        netdev->tx_queue_len = eib->ipmsglim;
        fsm_event(privptr->fsm, DEV_EVENT_CONUP, netdev);
}
 
static void
conn_action_connsever(fsm_instance *fi, int event, void *arg)
{
        iucv_event *ev = (iucv_event *)arg;
        iucv_connection *conn = ev->conn;
        // iucv_ConnectionSevered *eib = (iucv_ConnectionSevered *)ev->data;
        net_device *netdev = conn->netdev;
        netiucv_priv *privptr = (netiucv_priv *)netdev->priv;
        int state = fsm_getstate(fi);
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        switch (state) {
                case CONN_STATE_SETUPWAIT:
                        printk(KERN_INFO "%s: Remote dropped connection\n",
                               netdev->name);
                        conn->handle = 0;
                        fsm_newstate(fi, CONN_STATE_STOPPED);
                        fsm_event(privptr->fsm, DEV_EVENT_CONDOWN, netdev);
                        break;
                case CONN_STATE_IDLE:
                case CONN_STATE_TX:
                        printk(KERN_INFO "%s: Remote dropped connection\n",
                               netdev->name);
                        if (conn->handle)
                                iucv_unregister_program(conn->handle);
                        conn->handle = 0;
                        fsm_newstate(fi, CONN_STATE_STOPPED);
                        fsm_event(privptr->fsm, DEV_EVENT_CONDOWN, netdev);
                        break;
        }
}
 
static void
conn_action_start(fsm_instance *fi, int event, void *arg)
{
        iucv_event *ev = (iucv_event *)arg;
        iucv_connection *conn = ev->conn;
 
        int rc;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        if (conn->handle == 0) {
                conn->handle =
                        iucv_register_program(iucvMagic, conn->userid, mask,
                                              &netiucv_ops, conn);
                fsm_newstate(fi, CONN_STATE_STARTWAIT);
                if (conn->handle <= 0) {
                        fsm_newstate(fi, CONN_STATE_REGERR);
                        conn->handle = 0;
                        return;
                }
#ifdef DEBUG
                printk(KERN_DEBUG "%s('%s'): registered successfully\n",
                       conn->netdev->name, conn->userid);
#endif
        }
#ifdef DEBUG
        printk(KERN_DEBUG "%s('%s'): connecting ...\n",
               conn->netdev->name, conn->userid);
#endif
 
        /* We must set the state before calling iucv_connect because the callback
         * handler could be called at any point after the connection request is
         * sent. */
 
        fsm_newstate(fi, CONN_STATE_SETUPWAIT);
        rc = iucv_connect(&(conn->pathid), NETIUCV_QUEUELEN_DEFAULT, iucvMagic,
                          conn->userid, iucv_host, 0, NULL, NULL, conn->handle,
                          conn);
        switch (rc) {
                case 0:
                        return;
                case 11:
                        printk(KERN_NOTICE
                               "%s: User %s is currently not available.\n",
                               conn->netdev->name,
                               netiucv_printname(conn->userid));
                        fsm_newstate(fi, CONN_STATE_STARTWAIT);
                        return;
                case 12:
                        printk(KERN_NOTICE
                               "%s: User %s is currently not ready.\n",
                               conn->netdev->name,
                               netiucv_printname(conn->userid));
                        fsm_newstate(fi, CONN_STATE_STARTWAIT);
                        return;
                case 13:
                        printk(KERN_WARNING
                               "%s: Too many IUCV connections.\n",
                               conn->netdev->name);
                        fsm_newstate(fi, CONN_STATE_CONNERR);
                        break;
                case 14:
                        printk(KERN_WARNING
                               "%s: User %s has too many IUCV connections.\n",
                               conn->netdev->name,
                               netiucv_printname(conn->userid));
                        fsm_newstate(fi, CONN_STATE_CONNERR);
                        break;
                case 15:
                        printk(KERN_WARNING
                               "%s: No IUCV authorization in CP directory.\n",
                               conn->netdev->name);
                        fsm_newstate(fi, CONN_STATE_CONNERR);
                        break;
                default:
                        printk(KERN_WARNING
                               "%s: iucv_connect returned error %d\n",
                               conn->netdev->name, rc);
                        fsm_newstate(fi, CONN_STATE_CONNERR);
                        break;
        }
        iucv_unregister_program(conn->handle);
        conn->handle = 0;
}
 
static void
netiucv_purge_skb_queue(struct sk_buff_head *q)
{
        struct sk_buff *skb;
 
        while ((skb = skb_dequeue(q))) {
                atomic_dec(&skb->users);
                dev_kfree_skb_any(skb);
        }
}
 
static void
conn_action_stop(fsm_instance *fi, int event, void *arg)
{
        iucv_event *ev = (iucv_event *)arg;
        iucv_connection *conn = ev->conn;
        net_device *netdev = conn->netdev;
        netiucv_priv *privptr = (netiucv_priv *)netdev->priv;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        fsm_newstate(fi, CONN_STATE_STOPPED);
        netiucv_purge_skb_queue(&conn->collect_queue);
        if (conn->handle)
                iucv_unregister_program(conn->handle);
        conn->handle = 0;
        netiucv_purge_skb_queue(&conn->commit_queue);
        fsm_event(privptr->fsm, DEV_EVENT_CONDOWN, netdev);
}
 
static void
conn_action_inval(fsm_instance *fi, int event, void *arg)
{
        iucv_event *ev = (iucv_event *)arg;
        iucv_connection *conn = ev->conn;
        net_device *netdev = conn->netdev;
 
        printk(KERN_WARNING
               "%s: Cannot connect without username\n",
               netdev->name);
}
 
static const fsm_node conn_fsm[] = {
        { CONN_STATE_INVALID,   CONN_EVENT_START,    conn_action_inval      },
        { CONN_STATE_STOPPED,   CONN_EVENT_START,    conn_action_start      },
        { CONN_STATE_STARTWAIT, CONN_EVENT_START,    conn_action_start      },
 
        { CONN_STATE_STARTWAIT, CONN_EVENT_STOP,     conn_action_stop       },
        { CONN_STATE_SETUPWAIT, CONN_EVENT_STOP,     conn_action_stop       },
        { CONN_STATE_IDLE,      CONN_EVENT_STOP,     conn_action_stop       },
        { CONN_STATE_TX,        CONN_EVENT_STOP,     conn_action_stop       },
        { CONN_STATE_REGERR,    CONN_EVENT_STOP,     conn_action_stop       },
        { CONN_STATE_CONNERR,   CONN_EVENT_STOP,     conn_action_stop       },
 
        { CONN_STATE_STOPPED,   CONN_EVENT_CONN_REQ, conn_action_connreject },
        { CONN_STATE_STARTWAIT, CONN_EVENT_CONN_REQ, conn_action_connaccept },
        { CONN_STATE_SETUPWAIT, CONN_EVENT_CONN_REQ, conn_action_connaccept },
        { CONN_STATE_IDLE,      CONN_EVENT_CONN_REQ, conn_action_connreject },
        { CONN_STATE_TX,        CONN_EVENT_CONN_REQ, conn_action_connreject },
 
        { CONN_STATE_SETUPWAIT, CONN_EVENT_CONN_ACK, conn_action_connack    },
 
        { CONN_STATE_SETUPWAIT, CONN_EVENT_CONN_REJ, conn_action_connsever  },
        { CONN_STATE_IDLE,      CONN_EVENT_CONN_REJ, conn_action_connsever  },
        { CONN_STATE_TX,        CONN_EVENT_CONN_REJ, conn_action_connsever  },
 
        { CONN_STATE_IDLE,      CONN_EVENT_RX,       conn_action_rx         },
        { CONN_STATE_TX,        CONN_EVENT_RX,       conn_action_rx         },
 
        { CONN_STATE_TX,        CONN_EVENT_TXDONE,   conn_action_txdone     },
        { CONN_STATE_IDLE,      CONN_EVENT_TXDONE,   conn_action_txdone     },
};
 
static const int CONN_FSM_LEN = sizeof(conn_fsm) / sizeof(fsm_node);
 
 
/**
 * Actions for interface - statemachine.
 *****************************************************************************/
 
/**
 * Startup connection by sending CONN_EVENT_START to it.
 *
 * @param fi    An instance of an interface statemachine.
 * @param event The event, just happened.
 * @param arg   Generic pointer, casted from net_device * upon call.
 */
static void
dev_action_start(fsm_instance *fi, int event, void *arg)
{
        net_device   *dev = (net_device *)arg;
        netiucv_priv *privptr = dev->priv;
        iucv_event   ev;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        ev.conn = privptr->conn;
        fsm_newstate(fi, DEV_STATE_STARTWAIT);
        fsm_event(privptr->conn->fsm, CONN_EVENT_START, &ev);
}
 
/**
 * Shutdown connection by sending CONN_EVENT_STOP to it.
 *
 * @param fi    An instance of an interface statemachine.
 * @param event The event, just happened.
 * @param arg   Generic pointer, casted from net_device * upon call.
 */
static void
dev_action_stop(fsm_instance *fi, int event, void *arg)
{
        net_device   *dev = (net_device *)arg;
        netiucv_priv *privptr = dev->priv;
        iucv_event   ev;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        ev.conn = privptr->conn;
 
        fsm_newstate(fi, DEV_STATE_STOPWAIT);
        fsm_event(privptr->conn->fsm, CONN_EVENT_STOP, &ev);
}
 
/**
 * Called from connection statemachine
 * when a connection is up and running.
 *
 * @param fi    An instance of an interface statemachine.
 * @param event The event, just happened.
 * @param arg   Generic pointer, casted from net_device * upon call.
 */
static void
dev_action_connup(fsm_instance *fi, int event, void *arg)
{
        net_device   *dev = (net_device *)arg;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        switch (fsm_getstate(fi)) {
                case DEV_STATE_STARTWAIT:
                        fsm_newstate(fi, DEV_STATE_RUNNING);
                        printk(KERN_INFO
                               "%s: connected with remote side\n",
                               dev->name);
                        break;
                case DEV_STATE_STOPWAIT:
                        printk(KERN_INFO
                               "%s: got connection UP event during shutdown!!\n",
                               dev->name);
                        break;
        }
}
 
/**
 * Called from connection statemachine
 * when a connection has been shutdown.
 *
 * @param fi    An instance of an interface statemachine.
 * @param event The event, just happened.
 * @param arg   Generic pointer, casted from net_device * upon call.
 */
static void
dev_action_conndown(fsm_instance *fi, int event, void *arg)
{
        net_device   *dev = (net_device *)arg;
        netiucv_priv *privptr = dev->priv;
        iucv_event   ev;
 
#ifdef DEBUG
        printk(KERN_DEBUG "%s() called\n", __FUNCTION__);
#endif
        switch (fsm_getstate(fi)) {
                case DEV_STATE_RUNNING:
                        fsm_newstate(fi, DEV_STATE_STARTWAIT);
                        ev.conn = privptr->conn;
                        fsm_event(privptr->conn->fsm, CONN_EVENT_START, &ev);
                        break;
                case DEV_STATE_STARTWAIT:
                        break;
                case DEV_STATE_STOPWAIT:
                        fsm_newstate(fi, DEV_STATE_STOPPED);
                        break;
        }
}
 
static const fsm_node dev_fsm[] = {
        { DEV_STATE_STOPPED,   DEV_EVENT_START,   dev_action_start    },
 
        { DEV_STATE_STOPWAIT,  DEV_EVENT_START,   dev_action_start    },
        { DEV_STATE_STOPWAIT,  DEV_EVENT_CONDOWN, dev_action_conndown },
 
        { DEV_STATE_STARTWAIT, DEV_EVENT_STOP,    dev_action_stop     },
        { DEV_STATE_STARTWAIT, DEV_EVENT_CONUP,   dev_action_connup   },
        { DEV_STATE_STARTWAIT, DEV_EVENT_CONDOWN, dev_action_conndown },
 
        { DEV_STATE_RUNNING,   DEV_EVENT_STOP,    dev_action_stop     },
        { DEV_STATE_RUNNING,   DEV_EVENT_CONDOWN, dev_action_conndown },
        { DEV_STATE_RUNNING,   DEV_EVENT_CONUP,   fsm_action_nop      },
};
 
static const int DEV_FSM_LEN = sizeof(dev_fsm) / sizeof(fsm_node);
 
/**
 * Transmit a packet.
 * This is a helper function for netiucv_tx().
 *
 * @param conn Connection to be used for sending.
 * @param skb Pointer to struct sk_buff of packet to send.
 *            The linklevel header has already been set up
 *            by netiucv_tx().
 *
 * @return 0 on success, -ERRNO on failure. (Never fails.)
 */
static int
netiucv_transmit_skb(iucv_connection *conn, struct sk_buff *skb) {
        unsigned long saveflags;
        ll_header header;
        int       rc = 0;
 
        if (fsm_getstate(conn->fsm) != CONN_STATE_IDLE) {
                int l = skb->len + NETIUCV_HDRLEN;
 
                spin_lock_irqsave(&conn->collect_lock, saveflags);
                if (conn->collect_len + l >
                    (conn->max_buffsize - NETIUCV_HDRLEN))
                        rc = -EBUSY;
                else {
                        atomic_inc(&skb->users);
                        skb_queue_tail(&conn->collect_queue, skb);
                        conn->collect_len += l;
                }
                spin_unlock_irqrestore(&conn->collect_lock, saveflags);
        } else {
                struct sk_buff *nskb = skb;
                /**
                 * Copy the skb to a new allocated skb in lowmem only if the
                 * data is located above 2G in memory or tailroom is < 2.
                 */
                unsigned long hi =
                        ((unsigned long)(skb->tail + NETIUCV_HDRLEN)) >> 31;
                int copied = 0;
                if (hi || (skb_tailroom(skb) < 2)) {
                        nskb = alloc_skb(skb->len + NETIUCV_HDRLEN +
                                         NETIUCV_HDRLEN, GFP_ATOMIC | GFP_DMA);
                        if (!nskb) {
                                printk(KERN_WARNING
                                       "%s: Could not allocate tx_skb\n",
                                       conn->netdev->name);
                                rc = -ENOMEM;
                        } else {
                                skb_reserve(nskb, NETIUCV_HDRLEN);
                                memcpy(skb_put(nskb, skb->len),
                                       skb->data, skb->len);
                        }
                        copied = 1;
                }
                /**
                 * skb now is below 2G and has enough room. Add headers.
                 */
                header.next = nskb->len + NETIUCV_HDRLEN;
                memcpy(skb_push(nskb, NETIUCV_HDRLEN), &header, NETIUCV_HDRLEN);
                header.next = 0;
                memcpy(skb_put(nskb, NETIUCV_HDRLEN), &header,  NETIUCV_HDRLEN);
 
                conn->retry = 0;
                fsm_newstate(conn->fsm, CONN_STATE_TX);
                fsm_addtimer(&conn->timer, NETIUCV_TIMEOUT_5SEC,
                             CONN_EVENT_TIMER, conn);
                conn->prof.send_stamp = xtime;
 
                rc = iucv_send(conn->pathid, NULL, 0, 0, 1 /* single_flag */,
                               0, nskb->data, nskb->len);
                conn->prof.doios_single++;
                conn->prof.txlen += skb->len;
                conn->prof.tx_pending++;
                if (conn->prof.tx_pending > conn->prof.tx_max_pending)
                        conn->prof.tx_max_pending = conn->prof.tx_pending;
                if (rc != 0) {
                        netiucv_priv *privptr;
                        fsm_deltimer(&conn->timer);
                        fsm_newstate(conn->fsm, CONN_STATE_IDLE);
                        conn->prof.tx_pending--;
                        privptr = (netiucv_priv *)conn->netdev->priv;
                        if (privptr)
                                privptr->stats.tx_errors++;
                        if (copied)
                                dev_kfree_skb(nskb);
                        else {
                                /**
                                 * Remove our headers. They get added
                                 * again on retransmit.
                                 */
                                skb_pull(skb, NETIUCV_HDRLEN);
                                skb_trim(skb, skb->len - NETIUCV_HDRLEN);
                        }
                        printk(KERN_DEBUG "iucv_send returned %08x\n",
                               rc);
                } else {
                        if (copied)
                                dev_kfree_skb(skb);
                        atomic_inc(&nskb->users);
                        skb_queue_tail(&conn->commit_queue, nskb);
                }
        }
 
        return rc;
}
 
/**
 * Interface API for upper network layers
 *****************************************************************************/
 
/**
 * Open an interface.
 * Called from generic network layer when ifconfig up is run.
 *
 * @param dev Pointer to interface struct.
 *
 * @return 0 on success, -ERRNO on failure. (Never fails.)
 */
static int
netiucv_open(net_device *dev) {
        MOD_INC_USE_COUNT;
        SET_DEVICE_START(dev, 1);
        fsm_event(((netiucv_priv *)dev->priv)->fsm, DEV_EVENT_START, dev);
        return 0;
}
 
/**
 * Close an interface.
 * Called from generic network layer when ifconfig down is run.
 *
 * @param dev Pointer to interface struct.
 *
 * @return 0 on success, -ERRNO on failure. (Never fails.)
 */
static int
netiucv_close(net_device *dev) {
        SET_DEVICE_START(dev, 0);
        fsm_event(((netiucv_priv *)dev->priv)->fsm, DEV_EVENT_STOP, dev);
        MOD_DEC_USE_COUNT;
        return 0;
}
 
/**
 * Start transmission of a packet.
 * Called from generic network device layer.
 *
 * @param skb Pointer to buffer containing the packet.
 * @param dev Pointer to interface struct.
 *
 * @return 0 if packet consumed, !0 if packet rejected.
 *         Note: If we return !0, then the packet is free'd by
 *               the generic network layer.
 */
static int netiucv_tx(struct sk_buff *skb, net_device *dev)
{
        int          rc = 0;
        netiucv_priv *privptr = (netiucv_priv *)dev->priv;
 
        /**
         * Some sanity checks ...
         */
        if (skb == NULL) {
                printk(KERN_WARNING "%s: NULL sk_buff passed\n", dev->name);
                privptr->stats.tx_dropped++;
                return 0;
        }
        if (skb_headroom(skb) < (NETIUCV_HDRLEN)) {
                printk(KERN_WARNING
                       "%s: Got sk_buff with head room < %ld bytes\n",
                       dev->name, NETIUCV_HDRLEN);
                dev_kfree_skb(skb);
                privptr->stats.tx_dropped++;
                return 0;
        }
 
        /**
         * If connection is not running, try to restart it
         * notify anybody about a link failure and throw
         * away packet.
         */
        if (fsm_getstate(privptr->fsm) != DEV_STATE_RUNNING) {
                fsm_event(privptr->fsm, DEV_EVENT_START, dev);
                dst_link_failure(skb);
                dev_kfree_skb(skb);
                privptr->stats.tx_dropped++;
                privptr->stats.tx_errors++;
                privptr->stats.tx_carrier_errors++;
                return 0;
        }
 
        if (netiucv_test_and_set_busy(dev))
                return -EBUSY;
 
        dev->trans_start = jiffies;
        if (netiucv_transmit_skb(privptr->conn, skb) != 0)
                rc = 1;
        netiucv_clear_busy(dev);
        return rc;
}
 
/**
 * Returns interface statistics of a device.
 *
 * @param dev Pointer to interface struct.
 *
 * @return Pointer to stats struct of this interface.
 */
static struct net_device_stats *
netiucv_stats (net_device * dev)
{
        return &((netiucv_priv *)dev->priv)->stats;
}
 
/**
 * Sets MTU of an interface.
 *
 * @param dev     Pointer to interface struct.
 * @param new_mtu The new MTU to use for this interface.
 *
 * @return 0 on success, -EINVAL if MTU is out of valid range.
 *         (valid range is 576 .. NETIUCV_MTU_MAX).
 */
static int
netiucv_change_mtu (net_device * dev, int new_mtu)
{
        if ((new_mtu < 576) || (new_mtu > NETIUCV_MTU_MAX))
                return -EINVAL;
        dev->mtu = new_mtu;
        return 0;
}
 
 
/**
 * procfs related structures and routines
 *****************************************************************************/
 
static net_device *
find_netdev_by_ino(unsigned long ino)
{
        iucv_connection *conn = connections;
        net_device *dev = NULL;
        netiucv_priv *privptr;
 
        while (conn) {
                if (conn->netdev != dev) {
                        dev = conn->netdev;
                        privptr = (netiucv_priv *)dev->priv;
 
                        if ((privptr->proc_buffer_entry->low_ino == ino) ||
                            (privptr->proc_user_entry->low_ino == ino)   ||
                            (privptr->proc_stat_entry->low_ino == ino)     )
                                return dev;
                }
                conn = conn->next;
        }
        return NULL;
}
 
#if LINUX_VERSION_CODE < 0x020363
/**
 * Lock the module, if someone changes into
 * our proc directory.
 */
static void
netiucv_fill_inode(struct inode *inode, int fill)
{
        if (fill) {
                MOD_INC_USE_COUNT;
        } else
                MOD_DEC_USE_COUNT;
}
#endif
 
#define CTRL_BUFSIZE 40
 
static int
netiucv_buffer_open(struct inode *inode, struct file *file)
{
        file->private_data = kmalloc(CTRL_BUFSIZE, GFP_KERNEL);
        if (file->private_data == NULL)
                return -ENOMEM;
        MOD_INC_USE_COUNT;
        return 0;
}
 
static int
netiucv_buffer_close(struct inode *inode, struct file *file)
{
        kfree(file->private_data);
        MOD_DEC_USE_COUNT;
        return 0;
}
 
static ssize_t
netiucv_buffer_write(struct file *file, const char *buf, size_t count,
                           loff_t *off)
{
        unsigned int ino = ((struct inode *)file->f_dentry->d_inode)->i_ino;
        net_device   *dev;
        netiucv_priv *privptr;
        char         *e;
        int          bs1;
        char         tmp[CTRL_BUFSIZE];
 
        if (!(dev = find_netdev_by_ino(ino)))
                return -ENODEV;
        if (off != &file->f_pos)
                return -ESPIPE;
 
        privptr = (netiucv_priv *)dev->priv;
 
        if (count >= CTRL_BUFSIZE-1)
                return -EINVAL;
 
        if (copy_from_user(tmp, buf, count))
                return -EFAULT;
        tmp[count+1] = '\0';
        bs1 = simple_strtoul(tmp, &e, 0);
 
        if ((bs1 > NETIUCV_BUFSIZE_MAX) ||
            (e && (!isspace(*e))))
                return -EINVAL;
        if ((dev->flags & IFF_RUNNING) &&
            (bs1 < (dev->mtu + NETIUCV_HDRLEN + 2)))
                return -EINVAL;
        if (bs1 < (576 + NETIUCV_HDRLEN + NETIUCV_HDRLEN))
                return -EINVAL;
 
 
        privptr->conn->max_buffsize = bs1;
        if (!(dev->flags & IFF_RUNNING))
                dev->mtu = bs1 - NETIUCV_HDRLEN - NETIUCV_HDRLEN;
        privptr->conn->flags |= CONN_FLAGS_BUFSIZE_CHANGED;
 
        return count;
}
 
static ssize_t
netiucv_buffer_read(struct file *file, char *buf, size_t count, loff_t *off)
{
        unsigned int ino = ((struct inode *)file->f_dentry->d_inode)->i_ino;
        char *sbuf = (char *)file->private_data;
        net_device *dev;
        netiucv_priv *privptr;
        ssize_t ret = 0;
        char *p = sbuf;
        int l;
 
        if (!(dev = find_netdev_by_ino(ino)))
                return -ENODEV;
        if (off != &file->f_pos)
                return -ESPIPE;
 
        privptr = (netiucv_priv *)dev->priv;
 
        if (file->f_pos == 0)
                sprintf(sbuf, "%d\n", privptr->conn->max_buffsize);
 
        l = strlen(sbuf);
        p = sbuf;
        if (file->f_pos < l) {
                p += file->f_pos;
                l = strlen(p);
                ret = (count > l) ? l : count;
                if (copy_to_user(buf, p, ret))
                        return -EFAULT;
        }
        file->f_pos += ret;
        return ret;
}
 
static int
netiucv_user_open(struct inode *inode, struct file *file)
{
        file->private_data = kmalloc(CTRL_BUFSIZE, GFP_KERNEL);
        if (file->private_data == NULL)
                return -ENOMEM;
        MOD_INC_USE_COUNT;
        return 0;
}
 
static int
netiucv_user_close(struct inode *inode, struct file *file)
{
        kfree(file->private_data);
        MOD_DEC_USE_COUNT;
        return 0;
}
 
static ssize_t
netiucv_user_write(struct file *file, const char *buf, size_t count,
                           loff_t *off)
{
        unsigned int ino = ((struct inode *)file->f_dentry->d_inode)->i_ino;
        net_device   *dev;
        netiucv_priv *privptr;
        int          i;
        char         *p;
        char         tmp[CTRL_BUFSIZE];
        char         user[9];
 
        if (!(dev = find_netdev_by_ino(ino)))
                return -ENODEV;
        if (off != &file->f_pos)
                return -ESPIPE;
 
        privptr = (netiucv_priv *)dev->priv;
 
        if (count >= CTRL_BUFSIZE-1)
                return -EINVAL;
 
        if (copy_from_user(tmp, buf, count))
                return -EFAULT;
        tmp[count+1] = '\0';
 
        memset(user, ' ', sizeof(user));
        user[8] = '\0';
        for (p = tmp, i = 0; *p && (!isspace(*p)); p++) {
                if (i > 7)
                        return -EINVAL;
                user[i++] = *p;
        }
 
        if (memcmp(user, privptr->conn->userid, 8) != 0) {
                /* username changed */
                if (dev->flags & IFF_RUNNING)
                        return -EBUSY;
        }
        memcpy(privptr->conn->userid, user, 9);
        return count;
}
 
static ssize_t
netiucv_user_read(struct file *file, char *buf, size_t count, loff_t *off)
{
        unsigned int ino = ((struct inode *)file->f_dentry->d_inode)->i_ino;
        char *sbuf = (char *)file->private_data;
        net_device *dev;
        netiucv_priv *privptr;
        ssize_t ret = 0;
        char *p = sbuf;
        int l;
 
        if (!(dev = find_netdev_by_ino(ino)))
                return -ENODEV;
        if (off != &file->f_pos)
                return -ESPIPE;
 
        privptr = (netiucv_priv *)dev->priv;
 
 
        if (file->f_pos == 0)
                sprintf(sbuf, "%s\n",
                        netiucv_printname(privptr->conn->userid));
 
        l = strlen(sbuf);
        p = sbuf;
        if (file->f_pos < l) {
                p += file->f_pos;
                l = strlen(p);
                ret = (count > l) ? l : count;
                if (copy_to_user(buf, p, ret))
                        return -EFAULT;
        }
        file->f_pos += ret;
        return ret;
}
 
#define STATS_BUFSIZE 2048
 
static int
netiucv_stat_open(struct inode *inode, struct file *file)
{
        file->private_data = kmalloc(STATS_BUFSIZE, GFP_KERNEL);
        if (file->private_data == NULL)
                return -ENOMEM;
        MOD_INC_USE_COUNT;
        return 0;
}
 
static int
netiucv_stat_close(struct inode *inode, struct file *file)
{
        kfree(file->private_data);
        MOD_DEC_USE_COUNT;
        return 0;
}
 
static ssize_t
netiucv_stat_write(struct file *file, const char *buf, size_t count, loff_t *off)
{
        unsigned int ino = ((struct inode *)file->f_dentry->d_inode)->i_ino;
        net_device *dev;
        netiucv_priv *privptr;
 
        if (!(dev = find_netdev_by_ino(ino)))
                return -ENODEV;
        privptr = (netiucv_priv *)dev->priv;
        memset(&(privptr->conn->prof), 0, sizeof(privptr->conn->prof));
        return count;
}
 
static ssize_t
netiucv_stat_read(struct file *file, char *buf, size_t count, loff_t *off)
{
        unsigned int ino = ((struct inode *)file->f_dentry->d_inode)->i_ino;
        char *sbuf = (char *)file->private_data;
        net_device *dev;
        netiucv_priv *privptr;
        ssize_t ret = 0;
        char *p = sbuf;
        int l;
 
        if (!(dev = find_netdev_by_ino(ino)))
                return -ENODEV;
        if (off != &file->f_pos)
                return -ESPIPE;
 
        privptr = (netiucv_priv *)dev->priv;
 
        if (file->f_pos == 0) {
                p += sprintf(p, "Device FSM state: %s\n",
                             fsm_getstate_str(privptr->fsm));
                p += sprintf(p, "Connection FSM state: %s\n",
                             fsm_getstate_str(privptr->conn->fsm));
                p += sprintf(p, "Max. TX buffer used: %ld\n",
                             privptr->conn->prof.maxmulti);
                p += sprintf(p, "Max. chained SKBs: %ld\n",
                             privptr->conn->prof.maxcqueue);
                p += sprintf(p, "TX single write ops: %ld\n",
                             privptr->conn->prof.doios_single);
                p += sprintf(p, "TX multi write ops: %ld\n",
                             privptr->conn->prof.doios_multi);
                p += sprintf(p, "Netto bytes written: %ld\n",
                             privptr->conn->prof.txlen);
                p += sprintf(p, "Max. TX IO-time: %ld\n",
                             privptr->conn->prof.tx_time);
                p += sprintf(p, "Pending transmits: %ld\n",
                             privptr->conn->prof.tx_pending);
                p += sprintf(p, "Max. pending transmits: %ld\n",
                             privptr->conn->prof.tx_max_pending);
        }
        l = strlen(sbuf);
        p = sbuf;
        if (file->f_pos < l) {
                p += file->f_pos;
                l = strlen(p);
                ret = (count > l) ? l : count;
                if (copy_to_user(buf, p, ret))
                        return -EFAULT;
        }
        file->f_pos += ret;
        return ret;
}
 
static struct file_operations netiucv_stat_fops = {
        read:    netiucv_stat_read,
        write:   netiucv_stat_write,
        open:    netiucv_stat_open,
        release: netiucv_stat_close,
};
 
static struct file_operations netiucv_buffer_fops = {
        read:    netiucv_buffer_read,
        write:   netiucv_buffer_write,
        open:    netiucv_buffer_open,
        release: netiucv_buffer_close,
};
 
static struct file_operations netiucv_user_fops = {
        read:    netiucv_user_read,
        write:   netiucv_user_write,
        open:    netiucv_user_open,
        release: netiucv_user_close,
};
 
static struct inode_operations netiucv_stat_iops = {
#if LINUX_VERSION_CODE < 0x020363
        default_file_ops: &netiucv_stat_fops
#endif
};
static struct inode_operations netiucv_buffer_iops = {
#if LINUX_VERSION_CODE < 0x020363
        default_file_ops: &netiucv_buffer_fops
#endif
};
 
static struct inode_operations netiucv_user_iops = {
#if LINUX_VERSION_CODE < 0x020363
        default_file_ops: &netiucv_user_fops
#endif
};
 
static struct proc_dir_entry stat_entry = {
        0,                           /* low_ino */
        10,                          /* namelen */
        "statistics",                /* name    */
        S_IFREG | S_IRUGO | S_IWUSR, /* mode    */
        1,                           /* nlink   */
        0,                           /* uid     */
        0,                           /* gid     */
        0,                           /* size    */
        &netiucv_stat_iops           /* ops     */
};
 
static struct proc_dir_entry buffer_entry = {
        0,                           /* low_ino */
        10,                          /* namelen */
        "buffersize",                /* name    */
        S_IFREG | S_IRUSR | S_IWUSR, /* mode    */
        1,                           /* nlink   */
        0,                           /* uid     */
        0,                           /* gid     */
        0,                           /* size    */
        &netiucv_buffer_iops         /* ops     */
};
 
static struct proc_dir_entry user_entry = {
        0,                           /* low_ino */
        8,                           /* namelen */
        "username",                  /* name    */
        S_IFREG | S_IRUSR | S_IWUSR, /* mode    */
        1,                           /* nlink   */
        0,                           /* uid     */
        0,                           /* gid     */
        0,                           /* size    */
        &netiucv_user_iops           /* ops     */
};
 
#if LINUX_VERSION_CODE < 0x020363
static struct proc_dir_entry netiucv_dir = {
        0,                           /* low_ino  */
        4,                           /* namelen  */
        "iucv",                      /* name     */
        S_IFDIR | S_IRUGO | S_IXUGO, /* mode     */
        2,                           /* nlink    */
        0,                           /* uid      */
        0,                           /* gid      */
        0,                           /* size     */
        0,                           /* ops      */
        0,                           /* get_info */
        netiucv_fill_inode           /* fill_ino (for locking) */
};
 
static struct proc_dir_entry netiucv_template =
{
        0,                           /* low_ino  */
        0,                           /* namelen  */
        "",                          /* name     */
        S_IFDIR | S_IRUGO | S_IXUGO, /* mode     */
        2,                           /* nlink    */
        0,                           /* uid      */
        0,                           /* gid      */
        0,                           /* size     */
        0,                           /* ops      */
        0,                           /* get_info */
        netiucv_fill_inode           /* fill_ino (for locking) */
};
#else
static struct proc_dir_entry *netiucv_dir = NULL;
static struct proc_dir_entry *netiucv_template = NULL;
#endif
 
/**
 * Create the driver's main directory /proc/net/iucv
 */
static void
netiucv_proc_create_main(void)
{
        /**
         * If not registered, register main proc dir-entry now
         */
#if LINUX_VERSION_CODE > 0x020362
#ifdef CONFIG_PROC_FS
        if (!netiucv_dir)
                netiucv_dir = proc_mkdir("iucv", proc_net);
#endif
#else
        if (netiucv_dir.low_ino == 0)
                proc_net_register(&netiucv_dir);
#endif
}
 
#ifdef MODULE
/**
 * Destroy /proc/net/iucv
 */
static void
netiucv_proc_destroy_main(void)
{
#if LINUX_VERSION_CODE > 0x020362
#ifdef CONFIG_PROC_FS
        remove_proc_entry("iucv", proc_net);
#endif
#else
        proc_net_unregister(netiucv_dir.low_ino);
#endif
}
#endif MODULE
 
/**
 * Create a device specific subdirectory in /proc/net/iucv/ with the
 * same name like the device. In that directory, create 3 entries
 * "statistics", "buffersize" and "username".
 *
 * @param dev The device for which the subdirectory should be created.
 *
 */
static void
netiucv_proc_create_sub(net_device *dev) {
        netiucv_priv *privptr = dev->priv;
 
#if LINUX_VERSION_CODE > 0x020362
        privptr->proc_dentry = proc_mkdir(dev->name, netiucv_dir);
        privptr->proc_stat_entry =
                create_proc_entry("statistics",
                                  S_IFREG | S_IRUSR | S_IWUSR,
                                  privptr->proc_dentry);
        privptr->proc_stat_entry->proc_fops = &netiucv_stat_fops;
        privptr->proc_stat_entry->proc_iops = &netiucv_stat_iops;
        privptr->proc_buffer_entry =
                create_proc_entry("buffersize",
                                  S_IFREG | S_IRUSR | S_IWUSR,
                                  privptr->proc_dentry);
        privptr->proc_buffer_entry->proc_fops = &netiucv_buffer_fops;
        privptr->proc_buffer_entry->proc_iops = &netiucv_buffer_iops;
        privptr->proc_user_entry =
                create_proc_entry("username",
                                  S_IFREG | S_IRUSR | S_IWUSR,
                                  privptr->proc_dentry);
        privptr->proc_user_entry->proc_fops = &netiucv_user_fops;
        privptr->proc_user_entry->proc_iops = &netiucv_user_iops;
#else
        privptr->proc_dentry->name = dev->name;
        privptr->proc_dentry->namelen = strlen(dev->name);
        proc_register(&netiucv_dir, privptr->proc_dentry);
        proc_register(privptr->proc_dentry, privptr->proc_stat_entry);
        proc_register(privptr->proc_dentry, privptr->proc_buffer_entry);
        proc_register(privptr->proc_dentry, privptr->proc_user_entry);
#endif
        privptr->proc_registered = 1;
}
 
 
/**
 * Destroy a device specific subdirectory.
 *
 * @param privptr Pointer to device private data.
 */
static void
netiucv_proc_destroy_sub(netiucv_priv *privptr) {
        if (!privptr->proc_registered)
                return;
#if LINUX_VERSION_CODE > 0x020362
        remove_proc_entry("statistics", privptr->proc_dentry);
        remove_proc_entry("buffersize", privptr->proc_dentry);
        remove_proc_entry("username", privptr->proc_dentry);
        remove_proc_entry(privptr->proc_dentry->name, netiucv_dir);
#else
        proc_unregister(privptr->proc_dentry,
                        privptr->proc_stat_entry->low_ino);
        proc_unregister(privptr->proc_dentry,
                        privptr->proc_buffer_entry->low_ino);
        proc_unregister(privptr->proc_dentry,
                        privptr->proc_user_entry->low_ino);
        proc_unregister(&netiucv_dir,
                        privptr->proc_dentry->low_ino);
#endif
        privptr->proc_registered = 0;
}
 
 
/**
 * Allocate and initialize a new connection structure.
 * Add it to the list of connections;
 */
static iucv_connection *
netiucv_new_connection(net_device *dev, char *username)
{
        iucv_connection **clist = &connections;
        iucv_connection *conn =
                (iucv_connection *)kmalloc(sizeof(iucv_connection), GFP_KERNEL);
        if (conn) {
                memset(conn, 0, sizeof(iucv_connection));
                skb_queue_head_init(&conn->collect_queue);
                skb_queue_head_init(&conn->commit_queue);
                conn->max_buffsize = NETIUCV_BUFSIZE_DEFAULT;
                conn->netdev = dev;
 
                conn->rx_buff = alloc_skb(NETIUCV_BUFSIZE_DEFAULT, GFP_DMA);
                if (!conn->rx_buff) {
                        kfree(conn);
                        return NULL;
                }
                conn->tx_buff = alloc_skb(NETIUCV_BUFSIZE_DEFAULT, GFP_DMA);
                if (!conn->tx_buff) {
                        kfree_skb(conn->rx_buff);
                        kfree(conn);
                        return NULL;
                }
                conn->fsm = init_fsm("netiucvconn", conn_state_names,
                                     conn_event_names, NR_CONN_STATES,
                                     NR_CONN_EVENTS, conn_fsm, CONN_FSM_LEN,
                                     GFP_KERNEL);
                if (!conn->fsm) {
                        kfree_skb(conn->tx_buff);
                        kfree_skb(conn->rx_buff);
                        kfree(conn);
                        return NULL;
                }
                fsm_settimer(conn->fsm, &conn->timer);
                fsm_newstate(conn->fsm, CONN_STATE_INVALID);
 
                if (username) {
                        memcpy(conn->userid, username, 9);
                        fsm_newstate(conn->fsm, CONN_STATE_STOPPED);
                }
 
                conn->next = *clist;
                *clist = conn;
        }
        return conn;
}
 
/**
 * Release a connection structure and remove it from the
 * list of connections.
 */
static void
netiucv_remove_connection(iucv_connection *conn)
{
        iucv_connection **clist = &connections;
 
        if (conn == NULL)
                return;
        while (*clist) {
                if (*clist == conn) {
                        *clist = conn->next;
                        if (conn->handle != 0) {
                                iucv_unregister_program(conn->handle);
                                conn->handle = 0;
                        }
                        fsm_deltimer(&conn->timer);
                        kfree_fsm(conn->fsm);
                        kfree_skb(conn->rx_buff);
                        kfree_skb(conn->tx_buff);
                        return;
                }
                clist = &((*clist)->next);
        }
}
 
/**
 * Allocate and initialize everything of a net device.
 */
static net_device *
netiucv_init_netdevice(int ifno, char *username)
{
        netiucv_priv *privptr;
        int          priv_size;
 
        net_device *dev = kmalloc(sizeof(net_device)
#if LINUX_VERSION_CODE < 0x020300
                      + 11 /* name + zero */
#endif
                      , GFP_KERNEL);
        if (!dev)
                return NULL;
        memset(dev, 0, sizeof(net_device));
#if LINUX_VERSION_CODE < 0x020300
        dev->name = (char *)dev + sizeof(net_device);
#endif
        sprintf(dev->name, "iucv%d", ifno);
 
        priv_size = sizeof(netiucv_priv) + sizeof(netiucv_template) +
                sizeof(stat_entry) + sizeof(buffer_entry) + sizeof(user_entry);
        dev->priv = kmalloc(priv_size, GFP_KERNEL);
        if (dev->priv == NULL) {
                kfree(dev);
                return NULL;
        }
        memset(dev->priv, 0, priv_size);
        privptr = (netiucv_priv *)dev->priv;
        privptr->proc_dentry = (struct proc_dir_entry *)
                (((char *)privptr) + sizeof(netiucv_priv));
        privptr->proc_stat_entry = (struct proc_dir_entry *)
                (((char *)privptr) + sizeof(netiucv_priv) +
                 sizeof(netiucv_template));
        privptr->proc_buffer_entry = (struct proc_dir_entry *)
                (((char *)privptr) + sizeof(netiucv_priv) +
                 sizeof(netiucv_template) + sizeof(stat_entry));
        privptr->proc_user_entry = (struct proc_dir_entry *)
                (((char *)privptr) + sizeof(netiucv_priv) +
                 sizeof(netiucv_template) + sizeof(stat_entry) +
                 sizeof(buffer_entry));
        memcpy(privptr->proc_dentry, &netiucv_template,
               sizeof(netiucv_template));
        memcpy(privptr->proc_stat_entry, &stat_entry, sizeof(stat_entry));
        memcpy(privptr->proc_buffer_entry, &buffer_entry, sizeof(buffer_entry));
        memcpy(privptr->proc_user_entry, &user_entry, sizeof(user_entry));
        privptr->fsm = init_fsm("netiucvdev", dev_state_names,
                                dev_event_names, NR_DEV_STATES, NR_DEV_EVENTS,
                                dev_fsm, DEV_FSM_LEN, GFP_KERNEL);
        if (privptr->fsm == NULL) {
                kfree(privptr);
                kfree(dev);
                return NULL;
        }
        privptr->conn = netiucv_new_connection(dev, username);
        if (!privptr->conn) {
                kfree_fsm(privptr->fsm);
                kfree(privptr);
                kfree(dev);
                return NULL;
        }
 
        fsm_newstate(privptr->fsm, DEV_STATE_STOPPED);
        dev->mtu                 = NETIUCV_MTU_DEFAULT;
        dev->hard_start_xmit     = netiucv_tx;
        dev->open                = netiucv_open;
        dev->stop                = netiucv_close;
        dev->get_stats           = netiucv_stats;
        dev->change_mtu          = netiucv_change_mtu;
        dev->hard_header_len     = NETIUCV_HDRLEN;
        dev->addr_len            = 0;
        dev->type                = ARPHRD_SLIP;
        dev->tx_queue_len        = NETIUCV_QUEUELEN_DEFAULT;
        dev_init_buffers(dev);
        dev->flags               = IFF_POINTOPOINT | IFF_NOARP;
        return dev;
}
 
/**
 * Allocate and initialize everything of a net device.
 */
static void
netiucv_free_netdevice(net_device *dev)
{
        netiucv_priv *privptr;
 
        if (!dev)
                return;
 
        privptr = (netiucv_priv *)dev->priv;
        if (privptr) {
                if (privptr->conn)
                        netiucv_remove_connection(privptr->conn);
                if (privptr->fsm)
                        kfree_fsm(privptr->fsm);
                netiucv_proc_destroy_sub(privptr);
                kfree(privptr);
        }
        kfree(dev);
}
 
static void
netiucv_banner(void)
{
        char vbuf[] = "$Revision: 1.1.1.1 $";
        char *version = vbuf;
 
        if ((version = strchr(version, ':'))) {
                char *p = strchr(version + 1, '$');
                if (p)
                        *p = '\0';
        } else
                version = " ??? ";
        printk(KERN_INFO "NETIUCV driver Version%s initialized\n", version);
}
 
#ifndef MODULE
# if (LINUX_VERSION_CODE >= KERNEL_VERSION(2,3,0))
#  define init_return(a) return a
static int __init
iucv_setup(char *param)
# else
#  define init_return(a) return
__initfunc (void iucv_setup(char *param, int *ints))
# endif
{
        /**
        * We do not parse parameters here because at the time of
        * calling iucv_setup(), the kernel does not yet have
        * memory management running. We delay this until probing
        * is called.
        */
        iucv = param;
        init_return(1);
}
 
# if (LINUX_VERSION_CODE >= KERNEL_VERSION(2,3,0))
__setup ("iucv=", iucv_setup);
# endif
#else
static void
netiucv_exit(void)
{
        while (connections) {
                net_device *dev = connections->netdev;
                unregister_netdev(dev);
                netiucv_free_netdevice(dev);
        }
        netiucv_proc_destroy_main();
 
        printk(KERN_INFO "NETIUCV driver unloaded\n");
        return;
}
#endif
 
static int
netiucv_init(void)
{
        char *p = iucv;
        int ifno = 0;
        int i = 0;
        char username[10];
 
        netiucv_proc_create_main();
        while (p) {
                if (isalnum(*p) || (*p == '$')) {
                        username[i++] = *p++;
                        username[i] = '\0';
                        if (i > 8) {
                                printk(KERN_WARNING
                                       "netiucv: Invalid user name '%s'\n",
                                       username);
                                while (*p && (*p != ':') && (*p != ','))
                                        p++;
                        }
                } else {
                        if (*p && (*p != ':') && (*p != ',')) {
                                printk(KERN_WARNING
                                       "netiucv: Invalid delimiter '%c'\n",
                                       *p);
                                while (*p && (*p != ':') && (*p != ','))
                                        p++;
                        } else {
                                if (i) {
                                        net_device *dev;
 
                                        while (i < 9)
                                                username[i++] = ' ';
                                        username[9] = '\0';
                                        dev = netiucv_init_netdevice(ifno,
                                                                     username);
                                        if (!dev)
                                                printk(KERN_WARNING
                                                       "netiucv: Could not allocate network device structure for user '%s'\n", netiucv_printname(username));
                                        else {
                                                if (register_netdev(dev)) {
                                                        printk(KERN_WARNING
                                                               "netiucv: Could not register '%s'\n", dev->name);
                                                        netiucv_free_netdevice(dev);
                                                } else {
                                                        printk(KERN_INFO "%s: '%s'\n", dev->name, netiucv_printname(username));
                                                        netiucv_proc_create_sub(dev);
                                                        ifno++;
                                                }
                                        }
                                }
                                if (!(*p))
                                        break;
                                i = 0;
                                p++;
                        }
                }
        }
        netiucv_banner();
        return 0;
}
 
#ifdef MODULE
module_init(netiucv_init);
module_exit(netiucv_exit);
#if (LINUX_VERSION_CODE >= KERNEL_VERSION(2,4,12))
MODULE_LICENSE("GPL");
#endif
#endif
Browse

Tools

Subversion Repositories or1k

[/] [or1k/] [trunk/] [linux/] [linux-2.4/] [drivers/] [s390/] [net/] [netiucv.c] - Blame information for rev 1275

Line No.	Rev	Author	Line
1	1275	phoenix	`/*`
2			`* $Id: netiucv.c,v 1.1.1.1 2004-04-15 02:05:58 phoenix Exp $`
3			`*`
4			`* IUCV network driver`
5			`*`
6			`* Copyright (C) 2001 IBM Deutschland Entwicklung GmbH, IBM Corporation`
7			`* Author(s): Fritz Elfert (elfert@de.ibm.com, felfert@millenux.com)`
8			`*`
9			`* Documentation used:`
10			`* the source of the original IUCV driver by:`
11			`* Stefan Hegewald <hegewald@de.ibm.com>`
12			`* Hartmut Penner <hpenner@de.ibm.com>`
13			`* Denis Joseph Barrow (djbarrow@de.ibm.com,barrow_dj@yahoo.com)`
14			`* Martin Schwidefsky (schwidefsky@de.ibm.com)`
15			`* Alan Altmark (Alan_Altmark@us.ibm.com) Sept. 2000`
16			`*`
17			`* This program is free software; you can redistribute it and/or modify`
18			`* it under the terms of the GNU General Public License as published by`
19			`* the Free Software Foundation; either version 2, or (at your option)`
20			`* any later version.`
21			`*`
22			`* This program is distributed in the hope that it will be useful,`
23			`* but WITHOUT ANY WARRANTY; without even the implied warranty of`
24			`* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the`
25			`* GNU General Public License for more details.`
26			`*`
27			`* You should have received a copy of the GNU General Public License`
28			`* along with this program; if not, write to the Free Software`
29			`* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.`
30			`*`
31			`* RELEASE-TAG: IUCV network driver $Revision: 1.1.1.1 $`
32			`*`
33			`*/`
34
35			`#include <linux/version.h>`
36			`#include <linux/module.h>`
37			`#include <linux/init.h>`
38			`#include <linux/kernel.h>`
39			`#include <linux/slab.h>`
40			`#include <linux/errno.h>`