linux-imx

/*

 *  X.25 Packet Layer release 002

 *

 *  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.

 *

 *  This code REQUIRES 2.1.15 or higher

 *

 *  This module:

 *      This module 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 of the License, or (at your option) any later version.

 *

 *  History

 *  X.25 001    Jonathan Naylor   Started coding.

 *  X.25 002    Jonathan Naylor   Centralised disconnection code.

 *                    New timer architecture.

 *  2000-03-20  Daniela Squassoni Disabling/enabling of facilities

 *                    negotiation.

 *  2000-11-10  Henner Eisen      Check and reset for out-of-sequence

 *                    i-frames.

 */

​

#define pr_fmt(fmt) "X25: " fmt

​

#include <linux/slab.h>

#include <linux/errno.h>

#include <linux/kernel.h>

#include <linux/string.h>

#include <linux/skbuff.h>

#include <net/sock.h>

#include <net/tcp_states.h>

#include <net/x25.h>

​

static int x25_queue_rx_frame(struct sock *sk, struct sk_buff *skb, int more)

{

    struct sk_buff *skbo, *skbn = skb;

    struct x25_sock *x25 = x25_sk(sk);

​

    if (more) {

        x25->fraglen += skb->len;

        skb_queue_tail(&x25->fragment_queue, skb);

        skb_set_owner_r(skb, sk);

        return 0;

    }

​

    if (!more && x25->fraglen > 0) {    /* End of fragment */

        int len = x25->fraglen + skb->len;

​

        if ((skbn = alloc_skb(len, GFP_ATOMIC)) == NULL){

            kfree_skb(skb);

            return 1;

        }

​

        skb_queue_tail(&x25->fragment_queue, skb);

​

        skb_reset_transport_header(skbn);

​

        skbo = skb_dequeue(&x25->fragment_queue);

        skb_copy_from_linear_data(skbo, skb_put(skbn, skbo->len),

                      skbo->len);

        kfree_skb(skbo);

​

        while ((skbo =

            skb_dequeue(&x25->fragment_queue)) != NULL) {

            skb_pull(skbo, (x25->neighbour->extended) ?

                    X25_EXT_MIN_LEN : X25_STD_MIN_LEN);

            skb_copy_from_linear_data(skbo,

                          skb_put(skbn, skbo->len),

                          skbo->len);

            kfree_skb(skbo);

        }

​

        x25->fraglen = 0;

    }

​

    skb_set_owner_r(skbn, sk);

    skb_queue_tail(&sk->sk_receive_queue, skbn);

    if (!sock_flag(sk, SOCK_DEAD))

        sk->sk_data_ready(sk);

​

    return 0;

}

​

/*

 * State machine for state 1, Awaiting Call Accepted State.

 * The handling of the timer(s) is in file x25_timer.c.

 * Handling of state 0 and connection release is in af_x25.c.

 */

static int x25_state1_machine(struct sock *sk, struct sk_buff *skb, int frametype)