blob: 7809a79feec735537d7746043f107662adccb8e2 [file] [log] [blame]
Linus Torvalds1da177e2005-04-16 15:20:36 -07001/*
2 * drivers/s390/net/claw.c
3 * ESCON CLAW network driver
4 *
Frank Pavlic8e84c802005-09-06 15:03:09 +02005 * Linux for zSeries version
Linus Torvalds1da177e2005-04-16 15:20:36 -07006 * Copyright (C) 2002,2005 IBM Corporation
7 * Author(s) Original code written by:
8 * Kazuo Iimura (iimura@jp.ibm.com)
9 * Rewritten by
10 * Andy Richter (richtera@us.ibm.com)
11 * Marc Price (mwprice@us.ibm.com)
12 *
13 * sysfs parms:
14 * group x.x.rrrr,x.x.wwww
15 * read_buffer nnnnnnn
16 * write_buffer nnnnnn
17 * host_name aaaaaaaa
18 * adapter_name aaaaaaaa
19 * api_type aaaaaaaa
20 *
21 * eg.
22 * group 0.0.0200 0.0.0201
23 * read_buffer 25
24 * write_buffer 20
25 * host_name LINUX390
26 * adapter_name RS6K
27 * api_type TCPIP
28 *
29 * where
30 *
31 * The device id is decided by the order entries
32 * are added to the group the first is claw0 the second claw1
33 * up to CLAW_MAX_DEV
34 *
35 * rrrr - the first of 2 consecutive device addresses used for the
36 * CLAW protocol.
37 * The specified address is always used as the input (Read)
38 * channel and the next address is used as the output channel.
39 *
40 * wwww - the second of 2 consecutive device addresses used for
41 * the CLAW protocol.
42 * The specified address is always used as the output
43 * channel and the previous address is used as the input channel.
44 *
45 * read_buffer - specifies number of input buffers to allocate.
46 * write_buffer - specifies number of output buffers to allocate.
47 * host_name - host name
48 * adaptor_name - adaptor name
49 * api_type - API type TCPIP or API will be sent and expected
50 * as ws_name
51 *
52 * Note the following requirements:
53 * 1) host_name must match the configured adapter_name on the remote side
54 * 2) adaptor_name must match the configured host name on the remote side
55 *
56 * Change History
57 * 1.00 Initial release shipped
58 * 1.10 Changes for Buffer allocation
59 * 1.15 Changed for 2.6 Kernel No longer compiles on 2.4 or lower
60 * 1.25 Added Packing support
61 */
62#include <asm/bitops.h>
63#include <asm/ccwdev.h>
64#include <asm/ccwgroup.h>
65#include <asm/debug.h>
66#include <asm/idals.h>
67#include <asm/io.h>
68
69#include <linux/ctype.h>
70#include <linux/delay.h>
71#include <linux/errno.h>
72#include <linux/if_arp.h>
73#include <linux/init.h>
74#include <linux/interrupt.h>
75#include <linux/ip.h>
76#include <linux/kernel.h>
77#include <linux/module.h>
78#include <linux/netdevice.h>
79#include <linux/etherdevice.h>
80#include <linux/proc_fs.h>
81#include <linux/sched.h>
82#include <linux/signal.h>
83#include <linux/skbuff.h>
84#include <linux/slab.h>
85#include <linux/string.h>
86#include <linux/tcp.h>
87#include <linux/timer.h>
88#include <linux/types.h>
Linus Torvalds1da177e2005-04-16 15:20:36 -070089
90#include "cu3088.h"
91#include "claw.h"
92
93MODULE_AUTHOR("Andy Richter <richtera@us.ibm.com>");
94MODULE_DESCRIPTION("Linux for zSeries CLAW Driver\n" \
95 "Copyright 2000,2005 IBM Corporation\n");
96MODULE_LICENSE("GPL");
97
98/* Debugging is based on DEBUGMSG, IOTRACE, or FUNCTRACE options:
99 DEBUGMSG - Enables output of various debug messages in the code
100 IOTRACE - Enables output of CCW and other IO related traces
101 FUNCTRACE - Enables output of function entry/exit trace
102 Define any combination of above options to enable tracing
103
104 CLAW also uses the s390dbf file system see claw_trace and claw_setup
105*/
106
107/* following enables tracing */
108//#define DEBUGMSG
109//#define IOTRACE
110//#define FUNCTRACE
111
112#ifdef DEBUGMSG
113#define DEBUG
114#endif
115
116#ifdef IOTRACE
117#define DEBUG
118#endif
119
120#ifdef FUNCTRACE
121#define DEBUG
122#endif
123
Heiko Carstens2b67fc42007-02-05 21:16:47 +0100124static char debug_buffer[255];
Linus Torvalds1da177e2005-04-16 15:20:36 -0700125/**
126 * Debug Facility Stuff
127 */
128static debug_info_t *claw_dbf_setup;
129static debug_info_t *claw_dbf_trace;
130
131/**
132 * CLAW Debug Facility functions
133 */
134static void
135claw_unregister_debug_facility(void)
136{
137 if (claw_dbf_setup)
138 debug_unregister(claw_dbf_setup);
139 if (claw_dbf_trace)
140 debug_unregister(claw_dbf_trace);
141}
142
143static int
144claw_register_debug_facility(void)
145{
Michael Holzheu66a464d2005-06-25 14:55:33 -0700146 claw_dbf_setup = debug_register("claw_setup", 2, 1, 8);
147 claw_dbf_trace = debug_register("claw_trace", 2, 2, 8);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700148 if (claw_dbf_setup == NULL || claw_dbf_trace == NULL) {
149 printk(KERN_WARNING "Not enough memory for debug facility.\n");
150 claw_unregister_debug_facility();
151 return -ENOMEM;
152 }
153 debug_register_view(claw_dbf_setup, &debug_hex_ascii_view);
154 debug_set_level(claw_dbf_setup, 2);
155 debug_register_view(claw_dbf_trace, &debug_hex_ascii_view);
156 debug_set_level(claw_dbf_trace, 2);
157 return 0;
158}
159
160static inline void
161claw_set_busy(struct net_device *dev)
162{
163 ((struct claw_privbk *) dev->priv)->tbusy=1;
164 eieio();
165}
166
167static inline void
168claw_clear_busy(struct net_device *dev)
169{
170 clear_bit(0, &(((struct claw_privbk *) dev->priv)->tbusy));
171 netif_wake_queue(dev);
172 eieio();
173}
174
175static inline int
176claw_check_busy(struct net_device *dev)
177{
178 eieio();
179 return ((struct claw_privbk *) dev->priv)->tbusy;
180}
181
182static inline void
183claw_setbit_busy(int nr,struct net_device *dev)
184{
185 netif_stop_queue(dev);
186 set_bit(nr, (void *)&(((struct claw_privbk *)dev->priv)->tbusy));
187}
188
189static inline void
190claw_clearbit_busy(int nr,struct net_device *dev)
191{
192 clear_bit(nr,(void *)&(((struct claw_privbk *)dev->priv)->tbusy));
193 netif_wake_queue(dev);
194}
195
196static inline int
197claw_test_and_setbit_busy(int nr,struct net_device *dev)
198{
199 netif_stop_queue(dev);
200 return test_and_set_bit(nr,
201 (void *)&(((struct claw_privbk *) dev->priv)->tbusy));
202}
203
204
205/* Functions for the DEV methods */
206
207static int claw_probe(struct ccwgroup_device *cgdev);
208static void claw_remove_device(struct ccwgroup_device *cgdev);
209static void claw_purge_skb_queue(struct sk_buff_head *q);
210static int claw_new_device(struct ccwgroup_device *cgdev);
211static int claw_shutdown_device(struct ccwgroup_device *cgdev);
212static int claw_tx(struct sk_buff *skb, struct net_device *dev);
213static int claw_change_mtu( struct net_device *dev, int new_mtu);
214static int claw_open(struct net_device *dev);
215static void claw_irq_handler(struct ccw_device *cdev,
216 unsigned long intparm, struct irb *irb);
217static void claw_irq_tasklet ( unsigned long data );
218static int claw_release(struct net_device *dev);
219static void claw_write_retry ( struct chbk * p_ch );
220static void claw_write_next ( struct chbk * p_ch );
221static void claw_timer ( struct chbk * p_ch );
222
223/* Functions */
224static int add_claw_reads(struct net_device *dev,
225 struct ccwbk* p_first, struct ccwbk* p_last);
Heiko Carstens4d284ca2007-02-05 21:18:53 +0100226static void ccw_check_return_code (struct ccw_device *cdev, int return_code);
227static void ccw_check_unit_check (struct chbk * p_ch, unsigned char sense );
Linus Torvalds1da177e2005-04-16 15:20:36 -0700228static int find_link(struct net_device *dev, char *host_name, char *ws_name );
229static int claw_hw_tx(struct sk_buff *skb, struct net_device *dev, long linkid);
230static int init_ccw_bk(struct net_device *dev);
231static void probe_error( struct ccwgroup_device *cgdev);
232static struct net_device_stats *claw_stats(struct net_device *dev);
Heiko Carstens4d284ca2007-02-05 21:18:53 +0100233static int pages_to_order_of_mag(int num_of_pages);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700234static struct sk_buff *claw_pack_skb(struct claw_privbk *privptr);
235#ifdef DEBUG
236static void dumpit (char *buf, int len);
237#endif
238/* sysfs Functions */
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -0400239static ssize_t claw_hname_show(struct device *dev, struct device_attribute *attr, char *buf);
240static ssize_t claw_hname_write(struct device *dev, struct device_attribute *attr,
Linus Torvalds1da177e2005-04-16 15:20:36 -0700241 const char *buf, size_t count);
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -0400242static ssize_t claw_adname_show(struct device *dev, struct device_attribute *attr, char *buf);
243static ssize_t claw_adname_write(struct device *dev, struct device_attribute *attr,
Linus Torvalds1da177e2005-04-16 15:20:36 -0700244 const char *buf, size_t count);
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -0400245static ssize_t claw_apname_show(struct device *dev, struct device_attribute *attr, char *buf);
246static ssize_t claw_apname_write(struct device *dev, struct device_attribute *attr,
Linus Torvalds1da177e2005-04-16 15:20:36 -0700247 const char *buf, size_t count);
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -0400248static ssize_t claw_wbuff_show(struct device *dev, struct device_attribute *attr, char *buf);
249static ssize_t claw_wbuff_write(struct device *dev, struct device_attribute *attr,
Linus Torvalds1da177e2005-04-16 15:20:36 -0700250 const char *buf, size_t count);
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -0400251static ssize_t claw_rbuff_show(struct device *dev, struct device_attribute *attr, char *buf);
252static ssize_t claw_rbuff_write(struct device *dev, struct device_attribute *attr,
Linus Torvalds1da177e2005-04-16 15:20:36 -0700253 const char *buf, size_t count);
254static int claw_add_files(struct device *dev);
255static void claw_remove_files(struct device *dev);
256
257/* Functions for System Validate */
258static int claw_process_control( struct net_device *dev, struct ccwbk * p_ccw);
259static int claw_send_control(struct net_device *dev, __u8 type, __u8 link,
260 __u8 correlator, __u8 rc , char *local_name, char *remote_name);
261static int claw_snd_conn_req(struct net_device *dev, __u8 link);
262static int claw_snd_disc(struct net_device *dev, struct clawctl * p_ctl);
263static int claw_snd_sys_validate_rsp(struct net_device *dev,
264 struct clawctl * p_ctl, __u32 return_code);
265static int claw_strt_conn_req(struct net_device *dev );
266static void claw_strt_read ( struct net_device *dev, int lock );
267static void claw_strt_out_IO( struct net_device *dev );
268static void claw_free_wrt_buf( struct net_device *dev );
269
270/* Functions for unpack reads */
271static void unpack_read (struct net_device *dev );
272
273/* ccwgroup table */
274
275static struct ccwgroup_driver claw_group_driver = {
276 .owner = THIS_MODULE,
277 .name = "claw",
278 .max_slaves = 2,
279 .driver_id = 0xC3D3C1E6,
280 .probe = claw_probe,
281 .remove = claw_remove_device,
282 .set_online = claw_new_device,
283 .set_offline = claw_shutdown_device,
284};
285
286/*
287*
288* Key functions
289*/
290
291/*----------------------------------------------------------------*
292 * claw_probe *
293 * this function is called for each CLAW device. *
294 *----------------------------------------------------------------*/
295static int
296claw_probe(struct ccwgroup_device *cgdev)
297{
298 int rc;
299 struct claw_privbk *privptr=NULL;
300
301#ifdef FUNCTRACE
302 printk(KERN_INFO "%s Enter\n",__FUNCTION__);
303#endif
304 CLAW_DBF_TEXT(2,setup,"probe");
305 if (!get_device(&cgdev->dev))
306 return -ENODEV;
307#ifdef DEBUGMSG
308 printk(KERN_INFO "claw: variable cgdev =\n");
309 dumpit((char *)cgdev, sizeof(struct ccwgroup_device));
310#endif
Eric Sesterhenn88abaab2006-03-24 03:15:31 -0800311 privptr = kzalloc(sizeof(struct claw_privbk), GFP_KERNEL);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700312 if (privptr == NULL) {
313 probe_error(cgdev);
314 put_device(&cgdev->dev);
315 printk(KERN_WARNING "Out of memory %s %s Exit Line %d \n",
316 cgdev->cdev[0]->dev.bus_id,__FUNCTION__,__LINE__);
317 CLAW_DBF_TEXT_(2,setup,"probex%d",-ENOMEM);
318 return -ENOMEM;
319 }
Linus Torvalds1da177e2005-04-16 15:20:36 -0700320 privptr->p_mtc_envelope= kmalloc( MAX_ENVELOPE_SIZE, GFP_KERNEL);
321 privptr->p_env = kmalloc(sizeof(struct claw_env), GFP_KERNEL);
322 if ((privptr->p_mtc_envelope==NULL) || (privptr->p_env==NULL)) {
323 probe_error(cgdev);
324 put_device(&cgdev->dev);
325 printk(KERN_WARNING "Out of memory %s %s Exit Line %d \n",
326 cgdev->cdev[0]->dev.bus_id,__FUNCTION__,__LINE__);
327 CLAW_DBF_TEXT_(2,setup,"probex%d",-ENOMEM);
328 return -ENOMEM;
329 }
330 memset(privptr->p_mtc_envelope, 0x00, MAX_ENVELOPE_SIZE);
331 memset(privptr->p_env, 0x00, sizeof(struct claw_env));
332 memcpy(privptr->p_env->adapter_name,WS_NAME_NOT_DEF,8);
333 memcpy(privptr->p_env->host_name,WS_NAME_NOT_DEF,8);
334 memcpy(privptr->p_env->api_type,WS_NAME_NOT_DEF,8);
335 privptr->p_env->packing = 0;
336 privptr->p_env->write_buffers = 5;
337 privptr->p_env->read_buffers = 5;
338 privptr->p_env->read_size = CLAW_FRAME_SIZE;
339 privptr->p_env->write_size = CLAW_FRAME_SIZE;
340 rc = claw_add_files(&cgdev->dev);
341 if (rc) {
342 probe_error(cgdev);
343 put_device(&cgdev->dev);
344 printk(KERN_WARNING "add_files failed %s %s Exit Line %d \n",
345 cgdev->cdev[0]->dev.bus_id,__FUNCTION__,__LINE__);
346 CLAW_DBF_TEXT_(2,setup,"probex%d",rc);
347 return rc;
348 }
349 printk(KERN_INFO "claw: sysfs files added for %s\n",cgdev->cdev[0]->dev.bus_id);
350 privptr->p_env->p_priv = privptr;
351 cgdev->cdev[0]->handler = claw_irq_handler;
352 cgdev->cdev[1]->handler = claw_irq_handler;
353 cgdev->dev.driver_data = privptr;
354#ifdef FUNCTRACE
355 printk(KERN_INFO "claw:%s exit on line %d, "
356 "rc = 0\n",__FUNCTION__,__LINE__);
357#endif
358 CLAW_DBF_TEXT(2,setup,"prbext 0");
359
360 return 0;
361} /* end of claw_probe */
362
363/*-------------------------------------------------------------------*
364 * claw_tx *
365 *-------------------------------------------------------------------*/
366
367static int
368claw_tx(struct sk_buff *skb, struct net_device *dev)
369{
370 int rc;
371 struct claw_privbk *privptr=dev->priv;
372 unsigned long saveflags;
373 struct chbk *p_ch;
374
375#ifdef FUNCTRACE
376 printk(KERN_INFO "%s:%s enter\n",dev->name,__FUNCTION__);
377#endif
378 CLAW_DBF_TEXT(4,trace,"claw_tx");
379 p_ch=&privptr->channel[WRITE];
380 if (skb == NULL) {
381 printk(KERN_WARNING "%s: null pointer passed as sk_buffer\n",
382 dev->name);
383 privptr->stats.tx_dropped++;
384#ifdef FUNCTRACE
385 printk(KERN_INFO "%s: %s() exit on line %d, rc = EIO\n",
386 dev->name,__FUNCTION__, __LINE__);
387#endif
388 CLAW_DBF_TEXT_(2,trace,"clawtx%d",-EIO);
389 return -EIO;
390 }
391
392#ifdef IOTRACE
393 printk(KERN_INFO "%s: variable sk_buff=\n",dev->name);
394 dumpit((char *) skb, sizeof(struct sk_buff));
395 printk(KERN_INFO "%s: variable dev=\n",dev->name);
396 dumpit((char *) dev, sizeof(struct net_device));
397#endif
398 spin_lock_irqsave(get_ccwdev_lock(p_ch->cdev), saveflags);
399 rc=claw_hw_tx( skb, dev, 1 );
400 spin_unlock_irqrestore(get_ccwdev_lock(p_ch->cdev), saveflags);
401#ifdef FUNCTRACE
402 printk(KERN_INFO "%s:%s exit on line %d, rc = %d\n",
403 dev->name, __FUNCTION__, __LINE__, rc);
404#endif
405 CLAW_DBF_TEXT_(4,trace,"clawtx%d",rc);
406 return rc;
407} /* end of claw_tx */
408
409/*------------------------------------------------------------------*
410 * pack the collect queue into an skb and return it *
411 * If not packing just return the top skb from the queue *
412 *------------------------------------------------------------------*/
413
414static struct sk_buff *
415claw_pack_skb(struct claw_privbk *privptr)
416{
417 struct sk_buff *new_skb,*held_skb;
418 struct chbk *p_ch = &privptr->channel[WRITE];
419 struct claw_env *p_env = privptr->p_env;
420 int pkt_cnt,pk_ind,so_far;
421
422 new_skb = NULL; /* assume no dice */
423 pkt_cnt = 0;
424 CLAW_DBF_TEXT(4,trace,"PackSKBe");
David S. Millerb03efcf2005-07-08 14:57:23 -0700425 if (!skb_queue_empty(&p_ch->collect_queue)) {
Linus Torvalds1da177e2005-04-16 15:20:36 -0700426 /* some data */
427 held_skb = skb_dequeue(&p_ch->collect_queue);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700428 if (held_skb)
Frank Pavlic8e84c802005-09-06 15:03:09 +0200429 dev_kfree_skb_any(held_skb);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700430 else
431 return NULL;
Frank Pavlic8e84c802005-09-06 15:03:09 +0200432 if (p_env->packing != DO_PACKED)
433 return held_skb;
Linus Torvalds1da177e2005-04-16 15:20:36 -0700434 /* get a new SKB we will pack at least one */
435 new_skb = dev_alloc_skb(p_env->write_size);
436 if (new_skb == NULL) {
437 atomic_inc(&held_skb->users);
438 skb_queue_head(&p_ch->collect_queue,held_skb);
439 return NULL;
440 }
441 /* we have packed packet and a place to put it */
442 pk_ind = 1;
443 so_far = 0;
444 new_skb->cb[1] = 'P'; /* every skb on queue has pack header */
445 while ((pk_ind) && (held_skb != NULL)) {
446 if (held_skb->len+so_far <= p_env->write_size-8) {
447 memcpy(skb_put(new_skb,held_skb->len),
448 held_skb->data,held_skb->len);
449 privptr->stats.tx_packets++;
450 so_far += held_skb->len;
451 pkt_cnt++;
Frank Pavlic8e84c802005-09-06 15:03:09 +0200452 dev_kfree_skb_any(held_skb);
Linus Torvalds1da177e2005-04-16 15:20:36 -0700453 held_skb = skb_dequeue(&p_ch->collect_queue);
454 if (held_skb)
455 atomic_dec(&held_skb->users);
456 } else {
457 pk_ind = 0;
458 atomic_inc(&held_skb->users);
459 skb_queue_head(&p_ch->collect_queue,held_skb);
460 }
461 }
462#ifdef IOTRACE
463 printk(KERN_INFO "%s: %s() Packed %d len %d\n",
464 p_env->ndev->name,
465 __FUNCTION__,pkt_cnt,new_skb->len);
466#endif
467 }
468 CLAW_DBF_TEXT(4,trace,"PackSKBx");
469 return new_skb;
470}
471
472/*-------------------------------------------------------------------*
473 * claw_change_mtu *
474 * *
475 *-------------------------------------------------------------------*/
476
477static int
478claw_change_mtu(struct net_device *dev, int new_mtu)
479{
480 struct claw_privbk *privptr=dev->priv;
481 int buff_size;
482#ifdef FUNCTRACE
483 printk(KERN_INFO "%s:%s Enter \n",dev->name,__FUNCTION__);
484#endif
485#ifdef DEBUGMSG
486 printk(KERN_INFO "variable dev =\n");
487 dumpit((char *) dev, sizeof(struct net_device));
488 printk(KERN_INFO "variable new_mtu = %d\n", new_mtu);
489#endif
490 CLAW_DBF_TEXT(4,trace,"setmtu");
491 buff_size = privptr->p_env->write_size;
492 if ((new_mtu < 60) || (new_mtu > buff_size)) {
493#ifdef FUNCTRACE
494 printk(KERN_INFO "%s:%s Exit on line %d, rc=EINVAL\n",
495 dev->name,
496 __FUNCTION__, __LINE__);
497#endif
498 return -EINVAL;
499 }
500 dev->mtu = new_mtu;
501#ifdef FUNCTRACE
502 printk(KERN_INFO "%s:%s Exit on line %d\n",dev->name,
503 __FUNCTION__, __LINE__);
504#endif
505 return 0;
506} /* end of claw_change_mtu */
507
508
509/*-------------------------------------------------------------------*
510 * claw_open *
511 * *
512 *-------------------------------------------------------------------*/
513static int
514claw_open(struct net_device *dev)
515{
516
517 int rc;
518 int i;
519 unsigned long saveflags=0;
520 unsigned long parm;
521 struct claw_privbk *privptr;
522 DECLARE_WAITQUEUE(wait, current);
523 struct timer_list timer;
524 struct ccwbk *p_buf;
525
526#ifdef FUNCTRACE
527 printk(KERN_INFO "%s:%s Enter \n",dev->name,__FUNCTION__);
528#endif
529 CLAW_DBF_TEXT(4,trace,"open");
Dave Jones68e3c5e2006-07-10 04:45:18 -0700530 if (!dev || (dev->name[0] == 0x00)) {
Linus Torvalds1da177e2005-04-16 15:20:36 -0700531 CLAW_DBF_TEXT(2,trace,"BadDev");
532 printk(KERN_WARNING "claw: Bad device at open failing \n");
533 return -ENODEV;
534 }
535 privptr = (struct claw_privbk *)dev->priv;
536 /* allocate and initialize CCW blocks */
537 if (privptr->buffs_alloc == 0) {
538 rc=init_ccw_bk(dev);
539 if (rc) {
540 printk(KERN_INFO "%s:%s Exit on line %d, rc=ENOMEM\n",
541 dev->name,
542 __FUNCTION__, __LINE__);
543 CLAW_DBF_TEXT(2,trace,"openmem");
544 return -ENOMEM;
545 }
546 }
547 privptr->system_validate_comp=0;
548 privptr->release_pend=0;
549 if(strncmp(privptr->p_env->api_type,WS_APPL_NAME_PACKED,6) == 0) {
550 privptr->p_env->read_size=DEF_PACK_BUFSIZE;
551 privptr->p_env->write_size=DEF_PACK_BUFSIZE;
552 privptr->p_env->packing=PACKING_ASK;
553 } else {
554 privptr->p_env->packing=0;
555 privptr->p_env->read_size=CLAW_FRAME_SIZE;
556 privptr->p_env->write_size=CLAW_FRAME_SIZE;
557 }
558 claw_set_busy(dev);
559 tasklet_init(&privptr->channel[READ].tasklet, claw_irq_tasklet,
560 (unsigned long) &privptr->channel[READ]);
561 for ( i = 0; i < 2; i++) {
562 CLAW_DBF_TEXT_(2,trace,"opn_ch%d",i);
563 init_waitqueue_head(&privptr->channel[i].wait);
564 /* skb_queue_head_init(&p_ch->io_queue); */
565 if (i == WRITE)
566 skb_queue_head_init(
567 &privptr->channel[WRITE].collect_queue);
568 privptr->channel[i].flag_a = 0;
569 privptr->channel[i].IO_active = 0;
570 privptr->channel[i].flag &= ~CLAW_TIMER;
571 init_timer(&timer);
572 timer.function = (void *)claw_timer;
573 timer.data = (unsigned long)(&privptr->channel[i]);
574 timer.expires = jiffies + 15*HZ;
575 add_timer(&timer);
576 spin_lock_irqsave(get_ccwdev_lock(
577 privptr->channel[i].cdev), saveflags);
578 parm = (unsigned long) &privptr->channel[i];
579 privptr->channel[i].claw_state = CLAW_START_HALT_IO;
580 rc = 0;
581 add_wait_queue(&privptr->channel[i].wait, &wait);
582 rc = ccw_device_halt(
583 (struct ccw_device *)privptr->channel[i].cdev,parm);
584 set_current_state(TASK_INTERRUPTIBLE);
585 spin_unlock_irqrestore(
586 get_ccwdev_lock(privptr->channel[i].cdev), saveflags);
587 schedule();
588 set_current_state(TASK_RUNNING);
589 remove_wait_queue(&privptr->channel[i].wait, &wait);
590 if(rc != 0)
591 ccw_check_return_code(privptr->channel[i].cdev, rc);
592 if((privptr->channel[i].flag & CLAW_TIMER) == 0x00)
593 del_timer(&timer);
594 }
595 if ((((privptr->channel[READ].last_dstat |
596 privptr->channel[WRITE].last_dstat) &
597 ~(DEV_STAT_CHN_END | DEV_STAT_DEV_END)) != 0x00) ||
598 (((privptr->channel[READ].flag |
599 privptr->channel[WRITE].flag) & CLAW_TIMER) != 0x00)) {
600#ifdef DEBUGMSG
601 printk(KERN_INFO "%s: channel problems during open - read:"
602 " %02x - write: %02x\n",
603 dev->name,
604 privptr->channel[READ].last_dstat,
605 privptr->channel[WRITE].last_dstat);
606#endif
607 printk(KERN_INFO "%s: remote side is not ready\n", dev->name);
608 CLAW_DBF_TEXT(2,trace,"notrdy");
609
610 for ( i = 0; i < 2; i++) {
611 spin_lock_irqsave(
612 get_ccwdev_lock(privptr->channel[i].cdev),
613 saveflags);
614 parm = (unsigned long) &privptr->channel[i];
615 privptr->channel[i].claw_state = CLAW_STOP;
616 rc = ccw_device_halt(
617 (struct ccw_device *)&privptr->channel[i].cdev,
618 parm);
619 spin_unlock_irqrestore(
620 get_ccwdev_lock(privptr->channel[i].cdev),
621 saveflags);
622 if (rc != 0) {
623 ccw_check_return_code(
624 privptr->channel[i].cdev, rc);
625 }
626 }
627 free_pages((unsigned long)privptr->p_buff_ccw,
628 (int)pages_to_order_of_mag(privptr->p_buff_ccw_num));
629 if (privptr->p_env->read_size < PAGE_SIZE) {
630 free_pages((unsigned long)privptr->p_buff_read,
631 (int)pages_to_order_of_mag(
632 privptr->p_buff_read_num));
633 }
634 else {
635 p_buf=privptr->p_read_active_first;
636 while (p_buf!=NULL) {
637 free_pages((unsigned long)p_buf->p_buffer,
638 (int)pages_to_order_of_mag(
639 privptr->p_buff_pages_perread ));
640 p_buf=p_buf->next;
641 }
642 }
643 if (privptr->p_env->write_size < PAGE_SIZE ) {
644 free_pages((unsigned long)privptr->p_buff_write,
645 (int)pages_to_order_of_mag(
646 privptr->p_buff_write_num));
647 }
648 else {
649 p_buf=privptr->p_write_active_first;
650 while (p_buf!=NULL) {
651 free_pages((unsigned long)p_buf->p_buffer,
652 (int)pages_to_order_of_mag(
653 privptr->p_buff_pages_perwrite ));
654 p_buf=p_buf->next;
655 }
656 }
657 privptr->buffs_alloc = 0;
658 privptr->channel[READ].flag= 0x00;
659 privptr->channel[WRITE].flag = 0x00;
660 privptr->p_buff_ccw=NULL;
661 privptr->p_buff_read=NULL;
662 privptr->p_buff_write=NULL;
663 claw_clear_busy(dev);
664#ifdef FUNCTRACE
665 printk(KERN_INFO "%s:%s Exit on line %d, rc=EIO\n",
666 dev->name,__FUNCTION__,__LINE__);
667#endif
668 CLAW_DBF_TEXT(2,trace,"open EIO");
669 return -EIO;
670 }
671
672 /* Send SystemValidate command */
673
674 claw_clear_busy(dev);
675
676#ifdef FUNCTRACE
677 printk(KERN_INFO "%s:%s Exit on line %d, rc=0\n",
678 dev->name,__FUNCTION__,__LINE__);
679#endif
680 CLAW_DBF_TEXT(4,trace,"openok");
681 return 0;
682} /* end of claw_open */
683
684/*-------------------------------------------------------------------*
685* *
686* claw_irq_handler *
687* *
688*--------------------------------------------------------------------*/
689static void
690claw_irq_handler(struct ccw_device *cdev,
691 unsigned long intparm, struct irb *irb)
692{
693 struct chbk *p_ch = NULL;
694 struct claw_privbk *privptr = NULL;
695 struct net_device *dev = NULL;
696 struct claw_env *p_env;
697 struct chbk *p_ch_r=NULL;
698
699
700#ifdef FUNCTRACE
701 printk(KERN_INFO "%s enter \n",__FUNCTION__);
702#endif
703 CLAW_DBF_TEXT(4,trace,"clawirq");
704 /* Bypass all 'unsolicited interrupts' */
705 if (!cdev->dev.driver_data) {
706 printk(KERN_WARNING "claw: unsolicited interrupt for device:"
707 "%s received c-%02x d-%02x\n",
708 cdev->dev.bus_id,irb->scsw.cstat, irb->scsw.dstat);
709#ifdef FUNCTRACE
710 printk(KERN_INFO "claw: %s() "
711 "exit on line %d\n",__FUNCTION__,__LINE__);
712#endif
713 CLAW_DBF_TEXT(2,trace,"badirq");
714 return;
715 }
716 privptr = (struct claw_privbk *)cdev->dev.driver_data;
717
718 /* Try to extract channel from driver data. */
719 if (privptr->channel[READ].cdev == cdev)
720 p_ch = &privptr->channel[READ];
721 else if (privptr->channel[WRITE].cdev == cdev)
722 p_ch = &privptr->channel[WRITE];
723 else {
724 printk(KERN_WARNING "claw: Can't determine channel for "
725 "interrupt, device %s\n", cdev->dev.bus_id);
726 CLAW_DBF_TEXT(2,trace,"badchan");
727 return;
728 }
729 CLAW_DBF_TEXT_(4,trace,"IRQCH=%d",p_ch->flag);
730
731 dev = (struct net_device *) (p_ch->ndev);
732 p_env=privptr->p_env;
733
734#ifdef IOTRACE
735 printk(KERN_INFO "%s: interrupt for device: %04x "
736 "received c-%02x d-%02x state-%02x\n",
737 dev->name, p_ch->devno, irb->scsw.cstat,
738 irb->scsw.dstat, p_ch->claw_state);
739#endif
740
741 /* Copy interruption response block. */
742 memcpy(p_ch->irb, irb, sizeof(struct irb));
743
744 /* Check for good subchannel return code, otherwise error message */
745 if (irb->scsw.cstat && !(irb->scsw.cstat & SCHN_STAT_PCI)) {
746 printk(KERN_INFO "%s: subchannel check for device: %04x -"
747 " Sch Stat %02x Dev Stat %02x CPA - %04x\n",
748 dev->name, p_ch->devno,
749 irb->scsw.cstat, irb->scsw.dstat,irb->scsw.cpa);
750#ifdef IOTRACE
751 dumpit((char *)irb,sizeof(struct irb));
752 dumpit((char *)(unsigned long)irb->scsw.cpa,
753 sizeof(struct ccw1));
754#endif
755#ifdef FUNCTRACE
756 printk(KERN_INFO "%s:%s Exit on line %d\n",
757 dev->name,__FUNCTION__,__LINE__);
758#endif
759 CLAW_DBF_TEXT(2,trace,"chanchk");
760 /* return; */
761 }
762
763 /* Check the reason-code of a unit check */
764 if (irb->scsw.dstat & DEV_STAT_UNIT_CHECK) {
765 ccw_check_unit_check(p_ch, irb->ecw[0]);
766 }
767
768 /* State machine to bring the connection up, down and to restart */
769 p_ch->last_dstat = irb->scsw.dstat;
770
771 switch (p_ch->claw_state) {
772 case CLAW_STOP:/* HALT_IO by claw_release (halt sequence) */
773#ifdef DEBUGMSG
774 printk(KERN_INFO "%s: CLAW_STOP enter\n", dev->name);
775#endif
776 if (!((p_ch->irb->scsw.stctl & SCSW_STCTL_SEC_STATUS) ||
777 (p_ch->irb->scsw.stctl == SCSW_STCTL_STATUS_PEND) ||
778 (p_ch->irb->scsw.stctl ==
779 (SCSW_STCTL_ALERT_STATUS | SCSW_STCTL_STATUS_PEND)))) {
780#ifdef FUNCTRACE
781 printk(KERN_INFO "%s:%s Exit on line %d\n",
782 dev->name,__FUNCTION__,__LINE__);
783#endif
784 return;
785 }
786 wake_up(&p_ch->wait); /* wake up claw_release */
787
788#ifdef DEBUGMSG
789 printk(KERN_INFO "%s: CLAW_STOP exit\n", dev->name);
790#endif
791#ifdef FUNCTRACE
792 printk(KERN_INFO "%s:%s Exit on line %d\n",
793 dev->name,__FUNCTION__,__LINE__);
794#endif
795 CLAW_DBF_TEXT(4,trace,"stop");
796 return;
797
798 case CLAW_START_HALT_IO: /* HALT_IO issued by claw_open */
799#ifdef DEBUGMSG
800 printk(KERN_INFO "%s: process CLAW_STAT_HALT_IO\n",
801 dev->name);
802#endif
803 if (!((p_ch->irb->scsw.stctl & SCSW_STCTL_SEC_STATUS) ||
804 (p_ch->irb->scsw.stctl == SCSW_STCTL_STATUS_PEND) ||
805 (p_ch->irb->scsw.stctl ==
806 (SCSW_STCTL_ALERT_STATUS | SCSW_STCTL_STATUS_PEND)))) {
807#ifdef FUNCTRACE
808 printk(KERN_INFO "%s:%s Exit on line %d\n",
809 dev->name,__FUNCTION__,__LINE__);
810#endif
811 CLAW_DBF_TEXT(4,trace,"haltio");
812 return;
813 }
814 if (p_ch->flag == CLAW_READ) {
815 p_ch->claw_state = CLAW_START_READ;
816 wake_up(&p_ch->wait); /* wake claw_open (READ)*/
817 }
818 else
819 if (p_ch->flag == CLAW_WRITE) {
820 p_ch->claw_state = CLAW_START_WRITE;
821 /* send SYSTEM_VALIDATE */
822 claw_strt_read(dev, LOCK_NO);
823 claw_send_control(dev,
824 SYSTEM_VALIDATE_REQUEST,
825 0, 0, 0,
826 p_env->host_name,
827 p_env->adapter_name );
828 } else {
829 printk(KERN_WARNING "claw: unsolicited "
830 "interrupt for device:"
831 "%s received c-%02x d-%02x\n",
832 cdev->dev.bus_id,
833 irb->scsw.cstat,
834 irb->scsw.dstat);
835 return;
836 }
837#ifdef DEBUGMSG
838 printk(KERN_INFO "%s: process CLAW_STAT_HALT_IO exit\n",
839 dev->name);
840#endif
841#ifdef FUNCTRACE
842 printk(KERN_INFO "%s:%s Exit on line %d\n",
843 dev->name,__FUNCTION__,__LINE__);
844#endif
845 CLAW_DBF_TEXT(4,trace,"haltio");
846 return;
847 case CLAW_START_READ:
848 CLAW_DBF_TEXT(4,trace,"ReadIRQ");
849 if (p_ch->irb->scsw.dstat & DEV_STAT_UNIT_CHECK) {
850 clear_bit(0, (void *)&p_ch->IO_active);
851 if ((p_ch->irb->ecw[0] & 0x41) == 0x41 ||
852 (p_ch->irb->ecw[0] & 0x40) == 0x40 ||
853 (p_ch->irb->ecw[0]) == 0)
854 {
855 privptr->stats.rx_errors++;
856 printk(KERN_INFO "%s: Restart is "
857 "required after remote "
858 "side recovers \n",
859 dev->name);
860 }
861#ifdef FUNCTRACE
862 printk(KERN_INFO "%s:%s Exit on line %d\n",
863 dev->name,__FUNCTION__,__LINE__);
864#endif
865 CLAW_DBF_TEXT(4,trace,"notrdy");
866 return;
867 }
868 if ((p_ch->irb->scsw.cstat & SCHN_STAT_PCI) &&
869 (p_ch->irb->scsw.dstat==0)) {
870 if (test_and_set_bit(CLAW_BH_ACTIVE,
871 (void *)&p_ch->flag_a) == 0) {
872 tasklet_schedule(&p_ch->tasklet);
873 }
874 else {
875 CLAW_DBF_TEXT(4,trace,"PCINoBH");
876 }
877#ifdef FUNCTRACE
878 printk(KERN_INFO "%s:%s Exit on line %d\n",
879 dev->name,__FUNCTION__,__LINE__);
880#endif
881 CLAW_DBF_TEXT(4,trace,"PCI_read");
882 return;
883 }
884 if(!((p_ch->irb->scsw.stctl & SCSW_STCTL_SEC_STATUS) ||
885 (p_ch->irb->scsw.stctl == SCSW_STCTL_STATUS_PEND) ||
886 (p_ch->irb->scsw.stctl ==
887 (SCSW_STCTL_ALERT_STATUS | SCSW_STCTL_STATUS_PEND)))) {
888#ifdef FUNCTRACE
889 printk(KERN_INFO "%s:%s Exit on line %d\n",
890 dev->name,__FUNCTION__,__LINE__);
891#endif
892 CLAW_DBF_TEXT(4,trace,"SPend_rd");
893 return;
894 }
895 clear_bit(0, (void *)&p_ch->IO_active);
896 claw_clearbit_busy(TB_RETRY,dev);
897 if (test_and_set_bit(CLAW_BH_ACTIVE,
898 (void *)&p_ch->flag_a) == 0) {
899 tasklet_schedule(&p_ch->tasklet);
900 }
901 else {
902 CLAW_DBF_TEXT(4,trace,"RdBHAct");
903 }
904
905#ifdef DEBUGMSG
906 printk(KERN_INFO "%s: process CLAW_START_READ exit\n",
907 dev->name);
908#endif
909#ifdef FUNCTRACE
910 printk(KERN_INFO "%s:%s Exit on line %d\n",
911 dev->name,__FUNCTION__,__LINE__);
912#endif
913 CLAW_DBF_TEXT(4,trace,"RdIRQXit");
914 return;
915 case CLAW_START_WRITE:
916 if (p_ch->irb->scsw.dstat & DEV_STAT_UNIT_CHECK) {
917 printk(KERN_INFO "%s: Unit Check Occured in "
918 "write channel\n",dev->name);
919 clear_bit(0, (void *)&p_ch->IO_active);
920 if (p_ch->irb->ecw[0] & 0x80 ) {
921 printk(KERN_INFO "%s: Resetting Event "
922 "occurred:\n",dev->name);
923 init_timer(&p_ch->timer);
924 p_ch->timer.function =
925 (void *)claw_write_retry;
926 p_ch->timer.data = (unsigned long)p_ch;
927 p_ch->timer.expires = jiffies + 10*HZ;
928 add_timer(&p_ch->timer);
929 printk(KERN_INFO "%s: write connection "
930 "restarting\n",dev->name);
931 }
932#ifdef FUNCTRACE
933 printk(KERN_INFO "%s:%s Exit on line %d\n",
934 dev->name,__FUNCTION__,__LINE__);
935#endif
936 CLAW_DBF_TEXT(4,trace,"rstrtwrt");
937 return;
938 }
939 if (p_ch->irb->scsw.dstat & DEV_STAT_UNIT_EXCEP) {
940 clear_bit(0, (void *)&p_ch->IO_active);
941 printk(KERN_INFO "%s: Unit Exception "
942 "Occured in write channel\n",
943 dev->name);
944 }
945 if(!((p_ch->irb->scsw.stctl & SCSW_STCTL_SEC_STATUS) ||
946 (p_ch->irb->scsw.stctl == SCSW_STCTL_STATUS_PEND) ||
947 (p_ch->irb->scsw.stctl ==
948 (SCSW_STCTL_ALERT_STATUS | SCSW_STCTL_STATUS_PEND)))) {
949#ifdef FUNCTRACE
950 printk(KERN_INFO "%s:%s Exit on line %d\n",
951 dev->name,__FUNCTION__,__LINE__);
952#endif
953 CLAW_DBF_TEXT(4,trace,"writeUE");
954 return;
955 }
956 clear_bit(0, (void *)&p_ch->IO_active);
957 if (claw_test_and_setbit_busy(TB_TX,dev)==0) {
958 claw_write_next(p_ch);
959 claw_clearbit_busy(TB_TX,dev);
960 claw_clear_busy(dev);
961 }
962 p_ch_r=(struct chbk *)&privptr->channel[READ];
963 if (test_and_set_bit(CLAW_BH_ACTIVE,
964 (void *)&p_ch_r->flag_a) == 0) {
965 tasklet_schedule(&p_ch_r->tasklet);
966 }
967
968#ifdef DEBUGMSG
969 printk(KERN_INFO "%s: process CLAW_START_WRITE exit\n",
970 dev->name);
971#endif
972#ifdef FUNCTRACE
973 printk(KERN_INFO "%s:%s Exit on line %d\n",
974 dev->name,__FUNCTION__,__LINE__);
975#endif
976 CLAW_DBF_TEXT(4,trace,"StWtExit");
977 return;
978 default:
979 printk(KERN_WARNING "%s: wrong selection code - irq "
980 "state=%d\n",dev->name,p_ch->claw_state);
981#ifdef FUNCTRACE
982 printk(KERN_INFO "%s:%s Exit on line %d\n",
983 dev->name,__FUNCTION__,__LINE__);
984#endif
985 CLAW_DBF_TEXT(2,trace,"badIRQ");
986 return;
987 }
988
989} /* end of claw_irq_handler */
990
991
992/*-------------------------------------------------------------------*
993* claw_irq_tasklet *
994* *
995*--------------------------------------------------------------------*/
996static void
997claw_irq_tasklet ( unsigned long data )
998{
999 struct chbk * p_ch;
1000 struct net_device *dev;
1001 struct claw_privbk * privptr;
1002
1003 p_ch = (struct chbk *) data;
1004 dev = (struct net_device *)p_ch->ndev;
1005#ifdef FUNCTRACE
1006 printk(KERN_INFO "%s:%s Enter \n",dev->name,__FUNCTION__);
1007#endif
1008#ifdef DEBUGMSG
1009 printk(KERN_INFO "%s: variable p_ch =\n",dev->name);
1010 dumpit((char *) p_ch, sizeof(struct chbk));
1011#endif
1012 CLAW_DBF_TEXT(4,trace,"IRQtask");
1013
1014 privptr = (struct claw_privbk *) dev->priv;
1015
1016#ifdef DEBUGMSG
1017 printk(KERN_INFO "%s: bh routine - state-%02x\n" ,
1018 dev->name, p_ch->claw_state);
1019#endif
1020
1021 unpack_read(dev);
1022 clear_bit(CLAW_BH_ACTIVE, (void *)&p_ch->flag_a);
1023 CLAW_DBF_TEXT(4,trace,"TskletXt");
1024#ifdef FUNCTRACE
1025 printk(KERN_INFO "%s:%s Exit on line %d\n",
1026 dev->name,__FUNCTION__,__LINE__);
1027#endif
1028 return;
1029} /* end of claw_irq_bh */
1030
1031/*-------------------------------------------------------------------*
1032* claw_release *
1033* *
1034*--------------------------------------------------------------------*/
1035static int
1036claw_release(struct net_device *dev)
1037{
1038 int rc;
1039 int i;
1040 unsigned long saveflags;
1041 unsigned long parm;
1042 struct claw_privbk *privptr;
1043 DECLARE_WAITQUEUE(wait, current);
1044 struct ccwbk* p_this_ccw;
1045 struct ccwbk* p_buf;
1046
1047 if (!dev)
1048 return 0;
1049 privptr = (struct claw_privbk *) dev->priv;
1050 if (!privptr)
1051 return 0;
1052#ifdef FUNCTRACE
1053 printk(KERN_INFO "%s:%s Enter \n",dev->name,__FUNCTION__);
1054#endif
1055 CLAW_DBF_TEXT(4,trace,"release");
1056#ifdef DEBUGMSG
1057 printk(KERN_INFO "%s: variable dev =\n",dev->name);
1058 dumpit((char *) dev, sizeof(struct net_device));
1059 printk(KERN_INFO "Priv Buffalloc %d\n",privptr->buffs_alloc);
1060 printk(KERN_INFO "Priv p_buff_ccw = %p\n",&privptr->p_buff_ccw);
1061#endif
1062 privptr->release_pend=1;
1063 claw_setbit_busy(TB_STOP,dev);
1064 for ( i = 1; i >=0 ; i--) {
1065 spin_lock_irqsave(
1066 get_ccwdev_lock(privptr->channel[i].cdev), saveflags);
1067 /* del_timer(&privptr->channel[READ].timer); */
1068 privptr->channel[i].claw_state = CLAW_STOP;
1069 privptr->channel[i].IO_active = 0;
1070 parm = (unsigned long) &privptr->channel[i];
1071 if (i == WRITE)
1072 claw_purge_skb_queue(
1073 &privptr->channel[WRITE].collect_queue);
1074 rc = ccw_device_halt (privptr->channel[i].cdev, parm);
1075 if (privptr->system_validate_comp==0x00) /* never opened? */
1076 init_waitqueue_head(&privptr->channel[i].wait);
1077 add_wait_queue(&privptr->channel[i].wait, &wait);
1078 set_current_state(TASK_INTERRUPTIBLE);
1079 spin_unlock_irqrestore(
1080 get_ccwdev_lock(privptr->channel[i].cdev), saveflags);
1081 schedule();
1082 set_current_state(TASK_RUNNING);
1083 remove_wait_queue(&privptr->channel[i].wait, &wait);
1084 if (rc != 0) {
1085 ccw_check_return_code(privptr->channel[i].cdev, rc);
1086 }
1087 }
1088 if (privptr->pk_skb != NULL) {
Frank Pavlic8e84c802005-09-06 15:03:09 +02001089 dev_kfree_skb_any(privptr->pk_skb);
Linus Torvalds1da177e2005-04-16 15:20:36 -07001090 privptr->pk_skb = NULL;
1091 }
1092 if(privptr->buffs_alloc != 1) {
1093#ifdef FUNCTRACE
1094 printk(KERN_INFO "%s:%s Exit on line %d\n",
1095 dev->name,__FUNCTION__,__LINE__);
1096#endif
1097 CLAW_DBF_TEXT(4,trace,"none2fre");
1098 return 0;
1099 }
1100 CLAW_DBF_TEXT(4,trace,"freebufs");
1101 if (privptr->p_buff_ccw != NULL) {
1102 free_pages((unsigned long)privptr->p_buff_ccw,
1103 (int)pages_to_order_of_mag(privptr->p_buff_ccw_num));
1104 }
1105 CLAW_DBF_TEXT(4,trace,"freeread");
1106 if (privptr->p_env->read_size < PAGE_SIZE) {
1107 if (privptr->p_buff_read != NULL) {
1108 free_pages((unsigned long)privptr->p_buff_read,
1109 (int)pages_to_order_of_mag(privptr->p_buff_read_num));
1110 }
1111 }
1112 else {
1113 p_buf=privptr->p_read_active_first;
1114 while (p_buf!=NULL) {
1115 free_pages((unsigned long)p_buf->p_buffer,
1116 (int)pages_to_order_of_mag(
1117 privptr->p_buff_pages_perread ));
1118 p_buf=p_buf->next;
1119 }
1120 }
1121 CLAW_DBF_TEXT(4,trace,"freewrit");
1122 if (privptr->p_env->write_size < PAGE_SIZE ) {
1123 free_pages((unsigned long)privptr->p_buff_write,
1124 (int)pages_to_order_of_mag(privptr->p_buff_write_num));
1125 }
1126 else {
1127 p_buf=privptr->p_write_active_first;
1128 while (p_buf!=NULL) {
1129 free_pages((unsigned long)p_buf->p_buffer,
1130 (int)pages_to_order_of_mag(
1131 privptr->p_buff_pages_perwrite ));
1132 p_buf=p_buf->next;
1133 }
1134 }
1135 CLAW_DBF_TEXT(4,trace,"clearptr");
1136 privptr->buffs_alloc = 0;
1137 privptr->p_buff_ccw=NULL;
1138 privptr->p_buff_read=NULL;
1139 privptr->p_buff_write=NULL;
1140 privptr->system_validate_comp=0;
1141 privptr->release_pend=0;
1142 /* Remove any writes that were pending and reset all reads */
1143 p_this_ccw=privptr->p_read_active_first;
1144 while (p_this_ccw!=NULL) {
1145 p_this_ccw->header.length=0xffff;
1146 p_this_ccw->header.opcode=0xff;
1147 p_this_ccw->header.flag=0x00;
1148 p_this_ccw=p_this_ccw->next;
1149 }
1150
1151 while (privptr->p_write_active_first!=NULL) {
1152 p_this_ccw=privptr->p_write_active_first;
1153 p_this_ccw->header.flag=CLAW_PENDING;
1154 privptr->p_write_active_first=p_this_ccw->next;
1155 p_this_ccw->next=privptr->p_write_free_chain;
1156 privptr->p_write_free_chain=p_this_ccw;
1157 ++privptr->write_free_count;
1158 }
1159 privptr->p_write_active_last=NULL;
1160 privptr->mtc_logical_link = -1;
1161 privptr->mtc_skipping = 1;
1162 privptr->mtc_offset=0;
1163
1164 if (((privptr->channel[READ].last_dstat |
1165 privptr->channel[WRITE].last_dstat) &
1166 ~(DEV_STAT_CHN_END | DEV_STAT_DEV_END)) != 0x00) {
1167 printk(KERN_WARNING "%s: channel problems during close - "
1168 "read: %02x - write: %02x\n",
1169 dev->name,
1170 privptr->channel[READ].last_dstat,
1171 privptr->channel[WRITE].last_dstat);
1172 CLAW_DBF_TEXT(2,trace,"badclose");
1173 }
1174#ifdef FUNCTRACE
1175 printk(KERN_INFO "%s:%s Exit on line %d\n",
1176 dev->name,__FUNCTION__,__LINE__);
1177#endif
1178 CLAW_DBF_TEXT(4,trace,"rlsexit");
1179 return 0;
1180} /* end of claw_release */
1181
1182
1183
1184/*-------------------------------------------------------------------*
1185* claw_write_retry *
1186* *
1187*--------------------------------------------------------------------*/
1188
1189static void
1190claw_write_retry ( struct chbk *p_ch )
1191{
1192
1193 struct net_device *dev=p_ch->ndev;
1194
1195
1196#ifdef FUNCTRACE
1197 printk(KERN_INFO "%s:%s Enter\n",dev->name,__FUNCTION__);
1198 printk(KERN_INFO "claw: variable p_ch =\n");
1199 dumpit((char *) p_ch, sizeof(struct chbk));
1200#endif
1201 CLAW_DBF_TEXT(4,trace,"w_retry");
1202 if (p_ch->claw_state == CLAW_STOP) {
1203#ifdef FUNCTRACE
1204 printk(KERN_INFO "%s:%s Exit on line %d\n",
1205 dev->name,__FUNCTION__,__LINE__);
1206#endif
1207 return;
1208 }
1209#ifdef DEBUGMSG
1210 printk( KERN_INFO "%s:%s state-%02x\n" ,
1211 dev->name,
1212 __FUNCTION__,
1213 p_ch->claw_state);
1214#endif
1215 claw_strt_out_IO( dev );
1216#ifdef FUNCTRACE
1217 printk(KERN_INFO "%s:%s Exit on line %d\n",
1218 dev->name,__FUNCTION__,__LINE__);
1219#endif
1220 CLAW_DBF_TEXT(4,trace,"rtry_xit");
1221 return;
1222} /* end of claw_write_retry */
1223
1224
1225/*-------------------------------------------------------------------*
1226* claw_write_next *
1227* *
1228*--------------------------------------------------------------------*/
1229
1230static void
1231claw_write_next ( struct chbk * p_ch )
1232{
1233
1234 struct net_device *dev;
1235 struct claw_privbk *privptr=NULL;
1236 struct sk_buff *pk_skb;
1237 int rc;
1238
1239#ifdef FUNCTRACE
1240 printk(KERN_INFO "%s:%s Enter \n",p_ch->ndev->name,__FUNCTION__);
1241 printk(KERN_INFO "%s: variable p_ch =\n",p_ch->ndev->name);
1242 dumpit((char *) p_ch, sizeof(struct chbk));
1243#endif
1244 CLAW_DBF_TEXT(4,trace,"claw_wrt");
1245 if (p_ch->claw_state == CLAW_STOP)
1246 return;
1247 dev = (struct net_device *) p_ch->ndev;
1248 privptr = (struct claw_privbk *) dev->priv;
1249 claw_free_wrt_buf( dev );
1250 if ((privptr->write_free_count > 0) &&
David S. Millerb03efcf2005-07-08 14:57:23 -07001251 !skb_queue_empty(&p_ch->collect_queue)) {
Linus Torvalds1da177e2005-04-16 15:20:36 -07001252 pk_skb = claw_pack_skb(privptr);
1253 while (pk_skb != NULL) {
1254 rc = claw_hw_tx( pk_skb, dev,1);
1255 if (privptr->write_free_count > 0) {
1256 pk_skb = claw_pack_skb(privptr);
1257 } else
1258 pk_skb = NULL;
1259 }
1260 }
1261 if (privptr->p_write_active_first!=NULL) {
1262 claw_strt_out_IO(dev);
1263 }
1264
1265#ifdef FUNCTRACE
1266 printk(KERN_INFO "%s:%s Exit on line %d\n",
1267 dev->name,__FUNCTION__,__LINE__);
1268#endif
1269 return;
1270} /* end of claw_write_next */
1271
1272/*-------------------------------------------------------------------*
1273* *
1274* claw_timer *
1275*--------------------------------------------------------------------*/
1276
1277static void
1278claw_timer ( struct chbk * p_ch )
1279{
1280#ifdef FUNCTRACE
1281 printk(KERN_INFO "%s:%s Entry\n",p_ch->ndev->name,__FUNCTION__);
1282 printk(KERN_INFO "%s: variable p_ch =\n",p_ch->ndev->name);
1283 dumpit((char *) p_ch, sizeof(struct chbk));
1284#endif
1285 CLAW_DBF_TEXT(4,trace,"timer");
1286 p_ch->flag |= CLAW_TIMER;
1287 wake_up(&p_ch->wait);
1288#ifdef FUNCTRACE
1289 printk(KERN_INFO "%s:%s Exit on line %d\n",
1290 p_ch->ndev->name,__FUNCTION__,__LINE__);
1291#endif
1292 return;
1293} /* end of claw_timer */
1294
1295
1296/*
1297*
1298* functions
1299*/
1300
1301
1302/*-------------------------------------------------------------------*
1303* *
1304* pages_to_order_of_mag *
1305* *
1306* takes a number of pages from 1 to 512 and returns the *
1307* log(num_pages)/log(2) get_free_pages() needs a base 2 order *
1308* of magnitude get_free_pages() has an upper order of 9 *
1309*--------------------------------------------------------------------*/
1310
Heiko Carstens4d284ca2007-02-05 21:18:53 +01001311static int
Linus Torvalds1da177e2005-04-16 15:20:36 -07001312pages_to_order_of_mag(int num_of_pages)
1313{
1314 int order_of_mag=1; /* assume 2 pages */
1315 int nump=2;
1316#ifdef FUNCTRACE
1317 printk(KERN_INFO "%s Enter pages = %d \n",__FUNCTION__,num_of_pages);
1318#endif
1319 CLAW_DBF_TEXT_(5,trace,"pages%d",num_of_pages);
1320 if (num_of_pages == 1) {return 0; } /* magnitude of 0 = 1 page */
1321 /* 512 pages = 2Meg on 4k page systems */
1322 if (num_of_pages >= 512) {return 9; }
1323 /* we have two or more pages order is at least 1 */
1324 for (nump=2 ;nump <= 512;nump*=2) {
1325 if (num_of_pages <= nump)
1326 break;
1327 order_of_mag +=1;
1328 }
1329 if (order_of_mag > 9) { order_of_mag = 9; } /* I know it's paranoid */
1330#ifdef FUNCTRACE
1331 printk(KERN_INFO "%s Exit on line %d, order = %d\n",
1332 __FUNCTION__,__LINE__, order_of_mag);
1333#endif
1334 CLAW_DBF_TEXT_(5,trace,"mag%d",order_of_mag);
1335 return order_of_mag;
1336}
1337
1338/*-------------------------------------------------------------------*
1339* *
1340* add_claw_reads *
1341* *
1342*--------------------------------------------------------------------*/
1343static int
1344add_claw_reads(struct net_device *dev, struct ccwbk* p_first,
1345 struct ccwbk* p_last)
1346{
1347 struct claw_privbk *privptr;
1348 struct ccw1 temp_ccw;
1349 struct endccw * p_end;
1350#ifdef IOTRACE
1351 struct ccwbk* p_buf;
1352#endif
1353#ifdef FUNCTRACE
1354 printk(KERN_INFO "%s:%s Enter \n",dev->name,__FUNCTION__);
1355#endif
1356#ifdef DEBUGMSG
1357 printk(KERN_INFO "dev\n");
1358 dumpit((char *) dev, sizeof(struct net_device));
1359 printk(KERN_INFO "p_first\n");
1360 dumpit((char *) p_first, sizeof(struct ccwbk));
1361 printk(KERN_INFO "p_last\n");
1362 dumpit((char *) p_last, sizeof(struct ccwbk));
1363#endif
1364 CLAW_DBF_TEXT(4,trace,"addreads");
1365 privptr = dev->priv;
1366 p_end = privptr->p_end_ccw;
1367
1368 /* first CCW and last CCW contains a new set of read channel programs
1369 * to apend the running channel programs
1370 */
1371 if ( p_first==NULL) {
1372#ifdef FUNCTRACE
1373 printk(KERN_INFO "%s:%s Exit on line %d\n",
1374 dev->name,__FUNCTION__,__LINE__);
1375#endif
1376 CLAW_DBF_TEXT(4,trace,"addexit");
1377 return 0;
1378 }
1379
1380 /* set up ending CCW sequence for this segment */
1381 if (p_end->read1) {
1382 p_end->read1=0x00; /* second ending CCW is now active */
1383 /* reset ending CCWs and setup TIC CCWs */
1384 p_end->read2_nop2.cmd_code = CCW_CLAW_CMD_READFF;
1385 p_end->read2_nop2.flags = CCW_FLAG_SLI | CCW_FLAG_SKIP;
1386 p_last->r_TIC_1.cda =(__u32)__pa(&p_end->read2_nop1);
1387 p_last->r_TIC_2.cda =(__u32)__pa(&p_end->read2_nop1);
1388 p_end->read2_nop2.cda=0;
1389 p_end->read2_nop2.count=1;
1390 }
1391 else {
1392 p_end->read1=0x01; /* first ending CCW is now active */
1393 /* reset ending CCWs and setup TIC CCWs */
1394 p_end->read1_nop2.cmd_code = CCW_CLAW_CMD_READFF;
1395 p_end->read1_nop2.flags = CCW_FLAG_SLI | CCW_FLAG_SKIP;
1396 p_last->r_TIC_1.cda = (__u32)__pa(&p_end->read1_nop1);
1397 p_last->r_TIC_2.cda = (__u32)__pa(&p_end->read1_nop1);
1398 p_end->read1_nop2.cda=0;
1399 p_end->read1_nop2.count=1;
1400 }
1401
1402 if ( privptr-> p_read_active_first ==NULL ) {
1403#ifdef DEBUGMSG
Uwe Zeisberger80682fa2006-03-22 00:21:33 +01001404 printk(KERN_INFO "%s:%s p_read_active_first == NULL \n",
Linus Torvalds1da177e2005-04-16 15:20:36 -07001405 dev->name,__FUNCTION__);
1406 printk(KERN_INFO "%s:%s Read active first/last changed \n",
1407 dev->name,__FUNCTION__);
1408#endif
1409 privptr-> p_read_active_first= p_first; /* set new first */
1410 privptr-> p_read_active_last = p_last; /* set new last */
1411 }
1412 else {
1413
1414#ifdef DEBUGMSG
1415 printk(KERN_INFO "%s:%s Read in progress \n",
1416 dev->name,__FUNCTION__);
1417#endif
1418 /* set up TIC ccw */
1419 temp_ccw.cda= (__u32)__pa(&p_first->read);
1420 temp_ccw.count=0;
1421 temp_ccw.flags=0;
1422 temp_ccw.cmd_code = CCW_CLAW_CMD_TIC;
1423
1424
1425 if (p_end->read1) {
1426
1427 /* first set of CCW's is chained to the new read */
1428 /* chain, so the second set is chained to the active chain. */
1429 /* Therefore modify the second set to point to the new */
1430 /* read chain set up TIC CCWs */
1431 /* make sure we update the CCW so channel doesn't fetch it */
1432 /* when it's only half done */
1433 memcpy( &p_end->read2_nop2, &temp_ccw ,
1434 sizeof(struct ccw1));
1435 privptr->p_read_active_last->r_TIC_1.cda=
1436 (__u32)__pa(&p_first->read);
1437 privptr->p_read_active_last->r_TIC_2.cda=
1438 (__u32)__pa(&p_first->read);
1439 }
1440 else {
1441 /* make sure we update the CCW so channel doesn't */
1442 /* fetch it when it is only half done */
1443 memcpy( &p_end->read1_nop2, &temp_ccw ,
1444 sizeof(struct ccw1));
1445 privptr->p_read_active_last->r_TIC_1.cda=
1446 (__u32)__pa(&p_first->read);
1447 privptr->p_read_active_last->r_TIC_2.cda=
1448 (__u32)__pa(&p_first->read);
1449 }
1450 /* chain in new set of blocks */
1451 privptr->p_read_active_last->next = p_first;
1452 privptr->p_read_active_last=p_last;
1453 } /* end of if ( privptr-> p_read_active_first ==NULL) */
1454#ifdef IOTRACE
1455 printk(KERN_INFO "%s:%s dump p_last CCW BK \n",dev->name,__FUNCTION__);
1456 dumpit((char *)p_last, sizeof(struct ccwbk));
1457 printk(KERN_INFO "%s:%s dump p_end CCW BK \n",dev->name,__FUNCTION__);
1458 dumpit((char *)p_end, sizeof(struct endccw));
1459
1460 printk(KERN_INFO "%s:%s dump p_first CCW BK \n",dev->name,__FUNCTION__);
1461 dumpit((char *)p_first, sizeof(struct ccwbk));
1462 printk(KERN_INFO "%s:%s Dump Active CCW chain \n",
1463 dev->name,__FUNCTION__);
1464 p_buf=privptr->p_read_active_first;
1465 while (p_buf!=NULL) {
1466 dumpit((char *)p_buf, sizeof(struct ccwbk));
1467 p_buf=p_buf->next;
1468 }
1469#endif
1470#ifdef FUNCTRACE
1471 printk(KERN_INFO "%s:%s Exit on line %d\n",
1472 dev->name,__FUNCTION__,__LINE__);
1473#endif
1474 CLAW_DBF_TEXT(4,trace,"addexit");
1475 return 0;
1476} /* end of add_claw_reads */
1477
1478/*-------------------------------------------------------------------*
1479 * ccw_check_return_code *
1480 * *
1481 *-------------------------------------------------------------------*/
1482
Heiko Carstens4d284ca2007-02-05 21:18:53 +01001483static void
Linus Torvalds1da177e2005-04-16 15:20:36 -07001484ccw_check_return_code(struct ccw_device *cdev, int return_code)
1485{
1486#ifdef FUNCTRACE
1487 printk(KERN_INFO "%s: %s() > enter \n",
1488 cdev->dev.bus_id,__FUNCTION__);
1489#endif
1490 CLAW_DBF_TEXT(4,trace,"ccwret");
1491#ifdef DEBUGMSG
1492 printk(KERN_INFO "variable cdev =\n");
1493 dumpit((char *) cdev, sizeof(struct ccw_device));
1494 printk(KERN_INFO "variable return_code = %d\n",return_code);
1495#endif
1496 if (return_code != 0) {
1497 switch (return_code) {
1498 case -EBUSY:
1499 printk(KERN_INFO "%s: Busy !\n",
1500 cdev->dev.bus_id);
1501 break;
1502 case -ENODEV:
1503 printk(KERN_EMERG "%s: Missing device called "
1504 "for IO ENODEV\n", cdev->dev.bus_id);
1505 break;
1506 case -EIO:
1507 printk(KERN_EMERG "%s: Status pending... EIO \n",
1508 cdev->dev.bus_id);
1509 break;
1510 case -EINVAL:
1511 printk(KERN_EMERG "%s: Invalid Dev State EINVAL \n",
1512 cdev->dev.bus_id);
1513 break;
1514 default:
1515 printk(KERN_EMERG "%s: Unknown error in "
1516 "Do_IO %d\n",cdev->dev.bus_id, return_code);
1517 }
1518 }
1519#ifdef FUNCTRACE
1520 printk(KERN_INFO "%s: %s() > exit on line %d\n",
1521 cdev->dev.bus_id,__FUNCTION__,__LINE__);
1522#endif
1523 CLAW_DBF_TEXT(4,trace,"ccwret");
1524} /* end of ccw_check_return_code */
1525
1526/*-------------------------------------------------------------------*
1527* ccw_check_unit_check *
1528*--------------------------------------------------------------------*/
1529
Heiko Carstens4d284ca2007-02-05 21:18:53 +01001530static void
Linus Torvalds1da177e2005-04-16 15:20:36 -07001531ccw_check_unit_check(struct chbk * p_ch, unsigned char sense )
1532{
1533 struct net_device *dev = p_ch->ndev;
1534
1535#ifdef FUNCTRACE
1536 printk(KERN_INFO "%s: %s() > enter\n",dev->name,__FUNCTION__);
1537#endif
1538#ifdef DEBUGMSG
1539 printk(KERN_INFO "%s: variable dev =\n",dev->name);
1540 dumpit((char *)dev, sizeof(struct net_device));
1541 printk(KERN_INFO "%s: variable sense =\n",dev->name);
1542 dumpit((char *)&sense, 2);
1543#endif
1544 CLAW_DBF_TEXT(4,trace,"unitchek");
1545
1546 printk(KERN_INFO "%s: Unit Check with sense byte:0x%04x\n",
1547 dev->name, sense);
1548
1549 if (sense & 0x40) {
1550 if (sense & 0x01) {
1551 printk(KERN_WARNING "%s: Interface disconnect or "
1552 "Selective reset "
1553 "occurred (remote side)\n", dev->name);
1554 }
1555 else {
1556 printk(KERN_WARNING "%s: System reset occured"
1557 " (remote side)\n", dev->name);
1558 }
1559 }
1560 else if (sense & 0x20) {
1561 if (sense & 0x04) {
1562 printk(KERN_WARNING "%s: Data-streaming "
1563 "timeout)\n", dev->name);
1564 }
1565 else {
1566 printk(KERN_WARNING "%s: Data-transfer parity"
1567 " error\n", dev->name);
1568 }
1569 }
1570 else if (sense & 0x10) {
1571 if (sense & 0x20) {
1572 printk(KERN_WARNING "%s: Hardware malfunction "
1573 "(remote side)\n", dev->name);
1574 }
1575 else {
1576 printk(KERN_WARNING "%s: read-data parity error "
1577 "(remote side)\n", dev->name);
1578 }
1579 }
1580
1581#ifdef FUNCTRACE
1582 printk(KERN_INFO "%s: %s() exit on line %d\n",
1583 dev->name,__FUNCTION__,__LINE__);
1584#endif
1585} /* end of ccw_check_unit_check */
1586
1587
1588
1589/*-------------------------------------------------------------------*
1590* Dump buffer format *
1591* *
1592*--------------------------------------------------------------------*/
1593#ifdef DEBUG
1594static void
1595dumpit(char* buf, int len)
1596{
1597
1598 __u32 ct, sw, rm, dup;
1599 char *ptr, *rptr;
1600 char tbuf[82], tdup[82];
Martin Schwidefsky347a8dc2006-01-06 00:19:28 -08001601#if (CONFIG_64BIT)
Linus Torvalds1da177e2005-04-16 15:20:36 -07001602 char addr[22];
1603#else
1604 char addr[12];
1605#endif
1606 char boff[12];
1607 char bhex[82], duphex[82];
1608 char basc[40];
1609
1610 sw = 0;
1611 rptr =ptr=buf;
1612 rm = 16;
1613 duphex[0] = 0x00;
1614 dup = 0;
1615 for ( ct=0; ct < len; ct++, ptr++, rptr++ ) {
1616 if (sw == 0) {
Martin Schwidefsky347a8dc2006-01-06 00:19:28 -08001617#if (CONFIG_64BIT)
Linus Torvalds1da177e2005-04-16 15:20:36 -07001618 sprintf(addr, "%16.16lX",(unsigned long)rptr);
1619#else
1620 sprintf(addr, "%8.8X",(__u32)rptr);
1621#endif
1622 sprintf(boff, "%4.4X", (__u32)ct);
1623 bhex[0] = '\0';
1624 basc[0] = '\0';
1625 }
1626 if ((sw == 4) || (sw == 12)) {
1627 strcat(bhex, " ");
1628 }
1629 if (sw == 8) {
1630 strcat(bhex, " ");
1631 }
Martin Schwidefsky347a8dc2006-01-06 00:19:28 -08001632#if (CONFIG_64BIT)
Linus Torvalds1da177e2005-04-16 15:20:36 -07001633 sprintf(tbuf,"%2.2lX", (unsigned long)*ptr);
1634#else
1635 sprintf(tbuf,"%2.2X", (__u32)*ptr);
1636#endif
1637 tbuf[2] = '\0';
1638 strcat(bhex, tbuf);
1639 if ((0!=isprint(*ptr)) && (*ptr >= 0x20)) {
1640 basc[sw] = *ptr;
1641 }
1642 else {
1643 basc[sw] = '.';
1644 }
1645 basc[sw+1] = '\0';
1646 sw++;
1647 rm--;
1648 if (sw==16) {
1649 if ((strcmp(duphex, bhex)) !=0) {
1650 if (dup !=0) {
1651 sprintf(tdup,"Duplicate as above to"
1652 " %s", addr);
1653 printk( KERN_INFO " "
1654 " --- %s ---\n",tdup);
1655 }
1656 printk( KERN_INFO " %s (+%s) : %s [%s]\n",
1657 addr, boff, bhex, basc);
1658 dup = 0;
1659 strcpy(duphex, bhex);
1660 }
1661 else {
1662 dup++;
1663 }
1664 sw = 0;
1665 rm = 16;
1666 }
1667 } /* endfor */
1668
1669 if (sw != 0) {
1670 for ( ; rm > 0; rm--, sw++ ) {
1671 if ((sw==4) || (sw==12)) strcat(bhex, " ");
1672 if (sw==8) strcat(bhex, " ");
1673 strcat(bhex, " ");
1674 strcat(basc, " ");
1675 }
1676 if (dup !=0) {
1677 sprintf(tdup,"Duplicate as above to %s", addr);
1678 printk( KERN_INFO " --- %s ---\n",
1679 tdup);
1680 }
1681 printk( KERN_INFO " %s (+%s) : %s [%s]\n",
1682 addr, boff, bhex, basc);
1683 }
1684 else {
1685 if (dup >=1) {
1686 sprintf(tdup,"Duplicate as above to %s", addr);
1687 printk( KERN_INFO " --- %s ---\n",
1688 tdup);
1689 }
1690 if (dup !=0) {
1691 printk( KERN_INFO " %s (+%s) : %s [%s]\n",
1692 addr, boff, bhex, basc);
1693 }
1694 }
1695 return;
1696
1697} /* end of dumpit */
1698#endif
1699
1700/*-------------------------------------------------------------------*
1701* find_link *
1702*--------------------------------------------------------------------*/
1703static int
1704find_link(struct net_device *dev, char *host_name, char *ws_name )
1705{
1706 struct claw_privbk *privptr;
1707 struct claw_env *p_env;
1708 int rc=0;
1709
1710#ifdef FUNCTRACE
1711 printk(KERN_INFO "%s:%s > enter \n",dev->name,__FUNCTION__);
1712#endif
1713 CLAW_DBF_TEXT(2,setup,"findlink");
1714#ifdef DEBUGMSG
1715 printk(KERN_INFO "%s: variable dev = \n",dev->name);
1716 dumpit((char *) dev, sizeof(struct net_device));
1717 printk(KERN_INFO "%s: variable host_name = %s\n",dev->name, host_name);
1718 printk(KERN_INFO "%s: variable ws_name = %s\n",dev->name, ws_name);
1719#endif
1720 privptr=dev->priv;
1721 p_env=privptr->p_env;
1722 switch (p_env->packing)
1723 {
1724 case PACKING_ASK:
1725 if ((memcmp(WS_APPL_NAME_PACKED, host_name, 8)!=0) ||
1726 (memcmp(WS_APPL_NAME_PACKED, ws_name, 8)!=0 ))
1727 rc = EINVAL;
1728 break;
1729 case DO_PACKED:
1730 case PACK_SEND:
1731 if ((memcmp(WS_APPL_NAME_IP_NAME, host_name, 8)!=0) ||
1732 (memcmp(WS_APPL_NAME_IP_NAME, ws_name, 8)!=0 ))
1733 rc = EINVAL;
1734 break;
1735 default:
1736 if ((memcmp(HOST_APPL_NAME, host_name, 8)!=0) ||
1737 (memcmp(p_env->api_type , ws_name, 8)!=0))
1738 rc = EINVAL;
1739 break;
1740 }
1741
1742#ifdef FUNCTRACE
1743 printk(KERN_INFO "%s:%s Exit on line %d\n",
1744 dev->name,__FUNCTION__,__LINE__);
1745#endif
1746 return 0;
1747} /* end of find_link */
1748
1749/*-------------------------------------------------------------------*
1750 * claw_hw_tx *
1751 * *
1752 * *
1753 *-------------------------------------------------------------------*/
1754
1755static int
1756claw_hw_tx(struct sk_buff *skb, struct net_device *dev, long linkid)
1757{
1758 int rc=0;
1759 struct claw_privbk *privptr;
1760 struct ccwbk *p_this_ccw;
1761 struct ccwbk *p_first_ccw;
1762 struct ccwbk *p_last_ccw;
1763 __u32 numBuffers;
1764 signed long len_of_data;
1765 unsigned long bytesInThisBuffer;
1766 unsigned char *pDataAddress;
1767 struct endccw *pEnd;
1768 struct ccw1 tempCCW;
1769 struct chbk *p_ch;
1770 struct claw_env *p_env;
1771 int lock;
1772 struct clawph *pk_head;
1773 struct chbk *ch;
1774#ifdef IOTRACE
1775 struct ccwbk *p_buf;
1776#endif
1777#ifdef FUNCTRACE
1778 printk(KERN_INFO "%s: %s() > enter\n",dev->name,__FUNCTION__);
1779#endif
1780 CLAW_DBF_TEXT(4,trace,"hw_tx");
1781#ifdef DEBUGMSG
1782 printk(KERN_INFO "%s: variable dev skb =\n",dev->name);
1783 dumpit((char *) skb, sizeof(struct sk_buff));
1784 printk(KERN_INFO "%s: variable dev =\n",dev->name);
1785 dumpit((char *) dev, sizeof(struct net_device));
1786 printk(KERN_INFO "%s: variable linkid = %ld\n",dev->name,linkid);
1787#endif
1788 privptr = (struct claw_privbk *) (dev->priv);
1789 p_ch=(struct chbk *)&privptr->channel[WRITE];
1790 p_env =privptr->p_env;
1791#ifdef IOTRACE
1792 printk(KERN_INFO "%s: %s() dump sk_buff \n",dev->name,__FUNCTION__);
1793 dumpit((char *)skb ,sizeof(struct sk_buff));
1794#endif
1795 claw_free_wrt_buf(dev); /* Clean up free chain if posible */
1796 /* scan the write queue to free any completed write packets */
1797 p_first_ccw=NULL;
1798 p_last_ccw=NULL;
1799 if ((p_env->packing >= PACK_SEND) &&
1800 (skb->cb[1] != 'P')) {
1801 skb_push(skb,sizeof(struct clawph));
1802 pk_head=(struct clawph *)skb->data;
1803 pk_head->len=skb->len-sizeof(struct clawph);
1804 if (pk_head->len%4) {
1805 pk_head->len+= 4-(pk_head->len%4);
1806 skb_pad(skb,4-(pk_head->len%4));
1807 skb_put(skb,4-(pk_head->len%4));
1808 }
1809 if (p_env->packing == DO_PACKED)
1810 pk_head->link_num = linkid;
1811 else
1812 pk_head->link_num = 0;
1813 pk_head->flag = 0x00;
1814 skb_pad(skb,4);
1815 skb->cb[1] = 'P';
1816 }
1817 if (linkid == 0) {
1818 if (claw_check_busy(dev)) {
1819 if (privptr->write_free_count!=0) {
1820 claw_clear_busy(dev);
1821 }
1822 else {
1823 claw_strt_out_IO(dev );
1824 claw_free_wrt_buf( dev );
1825 if (privptr->write_free_count==0) {
1826#ifdef IOTRACE
1827 printk(KERN_INFO "%s: "
1828 "(claw_check_busy) no free write "
1829 "buffers\n", dev->name);
1830#endif
1831 ch = &privptr->channel[WRITE];
1832 atomic_inc(&skb->users);
1833 skb_queue_tail(&ch->collect_queue, skb);
1834 goto Done;
1835 }
1836 else {
1837 claw_clear_busy(dev);
1838 }
1839 }
1840 }
1841 /* tx lock */
1842 if (claw_test_and_setbit_busy(TB_TX,dev)) { /* set to busy */
1843#ifdef DEBUGMSG
1844 printk(KERN_INFO "%s: busy (claw_test_and_setbit_"
1845 "busy)\n", dev->name);
1846#endif
1847 ch = &privptr->channel[WRITE];
1848 atomic_inc(&skb->users);
1849 skb_queue_tail(&ch->collect_queue, skb);
1850 claw_strt_out_IO(dev );
1851 rc=-EBUSY;
1852 goto Done2;
1853 }
1854 }
1855 /* See how many write buffers are required to hold this data */
1856 numBuffers= ( skb->len + privptr->p_env->write_size - 1) /
1857 ( privptr->p_env->write_size);
1858
1859 /* If that number of buffers isn't available, give up for now */
1860 if (privptr->write_free_count < numBuffers ||
1861 privptr->p_write_free_chain == NULL ) {
1862
1863 claw_setbit_busy(TB_NOBUFFER,dev);
1864
1865#ifdef DEBUGMSG
1866 printk(KERN_INFO "%s: busy (claw_setbit_busy"
1867 "(TB_NOBUFFER))\n", dev->name);
1868 printk(KERN_INFO " free_count: %d, numBuffers : %d\n",
1869 (int)privptr->write_free_count,(int) numBuffers );
1870#endif
1871 ch = &privptr->channel[WRITE];
1872 atomic_inc(&skb->users);
1873 skb_queue_tail(&ch->collect_queue, skb);
1874 CLAW_DBF_TEXT(2,trace,"clawbusy");
1875 goto Done2;
1876 }
1877 pDataAddress=skb->data;
1878 len_of_data=skb->len;
1879
1880 while (len_of_data > 0) {
1881#ifdef DEBUGMSG
1882 printk(KERN_INFO "%s: %s() length-of-data is %ld \n",
1883 dev->name ,__FUNCTION__,len_of_data);
1884 dumpit((char *)pDataAddress ,64);
1885#endif
1886 p_this_ccw=privptr->p_write_free_chain; /* get a block */
1887 if (p_this_ccw == NULL) { /* lost the race */
1888 ch = &privptr->channel[WRITE];
1889 atomic_inc(&skb->users);
1890 skb_queue_tail(&ch->collect_queue, skb);
1891 goto Done2;
1892 }
1893 privptr->p_write_free_chain=p_this_ccw->next;
1894 p_this_ccw->next=NULL;
1895 --privptr->write_free_count; /* -1 */
1896 bytesInThisBuffer=len_of_data;
1897 memcpy( p_this_ccw->p_buffer,pDataAddress, bytesInThisBuffer);
1898 len_of_data-=bytesInThisBuffer;
1899 pDataAddress+=(unsigned long)bytesInThisBuffer;
1900 /* setup write CCW */
1901 p_this_ccw->write.cmd_code = (linkid * 8) +1;
1902 if (len_of_data>0) {
1903 p_this_ccw->write.cmd_code+=MORE_to_COME_FLAG;
1904 }
1905 p_this_ccw->write.count=bytesInThisBuffer;
1906 /* now add to end of this chain */
1907 if (p_first_ccw==NULL) {
1908 p_first_ccw=p_this_ccw;
1909 }
1910 if (p_last_ccw!=NULL) {
1911 p_last_ccw->next=p_this_ccw;
1912 /* set up TIC ccws */
1913 p_last_ccw->w_TIC_1.cda=
1914 (__u32)__pa(&p_this_ccw->write);
1915 }
1916 p_last_ccw=p_this_ccw; /* save new last block */
1917#ifdef IOTRACE
1918 printk(KERN_INFO "%s: %s() > CCW and Buffer %ld bytes long \n",
1919 dev->name,__FUNCTION__,bytesInThisBuffer);
1920 dumpit((char *)p_this_ccw, sizeof(struct ccwbk));
1921 dumpit((char *)p_this_ccw->p_buffer, 64);
1922#endif
1923 }
1924
1925 /* FirstCCW and LastCCW now contain a new set of write channel
1926 * programs to append to the running channel program
1927 */
1928
1929 if (p_first_ccw!=NULL) {
1930 /* setup ending ccw sequence for this segment */
1931 pEnd=privptr->p_end_ccw;
1932 if (pEnd->write1) {
1933 pEnd->write1=0x00; /* second end ccw is now active */
1934 /* set up Tic CCWs */
1935 p_last_ccw->w_TIC_1.cda=
1936 (__u32)__pa(&pEnd->write2_nop1);
1937 pEnd->write2_nop2.cmd_code = CCW_CLAW_CMD_READFF;
1938 pEnd->write2_nop2.flags =
1939 CCW_FLAG_SLI | CCW_FLAG_SKIP;
1940 pEnd->write2_nop2.cda=0;
1941 pEnd->write2_nop2.count=1;
1942 }
1943 else { /* end of if (pEnd->write1)*/
1944 pEnd->write1=0x01; /* first end ccw is now active */
1945 /* set up Tic CCWs */
1946 p_last_ccw->w_TIC_1.cda=
1947 (__u32)__pa(&pEnd->write1_nop1);
1948 pEnd->write1_nop2.cmd_code = CCW_CLAW_CMD_READFF;
1949 pEnd->write1_nop2.flags =
1950 CCW_FLAG_SLI | CCW_FLAG_SKIP;
1951 pEnd->write1_nop2.cda=0;
1952 pEnd->write1_nop2.count=1;
1953 } /* end if if (pEnd->write1) */
1954
1955
1956 if (privptr->p_write_active_first==NULL ) {
1957 privptr->p_write_active_first=p_first_ccw;
1958 privptr->p_write_active_last=p_last_ccw;
1959 }
1960 else {
1961
1962 /* set up Tic CCWs */
1963
1964 tempCCW.cda=(__u32)__pa(&p_first_ccw->write);
1965 tempCCW.count=0;
1966 tempCCW.flags=0;
1967 tempCCW.cmd_code=CCW_CLAW_CMD_TIC;
1968
1969 if (pEnd->write1) {
1970
1971 /*
1972 * first set of ending CCW's is chained to the new write
1973 * chain, so the second set is chained to the active chain
1974 * Therefore modify the second set to point the new write chain.
1975 * make sure we update the CCW atomically
1976 * so channel does not fetch it when it's only half done
1977 */
1978 memcpy( &pEnd->write2_nop2, &tempCCW ,
1979 sizeof(struct ccw1));
1980 privptr->p_write_active_last->w_TIC_1.cda=
1981 (__u32)__pa(&p_first_ccw->write);
1982 }
1983 else {
1984
1985 /*make sure we update the CCW atomically
1986 *so channel does not fetch it when it's only half done
1987 */
1988 memcpy(&pEnd->write1_nop2, &tempCCW ,
1989 sizeof(struct ccw1));
1990 privptr->p_write_active_last->w_TIC_1.cda=
1991 (__u32)__pa(&p_first_ccw->write);
1992
1993 } /* end if if (pEnd->write1) */
1994
1995 privptr->p_write_active_last->next=p_first_ccw;
1996 privptr->p_write_active_last=p_last_ccw;
1997 }
1998
1999 } /* endif (p_first_ccw!=NULL) */
2000
2001
2002#ifdef IOTRACE
2003 printk(KERN_INFO "%s: %s() > Dump Active CCW chain \n",
2004 dev->name,__FUNCTION__);
2005 p_buf=privptr->p_write_active_first;
2006 while (p_buf!=NULL) {
2007 dumpit((char *)p_buf, sizeof(struct ccwbk));
2008 p_buf=p_buf->next;
2009 }
2010 p_buf=(struct ccwbk*)privptr->p_end_ccw;
2011 dumpit((char *)p_buf, sizeof(struct endccw));
2012#endif
Frank Pavlic8e84c802005-09-06 15:03:09 +02002013 dev_kfree_skb_any(skb);
Linus Torvalds1da177e2005-04-16 15:20:36 -07002014 if (linkid==0) {
2015 lock=LOCK_NO;
2016 }
2017 else {
2018 lock=LOCK_YES;
2019 }
2020 claw_strt_out_IO(dev );
2021 /* if write free count is zero , set NOBUFFER */
2022#ifdef DEBUGMSG
2023 printk(KERN_INFO "%s: %s() > free_count is %d\n",
2024 dev->name,__FUNCTION__,
2025 (int) privptr->write_free_count );
2026#endif
2027 if (privptr->write_free_count==0) {
2028 claw_setbit_busy(TB_NOBUFFER,dev);
2029 }
2030Done2:
2031 claw_clearbit_busy(TB_TX,dev);
2032Done:
2033#ifdef FUNCTRACE
2034 printk(KERN_INFO "%s: %s() > exit on line %d, rc = %d \n",
2035 dev->name,__FUNCTION__,__LINE__, rc);
2036#endif
2037 return(rc);
2038} /* end of claw_hw_tx */
2039
2040/*-------------------------------------------------------------------*
2041* *
2042* init_ccw_bk *
2043* *
2044*--------------------------------------------------------------------*/
2045
2046static int
2047init_ccw_bk(struct net_device *dev)
2048{
2049
2050 __u32 ccw_blocks_required;
2051 __u32 ccw_blocks_perpage;
2052 __u32 ccw_pages_required;
2053 __u32 claw_reads_perpage=1;
2054 __u32 claw_read_pages;
2055 __u32 claw_writes_perpage=1;
2056 __u32 claw_write_pages;
2057 void *p_buff=NULL;
2058 struct ccwbk*p_free_chain;
2059 struct ccwbk*p_buf;
2060 struct ccwbk*p_last_CCWB;
2061 struct ccwbk*p_first_CCWB;
2062 struct endccw *p_endccw=NULL;
2063 addr_t real_address;
2064 struct claw_privbk *privptr=dev->priv;
2065 struct clawh *pClawH=NULL;
2066 addr_t real_TIC_address;
2067 int i,j;
2068#ifdef FUNCTRACE
2069 printk(KERN_INFO "%s: %s() enter \n",dev->name,__FUNCTION__);
2070#endif
2071 CLAW_DBF_TEXT(4,trace,"init_ccw");
2072#ifdef DEBUGMSG
2073 printk(KERN_INFO "%s: variable dev =\n",dev->name);
2074 dumpit((char *) dev, sizeof(struct net_device));
2075#endif
2076
2077 /* initialize statistics field */
2078 privptr->active_link_ID=0;
2079 /* initialize ccwbk pointers */
2080 privptr->p_write_free_chain=NULL; /* pointer to free ccw chain*/
2081 privptr->p_write_active_first=NULL; /* pointer to the first write ccw*/
2082 privptr->p_write_active_last=NULL; /* pointer to the last write ccw*/
2083 privptr->p_read_active_first=NULL; /* pointer to the first read ccw*/
2084 privptr->p_read_active_last=NULL; /* pointer to the last read ccw */
2085 privptr->p_end_ccw=NULL; /* pointer to ending ccw */
2086 privptr->p_claw_signal_blk=NULL; /* pointer to signal block */
2087 privptr->buffs_alloc = 0;
2088 memset(&privptr->end_ccw, 0x00, sizeof(struct endccw));
2089 memset(&privptr->ctl_bk, 0x00, sizeof(struct clawctl));
2090 /* initialize free write ccwbk counter */
2091 privptr->write_free_count=0; /* number of free bufs on write chain */
2092 p_last_CCWB = NULL;
2093 p_first_CCWB= NULL;
2094 /*
2095 * We need 1 CCW block for each read buffer, 1 for each
2096 * write buffer, plus 1 for ClawSignalBlock
2097 */
2098 ccw_blocks_required =
2099 privptr->p_env->read_buffers+privptr->p_env->write_buffers+1;
2100#ifdef DEBUGMSG
2101 printk(KERN_INFO "%s: %s() "
2102 "ccw_blocks_required=%d\n",
2103 dev->name,__FUNCTION__,
2104 ccw_blocks_required);
2105 printk(KERN_INFO "%s: %s() "
2106 "PAGE_SIZE=0x%x\n",
2107 dev->name,__FUNCTION__,
2108 (unsigned int)PAGE_SIZE);
2109 printk(KERN_INFO "%s: %s() > "
2110 "PAGE_MASK=0x%x\n",
2111 dev->name,__FUNCTION__,
2112 (unsigned int)PAGE_MASK);
2113#endif
2114 /*
2115 * compute number of CCW blocks that will fit in a page
2116 */
2117 ccw_blocks_perpage= PAGE_SIZE / CCWBK_SIZE;
2118 ccw_pages_required=
2119 (ccw_blocks_required+ccw_blocks_perpage -1) /
2120 ccw_blocks_perpage;
2121
2122#ifdef DEBUGMSG
2123 printk(KERN_INFO "%s: %s() > ccw_blocks_perpage=%d\n",
2124 dev->name,__FUNCTION__,
2125 ccw_blocks_perpage);
2126 printk(KERN_INFO "%s: %s() > ccw_pages_required=%d\n",
2127 dev->name,__FUNCTION__,
2128 ccw_pages_required);
2129#endif
2130 /*
2131 * read and write sizes are set by 2 constants in claw.h
2132 * 4k and 32k. Unpacked values other than 4k are not going to
2133 * provide good performance. With packing buffers support 32k
2134 * buffers are used.
2135 */
2136 if (privptr->p_env->read_size < PAGE_SIZE) {
2137 claw_reads_perpage= PAGE_SIZE / privptr->p_env->read_size;
2138 claw_read_pages= (privptr->p_env->read_buffers +
2139 claw_reads_perpage -1) / claw_reads_perpage;
2140 }
2141 else { /* > or equal */
2142 privptr->p_buff_pages_perread=
2143 (privptr->p_env->read_size + PAGE_SIZE - 1) / PAGE_SIZE;
2144 claw_read_pages=
2145 privptr->p_env->read_buffers * privptr->p_buff_pages_perread;
2146 }
2147 if (privptr->p_env->write_size < PAGE_SIZE) {
2148 claw_writes_perpage=
2149 PAGE_SIZE / privptr->p_env->write_size;
2150 claw_write_pages=
2151 (privptr->p_env->write_buffers + claw_writes_perpage -1) /
2152 claw_writes_perpage;
2153
2154 }
2155 else { /* > or equal */
2156 privptr->p_buff_pages_perwrite=
2157 (privptr->p_env->read_size + PAGE_SIZE - 1) / PAGE_SIZE;
2158 claw_write_pages=
2159 privptr->p_env->write_buffers * privptr->p_buff_pages_perwrite;
2160 }
2161#ifdef DEBUGMSG
2162 if (privptr->p_env->read_size < PAGE_SIZE) {
2163 printk(KERN_INFO "%s: %s() reads_perpage=%d\n",
2164 dev->name,__FUNCTION__,
2165 claw_reads_perpage);
2166 }
2167 else {
2168 printk(KERN_INFO "%s: %s() pages_perread=%d\n",
2169 dev->name,__FUNCTION__,
2170 privptr->p_buff_pages_perread);
2171 }
2172 printk(KERN_INFO "%s: %s() read_pages=%d\n",
2173 dev->name,__FUNCTION__,
2174 claw_read_pages);
2175 if (privptr->p_env->write_size < PAGE_SIZE) {
2176 printk(KERN_INFO "%s: %s() writes_perpage=%d\n",
2177 dev->name,__FUNCTION__,
2178 claw_writes_perpage);
2179 }
2180 else {
2181 printk(KERN_INFO "%s: %s() pages_perwrite=%d\n",
2182 dev->name,__FUNCTION__,
2183 privptr->p_buff_pages_perwrite);
2184 }
2185 printk(KERN_INFO "%s: %s() write_pages=%d\n",
2186 dev->name,__FUNCTION__,
2187 claw_write_pages);
2188#endif
2189
2190
2191 /*
2192 * allocate ccw_pages_required
2193 */
2194 if (privptr->p_buff_ccw==NULL) {
2195 privptr->p_buff_ccw=
2196 (void *)__get_free_pages(__GFP_DMA,
2197 (int)pages_to_order_of_mag(ccw_pages_required ));
2198 if (privptr->p_buff_ccw==NULL) {
2199 printk(KERN_INFO "%s: %s() "
2200 "__get_free_pages for CCWs failed : "
2201 "pages is %d\n",
2202 dev->name,__FUNCTION__,
2203 ccw_pages_required );
2204#ifdef FUNCTRACE
2205 printk(KERN_INFO "%s: %s() > "
2206 "exit on line %d, rc = ENOMEM\n",
2207 dev->name,__FUNCTION__,
2208 __LINE__);
2209#endif
2210 return -ENOMEM;
2211 }
2212 privptr->p_buff_ccw_num=ccw_pages_required;
2213 }
2214 memset(privptr->p_buff_ccw, 0x00,
2215 privptr->p_buff_ccw_num * PAGE_SIZE);
2216
2217 /*
2218 * obtain ending ccw block address
2219 *
2220 */
2221 privptr->p_end_ccw = (struct endccw *)&privptr->end_ccw;
2222 real_address = (__u32)__pa(privptr->p_end_ccw);
2223 /* Initialize ending CCW block */
2224#ifdef DEBUGMSG
2225 printk(KERN_INFO "%s: %s() begin initialize ending CCW blocks\n",
2226 dev->name,__FUNCTION__);
2227#endif
2228
2229 p_endccw=privptr->p_end_ccw;
2230 p_endccw->real=real_address;
2231 p_endccw->write1=0x00;
2232 p_endccw->read1=0x00;
2233
2234 /* write1_nop1 */
2235 p_endccw->write1_nop1.cmd_code = CCW_CLAW_CMD_NOP;
2236 p_endccw->write1_nop1.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2237 p_endccw->write1_nop1.count = 1;
2238 p_endccw->write1_nop1.cda = 0;
2239
2240 /* write1_nop2 */
2241 p_endccw->write1_nop2.cmd_code = CCW_CLAW_CMD_READFF;
2242 p_endccw->write1_nop2.flags = CCW_FLAG_SLI | CCW_FLAG_SKIP;
2243 p_endccw->write1_nop2.count = 1;
2244 p_endccw->write1_nop2.cda = 0;
2245
2246 /* write2_nop1 */
2247 p_endccw->write2_nop1.cmd_code = CCW_CLAW_CMD_NOP;
2248 p_endccw->write2_nop1.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2249 p_endccw->write2_nop1.count = 1;
2250 p_endccw->write2_nop1.cda = 0;
2251
2252 /* write2_nop2 */
2253 p_endccw->write2_nop2.cmd_code = CCW_CLAW_CMD_READFF;
2254 p_endccw->write2_nop2.flags = CCW_FLAG_SLI | CCW_FLAG_SKIP;
2255 p_endccw->write2_nop2.count = 1;
2256 p_endccw->write2_nop2.cda = 0;
2257
2258 /* read1_nop1 */
2259 p_endccw->read1_nop1.cmd_code = CCW_CLAW_CMD_NOP;
2260 p_endccw->read1_nop1.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2261 p_endccw->read1_nop1.count = 1;
2262 p_endccw->read1_nop1.cda = 0;
2263
2264 /* read1_nop2 */
2265 p_endccw->read1_nop2.cmd_code = CCW_CLAW_CMD_READFF;
2266 p_endccw->read1_nop2.flags = CCW_FLAG_SLI | CCW_FLAG_SKIP;
2267 p_endccw->read1_nop2.count = 1;
2268 p_endccw->read1_nop2.cda = 0;
2269
2270 /* read2_nop1 */
2271 p_endccw->read2_nop1.cmd_code = CCW_CLAW_CMD_NOP;
2272 p_endccw->read2_nop1.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2273 p_endccw->read2_nop1.count = 1;
2274 p_endccw->read2_nop1.cda = 0;
2275
2276 /* read2_nop2 */
2277 p_endccw->read2_nop2.cmd_code = CCW_CLAW_CMD_READFF;
2278 p_endccw->read2_nop2.flags = CCW_FLAG_SLI | CCW_FLAG_SKIP;
2279 p_endccw->read2_nop2.count = 1;
2280 p_endccw->read2_nop2.cda = 0;
2281
2282#ifdef IOTRACE
2283 printk(KERN_INFO "%s: %s() dump claw ending CCW BK \n",
2284 dev->name,__FUNCTION__);
2285 dumpit((char *)p_endccw, sizeof(struct endccw));
2286#endif
2287
2288 /*
2289 * Build a chain of CCWs
2290 *
2291 */
2292
2293#ifdef DEBUGMSG
2294 printk(KERN_INFO "%s: %s() Begin build a chain of CCW buffer \n",
2295 dev->name,__FUNCTION__);
2296#endif
2297 p_buff=privptr->p_buff_ccw;
2298
2299 p_free_chain=NULL;
2300 for (i=0 ; i < ccw_pages_required; i++ ) {
2301 real_address = (__u32)__pa(p_buff);
2302 p_buf=p_buff;
2303 for (j=0 ; j < ccw_blocks_perpage ; j++) {
2304 p_buf->next = p_free_chain;
2305 p_free_chain = p_buf;
2306 p_buf->real=(__u32)__pa(p_buf);
2307 ++p_buf;
2308 }
2309 p_buff+=PAGE_SIZE;
2310 }
2311#ifdef DEBUGMSG
2312 printk(KERN_INFO "%s: %s() "
2313 "End build a chain of CCW buffer \n",
2314 dev->name,__FUNCTION__);
2315 p_buf=p_free_chain;
2316 while (p_buf!=NULL) {
2317 dumpit((char *)p_buf, sizeof(struct ccwbk));
2318 p_buf=p_buf->next;
2319 }
2320#endif
2321
2322 /*
2323 * Initialize ClawSignalBlock
2324 *
2325 */
2326#ifdef DEBUGMSG
2327 printk(KERN_INFO "%s: %s() "
2328 "Begin initialize ClawSignalBlock \n",
2329 dev->name,__FUNCTION__);
2330#endif
2331 if (privptr->p_claw_signal_blk==NULL) {
2332 privptr->p_claw_signal_blk=p_free_chain;
2333 p_free_chain=p_free_chain->next;
2334 pClawH=(struct clawh *)privptr->p_claw_signal_blk;
2335 pClawH->length=0xffff;
2336 pClawH->opcode=0xff;
2337 pClawH->flag=CLAW_BUSY;
2338 }
2339#ifdef DEBUGMSG
2340 printk(KERN_INFO "%s: %s() > End initialize "
2341 "ClawSignalBlock\n",
2342 dev->name,__FUNCTION__);
2343 dumpit((char *)privptr->p_claw_signal_blk, sizeof(struct ccwbk));
2344#endif
2345
2346 /*
2347 * allocate write_pages_required and add to free chain
2348 */
2349 if (privptr->p_buff_write==NULL) {
2350 if (privptr->p_env->write_size < PAGE_SIZE) {
2351 privptr->p_buff_write=
2352 (void *)__get_free_pages(__GFP_DMA,
2353 (int)pages_to_order_of_mag(claw_write_pages ));
2354 if (privptr->p_buff_write==NULL) {
2355 printk(KERN_INFO "%s: %s() __get_free_pages for write"
2356 " bufs failed : get is for %d pages\n",
2357 dev->name,__FUNCTION__,claw_write_pages );
2358 free_pages((unsigned long)privptr->p_buff_ccw,
2359 (int)pages_to_order_of_mag(privptr->p_buff_ccw_num));
2360 privptr->p_buff_ccw=NULL;
2361#ifdef FUNCTRACE
2362 printk(KERN_INFO "%s: %s() > exit on line %d,"
2363 "rc = ENOMEM\n",
2364 dev->name,__FUNCTION__,__LINE__);
2365#endif
2366 return -ENOMEM;
2367 }
2368 /*
2369 * Build CLAW write free chain
2370 *
2371 */
2372
2373 memset(privptr->p_buff_write, 0x00,
2374 ccw_pages_required * PAGE_SIZE);
2375#ifdef DEBUGMSG
2376 printk(KERN_INFO "%s: %s() Begin build claw write free "
2377 "chain \n",dev->name,__FUNCTION__);
2378#endif
2379 privptr->p_write_free_chain=NULL;
2380
2381 p_buff=privptr->p_buff_write;
2382
2383 for (i=0 ; i< privptr->p_env->write_buffers ; i++) {
2384 p_buf = p_free_chain; /* get a CCW */
2385 p_free_chain = p_buf->next;
2386 p_buf->next =privptr->p_write_free_chain;
2387 privptr->p_write_free_chain = p_buf;
2388 p_buf-> p_buffer = (struct clawbuf *)p_buff;
2389 p_buf-> write.cda = (__u32)__pa(p_buff);
2390 p_buf-> write.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2391 p_buf-> w_read_FF.cmd_code = CCW_CLAW_CMD_READFF;
2392 p_buf-> w_read_FF.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2393 p_buf-> w_read_FF.count = 1;
2394 p_buf-> w_read_FF.cda =
2395 (__u32)__pa(&p_buf-> header.flag);
2396 p_buf-> w_TIC_1.cmd_code = CCW_CLAW_CMD_TIC;
2397 p_buf-> w_TIC_1.flags = 0;
2398 p_buf-> w_TIC_1.count = 0;
2399
2400 if (((unsigned long)p_buff+privptr->p_env->write_size) >=
2401 ((unsigned long)(p_buff+2*
2402 (privptr->p_env->write_size) -1) & PAGE_MASK)) {
2403 p_buff= p_buff+privptr->p_env->write_size;
2404 }
2405 }
2406 }
2407 else /* Buffers are => PAGE_SIZE. 1 buff per get_free_pages */
2408 {
2409 privptr->p_write_free_chain=NULL;
2410 for (i = 0; i< privptr->p_env->write_buffers ; i++) {
2411 p_buff=(void *)__get_free_pages(__GFP_DMA,
2412 (int)pages_to_order_of_mag(
2413 privptr->p_buff_pages_perwrite) );
2414#ifdef IOTRACE
2415 printk(KERN_INFO "%s:%s __get_free_pages "
2416 "for writes buf: get for %d pages\n",
2417 dev->name,__FUNCTION__,
2418 privptr->p_buff_pages_perwrite);
2419#endif
2420 if (p_buff==NULL) {
2421 printk(KERN_INFO "%s:%s __get_free_pages"
2422 "for writes buf failed : get is for %d pages\n",
2423 dev->name,
2424 __FUNCTION__,
2425 privptr->p_buff_pages_perwrite );
2426 free_pages((unsigned long)privptr->p_buff_ccw,
2427 (int)pages_to_order_of_mag(
2428 privptr->p_buff_ccw_num));
2429 privptr->p_buff_ccw=NULL;
2430 p_buf=privptr->p_buff_write;
2431 while (p_buf!=NULL) {
2432 free_pages((unsigned long)
2433 p_buf->p_buffer,
2434 (int)pages_to_order_of_mag(
2435 privptr->p_buff_pages_perwrite));
2436 p_buf=p_buf->next;
2437 }
2438#ifdef FUNCTRACE
2439 printk(KERN_INFO "%s: %s exit on line %d, rc = ENOMEM\n",
2440 dev->name,
2441 __FUNCTION__,
2442 __LINE__);
2443#endif
2444 return -ENOMEM;
2445 } /* Error on get_pages */
2446 memset(p_buff, 0x00, privptr->p_env->write_size );
2447 p_buf = p_free_chain;
2448 p_free_chain = p_buf->next;
2449 p_buf->next = privptr->p_write_free_chain;
2450 privptr->p_write_free_chain = p_buf;
2451 privptr->p_buff_write = p_buf;
2452 p_buf->p_buffer=(struct clawbuf *)p_buff;
2453 p_buf-> write.cda = (__u32)__pa(p_buff);
2454 p_buf-> write.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2455 p_buf-> w_read_FF.cmd_code = CCW_CLAW_CMD_READFF;
2456 p_buf-> w_read_FF.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2457 p_buf-> w_read_FF.count = 1;
2458 p_buf-> w_read_FF.cda =
2459 (__u32)__pa(&p_buf-> header.flag);
2460 p_buf-> w_TIC_1.cmd_code = CCW_CLAW_CMD_TIC;
2461 p_buf-> w_TIC_1.flags = 0;
2462 p_buf-> w_TIC_1.count = 0;
2463 } /* for all write_buffers */
2464
2465 } /* else buffers are PAGE_SIZE or bigger */
2466
2467 }
2468 privptr->p_buff_write_num=claw_write_pages;
2469 privptr->write_free_count=privptr->p_env->write_buffers;
2470
2471
2472#ifdef DEBUGMSG
2473 printk(KERN_INFO "%s:%s End build claw write free chain \n",
2474 dev->name,__FUNCTION__);
2475 p_buf=privptr->p_write_free_chain;
2476 while (p_buf!=NULL) {
2477 dumpit((char *)p_buf, sizeof(struct ccwbk));
2478 p_buf=p_buf->next;
2479 }
2480#endif
2481 /*
2482 * allocate read_pages_required and chain to free chain
2483 */
2484 if (privptr->p_buff_read==NULL) {
2485 if (privptr->p_env->read_size < PAGE_SIZE) {
2486 privptr->p_buff_read=
2487 (void *)__get_free_pages(__GFP_DMA,
2488 (int)pages_to_order_of_mag(claw_read_pages) );
2489 if (privptr->p_buff_read==NULL) {
2490 printk(KERN_INFO "%s: %s() "
2491 "__get_free_pages for read buf failed : "
2492 "get is for %d pages\n",
2493 dev->name,__FUNCTION__,claw_read_pages );
2494 free_pages((unsigned long)privptr->p_buff_ccw,
2495 (int)pages_to_order_of_mag(
2496 privptr->p_buff_ccw_num));
2497 /* free the write pages size is < page size */
2498 free_pages((unsigned long)privptr->p_buff_write,
2499 (int)pages_to_order_of_mag(
2500 privptr->p_buff_write_num));
2501 privptr->p_buff_ccw=NULL;
2502 privptr->p_buff_write=NULL;
2503#ifdef FUNCTRACE
2504 printk(KERN_INFO "%s: %s() > exit on line %d, rc ="
2505 " ENOMEM\n",dev->name,__FUNCTION__,__LINE__);
2506#endif
2507 return -ENOMEM;
2508 }
2509 memset(privptr->p_buff_read, 0x00, claw_read_pages * PAGE_SIZE);
2510 privptr->p_buff_read_num=claw_read_pages;
2511 /*
2512 * Build CLAW read free chain
2513 *
2514 */
2515#ifdef DEBUGMSG
2516 printk(KERN_INFO "%s: %s() Begin build claw read free chain \n",
2517 dev->name,__FUNCTION__);
2518#endif
2519 p_buff=privptr->p_buff_read;
2520 for (i=0 ; i< privptr->p_env->read_buffers ; i++) {
2521 p_buf = p_free_chain;
2522 p_free_chain = p_buf->next;
2523
2524 if (p_last_CCWB==NULL) {
2525 p_buf->next=NULL;
2526 real_TIC_address=0;
2527 p_last_CCWB=p_buf;
2528 }
2529 else {
2530 p_buf->next=p_first_CCWB;
2531 real_TIC_address=
2532 (__u32)__pa(&p_first_CCWB -> read );
2533 }
2534
2535 p_first_CCWB=p_buf;
2536
2537 p_buf->p_buffer=(struct clawbuf *)p_buff;
2538 /* initialize read command */
2539 p_buf-> read.cmd_code = CCW_CLAW_CMD_READ;
2540 p_buf-> read.cda = (__u32)__pa(p_buff);
2541 p_buf-> read.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2542 p_buf-> read.count = privptr->p_env->read_size;
2543
2544 /* initialize read_h command */
2545 p_buf-> read_h.cmd_code = CCW_CLAW_CMD_READHEADER;
2546 p_buf-> read_h.cda =
2547 (__u32)__pa(&(p_buf->header));
2548 p_buf-> read_h.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2549 p_buf-> read_h.count = sizeof(struct clawh);
2550
2551 /* initialize Signal command */
2552 p_buf-> signal.cmd_code = CCW_CLAW_CMD_SIGNAL_SMOD;
2553 p_buf-> signal.cda =
2554 (__u32)__pa(&(pClawH->flag));
2555 p_buf-> signal.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2556 p_buf-> signal.count = 1;
2557
2558 /* initialize r_TIC_1 command */
2559 p_buf-> r_TIC_1.cmd_code = CCW_CLAW_CMD_TIC;
2560 p_buf-> r_TIC_1.cda = (__u32)real_TIC_address;
2561 p_buf-> r_TIC_1.flags = 0;
2562 p_buf-> r_TIC_1.count = 0;
2563
2564 /* initialize r_read_FF command */
2565 p_buf-> r_read_FF.cmd_code = CCW_CLAW_CMD_READFF;
2566 p_buf-> r_read_FF.cda =
2567 (__u32)__pa(&(pClawH->flag));
2568 p_buf-> r_read_FF.flags =
2569 CCW_FLAG_SLI | CCW_FLAG_CC | CCW_FLAG_PCI;
2570 p_buf-> r_read_FF.count = 1;
2571
2572 /* initialize r_TIC_2 */
2573 memcpy(&p_buf->r_TIC_2,
2574 &p_buf->r_TIC_1, sizeof(struct ccw1));
2575
2576 /* initialize Header */
2577 p_buf->header.length=0xffff;
2578 p_buf->header.opcode=0xff;
2579 p_buf->header.flag=CLAW_PENDING;
2580
2581 if (((unsigned long)p_buff+privptr->p_env->read_size) >=
2582 ((unsigned long)(p_buff+2*(privptr->p_env->read_size) -1)
2583 & PAGE_MASK) ) {
2584 p_buff= p_buff+privptr->p_env->read_size;
2585 }
2586 else {
2587 p_buff=
2588 (void *)((unsigned long)
2589 (p_buff+2*(privptr->p_env->read_size) -1)
2590 & PAGE_MASK) ;
2591 }
2592 } /* for read_buffers */
2593 } /* read_size < PAGE_SIZE */
2594 else { /* read Size >= PAGE_SIZE */
2595
2596#ifdef DEBUGMSG
2597 printk(KERN_INFO "%s: %s() Begin build claw read free chain \n",
2598 dev->name,__FUNCTION__);
2599#endif
2600 for (i=0 ; i< privptr->p_env->read_buffers ; i++) {
2601 p_buff = (void *)__get_free_pages(__GFP_DMA,
2602 (int)pages_to_order_of_mag(privptr->p_buff_pages_perread) );
2603 if (p_buff==NULL) {
2604 printk(KERN_INFO "%s: %s() __get_free_pages for read "
2605 "buf failed : get is for %d pages\n",
2606 dev->name,__FUNCTION__,
2607 privptr->p_buff_pages_perread );
2608 free_pages((unsigned long)privptr->p_buff_ccw,
2609 (int)pages_to_order_of_mag(privptr->p_buff_ccw_num));
2610 /* free the write pages */
2611 p_buf=privptr->p_buff_write;
2612 while (p_buf!=NULL) {
2613 free_pages((unsigned long)p_buf->p_buffer,
2614 (int)pages_to_order_of_mag(
2615 privptr->p_buff_pages_perwrite ));
2616 p_buf=p_buf->next;
2617 }
2618 /* free any read pages already alloc */
2619 p_buf=privptr->p_buff_read;
2620 while (p_buf!=NULL) {
2621 free_pages((unsigned long)p_buf->p_buffer,
2622 (int)pages_to_order_of_mag(
2623 privptr->p_buff_pages_perread ));
2624 p_buf=p_buf->next;
2625 }
2626 privptr->p_buff_ccw=NULL;
2627 privptr->p_buff_write=NULL;
2628#ifdef FUNCTRACE
2629 printk(KERN_INFO "%s: %s() exit on line %d, rc = ENOMEM\n",
2630 dev->name,__FUNCTION__,
2631 __LINE__);
2632#endif
2633 return -ENOMEM;
2634 }
2635 memset(p_buff, 0x00, privptr->p_env->read_size);
2636 p_buf = p_free_chain;
2637 privptr->p_buff_read = p_buf;
2638 p_free_chain = p_buf->next;
2639
2640 if (p_last_CCWB==NULL) {
2641 p_buf->next=NULL;
2642 real_TIC_address=0;
2643 p_last_CCWB=p_buf;
2644 }
2645 else {
2646 p_buf->next=p_first_CCWB;
2647 real_TIC_address=
2648 (addr_t)__pa(
2649 &p_first_CCWB -> read );
2650 }
2651
2652 p_first_CCWB=p_buf;
2653 /* save buff address */
2654 p_buf->p_buffer=(struct clawbuf *)p_buff;
2655 /* initialize read command */
2656 p_buf-> read.cmd_code = CCW_CLAW_CMD_READ;
2657 p_buf-> read.cda = (__u32)__pa(p_buff);
2658 p_buf-> read.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2659 p_buf-> read.count = privptr->p_env->read_size;
2660
2661 /* initialize read_h command */
2662 p_buf-> read_h.cmd_code = CCW_CLAW_CMD_READHEADER;
2663 p_buf-> read_h.cda =
2664 (__u32)__pa(&(p_buf->header));
2665 p_buf-> read_h.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2666 p_buf-> read_h.count = sizeof(struct clawh);
2667
2668 /* initialize Signal command */
2669 p_buf-> signal.cmd_code = CCW_CLAW_CMD_SIGNAL_SMOD;
2670 p_buf-> signal.cda =
2671 (__u32)__pa(&(pClawH->flag));
2672 p_buf-> signal.flags = CCW_FLAG_SLI | CCW_FLAG_CC;
2673 p_buf-> signal.count = 1;
2674
2675 /* initialize r_TIC_1 command */
2676 p_buf-> r_TIC_1.cmd_code = CCW_CLAW_CMD_TIC;
2677 p_buf-> r_TIC_1.cda = (__u32)real_TIC_address;
2678 p_buf-> r_TIC_1.flags = 0;
2679 p_buf-> r_TIC_1.count = 0;
2680
2681 /* initialize r_read_FF command */
2682 p_buf-> r_read_FF.cmd_code = CCW_CLAW_CMD_READFF;
2683 p_buf-> r_read_FF.cda =
2684 (__u32)__pa(&(pClawH->flag));
2685 p_buf-> r_read_FF.flags =
2686 CCW_FLAG_SLI | CCW_FLAG_CC | CCW_FLAG_PCI;
2687 p_buf-> r_read_FF.count = 1;
2688
2689 /* initialize r_TIC_2 */
2690 memcpy(&p_buf->r_TIC_2, &p_buf->r_TIC_1,
2691 sizeof(struct ccw1));
2692
2693 /* initialize Header */
2694 p_buf->header.length=0xffff;
2695 p_buf->header.opcode=0xff;
2696 p_buf->header.flag=CLAW_PENDING;
2697
2698 } /* For read_buffers */
2699 } /* read_size >= PAGE_SIZE */
2700 } /* pBuffread = NULL */
2701#ifdef DEBUGMSG
2702 printk(KERN_INFO "%s: %s() > End build claw read free chain \n",
2703 dev->name,__FUNCTION__);
2704 p_buf=p_first_CCWB;
2705 while (p_buf!=NULL) {
2706 dumpit((char *)p_buf, sizeof(struct ccwbk));
2707 p_buf=p_buf->next;
2708 }
2709
2710#endif
2711 add_claw_reads( dev ,p_first_CCWB , p_last_CCWB);
2712 privptr->buffs_alloc = 1;
2713#ifdef FUNCTRACE
2714 printk(KERN_INFO "%s: %s() exit on line %d\n",
2715 dev->name,__FUNCTION__,__LINE__);
2716#endif
2717 return 0;
2718} /* end of init_ccw_bk */
2719
2720/*-------------------------------------------------------------------*
2721* *
2722* probe_error *
2723* *
2724*--------------------------------------------------------------------*/
2725
2726static void
2727probe_error( struct ccwgroup_device *cgdev)
2728{
2729 struct claw_privbk *privptr;
2730#ifdef FUNCTRACE
2731 printk(KERN_INFO "%s enter \n",__FUNCTION__);
2732#endif
2733 CLAW_DBF_TEXT(4,trace,"proberr");
2734#ifdef DEBUGMSG
2735 printk(KERN_INFO "%s variable cgdev =\n",__FUNCTION__);
2736 dumpit((char *) cgdev, sizeof(struct ccwgroup_device));
2737#endif
2738 privptr=(struct claw_privbk *)cgdev->dev.driver_data;
2739 if (privptr!=NULL) {
Jesper Juhl17fd6822005-11-07 01:01:30 -08002740 kfree(privptr->p_env);
2741 privptr->p_env=NULL;
2742 kfree(privptr->p_mtc_envelope);
2743 privptr->p_mtc_envelope=NULL;
Linus Torvalds1da177e2005-04-16 15:20:36 -07002744 kfree(privptr);
2745 privptr=NULL;
2746 }
2747#ifdef FUNCTRACE
2748 printk(KERN_INFO "%s > exit on line %d\n",
2749 __FUNCTION__,__LINE__);
2750#endif
2751
2752 return;
2753} /* probe_error */
2754
2755
2756
2757/*-------------------------------------------------------------------*
2758* claw_process_control *
2759* *
2760* *
2761*--------------------------------------------------------------------*/
2762
2763static int
2764claw_process_control( struct net_device *dev, struct ccwbk * p_ccw)
2765{
2766
2767 struct clawbuf *p_buf;
2768 struct clawctl ctlbk;
2769 struct clawctl *p_ctlbk;
2770 char temp_host_name[8];
2771 char temp_ws_name[8];
2772 struct claw_privbk *privptr;
2773 struct claw_env *p_env;
2774 struct sysval *p_sysval;
2775 struct conncmd *p_connect=NULL;
2776 int rc;
2777 struct chbk *p_ch = NULL;
2778#ifdef FUNCTRACE
2779 printk(KERN_INFO "%s: %s() > enter \n",
2780 dev->name,__FUNCTION__);
2781#endif
2782 CLAW_DBF_TEXT(2,setup,"clw_cntl");
2783#ifdef DEBUGMSG
2784 printk(KERN_INFO "%s: variable dev =\n",dev->name);
2785 dumpit((char *) dev, sizeof(struct net_device));
2786 printk(KERN_INFO "%s: variable p_ccw =\n",dev->name);
2787 dumpit((char *) p_ccw, sizeof(struct ccwbk *));
2788#endif
2789 udelay(1000); /* Wait a ms for the control packets to
2790 *catch up to each other */
2791 privptr=dev->priv;
2792 p_env=privptr->p_env;
2793 memcpy( &temp_host_name, p_env->host_name, 8);
2794 memcpy( &temp_ws_name, p_env->adapter_name , 8);
2795 printk(KERN_INFO "%s: CLAW device %.8s: "
2796 "Received Control Packet\n",
2797 dev->name, temp_ws_name);
2798 if (privptr->release_pend==1) {
2799#ifdef FUNCTRACE
2800 printk(KERN_INFO "%s: %s() > "
2801 "exit on line %d, rc=0\n",
2802 dev->name,__FUNCTION__,__LINE__);
2803#endif
2804 return 0;
2805 }
2806 p_buf=p_ccw->p_buffer;
2807 p_ctlbk=&ctlbk;
2808 if (p_env->packing == DO_PACKED) { /* packing in progress?*/
2809 memcpy(p_ctlbk, &p_buf->buffer[4], sizeof(struct clawctl));
2810 } else {
2811 memcpy(p_ctlbk, p_buf, sizeof(struct clawctl));
2812 }
2813#ifdef IOTRACE
2814 printk(KERN_INFO "%s: dump claw control data inbound\n",dev->name);
2815 dumpit((char *)p_ctlbk, sizeof(struct clawctl));
2816#endif
2817 switch (p_ctlbk->command)
2818 {
2819 case SYSTEM_VALIDATE_REQUEST:
2820 if (p_ctlbk->version!=CLAW_VERSION_ID) {
2821 claw_snd_sys_validate_rsp(dev, p_ctlbk,
2822 CLAW_RC_WRONG_VERSION );
2823 printk("%s: %d is wrong version id. "
2824 "Expected %d\n",
2825 dev->name, p_ctlbk->version,
2826 CLAW_VERSION_ID);
2827 }
2828 p_sysval=(struct sysval *)&(p_ctlbk->data);
2829 printk( "%s: Recv Sys Validate Request: "
2830 "Vers=%d,link_id=%d,Corr=%d,WS name=%."
2831 "8s,Host name=%.8s\n",
2832 dev->name, p_ctlbk->version,
2833 p_ctlbk->linkid,
2834 p_ctlbk->correlator,
2835 p_sysval->WS_name,
2836 p_sysval->host_name);
2837 if (0!=memcmp(temp_host_name,p_sysval->host_name,8)) {
2838 claw_snd_sys_validate_rsp(dev, p_ctlbk,
2839 CLAW_RC_NAME_MISMATCH );
2840 CLAW_DBF_TEXT(2,setup,"HSTBAD");
2841 CLAW_DBF_TEXT_(2,setup,"%s",p_sysval->host_name);
2842 CLAW_DBF_TEXT_(2,setup,"%s",temp_host_name);
2843 printk(KERN_INFO "%s: Host name mismatch\n",
2844 dev->name);
2845 printk(KERN_INFO "%s: Received :%s: "
2846 "expected :%s: \n",
2847 dev->name,
2848 p_sysval->host_name,
2849 temp_host_name);
2850 }
2851 if (0!=memcmp(temp_ws_name,p_sysval->WS_name,8)) {
2852 claw_snd_sys_validate_rsp(dev, p_ctlbk,
2853 CLAW_RC_NAME_MISMATCH );
2854 CLAW_DBF_TEXT(2,setup,"WSNBAD");
2855 CLAW_DBF_TEXT_(2,setup,"%s",p_sysval->WS_name);
2856 CLAW_DBF_TEXT_(2,setup,"%s",temp_ws_name);
2857 printk(KERN_INFO "%s: WS name mismatch\n",
2858 dev->name);
2859 printk(KERN_INFO "%s: Received :%s: "
2860 "expected :%s: \n",
2861 dev->name,
2862 p_sysval->WS_name,
2863 temp_ws_name);
2864 }
2865 if (( p_sysval->write_frame_size < p_env->write_size) &&
2866 ( p_env->packing == 0)) {
2867 claw_snd_sys_validate_rsp(dev, p_ctlbk,
2868 CLAW_RC_HOST_RCV_TOO_SMALL );
2869 printk(KERN_INFO "%s: host write size is too "
2870 "small\n", dev->name);
2871 CLAW_DBF_TEXT(2,setup,"wrtszbad");
2872 }
2873 if (( p_sysval->read_frame_size < p_env->read_size) &&
2874 ( p_env->packing == 0)) {
2875 claw_snd_sys_validate_rsp(dev, p_ctlbk,
2876 CLAW_RC_HOST_RCV_TOO_SMALL );
2877 printk(KERN_INFO "%s: host read size is too "
2878 "small\n", dev->name);
2879 CLAW_DBF_TEXT(2,setup,"rdsizbad");
2880 }
2881 claw_snd_sys_validate_rsp(dev, p_ctlbk, 0 );
2882 printk("%s: CLAW device %.8s: System validate"
2883 " completed.\n",dev->name, temp_ws_name);
2884 printk("%s: sys Validate Rsize:%d Wsize:%d\n",dev->name,
2885 p_sysval->read_frame_size,p_sysval->write_frame_size);
2886 privptr->system_validate_comp=1;
2887 if(strncmp(p_env->api_type,WS_APPL_NAME_PACKED,6) == 0) {
2888 p_env->packing = PACKING_ASK;
2889 }
2890 claw_strt_conn_req(dev);
2891 break;
2892
2893 case SYSTEM_VALIDATE_RESPONSE:
2894 p_sysval=(struct sysval *)&(p_ctlbk->data);
2895 printk("%s: Recv Sys Validate Resp: Vers=%d,Corr=%d,RC=%d,"
2896 "WS name=%.8s,Host name=%.8s\n",
2897 dev->name,
2898 p_ctlbk->version,
2899 p_ctlbk->correlator,
2900 p_ctlbk->rc,
2901 p_sysval->WS_name,
2902 p_sysval->host_name);
2903 switch (p_ctlbk->rc)
2904 {
2905 case 0:
2906 printk(KERN_INFO "%s: CLAW device "
2907 "%.8s: System validate "
2908 "completed.\n",
2909 dev->name, temp_ws_name);
2910 if (privptr->system_validate_comp == 0)
2911 claw_strt_conn_req(dev);
2912 privptr->system_validate_comp=1;
2913 break;
2914 case CLAW_RC_NAME_MISMATCH:
2915 printk(KERN_INFO "%s: Sys Validate "
2916 "Resp : Host, WS name is "
2917 "mismatch\n",
2918 dev->name);
2919 break;
2920 case CLAW_RC_WRONG_VERSION:
2921 printk(KERN_INFO "%s: Sys Validate "
2922 "Resp : Wrong version\n",
2923 dev->name);
2924 break;
2925 case CLAW_RC_HOST_RCV_TOO_SMALL:
2926 printk(KERN_INFO "%s: Sys Validate "
2927 "Resp : bad frame size\n",
2928 dev->name);
2929 break;
2930 default:
2931 printk(KERN_INFO "%s: Sys Validate "
2932 "error code=%d \n",
2933 dev->name, p_ctlbk->rc );
2934 break;
2935 }
2936 break;
2937
2938 case CONNECTION_REQUEST:
2939 p_connect=(struct conncmd *)&(p_ctlbk->data);
2940 printk(KERN_INFO "%s: Recv Conn Req: Vers=%d,link_id=%d,"
2941 "Corr=%d,HOST appl=%.8s,WS appl=%.8s\n",
2942 dev->name,
2943 p_ctlbk->version,
2944 p_ctlbk->linkid,
2945 p_ctlbk->correlator,
2946 p_connect->host_name,
2947 p_connect->WS_name);
2948 if (privptr->active_link_ID!=0 ) {
2949 claw_snd_disc(dev, p_ctlbk);
2950 printk(KERN_INFO "%s: Conn Req error : "
2951 "already logical link is active \n",
2952 dev->name);
2953 }
2954 if (p_ctlbk->linkid!=1 ) {
2955 claw_snd_disc(dev, p_ctlbk);
2956 printk(KERN_INFO "%s: Conn Req error : "
2957 "req logical link id is not 1\n",
2958 dev->name);
2959 }
2960 rc=find_link(dev,
2961 p_connect->host_name, p_connect->WS_name);
2962 if (rc!=0) {
2963 claw_snd_disc(dev, p_ctlbk);
2964 printk(KERN_INFO "%s: Conn Req error : "
2965 "req appl name does not match\n",
2966 dev->name);
2967 }
2968 claw_send_control(dev,
2969 CONNECTION_CONFIRM, p_ctlbk->linkid,
2970 p_ctlbk->correlator,
2971 0, p_connect->host_name,
2972 p_connect->WS_name);
2973 if (p_env->packing == PACKING_ASK) {
2974 printk("%s: Now Pack ask\n",dev->name);
2975 p_env->packing = PACK_SEND;
2976 claw_snd_conn_req(dev,0);
2977 }
2978 printk(KERN_INFO "%s: CLAW device %.8s: Connection "
2979 "completed link_id=%d.\n",
2980 dev->name, temp_ws_name,
2981 p_ctlbk->linkid);
2982 privptr->active_link_ID=p_ctlbk->linkid;
2983 p_ch=&privptr->channel[WRITE];
2984 wake_up(&p_ch->wait); /* wake up claw_open ( WRITE) */
2985 break;
2986 case CONNECTION_RESPONSE:
2987 p_connect=(struct conncmd *)&(p_ctlbk->data);
2988 printk(KERN_INFO "%s: Revc Conn Resp: Vers=%d,link_id=%d,"
2989 "Corr=%d,RC=%d,Host appl=%.8s, WS appl=%.8s\n",
2990 dev->name,
2991 p_ctlbk->version,
2992 p_ctlbk->linkid,
2993 p_ctlbk->correlator,
2994 p_ctlbk->rc,
2995 p_connect->host_name,
2996 p_connect->WS_name);
2997
2998 if (p_ctlbk->rc !=0 ) {
2999 printk(KERN_INFO "%s: Conn Resp error: rc=%d \n",
3000 dev->name, p_ctlbk->rc);
3001 return 1;
3002 }
3003 rc=find_link(dev,
3004 p_connect->host_name, p_connect->WS_name);
3005 if (rc!=0) {
3006 claw_snd_disc(dev, p_ctlbk);
3007 printk(KERN_INFO "%s: Conn Resp error: "
3008 "req appl name does not match\n",
3009 dev->name);
3010 }
3011 /* should be until CONNECTION_CONFIRM */
3012 privptr->active_link_ID = - (p_ctlbk->linkid);
3013 break;
3014 case CONNECTION_CONFIRM:
3015 p_connect=(struct conncmd *)&(p_ctlbk->data);
3016 printk(KERN_INFO "%s: Recv Conn Confirm:Vers=%d,link_id=%d,"
3017 "Corr=%d,Host appl=%.8s,WS appl=%.8s\n",
3018 dev->name,
3019 p_ctlbk->version,
3020 p_ctlbk->linkid,
3021 p_ctlbk->correlator,
3022 p_connect->host_name,
3023 p_connect->WS_name);
3024 if (p_ctlbk->linkid== -(privptr->active_link_ID)) {
3025 privptr->active_link_ID=p_ctlbk->linkid;
3026 if (p_env->packing > PACKING_ASK) {
3027 printk(KERN_INFO "%s: Confirmed Now packing\n",dev->name);
3028 p_env->packing = DO_PACKED;
3029 }
3030 p_ch=&privptr->channel[WRITE];
3031 wake_up(&p_ch->wait);
3032 }
3033 else {
3034 printk(KERN_INFO "%s: Conn confirm: "
3035 "unexpected linkid=%d \n",
3036 dev->name, p_ctlbk->linkid);
3037 claw_snd_disc(dev, p_ctlbk);
3038 }
3039 break;
3040 case DISCONNECT:
3041 printk(KERN_INFO "%s: Disconnect: "
3042 "Vers=%d,link_id=%d,Corr=%d\n",
3043 dev->name, p_ctlbk->version,
3044 p_ctlbk->linkid, p_ctlbk->correlator);
3045 if ((p_ctlbk->linkid == 2) &&
3046 (p_env->packing == PACK_SEND)) {
3047 privptr->active_link_ID = 1;
3048 p_env->packing = DO_PACKED;
3049 }
3050 else
3051 privptr->active_link_ID=0;
3052 break;
3053 case CLAW_ERROR:
3054 printk(KERN_INFO "%s: CLAW ERROR detected\n",
3055 dev->name);
3056 break;
3057 default:
3058 printk(KERN_INFO "%s: Unexpected command code=%d \n",
3059 dev->name, p_ctlbk->command);
3060 break;
3061 }
3062
3063#ifdef FUNCTRACE
3064 printk(KERN_INFO "%s: %s() exit on line %d, rc = 0\n",
3065 dev->name,__FUNCTION__,__LINE__);
3066#endif
3067
3068 return 0;
3069} /* end of claw_process_control */
3070
3071
3072/*-------------------------------------------------------------------*
3073* claw_send_control *
3074* *
3075*--------------------------------------------------------------------*/
3076
3077static int
3078claw_send_control(struct net_device *dev, __u8 type, __u8 link,
3079 __u8 correlator, __u8 rc, char *local_name, char *remote_name)
3080{
3081 struct claw_privbk *privptr;
3082 struct clawctl *p_ctl;
3083 struct sysval *p_sysval;
3084 struct conncmd *p_connect;
3085 struct sk_buff *skb;
3086
3087#ifdef FUNCTRACE
3088 printk(KERN_INFO "%s:%s > enter \n",dev->name,__FUNCTION__);
3089#endif
3090 CLAW_DBF_TEXT(2,setup,"sndcntl");
3091#ifdef DEBUGMSG
3092 printk(KERN_INFO "%s: Sending Control Packet \n",dev->name);
3093 printk(KERN_INFO "%s: variable type = 0x%X, link = "
3094 "%d, correlator = %d, rc = %d\n",
3095 dev->name,type, link, correlator, rc);
3096 printk(KERN_INFO "%s: variable local_name = %s, "
3097 "remote_name = %s\n",dev->name, local_name, remote_name);
3098#endif
3099 privptr=dev->priv;
3100 p_ctl=(struct clawctl *)&privptr->ctl_bk;
3101
3102 p_ctl->command=type;
3103 p_ctl->version=CLAW_VERSION_ID;
3104 p_ctl->linkid=link;
3105 p_ctl->correlator=correlator;
3106 p_ctl->rc=rc;
3107
3108 p_sysval=(struct sysval *)&p_ctl->data;
3109 p_connect=(struct conncmd *)&p_ctl->data;
3110
3111 switch (p_ctl->command) {
3112 case SYSTEM_VALIDATE_REQUEST:
3113 case SYSTEM_VALIDATE_RESPONSE:
3114 memcpy(&p_sysval->host_name, local_name, 8);
3115 memcpy(&p_sysval->WS_name, remote_name, 8);
3116 if (privptr->p_env->packing > 0) {
3117 p_sysval->read_frame_size=DEF_PACK_BUFSIZE;
3118 p_sysval->write_frame_size=DEF_PACK_BUFSIZE;
3119 } else {
3120 /* how big is the piggest group of packets */
3121 p_sysval->read_frame_size=privptr->p_env->read_size;
3122 p_sysval->write_frame_size=privptr->p_env->write_size;
3123 }
3124 memset(&p_sysval->reserved, 0x00, 4);
3125 break;
3126 case CONNECTION_REQUEST:
3127 case CONNECTION_RESPONSE:
3128 case CONNECTION_CONFIRM:
3129 case DISCONNECT:
3130 memcpy(&p_sysval->host_name, local_name, 8);
3131 memcpy(&p_sysval->WS_name, remote_name, 8);
3132 if (privptr->p_env->packing > 0) {
3133 /* How big is the biggest packet */
3134 p_connect->reserved1[0]=CLAW_FRAME_SIZE;
3135 p_connect->reserved1[1]=CLAW_FRAME_SIZE;
3136 } else {
3137 memset(&p_connect->reserved1, 0x00, 4);
3138 memset(&p_connect->reserved2, 0x00, 4);
3139 }
3140 break;
3141 default:
3142 break;
3143 }
3144
3145 /* write Control Record to the device */
3146
3147
3148 skb = dev_alloc_skb(sizeof(struct clawctl));
3149 if (!skb) {
3150 printk( "%s:%s low on mem, returning...\n",
3151 dev->name,__FUNCTION__);
3152#ifdef DEBUG
3153 printk(KERN_INFO "%s:%s Exit, rc = ENOMEM\n",
3154 dev->name,__FUNCTION__);
3155#endif
3156 return -ENOMEM;
3157 }
3158 memcpy(skb_put(skb, sizeof(struct clawctl)),
3159 p_ctl, sizeof(struct clawctl));
3160#ifdef IOTRACE
3161 printk(KERN_INFO "%s: outbnd claw cntl data \n",dev->name);
3162 dumpit((char *)p_ctl,sizeof(struct clawctl));
3163#endif
3164 if (privptr->p_env->packing >= PACK_SEND)
3165 claw_hw_tx(skb, dev, 1);
3166 else
3167 claw_hw_tx(skb, dev, 0);
3168#ifdef FUNCTRACE
3169 printk(KERN_INFO "%s:%s Exit on line %d\n",
3170 dev->name,__FUNCTION__,__LINE__);
3171#endif
3172
3173 return 0;
3174} /* end of claw_send_control */
3175
3176/*-------------------------------------------------------------------*
3177* claw_snd_conn_req *
3178* *
3179*--------------------------------------------------------------------*/
3180static int
3181claw_snd_conn_req(struct net_device *dev, __u8 link)
3182{
3183 int rc;
3184 struct claw_privbk *privptr=dev->priv;
3185 struct clawctl *p_ctl;
3186
3187#ifdef FUNCTRACE
3188 printk(KERN_INFO "%s:%s Enter \n",dev->name,__FUNCTION__);
3189#endif
3190 CLAW_DBF_TEXT(2,setup,"snd_conn");
3191#ifdef DEBUGMSG
3192 printk(KERN_INFO "%s: variable link = %X, dev =\n",dev->name, link);
3193 dumpit((char *) dev, sizeof(struct net_device));
3194#endif
3195 rc = 1;
3196 p_ctl=(struct clawctl *)&privptr->ctl_bk;
3197 p_ctl->linkid = link;
3198 if ( privptr->system_validate_comp==0x00 ) {
3199#ifdef FUNCTRACE
3200 printk(KERN_INFO "%s:%s Exit on line %d, rc = 1\n",
3201 dev->name,__FUNCTION__,__LINE__);
3202#endif
3203 return rc;
3204 }
3205 if (privptr->p_env->packing == PACKING_ASK )
3206 rc=claw_send_control(dev, CONNECTION_REQUEST,0,0,0,
3207 WS_APPL_NAME_PACKED, WS_APPL_NAME_PACKED);
3208 if (privptr->p_env->packing == PACK_SEND) {
3209 rc=claw_send_control(dev, CONNECTION_REQUEST,0,0,0,
3210 WS_APPL_NAME_IP_NAME, WS_APPL_NAME_IP_NAME);
3211 }
3212 if (privptr->p_env->packing == 0)
3213 rc=claw_send_control(dev, CONNECTION_REQUEST,0,0,0,
3214 HOST_APPL_NAME, privptr->p_env->api_type);
3215#ifdef FUNCTRACE
3216 printk(KERN_INFO "%s:%s Exit on line %d, rc = %d\n",
3217 dev->name,__FUNCTION__,__LINE__, rc);
3218#endif
3219 return rc;
3220
3221} /* end of claw_snd_conn_req */
3222
3223
3224/*-------------------------------------------------------------------*
3225* claw_snd_disc *
3226* *
3227*--------------------------------------------------------------------*/
3228
3229static int
3230claw_snd_disc(struct net_device *dev, struct clawctl * p_ctl)
3231{
3232 int rc;
3233 struct conncmd * p_connect;
3234
3235#ifdef FUNCTRACE
3236 printk(KERN_INFO "%s:%s Enter\n",dev->name,__FUNCTION__);
3237#endif
3238 CLAW_DBF_TEXT(2,setup,"snd_dsc");
3239#ifdef DEBUGMSG
3240 printk(KERN_INFO "%s: variable dev =\n",dev->name);
3241 dumpit((char *) dev, sizeof(struct net_device));
3242 printk(KERN_INFO "%s: variable p_ctl",dev->name);
3243 dumpit((char *) p_ctl, sizeof(struct clawctl));
3244#endif
3245 p_connect=(struct conncmd *)&p_ctl->data;
3246
3247 rc=claw_send_control(dev, DISCONNECT, p_ctl->linkid,
3248 p_ctl->correlator, 0,
3249 p_connect->host_name, p_connect->WS_name);
3250#ifdef FUNCTRACE
3251 printk(KERN_INFO "%s:%s Exit on line %d, rc = %d\n",
3252 dev->name,__FUNCTION__, __LINE__, rc);
3253#endif
3254 return rc;
3255} /* end of claw_snd_disc */
3256
3257
3258/*-------------------------------------------------------------------*
3259* claw_snd_sys_validate_rsp *
3260* *
3261*--------------------------------------------------------------------*/
3262
3263static int
3264claw_snd_sys_validate_rsp(struct net_device *dev,
3265 struct clawctl *p_ctl, __u32 return_code)
3266{
3267 struct claw_env * p_env;
3268 struct claw_privbk *privptr;
3269 int rc;
3270
3271#ifdef FUNCTRACE
3272 printk(KERN_INFO "%s:%s Enter\n",
3273 dev->name,__FUNCTION__);
3274#endif
3275 CLAW_DBF_TEXT(2,setup,"chkresp");
3276#ifdef DEBUGMSG
3277 printk(KERN_INFO "%s: variable return_code = %d, dev =\n",
3278 dev->name, return_code);
3279 dumpit((char *) dev, sizeof(struct net_device));
3280 printk(KERN_INFO "%s: variable p_ctl =\n",dev->name);
3281 dumpit((char *) p_ctl, sizeof(struct clawctl));
3282#endif
3283 privptr = dev->priv;
3284 p_env=privptr->p_env;
3285 rc=claw_send_control(dev, SYSTEM_VALIDATE_RESPONSE,
3286 p_ctl->linkid,
3287 p_ctl->correlator,
3288 return_code,
3289 p_env->host_name,
3290 p_env->adapter_name );
3291#ifdef FUNCTRACE
3292 printk(KERN_INFO "%s:%s Exit on line %d, rc = %d\n",
3293 dev->name,__FUNCTION__,__LINE__, rc);
3294#endif
3295 return rc;
3296} /* end of claw_snd_sys_validate_rsp */
3297
3298/*-------------------------------------------------------------------*
3299* claw_strt_conn_req *
3300* *
3301*--------------------------------------------------------------------*/
3302
3303static int
3304claw_strt_conn_req(struct net_device *dev )
3305{
3306 int rc;
3307
3308#ifdef FUNCTRACE
3309 printk(KERN_INFO "%s:%s Enter\n",dev->name,__FUNCTION__);
3310#endif
3311 CLAW_DBF_TEXT(2,setup,"conn_req");
3312#ifdef DEBUGMSG
3313 printk(KERN_INFO "%s: variable dev =\n",dev->name);
3314 dumpit((char *) dev, sizeof(struct net_device));
3315#endif
3316 rc=claw_snd_conn_req(dev, 1);
3317#ifdef FUNCTRACE
3318 printk(KERN_INFO "%s:%s Exit on line %d, rc = %d\n",
3319 dev->name,__FUNCTION__,__LINE__, rc);
3320#endif
3321 return rc;
3322} /* end of claw_strt_conn_req */
3323
3324
3325
3326/*-------------------------------------------------------------------*
3327 * claw_stats *
3328 *-------------------------------------------------------------------*/
3329
3330static struct
3331net_device_stats *claw_stats(struct net_device *dev)
3332{
3333 struct claw_privbk *privptr;
3334#ifdef FUNCTRACE
3335 printk(KERN_INFO "%s:%s Enter\n",dev->name,__FUNCTION__);
3336#endif
3337 CLAW_DBF_TEXT(4,trace,"stats");
3338 privptr = dev->priv;
3339#ifdef FUNCTRACE
3340 printk(KERN_INFO "%s:%s Exit on line %d\n",
3341 dev->name,__FUNCTION__,__LINE__);
3342#endif
3343 return &privptr->stats;
3344} /* end of claw_stats */
3345
3346
3347/*-------------------------------------------------------------------*
3348* unpack_read *
3349* *
3350*--------------------------------------------------------------------*/
3351static void
3352unpack_read(struct net_device *dev )
3353{
3354 struct sk_buff *skb;
3355 struct claw_privbk *privptr;
3356 struct claw_env *p_env;
3357 struct ccwbk *p_this_ccw;
3358 struct ccwbk *p_first_ccw;
3359 struct ccwbk *p_last_ccw;
3360 struct clawph *p_packh;
3361 void *p_packd;
3362 struct clawctl *p_ctlrec=NULL;
3363
3364 __u32 len_of_data;
3365 __u32 pack_off;
3366 __u8 link_num;
3367 __u8 mtc_this_frm=0;
3368 __u32 bytes_to_mov;
3369 struct chbk *p_ch = NULL;
3370 int i=0;
3371 int p=0;
3372
3373#ifdef FUNCTRACE
3374 printk(KERN_INFO "%s:%s enter \n",dev->name,__FUNCTION__);
3375#endif
3376 CLAW_DBF_TEXT(4,trace,"unpkread");
3377 p_first_ccw=NULL;
3378 p_last_ccw=NULL;
3379 p_packh=NULL;
3380 p_packd=NULL;
3381 privptr=dev->priv;
3382 p_env = privptr->p_env;
3383 p_this_ccw=privptr->p_read_active_first;
3384 i=0;
3385 while (p_this_ccw!=NULL && p_this_ccw->header.flag!=CLAW_PENDING) {
3386#ifdef IOTRACE
3387 printk(KERN_INFO "%s p_this_ccw \n",dev->name);
3388 dumpit((char*)p_this_ccw, sizeof(struct ccwbk));
3389 printk(KERN_INFO "%s Inbound p_this_ccw->p_buffer(64)"
3390 " pk=%d \n",dev->name,p_env->packing);
3391 dumpit((char *)p_this_ccw->p_buffer, 64 );
3392#endif
3393 pack_off = 0;
3394 p = 0;
3395 p_this_ccw->header.flag=CLAW_PENDING;
3396 privptr->p_read_active_first=p_this_ccw->next;
3397 p_this_ccw->next=NULL;
3398 p_packh = (struct clawph *)p_this_ccw->p_buffer;
3399 if ((p_env->packing == PACK_SEND) &&
3400 (p_packh->len == 32) &&
3401 (p_packh->link_num == 0)) { /* is it a packed ctl rec? */
3402 p_packh++; /* peek past pack header */
3403 p_ctlrec = (struct clawctl *)p_packh;
3404 p_packh--; /* un peek */
3405 if ((p_ctlrec->command == CONNECTION_RESPONSE) ||
3406 (p_ctlrec->command == CONNECTION_CONFIRM))
3407 p_env->packing = DO_PACKED;
3408 }
3409 if (p_env->packing == DO_PACKED)
3410 link_num=p_packh->link_num;
3411 else
3412 link_num=p_this_ccw->header.opcode / 8;
3413 if ((p_this_ccw->header.opcode & MORE_to_COME_FLAG)!=0) {
3414#ifdef DEBUGMSG
3415 printk(KERN_INFO "%s: %s > More_to_come is ON\n",
3416 dev->name,__FUNCTION__);
3417#endif
3418 mtc_this_frm=1;
3419 if (p_this_ccw->header.length!=
3420 privptr->p_env->read_size ) {
3421 printk(KERN_INFO " %s: Invalid frame detected "
3422 "length is %02x\n" ,
3423 dev->name, p_this_ccw->header.length);
3424 }
3425 }
3426
3427 if (privptr->mtc_skipping) {
3428 /*
3429 * We're in the mode of skipping past a
3430 * multi-frame message
3431 * that we can't process for some reason or other.
3432 * The first frame without the More-To-Come flag is
3433 * the last frame of the skipped message.
3434 */
3435 /* in case of More-To-Come not set in this frame */
3436 if (mtc_this_frm==0) {
3437 privptr->mtc_skipping=0; /* Ok, the end */
3438 privptr->mtc_logical_link=-1;
3439 }
3440#ifdef DEBUGMSG
3441 printk(KERN_INFO "%s:%s goto next "
3442 "frame from MoretoComeSkip \n",
3443 dev->name,__FUNCTION__);
3444#endif
3445 goto NextFrame;
3446 }
3447
3448 if (link_num==0) {
3449 claw_process_control(dev, p_this_ccw);
3450#ifdef DEBUGMSG
3451 printk(KERN_INFO "%s:%s goto next "
3452 "frame from claw_process_control \n",
3453 dev->name,__FUNCTION__);
3454#endif
3455 CLAW_DBF_TEXT(4,trace,"UnpkCntl");
3456 goto NextFrame;
3457 }
3458unpack_next:
3459 if (p_env->packing == DO_PACKED) {
3460 if (pack_off > p_env->read_size)
3461 goto NextFrame;
3462 p_packd = p_this_ccw->p_buffer+pack_off;
3463 p_packh = (struct clawph *) p_packd;
3464 if ((p_packh->len == 0) || /* all done with this frame? */
3465 (p_packh->flag != 0))
3466 goto NextFrame;
3467 bytes_to_mov = p_packh->len;
3468 pack_off += bytes_to_mov+sizeof(struct clawph);
3469 p++;
3470 } else {
3471 bytes_to_mov=p_this_ccw->header.length;
3472 }
3473 if (privptr->mtc_logical_link<0) {
3474#ifdef DEBUGMSG
3475 printk(KERN_INFO "%s: %s mtc_logical_link < 0 \n",
3476 dev->name,__FUNCTION__);
3477#endif
3478
3479 /*
3480 * if More-To-Come is set in this frame then we don't know
3481 * length of entire message, and hence have to allocate
3482 * large buffer */
3483
3484 /* We are starting a new envelope */
3485 privptr->mtc_offset=0;
3486 privptr->mtc_logical_link=link_num;
3487 }
3488
3489 if (bytes_to_mov > (MAX_ENVELOPE_SIZE- privptr->mtc_offset) ) {
3490 /* error */
3491#ifdef DEBUGMSG
3492 printk(KERN_INFO "%s: %s > goto next "
3493 "frame from MoretoComeSkip \n",
3494 dev->name,
3495 __FUNCTION__);
3496 printk(KERN_INFO " bytes_to_mov %d > (MAX_ENVELOPE_"
3497 "SIZE-privptr->mtc_offset %d)\n",
3498 bytes_to_mov,(MAX_ENVELOPE_SIZE- privptr->mtc_offset));
3499#endif
3500 privptr->stats.rx_frame_errors++;
3501 goto NextFrame;
3502 }
3503 if (p_env->packing == DO_PACKED) {
3504 memcpy( privptr->p_mtc_envelope+ privptr->mtc_offset,
3505 p_packd+sizeof(struct clawph), bytes_to_mov);
3506
3507 } else {
3508 memcpy( privptr->p_mtc_envelope+ privptr->mtc_offset,
3509 p_this_ccw->p_buffer, bytes_to_mov);
3510 }
3511#ifdef DEBUGMSG
3512 printk(KERN_INFO "%s: %s() received data \n",
3513 dev->name,__FUNCTION__);
3514 if (p_env->packing == DO_PACKED)
3515 dumpit((char *)p_packd+sizeof(struct clawph),32);
3516 else
3517 dumpit((char *)p_this_ccw->p_buffer, 32);
3518 printk(KERN_INFO "%s: %s() bytelength %d \n",
3519 dev->name,__FUNCTION__,bytes_to_mov);
3520#endif
3521 if (mtc_this_frm==0) {
3522 len_of_data=privptr->mtc_offset+bytes_to_mov;
3523 skb=dev_alloc_skb(len_of_data);
3524 if (skb) {
3525 memcpy(skb_put(skb,len_of_data),
3526 privptr->p_mtc_envelope,
3527 len_of_data);
3528 skb->mac.raw=skb->data;
3529 skb->dev=dev;
3530 skb->protocol=htons(ETH_P_IP);
3531 skb->ip_summed=CHECKSUM_UNNECESSARY;
3532 privptr->stats.rx_packets++;
3533 privptr->stats.rx_bytes+=len_of_data;
3534 netif_rx(skb);
3535#ifdef DEBUGMSG
3536 printk(KERN_INFO "%s: %s() netif_"
3537 "rx(skb) completed \n",
3538 dev->name,__FUNCTION__);
3539#endif
3540 }
3541 else {
3542 privptr->stats.rx_dropped++;
3543 printk(KERN_WARNING "%s: %s() low on memory\n",
3544 dev->name,__FUNCTION__);
3545 }
3546 privptr->mtc_offset=0;
3547 privptr->mtc_logical_link=-1;
3548 }
3549 else {
3550 privptr->mtc_offset+=bytes_to_mov;
3551 }
3552 if (p_env->packing == DO_PACKED)
3553 goto unpack_next;
3554NextFrame:
3555 /*
3556 * Remove ThisCCWblock from active read queue, and add it
3557 * to queue of free blocks to be reused.
3558 */
3559 i++;
3560 p_this_ccw->header.length=0xffff;
3561 p_this_ccw->header.opcode=0xff;
3562 /*
3563 * add this one to the free queue for later reuse
3564 */
3565 if (p_first_ccw==NULL) {
3566 p_first_ccw = p_this_ccw;
3567 }
3568 else {
3569 p_last_ccw->next = p_this_ccw;
3570 }
3571 p_last_ccw = p_this_ccw;
3572 /*
3573 * chain to next block on active read queue
3574 */
3575 p_this_ccw = privptr->p_read_active_first;
3576 CLAW_DBF_TEXT_(4,trace,"rxpkt %d",p);
3577 } /* end of while */
3578
3579 /* check validity */
3580
3581#ifdef IOTRACE
3582 printk(KERN_INFO "%s:%s processed frame is %d \n",
3583 dev->name,__FUNCTION__,i);
3584 printk(KERN_INFO "%s:%s F:%lx L:%lx\n",
3585 dev->name,
3586 __FUNCTION__,
3587 (unsigned long)p_first_ccw,
3588 (unsigned long)p_last_ccw);
3589#endif
3590 CLAW_DBF_TEXT_(4,trace,"rxfrm %d",i);
3591 add_claw_reads(dev, p_first_ccw, p_last_ccw);
3592 p_ch=&privptr->channel[READ];
3593 claw_strt_read(dev, LOCK_YES);
3594#ifdef FUNCTRACE
3595 printk(KERN_INFO "%s: %s exit on line %d\n",
3596 dev->name, __FUNCTION__, __LINE__);
3597#endif
3598 return;
3599} /* end of unpack_read */
3600
3601/*-------------------------------------------------------------------*
3602* claw_strt_read *
3603* *
3604*--------------------------------------------------------------------*/
3605static void
3606claw_strt_read (struct net_device *dev, int lock )
3607{
3608 int rc = 0;
3609 __u32 parm;
3610 unsigned long saveflags = 0;
3611 struct claw_privbk *privptr=dev->priv;
3612 struct ccwbk*p_ccwbk;
3613 struct chbk *p_ch;
3614 struct clawh *p_clawh;
3615 p_ch=&privptr->channel[READ];
3616
3617#ifdef FUNCTRACE
3618 printk(KERN_INFO "%s:%s Enter \n",dev->name,__FUNCTION__);
3619 printk(KERN_INFO "%s: variable lock = %d, dev =\n",dev->name, lock);
3620 dumpit((char *) dev, sizeof(struct net_device));
3621#endif
3622 CLAW_DBF_TEXT(4,trace,"StRdNter");
3623 p_clawh=(struct clawh *)privptr->p_claw_signal_blk;
3624 p_clawh->flag=CLAW_IDLE; /* 0x00 */
3625
3626 if ((privptr->p_write_active_first!=NULL &&
3627 privptr->p_write_active_first->header.flag!=CLAW_PENDING) ||
3628 (privptr->p_read_active_first!=NULL &&
3629 privptr->p_read_active_first->header.flag!=CLAW_PENDING )) {
3630 p_clawh->flag=CLAW_BUSY; /* 0xff */
3631 }
3632#ifdef DEBUGMSG
3633 printk(KERN_INFO "%s:%s state-%02x\n" ,
3634 dev->name,__FUNCTION__, p_ch->claw_state);
3635#endif
3636 if (lock==LOCK_YES) {
3637 spin_lock_irqsave(get_ccwdev_lock(p_ch->cdev), saveflags);
3638 }
3639 if (test_and_set_bit(0, (void *)&p_ch->IO_active) == 0) {
3640#ifdef DEBUGMSG
3641 printk(KERN_INFO "%s: HOT READ started in %s\n" ,
3642 dev->name,__FUNCTION__);
3643 p_clawh=(struct clawh *)privptr->p_claw_signal_blk;
3644 dumpit((char *)&p_clawh->flag , 1);
3645#endif
3646 CLAW_DBF_TEXT(4,trace,"HotRead");
3647 p_ccwbk=privptr->p_read_active_first;
3648 parm = (unsigned long) p_ch;
3649 rc = ccw_device_start (p_ch->cdev, &p_ccwbk->read, parm,
3650 0xff, 0);
3651 if (rc != 0) {
3652 ccw_check_return_code(p_ch->cdev, rc);
3653 }
3654 }
3655 else {
3656#ifdef DEBUGMSG
3657 printk(KERN_INFO "%s: No READ started by %s() In progress\n" ,
3658 dev->name,__FUNCTION__);
3659#endif
3660 CLAW_DBF_TEXT(2,trace,"ReadAct");
3661 }
3662
3663 if (lock==LOCK_YES) {
3664 spin_unlock_irqrestore(get_ccwdev_lock(p_ch->cdev), saveflags);
3665 }
3666#ifdef FUNCTRACE
3667 printk(KERN_INFO "%s:%s Exit on line %d\n",
3668 dev->name,__FUNCTION__,__LINE__);
3669#endif
3670 CLAW_DBF_TEXT(4,trace,"StRdExit");
3671 return;
3672} /* end of claw_strt_read */
3673
3674/*-------------------------------------------------------------------*
3675* claw_strt_out_IO *
3676* *
3677*--------------------------------------------------------------------*/
3678
3679static void
3680claw_strt_out_IO( struct net_device *dev )
3681{
3682 int rc = 0;
3683 unsigned long parm;
3684 struct claw_privbk *privptr;
3685 struct chbk *p_ch;
3686 struct ccwbk *p_first_ccw;
3687
3688#ifdef FUNCTRACE
3689 printk(KERN_INFO "%s:%s Enter\n",dev->name,__FUNCTION__);
3690#endif
3691 if (!dev) {
3692 return;
3693 }
3694 privptr=(struct claw_privbk *)dev->priv;
3695 p_ch=&privptr->channel[WRITE];
3696
3697#ifdef DEBUGMSG
3698 printk(KERN_INFO "%s:%s state-%02x\n" ,
3699 dev->name,__FUNCTION__,p_ch->claw_state);
3700#endif
3701 CLAW_DBF_TEXT(4,trace,"strt_io");
3702 p_first_ccw=privptr->p_write_active_first;
3703
3704 if (p_ch->claw_state == CLAW_STOP)
3705 return;
3706 if (p_first_ccw == NULL) {
3707#ifdef FUNCTRACE
3708 printk(KERN_INFO "%s:%s Exit on line %d\n",
3709 dev->name,__FUNCTION__,__LINE__);
3710#endif
3711 return;
3712 }
3713 if (test_and_set_bit(0, (void *)&p_ch->IO_active) == 0) {
3714 parm = (unsigned long) p_ch;
3715#ifdef DEBUGMSG
3716 printk(KERN_INFO "%s:%s do_io \n" ,dev->name,__FUNCTION__);
3717 dumpit((char *)p_first_ccw, sizeof(struct ccwbk));
3718#endif
3719 CLAW_DBF_TEXT(2,trace,"StWrtIO");
3720 rc = ccw_device_start (p_ch->cdev,&p_first_ccw->write, parm,
3721 0xff, 0);
3722 if (rc != 0) {
3723 ccw_check_return_code(p_ch->cdev, rc);
3724 }
3725 }
3726 dev->trans_start = jiffies;
3727#ifdef FUNCTRACE
3728 printk(KERN_INFO "%s:%s Exit on line %d\n",
3729 dev->name,__FUNCTION__,__LINE__);
3730#endif
3731
3732 return;
3733} /* end of claw_strt_out_IO */
3734
3735/*-------------------------------------------------------------------*
3736* Free write buffers *
3737* *
3738*--------------------------------------------------------------------*/
3739
3740static void
3741claw_free_wrt_buf( struct net_device *dev )
3742{
3743
3744 struct claw_privbk *privptr=(struct claw_privbk *)dev->priv;
3745 struct ccwbk*p_first_ccw;
3746 struct ccwbk*p_last_ccw;
3747 struct ccwbk*p_this_ccw;
3748 struct ccwbk*p_next_ccw;
3749#ifdef IOTRACE
3750 struct ccwbk*p_buf;
3751#endif
3752#ifdef FUNCTRACE
3753 printk(KERN_INFO "%s:%s Enter\n",dev->name,__FUNCTION__);
3754 printk(KERN_INFO "%s: free count = %d variable dev =\n",
3755 dev->name,privptr->write_free_count);
3756#endif
3757 CLAW_DBF_TEXT(4,trace,"freewrtb");
3758 /* scan the write queue to free any completed write packets */
3759 p_first_ccw=NULL;
3760 p_last_ccw=NULL;
3761#ifdef IOTRACE
3762 printk(KERN_INFO "%s: Dump current CCW chain \n",dev->name );
3763 p_buf=privptr->p_write_active_first;
3764 while (p_buf!=NULL) {
3765 dumpit((char *)p_buf, sizeof(struct ccwbk));
3766 p_buf=p_buf->next;
3767 }
3768 if (p_buf==NULL) {
3769 printk(KERN_INFO "%s: privptr->p_write_"
3770 "active_first==NULL\n",dev->name );
3771 }
3772 p_buf=(struct ccwbk*)privptr->p_end_ccw;
3773 dumpit((char *)p_buf, sizeof(struct endccw));
3774#endif
3775 p_this_ccw=privptr->p_write_active_first;
3776 while ( (p_this_ccw!=NULL) && (p_this_ccw->header.flag!=CLAW_PENDING))
3777 {
3778 p_next_ccw = p_this_ccw->next;
3779 if (((p_next_ccw!=NULL) &&
3780 (p_next_ccw->header.flag!=CLAW_PENDING)) ||
3781 ((p_this_ccw == privptr->p_write_active_last) &&
3782 (p_this_ccw->header.flag!=CLAW_PENDING))) {
3783 /* The next CCW is OK or this is */
3784 /* the last CCW...free it @A1A */
3785 privptr->p_write_active_first=p_this_ccw->next;
3786 p_this_ccw->header.flag=CLAW_PENDING;
3787 p_this_ccw->next=privptr->p_write_free_chain;
3788 privptr->p_write_free_chain=p_this_ccw;
3789 ++privptr->write_free_count;
3790 privptr->stats.tx_bytes+= p_this_ccw->write.count;
3791 p_this_ccw=privptr->p_write_active_first;
3792 privptr->stats.tx_packets++;
3793 }
3794 else {
3795 break;
3796 }
3797 }
3798 if (privptr->write_free_count!=0) {
3799 claw_clearbit_busy(TB_NOBUFFER,dev);
3800 }
3801 /* whole chain removed? */
3802 if (privptr->p_write_active_first==NULL) {
3803 privptr->p_write_active_last=NULL;
3804#ifdef DEBUGMSG
3805 printk(KERN_INFO "%s:%s p_write_"
3806 "active_first==NULL\n",dev->name,__FUNCTION__);
3807#endif
3808 }
3809#ifdef IOTRACE
3810 printk(KERN_INFO "%s: Dump arranged CCW chain \n",dev->name );
3811 p_buf=privptr->p_write_active_first;
3812 while (p_buf!=NULL) {
3813 dumpit((char *)p_buf, sizeof(struct ccwbk));
3814 p_buf=p_buf->next;
3815 }
3816 if (p_buf==NULL) {
3817 printk(KERN_INFO "%s: privptr->p_write_active_"
3818 "first==NULL\n",dev->name );
3819 }
3820 p_buf=(struct ccwbk*)privptr->p_end_ccw;
3821 dumpit((char *)p_buf, sizeof(struct endccw));
3822#endif
3823
3824 CLAW_DBF_TEXT_(4,trace,"FWC=%d",privptr->write_free_count);
3825#ifdef FUNCTRACE
3826 printk(KERN_INFO "%s:%s Exit on line %d free_count =%d\n",
3827 dev->name,__FUNCTION__, __LINE__,privptr->write_free_count);
3828#endif
3829 return;
3830}
3831
3832/*-------------------------------------------------------------------*
3833* claw free netdevice *
3834* *
3835*--------------------------------------------------------------------*/
3836static void
3837claw_free_netdevice(struct net_device * dev, int free_dev)
3838{
3839 struct claw_privbk *privptr;
3840#ifdef FUNCTRACE
3841 printk(KERN_INFO "%s:%s Enter\n",dev->name,__FUNCTION__);
3842#endif
3843 CLAW_DBF_TEXT(2,setup,"free_dev");
3844
3845 if (!dev)
3846 return;
3847 CLAW_DBF_TEXT_(2,setup,"%s",dev->name);
3848 privptr = dev->priv;
3849 if (dev->flags & IFF_RUNNING)
3850 claw_release(dev);
3851 if (privptr) {
3852 privptr->channel[READ].ndev = NULL; /* say it's free */
3853 }
3854 dev->priv=NULL;
3855#ifdef MODULE
3856 if (free_dev) {
3857 free_netdev(dev);
3858 }
3859#endif
3860 CLAW_DBF_TEXT(2,setup,"feee_ok");
3861#ifdef FUNCTRACE
3862 printk(KERN_INFO "%s:%s Exit\n",dev->name,__FUNCTION__);
3863#endif
3864}
3865
3866/**
3867 * Claw init netdevice
3868 * Initialize everything of the net device except the name and the
3869 * channel structs.
3870 */
3871static void
3872claw_init_netdevice(struct net_device * dev)
3873{
3874#ifdef FUNCTRACE
3875 printk(KERN_INFO "%s:%s Enter\n",dev->name,__FUNCTION__);
3876#endif
3877 CLAW_DBF_TEXT(2,setup,"init_dev");
3878 CLAW_DBF_TEXT_(2,setup,"%s",dev->name);
3879 if (!dev) {
3880 printk(KERN_WARNING "claw:%s BAD Device exit line %d\n",
3881 __FUNCTION__,__LINE__);
3882 CLAW_DBF_TEXT(2,setup,"baddev");
3883 return;
3884 }
3885 dev->mtu = CLAW_DEFAULT_MTU_SIZE;
3886 dev->hard_start_xmit = claw_tx;
3887 dev->open = claw_open;
3888 dev->stop = claw_release;
3889 dev->get_stats = claw_stats;
3890 dev->change_mtu = claw_change_mtu;
3891 dev->hard_header_len = 0;
3892 dev->addr_len = 0;
3893 dev->type = ARPHRD_SLIP;
3894 dev->tx_queue_len = 1300;
3895 dev->flags = IFF_POINTOPOINT | IFF_NOARP;
3896 SET_MODULE_OWNER(dev);
3897#ifdef FUNCTRACE
3898 printk(KERN_INFO "%s:%s Exit\n",dev->name,__FUNCTION__);
3899#endif
3900 CLAW_DBF_TEXT(2,setup,"initok");
3901 return;
3902}
3903
3904/**
3905 * Init a new channel in the privptr->channel[i].
3906 *
3907 * @param cdev The ccw_device to be added.
3908 *
3909 * @return 0 on success, !0 on error.
3910 */
3911static int
3912add_channel(struct ccw_device *cdev,int i,struct claw_privbk *privptr)
3913{
3914 struct chbk *p_ch;
3915
3916#ifdef FUNCTRACE
3917 printk(KERN_INFO "%s:%s Enter\n",cdev->dev.bus_id,__FUNCTION__);
3918#endif
3919 CLAW_DBF_TEXT_(2,setup,"%s",cdev->dev.bus_id);
3920 privptr->channel[i].flag = i+1; /* Read is 1 Write is 2 */
3921 p_ch = &privptr->channel[i];
3922 p_ch->cdev = cdev;
3923 snprintf(p_ch->id, CLAW_ID_SIZE, "cl-%s", cdev->dev.bus_id);
3924 sscanf(cdev->dev.bus_id+4,"%x",&p_ch->devno);
3925 if ((p_ch->irb = kmalloc(sizeof (struct irb),GFP_KERNEL)) == NULL) {
3926 printk(KERN_WARNING "%s Out of memory in %s for irb\n",
3927 p_ch->id,__FUNCTION__);
3928#ifdef FUNCTRACE
3929 printk(KERN_INFO "%s:%s Exit on line %d\n",
3930 p_ch->id,__FUNCTION__,__LINE__);
3931#endif
3932 return -ENOMEM;
3933 }
3934 memset(p_ch->irb, 0, sizeof (struct irb));
3935#ifdef FUNCTRACE
3936 printk(KERN_INFO "%s:%s Exit on line %d\n",
3937 cdev->dev.bus_id,__FUNCTION__,__LINE__);
3938#endif
3939 return 0;
3940}
3941
3942
3943/**
3944 *
3945 * Setup an interface.
3946 *
3947 * @param cgdev Device to be setup.
3948 *
3949 * @returns 0 on success, !0 on failure.
3950 */
3951static int
3952claw_new_device(struct ccwgroup_device *cgdev)
3953{
3954 struct claw_privbk *privptr;
3955 struct claw_env *p_env;
3956 struct net_device *dev;
3957 int ret;
3958
3959 pr_debug("%s() called\n", __FUNCTION__);
3960 printk(KERN_INFO "claw: add for %s\n",cgdev->cdev[READ]->dev.bus_id);
3961 CLAW_DBF_TEXT(2,setup,"new_dev");
3962 privptr = cgdev->dev.driver_data;
3963 cgdev->cdev[READ]->dev.driver_data = privptr;
3964 cgdev->cdev[WRITE]->dev.driver_data = privptr;
3965 if (!privptr)
3966 return -ENODEV;
3967 p_env = privptr->p_env;
3968 sscanf(cgdev->cdev[READ]->dev.bus_id+4,"%x",
3969 &p_env->devno[READ]);
3970 sscanf(cgdev->cdev[WRITE]->dev.bus_id+4,"%x",
3971 &p_env->devno[WRITE]);
3972 ret = add_channel(cgdev->cdev[0],0,privptr);
3973 if (ret == 0)
3974 ret = add_channel(cgdev->cdev[1],1,privptr);
3975 if (ret != 0) {
3976 printk(KERN_WARNING
3977 "add channel failed "
3978 "with ret = %d\n", ret);
3979 goto out;
3980 }
3981 ret = ccw_device_set_online(cgdev->cdev[READ]);
3982 if (ret != 0) {
3983 printk(KERN_WARNING
3984 "claw: ccw_device_set_online %s READ failed "
3985 "with ret = %d\n",cgdev->cdev[READ]->dev.bus_id,ret);
3986 goto out;
3987 }
3988 ret = ccw_device_set_online(cgdev->cdev[WRITE]);
3989 if (ret != 0) {
3990 printk(KERN_WARNING
3991 "claw: ccw_device_set_online %s WRITE failed "
3992 "with ret = %d\n",cgdev->cdev[WRITE]->dev.bus_id, ret);
3993 goto out;
3994 }
3995 dev = alloc_netdev(0,"claw%d",claw_init_netdevice);
3996 if (!dev) {
3997 printk(KERN_WARNING "%s:alloc_netdev failed\n",__FUNCTION__);
3998 goto out;
3999 }
4000 dev->priv = privptr;
4001 cgdev->dev.driver_data = privptr;
4002 cgdev->cdev[READ]->dev.driver_data = privptr;
4003 cgdev->cdev[WRITE]->dev.driver_data = privptr;
4004 /* sysfs magic */
4005 SET_NETDEV_DEV(dev, &cgdev->dev);
4006 if (register_netdev(dev) != 0) {
4007 claw_free_netdevice(dev, 1);
4008 CLAW_DBF_TEXT(2,trace,"regfail");
4009 goto out;
4010 }
4011 dev->flags &=~IFF_RUNNING;
4012 if (privptr->buffs_alloc == 0) {
4013 ret=init_ccw_bk(dev);
4014 if (ret !=0) {
4015 printk(KERN_WARNING
4016 "claw: init_ccw_bk failed with ret=%d\n", ret);
4017 unregister_netdev(dev);
4018 claw_free_netdevice(dev,1);
4019 CLAW_DBF_TEXT(2,trace,"ccwmem");
4020 goto out;
4021 }
4022 }
4023 privptr->channel[READ].ndev = dev;
4024 privptr->channel[WRITE].ndev = dev;
4025 privptr->p_env->ndev = dev;
4026
4027 printk(KERN_INFO "%s:readsize=%d writesize=%d "
4028 "readbuffer=%d writebuffer=%d read=0x%04x write=0x%04x\n",
4029 dev->name, p_env->read_size,
4030 p_env->write_size, p_env->read_buffers,
4031 p_env->write_buffers, p_env->devno[READ],
4032 p_env->devno[WRITE]);
4033 printk(KERN_INFO "%s:host_name:%.8s, adapter_name "
4034 ":%.8s api_type: %.8s\n",
4035 dev->name, p_env->host_name,
4036 p_env->adapter_name , p_env->api_type);
4037 return 0;
4038out:
4039 ccw_device_set_offline(cgdev->cdev[1]);
4040 ccw_device_set_offline(cgdev->cdev[0]);
4041
4042 return -ENODEV;
4043}
4044
4045static void
4046claw_purge_skb_queue(struct sk_buff_head *q)
4047{
4048 struct sk_buff *skb;
4049
4050 CLAW_DBF_TEXT(4,trace,"purgque");
4051
4052 while ((skb = skb_dequeue(q))) {
4053 atomic_dec(&skb->users);
Frank Pavlic8e84c802005-09-06 15:03:09 +02004054 dev_kfree_skb_any(skb);
Linus Torvalds1da177e2005-04-16 15:20:36 -07004055 }
4056}
4057
4058/**
4059 * Shutdown an interface.
4060 *
4061 * @param cgdev Device to be shut down.
4062 *
4063 * @returns 0 on success, !0 on failure.
4064 */
4065static int
4066claw_shutdown_device(struct ccwgroup_device *cgdev)
4067{
4068 struct claw_privbk *priv;
4069 struct net_device *ndev;
4070 int ret;
4071
4072 pr_debug("%s() called\n", __FUNCTION__);
4073 CLAW_DBF_TEXT_(2,setup,"%s",cgdev->dev.bus_id);
4074 priv = cgdev->dev.driver_data;
4075 if (!priv)
4076 return -ENODEV;
4077 ndev = priv->channel[READ].ndev;
4078 if (ndev) {
4079 /* Close the device */
4080 printk(KERN_INFO
4081 "%s: shuting down \n",ndev->name);
4082 if (ndev->flags & IFF_RUNNING)
4083 ret = claw_release(ndev);
4084 ndev->flags &=~IFF_RUNNING;
4085 unregister_netdev(ndev);
4086 ndev->priv = NULL; /* cgdev data, not ndev's to free */
4087 claw_free_netdevice(ndev, 1);
4088 priv->channel[READ].ndev = NULL;
4089 priv->channel[WRITE].ndev = NULL;
4090 priv->p_env->ndev = NULL;
4091 }
4092 ccw_device_set_offline(cgdev->cdev[1]);
4093 ccw_device_set_offline(cgdev->cdev[0]);
4094 return 0;
4095}
4096
4097static void
4098claw_remove_device(struct ccwgroup_device *cgdev)
4099{
4100 struct claw_privbk *priv;
4101
4102 pr_debug("%s() called\n", __FUNCTION__);
4103 CLAW_DBF_TEXT_(2,setup,"%s",cgdev->dev.bus_id);
4104 priv = cgdev->dev.driver_data;
4105 if (!priv) {
4106 printk(KERN_WARNING "claw: %s() no Priv exiting\n",__FUNCTION__);
4107 return;
4108 }
4109 printk(KERN_INFO "claw: %s() called %s will be removed.\n",
4110 __FUNCTION__,cgdev->cdev[0]->dev.bus_id);
4111 if (cgdev->state == CCWGROUP_ONLINE)
4112 claw_shutdown_device(cgdev);
4113 claw_remove_files(&cgdev->dev);
Jesper Juhl17fd6822005-11-07 01:01:30 -08004114 kfree(priv->p_mtc_envelope);
4115 priv->p_mtc_envelope=NULL;
4116 kfree(priv->p_env);
4117 priv->p_env=NULL;
4118 kfree(priv->channel[0].irb);
4119 priv->channel[0].irb=NULL;
4120 kfree(priv->channel[1].irb);
4121 priv->channel[1].irb=NULL;
Linus Torvalds1da177e2005-04-16 15:20:36 -07004122 kfree(priv);
4123 cgdev->dev.driver_data=NULL;
4124 cgdev->cdev[READ]->dev.driver_data = NULL;
4125 cgdev->cdev[WRITE]->dev.driver_data = NULL;
4126 put_device(&cgdev->dev);
4127}
4128
4129
4130/*
4131 * sysfs attributes
4132 */
4133static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004134claw_hname_show(struct device *dev, struct device_attribute *attr, char *buf)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004135{
4136 struct claw_privbk *priv;
4137 struct claw_env * p_env;
4138
4139 priv = dev->driver_data;
4140 if (!priv)
4141 return -ENODEV;
4142 p_env = priv->p_env;
4143 return sprintf(buf, "%s\n",p_env->host_name);
4144}
4145
4146static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004147claw_hname_write(struct device *dev, struct device_attribute *attr, const char *buf, size_t count)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004148{
4149 struct claw_privbk *priv;
4150 struct claw_env * p_env;
4151
4152 priv = dev->driver_data;
4153 if (!priv)
4154 return -ENODEV;
4155 p_env = priv->p_env;
4156 if (count > MAX_NAME_LEN+1)
4157 return -EINVAL;
4158 memset(p_env->host_name, 0x20, MAX_NAME_LEN);
4159 strncpy(p_env->host_name,buf, count);
4160 p_env->host_name[count-1] = 0x20; /* clear extra 0x0a */
4161 p_env->host_name[MAX_NAME_LEN] = 0x00;
4162 CLAW_DBF_TEXT(2,setup,"HstnSet");
4163 CLAW_DBF_TEXT_(2,setup,"%s",p_env->host_name);
4164
4165 return count;
4166}
4167
4168static DEVICE_ATTR(host_name, 0644, claw_hname_show, claw_hname_write);
4169
4170static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004171claw_adname_show(struct device *dev, struct device_attribute *attr, char *buf)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004172{
4173 struct claw_privbk *priv;
4174 struct claw_env * p_env;
4175
4176 priv = dev->driver_data;
4177 if (!priv)
4178 return -ENODEV;
4179 p_env = priv->p_env;
4180 return sprintf(buf, "%s\n",p_env->adapter_name);
4181}
4182
4183static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004184claw_adname_write(struct device *dev, struct device_attribute *attr, const char *buf, size_t count)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004185{
4186 struct claw_privbk *priv;
4187 struct claw_env * p_env;
4188
4189 priv = dev->driver_data;
4190 if (!priv)
4191 return -ENODEV;
4192 p_env = priv->p_env;
4193 if (count > MAX_NAME_LEN+1)
4194 return -EINVAL;
4195 memset(p_env->adapter_name, 0x20, MAX_NAME_LEN);
4196 strncpy(p_env->adapter_name,buf, count);
4197 p_env->adapter_name[count-1] = 0x20; /* clear extra 0x0a */
4198 p_env->adapter_name[MAX_NAME_LEN] = 0x00;
4199 CLAW_DBF_TEXT(2,setup,"AdnSet");
4200 CLAW_DBF_TEXT_(2,setup,"%s",p_env->adapter_name);
4201
4202 return count;
4203}
4204
4205static DEVICE_ATTR(adapter_name, 0644, claw_adname_show, claw_adname_write);
4206
4207static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004208claw_apname_show(struct device *dev, struct device_attribute *attr, char *buf)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004209{
4210 struct claw_privbk *priv;
4211 struct claw_env * p_env;
4212
4213 priv = dev->driver_data;
4214 if (!priv)
4215 return -ENODEV;
4216 p_env = priv->p_env;
4217 return sprintf(buf, "%s\n",
4218 p_env->api_type);
4219}
4220
4221static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004222claw_apname_write(struct device *dev, struct device_attribute *attr, const char *buf, size_t count)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004223{
4224 struct claw_privbk *priv;
4225 struct claw_env * p_env;
4226
4227 priv = dev->driver_data;
4228 if (!priv)
4229 return -ENODEV;
4230 p_env = priv->p_env;
4231 if (count > MAX_NAME_LEN+1)
4232 return -EINVAL;
4233 memset(p_env->api_type, 0x20, MAX_NAME_LEN);
4234 strncpy(p_env->api_type,buf, count);
4235 p_env->api_type[count-1] = 0x20; /* we get a loose 0x0a */
4236 p_env->api_type[MAX_NAME_LEN] = 0x00;
4237 if(strncmp(p_env->api_type,WS_APPL_NAME_PACKED,6) == 0) {
4238 p_env->read_size=DEF_PACK_BUFSIZE;
4239 p_env->write_size=DEF_PACK_BUFSIZE;
4240 p_env->packing=PACKING_ASK;
4241 CLAW_DBF_TEXT(2,setup,"PACKING");
4242 }
4243 else {
4244 p_env->packing=0;
4245 p_env->read_size=CLAW_FRAME_SIZE;
4246 p_env->write_size=CLAW_FRAME_SIZE;
4247 CLAW_DBF_TEXT(2,setup,"ApiSet");
4248 }
4249 CLAW_DBF_TEXT_(2,setup,"%s",p_env->api_type);
4250 return count;
4251}
4252
4253static DEVICE_ATTR(api_type, 0644, claw_apname_show, claw_apname_write);
4254
4255static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004256claw_wbuff_show(struct device *dev, struct device_attribute *attr, char *buf)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004257{
4258 struct claw_privbk *priv;
4259 struct claw_env * p_env;
4260
4261 priv = dev->driver_data;
4262 if (!priv)
4263 return -ENODEV;
4264 p_env = priv->p_env;
4265 return sprintf(buf, "%d\n", p_env->write_buffers);
4266}
4267
4268static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004269claw_wbuff_write(struct device *dev, struct device_attribute *attr, const char *buf, size_t count)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004270{
4271 struct claw_privbk *priv;
4272 struct claw_env * p_env;
4273 int nnn,max;
4274
4275 priv = dev->driver_data;
4276 if (!priv)
4277 return -ENODEV;
4278 p_env = priv->p_env;
4279 sscanf(buf, "%i", &nnn);
4280 if (p_env->packing) {
4281 max = 64;
4282 }
4283 else {
4284 max = 512;
4285 }
4286 if ((nnn > max ) || (nnn < 2))
4287 return -EINVAL;
4288 p_env->write_buffers = nnn;
4289 CLAW_DBF_TEXT(2,setup,"Wbufset");
4290 CLAW_DBF_TEXT_(2,setup,"WB=%d",p_env->write_buffers);
4291 return count;
4292}
4293
4294static DEVICE_ATTR(write_buffer, 0644, claw_wbuff_show, claw_wbuff_write);
4295
4296static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004297claw_rbuff_show(struct device *dev, struct device_attribute *attr, char *buf)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004298{
4299 struct claw_privbk *priv;
4300 struct claw_env * p_env;
4301
4302 priv = dev->driver_data;
4303 if (!priv)
4304 return -ENODEV;
4305 p_env = priv->p_env;
4306 return sprintf(buf, "%d\n", p_env->read_buffers);
4307}
4308
4309static ssize_t
Yani Ioannou3fd3c0a2005-05-17 06:43:27 -04004310claw_rbuff_write(struct device *dev, struct device_attribute *attr, const char *buf, size_t count)
Linus Torvalds1da177e2005-04-16 15:20:36 -07004311{
4312 struct claw_privbk *priv;
4313 struct claw_env *p_env;
4314 int nnn,max;
4315
4316 priv = dev->driver_data;
4317 if (!priv)
4318 return -ENODEV;
4319 p_env = priv->p_env;
4320 sscanf(buf, "%i", &nnn);
4321 if (p_env->packing) {
4322 max = 64;
4323 }
4324 else {
4325 max = 512;
4326 }
4327 if ((nnn > max ) || (nnn < 2))
4328 return -EINVAL;
4329 p_env->read_buffers = nnn;
4330 CLAW_DBF_TEXT(2,setup,"Rbufset");
4331 CLAW_DBF_TEXT_(2,setup,"RB=%d",p_env->read_buffers);
4332 return count;
4333}
4334
4335static DEVICE_ATTR(read_buffer, 0644, claw_rbuff_show, claw_rbuff_write);
4336
4337static struct attribute *claw_attr[] = {
4338 &dev_attr_read_buffer.attr,
4339 &dev_attr_write_buffer.attr,
4340 &dev_attr_adapter_name.attr,
4341 &dev_attr_api_type.attr,
4342 &dev_attr_host_name.attr,
4343 NULL,
4344};
4345
4346static struct attribute_group claw_attr_group = {
4347 .attrs = claw_attr,
4348};
4349
4350static int
4351claw_add_files(struct device *dev)
4352{
4353 pr_debug("%s() called\n", __FUNCTION__);
4354 CLAW_DBF_TEXT(2,setup,"add_file");
4355 return sysfs_create_group(&dev->kobj, &claw_attr_group);
4356}
4357
4358static void
4359claw_remove_files(struct device *dev)
4360{
4361 pr_debug("%s() called\n", __FUNCTION__);
4362 CLAW_DBF_TEXT(2,setup,"rem_file");
4363 sysfs_remove_group(&dev->kobj, &claw_attr_group);
4364}
4365
4366/*--------------------------------------------------------------------*
4367* claw_init and cleanup *
4368*---------------------------------------------------------------------*/
4369
4370static void __exit
4371claw_cleanup(void)
4372{
4373 unregister_cu3088_discipline(&claw_group_driver);
4374 claw_unregister_debug_facility();
4375 printk(KERN_INFO "claw: Driver unloaded\n");
4376
4377}
4378
4379/**
4380 * Initialize module.
4381 * This is called just after the module is loaded.
4382 *
4383 * @return 0 on success, !0 on error.
4384 */
4385static int __init
4386claw_init(void)
4387{
4388 int ret = 0;
Heiko Carstense018ba12006-02-01 03:06:31 -08004389 printk(KERN_INFO "claw: starting driver\n");
Linus Torvalds1da177e2005-04-16 15:20:36 -07004390
4391#ifdef FUNCTRACE
4392 printk(KERN_INFO "claw: %s() enter \n",__FUNCTION__);
4393#endif
4394 ret = claw_register_debug_facility();
4395 if (ret) {
4396 printk(KERN_WARNING "claw: %s() debug_register failed %d\n",
4397 __FUNCTION__,ret);
4398 return ret;
4399 }
4400 CLAW_DBF_TEXT(2,setup,"init_mod");
4401 ret = register_cu3088_discipline(&claw_group_driver);
4402 if (ret) {
4403 claw_unregister_debug_facility();
4404 printk(KERN_WARNING "claw; %s() cu3088 register failed %d\n",
4405 __FUNCTION__,ret);
4406 }
4407#ifdef FUNCTRACE
4408 printk(KERN_INFO "claw: %s() exit \n",__FUNCTION__);
4409#endif
4410 return ret;
4411}
4412
4413module_init(claw_init);
4414module_exit(claw_cleanup);
4415
4416
4417
4418/*--------------------------------------------------------------------*
4419* End of File *
4420*---------------------------------------------------------------------*/
4421
4422