xref: /openbmc/linux/drivers/s390/net/netiucv.c (revision 8730046c)
1 /*
2  * IUCV network driver
3  *
4  * Copyright IBM Corp. 2001, 2009
5  *
6  * Author(s):
7  *	Original netiucv driver:
8  *		Fritz Elfert (elfert@de.ibm.com, felfert@millenux.com)
9  *	Sysfs integration and all bugs therein:
10  *		Cornelia Huck (cornelia.huck@de.ibm.com)
11  *	PM functions:
12  *		Ursula Braun (ursula.braun@de.ibm.com)
13  *
14  * Documentation used:
15  *  the source of the original IUCV driver by:
16  *    Stefan Hegewald <hegewald@de.ibm.com>
17  *    Hartmut Penner <hpenner@de.ibm.com>
18  *    Denis Joseph Barrow (djbarrow@de.ibm.com,barrow_dj@yahoo.com)
19  *    Martin Schwidefsky (schwidefsky@de.ibm.com)
20  *    Alan Altmark (Alan_Altmark@us.ibm.com)  Sept. 2000
21  *
22  * This program is free software; you can redistribute it and/or modify
23  * it under the terms of the GNU General Public License as published by
24  * the Free Software Foundation; either version 2, or (at your option)
25  * any later version.
26  *
27  * This program is distributed in the hope that it will be useful,
28  * but WITHOUT ANY WARRANTY; without even the implied warranty of
29  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
30  * GNU General Public License for more details.
31  *
32  * You should have received a copy of the GNU General Public License
33  * along with this program; if not, write to the Free Software
34  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
35  *
36  */
37 
38 #define KMSG_COMPONENT "netiucv"
39 #define pr_fmt(fmt) KMSG_COMPONENT ": " fmt
40 
41 #undef DEBUG
42 
43 #include <linux/module.h>
44 #include <linux/init.h>
45 #include <linux/kernel.h>
46 #include <linux/slab.h>
47 #include <linux/errno.h>
48 #include <linux/types.h>
49 #include <linux/interrupt.h>
50 #include <linux/timer.h>
51 #include <linux/bitops.h>
52 
53 #include <linux/signal.h>
54 #include <linux/string.h>
55 #include <linux/device.h>
56 
57 #include <linux/ip.h>
58 #include <linux/if_arp.h>
59 #include <linux/tcp.h>
60 #include <linux/skbuff.h>
61 #include <linux/ctype.h>
62 #include <net/dst.h>
63 
64 #include <asm/io.h>
65 #include <linux/uaccess.h>
66 #include <asm/ebcdic.h>
67 
68 #include <net/iucv/iucv.h>
69 #include "fsm.h"
70 
71 MODULE_AUTHOR
72     ("(C) 2001 IBM Corporation by Fritz Elfert (felfert@millenux.com)");
73 MODULE_DESCRIPTION ("Linux for S/390 IUCV network driver");
74 
75 /**
76  * Debug Facility stuff
77  */
78 #define IUCV_DBF_SETUP_NAME "iucv_setup"
79 #define IUCV_DBF_SETUP_LEN 64
80 #define IUCV_DBF_SETUP_PAGES 2
81 #define IUCV_DBF_SETUP_NR_AREAS 1
82 #define IUCV_DBF_SETUP_LEVEL 3
83 
84 #define IUCV_DBF_DATA_NAME "iucv_data"
85 #define IUCV_DBF_DATA_LEN 128
86 #define IUCV_DBF_DATA_PAGES 2
87 #define IUCV_DBF_DATA_NR_AREAS 1
88 #define IUCV_DBF_DATA_LEVEL 2
89 
90 #define IUCV_DBF_TRACE_NAME "iucv_trace"
91 #define IUCV_DBF_TRACE_LEN 16
92 #define IUCV_DBF_TRACE_PAGES 4
93 #define IUCV_DBF_TRACE_NR_AREAS 1
94 #define IUCV_DBF_TRACE_LEVEL 3
95 
96 #define IUCV_DBF_TEXT(name,level,text) \
97 	do { \
98 		debug_text_event(iucv_dbf_##name,level,text); \
99 	} while (0)
100 
101 #define IUCV_DBF_HEX(name,level,addr,len) \
102 	do { \
103 		debug_event(iucv_dbf_##name,level,(void*)(addr),len); \
104 	} while (0)
105 
106 DECLARE_PER_CPU(char[256], iucv_dbf_txt_buf);
107 
108 #define IUCV_DBF_TEXT_(name, level, text...) \
109 	do { \
110 		if (debug_level_enabled(iucv_dbf_##name, level)) { \
111 			char* __buf = get_cpu_var(iucv_dbf_txt_buf); \
112 			sprintf(__buf, text); \
113 			debug_text_event(iucv_dbf_##name, level, __buf); \
114 			put_cpu_var(iucv_dbf_txt_buf); \
115 		} \
116 	} while (0)
117 
118 #define IUCV_DBF_SPRINTF(name,level,text...) \
119 	do { \
120 		debug_sprintf_event(iucv_dbf_trace, level, ##text ); \
121 		debug_sprintf_event(iucv_dbf_trace, level, text ); \
122 	} while (0)
123 
124 /**
125  * some more debug stuff
126  */
127 #define PRINTK_HEADER " iucv: "       /* for debugging */
128 
129 /* dummy device to make sure netiucv_pm functions are called */
130 static struct device *netiucv_dev;
131 
132 static int netiucv_pm_prepare(struct device *);
133 static void netiucv_pm_complete(struct device *);
134 static int netiucv_pm_freeze(struct device *);
135 static int netiucv_pm_restore_thaw(struct device *);
136 
137 static const struct dev_pm_ops netiucv_pm_ops = {
138 	.prepare = netiucv_pm_prepare,
139 	.complete = netiucv_pm_complete,
140 	.freeze = netiucv_pm_freeze,
141 	.thaw = netiucv_pm_restore_thaw,
142 	.restore = netiucv_pm_restore_thaw,
143 };
144 
145 static struct device_driver netiucv_driver = {
146 	.owner = THIS_MODULE,
147 	.name = "netiucv",
148 	.bus  = &iucv_bus,
149 	.pm = &netiucv_pm_ops,
150 };
151 
152 static int netiucv_callback_connreq(struct iucv_path *, u8 *, u8 *);
153 static void netiucv_callback_connack(struct iucv_path *, u8 *);
154 static void netiucv_callback_connrej(struct iucv_path *, u8 *);
155 static void netiucv_callback_connsusp(struct iucv_path *, u8 *);
156 static void netiucv_callback_connres(struct iucv_path *, u8 *);
157 static void netiucv_callback_rx(struct iucv_path *, struct iucv_message *);
158 static void netiucv_callback_txdone(struct iucv_path *, struct iucv_message *);
159 
160 static struct iucv_handler netiucv_handler = {
161 	.path_pending	  = netiucv_callback_connreq,
162 	.path_complete	  = netiucv_callback_connack,
163 	.path_severed	  = netiucv_callback_connrej,
164 	.path_quiesced	  = netiucv_callback_connsusp,
165 	.path_resumed	  = netiucv_callback_connres,
166 	.message_pending  = netiucv_callback_rx,
167 	.message_complete = netiucv_callback_txdone
168 };
169 
170 /**
171  * Per connection profiling data
172  */
173 struct connection_profile {
174 	unsigned long maxmulti;
175 	unsigned long maxcqueue;
176 	unsigned long doios_single;
177 	unsigned long doios_multi;
178 	unsigned long txlen;
179 	unsigned long tx_time;
180 	unsigned long send_stamp;
181 	unsigned long tx_pending;
182 	unsigned long tx_max_pending;
183 };
184 
185 /**
186  * Representation of one iucv connection
187  */
188 struct iucv_connection {
189 	struct list_head	  list;
190 	struct iucv_path	  *path;
191 	struct sk_buff            *rx_buff;
192 	struct sk_buff            *tx_buff;
193 	struct sk_buff_head       collect_queue;
194 	struct sk_buff_head	  commit_queue;
195 	spinlock_t                collect_lock;
196 	int                       collect_len;
197 	int                       max_buffsize;
198 	fsm_timer                 timer;
199 	fsm_instance              *fsm;
200 	struct net_device         *netdev;
201 	struct connection_profile prof;
202 	char                      userid[9];
203 	char			  userdata[17];
204 };
205 
206 /**
207  * Linked list of all connection structs.
208  */
209 static LIST_HEAD(iucv_connection_list);
210 static DEFINE_RWLOCK(iucv_connection_rwlock);
211 
212 /**
213  * Representation of event-data for the
214  * connection state machine.
215  */
216 struct iucv_event {
217 	struct iucv_connection *conn;
218 	void                   *data;
219 };
220 
221 /**
222  * Private part of the network device structure
223  */
224 struct netiucv_priv {
225 	struct net_device_stats stats;
226 	unsigned long           tbusy;
227 	fsm_instance            *fsm;
228         struct iucv_connection  *conn;
229 	struct device           *dev;
230 	int			 pm_state;
231 };
232 
233 /**
234  * Link level header for a packet.
235  */
236 struct ll_header {
237 	u16 next;
238 };
239 
240 #define NETIUCV_HDRLEN		 (sizeof(struct ll_header))
241 #define NETIUCV_BUFSIZE_MAX	 65537
242 #define NETIUCV_BUFSIZE_DEFAULT  NETIUCV_BUFSIZE_MAX
243 #define NETIUCV_MTU_MAX          (NETIUCV_BUFSIZE_MAX - NETIUCV_HDRLEN)
244 #define NETIUCV_MTU_DEFAULT      9216
245 #define NETIUCV_QUEUELEN_DEFAULT 50
246 #define NETIUCV_TIMEOUT_5SEC     5000
247 
248 /**
249  * Compatibility macros for busy handling
250  * of network devices.
251  */
252 static inline void netiucv_clear_busy(struct net_device *dev)
253 {
254 	struct netiucv_priv *priv = netdev_priv(dev);
255 	clear_bit(0, &priv->tbusy);
256 	netif_wake_queue(dev);
257 }
258 
259 static inline int netiucv_test_and_set_busy(struct net_device *dev)
260 {
261 	struct netiucv_priv *priv = netdev_priv(dev);
262 	netif_stop_queue(dev);
263 	return test_and_set_bit(0, &priv->tbusy);
264 }
265 
266 static u8 iucvMagic_ascii[16] = {
267 	0x30, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20,
268 	0x30, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20, 0x20
269 };
270 
271 static u8 iucvMagic_ebcdic[16] = {
272 	0xF0, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40,
273 	0xF0, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40, 0x40
274 };
275 
276 /**
277  * Convert an iucv userId to its printable
278  * form (strip whitespace at end).
279  *
280  * @param An iucv userId
281  *
282  * @returns The printable string (static data!!)
283  */
284 static char *netiucv_printname(char *name, int len)
285 {
286 	static char tmp[17];
287 	char *p = tmp;
288 	memcpy(tmp, name, len);
289 	tmp[len] = '\0';
290 	while (*p && ((p - tmp) < len) && (!isspace(*p)))
291 		p++;
292 	*p = '\0';
293 	return tmp;
294 }
295 
296 static char *netiucv_printuser(struct iucv_connection *conn)
297 {
298 	static char tmp_uid[9];
299 	static char tmp_udat[17];
300 	static char buf[100];
301 
302 	if (memcmp(conn->userdata, iucvMagic_ebcdic, 16)) {
303 		tmp_uid[8] = '\0';
304 		tmp_udat[16] = '\0';
305 		memcpy(tmp_uid, netiucv_printname(conn->userid, 8), 8);
306 		memcpy(tmp_udat, conn->userdata, 16);
307 		EBCASC(tmp_udat, 16);
308 		memcpy(tmp_udat, netiucv_printname(tmp_udat, 16), 16);
309 		sprintf(buf, "%s.%s", tmp_uid, tmp_udat);
310 		return buf;
311 	} else
312 		return netiucv_printname(conn->userid, 8);
313 }
314 
315 /**
316  * States of the interface statemachine.
317  */
318 enum dev_states {
319 	DEV_STATE_STOPPED,
320 	DEV_STATE_STARTWAIT,
321 	DEV_STATE_STOPWAIT,
322 	DEV_STATE_RUNNING,
323 	/**
324 	 * MUST be always the last element!!
325 	 */
326 	NR_DEV_STATES
327 };
328 
329 static const char *dev_state_names[] = {
330 	"Stopped",
331 	"StartWait",
332 	"StopWait",
333 	"Running",
334 };
335 
336 /**
337  * Events of the interface statemachine.
338  */
339 enum dev_events {
340 	DEV_EVENT_START,
341 	DEV_EVENT_STOP,
342 	DEV_EVENT_CONUP,
343 	DEV_EVENT_CONDOWN,
344 	/**
345 	 * MUST be always the last element!!
346 	 */
347 	NR_DEV_EVENTS
348 };
349 
350 static const char *dev_event_names[] = {
351 	"Start",
352 	"Stop",
353 	"Connection up",
354 	"Connection down",
355 };
356 
357 /**
358  * Events of the connection statemachine
359  */
360 enum conn_events {
361 	/**
362 	 * Events, representing callbacks from
363 	 * lowlevel iucv layer)
364 	 */
365 	CONN_EVENT_CONN_REQ,
366 	CONN_EVENT_CONN_ACK,
367 	CONN_EVENT_CONN_REJ,
368 	CONN_EVENT_CONN_SUS,
369 	CONN_EVENT_CONN_RES,
370 	CONN_EVENT_RX,
371 	CONN_EVENT_TXDONE,
372 
373 	/**
374 	 * Events, representing errors return codes from
375 	 * calls to lowlevel iucv layer
376 	 */
377 
378 	/**
379 	 * Event, representing timer expiry.
380 	 */
381 	CONN_EVENT_TIMER,
382 
383 	/**
384 	 * Events, representing commands from upper levels.
385 	 */
386 	CONN_EVENT_START,
387 	CONN_EVENT_STOP,
388 
389 	/**
390 	 * MUST be always the last element!!
391 	 */
392 	NR_CONN_EVENTS,
393 };
394 
395 static const char *conn_event_names[] = {
396 	"Remote connection request",
397 	"Remote connection acknowledge",
398 	"Remote connection reject",
399 	"Connection suspended",
400 	"Connection resumed",
401 	"Data received",
402 	"Data sent",
403 
404 	"Timer",
405 
406 	"Start",
407 	"Stop",
408 };
409 
410 /**
411  * States of the connection statemachine.
412  */
413 enum conn_states {
414 	/**
415 	 * Connection not assigned to any device,
416 	 * initial state, invalid
417 	 */
418 	CONN_STATE_INVALID,
419 
420 	/**
421 	 * Userid assigned but not operating
422 	 */
423 	CONN_STATE_STOPPED,
424 
425 	/**
426 	 * Connection registered,
427 	 * no connection request sent yet,
428 	 * no connection request received
429 	 */
430 	CONN_STATE_STARTWAIT,
431 
432 	/**
433 	 * Connection registered and connection request sent,
434 	 * no acknowledge and no connection request received yet.
435 	 */
436 	CONN_STATE_SETUPWAIT,
437 
438 	/**
439 	 * Connection up and running idle
440 	 */
441 	CONN_STATE_IDLE,
442 
443 	/**
444 	 * Data sent, awaiting CONN_EVENT_TXDONE
445 	 */
446 	CONN_STATE_TX,
447 
448 	/**
449 	 * Error during registration.
450 	 */
451 	CONN_STATE_REGERR,
452 
453 	/**
454 	 * Error during registration.
455 	 */
456 	CONN_STATE_CONNERR,
457 
458 	/**
459 	 * MUST be always the last element!!
460 	 */
461 	NR_CONN_STATES,
462 };
463 
464 static const char *conn_state_names[] = {
465 	"Invalid",
466 	"Stopped",
467 	"StartWait",
468 	"SetupWait",
469 	"Idle",
470 	"TX",
471 	"Terminating",
472 	"Registration error",
473 	"Connect error",
474 };
475 
476 
477 /**
478  * Debug Facility Stuff
479  */
480 static debug_info_t *iucv_dbf_setup = NULL;
481 static debug_info_t *iucv_dbf_data = NULL;
482 static debug_info_t *iucv_dbf_trace = NULL;
483 
484 DEFINE_PER_CPU(char[256], iucv_dbf_txt_buf);
485 
486 static void iucv_unregister_dbf_views(void)
487 {
488 	debug_unregister(iucv_dbf_setup);
489 	debug_unregister(iucv_dbf_data);
490 	debug_unregister(iucv_dbf_trace);
491 }
492 static int iucv_register_dbf_views(void)
493 {
494 	iucv_dbf_setup = debug_register(IUCV_DBF_SETUP_NAME,
495 					IUCV_DBF_SETUP_PAGES,
496 					IUCV_DBF_SETUP_NR_AREAS,
497 					IUCV_DBF_SETUP_LEN);
498 	iucv_dbf_data = debug_register(IUCV_DBF_DATA_NAME,
499 				       IUCV_DBF_DATA_PAGES,
500 				       IUCV_DBF_DATA_NR_AREAS,
501 				       IUCV_DBF_DATA_LEN);
502 	iucv_dbf_trace = debug_register(IUCV_DBF_TRACE_NAME,
503 					IUCV_DBF_TRACE_PAGES,
504 					IUCV_DBF_TRACE_NR_AREAS,
505 					IUCV_DBF_TRACE_LEN);
506 
507 	if ((iucv_dbf_setup == NULL) || (iucv_dbf_data == NULL) ||
508 	    (iucv_dbf_trace == NULL)) {
509 		iucv_unregister_dbf_views();
510 		return -ENOMEM;
511 	}
512 	debug_register_view(iucv_dbf_setup, &debug_hex_ascii_view);
513 	debug_set_level(iucv_dbf_setup, IUCV_DBF_SETUP_LEVEL);
514 
515 	debug_register_view(iucv_dbf_data, &debug_hex_ascii_view);
516 	debug_set_level(iucv_dbf_data, IUCV_DBF_DATA_LEVEL);
517 
518 	debug_register_view(iucv_dbf_trace, &debug_hex_ascii_view);
519 	debug_set_level(iucv_dbf_trace, IUCV_DBF_TRACE_LEVEL);
520 
521 	return 0;
522 }
523 
524 /*
525  * Callback-wrappers, called from lowlevel iucv layer.
526  */
527 
528 static void netiucv_callback_rx(struct iucv_path *path,
529 				struct iucv_message *msg)
530 {
531 	struct iucv_connection *conn = path->private;
532 	struct iucv_event ev;
533 
534 	ev.conn = conn;
535 	ev.data = msg;
536 	fsm_event(conn->fsm, CONN_EVENT_RX, &ev);
537 }
538 
539 static void netiucv_callback_txdone(struct iucv_path *path,
540 				    struct iucv_message *msg)
541 {
542 	struct iucv_connection *conn = path->private;
543 	struct iucv_event ev;
544 
545 	ev.conn = conn;
546 	ev.data = msg;
547 	fsm_event(conn->fsm, CONN_EVENT_TXDONE, &ev);
548 }
549 
550 static void netiucv_callback_connack(struct iucv_path *path, u8 ipuser[16])
551 {
552 	struct iucv_connection *conn = path->private;
553 
554 	fsm_event(conn->fsm, CONN_EVENT_CONN_ACK, conn);
555 }
556 
557 static int netiucv_callback_connreq(struct iucv_path *path, u8 *ipvmid,
558 				    u8 *ipuser)
559 {
560 	struct iucv_connection *conn = path->private;
561 	struct iucv_event ev;
562 	static char tmp_user[9];
563 	static char tmp_udat[17];
564 	int rc;
565 
566 	rc = -EINVAL;
567 	memcpy(tmp_user, netiucv_printname(ipvmid, 8), 8);
568 	memcpy(tmp_udat, ipuser, 16);
569 	EBCASC(tmp_udat, 16);
570 	read_lock_bh(&iucv_connection_rwlock);
571 	list_for_each_entry(conn, &iucv_connection_list, list) {
572 		if (strncmp(ipvmid, conn->userid, 8) ||
573 		    strncmp(ipuser, conn->userdata, 16))
574 			continue;
575 		/* Found a matching connection for this path. */
576 		conn->path = path;
577 		ev.conn = conn;
578 		ev.data = path;
579 		fsm_event(conn->fsm, CONN_EVENT_CONN_REQ, &ev);
580 		rc = 0;
581 	}
582 	IUCV_DBF_TEXT_(setup, 2, "Connection requested for %s.%s\n",
583 		       tmp_user, netiucv_printname(tmp_udat, 16));
584 	read_unlock_bh(&iucv_connection_rwlock);
585 	return rc;
586 }
587 
588 static void netiucv_callback_connrej(struct iucv_path *path, u8 *ipuser)
589 {
590 	struct iucv_connection *conn = path->private;
591 
592 	fsm_event(conn->fsm, CONN_EVENT_CONN_REJ, conn);
593 }
594 
595 static void netiucv_callback_connsusp(struct iucv_path *path, u8 *ipuser)
596 {
597 	struct iucv_connection *conn = path->private;
598 
599 	fsm_event(conn->fsm, CONN_EVENT_CONN_SUS, conn);
600 }
601 
602 static void netiucv_callback_connres(struct iucv_path *path, u8 *ipuser)
603 {
604 	struct iucv_connection *conn = path->private;
605 
606 	fsm_event(conn->fsm, CONN_EVENT_CONN_RES, conn);
607 }
608 
609 /**
610  * NOP action for statemachines
611  */
612 static void netiucv_action_nop(fsm_instance *fi, int event, void *arg)
613 {
614 }
615 
616 /*
617  * Actions of the connection statemachine
618  */
619 
620 /**
621  * netiucv_unpack_skb
622  * @conn: The connection where this skb has been received.
623  * @pskb: The received skb.
624  *
625  * Unpack a just received skb and hand it over to upper layers.
626  * Helper function for conn_action_rx.
627  */
628 static void netiucv_unpack_skb(struct iucv_connection *conn,
629 			       struct sk_buff *pskb)
630 {
631 	struct net_device     *dev = conn->netdev;
632 	struct netiucv_priv   *privptr = netdev_priv(dev);
633 	u16 offset = 0;
634 
635 	skb_put(pskb, NETIUCV_HDRLEN);
636 	pskb->dev = dev;
637 	pskb->ip_summed = CHECKSUM_NONE;
638 	pskb->protocol = ntohs(ETH_P_IP);
639 
640 	while (1) {
641 		struct sk_buff *skb;
642 		struct ll_header *header = (struct ll_header *) pskb->data;
643 
644 		if (!header->next)
645 			break;
646 
647 		skb_pull(pskb, NETIUCV_HDRLEN);
648 		header->next -= offset;
649 		offset += header->next;
650 		header->next -= NETIUCV_HDRLEN;
651 		if (skb_tailroom(pskb) < header->next) {
652 			IUCV_DBF_TEXT_(data, 2, "Illegal next field: %d > %d\n",
653 				header->next, skb_tailroom(pskb));
654 			return;
655 		}
656 		skb_put(pskb, header->next);
657 		skb_reset_mac_header(pskb);
658 		skb = dev_alloc_skb(pskb->len);
659 		if (!skb) {
660 			IUCV_DBF_TEXT(data, 2,
661 				"Out of memory in netiucv_unpack_skb\n");
662 			privptr->stats.rx_dropped++;
663 			return;
664 		}
665 		skb_copy_from_linear_data(pskb, skb_put(skb, pskb->len),
666 					  pskb->len);
667 		skb_reset_mac_header(skb);
668 		skb->dev = pskb->dev;
669 		skb->protocol = pskb->protocol;
670 		pskb->ip_summed = CHECKSUM_UNNECESSARY;
671 		privptr->stats.rx_packets++;
672 		privptr->stats.rx_bytes += skb->len;
673 		/*
674 		 * Since receiving is always initiated from a tasklet (in iucv.c),
675 		 * we must use netif_rx_ni() instead of netif_rx()
676 		 */
677 		netif_rx_ni(skb);
678 		skb_pull(pskb, header->next);
679 		skb_put(pskb, NETIUCV_HDRLEN);
680 	}
681 }
682 
683 static void conn_action_rx(fsm_instance *fi, int event, void *arg)
684 {
685 	struct iucv_event *ev = arg;
686 	struct iucv_connection *conn = ev->conn;
687 	struct iucv_message *msg = ev->data;
688 	struct netiucv_priv *privptr = netdev_priv(conn->netdev);
689 	int rc;
690 
691 	IUCV_DBF_TEXT(trace, 4, __func__);
692 
693 	if (!conn->netdev) {
694 		iucv_message_reject(conn->path, msg);
695 		IUCV_DBF_TEXT(data, 2,
696 			      "Received data for unlinked connection\n");
697 		return;
698 	}
699 	if (msg->length > conn->max_buffsize) {
700 		iucv_message_reject(conn->path, msg);
701 		privptr->stats.rx_dropped++;
702 		IUCV_DBF_TEXT_(data, 2, "msglen %d > max_buffsize %d\n",
703 			       msg->length, conn->max_buffsize);
704 		return;
705 	}
706 	conn->rx_buff->data = conn->rx_buff->head;
707 	skb_reset_tail_pointer(conn->rx_buff);
708 	conn->rx_buff->len = 0;
709 	rc = iucv_message_receive(conn->path, msg, 0, conn->rx_buff->data,
710 				  msg->length, NULL);
711 	if (rc || msg->length < 5) {
712 		privptr->stats.rx_errors++;
713 		IUCV_DBF_TEXT_(data, 2, "rc %d from iucv_receive\n", rc);
714 		return;
715 	}
716 	netiucv_unpack_skb(conn, conn->rx_buff);
717 }
718 
719 static void conn_action_txdone(fsm_instance *fi, int event, void *arg)
720 {
721 	struct iucv_event *ev = arg;
722 	struct iucv_connection *conn = ev->conn;
723 	struct iucv_message *msg = ev->data;
724 	struct iucv_message txmsg;
725 	struct netiucv_priv *privptr = NULL;
726 	u32 single_flag = msg->tag;
727 	u32 txbytes = 0;
728 	u32 txpackets = 0;
729 	u32 stat_maxcq = 0;
730 	struct sk_buff *skb;
731 	unsigned long saveflags;
732 	struct ll_header header;
733 	int rc;
734 
735 	IUCV_DBF_TEXT(trace, 4, __func__);
736 
737 	if (!conn || !conn->netdev) {
738 		IUCV_DBF_TEXT(data, 2,
739 			      "Send confirmation for unlinked connection\n");
740 		return;
741 	}
742 	privptr = netdev_priv(conn->netdev);
743 	conn->prof.tx_pending--;
744 	if (single_flag) {
745 		if ((skb = skb_dequeue(&conn->commit_queue))) {
746 			atomic_dec(&skb->users);
747 			if (privptr) {
748 				privptr->stats.tx_packets++;
749 				privptr->stats.tx_bytes +=
750 					(skb->len - NETIUCV_HDRLEN
751 						  - NETIUCV_HDRLEN);
752 			}
753 			dev_kfree_skb_any(skb);
754 		}
755 	}
756 	conn->tx_buff->data = conn->tx_buff->head;
757 	skb_reset_tail_pointer(conn->tx_buff);
758 	conn->tx_buff->len = 0;
759 	spin_lock_irqsave(&conn->collect_lock, saveflags);
760 	while ((skb = skb_dequeue(&conn->collect_queue))) {
761 		header.next = conn->tx_buff->len + skb->len + NETIUCV_HDRLEN;
762 		memcpy(skb_put(conn->tx_buff, NETIUCV_HDRLEN), &header,
763 		       NETIUCV_HDRLEN);
764 		skb_copy_from_linear_data(skb,
765 					  skb_put(conn->tx_buff, skb->len),
766 					  skb->len);
767 		txbytes += skb->len;
768 		txpackets++;
769 		stat_maxcq++;
770 		atomic_dec(&skb->users);
771 		dev_kfree_skb_any(skb);
772 	}
773 	if (conn->collect_len > conn->prof.maxmulti)
774 		conn->prof.maxmulti = conn->collect_len;
775 	conn->collect_len = 0;
776 	spin_unlock_irqrestore(&conn->collect_lock, saveflags);
777 	if (conn->tx_buff->len == 0) {
778 		fsm_newstate(fi, CONN_STATE_IDLE);
779 		return;
780 	}
781 
782 	header.next = 0;
783 	memcpy(skb_put(conn->tx_buff, NETIUCV_HDRLEN), &header, NETIUCV_HDRLEN);
784 	conn->prof.send_stamp = jiffies;
785 	txmsg.class = 0;
786 	txmsg.tag = 0;
787 	rc = iucv_message_send(conn->path, &txmsg, 0, 0,
788 			       conn->tx_buff->data, conn->tx_buff->len);
789 	conn->prof.doios_multi++;
790 	conn->prof.txlen += conn->tx_buff->len;
791 	conn->prof.tx_pending++;
792 	if (conn->prof.tx_pending > conn->prof.tx_max_pending)
793 		conn->prof.tx_max_pending = conn->prof.tx_pending;
794 	if (rc) {
795 		conn->prof.tx_pending--;
796 		fsm_newstate(fi, CONN_STATE_IDLE);
797 		if (privptr)
798 			privptr->stats.tx_errors += txpackets;
799 		IUCV_DBF_TEXT_(data, 2, "rc %d from iucv_send\n", rc);
800 	} else {
801 		if (privptr) {
802 			privptr->stats.tx_packets += txpackets;
803 			privptr->stats.tx_bytes += txbytes;
804 		}
805 		if (stat_maxcq > conn->prof.maxcqueue)
806 			conn->prof.maxcqueue = stat_maxcq;
807 	}
808 }
809 
810 static void conn_action_connaccept(fsm_instance *fi, int event, void *arg)
811 {
812 	struct iucv_event *ev = arg;
813 	struct iucv_connection *conn = ev->conn;
814 	struct iucv_path *path = ev->data;
815 	struct net_device *netdev = conn->netdev;
816 	struct netiucv_priv *privptr = netdev_priv(netdev);
817 	int rc;
818 
819 	IUCV_DBF_TEXT(trace, 3, __func__);
820 
821 	conn->path = path;
822 	path->msglim = NETIUCV_QUEUELEN_DEFAULT;
823 	path->flags = 0;
824 	rc = iucv_path_accept(path, &netiucv_handler, conn->userdata , conn);
825 	if (rc) {
826 		IUCV_DBF_TEXT_(setup, 2, "rc %d from iucv_accept", rc);
827 		return;
828 	}
829 	fsm_newstate(fi, CONN_STATE_IDLE);
830 	netdev->tx_queue_len = conn->path->msglim;
831 	fsm_event(privptr->fsm, DEV_EVENT_CONUP, netdev);
832 }
833 
834 static void conn_action_connreject(fsm_instance *fi, int event, void *arg)
835 {
836 	struct iucv_event *ev = arg;
837 	struct iucv_path *path = ev->data;
838 
839 	IUCV_DBF_TEXT(trace, 3, __func__);
840 	iucv_path_sever(path, NULL);
841 }
842 
843 static void conn_action_connack(fsm_instance *fi, int event, void *arg)
844 {
845 	struct iucv_connection *conn = arg;
846 	struct net_device *netdev = conn->netdev;
847 	struct netiucv_priv *privptr = netdev_priv(netdev);
848 
849 	IUCV_DBF_TEXT(trace, 3, __func__);
850 	fsm_deltimer(&conn->timer);
851 	fsm_newstate(fi, CONN_STATE_IDLE);
852 	netdev->tx_queue_len = conn->path->msglim;
853 	fsm_event(privptr->fsm, DEV_EVENT_CONUP, netdev);
854 }
855 
856 static void conn_action_conntimsev(fsm_instance *fi, int event, void *arg)
857 {
858 	struct iucv_connection *conn = arg;
859 
860 	IUCV_DBF_TEXT(trace, 3, __func__);
861 	fsm_deltimer(&conn->timer);
862 	iucv_path_sever(conn->path, conn->userdata);
863 	fsm_newstate(fi, CONN_STATE_STARTWAIT);
864 }
865 
866 static void conn_action_connsever(fsm_instance *fi, int event, void *arg)
867 {
868 	struct iucv_connection *conn = arg;
869 	struct net_device *netdev = conn->netdev;
870 	struct netiucv_priv *privptr = netdev_priv(netdev);
871 
872 	IUCV_DBF_TEXT(trace, 3, __func__);
873 
874 	fsm_deltimer(&conn->timer);
875 	iucv_path_sever(conn->path, conn->userdata);
876 	dev_info(privptr->dev, "The peer z/VM guest %s has closed the "
877 			       "connection\n", netiucv_printuser(conn));
878 	IUCV_DBF_TEXT(data, 2,
879 		      "conn_action_connsever: Remote dropped connection\n");
880 	fsm_newstate(fi, CONN_STATE_STARTWAIT);
881 	fsm_event(privptr->fsm, DEV_EVENT_CONDOWN, netdev);
882 }
883 
884 static void conn_action_start(fsm_instance *fi, int event, void *arg)
885 {
886 	struct iucv_connection *conn = arg;
887 	struct net_device *netdev = conn->netdev;
888 	struct netiucv_priv *privptr = netdev_priv(netdev);
889 	int rc;
890 
891 	IUCV_DBF_TEXT(trace, 3, __func__);
892 
893 	fsm_newstate(fi, CONN_STATE_STARTWAIT);
894 
895 	/*
896 	 * We must set the state before calling iucv_connect because the
897 	 * callback handler could be called at any point after the connection
898 	 * request is sent
899 	 */
900 
901 	fsm_newstate(fi, CONN_STATE_SETUPWAIT);
902 	conn->path = iucv_path_alloc(NETIUCV_QUEUELEN_DEFAULT, 0, GFP_KERNEL);
903 	IUCV_DBF_TEXT_(setup, 2, "%s: connecting to %s ...\n",
904 		netdev->name, netiucv_printuser(conn));
905 
906 	rc = iucv_path_connect(conn->path, &netiucv_handler, conn->userid,
907 			       NULL, conn->userdata, conn);
908 	switch (rc) {
909 	case 0:
910 		netdev->tx_queue_len = conn->path->msglim;
911 		fsm_addtimer(&conn->timer, NETIUCV_TIMEOUT_5SEC,
912 			     CONN_EVENT_TIMER, conn);
913 		return;
914 	case 11:
915 		dev_warn(privptr->dev,
916 			"The IUCV device failed to connect to z/VM guest %s\n",
917 			netiucv_printname(conn->userid, 8));
918 		fsm_newstate(fi, CONN_STATE_STARTWAIT);
919 		break;
920 	case 12:
921 		dev_warn(privptr->dev,
922 			"The IUCV device failed to connect to the peer on z/VM"
923 			" guest %s\n", netiucv_printname(conn->userid, 8));
924 		fsm_newstate(fi, CONN_STATE_STARTWAIT);
925 		break;
926 	case 13:
927 		dev_err(privptr->dev,
928 			"Connecting the IUCV device would exceed the maximum"
929 			" number of IUCV connections\n");
930 		fsm_newstate(fi, CONN_STATE_CONNERR);
931 		break;
932 	case 14:
933 		dev_err(privptr->dev,
934 			"z/VM guest %s has too many IUCV connections"
935 			" to connect with the IUCV device\n",
936 			netiucv_printname(conn->userid, 8));
937 		fsm_newstate(fi, CONN_STATE_CONNERR);
938 		break;
939 	case 15:
940 		dev_err(privptr->dev,
941 			"The IUCV device cannot connect to a z/VM guest with no"
942 			" IUCV authorization\n");
943 		fsm_newstate(fi, CONN_STATE_CONNERR);
944 		break;
945 	default:
946 		dev_err(privptr->dev,
947 			"Connecting the IUCV device failed with error %d\n",
948 			rc);
949 		fsm_newstate(fi, CONN_STATE_CONNERR);
950 		break;
951 	}
952 	IUCV_DBF_TEXT_(setup, 5, "iucv_connect rc is %d\n", rc);
953 	kfree(conn->path);
954 	conn->path = NULL;
955 }
956 
957 static void netiucv_purge_skb_queue(struct sk_buff_head *q)
958 {
959 	struct sk_buff *skb;
960 
961 	while ((skb = skb_dequeue(q))) {
962 		atomic_dec(&skb->users);
963 		dev_kfree_skb_any(skb);
964 	}
965 }
966 
967 static void conn_action_stop(fsm_instance *fi, int event, void *arg)
968 {
969 	struct iucv_event *ev = arg;
970 	struct iucv_connection *conn = ev->conn;
971 	struct net_device *netdev = conn->netdev;
972 	struct netiucv_priv *privptr = netdev_priv(netdev);
973 
974 	IUCV_DBF_TEXT(trace, 3, __func__);
975 
976 	fsm_deltimer(&conn->timer);
977 	fsm_newstate(fi, CONN_STATE_STOPPED);
978 	netiucv_purge_skb_queue(&conn->collect_queue);
979 	if (conn->path) {
980 		IUCV_DBF_TEXT(trace, 5, "calling iucv_path_sever\n");
981 		iucv_path_sever(conn->path, conn->userdata);
982 		kfree(conn->path);
983 		conn->path = NULL;
984 	}
985 	netiucv_purge_skb_queue(&conn->commit_queue);
986 	fsm_event(privptr->fsm, DEV_EVENT_CONDOWN, netdev);
987 }
988 
989 static void conn_action_inval(fsm_instance *fi, int event, void *arg)
990 {
991 	struct iucv_connection *conn = arg;
992 	struct net_device *netdev = conn->netdev;
993 
994 	IUCV_DBF_TEXT_(data, 2, "%s('%s'): conn_action_inval called\n",
995 		netdev->name, conn->userid);
996 }
997 
998 static const fsm_node conn_fsm[] = {
999 	{ CONN_STATE_INVALID,   CONN_EVENT_START,    conn_action_inval      },
1000 	{ CONN_STATE_STOPPED,   CONN_EVENT_START,    conn_action_start      },
1001 
1002 	{ CONN_STATE_STOPPED,   CONN_EVENT_STOP,     conn_action_stop       },
1003 	{ CONN_STATE_STARTWAIT, CONN_EVENT_STOP,     conn_action_stop       },
1004 	{ CONN_STATE_SETUPWAIT, CONN_EVENT_STOP,     conn_action_stop       },
1005 	{ CONN_STATE_IDLE,      CONN_EVENT_STOP,     conn_action_stop       },
1006 	{ CONN_STATE_TX,        CONN_EVENT_STOP,     conn_action_stop       },
1007 	{ CONN_STATE_REGERR,    CONN_EVENT_STOP,     conn_action_stop       },
1008 	{ CONN_STATE_CONNERR,   CONN_EVENT_STOP,     conn_action_stop       },
1009 
1010 	{ CONN_STATE_STOPPED,   CONN_EVENT_CONN_REQ, conn_action_connreject },
1011         { CONN_STATE_STARTWAIT, CONN_EVENT_CONN_REQ, conn_action_connaccept },
1012 	{ CONN_STATE_SETUPWAIT, CONN_EVENT_CONN_REQ, conn_action_connaccept },
1013 	{ CONN_STATE_IDLE,      CONN_EVENT_CONN_REQ, conn_action_connreject },
1014 	{ CONN_STATE_TX,        CONN_EVENT_CONN_REQ, conn_action_connreject },
1015 
1016 	{ CONN_STATE_SETUPWAIT, CONN_EVENT_CONN_ACK, conn_action_connack    },
1017 	{ CONN_STATE_SETUPWAIT, CONN_EVENT_TIMER,    conn_action_conntimsev },
1018 
1019 	{ CONN_STATE_SETUPWAIT, CONN_EVENT_CONN_REJ, conn_action_connsever  },
1020 	{ CONN_STATE_IDLE,      CONN_EVENT_CONN_REJ, conn_action_connsever  },
1021 	{ CONN_STATE_TX,        CONN_EVENT_CONN_REJ, conn_action_connsever  },
1022 
1023 	{ CONN_STATE_IDLE,      CONN_EVENT_RX,       conn_action_rx         },
1024 	{ CONN_STATE_TX,        CONN_EVENT_RX,       conn_action_rx         },
1025 
1026 	{ CONN_STATE_TX,        CONN_EVENT_TXDONE,   conn_action_txdone     },
1027 	{ CONN_STATE_IDLE,      CONN_EVENT_TXDONE,   conn_action_txdone     },
1028 };
1029 
1030 static const int CONN_FSM_LEN = sizeof(conn_fsm) / sizeof(fsm_node);
1031 
1032 
1033 /*
1034  * Actions for interface - statemachine.
1035  */
1036 
1037 /**
1038  * dev_action_start
1039  * @fi: An instance of an interface statemachine.
1040  * @event: The event, just happened.
1041  * @arg: Generic pointer, casted from struct net_device * upon call.
1042  *
1043  * Startup connection by sending CONN_EVENT_START to it.
1044  */
1045 static void dev_action_start(fsm_instance *fi, int event, void *arg)
1046 {
1047 	struct net_device   *dev = arg;
1048 	struct netiucv_priv *privptr = netdev_priv(dev);
1049 
1050 	IUCV_DBF_TEXT(trace, 3, __func__);
1051 
1052 	fsm_newstate(fi, DEV_STATE_STARTWAIT);
1053 	fsm_event(privptr->conn->fsm, CONN_EVENT_START, privptr->conn);
1054 }
1055 
1056 /**
1057  * Shutdown connection by sending CONN_EVENT_STOP to it.
1058  *
1059  * @param fi    An instance of an interface statemachine.
1060  * @param event The event, just happened.
1061  * @param arg   Generic pointer, casted from struct net_device * upon call.
1062  */
1063 static void
1064 dev_action_stop(fsm_instance *fi, int event, void *arg)
1065 {
1066 	struct net_device   *dev = arg;
1067 	struct netiucv_priv *privptr = netdev_priv(dev);
1068 	struct iucv_event   ev;
1069 
1070 	IUCV_DBF_TEXT(trace, 3, __func__);
1071 
1072 	ev.conn = privptr->conn;
1073 
1074 	fsm_newstate(fi, DEV_STATE_STOPWAIT);
1075 	fsm_event(privptr->conn->fsm, CONN_EVENT_STOP, &ev);
1076 }
1077 
1078 /**
1079  * Called from connection statemachine
1080  * when a connection is up and running.
1081  *
1082  * @param fi    An instance of an interface statemachine.
1083  * @param event The event, just happened.
1084  * @param arg   Generic pointer, casted from struct net_device * upon call.
1085  */
1086 static void
1087 dev_action_connup(fsm_instance *fi, int event, void *arg)
1088 {
1089 	struct net_device   *dev = arg;
1090 	struct netiucv_priv *privptr = netdev_priv(dev);
1091 
1092 	IUCV_DBF_TEXT(trace, 3, __func__);
1093 
1094 	switch (fsm_getstate(fi)) {
1095 		case DEV_STATE_STARTWAIT:
1096 			fsm_newstate(fi, DEV_STATE_RUNNING);
1097 			dev_info(privptr->dev,
1098 				"The IUCV device has been connected"
1099 				" successfully to %s\n",
1100 				netiucv_printuser(privptr->conn));
1101 			IUCV_DBF_TEXT(setup, 3,
1102 				"connection is up and running\n");
1103 			break;
1104 		case DEV_STATE_STOPWAIT:
1105 			IUCV_DBF_TEXT(data, 2,
1106 				"dev_action_connup: in DEV_STATE_STOPWAIT\n");
1107 			break;
1108 	}
1109 }
1110 
1111 /**
1112  * Called from connection statemachine
1113  * when a connection has been shutdown.
1114  *
1115  * @param fi    An instance of an interface statemachine.
1116  * @param event The event, just happened.
1117  * @param arg   Generic pointer, casted from struct net_device * upon call.
1118  */
1119 static void
1120 dev_action_conndown(fsm_instance *fi, int event, void *arg)
1121 {
1122 	IUCV_DBF_TEXT(trace, 3, __func__);
1123 
1124 	switch (fsm_getstate(fi)) {
1125 		case DEV_STATE_RUNNING:
1126 			fsm_newstate(fi, DEV_STATE_STARTWAIT);
1127 			break;
1128 		case DEV_STATE_STOPWAIT:
1129 			fsm_newstate(fi, DEV_STATE_STOPPED);
1130 			IUCV_DBF_TEXT(setup, 3, "connection is down\n");
1131 			break;
1132 	}
1133 }
1134 
1135 static const fsm_node dev_fsm[] = {
1136 	{ DEV_STATE_STOPPED,    DEV_EVENT_START,   dev_action_start    },
1137 
1138 	{ DEV_STATE_STOPWAIT,   DEV_EVENT_START,   dev_action_start    },
1139 	{ DEV_STATE_STOPWAIT,   DEV_EVENT_CONDOWN, dev_action_conndown },
1140 
1141 	{ DEV_STATE_STARTWAIT,  DEV_EVENT_STOP,    dev_action_stop     },
1142 	{ DEV_STATE_STARTWAIT,  DEV_EVENT_CONUP,   dev_action_connup   },
1143 
1144 	{ DEV_STATE_RUNNING,    DEV_EVENT_STOP,    dev_action_stop     },
1145 	{ DEV_STATE_RUNNING,    DEV_EVENT_CONDOWN, dev_action_conndown },
1146 	{ DEV_STATE_RUNNING,    DEV_EVENT_CONUP,   netiucv_action_nop  },
1147 };
1148 
1149 static const int DEV_FSM_LEN = sizeof(dev_fsm) / sizeof(fsm_node);
1150 
1151 /**
1152  * Transmit a packet.
1153  * This is a helper function for netiucv_tx().
1154  *
1155  * @param conn Connection to be used for sending.
1156  * @param skb Pointer to struct sk_buff of packet to send.
1157  *            The linklevel header has already been set up
1158  *            by netiucv_tx().
1159  *
1160  * @return 0 on success, -ERRNO on failure. (Never fails.)
1161  */
1162 static int netiucv_transmit_skb(struct iucv_connection *conn,
1163 				struct sk_buff *skb)
1164 {
1165 	struct iucv_message msg;
1166 	unsigned long saveflags;
1167 	struct ll_header header;
1168 	int rc;
1169 
1170 	if (fsm_getstate(conn->fsm) != CONN_STATE_IDLE) {
1171 		int l = skb->len + NETIUCV_HDRLEN;
1172 
1173 		spin_lock_irqsave(&conn->collect_lock, saveflags);
1174 		if (conn->collect_len + l >
1175 		    (conn->max_buffsize - NETIUCV_HDRLEN)) {
1176 			rc = -EBUSY;
1177 			IUCV_DBF_TEXT(data, 2,
1178 				      "EBUSY from netiucv_transmit_skb\n");
1179 		} else {
1180 			atomic_inc(&skb->users);
1181 			skb_queue_tail(&conn->collect_queue, skb);
1182 			conn->collect_len += l;
1183 			rc = 0;
1184 		}
1185 		spin_unlock_irqrestore(&conn->collect_lock, saveflags);
1186 	} else {
1187 		struct sk_buff *nskb = skb;
1188 		/**
1189 		 * Copy the skb to a new allocated skb in lowmem only if the
1190 		 * data is located above 2G in memory or tailroom is < 2.
1191 		 */
1192 		unsigned long hi = ((unsigned long)(skb_tail_pointer(skb) +
1193 				    NETIUCV_HDRLEN)) >> 31;
1194 		int copied = 0;
1195 		if (hi || (skb_tailroom(skb) < 2)) {
1196 			nskb = alloc_skb(skb->len + NETIUCV_HDRLEN +
1197 					 NETIUCV_HDRLEN, GFP_ATOMIC | GFP_DMA);
1198 			if (!nskb) {
1199 				IUCV_DBF_TEXT(data, 2, "alloc_skb failed\n");
1200 				rc = -ENOMEM;
1201 				return rc;
1202 			} else {
1203 				skb_reserve(nskb, NETIUCV_HDRLEN);
1204 				memcpy(skb_put(nskb, skb->len),
1205 				       skb->data, skb->len);
1206 			}
1207 			copied = 1;
1208 		}
1209 		/**
1210 		 * skb now is below 2G and has enough room. Add headers.
1211 		 */
1212 		header.next = nskb->len + NETIUCV_HDRLEN;
1213 		memcpy(skb_push(nskb, NETIUCV_HDRLEN), &header, NETIUCV_HDRLEN);
1214 		header.next = 0;
1215 		memcpy(skb_put(nskb, NETIUCV_HDRLEN), &header,  NETIUCV_HDRLEN);
1216 
1217 		fsm_newstate(conn->fsm, CONN_STATE_TX);
1218 		conn->prof.send_stamp = jiffies;
1219 
1220 		msg.tag = 1;
1221 		msg.class = 0;
1222 		rc = iucv_message_send(conn->path, &msg, 0, 0,
1223 				       nskb->data, nskb->len);
1224 		conn->prof.doios_single++;
1225 		conn->prof.txlen += skb->len;
1226 		conn->prof.tx_pending++;
1227 		if (conn->prof.tx_pending > conn->prof.tx_max_pending)
1228 			conn->prof.tx_max_pending = conn->prof.tx_pending;
1229 		if (rc) {
1230 			struct netiucv_priv *privptr;
1231 			fsm_newstate(conn->fsm, CONN_STATE_IDLE);
1232 			conn->prof.tx_pending--;
1233 			privptr = netdev_priv(conn->netdev);
1234 			if (privptr)
1235 				privptr->stats.tx_errors++;
1236 			if (copied)
1237 				dev_kfree_skb(nskb);
1238 			else {
1239 				/**
1240 				 * Remove our headers. They get added
1241 				 * again on retransmit.
1242 				 */
1243 				skb_pull(skb, NETIUCV_HDRLEN);
1244 				skb_trim(skb, skb->len - NETIUCV_HDRLEN);
1245 			}
1246 			IUCV_DBF_TEXT_(data, 2, "rc %d from iucv_send\n", rc);
1247 		} else {
1248 			if (copied)
1249 				dev_kfree_skb(skb);
1250 			atomic_inc(&nskb->users);
1251 			skb_queue_tail(&conn->commit_queue, nskb);
1252 		}
1253 	}
1254 
1255 	return rc;
1256 }
1257 
1258 /*
1259  * Interface API for upper network layers
1260  */
1261 
1262 /**
1263  * Open an interface.
1264  * Called from generic network layer when ifconfig up is run.
1265  *
1266  * @param dev Pointer to interface struct.
1267  *
1268  * @return 0 on success, -ERRNO on failure. (Never fails.)
1269  */
1270 static int netiucv_open(struct net_device *dev)
1271 {
1272 	struct netiucv_priv *priv = netdev_priv(dev);
1273 
1274 	fsm_event(priv->fsm, DEV_EVENT_START, dev);
1275 	return 0;
1276 }
1277 
1278 /**
1279  * Close an interface.
1280  * Called from generic network layer when ifconfig down is run.
1281  *
1282  * @param dev Pointer to interface struct.
1283  *
1284  * @return 0 on success, -ERRNO on failure. (Never fails.)
1285  */
1286 static int netiucv_close(struct net_device *dev)
1287 {
1288 	struct netiucv_priv *priv = netdev_priv(dev);
1289 
1290 	fsm_event(priv->fsm, DEV_EVENT_STOP, dev);
1291 	return 0;
1292 }
1293 
1294 static int netiucv_pm_prepare(struct device *dev)
1295 {
1296 	IUCV_DBF_TEXT(trace, 3, __func__);
1297 	return 0;
1298 }
1299 
1300 static void netiucv_pm_complete(struct device *dev)
1301 {
1302 	IUCV_DBF_TEXT(trace, 3, __func__);
1303 	return;
1304 }
1305 
1306 /**
1307  * netiucv_pm_freeze() - Freeze PM callback
1308  * @dev:	netiucv device
1309  *
1310  * close open netiucv interfaces
1311  */
1312 static int netiucv_pm_freeze(struct device *dev)
1313 {
1314 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1315 	struct net_device *ndev = NULL;
1316 	int rc = 0;
1317 
1318 	IUCV_DBF_TEXT(trace, 3, __func__);
1319 	if (priv && priv->conn)
1320 		ndev = priv->conn->netdev;
1321 	if (!ndev)
1322 		goto out;
1323 	netif_device_detach(ndev);
1324 	priv->pm_state = fsm_getstate(priv->fsm);
1325 	rc = netiucv_close(ndev);
1326 out:
1327 	return rc;
1328 }
1329 
1330 /**
1331  * netiucv_pm_restore_thaw() - Thaw and restore PM callback
1332  * @dev:	netiucv device
1333  *
1334  * re-open netiucv interfaces closed during freeze
1335  */
1336 static int netiucv_pm_restore_thaw(struct device *dev)
1337 {
1338 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1339 	struct net_device *ndev = NULL;
1340 	int rc = 0;
1341 
1342 	IUCV_DBF_TEXT(trace, 3, __func__);
1343 	if (priv && priv->conn)
1344 		ndev = priv->conn->netdev;
1345 	if (!ndev)
1346 		goto out;
1347 	switch (priv->pm_state) {
1348 	case DEV_STATE_RUNNING:
1349 	case DEV_STATE_STARTWAIT:
1350 		rc = netiucv_open(ndev);
1351 		break;
1352 	default:
1353 		break;
1354 	}
1355 	netif_device_attach(ndev);
1356 out:
1357 	return rc;
1358 }
1359 
1360 /**
1361  * Start transmission of a packet.
1362  * Called from generic network device layer.
1363  *
1364  * @param skb Pointer to buffer containing the packet.
1365  * @param dev Pointer to interface struct.
1366  *
1367  * @return 0 if packet consumed, !0 if packet rejected.
1368  *         Note: If we return !0, then the packet is free'd by
1369  *               the generic network layer.
1370  */
1371 static int netiucv_tx(struct sk_buff *skb, struct net_device *dev)
1372 {
1373 	struct netiucv_priv *privptr = netdev_priv(dev);
1374 	int rc;
1375 
1376 	IUCV_DBF_TEXT(trace, 4, __func__);
1377 	/**
1378 	 * Some sanity checks ...
1379 	 */
1380 	if (skb == NULL) {
1381 		IUCV_DBF_TEXT(data, 2, "netiucv_tx: skb is NULL\n");
1382 		privptr->stats.tx_dropped++;
1383 		return NETDEV_TX_OK;
1384 	}
1385 	if (skb_headroom(skb) < NETIUCV_HDRLEN) {
1386 		IUCV_DBF_TEXT(data, 2,
1387 			"netiucv_tx: skb_headroom < NETIUCV_HDRLEN\n");
1388 		dev_kfree_skb(skb);
1389 		privptr->stats.tx_dropped++;
1390 		return NETDEV_TX_OK;
1391 	}
1392 
1393 	/**
1394 	 * If connection is not running, try to restart it
1395 	 * and throw away packet.
1396 	 */
1397 	if (fsm_getstate(privptr->fsm) != DEV_STATE_RUNNING) {
1398 		dev_kfree_skb(skb);
1399 		privptr->stats.tx_dropped++;
1400 		privptr->stats.tx_errors++;
1401 		privptr->stats.tx_carrier_errors++;
1402 		return NETDEV_TX_OK;
1403 	}
1404 
1405 	if (netiucv_test_and_set_busy(dev)) {
1406 		IUCV_DBF_TEXT(data, 2, "EBUSY from netiucv_tx\n");
1407 		return NETDEV_TX_BUSY;
1408 	}
1409 	netif_trans_update(dev);
1410 	rc = netiucv_transmit_skb(privptr->conn, skb);
1411 	netiucv_clear_busy(dev);
1412 	return rc ? NETDEV_TX_BUSY : NETDEV_TX_OK;
1413 }
1414 
1415 /**
1416  * netiucv_stats
1417  * @dev: Pointer to interface struct.
1418  *
1419  * Returns interface statistics of a device.
1420  *
1421  * Returns pointer to stats struct of this interface.
1422  */
1423 static struct net_device_stats *netiucv_stats (struct net_device * dev)
1424 {
1425 	struct netiucv_priv *priv = netdev_priv(dev);
1426 
1427 	IUCV_DBF_TEXT(trace, 5, __func__);
1428 	return &priv->stats;
1429 }
1430 
1431 /*
1432  * attributes in sysfs
1433  */
1434 
1435 static ssize_t user_show(struct device *dev, struct device_attribute *attr,
1436 			 char *buf)
1437 {
1438 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1439 
1440 	IUCV_DBF_TEXT(trace, 5, __func__);
1441 	return sprintf(buf, "%s\n", netiucv_printuser(priv->conn));
1442 }
1443 
1444 static int netiucv_check_user(const char *buf, size_t count, char *username,
1445 			      char *userdata)
1446 {
1447 	const char *p;
1448 	int i;
1449 
1450 	p = strchr(buf, '.');
1451 	if ((p && ((count > 26) ||
1452 		   ((p - buf) > 8) ||
1453 		   (buf + count - p > 18))) ||
1454 	    (!p && (count > 9))) {
1455 		IUCV_DBF_TEXT(setup, 2, "conn_write: too long\n");
1456 		return -EINVAL;
1457 	}
1458 
1459 	for (i = 0, p = buf; i < 8 && *p && *p != '.'; i++, p++) {
1460 		if (isalnum(*p) || *p == '$') {
1461 			username[i] = toupper(*p);
1462 			continue;
1463 		}
1464 		if (*p == '\n')
1465 			/* trailing lf, grr */
1466 			break;
1467 		IUCV_DBF_TEXT_(setup, 2,
1468 			       "conn_write: invalid character %02x\n", *p);
1469 		return -EINVAL;
1470 	}
1471 	while (i < 8)
1472 		username[i++] = ' ';
1473 	username[8] = '\0';
1474 
1475 	if (*p == '.') {
1476 		p++;
1477 		for (i = 0; i < 16 && *p; i++, p++) {
1478 			if (*p == '\n')
1479 				break;
1480 			userdata[i] = toupper(*p);
1481 		}
1482 		while (i > 0 && i < 16)
1483 			userdata[i++] = ' ';
1484 	} else
1485 		memcpy(userdata, iucvMagic_ascii, 16);
1486 	userdata[16] = '\0';
1487 	ASCEBC(userdata, 16);
1488 
1489 	return 0;
1490 }
1491 
1492 static ssize_t user_write(struct device *dev, struct device_attribute *attr,
1493 			  const char *buf, size_t count)
1494 {
1495 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1496 	struct net_device *ndev = priv->conn->netdev;
1497 	char	username[9];
1498 	char	userdata[17];
1499 	int	rc;
1500 	struct iucv_connection *cp;
1501 
1502 	IUCV_DBF_TEXT(trace, 3, __func__);
1503 	rc = netiucv_check_user(buf, count, username, userdata);
1504 	if (rc)
1505 		return rc;
1506 
1507 	if (memcmp(username, priv->conn->userid, 9) &&
1508 	    (ndev->flags & (IFF_UP | IFF_RUNNING))) {
1509 		/* username changed while the interface is active. */
1510 		IUCV_DBF_TEXT(setup, 2, "user_write: device active\n");
1511 		return -EPERM;
1512 	}
1513 	read_lock_bh(&iucv_connection_rwlock);
1514 	list_for_each_entry(cp, &iucv_connection_list, list) {
1515 		if (!strncmp(username, cp->userid, 9) &&
1516 		   !strncmp(userdata, cp->userdata, 17) && cp->netdev != ndev) {
1517 			read_unlock_bh(&iucv_connection_rwlock);
1518 			IUCV_DBF_TEXT_(setup, 2, "user_write: Connection to %s "
1519 				"already exists\n", netiucv_printuser(cp));
1520 			return -EEXIST;
1521 		}
1522 	}
1523 	read_unlock_bh(&iucv_connection_rwlock);
1524 	memcpy(priv->conn->userid, username, 9);
1525 	memcpy(priv->conn->userdata, userdata, 17);
1526 	return count;
1527 }
1528 
1529 static DEVICE_ATTR(user, 0644, user_show, user_write);
1530 
1531 static ssize_t buffer_show (struct device *dev, struct device_attribute *attr,
1532 			    char *buf)
1533 {
1534 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1535 
1536 	IUCV_DBF_TEXT(trace, 5, __func__);
1537 	return sprintf(buf, "%d\n", priv->conn->max_buffsize);
1538 }
1539 
1540 static ssize_t buffer_write (struct device *dev, struct device_attribute *attr,
1541 			     const char *buf, size_t count)
1542 {
1543 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1544 	struct net_device *ndev = priv->conn->netdev;
1545 	unsigned int bs1;
1546 	int rc;
1547 
1548 	IUCV_DBF_TEXT(trace, 3, __func__);
1549 	if (count >= 39)
1550 		return -EINVAL;
1551 
1552 	rc = kstrtouint(buf, 0, &bs1);
1553 
1554 	if (rc == -EINVAL) {
1555 		IUCV_DBF_TEXT_(setup, 2, "buffer_write: invalid char %s\n",
1556 			buf);
1557 		return -EINVAL;
1558 	}
1559 	if ((rc == -ERANGE) || (bs1 > NETIUCV_BUFSIZE_MAX)) {
1560 		IUCV_DBF_TEXT_(setup, 2,
1561 			"buffer_write: buffer size %d too large\n",
1562 			bs1);
1563 		return -EINVAL;
1564 	}
1565 	if ((ndev->flags & IFF_RUNNING) &&
1566 	    (bs1 < (ndev->mtu + NETIUCV_HDRLEN + 2))) {
1567 		IUCV_DBF_TEXT_(setup, 2,
1568 			"buffer_write: buffer size %d too small\n",
1569 			bs1);
1570 		return -EINVAL;
1571 	}
1572 	if (bs1 < (576 + NETIUCV_HDRLEN + NETIUCV_HDRLEN)) {
1573 		IUCV_DBF_TEXT_(setup, 2,
1574 			"buffer_write: buffer size %d too small\n",
1575 			bs1);
1576 		return -EINVAL;
1577 	}
1578 
1579 	priv->conn->max_buffsize = bs1;
1580 	if (!(ndev->flags & IFF_RUNNING))
1581 		ndev->mtu = bs1 - NETIUCV_HDRLEN - NETIUCV_HDRLEN;
1582 
1583 	return count;
1584 
1585 }
1586 
1587 static DEVICE_ATTR(buffer, 0644, buffer_show, buffer_write);
1588 
1589 static ssize_t dev_fsm_show (struct device *dev, struct device_attribute *attr,
1590 			     char *buf)
1591 {
1592 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1593 
1594 	IUCV_DBF_TEXT(trace, 5, __func__);
1595 	return sprintf(buf, "%s\n", fsm_getstate_str(priv->fsm));
1596 }
1597 
1598 static DEVICE_ATTR(device_fsm_state, 0444, dev_fsm_show, NULL);
1599 
1600 static ssize_t conn_fsm_show (struct device *dev,
1601 			      struct device_attribute *attr, char *buf)
1602 {
1603 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1604 
1605 	IUCV_DBF_TEXT(trace, 5, __func__);
1606 	return sprintf(buf, "%s\n", fsm_getstate_str(priv->conn->fsm));
1607 }
1608 
1609 static DEVICE_ATTR(connection_fsm_state, 0444, conn_fsm_show, NULL);
1610 
1611 static ssize_t maxmulti_show (struct device *dev,
1612 			      struct device_attribute *attr, char *buf)
1613 {
1614 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1615 
1616 	IUCV_DBF_TEXT(trace, 5, __func__);
1617 	return sprintf(buf, "%ld\n", priv->conn->prof.maxmulti);
1618 }
1619 
1620 static ssize_t maxmulti_write (struct device *dev,
1621 			       struct device_attribute *attr,
1622 			       const char *buf, size_t count)
1623 {
1624 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1625 
1626 	IUCV_DBF_TEXT(trace, 4, __func__);
1627 	priv->conn->prof.maxmulti = 0;
1628 	return count;
1629 }
1630 
1631 static DEVICE_ATTR(max_tx_buffer_used, 0644, maxmulti_show, maxmulti_write);
1632 
1633 static ssize_t maxcq_show (struct device *dev, struct device_attribute *attr,
1634 			   char *buf)
1635 {
1636 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1637 
1638 	IUCV_DBF_TEXT(trace, 5, __func__);
1639 	return sprintf(buf, "%ld\n", priv->conn->prof.maxcqueue);
1640 }
1641 
1642 static ssize_t maxcq_write (struct device *dev, struct device_attribute *attr,
1643 			    const char *buf, size_t count)
1644 {
1645 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1646 
1647 	IUCV_DBF_TEXT(trace, 4, __func__);
1648 	priv->conn->prof.maxcqueue = 0;
1649 	return count;
1650 }
1651 
1652 static DEVICE_ATTR(max_chained_skbs, 0644, maxcq_show, maxcq_write);
1653 
1654 static ssize_t sdoio_show (struct device *dev, struct device_attribute *attr,
1655 			   char *buf)
1656 {
1657 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1658 
1659 	IUCV_DBF_TEXT(trace, 5, __func__);
1660 	return sprintf(buf, "%ld\n", priv->conn->prof.doios_single);
1661 }
1662 
1663 static ssize_t sdoio_write (struct device *dev, struct device_attribute *attr,
1664 			    const char *buf, size_t count)
1665 {
1666 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1667 
1668 	IUCV_DBF_TEXT(trace, 4, __func__);
1669 	priv->conn->prof.doios_single = 0;
1670 	return count;
1671 }
1672 
1673 static DEVICE_ATTR(tx_single_write_ops, 0644, sdoio_show, sdoio_write);
1674 
1675 static ssize_t mdoio_show (struct device *dev, struct device_attribute *attr,
1676 			   char *buf)
1677 {
1678 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1679 
1680 	IUCV_DBF_TEXT(trace, 5, __func__);
1681 	return sprintf(buf, "%ld\n", priv->conn->prof.doios_multi);
1682 }
1683 
1684 static ssize_t mdoio_write (struct device *dev, struct device_attribute *attr,
1685 			    const char *buf, size_t count)
1686 {
1687 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1688 
1689 	IUCV_DBF_TEXT(trace, 5, __func__);
1690 	priv->conn->prof.doios_multi = 0;
1691 	return count;
1692 }
1693 
1694 static DEVICE_ATTR(tx_multi_write_ops, 0644, mdoio_show, mdoio_write);
1695 
1696 static ssize_t txlen_show (struct device *dev, struct device_attribute *attr,
1697 			   char *buf)
1698 {
1699 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1700 
1701 	IUCV_DBF_TEXT(trace, 5, __func__);
1702 	return sprintf(buf, "%ld\n", priv->conn->prof.txlen);
1703 }
1704 
1705 static ssize_t txlen_write (struct device *dev, struct device_attribute *attr,
1706 			    const char *buf, size_t count)
1707 {
1708 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1709 
1710 	IUCV_DBF_TEXT(trace, 4, __func__);
1711 	priv->conn->prof.txlen = 0;
1712 	return count;
1713 }
1714 
1715 static DEVICE_ATTR(netto_bytes, 0644, txlen_show, txlen_write);
1716 
1717 static ssize_t txtime_show (struct device *dev, struct device_attribute *attr,
1718 			    char *buf)
1719 {
1720 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1721 
1722 	IUCV_DBF_TEXT(trace, 5, __func__);
1723 	return sprintf(buf, "%ld\n", priv->conn->prof.tx_time);
1724 }
1725 
1726 static ssize_t txtime_write (struct device *dev, struct device_attribute *attr,
1727 			     const char *buf, size_t count)
1728 {
1729 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1730 
1731 	IUCV_DBF_TEXT(trace, 4, __func__);
1732 	priv->conn->prof.tx_time = 0;
1733 	return count;
1734 }
1735 
1736 static DEVICE_ATTR(max_tx_io_time, 0644, txtime_show, txtime_write);
1737 
1738 static ssize_t txpend_show (struct device *dev, struct device_attribute *attr,
1739 			    char *buf)
1740 {
1741 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1742 
1743 	IUCV_DBF_TEXT(trace, 5, __func__);
1744 	return sprintf(buf, "%ld\n", priv->conn->prof.tx_pending);
1745 }
1746 
1747 static ssize_t txpend_write (struct device *dev, struct device_attribute *attr,
1748 			     const char *buf, size_t count)
1749 {
1750 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1751 
1752 	IUCV_DBF_TEXT(trace, 4, __func__);
1753 	priv->conn->prof.tx_pending = 0;
1754 	return count;
1755 }
1756 
1757 static DEVICE_ATTR(tx_pending, 0644, txpend_show, txpend_write);
1758 
1759 static ssize_t txmpnd_show (struct device *dev, struct device_attribute *attr,
1760 			    char *buf)
1761 {
1762 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1763 
1764 	IUCV_DBF_TEXT(trace, 5, __func__);
1765 	return sprintf(buf, "%ld\n", priv->conn->prof.tx_max_pending);
1766 }
1767 
1768 static ssize_t txmpnd_write (struct device *dev, struct device_attribute *attr,
1769 			     const char *buf, size_t count)
1770 {
1771 	struct netiucv_priv *priv = dev_get_drvdata(dev);
1772 
1773 	IUCV_DBF_TEXT(trace, 4, __func__);
1774 	priv->conn->prof.tx_max_pending = 0;
1775 	return count;
1776 }
1777 
1778 static DEVICE_ATTR(tx_max_pending, 0644, txmpnd_show, txmpnd_write);
1779 
1780 static struct attribute *netiucv_attrs[] = {
1781 	&dev_attr_buffer.attr,
1782 	&dev_attr_user.attr,
1783 	NULL,
1784 };
1785 
1786 static struct attribute_group netiucv_attr_group = {
1787 	.attrs = netiucv_attrs,
1788 };
1789 
1790 static struct attribute *netiucv_stat_attrs[] = {
1791 	&dev_attr_device_fsm_state.attr,
1792 	&dev_attr_connection_fsm_state.attr,
1793 	&dev_attr_max_tx_buffer_used.attr,
1794 	&dev_attr_max_chained_skbs.attr,
1795 	&dev_attr_tx_single_write_ops.attr,
1796 	&dev_attr_tx_multi_write_ops.attr,
1797 	&dev_attr_netto_bytes.attr,
1798 	&dev_attr_max_tx_io_time.attr,
1799 	&dev_attr_tx_pending.attr,
1800 	&dev_attr_tx_max_pending.attr,
1801 	NULL,
1802 };
1803 
1804 static struct attribute_group netiucv_stat_attr_group = {
1805 	.name  = "stats",
1806 	.attrs = netiucv_stat_attrs,
1807 };
1808 
1809 static const struct attribute_group *netiucv_attr_groups[] = {
1810 	&netiucv_stat_attr_group,
1811 	&netiucv_attr_group,
1812 	NULL,
1813 };
1814 
1815 static int netiucv_register_device(struct net_device *ndev)
1816 {
1817 	struct netiucv_priv *priv = netdev_priv(ndev);
1818 	struct device *dev = kzalloc(sizeof(struct device), GFP_KERNEL);
1819 	int ret;
1820 
1821 	IUCV_DBF_TEXT(trace, 3, __func__);
1822 
1823 	if (dev) {
1824 		dev_set_name(dev, "net%s", ndev->name);
1825 		dev->bus = &iucv_bus;
1826 		dev->parent = iucv_root;
1827 		dev->groups = netiucv_attr_groups;
1828 		/*
1829 		 * The release function could be called after the
1830 		 * module has been unloaded. It's _only_ task is to
1831 		 * free the struct. Therefore, we specify kfree()
1832 		 * directly here. (Probably a little bit obfuscating
1833 		 * but legitime ...).
1834 		 */
1835 		dev->release = (void (*)(struct device *))kfree;
1836 		dev->driver = &netiucv_driver;
1837 	} else
1838 		return -ENOMEM;
1839 
1840 	ret = device_register(dev);
1841 	if (ret) {
1842 		put_device(dev);
1843 		return ret;
1844 	}
1845 	priv->dev = dev;
1846 	dev_set_drvdata(dev, priv);
1847 	return 0;
1848 }
1849 
1850 static void netiucv_unregister_device(struct device *dev)
1851 {
1852 	IUCV_DBF_TEXT(trace, 3, __func__);
1853 	device_unregister(dev);
1854 }
1855 
1856 /**
1857  * Allocate and initialize a new connection structure.
1858  * Add it to the list of netiucv connections;
1859  */
1860 static struct iucv_connection *netiucv_new_connection(struct net_device *dev,
1861 						      char *username,
1862 						      char *userdata)
1863 {
1864 	struct iucv_connection *conn;
1865 
1866 	conn = kzalloc(sizeof(*conn), GFP_KERNEL);
1867 	if (!conn)
1868 		goto out;
1869 	skb_queue_head_init(&conn->collect_queue);
1870 	skb_queue_head_init(&conn->commit_queue);
1871 	spin_lock_init(&conn->collect_lock);
1872 	conn->max_buffsize = NETIUCV_BUFSIZE_DEFAULT;
1873 	conn->netdev = dev;
1874 
1875 	conn->rx_buff = alloc_skb(conn->max_buffsize, GFP_KERNEL | GFP_DMA);
1876 	if (!conn->rx_buff)
1877 		goto out_conn;
1878 	conn->tx_buff = alloc_skb(conn->max_buffsize, GFP_KERNEL | GFP_DMA);
1879 	if (!conn->tx_buff)
1880 		goto out_rx;
1881 	conn->fsm = init_fsm("netiucvconn", conn_state_names,
1882 			     conn_event_names, NR_CONN_STATES,
1883 			     NR_CONN_EVENTS, conn_fsm, CONN_FSM_LEN,
1884 			     GFP_KERNEL);
1885 	if (!conn->fsm)
1886 		goto out_tx;
1887 
1888 	fsm_settimer(conn->fsm, &conn->timer);
1889 	fsm_newstate(conn->fsm, CONN_STATE_INVALID);
1890 
1891 	if (userdata)
1892 		memcpy(conn->userdata, userdata, 17);
1893 	if (username) {
1894 		memcpy(conn->userid, username, 9);
1895 		fsm_newstate(conn->fsm, CONN_STATE_STOPPED);
1896 	}
1897 
1898 	write_lock_bh(&iucv_connection_rwlock);
1899 	list_add_tail(&conn->list, &iucv_connection_list);
1900 	write_unlock_bh(&iucv_connection_rwlock);
1901 	return conn;
1902 
1903 out_tx:
1904 	kfree_skb(conn->tx_buff);
1905 out_rx:
1906 	kfree_skb(conn->rx_buff);
1907 out_conn:
1908 	kfree(conn);
1909 out:
1910 	return NULL;
1911 }
1912 
1913 /**
1914  * Release a connection structure and remove it from the
1915  * list of netiucv connections.
1916  */
1917 static void netiucv_remove_connection(struct iucv_connection *conn)
1918 {
1919 
1920 	IUCV_DBF_TEXT(trace, 3, __func__);
1921 	write_lock_bh(&iucv_connection_rwlock);
1922 	list_del_init(&conn->list);
1923 	write_unlock_bh(&iucv_connection_rwlock);
1924 	fsm_deltimer(&conn->timer);
1925 	netiucv_purge_skb_queue(&conn->collect_queue);
1926 	if (conn->path) {
1927 		iucv_path_sever(conn->path, conn->userdata);
1928 		kfree(conn->path);
1929 		conn->path = NULL;
1930 	}
1931 	netiucv_purge_skb_queue(&conn->commit_queue);
1932 	kfree_fsm(conn->fsm);
1933 	kfree_skb(conn->rx_buff);
1934 	kfree_skb(conn->tx_buff);
1935 }
1936 
1937 /**
1938  * Release everything of a net device.
1939  */
1940 static void netiucv_free_netdevice(struct net_device *dev)
1941 {
1942 	struct netiucv_priv *privptr = netdev_priv(dev);
1943 
1944 	IUCV_DBF_TEXT(trace, 3, __func__);
1945 
1946 	if (!dev)
1947 		return;
1948 
1949 	if (privptr) {
1950 		if (privptr->conn)
1951 			netiucv_remove_connection(privptr->conn);
1952 		if (privptr->fsm)
1953 			kfree_fsm(privptr->fsm);
1954 		privptr->conn = NULL; privptr->fsm = NULL;
1955 		/* privptr gets freed by free_netdev() */
1956 	}
1957 	free_netdev(dev);
1958 }
1959 
1960 /**
1961  * Initialize a net device. (Called from kernel in alloc_netdev())
1962  */
1963 static const struct net_device_ops netiucv_netdev_ops = {
1964 	.ndo_open		= netiucv_open,
1965 	.ndo_stop		= netiucv_close,
1966 	.ndo_get_stats		= netiucv_stats,
1967 	.ndo_start_xmit		= netiucv_tx,
1968 };
1969 
1970 static void netiucv_setup_netdevice(struct net_device *dev)
1971 {
1972 	dev->mtu	         = NETIUCV_MTU_DEFAULT;
1973 	dev->min_mtu		 = 576;
1974 	dev->max_mtu		 = NETIUCV_MTU_MAX;
1975 	dev->destructor          = netiucv_free_netdevice;
1976 	dev->hard_header_len     = NETIUCV_HDRLEN;
1977 	dev->addr_len            = 0;
1978 	dev->type                = ARPHRD_SLIP;
1979 	dev->tx_queue_len        = NETIUCV_QUEUELEN_DEFAULT;
1980 	dev->flags	         = IFF_POINTOPOINT | IFF_NOARP;
1981 	dev->netdev_ops		 = &netiucv_netdev_ops;
1982 }
1983 
1984 /**
1985  * Allocate and initialize everything of a net device.
1986  */
1987 static struct net_device *netiucv_init_netdevice(char *username, char *userdata)
1988 {
1989 	struct netiucv_priv *privptr;
1990 	struct net_device *dev;
1991 
1992 	dev = alloc_netdev(sizeof(struct netiucv_priv), "iucv%d",
1993 			   NET_NAME_UNKNOWN, netiucv_setup_netdevice);
1994 	if (!dev)
1995 		return NULL;
1996 	rtnl_lock();
1997 	if (dev_alloc_name(dev, dev->name) < 0)
1998 		goto out_netdev;
1999 
2000 	privptr = netdev_priv(dev);
2001 	privptr->fsm = init_fsm("netiucvdev", dev_state_names,
2002 				dev_event_names, NR_DEV_STATES, NR_DEV_EVENTS,
2003 				dev_fsm, DEV_FSM_LEN, GFP_KERNEL);
2004 	if (!privptr->fsm)
2005 		goto out_netdev;
2006 
2007 	privptr->conn = netiucv_new_connection(dev, username, userdata);
2008 	if (!privptr->conn) {
2009 		IUCV_DBF_TEXT(setup, 2, "NULL from netiucv_new_connection\n");
2010 		goto out_fsm;
2011 	}
2012 	fsm_newstate(privptr->fsm, DEV_STATE_STOPPED);
2013 	return dev;
2014 
2015 out_fsm:
2016 	kfree_fsm(privptr->fsm);
2017 out_netdev:
2018 	rtnl_unlock();
2019 	free_netdev(dev);
2020 	return NULL;
2021 }
2022 
2023 static ssize_t conn_write(struct device_driver *drv,
2024 			  const char *buf, size_t count)
2025 {
2026 	char username[9];
2027 	char userdata[17];
2028 	int rc;
2029 	struct net_device *dev;
2030 	struct netiucv_priv *priv;
2031 	struct iucv_connection *cp;
2032 
2033 	IUCV_DBF_TEXT(trace, 3, __func__);
2034 	rc = netiucv_check_user(buf, count, username, userdata);
2035 	if (rc)
2036 		return rc;
2037 
2038 	read_lock_bh(&iucv_connection_rwlock);
2039 	list_for_each_entry(cp, &iucv_connection_list, list) {
2040 		if (!strncmp(username, cp->userid, 9) &&
2041 		    !strncmp(userdata, cp->userdata, 17)) {
2042 			read_unlock_bh(&iucv_connection_rwlock);
2043 			IUCV_DBF_TEXT_(setup, 2, "conn_write: Connection to %s "
2044 				"already exists\n", netiucv_printuser(cp));
2045 			return -EEXIST;
2046 		}
2047 	}
2048 	read_unlock_bh(&iucv_connection_rwlock);
2049 
2050 	dev = netiucv_init_netdevice(username, userdata);
2051 	if (!dev) {
2052 		IUCV_DBF_TEXT(setup, 2, "NULL from netiucv_init_netdevice\n");
2053 		return -ENODEV;
2054 	}
2055 
2056 	rc = netiucv_register_device(dev);
2057 	if (rc) {
2058 		rtnl_unlock();
2059 		IUCV_DBF_TEXT_(setup, 2,
2060 			"ret %d from netiucv_register_device\n", rc);
2061 		goto out_free_ndev;
2062 	}
2063 
2064 	/* sysfs magic */
2065 	priv = netdev_priv(dev);
2066 	SET_NETDEV_DEV(dev, priv->dev);
2067 
2068 	rc = register_netdevice(dev);
2069 	rtnl_unlock();
2070 	if (rc)
2071 		goto out_unreg;
2072 
2073 	dev_info(priv->dev, "The IUCV interface to %s has been established "
2074 			    "successfully\n",
2075 		netiucv_printuser(priv->conn));
2076 
2077 	return count;
2078 
2079 out_unreg:
2080 	netiucv_unregister_device(priv->dev);
2081 out_free_ndev:
2082 	netiucv_free_netdevice(dev);
2083 	return rc;
2084 }
2085 
2086 static DRIVER_ATTR(connection, 0200, NULL, conn_write);
2087 
2088 static ssize_t remove_write (struct device_driver *drv,
2089 			     const char *buf, size_t count)
2090 {
2091 	struct iucv_connection *cp;
2092         struct net_device *ndev;
2093         struct netiucv_priv *priv;
2094         struct device *dev;
2095         char name[IFNAMSIZ];
2096 	const char *p;
2097         int i;
2098 
2099 	IUCV_DBF_TEXT(trace, 3, __func__);
2100 
2101         if (count >= IFNAMSIZ)
2102                 count = IFNAMSIZ - 1;
2103 
2104 	for (i = 0, p = buf; i < count && *p; i++, p++) {
2105 		if (*p == '\n' || *p == ' ')
2106                         /* trailing lf, grr */
2107                         break;
2108 		name[i] = *p;
2109         }
2110         name[i] = '\0';
2111 
2112 	read_lock_bh(&iucv_connection_rwlock);
2113 	list_for_each_entry(cp, &iucv_connection_list, list) {
2114 		ndev = cp->netdev;
2115 		priv = netdev_priv(ndev);
2116                 dev = priv->dev;
2117 		if (strncmp(name, ndev->name, count))
2118 			continue;
2119 		read_unlock_bh(&iucv_connection_rwlock);
2120                 if (ndev->flags & (IFF_UP | IFF_RUNNING)) {
2121 			dev_warn(dev, "The IUCV device is connected"
2122 				" to %s and cannot be removed\n",
2123 				priv->conn->userid);
2124 			IUCV_DBF_TEXT(data, 2, "remove_write: still active\n");
2125 			return -EPERM;
2126                 }
2127                 unregister_netdev(ndev);
2128                 netiucv_unregister_device(dev);
2129                 return count;
2130         }
2131 	read_unlock_bh(&iucv_connection_rwlock);
2132 	IUCV_DBF_TEXT(data, 2, "remove_write: unknown device\n");
2133         return -EINVAL;
2134 }
2135 
2136 static DRIVER_ATTR(remove, 0200, NULL, remove_write);
2137 
2138 static struct attribute * netiucv_drv_attrs[] = {
2139 	&driver_attr_connection.attr,
2140 	&driver_attr_remove.attr,
2141 	NULL,
2142 };
2143 
2144 static struct attribute_group netiucv_drv_attr_group = {
2145 	.attrs = netiucv_drv_attrs,
2146 };
2147 
2148 static const struct attribute_group *netiucv_drv_attr_groups[] = {
2149 	&netiucv_drv_attr_group,
2150 	NULL,
2151 };
2152 
2153 static void netiucv_banner(void)
2154 {
2155 	pr_info("driver initialized\n");
2156 }
2157 
2158 static void __exit netiucv_exit(void)
2159 {
2160 	struct iucv_connection *cp;
2161 	struct net_device *ndev;
2162 	struct netiucv_priv *priv;
2163 	struct device *dev;
2164 
2165 	IUCV_DBF_TEXT(trace, 3, __func__);
2166 	while (!list_empty(&iucv_connection_list)) {
2167 		cp = list_entry(iucv_connection_list.next,
2168 				struct iucv_connection, list);
2169 		ndev = cp->netdev;
2170 		priv = netdev_priv(ndev);
2171 		dev = priv->dev;
2172 
2173 		unregister_netdev(ndev);
2174 		netiucv_unregister_device(dev);
2175 	}
2176 
2177 	device_unregister(netiucv_dev);
2178 	driver_unregister(&netiucv_driver);
2179 	iucv_unregister(&netiucv_handler, 1);
2180 	iucv_unregister_dbf_views();
2181 
2182 	pr_info("driver unloaded\n");
2183 	return;
2184 }
2185 
2186 static int __init netiucv_init(void)
2187 {
2188 	int rc;
2189 
2190 	rc = iucv_register_dbf_views();
2191 	if (rc)
2192 		goto out;
2193 	rc = iucv_register(&netiucv_handler, 1);
2194 	if (rc)
2195 		goto out_dbf;
2196 	IUCV_DBF_TEXT(trace, 3, __func__);
2197 	netiucv_driver.groups = netiucv_drv_attr_groups;
2198 	rc = driver_register(&netiucv_driver);
2199 	if (rc) {
2200 		IUCV_DBF_TEXT_(setup, 2, "ret %d from driver_register\n", rc);
2201 		goto out_iucv;
2202 	}
2203 	/* establish dummy device */
2204 	netiucv_dev = kzalloc(sizeof(struct device), GFP_KERNEL);
2205 	if (!netiucv_dev) {
2206 		rc = -ENOMEM;
2207 		goto out_driver;
2208 	}
2209 	dev_set_name(netiucv_dev, "netiucv");
2210 	netiucv_dev->bus = &iucv_bus;
2211 	netiucv_dev->parent = iucv_root;
2212 	netiucv_dev->release = (void (*)(struct device *))kfree;
2213 	netiucv_dev->driver = &netiucv_driver;
2214 	rc = device_register(netiucv_dev);
2215 	if (rc) {
2216 		put_device(netiucv_dev);
2217 		goto out_driver;
2218 	}
2219 	netiucv_banner();
2220 	return rc;
2221 
2222 out_driver:
2223 	driver_unregister(&netiucv_driver);
2224 out_iucv:
2225 	iucv_unregister(&netiucv_handler, 1);
2226 out_dbf:
2227 	iucv_unregister_dbf_views();
2228 out:
2229 	return rc;
2230 }
2231 
2232 module_init(netiucv_init);
2233 module_exit(netiucv_exit);
2234 MODULE_LICENSE("GPL");
2235