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