aboutsummaryrefslogtreecommitdiffstats
path: root/include/asm-m68k
ModeNameSize
-rw-r--r--Kbuild39logstatsplainblame
-rw-r--r--a.out.h765logstatsplainblame
-rw-r--r--adb.h2051logstatsplainblame
-rw-r--r--adb_iop.h1081logstatsplainblame
-rw-r--r--amigahw.h11397logstatsplainblame
-rw-r--r--amigaints.h3548logstatsplainblame
-rw-r--r--amigayle.h3135logstatsplainblame
-rw-r--r--amipcmcia.h2568logstatsplainblame
-rw-r--r--apollodma.h9462logstatsplainblame
-rw-r--r--apollohw.h2876logstatsplainblame
-rw-r--r--atafd.h261logstatsplainblame
-rw-r--r--atafdreg.h2704logstatsplainblame
-rw-r--r--atari_SLM.h523logstatsplainblame
-rw-r--r--atari_acsi.h1163logstatsplainblame
-rw-r--r--atari_joystick.h418logstatsplainblame
-rw-r--r--atari_stdma.h492logstatsplainblame
-rw-r--r--atari_stram.h429logstatsplainblame
-rw-r--r--atarihw.h20672logstatsplainblame
-rw-r--r--atariints.h5510logstatsplainblame
-rw-r--r--atarikb.h1275logstatsplainblame
-rw-r--r--atomic.h4138logstatsplainblame
-rw-r--r--auxvec.h62logstatsplainblame
-rw-r--r--bitops.h9920logstatsplainblame
-rw-r--r--blinken.h617logstatsplainblame
-rw-r--r--bootinfo.h11903logstatsplainblame
-rw-r--r--bug.h492logstatsplainblame
-rw-r--r--bugs.h266logstatsplainblame
-rw-r--r--bvme6000hw.h3490logstatsplainblame
-rw-r--r--byteorder.h550logstatsplainblame
-rw-r--r--cache.h215logstatsplainblame
-rw-r--r--cachectl.h496logstatsplainblame
-rw-r--r--cacheflush.h4141logstatsplainblame
-rw-r--r--checksum.h3502logstatsplainblame
-rw-r--r--contregs.h112logstatsplainblame
-rw-r--r--cputime.h115logstatsplainblame
-rw-r--r--current.h135logstatsplainblame
-rw-r--r--delay.h1362logstatsplainblame
-rw-r--r--div64.h621logstatsplainblame
-rw-r--r--dma-mapping.h2391logstatsplainblame
-rw-r--r--dma.h519logstatsplainblame
-rw-r--r--dsp56k.h1269logstatsplainblame
-rw-r--r--dvma.h10007logstatsplainblame
-rw-r--r--elf.h3204logstatsplainblame
-rw-r--r--emergency-restart.h149logstatsplainblame
-rw-r--r--entry.h2829logstatsplainblame
-rw-r--r--errno.h104logstatsplainblame
-rw-r--r--fbio.h28logstatsplainblame
-rw-r--r--fcntl.h313logstatsplainblame
-rw-r--r--floppy.h5316logstatsplainblame
-rw-r--r--fpu.h530logstatsplainblame
-rw-r--r--futex.h82logstatsplainblame
-rw-r--r--hardirq.h363logstatsplainblame
-rw-r--r--hp300hw.h982logstatsplainblame
-rw-r--r--hw_irq.h86logstatsplainblame
-rw-r--r--hwtest.h428logstatsplainblame
-rw-r--r--ide.h3559logstatsplainblame
-rw-r--r--idprom.h174logstatsplainblame
-rw-r--r--intersil.h1095logstatsplainblame
-rw-r--r--io.h10663logstatsplainblame
-rw-r--r--ioctl.h31logstatsplainblame
-rw-r--r--ioctls.h2419logstatsplainblame
-rw-r--r--ipc.h29logstatsplainblame
-rw-r--r--ipcbuf.h631logstatsplainblame
-rw-r--r--irq.h3684logstatsplainblame
-rw-r--r--kmap_types.h317logstatsplainblame
-rw-r--r--linkage.h113logstatsplainblame
-rw-r--r--local.h116logstatsplainblame
-rw-r--r--mac_asc.h481logstatsplainblame
-rw-r--r--mac_baboon.h852logstatsplainblame
-rw-r--r--mac_iop.h5434logstatsplainblame
-rw-r--r--mac_mouse.h433logstatsplainblame
-rw-r--r--mac_oss.h2583logstatsplainblame
-rw-r--r--mac_psc.h7301logstatsplainblame
-rw-r--r--mac_via.h11325logstatsplainblame
-rw-r--r--machdep.h1213logstatsplainblame
-rw-r--r--machines.h3290logstatsplainblame
-rw-r--r--machw.h2542logstatsplainblame
-rw-r--r--macintosh.h3551logstatsplainblame
-rw-r--r--macints.h4119logstatsplainblame
-rw-r--r--math-emu.h6497logstatsplainblame
-rw-r--r--mc146818rtc.h501logstatsplainblame
-rw-r--r--md.h249logstatsplainblame
-rw-r--r--mman.h616logstatsplainblame
-rw-r--r--mmu.h115logstatsplainblame
-rw-r--r--mmu_context.h3386logstatsplainblame
-rw-r--r--module.h198logstatsplainblame
-rw-r--r--motorola_pgalloc.h2011logstatsplainblame
-rw-r--r--motorola_pgtable.h10017logstatsplainblame
-rw-r--r--movs.h1433logstatsplainblame
-rw-r--r--msgbuf.h974logstatsplainblame
-rw-r--r--mutex.h308logstatsplainblame
-rw-r--r--mvme147hw.h2842logstatsplainblame
-rw-r--r--mvme16xhw.h2566logstatsplainblame
-rw-r--r--namei.h303logstatsplainblame
-rw-r--r--nubus.h1201logstatsplainblame
-rw-r--r--openprom.h8195logstatsplainblame
-rw-r--r--oplib.h9833logstatsplainblame
-rw-r--r--page.h4550logstatsplainblame
-rw-r--r--page_offset.h143logstatsplainblame
-rw-r--r--param.h438logstatsplainblame
-rw-r--r--parport.h793logstatsplainblame
-rw-r--r--pci.h1158logstatsplainblame
-rw-r--r--percpu.h123logstatsplainblame
-rw-r--r--pgalloc.h277logstatsplainblame
-rw-r--r--pgtable.h4926logstatsplainblame
-rw-r--r--poll.h415logstatsplainblame
-rw-r--r--posix_types.h1957logstatsplainblame
-rw-r--r--processor.h3136logstatsplainblame
-rw-r--r--ptrace.h1756logstatsplainblame
-rw-r--r--q40_master.h2293logstatsplainblame
-rw-r--r--q40ints.h808logstatsplainblame
-rw-r--r--raw_io.h7835logstatsplainblame
-rw-r--r--resource.h116logstatsplainblame
-rw-r--r--rtc.h1860logstatsplainblame
-rw-r--r--sbus.h1157logstatsplainblame
-rw-r--r--scatterlist.h420logstatsplainblame
-rw-r--r--sections.h128logstatsplainblame
-rw-r--r--segment.h1144logstatsplainblame
-rw-r--r--semaphore-helper.h2769logstatsplainblame
-rw-r--r--semaphore.h3829logstatsplainblame
-rw-r--r--sembuf.h696logstatsplainblame
-rw-r--r--serial.h1112logstatsplainblame
-rw-r--r--setup.h11289logstatsplainblame
-rw-r--r--shm.h1027logstatsplainblame
-rw-r--r--shmbuf.h1163logstatsplainblame
-rw-r--r--shmparam.h146logstatsplainblame
-rw-r--r--sigcontext.h488logstatsplainblame
-rw-r--r--siginfo.h2007logstatsplainblame
-rw-r--r--signal.h4349logstatsplainblame
-rw-r--r--socket.h1177logstatsplainblame
-rw-r--r--sockios.h304logstatsplainblame
-rw-r--r--spinlock.h94logstatsplainblame
-rw-r--r--stat.h1622logstatsplainblame
-rw-r--r--statfs.h108logstatsplainblame
-rw-r--r--string.h3586logstatsplainblame
-rw-r--r--sun3-head.h446logstatsplainblame
-rw-r--r--sun3_pgalloc.h2159logstatsplainblame
-rw-r--r--sun3_pgtable.h8553logstatsplainblame
-rw-r--r--sun3ints.h968logstatsplainblame
-rw-r--r--sun3mmu.h4953logstatsplainblame
-rw-r--r--sun3x.h829logstatsplainblame
-rw-r--r--sun3xflop.h5801logstatsplainblame
-rw-r--r--sun3xprom.h1304logstatsplainblame
-rw-r--r--suspend.h101logstatsplainblame
-rw-r--r--swim_iop.h6981logstatsplainblame
-rw-r--r--system.h5222logstatsplainblame
-rw-r--r--termbits.h3850logstatsplainblame
-rw-r--r--termios.h3288logstatsplainblame
-rw-r--r--thread_info.h2016logstatsplainblame
-rw-r--r--timex.h286logstatsplainblame
-rw-r--r--tlb.h447logstatsplainblame
-rw-r--r--tlbflush.h5163logstatsplainblame
-rw-r--r--topology.h128logstatsplainblame
-rw-r--r--traps.h8510logstatsplainblame
-rw-r--r--types.h1420logstatsplainblame
-rw-r--r--uaccess.h9821logstatsplainblame
-rw-r--r--ucontext.h531logstatsplainblame
-rw-r--r--unaligned.h390logstatsplainblame
-rw-r--r--unistd.h11977logstatsplainblame
-rw-r--r--user.h3877logstatsplainblame
-rw-r--r--virtconvert.h1745logstatsplainblame
-rw-r--r--xor.h29logstatsplainblame
-rw-r--r--zorro.h1161logstatsplainblame
generated by cgit v1.2.2 (git 2.25.0) at 2025-03-05 04:58:25 -0500
NSTAT, /** * Event, representing timer expiry. */ CH_EVENT_TIMER, /** * Events, representing commands from upper levels. */ CH_EVENT_START, CH_EVENT_STOP, /** * MUST be always the last element!! */ NR_CH_EVENTS, }; static const char *ch_event_names[] = { "ccw_device success", "ccw_device busy", "ccw_device enodev", "ccw_device ioerr", "ccw_device unknown", "Status ATTN & BUSY", "Status ATTN", "Status BUSY", "Unit check remote reset", "Unit check remote system reset", "Unit check TX timeout", "Unit check TX parity", "Unit check Hardware failure", "Unit check RX parity", "Unit check ZERO", "Unit check Unknown", "SubChannel check Unknown", "Machine check failure", "Machine check operational", "IRQ normal", "IRQ final", "Timer", "Start", "Stop", }; /** * States of the channel statemachine. */ enum ch_states { /** * Channel not assigned to any device, * initial state, direction invalid */ CH_STATE_IDLE, /** * Channel assigned but not operating */ CH_STATE_STOPPED, CH_STATE_STARTWAIT, CH_STATE_STARTRETRY, CH_STATE_SETUPWAIT, CH_STATE_RXINIT, CH_STATE_TXINIT, CH_STATE_RX, CH_STATE_TX, CH_STATE_RXIDLE, CH_STATE_TXIDLE, CH_STATE_RXERR, CH_STATE_TXERR, CH_STATE_TERM, CH_STATE_DTERM, CH_STATE_NOTOP, /** * MUST be always the last element!! */ NR_CH_STATES, }; static const char *ch_state_names[] = { "Idle", "Stopped", "StartWait", "StartRetry", "SetupWait", "RX init", "TX init", "RX", "TX", "RX idle", "TX idle", "RX error", "TX error", "Terminating", "Restarting", "Not operational", }; #ifdef DEBUG /** * Dump header and first 16 bytes of an sk_buff for debugging purposes. * * @param skb The sk_buff to dump. * @param offset Offset relative to skb-data, where to start the dump. */ static void ctc_dump_skb(struct sk_buff *skb, int offset) { unsigned char *p = skb->data; __u16 bl; struct ll_header *header; int i; if (!(loglevel & CTC_LOGLEVEL_DEBUG)) return; p += offset; bl = *((__u16 *) p); p += 2; header = (struct ll_header *) p; p -= 2; printk(KERN_DEBUG "dump:\n"); printk(KERN_DEBUG "blocklen=%d %04x\n", bl, bl); printk(KERN_DEBUG "h->length=%d %04x\n", header->length, header->length); printk(KERN_DEBUG "h->type=%04x\n", header->type); printk(KERN_DEBUG "h->unused=%04x\n", header->unused); if (bl > 16) bl = 16; printk(KERN_DEBUG "data: "); for (i = 0; i < bl; i++) printk("%02x%s", *p++, (i % 16) ? " " : "\n<7>"); printk("\n"); } #else static inline void ctc_dump_skb(struct sk_buff *skb, int offset) { } #endif /** * Unpack a just received skb and hand it over to * upper layers. * * @param ch The channel where this skb has been received. * @param pskb The received skb. */ static __inline__ void ctc_unpack_skb(struct channel *ch, struct sk_buff *pskb) { struct net_device *dev = ch->netdev; struct ctc_priv *privptr = (struct ctc_priv *) dev->priv; __u16 len = *((__u16 *) pskb->data); DBF_TEXT(trace, 4, __FUNCTION__); skb_put(pskb, 2 + LL_HEADER_LENGTH); skb_pull(pskb, 2); pskb->dev = dev; pskb->ip_summed = CHECKSUM_UNNECESSARY; while (len > 0) { struct sk_buff *skb; struct ll_header *header = (struct ll_header *) pskb->data; skb_pull(pskb, LL_HEADER_LENGTH); if ((ch->protocol == CTC_PROTO_S390) && (header->type != ETH_P_IP)) { #ifndef DEBUG if (!(ch->logflags & LOG_FLAG_ILLEGALPKT)) { #endif /** * Check packet type only if we stick strictly * to S/390's protocol of OS390. This only * supports IP. Otherwise allow any packet * type. */ ctc_pr_warn( "%s Illegal packet type 0x%04x received, dropping\n", dev->name, header->type); ch->logflags |= LOG_FLAG_ILLEGALPKT; #ifndef DEBUG } #endif #ifdef DEBUG ctc_dump_skb(pskb, -6); #endif privptr->stats.rx_dropped++; privptr->stats.rx_frame_errors++; return; } pskb->protocol = ntohs(header->type); if (header->length <= LL_HEADER_LENGTH) { #ifndef DEBUG if (!(ch->logflags & LOG_FLAG_ILLEGALSIZE)) { #endif ctc_pr_warn( "%s Illegal packet size %d " "received (MTU=%d blocklen=%d), " "dropping\n", dev->name, header->length, dev->mtu, len); ch->logflags |= LOG_FLAG_ILLEGALSIZE; #ifndef DEBUG } #endif #ifdef DEBUG ctc_dump_skb(pskb, -6); #endif privptr->stats.rx_dropped++; privptr->stats.rx_length_errors++; return; } header->length -= LL_HEADER_LENGTH; len -= LL_HEADER_LENGTH; if ((header->length > skb_tailroom(pskb)) || (header->length > len)) { #ifndef DEBUG if (!(ch->logflags & LOG_FLAG_OVERRUN)) { #endif ctc_pr_warn( "%s Illegal packet size %d " "(beyond the end of received data), " "dropping\n", dev->name, header->length); ch->logflags |= LOG_FLAG_OVERRUN; #ifndef DEBUG } #endif #ifdef DEBUG ctc_dump_skb(pskb, -6); #endif privptr->stats.rx_dropped++; privptr->stats.rx_length_errors++; return; } skb_put(pskb, header->length); pskb->mac.raw = pskb->data; len -= header->length; skb = dev_alloc_skb(pskb->len); if (!skb) { #ifndef DEBUG if (!(ch->logflags & LOG_FLAG_NOMEM)) { #endif ctc_pr_warn( "%s Out of memory in ctc_unpack_skb\n", dev->name); ch->logflags |= LOG_FLAG_NOMEM; #ifndef DEBUG } #endif privptr->stats.rx_dropped++; return; } memcpy(skb_put(skb, pskb->len), pskb->data, pskb->len); skb->mac.raw = skb->data; skb->dev = pskb->dev; skb->protocol = pskb->protocol; pskb->ip_summed = CHECKSUM_UNNECESSARY; if (ch->protocol == CTC_PROTO_LINUX_TTY) ctc_tty_netif_rx(skb); else netif_rx_ni(skb); /** * Successful rx; reset logflags */ ch->logflags = 0; dev->last_rx = jiffies; privptr->stats.rx_packets++; privptr->stats.rx_bytes += skb->len; if (len > 0) { skb_pull(pskb, header->length); if (skb_tailroom(pskb) < LL_HEADER_LENGTH) { #ifndef DEBUG if (!(ch->logflags & LOG_FLAG_OVERRUN)) { #endif ctc_pr_warn( "%s Overrun in ctc_unpack_skb\n", dev->name); ch->logflags |= LOG_FLAG_OVERRUN; #ifndef DEBUG } #endif return; } skb_put(pskb, LL_HEADER_LENGTH); } } } /** * Check return code of a preceeding ccw_device call, halt_IO etc... * * @param ch The channel, the error belongs to. * @param return_code The error code to inspect. */ static void inline ccw_check_return_code(struct channel *ch, int return_code, char *msg) { DBF_TEXT(trace, 5, __FUNCTION__); switch (return_code) { case 0: fsm_event(ch->fsm, CH_EVENT_IO_SUCCESS, ch); break; case -EBUSY: ctc_pr_warn("%s (%s): Busy !\n", ch->id, msg); fsm_event(ch->fsm, CH_EVENT_IO_EBUSY, ch); break; case -ENODEV: ctc_pr_emerg("%s (%s): Invalid device called for IO\n", ch->id, msg); fsm_event(ch->fsm, CH_EVENT_IO_ENODEV, ch); break; case -EIO: ctc_pr_emerg("%s (%s): Status pending... \n", ch->id, msg); fsm_event(ch->fsm, CH_EVENT_IO_EIO, ch); break; default: ctc_pr_emerg("%s (%s): Unknown error in do_IO %04x\n", ch->id, msg, return_code); fsm_event(ch->fsm, CH_EVENT_IO_UNKNOWN, ch); } } /** * Check sense of a unit check. * * @param ch The channel, the sense code belongs to. * @param sense The sense code to inspect. */ static void inline ccw_unit_check(struct channel *ch, unsigned char sense) { DBF_TEXT(trace, 5, __FUNCTION__); if (sense & SNS0_INTERVENTION_REQ) { if (sense & 0x01) { if (ch->protocol != CTC_PROTO_LINUX_TTY) ctc_pr_debug("%s: Interface disc. or Sel. reset " "(remote)\n", ch->id); fsm_event(ch->fsm, CH_EVENT_UC_RCRESET, ch); } else { ctc_pr_debug("%s: System reset (remote)\n", ch->id); fsm_event(ch->fsm, CH_EVENT_UC_RSRESET, ch); } } else if (sense & SNS0_EQUIPMENT_CHECK) { if (sense & SNS0_BUS_OUT_CHECK) { ctc_pr_warn("%s: Hardware malfunction (remote)\n", ch->id); fsm_event(ch->fsm, CH_EVENT_UC_HWFAIL, ch); } else { ctc_pr_warn("%s: Read-data parity error (remote)\n", ch->id); fsm_event(ch->fsm, CH_EVENT_UC_RXPARITY, ch); } } else if (sense & SNS0_BUS_OUT_CHECK) { if (sense & 0x04) { ctc_pr_warn("%s: Data-streaming timeout)\n", ch->id); fsm_event(ch->fsm, CH_EVENT_UC_TXTIMEOUT, ch); } else { ctc_pr_warn("%s: Data-transfer parity error\n", ch->id); fsm_event(ch->fsm, CH_EVENT_UC_TXPARITY, ch); } } else if (sense & SNS0_CMD_REJECT) { ctc_pr_warn("%s: Command reject\n", ch->id); } else if (sense == 0) { ctc_pr_debug("%s: Unit check ZERO\n", ch->id); fsm_event(ch->fsm, CH_EVENT_UC_ZERO, ch); } else { ctc_pr_warn("%s: Unit Check with sense code: %02x\n", ch->id, sense); fsm_event(ch->fsm, CH_EVENT_UC_UNKNOWN, ch); } } static void ctc_purge_skb_queue(struct sk_buff_head *q) { struct sk_buff *skb; DBF_TEXT(trace, 5, __FUNCTION__); while ((skb = skb_dequeue(q))) { atomic_dec(&skb->users); dev_kfree_skb_irq(skb); } } static __inline__ int ctc_checkalloc_buffer(struct channel *ch, int warn) { DBF_TEXT(trace, 5, __FUNCTION__); if ((ch->trans_skb == NULL) || (ch->flags & CHANNEL_FLAGS_BUFSIZE_CHANGED)) { if (ch->trans_skb != NULL) dev_kfree_skb(ch->trans_skb); clear_normalized_cda(&ch->ccw[1]); ch->trans_skb = __dev_alloc_skb(ch->max_bufsize, GFP_ATOMIC | GFP_DMA); if (ch->trans_skb == NULL) { if (warn) ctc_pr_warn( "%s: Couldn't alloc %s trans_skb\n", ch->id, (CHANNEL_DIRECTION(ch->flags) == READ) ? "RX" : "TX"); return -ENOMEM; } ch->ccw[1].count = ch->max_bufsize; if (set_normalized_cda(&ch->ccw[1], ch->trans_skb->data)) { dev_kfree_skb(ch->trans_skb); ch->trans_skb = NULL; if (warn) ctc_pr_warn( "%s: set_normalized_cda for %s " "trans_skb failed, dropping packets\n", ch->id, (CHANNEL_DIRECTION(ch->flags) == READ) ? "RX" : "TX"); return -ENOMEM; } ch->ccw[1].count = 0; ch->trans_skb_data = ch->trans_skb->data; ch->flags &= ~CHANNEL_FLAGS_BUFSIZE_CHANGED; } return 0; } /** * Dummy NOP action for statemachines */ static void fsm_action_nop(fsm_instance * fi, int event, void *arg) { } /** * Actions for channel - statemachines. *****************************************************************************/ /** * Normal data has been send. Free the corresponding * skb (it's in io_queue), reset dev->tbusy and * revert to idle state. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_txdone(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; struct ctc_priv *privptr = dev->priv; struct sk_buff *skb; int first = 1; int i; unsigned long duration; struct timespec done_stamp = xtime; DBF_TEXT(trace, 4, __FUNCTION__); duration = (done_stamp.tv_sec - ch->prof.send_stamp.tv_sec) * 1000000 + (done_stamp.tv_nsec - ch->prof.send_stamp.tv_nsec) / 1000; if (duration > ch->prof.tx_time) ch->prof.tx_time = duration; if (ch->irb->scsw.count != 0) ctc_pr_debug("%s: TX not complete, remaining %d bytes\n", dev->name, ch->irb->scsw.count); fsm_deltimer(&ch->timer); while ((skb = skb_dequeue(&ch->io_queue))) { privptr->stats.tx_packets++; privptr->stats.tx_bytes += skb->len - LL_HEADER_LENGTH; if (first) { privptr->stats.tx_bytes += 2; first = 0; } atomic_dec(&skb->users); dev_kfree_skb_irq(skb); } spin_lock(&ch->collect_lock); clear_normalized_cda(&ch->ccw[4]); if (ch->collect_len > 0) { int rc; if (ctc_checkalloc_buffer(ch, 1)) { spin_unlock(&ch->collect_lock); return; } ch->trans_skb->tail = ch->trans_skb->data = ch->trans_skb_data; ch->trans_skb->len = 0; if (ch->prof.maxmulti < (ch->collect_len + 2)) ch->prof.maxmulti = ch->collect_len + 2; if (ch->prof.maxcqueue < skb_queue_len(&ch->collect_queue)) ch->prof.maxcqueue = skb_queue_len(&ch->collect_queue); *((__u16 *) skb_put(ch->trans_skb, 2)) = ch->collect_len + 2; i = 0; while ((skb = skb_dequeue(&ch->collect_queue))) { memcpy(skb_put(ch->trans_skb, skb->len), skb->data, skb->len); privptr->stats.tx_packets++; privptr->stats.tx_bytes += skb->len - LL_HEADER_LENGTH; atomic_dec(&skb->users); dev_kfree_skb_irq(skb); i++; } ch->collect_len = 0; spin_unlock(&ch->collect_lock); ch->ccw[1].count = ch->trans_skb->len; fsm_addtimer(&ch->timer, CTC_TIMEOUT_5SEC, CH_EVENT_TIMER, ch); ch->prof.send_stamp = xtime; rc = ccw_device_start(ch->cdev, &ch->ccw[0], (unsigned long) ch, 0xff, 0); ch->prof.doios_multi++; if (rc != 0) { privptr->stats.tx_dropped += i; privptr->stats.tx_errors += i; fsm_deltimer(&ch->timer); ccw_check_return_code(ch, rc, "chained TX"); } } else { spin_unlock(&ch->collect_lock); fsm_newstate(fi, CH_STATE_TXIDLE); } ctc_clear_busy(dev); } /** * Initial data is sent. * Notify device statemachine that we are up and * running. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_txidle(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; DBF_TEXT(trace, 4, __FUNCTION__); fsm_deltimer(&ch->timer); fsm_newstate(fi, CH_STATE_TXIDLE); fsm_event(((struct ctc_priv *) ch->netdev->priv)->fsm, DEV_EVENT_TXUP, ch->netdev); } /** * Got normal data, check for sanity, queue it up, allocate new buffer * trigger bottom half, and initiate next read. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_rx(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; struct ctc_priv *privptr = dev->priv; int len = ch->max_bufsize - ch->irb->scsw.count; struct sk_buff *skb = ch->trans_skb; __u16 block_len = *((__u16 *) skb->data); int check_len; int rc; DBF_TEXT(trace, 4, __FUNCTION__); fsm_deltimer(&ch->timer); if (len < 8) { ctc_pr_debug("%s: got packet with length %d < 8\n", dev->name, len); privptr->stats.rx_dropped++; privptr->stats.rx_length_errors++; goto again; } if (len > ch->max_bufsize) { ctc_pr_debug("%s: got packet with length %d > %d\n", dev->name, len, ch->max_bufsize); privptr->stats.rx_dropped++; privptr->stats.rx_length_errors++; goto again; } /** * VM TCP seems to have a bug sending 2 trailing bytes of garbage. */ switch (ch->protocol) { case CTC_PROTO_S390: case CTC_PROTO_OS390: check_len = block_len + 2; break; default: check_len = block_len; break; } if ((len < block_len) || (len > check_len)) { ctc_pr_debug("%s: got block length %d != rx length %d\n", dev->name, block_len, len); #ifdef DEBUG ctc_dump_skb(skb, 0); #endif *((__u16 *) skb->data) = len; privptr->stats.rx_dropped++; privptr->stats.rx_length_errors++; goto again; } block_len -= 2; if (block_len > 0) { *((__u16 *) skb->data) = block_len; ctc_unpack_skb(ch, skb); } again: skb->data = skb->tail = ch->trans_skb_data; skb->len = 0; if (ctc_checkalloc_buffer(ch, 1)) return; ch->ccw[1].count = ch->max_bufsize; rc = ccw_device_start(ch->cdev, &ch->ccw[0], (unsigned long) ch, 0xff, 0); if (rc != 0) ccw_check_return_code(ch, rc, "normal RX"); } static void ch_action_rxidle(fsm_instance * fi, int event, void *arg); /** * Initialize connection by sending a __u16 of value 0. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_firstio(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; int rc; DBF_TEXT(trace, 4, __FUNCTION__); if (fsm_getstate(fi) == CH_STATE_TXIDLE) ctc_pr_debug("%s: remote side issued READ?, init ...\n", ch->id); fsm_deltimer(&ch->timer); if (ctc_checkalloc_buffer(ch, 1)) return; if ((fsm_getstate(fi) == CH_STATE_SETUPWAIT) && (ch->protocol == CTC_PROTO_OS390)) { /* OS/390 resp. z/OS */ if (CHANNEL_DIRECTION(ch->flags) == READ) { *((__u16 *) ch->trans_skb->data) = CTC_INITIAL_BLOCKLEN; fsm_addtimer(&ch->timer, CTC_TIMEOUT_5SEC, CH_EVENT_TIMER, ch); ch_action_rxidle(fi, event, arg); } else { struct net_device *dev = ch->netdev; fsm_newstate(fi, CH_STATE_TXIDLE); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_TXUP, dev); } return; } /** * Don´t setup a timer for receiving the initial RX frame * if in compatibility mode, since VM TCP delays the initial * frame until it has some data to send. */ if ((CHANNEL_DIRECTION(ch->flags) == WRITE) || (ch->protocol != CTC_PROTO_S390)) fsm_addtimer(&ch->timer, CTC_TIMEOUT_5SEC, CH_EVENT_TIMER, ch); *((__u16 *) ch->trans_skb->data) = CTC_INITIAL_BLOCKLEN; ch->ccw[1].count = 2; /* Transfer only length */ fsm_newstate(fi, (CHANNEL_DIRECTION(ch->flags) == READ) ? CH_STATE_RXINIT : CH_STATE_TXINIT); rc = ccw_device_start(ch->cdev, &ch->ccw[0], (unsigned long) ch, 0xff, 0); if (rc != 0) { fsm_deltimer(&ch->timer); fsm_newstate(fi, CH_STATE_SETUPWAIT); ccw_check_return_code(ch, rc, "init IO"); } /** * If in compatibility mode since we don´t setup a timer, we * also signal RX channel up immediately. This enables us * to send packets early which in turn usually triggers some * reply from VM TCP which brings up the RX channel to it´s * final state. */ if ((CHANNEL_DIRECTION(ch->flags) == READ) && (ch->protocol == CTC_PROTO_S390)) { struct net_device *dev = ch->netdev; fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_RXUP, dev); } } /** * Got initial data, check it. If OK, * notify device statemachine that we are up and * running. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_rxidle(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; __u16 buflen; int rc; DBF_TEXT(trace, 4, __FUNCTION__); fsm_deltimer(&ch->timer); buflen = *((__u16 *) ch->trans_skb->data); #ifdef DEBUG ctc_pr_debug("%s: Initial RX count %d\n", dev->name, buflen); #endif if (buflen >= CTC_INITIAL_BLOCKLEN) { if (ctc_checkalloc_buffer(ch, 1)) return; ch->ccw[1].count = ch->max_bufsize; fsm_newstate(fi, CH_STATE_RXIDLE); rc = ccw_device_start(ch->cdev, &ch->ccw[0], (unsigned long) ch, 0xff, 0); if (rc != 0) { fsm_newstate(fi, CH_STATE_RXINIT); ccw_check_return_code(ch, rc, "initial RX"); } else fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_RXUP, dev); } else { ctc_pr_debug("%s: Initial RX count %d not %d\n", dev->name, buflen, CTC_INITIAL_BLOCKLEN); ch_action_firstio(fi, event, arg); } } /** * Set channel into extended mode. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_setmode(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; int rc; unsigned long saveflags; DBF_TEXT(trace, 4, __FUNCTION__); fsm_deltimer(&ch->timer); fsm_addtimer(&ch->timer, CTC_TIMEOUT_5SEC, CH_EVENT_TIMER, ch); fsm_newstate(fi, CH_STATE_SETUPWAIT); saveflags = 0; /* avoids compiler warning with spin_unlock_irqrestore */ if (event == CH_EVENT_TIMER) // only for timer not yet locked spin_lock_irqsave(get_ccwdev_lock(ch->cdev), saveflags); rc = ccw_device_start(ch->cdev, &ch->ccw[6], (unsigned long) ch, 0xff, 0); if (event == CH_EVENT_TIMER) spin_unlock_irqrestore(get_ccwdev_lock(ch->cdev), saveflags); if (rc != 0) { fsm_deltimer(&ch->timer); fsm_newstate(fi, CH_STATE_STARTWAIT); ccw_check_return_code(ch, rc, "set Mode"); } else ch->retry = 0; } /** * Setup channel. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_start(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; unsigned long saveflags; int rc; struct net_device *dev; DBF_TEXT(trace, 4, __FUNCTION__); if (ch == NULL) { ctc_pr_warn("ch_action_start ch=NULL\n"); return; } if (ch->netdev == NULL) { ctc_pr_warn("ch_action_start dev=NULL, id=%s\n", ch->id); return; } dev = ch->netdev; #ifdef DEBUG ctc_pr_debug("%s: %s channel start\n", dev->name, (CHANNEL_DIRECTION(ch->flags) == READ) ? "RX" : "TX"); #endif if (ch->trans_skb != NULL) { clear_normalized_cda(&ch->ccw[1]); dev_kfree_skb(ch->trans_skb); ch->trans_skb = NULL; } if (CHANNEL_DIRECTION(ch->flags) == READ) { ch->ccw[1].cmd_code = CCW_CMD_READ; ch->ccw[1].flags = CCW_FLAG_SLI; ch->ccw[1].count = 0; } else { ch->ccw[1].cmd_code = CCW_CMD_WRITE; ch->ccw[1].flags = CCW_FLAG_SLI | CCW_FLAG_CC; ch->ccw[1].count = 0; } if (ctc_checkalloc_buffer(ch, 0)) { ctc_pr_notice( "%s: Could not allocate %s trans_skb, delaying " "allocation until first transfer\n", dev->name, (CHANNEL_DIRECTION(ch->flags) == READ) ? "RX" : "TX"); } ch->ccw[0].cmd_code = CCW_CMD_PREPARE; ch->ccw[0].flags = CCW_FLAG_SLI | CCW_FLAG_CC; ch->ccw[0].count = 0; ch->ccw[0].cda = 0; ch->ccw[2].cmd_code = CCW_CMD_NOOP; /* jointed CE + DE */ ch->ccw[2].flags = CCW_FLAG_SLI; ch->ccw[2].count = 0; ch->ccw[2].cda = 0; memcpy(&ch->ccw[3], &ch->ccw[0], sizeof (struct ccw1) * 3); ch->ccw[4].cda = 0; ch->ccw[4].flags &= ~CCW_FLAG_IDA; fsm_newstate(fi, CH_STATE_STARTWAIT); fsm_addtimer(&ch->timer, 1000, CH_EVENT_TIMER, ch); spin_lock_irqsave(get_ccwdev_lock(ch->cdev), saveflags); rc = ccw_device_halt(ch->cdev, (unsigned long) ch); spin_unlock_irqrestore(get_ccwdev_lock(ch->cdev), saveflags); if (rc != 0) { if (rc != -EBUSY) fsm_deltimer(&ch->timer); ccw_check_return_code(ch, rc, "initial HaltIO"); } #ifdef DEBUG ctc_pr_debug("ctc: %s(): leaving\n", __func__); #endif } /** * Shutdown a channel. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_haltio(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; unsigned long saveflags; int rc; int oldstate; DBF_TEXT(trace, 3, __FUNCTION__); fsm_deltimer(&ch->timer); fsm_addtimer(&ch->timer, CTC_TIMEOUT_5SEC, CH_EVENT_TIMER, ch); saveflags = 0; /* avoids comp warning with spin_unlock_irqrestore */ if (event == CH_EVENT_STOP) // only for STOP not yet locked spin_lock_irqsave(get_ccwdev_lock(ch->cdev), saveflags); oldstate = fsm_getstate(fi); fsm_newstate(fi, CH_STATE_TERM); rc = ccw_device_halt(ch->cdev, (unsigned long) ch); if (event == CH_EVENT_STOP) spin_unlock_irqrestore(get_ccwdev_lock(ch->cdev), saveflags); if (rc != 0) { if (rc != -EBUSY) { fsm_deltimer(&ch->timer); fsm_newstate(fi, oldstate); } ccw_check_return_code(ch, rc, "HaltIO in ch_action_haltio"); } } /** * A channel has successfully been halted. * Cleanup it's queue and notify interface statemachine. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_stopped(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; DBF_TEXT(trace, 3, __FUNCTION__); fsm_deltimer(&ch->timer); fsm_newstate(fi, CH_STATE_STOPPED); if (ch->trans_skb != NULL) { clear_normalized_cda(&ch->ccw[1]); dev_kfree_skb(ch->trans_skb); ch->trans_skb = NULL; } if (CHANNEL_DIRECTION(ch->flags) == READ) { skb_queue_purge(&ch->io_queue); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_RXDOWN, dev); } else { ctc_purge_skb_queue(&ch->io_queue); spin_lock(&ch->collect_lock); ctc_purge_skb_queue(&ch->collect_queue); ch->collect_len = 0; spin_unlock(&ch->collect_lock); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_TXDOWN, dev); } } /** * A stop command from device statemachine arrived and we are in * not operational mode. Set state to stopped. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_stop(fsm_instance * fi, int event, void *arg) { fsm_newstate(fi, CH_STATE_STOPPED); } /** * A machine check for no path, not operational status or gone device has * happened. * Cleanup queue and notify interface statemachine. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_fail(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; DBF_TEXT(trace, 3, __FUNCTION__); fsm_deltimer(&ch->timer); fsm_newstate(fi, CH_STATE_NOTOP); if (CHANNEL_DIRECTION(ch->flags) == READ) { skb_queue_purge(&ch->io_queue); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_RXDOWN, dev); } else { ctc_purge_skb_queue(&ch->io_queue); spin_lock(&ch->collect_lock); ctc_purge_skb_queue(&ch->collect_queue); ch->collect_len = 0; spin_unlock(&ch->collect_lock); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_TXDOWN, dev); } } /** * Handle error during setup of channel. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_setuperr(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; DBF_TEXT(setup, 3, __FUNCTION__); /** * Special case: Got UC_RCRESET on setmode. * This means that remote side isn't setup. In this case * simply retry after some 10 secs... */ if ((fsm_getstate(fi) == CH_STATE_SETUPWAIT) && ((event == CH_EVENT_UC_RCRESET) || (event == CH_EVENT_UC_RSRESET))) { fsm_newstate(fi, CH_STATE_STARTRETRY); fsm_deltimer(&ch->timer); fsm_addtimer(&ch->timer, CTC_TIMEOUT_5SEC, CH_EVENT_TIMER, ch); if (CHANNEL_DIRECTION(ch->flags) == READ) { int rc = ccw_device_halt(ch->cdev, (unsigned long) ch); if (rc != 0) ccw_check_return_code( ch, rc, "HaltIO in ch_action_setuperr"); } return; } ctc_pr_debug("%s: Error %s during %s channel setup state=%s\n", dev->name, ch_event_names[event], (CHANNEL_DIRECTION(ch->flags) == READ) ? "RX" : "TX", fsm_getstate_str(fi)); if (CHANNEL_DIRECTION(ch->flags) == READ) { fsm_newstate(fi, CH_STATE_RXERR); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_RXDOWN, dev); } else { fsm_newstate(fi, CH_STATE_TXERR); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_TXDOWN, dev); } } /** * Restart a channel after an error. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_restart(fsm_instance * fi, int event, void *arg) { unsigned long saveflags; int oldstate; int rc; struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; DBF_TEXT(trace, 3, __FUNCTION__); fsm_deltimer(&ch->timer); ctc_pr_debug("%s: %s channel restart\n", dev->name, (CHANNEL_DIRECTION(ch->flags) == READ) ? "RX" : "TX"); fsm_addtimer(&ch->timer, CTC_TIMEOUT_5SEC, CH_EVENT_TIMER, ch); oldstate = fsm_getstate(fi); fsm_newstate(fi, CH_STATE_STARTWAIT); saveflags = 0; /* avoids compiler warning with spin_unlock_irqrestore */ if (event == CH_EVENT_TIMER) // only for timer not yet locked spin_lock_irqsave(get_ccwdev_lock(ch->cdev), saveflags); rc = ccw_device_halt(ch->cdev, (unsigned long) ch); if (event == CH_EVENT_TIMER) spin_unlock_irqrestore(get_ccwdev_lock(ch->cdev), saveflags); if (rc != 0) { if (rc != -EBUSY) { fsm_deltimer(&ch->timer); fsm_newstate(fi, oldstate); } ccw_check_return_code(ch, rc, "HaltIO in ch_action_restart"); } } /** * Handle error during RX initial handshake (exchange of * 0-length block header) * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_rxiniterr(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; DBF_TEXT(setup, 3, __FUNCTION__); if (event == CH_EVENT_TIMER) { fsm_deltimer(&ch->timer); ctc_pr_debug("%s: Timeout during RX init handshake\n", dev->name); if (ch->retry++ < 3) ch_action_restart(fi, event, arg); else { fsm_newstate(fi, CH_STATE_RXERR); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_RXDOWN, dev); } } else ctc_pr_warn("%s: Error during RX init handshake\n", dev->name); } /** * Notify device statemachine if we gave up initialization * of RX channel. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_rxinitfail(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; DBF_TEXT(setup, 3, __FUNCTION__); fsm_newstate(fi, CH_STATE_RXERR); ctc_pr_warn("%s: RX initialization failed\n", dev->name); ctc_pr_warn("%s: RX <-> RX connection detected\n", dev->name); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_RXDOWN, dev); } /** * Handle RX Unit check remote reset (remote disconnected) * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_rxdisc(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct channel *ch2; struct net_device *dev = ch->netdev; DBF_TEXT(trace, 3, __FUNCTION__); fsm_deltimer(&ch->timer); ctc_pr_debug("%s: Got remote disconnect, re-initializing ...\n", dev->name); /** * Notify device statemachine */ fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_RXDOWN, dev); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_TXDOWN, dev); fsm_newstate(fi, CH_STATE_DTERM); ch2 = ((struct ctc_priv *) dev->priv)->channel[WRITE]; fsm_newstate(ch2->fsm, CH_STATE_DTERM); ccw_device_halt(ch->cdev, (unsigned long) ch); ccw_device_halt(ch2->cdev, (unsigned long) ch2); } /** * Handle error during TX channel initialization. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_txiniterr(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; DBF_TEXT(setup, 2, __FUNCTION__); if (event == CH_EVENT_TIMER) { fsm_deltimer(&ch->timer); ctc_pr_debug("%s: Timeout during TX init handshake\n", dev->name); if (ch->retry++ < 3) ch_action_restart(fi, event, arg); else { fsm_newstate(fi, CH_STATE_TXERR); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_TXDOWN, dev); } } else ctc_pr_warn("%s: Error during TX init handshake\n", dev->name); } /** * Handle TX timeout by retrying operation. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_txretry(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; unsigned long saveflags; DBF_TEXT(trace, 4, __FUNCTION__); fsm_deltimer(&ch->timer); if (ch->retry++ > 3) { ctc_pr_debug("%s: TX retry failed, restarting channel\n", dev->name); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_TXDOWN, dev); ch_action_restart(fi, event, arg); } else { struct sk_buff *skb; ctc_pr_debug("%s: TX retry %d\n", dev->name, ch->retry); if ((skb = skb_peek(&ch->io_queue))) { int rc = 0; clear_normalized_cda(&ch->ccw[4]); ch->ccw[4].count = skb->len; if (set_normalized_cda(&ch->ccw[4], skb->data)) { ctc_pr_debug( "%s: IDAL alloc failed, chan restart\n", dev->name); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_TXDOWN, dev); ch_action_restart(fi, event, arg); return; } fsm_addtimer(&ch->timer, 1000, CH_EVENT_TIMER, ch); saveflags = 0; /* avoids compiler warning with spin_unlock_irqrestore */ if (event == CH_EVENT_TIMER) // only for TIMER not yet locked spin_lock_irqsave(get_ccwdev_lock(ch->cdev), saveflags); rc = ccw_device_start(ch->cdev, &ch->ccw[3], (unsigned long) ch, 0xff, 0); if (event == CH_EVENT_TIMER) spin_unlock_irqrestore(get_ccwdev_lock(ch->cdev), saveflags); if (rc != 0) { fsm_deltimer(&ch->timer); ccw_check_return_code(ch, rc, "TX in ch_action_txretry"); ctc_purge_skb_queue(&ch->io_queue); } } } } /** * Handle fatal errors during an I/O command. * * @param fi An instance of a channel statemachine. * @param event The event, just happened. * @param arg Generic pointer, casted from channel * upon call. */ static void ch_action_iofatal(fsm_instance * fi, int event, void *arg) { struct channel *ch = (struct channel *) arg; struct net_device *dev = ch->netdev; DBF_TEXT(trace, 3, __FUNCTION__); fsm_deltimer(&ch->timer); if (CHANNEL_DIRECTION(ch->flags) == READ) { ctc_pr_debug("%s: RX I/O error\n", dev->name); fsm_newstate(fi, CH_STATE_RXERR); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_RXDOWN, dev); } else { ctc_pr_debug("%s: TX I/O error\n", dev->name); fsm_newstate(fi, CH_STATE_TXERR); fsm_event(((struct ctc_priv *) dev->priv)->fsm, DEV_EVENT_TXDOWN, dev); } } static void ch_action_reinit(fsm_instance *fi, int event, void *arg) { struct channel *ch = (struct channel *)arg; struct net_device *dev = ch->netdev; struct ctc_priv *privptr = dev->priv; DBF_TEXT(trace, 4, __FUNCTION__); ch_action_iofatal(fi, event, arg); fsm_addtimer(&privptr->restart_timer, 1000, DEV_EVENT_RESTART, dev); } /** * The statemachine for a channel. */ static const fsm_node ch_fsm[] = { {CH_STATE_STOPPED, CH_EVENT_STOP, fsm_action_nop }, {CH_STATE_STOPPED, CH_EVENT_START, ch_action_start }, {CH_STATE_STOPPED, CH_EVENT_FINSTAT, fsm_action_nop }, {CH_STATE_STOPPED, CH_EVENT_MC_FAIL, fsm_action_nop }, {CH_STATE_NOTOP, CH_EVENT_STOP, ch_action_stop }, {CH_STATE_NOTOP, CH_EVENT_START, fsm_action_nop }, {CH_STATE_NOTOP, CH_EVENT_FINSTAT, fsm_action_nop }, {CH_STATE_NOTOP, CH_EVENT_MC_FAIL, fsm_action_nop }, {CH_STATE_NOTOP, CH_EVENT_MC_GOOD, ch_action_start }, {CH_STATE_STARTWAIT, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_STARTWAIT, CH_EVENT_START, fsm_action_nop }, {CH_STATE_STARTWAIT, CH_EVENT_FINSTAT, ch_action_setmode }, {CH_STATE_STARTWAIT, CH_EVENT_TIMER, ch_action_setuperr }, {CH_STATE_STARTWAIT, CH_EVENT_IO_ENODEV, ch_action_iofatal }, {CH_STATE_STARTWAIT, CH_EVENT_IO_EIO, ch_action_reinit }, {CH_STATE_STARTWAIT, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_STARTRETRY, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_STARTRETRY, CH_EVENT_TIMER, ch_action_setmode }, {CH_STATE_STARTRETRY, CH_EVENT_FINSTAT, fsm_action_nop }, {CH_STATE_STARTRETRY, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_SETUPWAIT, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_SETUPWAIT, CH_EVENT_START, fsm_action_nop }, {CH_STATE_SETUPWAIT, CH_EVENT_FINSTAT, ch_action_firstio }, {CH_STATE_SETUPWAIT, CH_EVENT_UC_RCRESET, ch_action_setuperr }, {CH_STATE_SETUPWAIT, CH_EVENT_UC_RSRESET, ch_action_setuperr }, {CH_STATE_SETUPWAIT, CH_EVENT_TIMER, ch_action_setmode }, {CH_STATE_SETUPWAIT, CH_EVENT_IO_ENODEV, ch_action_iofatal }, {CH_STATE_SETUPWAIT, CH_EVENT_IO_EIO, ch_action_reinit }, {CH_STATE_SETUPWAIT, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_RXINIT, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_RXINIT, CH_EVENT_START, fsm_action_nop }, {CH_STATE_RXINIT, CH_EVENT_FINSTAT, ch_action_rxidle }, {CH_STATE_RXINIT, CH_EVENT_UC_RCRESET, ch_action_rxiniterr }, {CH_STATE_RXINIT, CH_EVENT_UC_RSRESET, ch_action_rxiniterr }, {CH_STATE_RXINIT, CH_EVENT_TIMER, ch_action_rxiniterr }, {CH_STATE_RXINIT, CH_EVENT_ATTNBUSY, ch_action_rxinitfail }, {CH_STATE_RXINIT, CH_EVENT_IO_ENODEV, ch_action_iofatal }, {CH_STATE_RXINIT, CH_EVENT_IO_EIO, ch_action_reinit }, {CH_STATE_RXINIT, CH_EVENT_UC_ZERO, ch_action_firstio }, {CH_STATE_RXINIT, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_RXIDLE, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_RXIDLE, CH_EVENT_START, fsm_action_nop }, {CH_STATE_RXIDLE, CH_EVENT_FINSTAT, ch_action_rx }, {CH_STATE_RXIDLE, CH_EVENT_UC_RCRESET, ch_action_rxdisc }, // {CH_STATE_RXIDLE, CH_EVENT_UC_RSRESET, ch_action_rxretry }, {CH_STATE_RXIDLE, CH_EVENT_IO_ENODEV, ch_action_iofatal }, {CH_STATE_RXIDLE, CH_EVENT_IO_EIO, ch_action_reinit }, {CH_STATE_RXIDLE, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_RXIDLE, CH_EVENT_UC_ZERO, ch_action_rx }, {CH_STATE_TXINIT, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_TXINIT, CH_EVENT_START, fsm_action_nop }, {CH_STATE_TXINIT, CH_EVENT_FINSTAT, ch_action_txidle }, {CH_STATE_TXINIT, CH_EVENT_UC_RCRESET, ch_action_txiniterr }, {CH_STATE_TXINIT, CH_EVENT_UC_RSRESET, ch_action_txiniterr }, {CH_STATE_TXINIT, CH_EVENT_TIMER, ch_action_txiniterr }, {CH_STATE_TXINIT, CH_EVENT_IO_ENODEV, ch_action_iofatal }, {CH_STATE_TXINIT, CH_EVENT_IO_EIO, ch_action_reinit }, {CH_STATE_TXINIT, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_TXIDLE, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_TXIDLE, CH_EVENT_START, fsm_action_nop }, {CH_STATE_TXIDLE, CH_EVENT_FINSTAT, ch_action_firstio }, {CH_STATE_TXIDLE, CH_EVENT_UC_RCRESET, fsm_action_nop }, {CH_STATE_TXIDLE, CH_EVENT_UC_RSRESET, fsm_action_nop }, {CH_STATE_TXIDLE, CH_EVENT_IO_ENODEV, ch_action_iofatal }, {CH_STATE_TXIDLE, CH_EVENT_IO_EIO, ch_action_reinit }, {CH_STATE_TXIDLE, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_TERM, CH_EVENT_STOP, fsm_action_nop }, {CH_STATE_TERM, CH_EVENT_START, ch_action_restart }, {CH_STATE_TERM, CH_EVENT_FINSTAT, ch_action_stopped }, {CH_STATE_TERM, CH_EVENT_UC_RCRESET, fsm_action_nop }, {CH_STATE_TERM, CH_EVENT_UC_RSRESET, fsm_action_nop }, {CH_STATE_TERM, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_DTERM, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_DTERM, CH_EVENT_START, ch_action_restart }, {CH_STATE_DTERM, CH_EVENT_FINSTAT, ch_action_setmode }, {CH_STATE_DTERM, CH_EVENT_UC_RCRESET, fsm_action_nop }, {CH_STATE_DTERM, CH_EVENT_UC_RSRESET, fsm_action_nop }, {CH_STATE_DTERM, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_TX, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_TX, CH_EVENT_START, fsm_action_nop }, {CH_STATE_TX, CH_EVENT_FINSTAT, ch_action_txdone }, {CH_STATE_TX, CH_EVENT_UC_RCRESET, ch_action_txretry }, {CH_STATE_TX, CH_EVENT_UC_RSRESET, ch_action_txretry }, {CH_STATE_TX, CH_EVENT_TIMER, ch_action_txretry }, {CH_STATE_TX, CH_EVENT_IO_ENODEV, ch_action_iofatal }, {CH_STATE_TX, CH_EVENT_IO_EIO, ch_action_reinit }, {CH_STATE_TX, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_RXERR, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_TXERR, CH_EVENT_STOP, ch_action_haltio }, {CH_STATE_TXERR, CH_EVENT_MC_FAIL, ch_action_fail }, {CH_STATE_RXERR, CH_EVENT_MC_FAIL, ch_action_fail }, }; static const int CH_FSM_LEN = sizeof (ch_fsm) / sizeof (fsm_node); /** * Functions related to setup and device detection. *****************************************************************************/ static inline int less_than(char *id1, char *id2) { int dev1, dev2, i; for (i = 0; i < 5; i++) { id1++; id2++; } dev1 = simple_strtoul(id1, &id1, 16); dev2 = simple_strtoul(id2, &id2, 16); return (dev1 < dev2); } /** * Add a new channel to the list of channels. * Keeps the channel list sorted. * * @param cdev The ccw_device to be added. * @param type The type class of the new channel. * * @return 0 on success, !0 on error. */ static int add_channel(struct ccw_device *cdev, enum channel_types type) { struct channel **c = &channels; struct channel *ch; DBF_TEXT(trace, 2, __FUNCTION__); if ((ch = (struct channel *) kmalloc(sizeof (struct channel), GFP_KERNEL)) == NULL) { ctc_pr_warn("ctc: Out of memory in add_channel\n"); return -1; } memset(ch, 0, sizeof (struct channel)); if ((ch->ccw = (struct ccw1 *) kmalloc(8*sizeof(struct ccw1), GFP_KERNEL | GFP_DMA)) == NULL) { kfree(ch); ctc_pr_warn("ctc: Out of memory in add_channel\n"); return -1; } memset(ch->ccw, 0, 8*sizeof(struct ccw1)); // assure all flags and counters are reset /** * "static" ccws are used in the following way: * * ccw[0..2] (Channel program for generic I/O): * 0: prepare * 1: read or write (depending on direction) with fixed * buffer (idal allocated once when buffer is allocated) * 2: nop * ccw[3..5] (Channel program for direct write of packets) * 3: prepare * 4: write (idal allocated on every write). * 5: nop * ccw[6..7] (Channel program for initial channel setup): * 6: set extended mode * 7: nop * * ch->ccw[0..5] are initialized in ch_action_start because * the channel's direction is yet unknown here. */ ch->ccw[6].cmd_code = CCW_CMD_SET_EXTENDED; ch->ccw[6].flags = CCW_FLAG_SLI; ch->ccw[7].cmd_code = CCW_CMD_NOOP; ch->ccw[7].flags = CCW_FLAG_SLI; ch->cdev = cdev; snprintf(ch->id, CTC_ID_SIZE, "ch-%s", cdev->dev.bus_id); ch->type = type; loglevel = CTC_LOGLEVEL_DEFAULT; ch->fsm = init_fsm(ch->id, ch_state_names, ch_event_names, NR_CH_STATES, NR_CH_EVENTS, ch_fsm, CH_FSM_LEN, GFP_KERNEL); if (ch->fsm == NULL) { ctc_pr_warn("ctc: Could not create FSM in add_channel\n"); kfree(ch->ccw); kfree(ch); return -1; } fsm_newstate(ch->fsm, CH_STATE_IDLE); if ((ch->irb = (struct irb *) kmalloc(sizeof (struct irb), GFP_KERNEL)) == NULL) { ctc_pr_warn("ctc: Out of memory in add_channel\n"); kfree_fsm(ch->fsm); kfree(ch->ccw); kfree(ch); return -1; } memset(ch->irb, 0, sizeof (struct irb)); while (*c && less_than((*c)->id, ch->id)) c = &(*c)->next; if (*c && (!strncmp((*c)->id, ch->id, CTC_ID_SIZE))) { ctc_pr_debug( "ctc: add_channel: device %s already in list, " "using old entry\n", (*c)->id); kfree(ch->irb); kfree_fsm(ch->fsm); kfree(ch->ccw); kfree(ch); return 0; } fsm_settimer(ch->fsm, &ch->timer); skb_queue_head_init(&ch->io_queue); skb_queue_head_init(&ch->collect_queue); ch->next = *c; *c = ch; return 0; } /** * Release a specific channel in the channel list. * * @param ch Pointer to channel struct to be released. */ static void channel_free(struct channel *ch) { ch->flags &= ~CHANNEL_FLAGS_INUSE; fsm_newstate(ch->fsm, CH_STATE_IDLE); } /** * Remove a specific channel in the channel list. * * @param ch Pointer to channel struct to be released. */ static void channel_remove(struct channel *ch) { struct channel **c = &channels; DBF_TEXT(trace, 2, __FUNCTION__); if (ch == NULL) return; channel_free(ch); while (*c) { if (*c == ch) { *c = ch->next; fsm_deltimer(&ch->timer); kfree_fsm(ch->fsm); clear_normalized_cda(&ch->ccw[4]); if (ch->trans_skb != NULL) { clear_normalized_cda(&ch->ccw[1]); dev_kfree_skb(ch->trans_skb); } kfree(ch->ccw); kfree(ch->irb); kfree(ch); return; } c = &((*c)->next); } } /** * Get a specific channel from the channel list. * * @param type Type of channel we are interested in. * @param id Id of channel we are interested in. * @param direction Direction we want to use this channel for. * * @return Pointer to a channel or NULL if no matching channel available. */ static struct channel * channel_get(enum channel_types type, char *id, int direction) { struct channel *ch = channels; DBF_TEXT(trace, 3, __FUNCTION__); #ifdef DEBUG ctc_pr_debug("ctc: %s(): searching for ch with id %s and type %d\n", __func__, id, type); #endif