folkert/simh-testsetgenerator
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
simh-testsetgenerator/SEL32/sel32_ec.c
Jim Bevier 25b79339fd SEL32: Do general code cleanup to remove unused code. 
SEL32: Update Ping and ICMP support code to use correct packet size.
SEL32: Update SetupNet script to support latest Fedora release.
SEL32: Improve disk write speed.
SEL32: Add .tap file reassignent support in sel32_mt.c.
2023-10-09 20:34:56 -04:00

1937 lines
86 KiB
C
Raw Blame History

/* sel32_ec.c: SEL-32 8516 Ethernet controller.
Copyright (c) 2020-2023, Richard Cornwell
Portions provided by James C. Bevier and other SIMH contributers
Permission is hereby granted, free of charge, to any person obtaining a
copy of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom the
Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in
all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
RICHARD CORNWELL BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
*/
#include "sel32_defs.h"
#if NUM_DEVS_ETHER > 0
#include "sim_ether.h"
/* allow 3 modes */
#define UNIT_V_MODE (UNIT_V_UF + 1)
#define UNIT_MODE (0x3 << UNIT_V_MODE)
/* get & set disk types */
#define GET_MODE(x) ((UNIT_MODE & (x)) >> UNIT_V_MODE)
#define SET_MODE(x) (UNIT_MODE & ((x) << UNIT_V_MODE))
#define CMD u3
/* u3 */
/* in u3 is device command code and status */
#define EC_CMDMSK 0x0ff /* Command being run */
/* commands */
#define EC_INCH 0x00 /* Initialize channel */
#define EC_INCH2 0xF0 /* Initialize channel command for processing */
#define EC_WRITE 0x01 /* Write frame */
#define EC_READ 0x02 /* Read frame*/
#define EC_NOP 0x03 /* No operation */
#define EC_SNS 0x04 /* Sense */
#define EC_LIA 0x07 /* Load individual address */
#define EC_TIC 0x08 /* Transfer in channel */
#define EC_CGA 0x0B /* Disable multicast address */
#define EC_LGA 0x0F /* Load Multicast address */
#define EC_LCC 0x10 /* Configure LCC */
#define EC_STATS 0x14 /* Read Statistics */
#define EC_CSTATS 0x15 /* Clear software counters */
#define EC_BUSY 0x100 /* Mark Device as Busy */
#define SNS u5
/* u5 */
/* Sense byte 0 */
#define SNS_CMDREJ 0x80000000 /* Command reject */
#define SNS_SPARE0 0x40000000 /* Spare */
#define SNS_SPARE1 0x20000000 /* Spare */
#define SNS_EQUCHK 0x10000000 /* Equipment check */
#define SNS_SPARE2 0x08000000 /* Spare */
#define SNS_SPARE3 0x04000000 /* Spare */
#define SNS_MODE_M 0x03000000 /* Mode Mask */
/* Sense byte 1 */
#define SNS_RCV_RDY 0x00800000 /* Receive unit ready */
#define SNS_TMT_DEF 0x00400000 /* Transmission deferred */
#define SNS_COL_RTY 0x00300000 /* Collision retry */
#define SNS_HRT_TST 0x00080000 /* Heartbeat test failure */
#define SNS_DMA_UND 0x00040000 /* DMA under run */
#define SNS_LST_CTS 0x00020000 /* Lost Clear to send */
#define SNS_NO_CAR 0x00010000 /* No carrier. */
/* Sense byte 2 & 3 */
#define SNS_XFR_MASK 0x0000FFFF /* Previous frame count */
typedef uint32 in_addr_T;
#define ETHTYPE_ARP 0x0806
#define ETHTYPE_IP 0x0800
#define STAT_FR_ALIGN 0 /* Frame alignment errors */
#define STAT_FR_CRC 1 /* Frame CRC errors */
#define STAT_LCL_AVAIL 2 /* Local bus available errors */
#define STAT_LCL_OVER 3 /* Local bus overflow */
#define STAT_TX_COLL 4 /* Transmission collisions */
#define STAT_RX_LEN 5 /* Receive length errors */
#define STAT_TX_SUCC 6 /* Transmitt success after 2-15 collisions */
#define STAT_TX_DEF 7 /* Transmitt deferred */
#define STAT_TX_UNSUCC 8 /* Transmitt unsuccessful */
#define STAT_TX_SUCC1 9 /* Transmitt success after 1 collision */
#define STAT_LEN 10 /* Number of half word stats */
PACKED_BEGIN
struct ec_eth_hdr {
ETH_MAC dest;
ETH_MAC src;
uint16 type;
} PACKED_END;
/*
* Structure of an internet header, naked of options.
*/
PACKED_BEGIN
struct ip {
uint8 ip_v_hl; /* version,header length */
uint8 ip_tos; /* type of service */
uint16 ip_len; /* total length */
uint16 ip_id; /* identification */
uint16 ip_off; /* fragment offset field */
#define IP_DF 0x4000 /* don't fragment flag */
#define IP_MF 0x2000 /* more fragments flag */
#define IP_OFFMASK 0x1fff /* mask for fragmenting bits */
uint8 ip_ttl; /* time to live */
uint8 ip_p; /* protocol */
uint16 ip_sum; /* checksum */
in_addr_T ip_src;
in_addr_T ip_dst; /* source and dest address */
} PACKED_END;
#define TCP_PROTO 6
PACKED_BEGIN
struct tcp {
uint16 tcp_sport; /* Source port */
uint16 tcp_dport; /* Destination port */
uint32 seq; /* Sequence number */
uint32 ack; /* Ack number */
uint16 flags; /* Flags */
#define TCP_FL_FIN 0x01
#define TCP_FL_SYN 0x02
#define TCP_FL_RST 0x04
#define TCP_FL_PSH 0x08
#define TCP_FL_ACK 0x10
#define TCP_FL_URG 0x20
uint16 window; /* Window size */
uint16 chksum; /* packet checksum */
uint16 urgent; /* Urgent pointer */
} PACKED_END;
#define UDP_PROTO 17
PACKED_BEGIN
struct udp {
uint16 udp_sport; /* Source port */
uint16 udp_dport; /* Destination port */
uint16 len; /* Length */
uint16 chksum; /* packet checksum */
} PACKED_END;
PACKED_BEGIN
struct udp_hdr {
in_addr_T ip_src;
in_addr_T ip_dst; /* source and dest address */
uint8 zero;
uint8 proto; /* Protocol */
uint16 hlen; /* Length of header and data */
} PACKED_END;
#define ICMP_PROTO 1
PACKED_BEGIN
struct icmp {
uint8 type; /* Type of packet */
uint8 code; /* Code */
uint16 chksum; /* packet checksum */
} PACKED_END;
PACKED_BEGIN
struct ip_hdr {
struct ec_eth_hdr ethhdr;
struct ip iphdr;
} PACKED_END;
#define ARP_REQUEST 1
#define ARP_REPLY 2
#define ARP_HWTYPE_ETH 1
PACKED_BEGIN
struct arp_hdr {
struct ec_eth_hdr ethhdr;
uint16 hwtype;
int16 protocol;
uint8 hwlen;
uint8 protolen;
uint16 opcode;
ETH_MAC shwaddr;
in_addr_T sipaddr;
ETH_MAC dhwaddr;
in_addr_T dipaddr;
uint8 padding[18];
} PACKED_END;
struct ec_device {
ETH_PCALLBACK rcallback; /* read callback routine */
ETH_PCALLBACK wcallback; /* write callback routine */
ETH_MAC mac; /* Hardware MAC addresses */
ETH_DEV etherface;
ETH_QUE ReadQ;
ETH_PACK rec_buff[1024]; /* Buffer for received packet */
ETH_PACK snd_buff; /* Buffer for sending packet */
int macs_n; /* Number of multi-cast addresses */
ETH_MAC macs[67]; /* Watched Multi-cast addresses */
int amc; /* Recieve all multicast packets */
uint32 rx_count; /* Packets received */
uint32 tx_count; /* Packets sent */
t_stat drop_cnt; /* Packets dropped */
int r_pkt; /* Packet pending */
int poll; /* Need to poll receiver */
int lp_rdy; /* Loop back packet ready */
int rec_ptr; /* Receive pointer */
int xtr_ptr; /* Extract pointer */
uint8 conf[12]; /* user specified configuration */
} ec_data;
#define LOOP_MSK 0x3ff
extern int32 tmxr_poll;
extern uint32 readfull(CHANP *chp, uint32 maddr, uint32 *word);
extern uint32 cont_chan(uint16 chsa);
static CONST ETH_MAC broadcast_ethaddr = {0xff,0xff,0xff,0xff,0xff,0xff};
/* channel program information */
CHANP ec_chp[NUM_UNITS_ETHER] = {0};
/* forward definitions */
t_stat ec_preio(UNIT *uptr, uint16 chan);
t_stat ec_startcmd(UNIT *uptr, uint16 chan, uint8 cmd);
t_stat ec_rec_srv(UNIT *uptr);
t_stat ec_srv(UNIT *uptr);
t_stat ec_haltio(UNIT *uptr);
t_stat ec_iocl(CHANP *chp, int32 tic_ok);
void ec_packet_debug(struct ec_device *ec, const char *action, ETH_PACK *packet);
t_stat ec_reset (DEVICE *dptr);
void ec_ini(UNIT *, t_bool);
t_stat ec_rsctrl(UNIT *uptr);
t_stat ec_rschnlio(UNIT *uptr);
t_stat ec_show_mac (FILE* st, UNIT* uptr, int32 val, CONST void* desc);
t_stat ec_set_mac (UNIT* uptr, int32 val, CONST char* cptr, void* desc);
t_stat ec_show_mode (FILE* st, UNIT* uptr, int32 val, CONST void* desc);
t_stat ec_set_mode (UNIT* uptr, int32 val, CONST char* cptr, void* desc);
t_stat ec_attach (UNIT * uptr, CONST char * cptr);
t_stat ec_detach (UNIT * uptr);
t_stat ec_help (FILE *st, DEVICE *dptr, UNIT *uptr, int32 flag, CONST char *cptr);
const char *ec_description (DEVICE *dptr);
#define ec_master_uptr (&ec_unit[0]) /* Unit doing receive digestion */
UNIT ec_unit[] = {
{UDATA(ec_rec_srv, UNIT_IDLE|UNIT_ATTABLE, 0), 0, UNIT_ADDR(0xE00)}, /* 0 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE01)}, /* 1 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE02)}, /* 2 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE03)}, /* 3 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE04)}, /* 4 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE05)}, /* 5 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE06)}, /* 6 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE07)}, /* 7 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE08)}, /* 8 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE09)}, /* 9 */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE0A)}, /* A */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE0B)}, /* B */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE0C)}, /* C */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE0D)}, /* D */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE0E)}, /* E */
{UDATA(ec_srv, UNIT_IDLE|UNIT_DIS|UNIT_SUBCHAN, 0), 0, UNIT_ADDR(0xE0F)}, /* F */
};
DIB ec_dib = {
ec_preio, /* t_stat (*pre_io)(UNIT *uptr, uint16 chan)*/ /* Pre Start I/O */
ec_startcmd, /* t_stat (*start_cmd)(UNIT *uptr, uint16 chan, uint8 cmd)*/ /* Start command */
ec_haltio, /* t_stat (*halt_io)(UNIT *uptr) */ /* Halt I/O */
NULL, /* t_stat (*stop_io)(UNIT *uptr) */ /* Stop I/O */
NULL, /* t_stat (*test_io)(UNIT *uptr) */ /* Test I/O */
ec_rsctrl, /* t_stat (*rsctl_io)(UNIT *uptr) */ /* Reset Controller */
ec_rschnlio, /* t_stat (*rschnl_io)(UNIT *uptr) */ /* Reset Channel */
ec_iocl, /* t_stat (*iocl_io)(CHANP *chp, int32 tic_ok)) */ /* Process IOCL */
ec_ini, /* void (*dev_ini)(UNIT *uptr) */ /* init function */
ec_unit, /* UNIT *units */ /* Pointer to units structure */
ec_chp, /* CHANP *chan_prg */ /* Pointer to chan_prg structure */
NULL, /* IOCLQ *ioclq_ptr */ /* IOCL entries, 1 per UNIT */
NUM_UNITS_ETHER, /* number of units defined */
0x0F, /* device mask */
0x0E00, /* parent channel address */
0, /* fifo input index */
0, /* fifo output index */
{0}, /* interrupt status fifo for channel */
};
MTAB ec_mod[] = {
{ MTAB_XTD|MTAB_VDV|MTAB_VALR|MTAB_NC, 0, "MODE", "MODE=#",
&ec_set_mode, &ec_show_mode, NULL, "Ethernet mode" },
{ MTAB_XTD|MTAB_VDV|MTAB_VALR|MTAB_NC, 0, "MAC", "MAC=xx:xx:xx:xx:xx:xx",
&ec_set_mac, &ec_show_mac, NULL, "MAC address" },
{ MTAB_XTD|MTAB_VDV|MTAB_NMO, 0, "ETH", NULL, NULL,
&eth_show, NULL, "Display attachedable devices" },
{MTAB_XTD | MTAB_VUN | MTAB_VALR, 0, "DEV", "DEV",
&set_dev_addr, &show_dev_addr, NULL, "Device channel address"},
{ 0 }
};
/* Simulator debug controls */
DEBTAB ec_debug[] = {
{"CMD", DEBUG_CMD, "Show command execution to devices"},
{"DATA", DEBUG_DATA, "Show data transfers"},
{"DETAIL", DEBUG_DETAIL, "Show details about device"},
{"EXP", DEBUG_EXP, "Show exception information"},
{"IRQ", DEBUG_IRQ, "Show IRQ requests"},
{"XIO", DEBUG_XIO, "Show XIO I/O instructions"},
#define DEBUG_ARP (DEBUG_IRQ<<1)
{"ARP", DEBUG_ARP, "Show ARP activities"},
#define DEBUG_TCP (DEBUG_ARP<<1)
{"TCP", DEBUG_TCP, "Show TCP packet activities"},
#define DEBUG_UDP (DEBUG_TCP<<1)
{"UDP", DEBUG_UDP, "Show UDP packet activities"},
#define DEBUG_ICMP (DEBUG_UDP<<1)
{"ICMP", DEBUG_ICMP, "Show ICMP packet activities"},
#define DEBUG_ETHER (DEBUG_ICMP<<1)
{"ETHER", DEBUG_ETHER, "Show ETHER activities"},
{0, 0}
};
DEVICE ec_dev = {
"EC", ec_unit, NULL, ec_mod,
NUM_UNITS_ETHER, 16, 24, 4, 16, 32,
NULL, NULL, &ec_reset, NULL, &ec_attach, &ec_detach,
&ec_dib, DEV_DISABLE | DEV_DEBUG | DEV_ETHER, 0, ec_debug,
NULL, NULL, &ec_help, NULL, NULL, &ec_description
};
/* load in the IOCD and process the commands */
/* return = 0 OK */
/* return = 1 error, chan_status will have reason */
t_stat ec_iocl(CHANP *chp, int32 tic_ok)
{
uint32 word1 = 0;
uint32 word2 = 0;
int32 docmd = 0;
UNIT *uptr = chp->unitptr; /* get the unit ptr */
uint16 chan = get_chan(chp->chan_dev); /* our channel */
uint16 chsa = chp->chan_dev;
uint16 devstat = 0;
DEVICE *dptr = get_dev(uptr);
/* check for valid iocd address if 1st iocd */
if (chp->chan_info & INFO_SIOCD) { /* see if 1st IOCD in channel prog */
if (chp->chan_caw & 0x3) { /* must be word bounded */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl iocd bad address chsa %02x caw %06x\n",
chsa, chp->chan_caw);
chp->ccw_addr = chp->chan_caw; /* set the bad iocl address */
chp->chan_status |= STATUS_PCHK; /* program check for invalid iocd addr */
return 1; /* error return */
}
}
loop:
sim_debug(DEBUG_EXP, dptr,
"ec_iocl @%06x @loop chan_status[%04x] %04x SNS %08x\n",
chp->chan_caw, chan, chp->chan_status, uptr->SNS);
/* Abort if we have any errors */
if (chp->chan_status & STATUS_ERROR) { /* check channel error status */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl ERROR1 chan_status[%04x] %04x\n", chan, chp->chan_status);
return 1; /* return error */
}
/* Read in first CCW */
if (readfull(chp, chp->chan_caw, &word1) != 0) { /* read word1 from memory */
chp->chan_status |= STATUS_PCHK; /* memory read error, program check */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl ERROR2 chan_status[%04x] %04x\n", chan, chp->chan_status);
return 1; /* error return */
}
/* Read in second CCW */
if (readfull(chp, chp->chan_caw+4, &word2) != 0) { /* read word2 from memory */
chp->chan_status |= STATUS_PCHK; /* memory read error, program check */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl ERROR3 chan_status[%04x] %04x\n", chan, chp->chan_status);
return 1; /* error return */
}
sim_debug(DEBUG_CMD, dptr,
"ec_iocl @%06x read ccw chsa %04x IOCD wd 1 %08x wd 2 %08x SNS %08x\n",
chp->chan_caw, chp->chan_dev, word1, word2, uptr->SNS);
chp->chan_caw = (chp->chan_caw & 0xfffffc) + 8; /* point to next IOCD */
/* Check if we had data chaining in previous iocd */
/* if we did, use previous cmd value */
if (((chp->chan_info & INFO_SIOCD) == 0) && /* see if 1st IOCD in channel prog */
(chp->ccw_flags & FLAG_DC)) { /* last IOCD have DC set? */
sim_debug(DEBUG_CMD, dptr,
"ec_iocl @%06x DO DC, ccw_flags %04x cmd %02x\n",
chp->chan_caw, chp->ccw_flags, chp->ccw_cmd);
} else
chp->ccw_cmd = (word1 >> 24) & 0xff; /* set new command from IOCD wd 1 */
chp->ccw_count = 0;
if (!MEM_ADDR_OK(word1 & MASK24)) { /* see if memory address invalid */
chp->chan_status |= STATUS_PCHK; /* bad, program check */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl mem error PCHK chan_status[%04x] %04x addr %08x\n",
chan, chp->chan_status, word1 & MASK24);
return 1; /* error return */
}
/* this switch is here to satisify the SEL diag who wants a program */
/* check error instead of a unit check error for these cmd values??? */
/* validate the commands for the ethernet */
switch (chp->ccw_cmd) {
case 0x18: case 0x20: case 0x28: case 0x30: case 0x38: case 0x40: case 0x48:
case 0x50: case 0x58: case 0x60: case 0x68: case 0x70: case 0x78: case 0x80:
case 0x88: case 0x90: case 0x98: case 0xa0: case 0xa8: case 0xb0: case 0xb8:
case 0xc0: case 0xc8: case 0xd0: case 0xd8: case 0xe0: case 0xe8: case 0xf0:
case 0xf8:
uptr->SNS &= ~SNS_CMDREJ; /* remove CMD reject status */
sim_debug(DEBUG_CMD, dptr,
"ec_iocl illegal at ec_startcmd %02x SNS %08x\n",
chp->ccw_cmd, uptr->SNS);
chp->ccw_count = 0; /* diags want zero count */
chp->chan_status |= STATUS_PCHK; /* program check for invalid cmd */
return 1; /* error return */
case EC_READ:
/* read count must be multiple of 4 */
if ((word2 & 0xffff) & 3) {
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_iocl READ cnt not multiple of 4 %d\n", word2 & 0xffff);
/* diags wants prog check instead of unit check */
chp->chan_status |= STATUS_PCHK; /* program check for invalid cmd */
return 1; /* error return */
}
/* see if too few bytes */
if (((chp->chan_info & INFO_SIOCD) == 1) && /* see if 1st IOCD in channel prog */
((word2 & 0xffff) < 20) && /* and not at least 20 bytes */
((word2 & BIT0) == 0)) { /* and not data chained */
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_iocl READ error small packet 0x%04x\n", word2 & 0xffff);
/* diags wants incorrect length instead of program check */
chp->chan_status |= STATUS_LENGTH; /* incorrect length error */
return 1; /* error return */
}
/* see if too many bytes */
if ((word2 & 0xffff) > (ETH_MAX_PACKET+2)) {
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_iocl READ error large packet 0x%04x\n", word2 & 0xffff);
/* diags wants prog check instead of length check for test 4E */
chp->chan_status |= STATUS_PCHK; /* program check for invalid cmd */
return 1; /* error return */
}
uptr->SNS = 0;
break;
case EC_WRITE:
/* see if too few bytes */
if (((chp->chan_info & INFO_SIOCD) == 1) && /* see if 1st IOCD in channel prog */
((word2 & 0xffff) < 8) && /* and not at least 8 bytes */
((word2 & BIT0) == 0)) { /* and not data chained */
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_iocl WRITE error small packet 0x%04x\n", word2 & 0xffff);
/* diags wants prog check instead of unit check */
chp->chan_status |= STATUS_PCHK; /* program check for invalid cmd */
return 1; /* error return */
}
/* see if too many bytes */
if ((word2 & 0xffff) > ETH_MAX_PACKET) {
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_iocl WRITE error large packet 0x%04x\n", word2 & 0xffff);
/* diags wants prog check instead of length check for test 4E */
chp->chan_status |= STATUS_PCHK; /* program check for invalid cmd */
return 1; /* error return */
}
uptr->SNS = 0;
break;
case EC_INCH: case EC_LIA:
case EC_TIC: case EC_CGA: case EC_LGA: case EC_LCC:
uptr->SNS = 0;
break;
case EC_STATS: case EC_CSTATS:
case EC_SNS:
break;
case EC_NOP:
uptr->SNS = 0;
/* nop must have non zero count */
if ((word2 & 0xffff) == 0) {
chp->chan_status |= STATUS_PCHK; /* program check for invalid cmd */
return 1; /* error return */
}
break;
default:
uptr->SNS |= SNS_CMDREJ;
chp->chan_status |= STATUS_CHECK; /* diags want unit check */
sim_debug(DEBUG_CMD, dptr,
"ec_startcmd illegal2 cmd %02x SNS %08x\n",
chp->ccw_cmd, uptr->SNS);
return 1; /* error return */
break;
}
chp->ccw_count = word2 & 0xffff; /* get 16 bit byte count from IOCD WD 2 */
if (chp->chan_info & INFO_SIOCD) { /* see if 1st IOCD in channel prog */
/* 1st command can not be a TIC */
if (chp->ccw_cmd == CMD_TIC) {
chp->chan_status |= STATUS_PCHK; /* program check for invalid tic */
uptr->SNS |= SNS_CMDREJ; /* cmd rejected status */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl TIC bad cmd chan_status[%04x] %04x\n",
chan, chp->chan_status);
return 1; /* error return */
}
}
/* TIC can't follow TIC or be first in command chain */
/* diags send bad commands for testing. Use all of op */
if (chp->ccw_cmd == CMD_TIC) {
if (tic_ok) {
if (((word1 & MASK24) == 0) || (word1 & 0x3)) {
sim_debug(DEBUG_EXP, dptr,
"ec_iocl tic cmd bad address chan %02x tic caw %06x IOCD wd 1 %08x\n",
chan, chp->chan_caw, word1);
chp->chan_status |= STATUS_PCHK; /* program check for invalid tic */
chp->chan_caw = word1 & MASK24; /* get new IOCD address */
uptr->SNS |= SNS_CMDREJ; /* cmd rejected status */
return 1; /* error return */
}
tic_ok = 0; /* another tic not allowed */
chp->chan_caw = word1 & MASK24; /* get new IOCD address */
sim_debug(DEBUG_CMD, dptr,
"ec_iocl tic cmd ccw chan %02x tic caw %06x IOCD wd 1 %08x\n",
chan, chp->chan_caw, word1);
goto loop; /* restart the IOCD processing */
}
chp->chan_caw = word1 & MASK24; /* get new IOCD address */
chp->chan_status |= STATUS_PCHK; /* program check for invalid tic */
uptr->SNS |= SNS_CMDREJ; /* cmd rejected status */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl TIC ERROR chan_status[%04x] %04x\n", chan, chp->chan_status);
return 1; /* error return */
}
/* Check if we had data chaining in previous iocd */
if ((chp->chan_info & INFO_SIOCD) || /* see if 1st IOCD in channel prog */
(((chp->chan_info & INFO_SIOCD) == 0) && /* see if 1st IOCD in channel prog */
((chp->ccw_flags & FLAG_DC) == 0))) { /* last IOCD have DC set? */
sim_debug(DEBUG_CMD, dptr,
"ec_iocl @%06x DO CMD No DC, ccw_flags %04x cmd %02x\n",
chp->chan_caw, chp->ccw_flags, chp->ccw_cmd);
docmd = 1; /* show we have a command */
}
/* Set up for this command */
chp->ccw_flags = (word2 >> 16) & 0xf800; /* get flags from bits 0-4 of WD 2 of IOCD */
chp->chan_status = 0; /* clear status for next IOCD */
/* make a 24 bit address */
chp->ccw_addr = word1 & MASK24; /* set the data/seek address */
/* validate parts of IOCD2 that are reserved */
if (word2 & 0x07ff0000) { /* bits 5-15 must be zero */
chp->chan_status |= STATUS_PCHK; /* program check for invalid iocd */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl IOCD2 chan_status[%04x] %04x\n", chan, chp->chan_status);
return 1; /* error return */
}
/* DC can only be used with a read/write cmd */
if (chp->ccw_flags & FLAG_DC) {
if ((chp->ccw_cmd == EC_INCH) || (chp->ccw_cmd == EC_NOP) ||
(chp->ccw_cmd == EC_CGA) || (chp->ccw_cmd == EC_CSTATS)) {
chp->chan_status |= STATUS_PCHK; /* program check for invalid DC */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl DC ERROR chan_status[%04x] %04x\n", chan, chp->chan_status);
return 1; /* error return */
}
}
chp->chan_byte = BUFF_BUSY; /* busy & no bytes transferred yet */
sim_debug(DEBUG_XIO, dptr,
"ec_iocl @%06x read docmd %01x addr %06x count %04x chan %04x ccw_flags %04x\n",
chp->chan_caw, docmd, chp->ccw_addr, chp->ccw_count, chan, chp->ccw_flags);
if (docmd) { /* see if we need to process a command */
DIB *dibp = dib_unit[chp->chan_dev]; /* get the DIB pointer */
uptr = chp->unitptr; /* get the unit ptr */
if (dibp == 0 || uptr == 0) {
chp->chan_status |= STATUS_PCHK; /* program check if it is */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl bad dibp or uptr chan_status[%04x] %04x\n", chan, chp->chan_status);
return 1; /* if none, error */
}
sim_debug(DEBUG_XIO, dptr,
"ec_iocl @%06x before start_cmd chan %04x status %04x count %04x SNS %08x\n",
chp->chan_caw, chan, chp->chan_status, chp->ccw_count, uptr->SNS);
/* call the device startcmd function to process the current command */
/* just replace device status bits */
chp->chan_info &= ~INFO_CEND; /* show chan_end not called yet */
devstat = dibp->start_cmd(uptr, chan, chp->ccw_cmd);
chp->chan_status = (chp->chan_status & 0xff00) | devstat;
chp->chan_info &= ~INFO_SIOCD; /* show not first IOCD in channel prog */
sim_debug(DEBUG_XIO, dptr,
"ec_iocl @%06x after start_cmd chsa %04x status %08x count %04x SNS %08x\n",
chp->chan_caw, chsa, chp->chan_status, chp->ccw_count, uptr->SNS);
/* see if bad status */
if (chp->chan_status & (STATUS_ATTN|STATUS_ERROR)) {
chp->chan_status |= STATUS_CEND; /* channel end status */
chp->ccw_flags = 0; /* no flags */
chp->chan_byte = BUFF_NEXT; /* have main pick us up */
sim_debug(DEBUG_EXP, dptr,
"ec_iocl bad status chsa %04x status %04x cmd %02x\n",
chsa, chp->chan_status, chp->ccw_cmd);
/* done with command */
sim_debug(DEBUG_EXP, &cpu_dev,
"ec_iocl ERROR return chsa %04x status %08x\n",
chp->chan_dev, chp->chan_status);
return 1; /* error return */
}
/* NOTE this code needed for MPX 1.X to run! */
/* see if command completed */
/* we have good status */
if (chp->chan_status & (STATUS_DEND|STATUS_CEND)) {
uint16 chsa = GET_UADDR(uptr->u3); /* get channel & sub address */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND); /* show I/O complete */
sim_debug(DEBUG_XIO, dptr,
"ec_iocl @%06x FIFO #%1x cmd complete chan %04x status %04x count %04x\n",
chp->chan_caw, FIFO_Num(chsa), chan, chp->chan_status, chp->ccw_count);
}
}
/* the device processor returned OK (0), so wait for I/O to complete */
/* nothing happening, so return */
sim_debug(DEBUG_XIO, dptr,
"ec_iocl @%06x return, chsa %04x status %04x count %04x\n",
chp->chan_caw, chsa, chp->chan_status, chp->ccw_count);
return 0; /* good return */
}
/* start an ethernet operation */
t_stat ec_preio(UNIT *uptr, uint16 chan) {
DEVICE *dptr = get_dev(uptr);
int unit = (uptr - dptr->units);
uint16 chsa = GET_UADDR(uptr->CMD);
sim_debug(DEBUG_CMD, dptr, "ec_preio CMD %08x unit %02x chsa %04x\n",
uptr->CMD, unit, chsa);
if ((uptr->CMD & EC_CMDMSK) != 0) { /* just return if busy */
sim_debug(DEBUG_CMD, dptr,
"ec_preio unit %02x chsa %04x BUSY\n", unit, chsa);
return SNS_BSY;
}
sim_debug(DEBUG_CMD, dptr, "ec_preio CMD %08x unit %02x chsa %04x OK\n",
uptr->CMD, unit, chsa);
return SCPE_OK; /* good to go */
}
/* Start ethernet command */
t_stat ec_startcmd(UNIT *uptr, uint16 chan, uint8 cmd)
{
DEVICE *dptr = get_dev(uptr);
uint16 chsa = GET_UADDR(uptr->CMD);
CHANP *chp = find_chanp_ptr(chsa); /* find the chanp pointer */
sim_debug(DEBUG_CMD, dptr,
"ec_startcmd chsa %04x unit %d cmd %02x CMD %08x\n",
chsa, (int)(uptr - ec_unit), cmd, uptr->CMD);
if ((uptr->CMD & 0xff) != 0) { /* if any status info, we are busy */
sim_debug(DEBUG_CMD, dptr, "ec_startcmd busy\n");
return SNS_BSY;
}
uptr->CMD &= LMASK; /* remove old status bits & cmd */
/* Unit is online, so process a command */
switch (cmd) {
case EC_WRITE: /* Write command 0x01 */
uptr->CMD |= (cmd|EC_BUSY); /* save cmd */
// This works most of the time & stops at test 30 with no len errors
//Was sim_activate(uptr, 5000); /* start things off */
// This works most of the time
//GF sim_activate(uptr, 7500); /* start things off */
//JCB sim_activate_abs(uptr, 750); /* start things off */
sim_activate_abs(uptr, 750); /* start things off */
return 0;
case EC_INCH: /* INCH cmd 0x0 */
cmd = EC_INCH2; /* set dummy INCH cmd 0xf0 */
case EC_READ: /* Read command 0x02 */
case EC_TIC: /* Transfer in channel */
case EC_CGA: /* Disable multicast address */
case EC_LCC: /* Configure LCC 0x10 */
case EC_STATS: /* Read Statistics */
case EC_CSTATS: /* Clear software counters */
case EC_NOP: /* NOP 0x03 */
case EC_LIA: /* Load individual address */
case EC_LGA: /* Load Multicast address */
/* Fall through */
case EC_SNS: /* Sense 0x04 */
uptr->CMD |= cmd|EC_BUSY; /* save cmd */
//GF sim_activate(uptr, 150); /* start things off */
//JCB sim_activate_abs(uptr, 150); /* start things off */
sim_activate_abs(uptr, 750); /* start things off */
return 0;
}
uptr->SNS |= SNS_CMDREJ;
sim_debug(DEBUG_CMD, dptr, "ec_startcmd illegal3 cmd %02x SNS %08x\n",
cmd, uptr->SNS);
chp->ccw_count = 0; /* diags want zero count */
return SNS_CHNEND|SNS_DEVEND|SNS_UNITCHK; /* diags want unit check */
}
/* Handle processing of ethernet requests. */
t_stat ec_rec_srv(UNIT *uptr)
{
DEVICE *dptr = get_dev(uptr);
int cmd = uptr->CMD & EC_CMDMSK;
/* If not in loopback try and receive a packet */
if ((ec_data.conf[0] & 0x40) == 0) {
int q = (((ec_data.rec_ptr + 1) & LOOP_MSK) + LOOP_MSK + 1) - ec_data.xtr_ptr;
if (q > LOOP_MSK)
q -= (LOOP_MSK + 1);
if (eth_read(&ec_data.etherface, &ec_data.rec_buff[ec_data.rec_ptr], NULL) > 0) {
if (q > 716) {
ec_data.drop_cnt++;
sim_debug(DEBUG_DETAIL, dptr,
"ec_rec_srv received packet %08x dropped %08x\n",
ec_data.rx_count, ec_data.drop_cnt);
} else {
ec_data.rec_ptr = (ec_data.rec_ptr + 1) & LOOP_MSK;
ec_data.rx_count++;
sim_debug(DEBUG_DETAIL, dptr,
"ec_rec_srv received packet %08x\n", ec_data.rx_count);
}
}
}
/* If there is a command on this subchannel, do it */
if (cmd != 0)
return ec_srv(uptr);
return SCPE_OK;
}
/* Handle processing of ethernet requests. */
t_stat ec_srv(UNIT *uptr)
{
uint16 chsa = GET_UADDR(uptr->CMD);
DEVICE *dptr = get_dev(uptr);
CHANP *chp = find_chanp_ptr(chsa); /* get channel prog pointer */
int cmd = uptr->CMD & EC_CMDMSK;
uint32 mema;
int i, pktlen;
int n, len;
int pirq, cnt, dcnt;
uint8 ch;
uint8 buf[1520];
uint8 *pck;
struct ec_eth_hdr *hdr;
DIB *pdibp = dib_chan[get_chan(chsa)]; /* channel DIB */
CHANP *pchp = pdibp->chan_prg; /* get channel chp */
sim_debug(DEBUG_CMD, dptr,
"ec_srv chp %p cmd=%02x chsa %04x count %04x SNS %08x\n",
chp, cmd, chsa, chp->ccw_count, uptr->SNS);
switch (cmd) {
// case EC_INCH: /* 0x00 INCH cmd */
case EC_INCH2: /* 0xF0 INCH cmd */
len = chp->ccw_count; /* INCH command count */
mema = chp->ccw_addr; /* get inch or buffer addr */
sim_debug(DEBUG_CMD, dptr,
"ec_srv starting INCH %06x cmd, chsa %04x addr %06x cnt %04x\n",
pchp->chan_inch_addr, chsa, chp->ccw_addr, chp->ccw_count);
/* now call set_inch() function to write and test inch buffer addresses */
/* Ethernet uses 1 dbl wd */
i = set_inch(uptr, mema, 1); /* new address */
ec_ini(uptr, 0);
if ((i == SCPE_MEM) || (i == SCPE_ARG)) { /* any error */
/* we have error, bail out */
uptr->SNS |= SNS_CMDREJ|SNS_EQUCHK;
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|SNS_UNITCHK);
break;
}
for (i=0; i < len; i++) {
if (chan_read_byte(chsa, &buf[i])) {
/* we have error, bail out */
uptr->SNS |= SNS_CMDREJ|SNS_EQUCHK;
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|SNS_UNITCHK);
break;
}
/* just dump data */
}
chan_end(chsa, SNS_CHNEND|SNS_DEVEND);
break;
case EC_LIA: /* 0x07 Load individual address */
uptr->CMD &= LMASK; /* remove old status bits & cmd */
for (i = 0; i < sizeof (ETH_MAC); i++) {
if (chan_read_byte(chsa, &buf[i])) {
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|SNS_UNITCHK);
return SCPE_OK;
}
}
memcpy(&ec_data.mac, &buf[0], sizeof (ETH_MAC));
eth_mac_fmt(&ec_data.mac, (char *)&buf[0]);
sim_debug(DEBUG_CMD, dptr, "ec_srv setting mac %s\n", buf);
n = ec_data.macs_n + 2;
memcpy(&ec_data.macs[0], &ec_data.mac, sizeof (ETH_MAC));
memcpy(&ec_data.macs[1], &broadcast_ethaddr, sizeof (ETH_MAC));
if (ec_master_uptr->flags & UNIT_ATT)
/* set promiscuous if bit 7 of byte zero of mac address is set */
eth_filter (&ec_data.etherface, n, ec_data.macs, ec_data.amc,
ec_data.macs[0][0] & 1);
chan_end(chsa, SNS_CHNEND|SNS_DEVEND);
break;
case EC_CGA: /* 0x0B Disable multicast address */
uptr->CMD &= LMASK; /* remove old status bits & cmd */
ec_data.macs_n = 0;
ec_data.amc = 0;
if (ec_master_uptr->flags & UNIT_ATT)
eth_filter (&ec_data.etherface, 2, ec_data.macs, ec_data.amc,
ec_data.macs[0][0] & 1);
if (chan_read_byte(chsa, &ch))
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|SNS_UNITCHK);
else
chan_end(chsa, SNS_CHNEND|SNS_DEVEND);
break;
case EC_LGA: /* 0x0F Load Multicast address */
uptr->CMD &= LMASK; /* remove old status bits & cmd */
ec_data.macs_n = 0;
len = 2;
for (n = 2; n < (int)(sizeof(ec_data.macs) / sizeof (ETH_MAC)); n++) {
for (i = 0; i < sizeof (ETH_MAC); i++) {
if (chan_read_byte(chsa, &buf[i])) {
break;
}
}
if (i != sizeof (ETH_MAC))
break;
memcpy(&ec_data.macs[len++], &buf[0], sizeof (ETH_MAC));
}
ec_data.macs_n = len - 2;
ec_data.amc = 1;
for (i = 0; i< len; i++) {
eth_mac_fmt(&ec_data.macs[i], (char *)&buf[0]);
sim_debug(DEBUG_DETAIL, &ec_dev, "ec_srv load mcast%d: %s\n",i,buf);
}
if (ec_master_uptr->flags & UNIT_ATT)
/* multicast on means promiscous is too */
eth_filter (&ec_data.etherface, n, ec_data.macs, ec_data.amc,
ec_data.macs[0][0] & 1);
chan_end(chsa, SNS_CHNEND|SNS_DEVEND);
break;
case EC_WRITE: /* 0x01 Write command */
/* get queue length */
n = (((ec_data.rec_ptr) & LOOP_MSK) + LOOP_MSK + 1) - ec_data.xtr_ptr;
if (n >LOOP_MSK)
n -= (LOOP_MSK + 1);
len = sizeof(struct ec_eth_hdr); /* std header size /dest/src/len/ (14) */
pirq = 0;
uptr->CMD &= LMASK; /* remove old status bits & cmd */
i = GET_MODE(ec_master_uptr->flags); /* get the mode setting */
sim_debug(DEBUG_DETAIL, dptr, "ec_srv START %04x mode %d write %d %d conf=%d cnt 0x%x q %d\n",
chsa, i, ec_data.xtr_ptr, ec_data.rec_ptr, ec_data.conf[9], chp->ccw_count, n);
hdr = (struct ec_eth_hdr *)(&ec_data.snd_buff.msg[0]);
pck = (uint8 *)(&ec_data.snd_buff.msg[0]);
uptr->SNS &= LMASK; /* remove old count */
pktlen = 0;
/* create packet: destination(6)/source(6)/type(2) or len(2)/ data 46-1500 */
switch (GET_MODE(ec_master_uptr->flags)) {
case 0:
/* user buffer has /dest(6)/src(6)/type(2) or len(2)/ data/ */
/* create packet: destination(6)/source(6)/type(2) or len(2)/ data 46-1500 */
/* copy users header unchanged */
for (i = 0; i < sizeof(struct ec_eth_hdr); i++) {
if (chan_read_byte(chsa, &pck[i])) {
pirq = 1;
n = i;
sim_debug(DEBUG_DETAIL, dptr, "rw_end case 0 error 0\n");
goto wr_end;
}
}
/* set transfer count of standard header supplied */
uptr->SNS |= (sizeof(struct ec_eth_hdr) & 0xffff); /* set transfer count (14) */
/* copy in user supplied packet data */
/* make min cnt 60 and max 1514 */
i = sizeof(struct ec_eth_hdr); /* dest/src/len 14 bytes */
while (chan_read_byte(chsa, &ch) == 0) {
if (i < ETH_MAX_PACKET) {
if (i>6 && i<28) /* only display char 7-27 */
sim_debug(DEBUG_DATA, dptr, "ec_srv data[%2x]: %06x %02x\n",
i, chp->ccw_addr, ch);
pck[i] = ch;
if (i == len + 2)
pktlen = pck[i] << 8; /* 1st 1/2 of user data len without ethernet header */
if (i == len + 3)
pktlen |= pck[i]; /* 2nd 1/2 of user data len without ethernet header */
}
i++;
uptr->SNS++; /* set count */
/* set correct packet count or ICMP and ARP response packet */
if (((chsa & 0xff) == 6) && (i > (len+3))) {/* make sure we have pkt len read in */
if (ntohs(hdr->type) == ETHTYPE_IP) { /* make sure IP packet */
if (i >= (pktlen+len)) /* see if all of data sent */
break; /* only transfer actual data */
} else
if (ntohs(hdr->type) == ETHTYPE_ARP) { /* make sure ARP packet */
if (i >= (46+len)) /* see if 60 byte packet present */
break; /* only transfer actual data */
}
}
}
sim_debug(DEBUG_DETAIL, dptr,
"ec_srv case 0 transmit bytes %d (0x%x) SNS %08x pktlen 0x%x\n",
len, len, uptr->SNS, pktlen);
break;
case 1:
case 2:
/* user buffer has /dest(6)/type(2)/data(46-1500)/ */
/* create packet: destination(6)/source(6)/type(2) or len(2)/ data 46-1500 */
/* copy in user dest/type/data */
/* get 6 byte destination from user */
for (i = 0; i < sizeof(ETH_MAC); i++) {
if (chan_read_byte(chsa, &pck[i])) {
pirq = 1;
n = i;
sim_debug(DEBUG_DETAIL, dptr, "rw_end case 1&2 error 0\n");
goto wr_end;
}
}
/* insert 6 byte source from configuration */
memcpy(&hdr->src, ec_data.mac, sizeof(ETH_MAC));
/* copy two byte type/len from user buffer */
for (i = sizeof(ETH_MAC) * 2; i < sizeof(struct ec_eth_hdr); i++) {
if (chan_read_byte(chsa, &pck[i])) {
pirq = 1;
n = i;
sim_debug(DEBUG_DETAIL, dptr, "rw_end case 1&2 error 2\n");
goto wr_end;
}
}
/* set transfer count of user bytes supplied dest(6)/type(2) */
uptr->SNS |= ((sizeof(struct ec_eth_hdr) - sizeof(ETH_MAC)) & 0xffff);
/* copy in user supplied packet data */
/* make min cnt 60 and max 1514 */
i = sizeof(struct ec_eth_hdr); /* dest/src/len 14 bytes */
while (chan_read_byte(chsa, &ch) == 0) {
if (i < ETH_MAX_PACKET) {
if (i>6 && i<28) /* only display char 7-27 */
sim_debug(DEBUG_DATA, dptr, "ec_srv data[%2x]: %06x %02x\n",
i, chp->ccw_addr, ch);
pck[i] = ch;
if (i == (len+2))
pktlen = pck[i] << 8; /* 1st 1/2 of user data len without ethernet header */
if (i == (len+3))
pktlen |= pck[i]; /* 2nd 1/2 of user data len without ethernet header */
}
i++;
uptr->SNS++; /* set count */
/* set correct packet count or ICMP and ARP response packet */
if (((chsa & 0xff) == 6) && (i > (len+3))) {/* make sure we have pkt len read in */
if (ntohs(hdr->type) == ETHTYPE_IP) { /* make sure IP packet */
if (i >= (pktlen+len)) /* see if all of data sent */
break; /* only transfer actual data */
} else
if (ntohs(hdr->type) == ETHTYPE_ARP) { /* make sure ARP packet */
if (i >= (46+len)) /* see if 60 byte packet present */
break; /* only transfer actual data */
}
}
}
sim_debug(DEBUG_DETAIL, dptr,
"ec_srv case 1&2 transmit bytes %d (0x%x) SNS %08x i 0x%x pktlen 0x%x\n",
len-6, len-6, uptr->SNS, i, pktlen);
/* This code is to simulate word transfers into memory */
/* from the users buffer. 1-3 extra bytes are placed */
/* into the buffer. Diags in test 20 checks for this data */
/* being present. These were set to 0 by the old code */
/* and diags would complain 11/11/2021 */
/* save data count */
dcnt = i - sizeof(struct ec_eth_hdr); /* dest/src/len 14 bytes */
n = 0;
while (dcnt++ % 4) {
pck[i+n] = RMB(((chp->ccw_addr+n)));
sim_debug(DEBUG_DATA, dptr, "ec_srx i %x data[%3x]: %06x %02x\n",
i, i+n, chp->ccw_addr+n, pck[i+n]);
n++;
}
n = n + i; /* last written char in buffer */
break;
case 3:
/* user buffer has /dest(6)/data(46-1500)/ */
/* create packet: destination(6)/source(6)/type(2) or len(2)/ data 46-1500 */
/* copy destination(6) from user buffer */
for (i = 0; i < sizeof(ETH_MAC); i++) {
if (chan_read_byte(chsa, &pck[i])) {
pirq = 1;
n = i;
sim_debug(DEBUG_DETAIL, dptr, "rw_end case 3 error 0\n");
goto wr_end;
}
}
/* insert source(6) */
memcpy(&hdr->src, ec_data.mac, sizeof(ETH_MAC));
//#define USE_DATA_CNT
#ifdef USE_DATA_CNT
/* insert type(2) */
hdr->type = htons(ETHTYPE_IP);
#endif
/* set transfer count of user bytes supplied */
uptr->SNS |= ((sizeof(struct ec_eth_hdr) -
sizeof(ETH_MAC) - sizeof(int16)) & 0xffff);
/* copy in user supplied packet data */
/* make min cnt 60 and max 1514 */
i = sizeof(struct ec_eth_hdr); /* dest/src/len 14 bytes */
cnt = 0;
while (chan_read_byte(chsa, &ch) == 0) {
if (i < ETH_MAX_PACKET) {
if (i>6 && i<28)
sim_debug(DEBUG_DATA, dptr, "ec_srv data[%3x]: %06x %02x\n",
i, chp->ccw_addr, ch);
pck[i] = ch;
if (i == len + 2)
pktlen = pck[i] << 8; /* 1st 1/2 of user data len without ethernet header */
if (i == len + 3)
pktlen |= pck[i]; /* 2nd 1/2 of user data len without ethernet header */
}
i++;
uptr->SNS++; /* set count */
#ifndef USE_DATA_CNT
cnt++; /* user data count */
#endif
/* set correct packet count or ICMP and ARP response packet */
if (((chsa & 0xff) == 6) && (i > (len+3))) {/* make sure we have pkt len read in */
if (ntohs(hdr->type) == ETHTYPE_IP) { /* make sure IP packet */
if (i >= (pktlen+len)) /* see if all of data sent */
break; /* only transfer actual data */
} else
if (ntohs(hdr->type) == ETHTYPE_ARP) { /* make sure ARP packet */
if (i >= (46+len)) /* see if 60 byte packet present */
break; /* only transfer actual data */
}
}
}
#ifndef USE_DATA_CNT
/* insert type(2) */
// hdr->type = htons(ETHTYPE_IP);
hdr->type = htons(cnt); /* set cnt into type/count field */
#endif
sim_debug(DEBUG_DETAIL, dptr,
"ec_srv case 3 transmit bytes %d (0x%x) SNS %08x i 0x%x cnt %x pktlen 0x%x\n",
len-8, len-8, uptr->SNS, i, cnt, pktlen);
/* This code is to simulate word transfers into memory */
/* from the users buffer. 1-3 extra bytes are placed */
/* into the buffer. Diags in test 20 check for this data */
/* being present. These were set to 0 by the old code */
/* and diags would complain 11/11/2021 */
/* save data count */
dcnt = i - sizeof(struct ec_eth_hdr); /* dest/src/len 14 bytes */
n = 0;
while (dcnt++ % 4) {
pck[i+n] = RMB(((chp->ccw_addr+n)));
sim_debug(DEBUG_DATA, dptr, "ec_srx i %x data[%3x]: %06x %02x\n",
i, i+n, chp->ccw_addr+n, pck[i+n]);
n++;
}
n = n + i; /* last written char in buffer */
break;
}
wr_end:
ec_data.snd_buff.len = i; /* set actual count */
ec_packet_debug(&ec_data, "send", &ec_data.snd_buff);
sim_debug(DEBUG_DETAIL, dptr,
"ec_srv @wr_end count 0x%x i 0x%04x SNS 0x%04x pktlen 0x%x type 0x%x\n",
chp->ccw_count, i, uptr->SNS, pktlen, ntohs(hdr->type));
/* make sure packet is minimum size for mode 1,2 & 3 */
/* when handling non-loopback packets */
if ((ec_data.snd_buff.len < ec_data.conf[9]) &&
GET_MODE(ec_master_uptr->flags)) {
/* If not in loopback, pad packet */
if (((ec_data.conf[0] & 0x40) == 0) ||
/* this fixes test 20 for mode 3 */
(GET_MODE(ec_master_uptr->flags) != 3)) {
/* Pad the packet */
while (i < ETH_MIN_PACKET) {
ec_data.snd_buff.len++; /* increment actual count */
pck[n++] = 0;
i++;
}
}
sim_debug(DEBUG_DETAIL, dptr,
"ec_srv @wr_end2 count 0x%x i 0x%04x n 0x%04x SNS 0x%04x\n",
chp->ccw_count, i, n, uptr->SNS);
if (i <= ETH_MIN_PACKET) {
ec_packet_debug(&ec_data, "send", &ec_data.snd_buff);
}
}
/* see if too many bytes, did not get channel end before packet filled */
if (ec_data.snd_buff.len > ETH_MAX_PACKET) {
sim_debug(DEBUG_DETAIL, dptr,
"ec_srv WRITE error user 2manybytes %0x\n", chp->ccw_count);
/* diags wants prog check instead of length check test 4E */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|STATUS_PCHK);
break;
}
ec_data.tx_count++;
if (ec_data.conf[0] & 0x40) { /* see if internal loopback */
/* yes loopback, buffer the packet */
int q = (((ec_data.rec_ptr + 1) & LOOP_MSK) + LOOP_MSK + 1) - ec_data.xtr_ptr;
if (q >LOOP_MSK)
q -= (LOOP_MSK + 1);
if (q > 716) {
ec_data.drop_cnt++;
sim_debug(DEBUG_DETAIL, dptr, "ec_srv write packet dropped %d q %d\n",
ec_data.drop_cnt, q);
} else {
memcpy(&ec_data.rec_buff[ec_data.rec_ptr],
&ec_data.snd_buff, sizeof(ETH_PACK));
ec_data.rec_ptr = (ec_data.rec_ptr + 1) & LOOP_MSK;
sim_debug(DEBUG_DETAIL, dptr, "ec_srv WRITE rec queued %d xtr %d queue %04x\n",
ec_data.rec_ptr, ec_data.xtr_ptr, q);
}
}
/* check for internal loopback */
if ((ec_data.conf[0] & 0x40) == 0) {
/* not internal loopback, user wants to write to network */
/* check if attached, if not give no carrier and unit exception */
if ((ec_master_uptr->flags & UNIT_ATT) == 0) {
sim_debug(DEBUG_EXP, dptr,
"EC write device %s not attached on unit EC%04X\n",
dptr->name, GET_UADDR(uptr->CMD));
uptr->SNS |= SNS_NO_CAR; /* no carrier error */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|STATUS_EXPT);
break;
}
/* no loopback, write out the packet */
if (eth_write(&ec_data.etherface, &ec_data.snd_buff, NULL) != SCPE_OK) {
sim_debug(DEBUG_DETAIL, dptr, "ec_srv short packet %d\n", i);
/* diags wants prog check instead of unit check */
pirq = 1;
}
}
sim_debug(DEBUG_DETAIL, dptr,
"ec_srv sent packet pirq %d 0x%x bytes tx_count=%08x SNS %08x\n",
pirq, ec_data.snd_buff.len, ec_data.tx_count, uptr->SNS);
if (pirq)
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|STATUS_PCHK);
else {
chan_end(chsa, SNS_CHNEND|SNS_DEVEND);
}
break;
case EC_READ: /* 0x02 Read command */
/* If no data to receive wait for some more */
if (ec_data.xtr_ptr == ec_data.rec_ptr) {
// sim_debug(DEBUG_DETAIL, &ec_dev, "ec_srv WAIT %04x read %d %d size=%d cnt %d\n",
// chsa, ec_data.xtr_ptr, ec_data.rec_ptr, ec_data.conf[9], chp->ccw_count);
/* this is really a 50000 cnt poll by simh */
//GF sim_clock_coschedule(uptr, 1000); /* continue poll */
//JCB sim_activate_abs(uptr, 2000); /* continue poll */
sim_activate_abs(uptr, 6000); /* continue poll */
return SCPE_OK;
}
/* get queue length */
n = (((ec_data.rec_ptr) & LOOP_MSK) + LOOP_MSK + 1) - ec_data.xtr_ptr;
if (n > LOOP_MSK)
n -= (LOOP_MSK + 1);
pirq = 0;
i = GET_MODE(ec_master_uptr->flags); /* get the mode setting */
sim_debug(DEBUG_DETAIL, &ec_dev, "ec_srv START %04x mode %d read %d %d conf=%d cnt %d q %d\n",
chsa, i, ec_data.xtr_ptr, ec_data.rec_ptr, ec_data.conf[9], chp->ccw_count, n);
uptr->CMD &= LMASK; /* remove old status bits & cnt */
/* Read must be word bounded */
if (chp->ccw_addr & 0x3) {
sim_debug(DEBUG_EXP, dptr,
"ec_srv iocd bad address caw %06x ccw %06x\n",
chp->chan_caw, chp->ccw_addr);
ec_data.xtr_ptr = (ec_data.xtr_ptr + 1) & LOOP_MSK;
chp->ccw_count = 0;
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|STATUS_LENGTH|STATUS_PCHK);
break;
}
uptr->SNS &= LMASK; /* remove old count */
ec_master_uptr->SNS |= SNS_RCV_RDY;
ec_packet_debug(&ec_data, "recv", &ec_data.rec_buff[ec_data.xtr_ptr]);
pck = (uint8 *)(&ec_data.rec_buff[ec_data.xtr_ptr].msg[0]);
len = (int)(ec_data.rec_buff[ec_data.xtr_ptr].len);
n = sizeof(struct ec_eth_hdr);
cnt = len - n; /* number of data bytes */
sim_debug(DEBUG_DETAIL, &ec_dev, "ec_srv READ addr %06x pktlen 0x%x rdcnt 0x%x conf 0x%x cnt 0x%x\n",
chp->ccw_addr, len, chp->ccw_count, ec_data.conf[9], cnt);
switch (GET_MODE(ec_master_uptr->flags)) {
case 0:
/* create output: destination(6)/source(6)/type(2) or len(2)/ data 46-1500 */
/* user buffer: destination(6)/source(6)/type(2) or len)2) */
for (i = 0; i < sizeof(struct ec_eth_hdr); i++) {
if (chan_write_byte(chsa, &pck[i])) {
pirq = 1;
break;
}
}
uptr->SNS |= (len & 0xffff); /* set real transfer count */
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_srv case 0 received bytes %d (0x%x) SNS %08x i 0x%x cnt 0x%x\n",
len, len, uptr->SNS, i, cnt);
break;
case 1:
case 2:
/* create output: destination(6)/len(2)/source(6)/type(2) or len(2)/ data 46-1500 */
/* destination / len / source / type or len */
/* copy 6 byte destination */
for (i = 0; i < sizeof(ETH_MAC); i++) {
if (chan_write_byte(chsa, &pck[i])) {
pirq = 1;
break;
}
}
/* insert length byte 1 */
ch = (len >> 8) & 0xff;
if (chan_write_byte(chsa, &ch)) {
pirq = 1;
break;
}
/* insert length byte 2 */
ch = len & 0xff;
if (chan_write_byte(chsa, &ch)) {
pirq = 1;
break;
}
/* copy in source(6)/type(2) 6 + 2 = 8 = 14 - 6 */
for (; i < sizeof(struct ec_eth_hdr); i++) {
if (chan_write_byte(chsa, &pck[i])) {
pirq = 1;
break;
}
if (i>5)
sim_debug(DEBUG_DATA, &ec_dev, "ec_srr pck[%3x]: %02x\n", i, pck[i]);
}
uptr->SNS |= ((len+2) & 0xffff); /* set real transfer count */
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_srv case 1&2 received bytes %d (0x%x) SNS %08x i 0x%x cnt 0x%x\n",
len, len, uptr->SNS, i, cnt);
break;
case 3:
/* create output: destination(6)/len(2)/source(6)/len(2)/ data 46-1500 */
/* copy 6 byte destination */
for (i = 0; i < sizeof(ETH_MAC); i++) {
if (chan_write_byte(chsa, &pck[i])) {
pirq = 1;
break;
}
}
/* insert length byte 1 */
ch = (len >> 8) & 0xff;
if (chan_write_byte(chsa, &ch)) {
pirq = 1;
break;
}
/* insert length byte 2 */
ch = len & 0xff;
if (chan_write_byte(chsa, &ch)) {
pirq = 1;
break;
}
/* copy in 6 byte source */
for (; i < sizeof(ETH_MAC) * 2; i++) {
if (chan_write_byte(chsa, &pck[i])) {
pirq = 1;
break;
}
if (i>5)
sim_debug(DEBUG_DATA, &ec_dev, "ec_srr pck[%3x]: %02x\n", i, pck[i]);
}
/* insert length byte 1 */
ch = (len >> 8) & 0xff;
if (chan_write_byte(chsa, &ch)) {
pirq = 1;
break;
}
/* insert length byte 2 */
ch = len & 0xff;
if (chan_write_byte(chsa, &ch)) {
pirq = 1;
break;
}
uptr->SNS |= ((len + 2) & 0xffff); /* set real transfer count */
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_srv case 3 received bytes %d (0x%x) SNS %08x i 0x%x cnt 0x%x\n",
len, len, uptr->SNS, i, cnt);
break;
}
/* see if user did not request enough data */
i = sizeof(struct ec_eth_hdr);
if (pirq || (i >= len)) {
ec_data.xtr_ptr = (ec_data.xtr_ptr + 1) & LOOP_MSK;
ec_data.rx_count++;
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_srv0 pirq %d cnt %x received bytes %d of %d rx_count=%08x conf %x\n",
pirq, cnt, i, len, ec_data.rx_count, ec_data.conf[9]);
/* diag wants incorrect length error */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|STATUS_LENGTH);
break;
}
/* now copy in the user data */
for (i = sizeof(struct ec_eth_hdr); i < len; i++) {
if (i > (len - 8))
sim_debug(DEBUG_DETAIL, &ec_dev, "ec_sww pck[%3x]: %02x %02x\n", i, pck[i], chp->ccw_count);
if (chan_write_byte(chsa, &pck[i])) {
/* we read less than or exact bytes, good to go */
ec_data.xtr_ptr = (ec_data.xtr_ptr + 1) & LOOP_MSK;
ec_data.rx_count++;
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_srv1 left 0x%x rec'd 0x%x bytes rx_count %08x conf %02x SNS %08x\n",
chp->ccw_count, len, ec_data.rx_count, ec_data.conf[9], uptr->SNS);
/* diag wants incorrect length error */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|STATUS_LENGTH);
sim_debug(DEBUG_DETAIL, dptr,
"ec_srv done cmd=%02x chsa %04x addr %06x count %04x SNS 0x%08x stat %04x\n",
cmd, chsa, chp->ccw_addr, chp->ccw_count, uptr->SNS, chp->chan_status);
return SCPE_OK;
}
}
/* we have some bytes left, set count mismatch */
chp->ccw_flags |= FLAG_SLI;
ec_data.xtr_ptr = (ec_data.xtr_ptr + 1) & LOOP_MSK;
ec_data.rx_count++;
sim_debug(DEBUG_DETAIL, &ec_dev,
"ec_srv2 left 0x%x rec'd 0x%x bytes rx_count %08x conf %02x SNS %08x\n",
chp->ccw_count, len, ec_data.rx_count, ec_data.conf[9], uptr->SNS);
/* diag does not want incorrect length error */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND);
break;
case EC_LCC: /* 0x10 Configure LCC */
uptr->CMD &= LMASK; /* remove old status bits & cmd */
/* Read up to 12 bytes of configuration data */
for (i = 0; i < 12; i++) {
if (chan_read_byte(chsa, &ec_data.conf[i])) {
break;
}
}
sim_debug(DEBUG_CMD, &ec_dev,
"ec_srv LCC CONF: %02x%02x%02x%02x %02x%02x%02x%02x %02x%02x%02x%02x\n",
ec_data.conf[0], ec_data.conf[1], ec_data.conf[2], ec_data.conf[3],
ec_data.conf[4], ec_data.conf[5], ec_data.conf[6], ec_data.conf[7],
ec_data.conf[8], ec_data.conf[9], ec_data.conf[10], ec_data.conf[11]);
chan_end(chsa, SNS_CHNEND|SNS_DEVEND);
break;
case EC_STATS: /* 0x14 Read Statistics */
ch = 0;
/* First 5 words are always zero since these errors are not supported */
uptr->CMD &= LMASK; /* remove old status bits & cmd */
sim_debug(DEBUG_DETAIL, dptr, "ec_srv stats drop_count %08x\n", ec_data.drop_cnt);
for (i = 0; i < STAT_LEN * 2; i++) {
if (i == 6)
ch = (ec_data.drop_cnt >> 8) & 0xff;
if (i == 7)
ch = ec_data.drop_cnt & 0xff;
if (i == 8)
ch = 0;
if (chan_write_byte(chsa, &ch)) {
break;
}
}
sim_debug(DEBUG_DETAIL, dptr, "ec_srv stats rx_count %08x\n", ec_data.rx_count);
ch = (ec_data.rx_count >> 24) & 0xff;
chan_write_byte(chsa, &ch);
ch = (ec_data.rx_count >> 16) & 0xff;
chan_write_byte(chsa, &ch);
ch = (ec_data.rx_count >> 8) & 0xff;
chan_write_byte(chsa, &ch);
ch = ec_data.rx_count & 0xff;
chan_write_byte(chsa, &ch);
sim_debug(DEBUG_DETAIL, dptr, "ec_srv stats tx_count %08x\n", ec_data.tx_count);
ch = (ec_data.tx_count >> 24) & 0xff;
chan_write_byte(chsa, &ch);
ch = (ec_data.tx_count >> 16) & 0xff;
chan_write_byte(chsa, &ch);
ch = (ec_data.tx_count >> 8) & 0xff;
chan_write_byte(chsa, &ch);
ch = ec_data.tx_count & 0xff;
chan_write_byte(chsa, &ch);
chan_end(chsa, SNS_CHNEND|SNS_DEVEND);
break;
case EC_CSTATS: /* 0x15 Clear software counters */
uptr->CMD &= LMASK; /* remove old status bits & cmd */
ec_data.rx_count = ec_data.tx_count = 0;
(void)chan_read_byte(chsa, &ch);
sim_debug(DEBUG_CMD, dptr,
"ec_srv cmd clear counters chsa %04x count %04x completed\n",
chsa, chp->ccw_count);
chan_end(chsa, SNS_CHNEND|SNS_DEVEND);
break;
case EC_NOP: /* 0x03 NOP */
uptr->CMD &= LMASK; /* remove old status bits & cmd */
sim_debug(DEBUG_CMD, dptr,
"ec_srv cmd NOP chsa %04x count %04x completed\n",
chsa, chp->ccw_count);
/* diags want the count to be returned zero */
chp->ccw_count = 0; /* NOP command count */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND); /* return OK */
break;
case EC_SNS: /* 0x04 Sense */
sim_debug(DEBUG_CMD, dptr,
"ec_startcmd CMD sense cnt %02x\n", chp->ccw_count);
uptr->CMD &= LMASK; /* remove old status bits & cmd */
/* diags want incorrect length or prog check */
if (chp->ccw_count < 0x04) {
chp->ccw_count = 0; /* zero command count */
if ((chp->ccw_flags & FLAG_SLI) == 0) {
/* diag wants incorrect length */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|STATUS_LENGTH);
break;
}
}
len = uptr->SNS & 0xffff;
sim_debug(DEBUG_DETAIL, &ec_dev, "ec_srv SNS len %d xt %d rd %d\n",
len, ec_data.xtr_ptr, ec_data.rec_ptr);
ch = (uptr->SNS >> 24) & 0xfc;
ch |= GET_MODE(ec_master_uptr->flags);
sim_debug(DEBUG_DETAIL, dptr, "ec_srv sense b0 1 %02x\n", ch);
chan_write_byte(chsa, &ch);
ch = (ec_master_uptr->SNS >> 16) & 0xff;
sim_debug(DEBUG_DETAIL, dptr, "ec_srv sense b1 2 %02x\n", ch);
chan_write_byte(chsa, &ch);
ch = (len >> 8) & 0xff;
sim_debug(DEBUG_DETAIL, dptr, "ec_srv sense b2 3 %02x\n", ch);
chan_write_byte(chsa, &ch);
ch = len & 0xff;
sim_debug(DEBUG_DETAIL, dptr, "ec_srv sense b3 4 %02x\n", ch);
chan_write_byte(chsa, &ch);
if (chp->ccw_count > 0) {
if (chp->ccw_flags & FLAG_SLI)
/* diags want prog check */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|STATUS_PCHK);
else
/* diag wants incorrect length */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|STATUS_LENGTH);
sim_debug(DEBUG_CMD, dptr,
"ec_startcmd CMD sense excess cnt %02x\n", chp->ccw_count);
break;
}
uptr->SNS = 0; /* clear old status */
uptr->SNS &= LMASK; /* remove old count */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND); /* done */
break;
default:
sim_debug(DEBUG_CMD, dptr, "invalid command %02x\n", cmd);
uptr->SNS |= SNS_CMDREJ;
uptr->CMD &= LMASK; /* remove old status bits & cmd */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND|SNS_UNITCHK);
}
sim_debug(DEBUG_DETAIL, dptr,
"ec_srv done cmd=%02x chsa %04x count %04x addr %06x flags %04x stat %x SNS 0x%x\n",
cmd, chsa, chp->ccw_count, chp->ccw_addr, chp->ccw_flags, chp->chan_status, uptr->SNS);
return SCPE_OK;
}
/* Handle haltio transfers for ethernet */
t_stat ec_haltio(UNIT *uptr) {
uint16 chsa = GET_UADDR(uptr->CMD);
DEVICE *dptr = get_dev(uptr);
int cmd = uptr->CMD & EC_CMDMSK;
CHANP *chp = find_chanp_ptr(chsa); /* find the chanp pointer */
sim_debug(DEBUG_EXP, dptr, "ec_haltio enter chsa %04x chp %p cmd %02x\n", chsa, chp, cmd);
/* terminate any input command */
/* UTX wants SLI bit, but no unit exception */
/* status must not have an error bit set */
/* otherwise, UTX will panic with "bad status" */
if ((uptr->CMD & EC_CMDMSK) != 0) { /* is unit busy */
sim_debug(DEBUG_CMD, dptr,
"ec_haltio HIO chsa %04x cmd = %02x ccw_count %02x\n", chsa, cmd, chp->ccw_count);
// stop any I/O and post status and return error status */
if (chsa & 0x0f) /* no cancel for 0 */
sim_cancel(uptr); /* clear the output timer */
chp->ccw_count = 0; /* zero the count */
chp->ccw_flags &= ~(FLAG_DC|FLAG_CC); /* stop any chaining */
uptr->CMD &= LMASK; /* make non-busy */
uptr->SNS = SNS_RCV_RDY; /* status is online & ready */
sim_debug(DEBUG_CMD, dptr,
"ec_haltio HIO I/O stop chsa %04x cmd = %02x\n", chsa, cmd);
/* No unit exception status for ethernet */
chan_end(chsa, SNS_CHNEND|SNS_DEVEND); /* force end */
return CC1BIT | SCPE_IOERR;
}
sim_debug(DEBUG_CMD, dptr,
"ec_haltio HIO I/O not busy chsa %04x cmd = %02x\n", chsa, cmd);
uptr->CMD &= LMASK; /* make non-busy */
uptr->SNS = SNS_RCV_RDY; /* status is online & ready */
return CC1BIT | SCPE_OK; /* not busy */
}
/* initialize the ethernet */
void ec_ini(UNIT *uptr, t_bool f)
{
DEVICE *dptr = get_dev(uptr);
uptr->CMD &= LMASK; /* remove old status bits & cmd */
uptr->SNS = 0; /* save mode value */
memset(&ec_data.conf[0], 0, sizeof(ec_data.conf));
ec_data.macs_n = 0;
ec_data.tx_count = 0;
ec_data.rx_count = 0;
ec_data.rec_ptr = 0;
ec_data.xtr_ptr = 0;
ec_data.drop_cnt = 0;
ec_data.amc = 0;
if (ec_master_uptr->flags & UNIT_ATT) {
/* multicast on means promiscous is too */
eth_filter (&ec_data.etherface, ec_data.macs_n + 2, ec_data.macs,
ec_data.amc, ec_data.macs[0][0] & 1);
sim_debug(DEBUG_EXP, dptr,
"EC init device %s is attached on unit EC%04X\n",
dptr->name, GET_UADDR(uptr->CMD));
} else {
sim_debug(DEBUG_EXP, dptr,
"EC init device %s not attached on unit EC%04X\n",
dptr->name, GET_UADDR(uptr->CMD));
}
}
/* handle reset controller cmds for Ethernet */
t_stat ec_rsctrl(UNIT *uptr) {
DEVICE *dptr = get_dev(uptr);
uint16 chsa = GET_UADDR(uptr->CMD);
int cmd = uptr->CMD & EC_CMDMSK;
/*JCB*/ uptr->CMD &= LMASK; /* remove old status bits & cmd */
/*JCB*/ uptr->SNS = 0; /* clear mode value */
/* This change causes test 17 to fail in diags, and then hang at test 18 */
//JCB memset(&ec_data.conf[0], 0, sizeof(ec_data.conf));
sim_debug(DEBUG_EXP, dptr,
"ec_rsctlr chsa %04x cmd = %02x\n", chsa, cmd);
ec_data.tx_count = 0;
ec_data.rx_count = 0;
ec_data.rec_ptr = 0; /* clear queue */
ec_data.xtr_ptr = 0; /* clear queue */
ec_data.drop_cnt = 0;
return SCPE_OK;
}
/* handle reset channel cmds for Ethernet */
t_stat ec_rschnlio(UNIT *uptr) {
DEVICE *dptr = get_dev(uptr);
uint16 chsa = GET_UADDR(uptr->CMD);
int cmd = uptr->CMD & EC_CMDMSK;
sim_debug(DEBUG_EXP, dptr,
"ec_rschnl chsa %04x cmd = %02x\n", chsa, cmd);
ec_ini(uptr, 0); /* reset the unit */
/* the interrupt level will be reset in sel32_chan.c code */
return SCPE_OK;
}
static char *
ipv4_inet_ntoa(struct in_addr ip)
{
static char str[20];
if (sim_end)
sprintf (str, "%d.%d.%d.%d", ip.s_addr & 0xFF,
(ip.s_addr >> 8) & 0xFF,
(ip.s_addr >> 16) & 0xFF,
(ip.s_addr >> 24) & 0xFF);
else
sprintf (str, "%d.%d.%d.%d", (ip.s_addr >> 24) & 0xFF,
(ip.s_addr >> 16) & 0xFF,
(ip.s_addr >> 8) & 0xFF,
ip.s_addr & 0xFF);
return str;
}
/*
* Pretty print a packet for debugging.
*/
void ec_packet_debug(struct ec_device *ec, const char *action,
ETH_PACK *packet) {
struct ec_eth_hdr *eth = (struct ec_eth_hdr *)&packet->msg[0];
struct arp_hdr *arp = (struct arp_hdr *)eth;
struct ip *ip = (struct ip *)&packet->msg[sizeof(struct ec_eth_hdr)];
struct udp *udp;
struct tcp *tcp;
struct icmp *icmp;
uint8 *payload;
struct in_addr ipaddr;
size_t len;
int flag;
char src_ip[20];
char dst_ip[20];
char src_port[8];
char dst_port[8];
char flags[64];
static struct tcp_flag_bits {
const char *name;
uint16 bitmask;
} bits[] = {
{"FIN", TCP_FL_FIN},
{"SYN", TCP_FL_SYN},
{"RST", TCP_FL_RST},
{"PSH", TCP_FL_PSH},
{"ACK", TCP_FL_ACK},
{"URG", TCP_FL_URG},
{NULL, 0}
};
static const char *icmp_types[] = {
"Echo Reply", // Type 0
"Type 1 - Unassigned",
"Type 2 - Unassigned",
"Destination Unreachable", // Type 3
"Source Quench (Deprecated)", // Type 4
"Redirect", // Type 5
"Type 6 - Alternate Host Address (Deprecated)",
"Type 7 - Unassigned",
"Echo Request", // Type 8
"Router Advertisement", // Type 9
"Router Selection", // Type 10
"Time Exceeded", // Type 11
"Type 12 - Parameter Problem",
"Type 13 - Timestamp",
"Type 14 - Timestamp Reply",
"Type 15 - Information Request (Deprecated)",
"Type 16 - Information Reply (Deprecated)",
"Type 17 - Address Mask Request (Deprecated)",
"Type 18 - Address Mask Reply (Deprecated)",
"Type 19 - Reserved (for Security)",
"Type 20 - Reserved (for Robustness Experiment)",
"Type 21 - Reserved (for Robustness Experiment)",
"Type 22 - Reserved (for Robustness Experiment)",
"Type 23 - Reserved (for Robustness Experiment)",
"Type 24 - Reserved (for Robustness Experiment)",
"Type 25 - Reserved (for Robustness Experiment)",
"Type 26 - Reserved (for Robustness Experiment)",
"Type 27 - Reserved (for Robustness Experiment)",
"Type 28 - Reserved (for Robustness Experiment)",
"Type 29 - Reserved (for Robustness Experiment)",
"Type 30 - Traceroute (Deprecated)",
"Type 31 - Datagram Conversion Error (Deprecated)",
"Type 32 - Mobile Host Redirect (Deprecated)",
"Type 33 - IPv6 Where-Are-You (Deprecated)",
"Type 34 - IPv6 I-Am-Here (Deprecated)",
"Type 35 - Mobile Registration Request (Deprecated)",
"Type 36 - Mobile Registration Reply (Deprecated)",
"Type 37 - Domain Name Request (Deprecated)",
"Type 38 - Domain Name Reply (Deprecated)",
"Type 39 - SKIP (Deprecated)",
"Type 40 - Photuris",
"Type 41 - ICMP messages utilized by experimental mobility protocols such as Seamoby",
"Type 42 - Extended Echo Request",
"Type 43 - Extended Echo Reply"
};
if (ntohs(eth->type) == ETHTYPE_ARP) {
struct in_addr in_addr;
const char *arp_op = (ARP_REQUEST == ntohs(arp->opcode)) ? "REQUEST" :
((ARP_REPLY == ntohs(arp->opcode)) ? "REPLY" : "Unknown");
char eth_src[20], eth_dst[20];
char arp_shwaddr[20], arp_dhwaddr[20];
char arp_sipaddr[20], arp_dipaddr[20];
if (!(ec_dev.dctrl & DEBUG_ARP))
return;
eth_mac_fmt(&arp->ethhdr.src, eth_src);
eth_mac_fmt(&arp->ethhdr.dest, eth_dst);
eth_mac_fmt(&arp->shwaddr, arp_shwaddr);
memcpy(&in_addr, &arp->sipaddr, sizeof(in_addr));
strlcpy(arp_sipaddr, ipv4_inet_ntoa(in_addr), sizeof(arp_sipaddr));
eth_mac_fmt(&arp->dhwaddr, arp_dhwaddr);
memcpy(&in_addr, &arp->dipaddr, sizeof(in_addr));
strlcpy(arp_dipaddr, ipv4_inet_ntoa(in_addr), sizeof(arp_dipaddr));
sim_debug(DEBUG_ARP, &ec_dev,
"%s %s EthDst=%s EthSrc=%s shwaddr=%s sipaddr=%s dhwaddr=%s dipaddr=%s\n",
action, arp_op, eth_dst, eth_src, arp_shwaddr, arp_sipaddr, arp_dhwaddr, arp_dipaddr);
return;
}
/* always dump packet */
payload = (uint8 *)&packet->msg[0];
len = packet->len & 0xffff; /* JCB */
sim_data_trace(&ec_dev, ec_unit, payload, "", len, "", DEBUG_DATA);
if (ntohs(eth->type) != ETHTYPE_IP) {
return;
}
if (!(ec_dev.dctrl & (DEBUG_TCP|DEBUG_UDP|DEBUG_ICMP)))
return;
memcpy(&ipaddr, &ip->ip_src, sizeof(ipaddr));
strlcpy(src_ip, ipv4_inet_ntoa(ipaddr), sizeof(src_ip));
memcpy(&ipaddr, &ip->ip_dst, sizeof(ipaddr));
strlcpy(dst_ip, ipv4_inet_ntoa(ipaddr), sizeof(dst_ip));
payload = (uint8 *)&packet->msg[sizeof(struct ec_eth_hdr) + (ip->ip_v_hl & 0xf) * 4];
switch (ip->ip_p) {
case UDP_PROTO:
udp = (struct udp *)payload;
snprintf(src_port, sizeof(src_port), "%d", ntohs(udp->udp_sport));
snprintf(dst_port, sizeof(dst_port), "%d", ntohs(udp->udp_dport));
sim_debug(DEBUG_UDP, &ec_dev, "%s %d byte packet from %s:%s to %s:%s\n", action,
ntohs(udp->len), src_ip, src_port, dst_ip, dst_port);
if (udp->len && (ec_dev.dctrl & DEBUG_UDP))
sim_data_trace(&ec_dev, ec_unit, payload + sizeof(struct udp), "",
ntohs(udp->len), "", DEBUG_DATA);
break;
case TCP_PROTO:
tcp = (struct tcp *)payload;
snprintf(src_port, sizeof(src_port), "%d", ntohs(tcp->tcp_sport));
snprintf(dst_port, sizeof(dst_port), "%d", ntohs(tcp->tcp_dport));
strlcpy(flags, "", sizeof(flags));
for (flag=0; bits[flag].name; flag++) {
if (ntohs(tcp->flags) & bits[flag].bitmask) {
if (*flags)
strlcat(flags, ",", sizeof(flags));
strlcat(flags, bits[flag].name, sizeof(flags));
}
}
len = ntohs(ip->ip_len) - ((ip->ip_v_hl & 0xf) * 4 + (ntohs(tcp->flags) >> 12) * 4);
sim_debug(DEBUG_TCP, &ec_dev, "%s %s%s %d byte packet from %s:%s to %s:%s\n", action,
flags, *flags ? ":" : "", (int)len, src_ip, src_port, dst_ip, dst_port);
if (len && (ec_dev.dctrl & DEBUG_TCP))
sim_data_trace(&ec_dev, ec_unit, payload +
4 * (ntohs(tcp->flags) >> 12), "", len, "", DEBUG_DATA);
break;
case ICMP_PROTO:
icmp = (struct icmp *)payload;
len = ntohs(ip->ip_len) - (ip->ip_v_hl & 0xf) * 4;
sim_debug(DEBUG_ICMP, &ec_dev, "%s %s %d byte packet from %s to %s\n", action,
(icmp->type < sizeof(icmp_types)/sizeof(icmp_types[0])) ?
icmp_types[icmp->type] : "", (int)len, src_ip, dst_ip);
if (len && (ec_dev.dctrl & DEBUG_ICMP))
sim_data_trace(&ec_dev, ec_unit, payload + sizeof(struct icmp), "", len, "", DEBUG_DATA);
break;
}
}
t_stat ec_show_mode (FILE* st, UNIT* uptr, int32 val, CONST void* desc)
{
fprintf(st, "MODE=%d", GET_MODE(uptr->flags));
return SCPE_OK;
}
t_stat ec_set_mode (UNIT* uptr, int32 val, CONST char* cptr, void* desc)
{
t_stat r;
int newmode;
if (!cptr) return SCPE_IERR;
newmode = get_uint(cptr, 10, 4, &r);
if (r != SCPE_OK)
return r;
if (newmode > 3)
return SCPE_ARG;
uptr->flags &= ~UNIT_MODE;
uptr->flags |= SET_MODE(newmode);
return SCPE_OK;
}
t_stat ec_show_mac (FILE* st, UNIT* uptr, int32 val, CONST void* desc)
{
char buffer[20];
eth_mac_fmt(&ec_data.mac, buffer);
fprintf(st, "MAC=%s", buffer);
return SCPE_OK;
}
t_stat ec_set_mac (UNIT* uptr, int32 val, CONST char* cptr, void* desc)
{
t_stat status;
if (!cptr) return SCPE_IERR;
if (uptr->flags & UNIT_ATT) return SCPE_ALATT;
status = eth_mac_scan_ex(&ec_data.mac, cptr, uptr);
if (status != SCPE_OK)
return status;
return SCPE_OK;
}
t_stat ec_reset (DEVICE *dptr)
{
int i;
for (i = 0; i < sizeof(ETH_MAC); i++) {
if (ec_data.mac[i] != 0)
break;
}
if (i == 6) { /* First call to reset? */
/* Set a default MAC address in a BBN assigned OID range no longer in use */
ec_set_mac (dptr->units, 0, "00:00:02:00:00:00/24", NULL);
}
memset(&ec_data.conf[0], 0, sizeof(ec_data.conf));
ec_data.macs_n = 0;
ec_data.tx_count = 0;
ec_data.rx_count = 0;
ec_data.rec_ptr = 0;
ec_data.xtr_ptr = 0;
ec_data.drop_cnt = 0;
ec_data.amc = 0;
if (ec_master_uptr->flags & UNIT_ATT)
/* multicast on means promiscous is too */
eth_filter (&ec_data.etherface, ec_data.macs_n + 2, ec_data.macs,
ec_data.amc, ec_data.macs[0][0] & 1);
sim_debug(DEBUG_EXP, dptr,
"EC reset device %s on unit EC%04X\n", dptr->name,
GET_UADDR(dptr->units->CMD));
return SCPE_OK;
}
/* attach device: */
t_stat ec_attach(UNIT* uptr, CONST char* cptr)
{
t_stat status;
char* tptr;
char buf[32];
tptr = (char *) malloc(strlen(cptr) + 1);
if (tptr == NULL) return SCPE_MEM;
strcpy(tptr, cptr);
memcpy(&ec_data.macs[0], &ec_data.mac, sizeof (ETH_MAC));
memcpy(&ec_data.macs[1], &broadcast_ethaddr, sizeof (ETH_MAC));
status = eth_open(&ec_data.etherface, cptr, &ec_dev, DEBUG_ETHER);
if (status != SCPE_OK) {
free(tptr);
return status;
}
eth_mac_fmt(&ec_data.mac, buf); /* format ethernet mac address */
if (SCPE_OK != eth_check_address_conflict (&ec_data.etherface,
&ec_data.mac)) {
eth_close(&ec_data.etherface);
free(tptr);
return sim_messagef (SCPE_NOATT,
"%s: MAC Address Conflict on LAN for address %s\n",
ec_dev.name, buf);
}
if (SCPE_OK != eth_filter(&ec_data.etherface, 2, ec_data.macs, 0, 0)) {
eth_close(&ec_data.etherface);
free(tptr);
return sim_messagef (SCPE_NOATT,
"%s: Can't set packet filter for MAC Address %s\n",
ec_dev.name, buf);
}
uptr->filename = tptr;
uptr->flags |= UNIT_ATT;
eth_setcrc(&ec_data.etherface, 0); /* Enable CRC */
/* init read queue (first time only) */
status = ethq_init(&ec_data.ReadQ, 8); /* 8 per device */
if (status != SCPE_OK) {
eth_close(&ec_data.etherface);
uptr->filename = NULL;
free(tptr);
return sim_messagef (status, "%s: Can't initialize receive queue\n",
ec_dev.name);
}
eth_set_async (&ec_data.etherface, 0);
return SCPE_OK;
}
/* detach device: */
t_stat ec_detach(UNIT* uptr)
{
if ((uptr->flags & UNIT_ATT) && (uptr->flags & UNIT_DIS) == 0) {
eth_close (&ec_data.etherface);
free(uptr->filename);
uptr->filename = NULL;
uptr->flags &= ~UNIT_ATT;
}
return SCPE_OK;
}
t_stat ec_help (FILE *st, DEVICE *dptr, UNIT *uptr, int32 flag, const char *cptr)
{
fprintf(st, "Ethernet interface\n\n");
fprintf(st, "The ethernet interfaces to the network. Setting MAC defines default MAC address\n");
fprint_set_help(st, dptr);
fprint_show_help(st, dptr);
eth_attach_help(st, dptr, uptr, flag, cptr);
return SCPE_OK;
}
const char *ec_description (DEVICE *dptr)
{
return "SEL32 8516 Ethernet interface";
}
#endif
Reference in a new issue View git blame Copy permalink