2 ** -----------------------------------------------------------------------------
4 ** Perle Specialix driver for Linux
5 ** ported from the existing SCO driver source
8 * (C) 1990 - 2000 Specialix International Ltd., Byfleet, Surrey, UK.
10 * This program is free software; you can redistribute it and/or modify
11 * it under the terms of the GNU General Public License as published by
12 * the Free Software Foundation; either version 2 of the License, or
13 * (at your option) any later version.
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
20 * You should have received a copy of the GNU General Public License
21 * along with this program; if not, write to the Free Software
22 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
26 ** Last Modified : 11/6/98 10:33:41
27 ** Retrieved : 11/6/98 10:33:49
29 ** ident @(#)riocmd.c 1.2
31 ** -----------------------------------------------------------------------------
34 static char *_riocmd_c_sccs_
= "@(#)riocmd.c 1.2";
37 #include <linux/module.h>
38 #include <linux/slab.h>
39 #include <linux/errno.h>
40 #include <linux/tty.h>
42 #include <asm/system.h>
43 #include <asm/string.h>
44 #include <asm/semaphore.h>
46 #include <linux/termios.h>
47 #include <linux/serial.h>
49 #include <linux/generic_serial.h>
51 #include "linux_compat.h"
52 #include "rio_linux.h"
83 static struct IdentifyRta IdRta
;
84 static struct KillNeighbour KillUnit
;
86 int RIOFoadRta(struct Host
*HostP
, struct Map
*MapP
)
88 struct CmdBlk
*CmdBlkP
;
90 rio_dprintk(RIO_DEBUG_CMD
, "FOAD RTA\n");
92 CmdBlkP
= RIOGetCmdBlk();
95 rio_dprintk(RIO_DEBUG_CMD
, "FOAD RTA: GetCmdBlk failed\n");
99 CmdBlkP
->Packet
.dest_unit
= MapP
->ID
;
100 CmdBlkP
->Packet
.dest_port
= BOOT_RUP
;
101 CmdBlkP
->Packet
.src_unit
= 0;
102 CmdBlkP
->Packet
.src_port
= BOOT_RUP
;
103 CmdBlkP
->Packet
.len
= 0x84;
104 CmdBlkP
->Packet
.data
[0] = IFOAD
;
105 CmdBlkP
->Packet
.data
[1] = 0;
106 CmdBlkP
->Packet
.data
[2] = IFOAD_MAGIC
& 0xFF;
107 CmdBlkP
->Packet
.data
[3] = (IFOAD_MAGIC
>> 8) & 0xFF;
109 if (RIOQueueCmdBlk(HostP
, MapP
->ID
- 1, CmdBlkP
) == RIO_FAIL
) {
110 rio_dprintk(RIO_DEBUG_CMD
, "FOAD RTA: Failed to queue foad command\n");
116 int RIOZombieRta(struct Host
*HostP
, struct Map
*MapP
)
118 struct CmdBlk
*CmdBlkP
;
120 rio_dprintk(RIO_DEBUG_CMD
, "ZOMBIE RTA\n");
122 CmdBlkP
= RIOGetCmdBlk();
125 rio_dprintk(RIO_DEBUG_CMD
, "ZOMBIE RTA: GetCmdBlk failed\n");
129 CmdBlkP
->Packet
.dest_unit
= MapP
->ID
;
130 CmdBlkP
->Packet
.dest_port
= BOOT_RUP
;
131 CmdBlkP
->Packet
.src_unit
= 0;
132 CmdBlkP
->Packet
.src_port
= BOOT_RUP
;
133 CmdBlkP
->Packet
.len
= 0x84;
134 CmdBlkP
->Packet
.data
[0] = ZOMBIE
;
135 CmdBlkP
->Packet
.data
[1] = 0;
136 CmdBlkP
->Packet
.data
[2] = ZOMBIE_MAGIC
& 0xFF;
137 CmdBlkP
->Packet
.data
[3] = (ZOMBIE_MAGIC
>> 8) & 0xFF;
139 if (RIOQueueCmdBlk(HostP
, MapP
->ID
- 1, CmdBlkP
) == RIO_FAIL
) {
140 rio_dprintk(RIO_DEBUG_CMD
, "ZOMBIE RTA: Failed to queue zombie command\n");
146 int RIOCommandRta(struct rio_info
*p
, uint RtaUnique
, int (*func
) (struct Host
* HostP
, struct Map
* MapP
))
150 rio_dprintk(RIO_DEBUG_CMD
, "Command RTA 0x%x func 0x%x\n", RtaUnique
, (int) func
);
155 for (Host
= 0; Host
< p
->RIONumHosts
; Host
++) {
157 struct Host
*HostP
= &p
->RIOHosts
[Host
];
159 for (Rta
= 0; Rta
< RTAS_PER_HOST
; Rta
++) {
160 struct Map
*MapP
= &HostP
->Mapping
[Rta
];
162 if (MapP
->RtaUniqueNum
== RtaUnique
) {
166 ** now, lets just check we have a route to it...
167 ** IF the routing stuff is working, then one of the
168 ** topology entries for this unit will have a legit
169 ** route *somewhere*. We care not where - if its got
170 ** any connections, we can get to it.
172 for (Link
= 0; Link
< LINKS_PER_UNIT
; Link
++) {
173 if (MapP
->Topology
[Link
].Unit
<= (uchar
) MAX_RUP
) {
175 ** Its worth trying the operation...
177 return (*func
) (HostP
, MapP
);
187 int RIOIdentifyRta(struct rio_info
*p
, caddr_t arg
)
191 if (copyin((int) arg
, (caddr_t
) & IdRta
, sizeof(IdRta
)) == COPYFAIL
) {
192 rio_dprintk(RIO_DEBUG_CMD
, "RIO_IDENTIFY_RTA copy failed\n");
193 p
->RIOError
.Error
= COPYIN_FAILED
;
197 for (Host
= 0; Host
< p
->RIONumHosts
; Host
++) {
199 struct Host
*HostP
= &p
->RIOHosts
[Host
];
201 for (Rta
= 0; Rta
< RTAS_PER_HOST
; Rta
++) {
202 struct Map
*MapP
= &HostP
->Mapping
[Rta
];
204 if (MapP
->RtaUniqueNum
== IdRta
.RtaUnique
) {
207 ** now, lets just check we have a route to it...
208 ** IF the routing stuff is working, then one of the
209 ** topology entries for this unit will have a legit
210 ** route *somewhere*. We care not where - if its got
211 ** any connections, we can get to it.
213 for (Link
= 0; Link
< LINKS_PER_UNIT
; Link
++) {
214 if (MapP
->Topology
[Link
].Unit
<= (uchar
) MAX_RUP
) {
216 ** Its worth trying the operation...
218 struct CmdBlk
*CmdBlkP
;
220 rio_dprintk(RIO_DEBUG_CMD
, "IDENTIFY RTA\n");
222 CmdBlkP
= RIOGetCmdBlk();
225 rio_dprintk(RIO_DEBUG_CMD
, "IDENTIFY RTA: GetCmdBlk failed\n");
229 CmdBlkP
->Packet
.dest_unit
= MapP
->ID
;
230 CmdBlkP
->Packet
.dest_port
= BOOT_RUP
;
231 CmdBlkP
->Packet
.src_unit
= 0;
232 CmdBlkP
->Packet
.src_port
= BOOT_RUP
;
233 CmdBlkP
->Packet
.len
= 0x84;
234 CmdBlkP
->Packet
.data
[0] = IDENTIFY
;
235 CmdBlkP
->Packet
.data
[1] = 0;
236 CmdBlkP
->Packet
.data
[2] = IdRta
.ID
;
238 if (RIOQueueCmdBlk(HostP
, MapP
->ID
- 1, CmdBlkP
) == RIO_FAIL
) {
239 rio_dprintk(RIO_DEBUG_CMD
, "IDENTIFY RTA: Failed to queue command\n");
252 int RIOKillNeighbour(struct rio_info
*p
, caddr_t arg
)
257 struct CmdBlk
*CmdBlkP
;
259 rio_dprintk(RIO_DEBUG_CMD
, "KILL HOST NEIGHBOUR\n");
261 if (copyin((int) arg
, (caddr_t
) & KillUnit
, sizeof(KillUnit
)) == COPYFAIL
) {
262 rio_dprintk(RIO_DEBUG_CMD
, "RIO_KILL_NEIGHBOUR copy failed\n");
263 p
->RIOError
.Error
= COPYIN_FAILED
;
267 if (KillUnit
.Link
> 3)
270 CmdBlkP
= RIOGetCmdBlk();
273 rio_dprintk(RIO_DEBUG_CMD
, "UFOAD: GetCmdBlk failed\n");
277 CmdBlkP
->Packet
.dest_unit
= 0;
278 CmdBlkP
->Packet
.src_unit
= 0;
279 CmdBlkP
->Packet
.dest_port
= BOOT_RUP
;
280 CmdBlkP
->Packet
.src_port
= BOOT_RUP
;
281 CmdBlkP
->Packet
.len
= 0x84;
282 CmdBlkP
->Packet
.data
[0] = UFOAD
;
283 CmdBlkP
->Packet
.data
[1] = KillUnit
.Link
;
284 CmdBlkP
->Packet
.data
[2] = UFOAD_MAGIC
& 0xFF;
285 CmdBlkP
->Packet
.data
[3] = (UFOAD_MAGIC
>> 8) & 0xFF;
287 for (Host
= 0; Host
< p
->RIONumHosts
; Host
++) {
289 HostP
= &p
->RIOHosts
[Host
];
291 if (HostP
->UniqueNum
== KillUnit
.UniqueNum
) {
292 if (RIOQueueCmdBlk(HostP
, RTAS_PER_HOST
+ KillUnit
.Link
, CmdBlkP
) == RIO_FAIL
) {
293 rio_dprintk(RIO_DEBUG_CMD
, "UFOAD: Failed queue command\n");
299 for (ID
= 0; ID
< RTAS_PER_HOST
; ID
++) {
300 if (HostP
->Mapping
[ID
].RtaUniqueNum
== KillUnit
.UniqueNum
) {
301 CmdBlkP
->Packet
.dest_unit
= ID
+ 1;
302 if (RIOQueueCmdBlk(HostP
, ID
, CmdBlkP
) == RIO_FAIL
) {
303 rio_dprintk(RIO_DEBUG_CMD
, "UFOAD: Failed queue command\n");
310 RIOFreeCmdBlk(CmdBlkP
);
314 int RIOSuspendBootRta(struct Host
*HostP
, int ID
, int Link
)
316 struct CmdBlk
*CmdBlkP
;
318 rio_dprintk(RIO_DEBUG_CMD
, "SUSPEND BOOT ON RTA ID %d, link %c\n", ID
, 'A' + Link
);
320 CmdBlkP
= RIOGetCmdBlk();
323 rio_dprintk(RIO_DEBUG_CMD
, "SUSPEND BOOT ON RTA: GetCmdBlk failed\n");
327 CmdBlkP
->Packet
.dest_unit
= ID
;
328 CmdBlkP
->Packet
.dest_port
= BOOT_RUP
;
329 CmdBlkP
->Packet
.src_unit
= 0;
330 CmdBlkP
->Packet
.src_port
= BOOT_RUP
;
331 CmdBlkP
->Packet
.len
= 0x84;
332 CmdBlkP
->Packet
.data
[0] = IWAIT
;
333 CmdBlkP
->Packet
.data
[1] = Link
;
334 CmdBlkP
->Packet
.data
[2] = IWAIT_MAGIC
& 0xFF;
335 CmdBlkP
->Packet
.data
[3] = (IWAIT_MAGIC
>> 8) & 0xFF;
337 if (RIOQueueCmdBlk(HostP
, ID
- 1, CmdBlkP
) == RIO_FAIL
) {
338 rio_dprintk(RIO_DEBUG_CMD
, "SUSPEND BOOT ON RTA: Failed to queue iwait command\n");
344 int RIOFoadWakeup(struct rio_info
*p
)
347 register struct Port
*PortP
;
350 for (port
= 0; port
< RIO_PORTS
; port
++) {
351 PortP
= p
->RIOPortp
[port
];
353 rio_spin_lock_irqsave(&PortP
->portSem
, flags
);
356 PortP
->InUse
= NOT_INUSE
;
357 PortP
->PortState
= 0;
358 PortP
->FlushCmdBodge
= 0;
359 PortP
->ModemLines
= 0;
360 PortP
->ModemState
= 0;
364 PortP
->WflushFlag
= 0;
365 PortP
->MagicFlags
= 0;
366 PortP
->RxDataStart
= 0;
367 PortP
->TxBufferIn
= 0;
368 PortP
->TxBufferOut
= 0;
369 rio_spin_unlock_irqrestore(&PortP
->portSem
, flags
);
375 ** Incoming command on the COMMAND_RUP to be processed.
377 static int RIOCommandRup(struct rio_info
*p
, uint Rup
, struct Host
*HostP
, PKT
* PacketP
)
379 struct PktCmd
*PktCmdP
= (struct PktCmd
*) PacketP
->data
;
381 struct UnixRup
*UnixRupP
;
383 ushort ReportedModemStatus
;
392 ** Command rup packets coming from the RTA will have pkt->data[1] (which
393 ** translates to PktCmdP->PhbNum) set to the host port number for the
394 ** particular unit. To access the correct BaseSysPort for a 16 port RTA,
395 ** we can use PhbNum to get the rup number for the appropriate 8 port
396 ** block (for the first block, this should be equal to 'Rup').
398 rup
= RBYTE(PktCmdP
->PhbNum
) / (ushort
) PORTS_PER_RTA
;
399 UnixRupP
= &HostP
->UnixRups
[rup
];
400 SysPort
= UnixRupP
->BaseSysPort
+ (RBYTE(PktCmdP
->PhbNum
) % (ushort
) PORTS_PER_RTA
);
401 rio_dprintk(RIO_DEBUG_CMD
, "Command on rup %d, port %d\n", rup
, SysPort
);
403 if (UnixRupP
->BaseSysPort
== NO_PORT
) {
404 rio_dprintk(RIO_DEBUG_CMD
, "OBSCURE ERROR!\n");
405 rio_dprintk(RIO_DEBUG_CMD
, "Diagnostics follow. Please WRITE THESE DOWN and report them to Specialix Technical Support\n");
406 rio_dprintk(RIO_DEBUG_CMD
, "CONTROL information: Host number %d, name ``%s''\n", HostP
- p
->RIOHosts
, HostP
->Name
);
407 rio_dprintk(RIO_DEBUG_CMD
, "CONTROL information: Rup number 0x%x\n", rup
);
409 if (Rup
>= (ushort
) MAX_RUP
) {
410 rio_dprintk(RIO_DEBUG_CMD
, "CONTROL information: This is the RUP for RTA ``%s''\n", HostP
->Mapping
[Rup
].Name
);
412 rio_dprintk(RIO_DEBUG_CMD
, "CONTROL information: This is the RUP for link ``%c'' of host ``%s''\n", ('A' + Rup
- MAX_RUP
), HostP
->Name
);
414 rio_dprintk(RIO_DEBUG_CMD
, "PACKET information: Destination 0x%x:0x%x\n", PacketP
->dest_unit
, PacketP
->dest_port
);
415 rio_dprintk(RIO_DEBUG_CMD
, "PACKET information: Source 0x%x:0x%x\n", PacketP
->src_unit
, PacketP
->src_port
);
416 rio_dprintk(RIO_DEBUG_CMD
, "PACKET information: Length 0x%x (%d)\n", PacketP
->len
, PacketP
->len
);
417 rio_dprintk(RIO_DEBUG_CMD
, "PACKET information: Control 0x%x (%d)\n", PacketP
->control
, PacketP
->control
);
418 rio_dprintk(RIO_DEBUG_CMD
, "PACKET information: Check 0x%x (%d)\n", PacketP
->csum
, PacketP
->csum
);
419 rio_dprintk(RIO_DEBUG_CMD
, "COMMAND information: Host Port Number 0x%x, " "Command Code 0x%x\n", PktCmdP
->PhbNum
, PktCmdP
->Command
);
422 PortP
= p
->RIOPortp
[SysPort
];
423 rio_spin_lock_irqsave(&PortP
->portSem
, flags
);
424 switch (RBYTE(PktCmdP
->Command
)) {
426 rio_dprintk(RIO_DEBUG_CMD
, "Received a break!\n");
427 /* If the current line disc. is not multi-threading and
428 the current processor is not the default, reset rup_intr
429 and return FALSE to ensure that the command packet is
431 /* Call tmgr HANGUP HERE */
432 /* Fix this later when every thing works !!!! RAMRAJ */
433 gs_got_break(&PortP
->gs
);
437 rio_dprintk(RIO_DEBUG_CMD
, "Command complete on phb %d host %d\n", RBYTE(PktCmdP
->PhbNum
), HostP
- p
->RIOHosts
);
439 switch (RBYTE(PktCmdP
->SubCommand
)) {
441 rio_dprintk(RIO_DEBUG_CMD
, "Memory dump cmd (0x%x) from addr 0x%x\n", RBYTE(PktCmdP
->SubCommand
), RWORD(PktCmdP
->SubAddr
));
444 rio_dprintk(RIO_DEBUG_CMD
, "Read register (0x%x)\n", RWORD(PktCmdP
->SubAddr
));
445 p
->CdRegister
= (RBYTE(PktCmdP
->ModemStatus
) & MSVR1_HOST
);
453 rio_dprintk(RIO_DEBUG_CMD
, "New status is 0x%x was 0x%x\n", RBYTE(PktCmdP
->PortStatus
), PortP
->PortState
);
454 if (PortP
->PortState
!= RBYTE(PktCmdP
->PortStatus
)) {
455 rio_dprintk(RIO_DEBUG_CMD
, "Mark status & wakeup\n");
456 PortP
->PortState
= RBYTE(PktCmdP
->PortStatus
);
457 /* What should we do here ...
458 wakeup( &PortP->PortState );
461 rio_dprintk(RIO_DEBUG_CMD
, "No change\n");
466 ** Knock out the tbusy and tstop bits, as these are not relevant
467 ** to the check for modem status change (they're just there because
468 ** it's a convenient place to put them!).
470 ReportedModemStatus
= RBYTE(PktCmdP
->ModemStatus
);
471 if ((PortP
->ModemState
& MSVR1_HOST
) == (ReportedModemStatus
& MSVR1_HOST
)) {
472 rio_dprintk(RIO_DEBUG_CMD
, "Modem status unchanged 0x%x\n", PortP
->ModemState
);
474 ** Update ModemState just in case tbusy or tstop states have
477 PortP
->ModemState
= ReportedModemStatus
;
479 rio_dprintk(RIO_DEBUG_CMD
, "Modem status change from 0x%x to 0x%x\n", PortP
->ModemState
, ReportedModemStatus
);
480 PortP
->ModemState
= ReportedModemStatus
;
483 /***********************************************************\
484 *************************************************************
486 *** M O D E M S T A T E C H A N G E ***
488 *************************************************************
489 \***********************************************************/
491 ** If the device is a modem, then check the modem
494 if (PortP
->gs
.tty
== NULL
)
496 if (PortP
->gs
.tty
->termios
== NULL
)
499 if (!(PortP
->gs
.tty
->termios
->c_cflag
& CLOCAL
) && ((PortP
->State
& (RIO_MOPEN
| RIO_WOPEN
)))) {
501 rio_dprintk(RIO_DEBUG_CMD
, "Is there a Carrier?\n");
503 ** Is there a carrier?
505 if (PortP
->ModemState
& MSVR1_CD
) {
507 ** Has carrier just appeared?
509 if (!(PortP
->State
& RIO_CARR_ON
)) {
510 rio_dprintk(RIO_DEBUG_CMD
, "Carrier just came up.\n");
511 PortP
->State
|= RIO_CARR_ON
;
513 ** wakeup anyone in WOPEN
515 if (PortP
->State
& (PORT_ISOPEN
| RIO_WOPEN
))
516 wake_up_interruptible(&PortP
->gs
.open_wait
);
518 PortP
->Stat
.ModemOnCnt
++;
523 ** Has carrier just dropped?
525 if (PortP
->State
& RIO_CARR_ON
) {
526 if (PortP
->State
& (PORT_ISOPEN
| RIO_WOPEN
| RIO_MOPEN
))
527 tty_hangup(PortP
->gs
.tty
);
528 PortP
->State
&= ~RIO_CARR_ON
;
529 rio_dprintk(RIO_DEBUG_CMD
, "Carrirer just went down\n");
531 PortP
->Stat
.ModemOffCnt
++;
542 rio_dprintk(RIO_DEBUG_CMD
, "Unknown command %d on CMD_RUP of host %d\n", RBYTE(PktCmdP
->Command
), HostP
- p
->RIOHosts
);
545 rio_spin_unlock_irqrestore(&PortP
->portSem
, flags
);
553 ** The command mechanism:
554 ** Each rup has a chain of commands associated with it.
555 ** This chain is maintained by routines in this file.
556 ** Periodically we are called and we run a quick check of all the
557 ** active chains to determine if there is a command to be executed,
558 ** and if the rup is ready to accept it.
563 ** Allocate an empty command block.
565 struct CmdBlk
*RIOGetCmdBlk(void)
567 struct CmdBlk
*CmdBlkP
;
569 CmdBlkP
= (struct CmdBlk
*) sysbrk(sizeof(struct CmdBlk
));
571 bzero(CmdBlkP
, sizeof(struct CmdBlk
));
577 ** Return a block to the head of the free list.
579 void RIOFreeCmdBlk(struct CmdBlk
*CmdBlkP
)
581 sysfree((void *) CmdBlkP
, sizeof(struct CmdBlk
));
585 ** attach a command block to the list of commands to be performed for
588 int RIOQueueCmdBlk(struct Host
*HostP
, uint Rup
, struct CmdBlk
*CmdBlkP
)
590 struct CmdBlk
**Base
;
591 struct UnixRup
*UnixRupP
;
594 if (Rup
>= (ushort
) (MAX_RUP
+ LINKS_PER_UNIT
)) {
595 rio_dprintk(RIO_DEBUG_CMD
, "Illegal rup number %d in RIOQueueCmdBlk\n", Rup
);
596 RIOFreeCmdBlk(CmdBlkP
);
600 UnixRupP
= &HostP
->UnixRups
[Rup
];
602 rio_spin_lock_irqsave(&UnixRupP
->RupLock
, flags
);
605 ** If the RUP is currently inactive, then put the request
606 ** straight on the RUP....
608 if ((UnixRupP
->CmdsWaitingP
== NULL
) && (UnixRupP
->CmdPendingP
== NULL
) && (RWORD(UnixRupP
->RupP
->txcontrol
) == TX_RUP_INACTIVE
) && (CmdBlkP
->PreFuncP
? (*CmdBlkP
->PreFuncP
) (CmdBlkP
->PreArg
, CmdBlkP
)
610 rio_dprintk(RIO_DEBUG_CMD
, "RUP inactive-placing command straight on. Cmd byte is 0x%x\n", CmdBlkP
->Packet
.data
[0]);
613 ** Whammy! blat that pack!
615 HostP
->Copy((caddr_t
) & CmdBlkP
->Packet
, RIO_PTR(HostP
->Caddr
, UnixRupP
->RupP
->txpkt
), sizeof(PKT
));
618 ** place command packet on the pending position.
620 UnixRupP
->CmdPendingP
= CmdBlkP
;
623 ** set the command register
625 WWORD(UnixRupP
->RupP
->txcontrol
, TX_PACKET_READY
);
627 rio_spin_unlock_irqrestore(&UnixRupP
->RupLock
, flags
);
631 rio_dprintk(RIO_DEBUG_CMD
, "RUP active - en-queing\n");
633 if (UnixRupP
->CmdsWaitingP
!= NULL
)
634 rio_dprintk(RIO_DEBUG_CMD
, "Rup active - command waiting\n");
635 if (UnixRupP
->CmdPendingP
!= NULL
)
636 rio_dprintk(RIO_DEBUG_CMD
, "Rup active - command pending\n");
637 if (RWORD(UnixRupP
->RupP
->txcontrol
) != TX_RUP_INACTIVE
)
638 rio_dprintk(RIO_DEBUG_CMD
, "Rup active - command rup not ready\n");
640 Base
= &UnixRupP
->CmdsWaitingP
;
642 rio_dprintk(RIO_DEBUG_CMD
, "First try to queue cmdblk 0x%x at 0x%x\n", (int) CmdBlkP
, (int) Base
);
645 rio_dprintk(RIO_DEBUG_CMD
, "Command cmdblk 0x%x here\n", (int) (*Base
));
646 Base
= &((*Base
)->NextP
);
647 rio_dprintk(RIO_DEBUG_CMD
, "Now try to queue cmd cmdblk 0x%x at 0x%x\n", (int) CmdBlkP
, (int) Base
);
650 rio_dprintk(RIO_DEBUG_CMD
, "Will queue cmdblk 0x%x at 0x%x\n", (int) CmdBlkP
, (int) Base
);
654 CmdBlkP
->NextP
= NULL
;
656 rio_spin_unlock_irqrestore(&UnixRupP
->RupLock
, flags
);
662 ** Here we go - if there is an empty rup, fill it!
663 ** must be called at splrio() or higher.
665 void RIOPollHostCommands(struct rio_info
*p
, struct Host
*HostP
)
667 register struct CmdBlk
*CmdBlkP
;
668 register struct UnixRup
*UnixRupP
;
674 Rup
= MAX_RUP
+ LINKS_PER_UNIT
;
676 do { /* do this loop for each RUP */
678 ** locate the rup we are processing & lock it
680 UnixRupP
= &HostP
->UnixRups
[--Rup
];
682 spin_lock_irqsave(&UnixRupP
->RupLock
, flags
);
685 ** First check for incoming commands:
687 if (RWORD(UnixRupP
->RupP
->rxcontrol
) != RX_RUP_INACTIVE
) {
690 PacketP
= (PKT
*) RIO_PTR(HostP
->Caddr
, RWORD(UnixRupP
->RupP
->rxpkt
));
692 ShowPacket(DBG_CMD
, PacketP
);
694 switch (RBYTE(PacketP
->dest_port
)) {
696 rio_dprintk(RIO_DEBUG_CMD
, "Incoming Boot %s packet '%x'\n", RBYTE(PacketP
->len
) & 0x80 ? "Command" : "Data", RBYTE(PacketP
->data
[0]));
697 rio_spin_unlock_irqrestore(&UnixRupP
->RupLock
, flags
);
698 FreeMe
= RIOBootRup(p
, Rup
, HostP
, PacketP
);
699 rio_spin_lock_irqsave(&UnixRupP
->RupLock
, flags
);
704 ** Free the RUP lock as loss of carrier causes a
705 ** ttyflush which will (eventually) call another
706 ** routine that uses the RUP lock.
708 rio_spin_unlock_irqrestore(&UnixRupP
->RupLock
, flags
);
709 FreeMe
= RIOCommandRup(p
, Rup
, HostP
, PacketP
);
710 if (PacketP
->data
[5] == MEMDUMP
) {
711 rio_dprintk(RIO_DEBUG_CMD
, "Memdump from 0x%x complete\n", *(ushort
*) & (PacketP
->data
[6]));
712 HostP
->Copy((caddr_t
) & (PacketP
->data
[8]), (caddr_t
) p
->RIOMemDump
, 32);
714 rio_spin_lock_irqsave(&UnixRupP
->RupLock
, flags
);
718 rio_spin_unlock_irqrestore(&UnixRupP
->RupLock
, flags
);
719 FreeMe
= RIORouteRup(p
, Rup
, HostP
, PacketP
);
720 rio_spin_lock_irqsave(&UnixRupP
->RupLock
, flags
);
724 rio_dprintk(RIO_DEBUG_CMD
, "Unknown RUP %d\n", RBYTE(PacketP
->dest_port
));
730 rio_dprintk(RIO_DEBUG_CMD
, "Free processed incoming command packet\n");
731 put_free_end(HostP
, PacketP
);
733 WWORD(UnixRupP
->RupP
->rxcontrol
, RX_RUP_INACTIVE
);
735 if (RWORD(UnixRupP
->RupP
->handshake
) == PHB_HANDSHAKE_SET
) {
736 rio_dprintk(RIO_DEBUG_CMD
, "Handshake rup %d\n", Rup
);
737 WWORD(UnixRupP
->RupP
->handshake
, PHB_HANDSHAKE_SET
| PHB_HANDSHAKE_RESET
);
743 ** IF a command was running on the port,
744 ** and it has completed, then tidy it up.
746 if ((CmdBlkP
= UnixRupP
->CmdPendingP
) && /* ASSIGN! */
747 (RWORD(UnixRupP
->RupP
->txcontrol
) == TX_RUP_INACTIVE
)) {
750 ** there is a command in pending.
751 ** Therefore, this command has finished.
752 ** So, wakeup whoever is waiting for it (and tell them
755 if (CmdBlkP
->Packet
.dest_port
== BOOT_RUP
)
756 rio_dprintk(RIO_DEBUG_CMD
, "Free Boot %s Command Block '%x'\n", CmdBlkP
->Packet
.len
& 0x80 ? "Command" : "Data", CmdBlkP
->Packet
.data
[0]);
758 rio_dprintk(RIO_DEBUG_CMD
, "Command 0x%x completed\n", (int) CmdBlkP
);
761 ** Clear the Rup lock to prevent mutual exclusion.
763 if (CmdBlkP
->PostFuncP
) {
764 rio_spin_unlock_irqrestore(&UnixRupP
->RupLock
, flags
);
765 (*CmdBlkP
->PostFuncP
) (CmdBlkP
->PostArg
, CmdBlkP
);
766 rio_spin_lock_irqsave(&UnixRupP
->RupLock
, flags
);
770 ** ....clear the pending flag....
772 UnixRupP
->CmdPendingP
= NULL
;
775 ** ....and return the command block to the freelist.
777 RIOFreeCmdBlk(CmdBlkP
);
781 ** If there is a command for this rup, and the rup
782 ** is idle, then process the command
784 if ((CmdBlkP
= UnixRupP
->CmdsWaitingP
) && /* ASSIGN! */
785 (UnixRupP
->CmdPendingP
== NULL
) && (RWORD(UnixRupP
->RupP
->txcontrol
) == TX_RUP_INACTIVE
)) {
787 ** if the pre-function is non-zero, call it.
788 ** If it returns RIO_FAIL then don't
789 ** send this command yet!
791 if (!(CmdBlkP
->PreFuncP
? (*CmdBlkP
->PreFuncP
) (CmdBlkP
->PreArg
, CmdBlkP
) : TRUE
)) {
792 rio_dprintk(RIO_DEBUG_CMD
, "Not ready to start command 0x%x\n", (int) CmdBlkP
);
794 rio_dprintk(RIO_DEBUG_CMD
, "Start new command 0x%x Cmd byte is 0x%x\n", (int) CmdBlkP
, CmdBlkP
->Packet
.data
[0]);
796 ** Whammy! blat that pack!
798 HostP
->Copy((caddr_t
) & CmdBlkP
->Packet
, RIO_PTR(HostP
->Caddr
, UnixRupP
->RupP
->txpkt
), sizeof(PKT
));
801 ** remove the command from the rup command queue...
803 UnixRupP
->CmdsWaitingP
= CmdBlkP
->NextP
;
806 ** ...and place it on the pending position.
808 UnixRupP
->CmdPendingP
= CmdBlkP
;
811 ** set the command register
813 WWORD(UnixRupP
->RupP
->txcontrol
, TX_PACKET_READY
);
816 ** the command block will be freed
817 ** when the command has been processed.
821 spin_unlock_irqrestore(&UnixRupP
->RupLock
, flags
);
825 int RIOWFlushMark(int iPortP
, struct CmdBlk
*CmdBlkP
)
827 struct Port
*PortP
= (struct Port
*) iPortP
;
830 rio_spin_lock_irqsave(&PortP
->portSem
, flags
);
832 PortP
->MagicFlags
|= MAGIC_FLUSH
;
833 rio_spin_unlock_irqrestore(&PortP
->portSem
, flags
);
834 return RIOUnUse(iPortP
, CmdBlkP
);
837 int RIORFlushEnable(int iPortP
, struct CmdBlk
*CmdBlkP
)
839 struct Port
*PortP
= (struct Port
*) iPortP
;
843 rio_spin_lock_irqsave(&PortP
->portSem
, flags
);
845 while (can_remove_receive(&PacketP
, PortP
)) {
846 remove_receive(PortP
);
847 ShowPacket(DBG_PROC
, PacketP
);
848 put_free_end(PortP
->HostP
, PacketP
);
851 if (RWORD(PortP
->PhbP
->handshake
) == PHB_HANDSHAKE_SET
) {
853 ** MAGIC! (Basically, handshake the RX buffer, so that
854 ** the RTAs upstream can be re-enabled.)
856 rio_dprintk(RIO_DEBUG_CMD
, "Util: Set RX handshake bit\n");
857 WWORD(PortP
->PhbP
->handshake
, PHB_HANDSHAKE_SET
| PHB_HANDSHAKE_RESET
);
859 rio_spin_unlock_irqrestore(&PortP
->portSem
, flags
);
860 return RIOUnUse(iPortP
, CmdBlkP
);
863 int RIOUnUse(int iPortP
, struct CmdBlk
*CmdBlkP
)
865 struct Port
*PortP
= (struct Port
*) iPortP
;
868 rio_spin_lock_irqsave(&PortP
->portSem
, flags
);
870 rio_dprintk(RIO_DEBUG_CMD
, "Decrement in use count for port\n");
873 if (--PortP
->InUse
!= NOT_INUSE
) {
874 rio_spin_unlock_irqrestore(&PortP
->portSem
, flags
);
879 ** While PortP->InUse is set (i.e. a preemptive command has been sent to
880 ** the RTA and is awaiting completion), any transmit data is prevented from
881 ** being transferred from the write queue into the transmit packets
882 ** (add_transmit) and no furthur transmit interrupt will be sent for that
883 ** data. The next interrupt will occur up to 500ms later (RIOIntr is called
884 ** twice a second as a saftey measure). This was the case when kermit was
885 ** used to send data into a RIO port. After each packet was sent, TCFLSH
886 ** was called to flush the read queue preemptively. PortP->InUse was
887 ** incremented, thereby blocking the 6 byte acknowledgement packet
888 ** transmitted back. This acknowledgment hung around for 500ms before
889 ** being sent, thus reducing input performance substantially!.
890 ** When PortP->InUse becomes NOT_INUSE, we must ensure that any data
891 ** hanging around in the transmit buffer is sent immediately.
893 WWORD(PortP
->HostP
->ParmMapP
->tx_intr
, 1);
894 /* What to do here ..
895 wakeup( (caddr_t)&(PortP->InUse) );
897 rio_spin_unlock_irqrestore(&PortP
->portSem
, flags
);
901 void ShowPacket(uint Flags
, struct PKT
*PacketP
)
907 ** How to use this file:
909 ** To send a command down a rup, you need to allocate a command block, fill
910 ** in the packet information, fill in the command number, fill in the pre-
911 ** and post- functions and arguments, and then add the command block to the
912 ** queue of command blocks for the port in question. When the port is idle,
913 ** then the pre-function will be called. If this returns RIO_FAIL then the
914 ** command will be re-queued and tried again at a later date (probably in one
915 ** clock tick). If the pre-function returns NOT RIO_FAIL, then the command
916 ** packet will be queued on the RUP, and the txcontrol field set to the
917 ** command number. When the txcontrol field has changed from being the
918 ** command number, then the post-function will be called, with the argument
919 ** specified earlier, a pointer to the command block, and the value of
922 ** To allocate a command block, call RIOGetCmdBlk(). This returns a pointer
923 ** to the command block structure allocated, or NULL if there aren't any.
924 ** The block will have been zeroed for you.
926 ** The structure has the following fields:
930 ** struct CmdBlk *NextP; ** Pointer to next command block **
931 ** struct PKT Packet; ** A packet, to copy to the rup **
932 ** int (*PreFuncP)(); ** The func to call to check if OK **
933 ** int PreArg; ** The arg for the func **
934 ** int (*PostFuncP)(); ** The func to call when completed **
935 ** int PostArg; ** The arg for the func **
938 ** You need to fill in ALL fields EXCEPT NextP, which is used to link the
939 ** blocks together either on the free list or on the Rup list.
941 ** Packet is an actual packet structure to be filled in with the packet
942 ** information associated with the command. You need to fill in everything,
943 ** as the command processore doesn't process the command packet in any way.
945 ** The PreFuncP is called before the packet is enqueued on the host rup.
946 ** PreFuncP is called as (*PreFuncP)(PreArg, CmdBlkP);. PreFuncP must
947 ** return !RIO_FAIL to have the packet queued on the rup, and RIO_FAIL
948 ** if the packet is NOT to be queued.
950 ** The PostFuncP is called when the command has completed. It is called
951 ** as (*PostFuncP)(PostArg, CmdBlkP, txcontrol);. PostFuncP is not expected
952 ** to return a value. PostFuncP does NOT need to free the command block,
953 ** as this happens automatically after PostFuncP returns.
955 ** Once the command block has been filled in, it is attached to the correct
956 ** queue by calling RIOQueueCmdBlk( HostP, Rup, CmdBlkP ) where HostP is
957 ** a pointer to the struct Host, Rup is the NUMBER of the rup (NOT a pointer
958 ** to it!), and CmdBlkP is the pointer to the command block allocated using