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