src/AmigaOS/ether_amiga.cpp

/*
 *  ether_amiga.cpp - Ethernet device driver, AmigaOS specific stuff
 *
 *  Basilisk II (C) 1997-1999 Christian Bauer
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

#include <exec/types.h>
#include <exec/memory.h>
#include <exec/errors.h>
#include <dos/dos.h>
#include <dos/dosextens.h>
#include <dos/dostags.h>
#include <devices/sana2.h>
#include <proto/exec.h>
#include <proto/dos.h>

#include "sysdeps.h"
#include "cpu_emulation.h"
#include "main.h"
#include "prefs.h"
#include "user_strings.h"
#include "macos_util.h"
#include "ether.h"
#include "ether_defs.h"

#define DEBUG 0
#include "debug.h"

#define MONITOR 0


// These messages are sent to the network process
const uint32 MSG_CLEANUP = 'clea';                      // Remove all protocols
const uint32 MSG_ADD_MULTI = 'addm';            // Add multicast address
const uint32 MSG_DEL_MULTI = 'delm';            // Add multicast address
const uint32 MSG_ATTACH_PH = 'atph';            // Attach protocol handler
const uint32 MSG_DETACH_PH = 'deph';            // Attach protocol handler
const uint32 MSG_WRITE = 'writ';                        // Write packet

struct NetMessage : public Message {
        NetMessage(uint32 what_, const struct MsgPort *reply_port)
        {
                what = what_;
                mn_ReplyPort = (struct MsgPort *)reply_port;
                mn_Length = sizeof(*this);
        }
        uint32 what;
        uint32 pointer;
        uint16 type;
        int16 result;
};


// List of attached protocols
static const int NUM_READ_REQUESTS = 32;        // Number of read requests that are sent to device in advance

struct NetProtocol : public Node {
        struct IOSana2Req read_io[NUM_READ_REQUESTS];
        uint8 read_buf[NUM_READ_REQUESTS][1518];        // 14 bytes header, 1500 bytes data, 4 bytes CRC
        uint16 type;
        uint32 handler;
};

static struct List prot_list;


// Global variables
static struct Process *net_proc = NULL;         // Network device handler process
static bool proc_error;                                         // Flag: process didn't initialize
static struct MsgPort *proc_port = NULL;        // Message port of process, for communication with main task
static struct MsgPort *reply_port = NULL;       // Reply port for communication with process
static struct MsgPort *read_port = NULL;        // Reply port for read IORequests (set up and owned by network process)

static bool write_done = false;                         // Flag: write request done

extern struct Task *MainTask;                           // Pointer to main task (from main_amiga.cpp)


// Prototypes
static void net_func(void);


/*
 *  Send message to network process
 */

static int16 send_to_proc(uint32 what, uint32 pointer = 0, uint16 type = 0)
{
        D(bug("sending %08lx to net_proc\n", what));
        NetMessage msg(what, reply_port);
        msg.pointer = pointer;
        msg.type = type;
        PutMsg(proc_port, &msg);
        WaitPort(reply_port);
        GetMsg(reply_port);
        D(bug(" sent\n"));
        return msg.result;
}


/*
 *  Initialization
 */

void EtherInit(void)
{
        // Do nothing if no Ethernet device specified
        if (PrefsFindString("ether") == NULL)
                return;

        // Initialize protocol list
        NewList(&prot_list);

        // Create message port
        reply_port = CreateMsgPort();
        if (reply_port == NULL)
                goto open_error;
        D(bug("signal mask %08lx\n", 1 << reply_port->mp_SigBit));

        // Start process
        proc_error = false;
        SetSignal(0, SIGF_SINGLE);
        net_proc = CreateNewProcTags(
                NP_Entry, (ULONG)net_func,
                NP_Name, (ULONG)"Basilisk II Ethernet Task",
                NP_Priority, 1,
                TAG_END 
        );
        if (net_proc == NULL)
                goto open_error;

        // Wait for signal from process
        Wait(SIGF_SINGLE);

        // Initialization error? Then bail out
        if (proc_error)
                goto open_error;

        // Everything OK
        net_open = true;
        return;

open_error:
        net_proc = NULL;
        if (reply_port) {
                DeleteMsgPort(reply_port);
                reply_port = NULL;
        }
}


/*
 *  Deinitialization
 */

void EtherExit(void)
{
        // Stop process
        if (net_proc) {
                SetSignal(0, SIGF_SINGLE);
                Signal(&net_proc->pr_Task, SIGBREAKF_CTRL_C);
                Wait(SIGF_SINGLE);
        }

        // Delete reply port
        if (reply_port) {
                DeleteMsgPort(reply_port);
                reply_port = NULL;
        }
}


/*
 *  Reset
 */

void EtherReset(void)
{
        // Remove all protocols
        if (net_open)
                send_to_proc(MSG_CLEANUP);
}


/*
 *  Add multicast address
 */

int16 ether_add_multicast(uint32 pb)
{
        return send_to_proc(MSG_ADD_MULTI, pb);
}


/*
 *  Delete multicast address
 */

int16 ether_del_multicast(uint32 pb)
{
        return send_to_proc(MSG_DEL_MULTI, pb);
}


/*
 *  Attach protocol handler
 */

int16 ether_attach_ph(uint16 type, uint32 handler)
{
        return send_to_proc(MSG_ATTACH_PH, handler, type);
}


/*
 *  Detach protocol handler
 */

int16 ether_detach_ph(uint16 type)
{
        return send_to_proc(MSG_DETACH_PH, type);
}


/*
 *  Transmit raw ethernet packet
 */

int16 ether_write(uint32 wds)
{
        send_to_proc(MSG_WRITE, wds);
        return 1;       // Command in progress
}


/*
 *  Remove protocol from protocol list
 */

static void remove_protocol(NetProtocol *p)
{
        // Remove from list
        Forbid();
        Remove(p);
        Permit();

        // Cancel read requests
        for (int i=0; i<NUM_READ_REQUESTS; i++) {
                AbortIO((struct IORequest *)(p->read_io + i));
                WaitIO((struct IORequest *)(p->read_io + i));
        }

        // Free protocol struct
        FreeMem(p, sizeof(NetProtocol));
}


/*
 *  Remove all protocols
 */

static void remove_all_protocols(void)
{
        NetProtocol *n = (NetProtocol *)prot_list.lh_Head, *next;
        while ((next = (NetProtocol *)n->ln_Succ) != NULL) {
                remove_protocol(n);
                n = next;
        }
}


/*
 *  Copy received network packet to Mac side
 */

static __saveds __regargs LONG copy_to_buff(uint8 *to /*a0*/, uint8 *from /*a1*/, uint32 packet_len /*d0*/)
{
        D(bug("CopyToBuff to %08lx, from %08lx, size %08lx\n", to, from, packet_len));

        // It would be more efficient (and take up less memory) if we
        // could invoke the packet handler from here. But we don't know
        // in what context we run, so calling Execute68k() would not be
        // a good idea, and even worse, we might run inside a hardware
        // interrupt, so we can't even trigger a Basilisk interrupt from
        // here and wait for its completion.
        CopyMem(from, to, packet_len);
#if MONITOR
        bug("Receiving Ethernet packet:\n");
        for (int i=0; i<packet_len; i++) {
                bug("%02lx ", from[i]);
        }
        bug("\n");
#endif
        return 1;
}


/*
 *  Copy data from Mac WDS to outgoing network packet
 */

static __saveds __regargs LONG copy_from_buff(uint8 *to /*a0*/, char *wds /*a1*/, uint32 packet_len /*d0*/)
{
        D(bug("CopyFromBuff to %08lx, wds %08lx, size %08lx\n", to, wds, packet_len));
#if MONITOR
        bug("Sending Ethernet packet:\n");
#endif
        for (;;) {
                int len = ReadMacInt16((uint32)wds);
                if (len == 0)
                        break;
#if MONITOR
                uint8 *adr = Mac2HostAddr(ReadMacInt32((uint32)wds + 2));
                for (int i=0; i<len; i++) {
                        bug("%02lx ", adr[i]);
                }
#endif
                CopyMem(Mac2HostAddr(ReadMacInt32((uint32)wds + 2)), to, len);
                to += len;
                wds += 6;
        }
#if MONITOR
        bug("\n");
#endif
        return 1;
}


/*
 *  Process for communication with the Ethernet device
 */

static __saveds void net_func(void)
{
        struct MsgPort *write_port = NULL, *control_port = NULL;
        struct IOSana2Req *write_io = NULL, *control_io = NULL;
        bool opened = false;
        ULONG read_mask = 0, write_mask = 0, proc_port_mask = 0;
        struct Sana2DeviceQuery query_data = {sizeof(Sana2DeviceQuery)};
        ULONG buffer_tags[] = {
                S2_CopyToBuff, (uint32)copy_to_buff,
                S2_CopyFromBuff, (uint32)copy_from_buff,
                TAG_END
        };

        // Default: error occured
        proc_error = true;

        // Create message port for communication with main task
        proc_port = CreateMsgPort();
        if (proc_port == NULL)
                goto quit;
        proc_port_mask = 1 << proc_port->mp_SigBit;

        // Create message ports for device I/O
        read_port = CreateMsgPort();
        if (read_port == NULL)
                goto quit;
        read_mask = 1 << read_port->mp_SigBit;
        write_port = CreateMsgPort();
        if (write_port == NULL)
                goto quit;
        write_mask = 1 << write_port->mp_SigBit;
        control_port = CreateMsgPort();
        if (control_port == NULL)
                goto quit;

        // Create control IORequest
        control_io = (struct IOSana2Req *)CreateIORequest(control_port, sizeof(struct IOSana2Req));
        if (control_io == NULL)
                goto quit;
        control_io->ios2_Req.io_Message.mn_Node.ln_Type = 0;    // Avoid CheckIO() bug

        // Parse device name
        char dev_name[256];
        ULONG dev_unit;
        if (sscanf(PrefsFindString("ether"), "%[^/]/%ld", dev_name, &dev_unit) < 2)
                goto quit;

        // Open device
        control_io->ios2_BufferManagement = buffer_tags;
        if (OpenDevice((UBYTE *)dev_name, dev_unit, (struct IORequest *)control_io, 0) || control_io->ios2_Req.io_Device == 0)
                goto quit;
        opened = true;

        // Is it Ethernet?
        control_io->ios2_Req.io_Command = S2_DEVICEQUERY;
        control_io->ios2_StatData = (void *)&query_data;
        DoIO((struct IORequest *)control_io);
        if (control_io->ios2_Req.io_Error)
                goto quit;
        if (query_data.HardwareType != S2WireType_Ethernet) {
                WarningAlert(GetString(STR_NOT_ETHERNET_WARN));
                goto quit;
        }

        // Yes, create IORequest for writing
        write_io = (struct IOSana2Req *)CreateIORequest(write_port, sizeof(struct IOSana2Req));
        if (write_io == NULL)
                goto quit;
        memcpy(write_io, control_io, sizeof(struct IOSana2Req));
        write_io->ios2_Req.io_Message.mn_Node.ln_Type = 0;      // Avoid CheckIO() bug
        write_io->ios2_Req.io_Message.mn_ReplyPort = write_port;

        // Configure Ethernet
        control_io->ios2_Req.io_Command = S2_GETSTATIONADDRESS;
        DoIO((struct IORequest *)control_io);
        memcpy(ether_addr, control_io->ios2_DstAddr, 6);
        memcpy(control_io->ios2_SrcAddr, control_io->ios2_DstAddr, 6);
        control_io->ios2_Req.io_Command = S2_CONFIGINTERFACE;
        DoIO((struct IORequest *)control_io);
        D(bug("Ethernet address %08lx %08lx\n", *(uint32 *)ether_addr, *(uint16 *)(ether_addr + 4)));

        // Initialization went well, inform main task
        proc_error = false;
        Signal(MainTask, SIGF_SINGLE);

        // Main loop
        for (;;) {

                // Wait for I/O and messages (CTRL_C is used for quitting the task)
                ULONG sig = Wait(proc_port_mask | read_mask | write_mask | SIGBREAKF_CTRL_C);

                // Main task wants to quit us
                if (sig & SIGBREAKF_CTRL_C)
                        break;

                // Main task sent a command to us
                if (sig & proc_port_mask) {
                        struct NetMessage *msg;
                        while (msg = (NetMessage *)GetMsg(proc_port)) {
                                D(bug("net_proc received %08lx\n", msg->what));
                                switch (msg->what) {
                                        case MSG_CLEANUP:
                                                remove_all_protocols();
                                                break;

                                        case MSG_ADD_MULTI:
                                                control_io->ios2_Req.io_Command = S2_ADDMULTICASTADDRESS;
                                                Mac2Host_memcpy(control_io->ios2_SrcAddr, msg->pointer + eMultiAddr, 6);
                                                DoIO((struct IORequest *)control_io);
                                                if (control_io->ios2_Req.io_Error == S2ERR_NOT_SUPPORTED) {
                                                        WarningAlert(GetString(STR_NO_MULTICAST_WARN));
                                                        msg->result = noErr;
                                                } else if (control_io->ios2_Req.io_Error)
                                                        msg->result = eMultiErr;
                                                else
                                                        msg->result = noErr;
                                                break;

                                        case MSG_DEL_MULTI:
                                                control_io->ios2_Req.io_Command = S2_DELMULTICASTADDRESS;
                                                Mac2Host_memcpy(control_io->ios2_SrcAddr, msg->pointer + eMultiAddr, 6);
                                                DoIO((struct IORequest *)control_io);
                                                if (control_io->ios2_Req.io_Error)
                                                        msg->result = eMultiErr;
                                                else
                                                        msg->result = noErr;
                                                break;

                                        case MSG_ATTACH_PH: {
                                                uint16 type = msg->type;
                                                uint32 handler = msg->pointer;

                                                // Protocol of that type already installed?
                                                NetProtocol *p = (NetProtocol *)prot_list.lh_Head, *next;
                                                while ((next = (NetProtocol *)p->ln_Succ) != NULL) {
                                                        if (p->type == type) {
                                                                msg->result = lapProtErr;
                                                                goto reply;
                                                        }
                                                        p = next;
                                                }

                                                // Allocate NetProtocol, set type and handler
                                                p = (NetProtocol *)AllocMem(sizeof(NetProtocol), MEMF_PUBLIC);
                                                if (p == NULL) {
                                                        msg->result = lapProtErr;
                                                        goto reply;
                                                }
                                                p->type = type;
                                                p->handler = handler;

                                                // Set up and submit read requests
                                                for (int i=0; i<NUM_READ_REQUESTS; i++) {
                                                        memcpy(p->read_io + i, control_io, sizeof(struct IOSana2Req));
                                                        p->read_io[i].ios2_Req.io_Message.mn_Node.ln_Name = (char *)p;  // Hide pointer to NetProtocol in node name
                                                        p->read_io[i].ios2_Req.io_Message.mn_Node.ln_Type = 0;                  // Avoid CheckIO() bug
                                                        p->read_io[i].ios2_Req.io_Message.mn_ReplyPort = read_port;
                                                        p->read_io[i].ios2_Req.io_Command = CMD_READ;
                                                        p->read_io[i].ios2_PacketType = type;
                                                        p->read_io[i].ios2_Data = p->read_buf[i];
                                                        p->read_io[i].ios2_Req.io_Flags = SANA2IOF_RAW;
                                                        BeginIO((struct IORequest *)(p->read_io + i));
                                                }

                                                // Add protocol to list
                                                AddTail(&prot_list, p);

                                                // Everything OK
                                                msg->result = noErr;
                                                break;
                                        }

                                        case MSG_DETACH_PH: {
                                                uint16 type = msg->type;
                                                msg->result = lapProtErr;
                                                NetProtocol *p = (NetProtocol *)prot_list.lh_Head, *next;
                                                while ((next = (NetProtocol *)p->ln_Succ) != NULL) {
                                                        if (p->type == type) {
                                                                remove_protocol(p);
                                                                msg->result = noErr;
                                                                break;
                                                        }
                                                        p = next;
                                                }
                                                break;
                                        }

                                        case MSG_WRITE: {
                                                // Get pointer to Write Data Structure
                                                uint32 wds = msg->pointer;
                                                write_io->ios2_Data = (void *)wds;

                                                // Calculate total packet length
                                                long len = 0;
                                                uint32 tmp = wds;
                                                for (;;) {
                                                        int16 w = ReadMacInt16(tmp);
                                                        if (w == 0)
                                                                break;
                                                        len += w;
                                                        tmp += 6;
                                                }
                                                write_io->ios2_DataLength = len;

                                                // Get destination address, set source address
                                                uint32 hdr = ReadMacInt32(wds + 2);
                                                Mac2Host_memcpy(write_io->ios2_DstAddr, hdr, 6);
                                                Host2Mac_memcpy(hdr + 6, ether_addr, 6);

                                                // Get packet type
                                                uint32 type = ReadMacInt16(hdr + 12);
                                                if (type <= 1500)
                                                        type = 0;               // 802.3 packet
                                                write_io->ios2_PacketType = type;

                                                // Multicast/broadcard packet?
                                                if (write_io->ios2_DstAddr[0] & 1) {
                                                        if (*(uint32 *)(write_io->ios2_DstAddr) == 0xffffffff && *(uint16 *)(write_io->ios2_DstAddr + 4) == 0xffff)
                                                                write_io->ios2_Req.io_Command = S2_BROADCAST;
                                                        else
                                                                write_io->ios2_Req.io_Command = S2_MULTICAST;
                                                } else
                                                        write_io->ios2_Req.io_Command = CMD_WRITE;

                                                // Send packet
                                                write_done = false;
                                                write_io->ios2_Req.io_Flags = SANA2IOF_RAW;
                                                BeginIO((IORequest *)write_io);
                                                break;
                                        }
                                }
reply:                  D(bug(" net_proc replying\n"));
                                ReplyMsg(msg);
                        }
                }

                // Packet received
                if (sig & read_mask) {
                        D(bug(" packet received, triggering Ethernet interrupt\n"));
                        SetInterruptFlag(INTFLAG_ETHER);
                        TriggerInterrupt();
                }

                // Packet write completed
                if (sig & write_mask) {
                        GetMsg(write_port);
                        WriteMacInt32(ether_data + ed_Result, write_io->ios2_Req.io_Error ? excessCollsns : 0);
                        write_done = true;
                        D(bug(" packet write done, triggering Ethernet interrupt\n"));
                        SetInterruptFlag(INTFLAG_ETHER);
                        TriggerInterrupt();
                }
        }
quit:

        // Close everything
        remove_all_protocols();
        if (opened) {
                if (CheckIO((struct IORequest *)write_io) == 0) {
                        AbortIO((struct IORequest *)write_io);
                        WaitIO((struct IORequest *)write_io);
                }
                CloseDevice((struct IORequest *)control_io);
        }
        if (write_io)
                DeleteIORequest(write_io);
        if (control_io)
                DeleteIORequest(control_io);
        if (control_port)
                DeleteMsgPort(control_port);
        if (write_port)
                DeleteMsgPort(write_port);
        if (read_port)
                DeleteMsgPort(read_port);

        // Send signal to main task to confirm termination
        Forbid();
        Signal(MainTask, SIGF_SINGLE);
}


/*
 *  Ethernet interrupt - activate deferred tasks to call IODone or protocol handlers
 */

void EtherInterrupt(void)
{
        D(bug("EtherIRQ\n"));

        // Packet write done, enqueue DT to call IODone
        if (write_done) {
                EnqueueMac(ether_data + ed_DeferredTask, 0xd92);
                write_done = false;
        }

        // Call protocol handler for received packets
        IOSana2Req *io;
        while (io = (struct IOSana2Req *)GetMsg(read_port)) {

                // Get pointer to NetProtocol (hidden in node name)
                NetProtocol *p = (NetProtocol *)io->ios2_Req.io_Message.mn_Node.ln_Name;

                // No default handler
                if (p->handler == 0)
                        continue;

                // Copy header to RHA
                Host2Mac_memcpy(ether_data + ed_RHA, io->ios2_Data, 14);
                D(bug(" header %08lx%04lx %08lx%04lx %04lx\n", ReadMacInt32(ether_data + ed_RHA), ReadMacInt16(ether_data + ed_RHA + 4), ReadMacInt32(ether_data + ed_RHA + 6), ReadMacInt16(ether_data + ed_RHA + 10), ReadMacInt16(ether_data + ed_RHA + 12)));

                // Call protocol handler
                M68kRegisters r;
                r.d[0] = *(uint16 *)((uint32)io->ios2_Data + 12);       // Packet type
                r.d[1] = io->ios2_DataLength - 18;                                      // Remaining packet length (without header, for ReadPacket) (-18 because the CRC is also included)
                r.a[0] = (uint32)io->ios2_Data + 14;                            // Pointer to packet (host address, for ReadPacket)
                r.a[3] = ether_data + ed_RHA + 14;                                      // Pointer behind header in RHA
                r.a[4] = ether_data + ed_ReadPacket;                            // Pointer to ReadPacket/ReadRest routines
                D(bug(" calling protocol handler %08lx, type %08lx, length %08lx, data %08lx, rha %08lx, read_packet %08lx\n", p->handler, r.d[0], r.d[1], r.a[0], r.a[3], r.a[4]));
                Execute68k(p->handler, &r);

                // Resend IORequest
                io->ios2_Req.io_Flags = SANA2IOF_RAW;
                BeginIO((struct IORequest *)io);
        }
        D(bug(" EtherIRQ done\n"));
}
Revision:	1.3
Committed:	1999-11-03T10:56:18Z (25 years ago) by cebix
Branch:	MAIN
CVS Tags:	snapshot-22121999, release-0_8-1
Changes since 1.2:	+5 -5 lines
Log Message:	- imported UAE CPU 0.8.10 changes - new utility functions Mac_memset, Mac2Host_memcpy, Host2Mac_memcpu and Mac2Mac_memcpy - extfs.cpp: fixed bug in fs_rename() and fs_cat_move() (auxiliary IOParam block was not in Mac address space) - some provisions for using UAE CPU compiler (doesn't work yet)
#	User	Rev	Content
1	cebix	1.1	/*
2			* ether_amiga.cpp - Ethernet device driver, AmigaOS specific stuff
3			*
4			* Basilisk II (C) 1997-1999 Christian Bauer
5			*
6			* This program is free software; you can redistribute it and/or modify
7			* it under the terms of the GNU General Public License as published by
8			* the Free Software Foundation; either version 2 of the License, or
9			* (at your option) any later version.
10			*
11			* This program is distributed in the hope that it will be useful,
12			* but WITHOUT ANY WARRANTY; without even the implied warranty of
13			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14			* GNU General Public License for more details.
15			*
16			* You should have received a copy of the GNU General Public License
17			* along with this program; if not, write to the Free Software
18			* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19			*/
20
21			#include <exec/types.h>
22			#include <exec/memory.h>
23			#include <exec/errors.h>
24			#include <dos/dos.h>
25			#include <dos/dosextens.h>
26			#include <dos/dostags.h>
27			#include <devices/sana2.h>
28			#include <proto/exec.h>
29			#include <proto/dos.h>
30
31			#include "sysdeps.h"
32			#include "cpu_emulation.h"
33			#include "main.h"
34			#include "prefs.h"
35			#include "user_strings.h"
36			#include "macos_util.h"
37			#include "ether.h"
38			#include "ether_defs.h"
39
40			#define DEBUG 0
41			#include "debug.h"
42
43			#define MONITOR 0
44
45
46			// These messages are sent to the network process
47			const uint32 MSG_CLEANUP = 'clea'; // Remove all protocols
48			const uint32 MSG_ADD_MULTI = 'addm'; // Add multicast address
49			const uint32 MSG_DEL_MULTI = 'delm'; // Add multicast address
50			const uint32 MSG_ATTACH_PH = 'atph'; // Attach protocol handler
51			const uint32 MSG_DETACH_PH = 'deph'; // Attach protocol handler
52			const uint32 MSG_WRITE = 'writ'; // Write packet
53
54			struct NetMessage : public Message {
55			NetMessage(uint32 what_, const struct MsgPort *reply_port)
56			{
57			what = what_;
58			mn_ReplyPort = (struct MsgPort *)reply_port;
59			mn_Length = sizeof(*this);
60			}
61			uint32 what;
62			uint32 pointer;
63			uint16 type;
64			int16 result;
65			};
66
67
68			// List of attached protocols
69			static const int NUM_READ_REQUESTS = 32; // Number of read requests that are sent to device in advance
70
71			struct NetProtocol : public Node {
72			struct IOSana2Req read_io[NUM_READ_REQUESTS];
73			uint8 read_buf[NUM_READ_REQUESTS][1518]; // 14 bytes header, 1500 bytes data, 4 bytes CRC
74			uint16 type;
75			uint32 handler;
76			};
77
78			static struct List prot_list;
79
80
81			// Global variables
82			static struct Process *net_proc = NULL; // Network device handler process
83			static bool proc_error; // Flag: process didn't initialize
84			static struct MsgPort *proc_port = NULL; // Message port of process, for communication with main task
85			static struct MsgPort *reply_port = NULL; // Reply port for communication with process
86			static struct MsgPort *read_port = NULL; // Reply port for read IORequests (set up and owned by network process)
87
88			static bool write_done = false; // Flag: write request done
89
90			extern struct Task *MainTask; // Pointer to main task (from main_amiga.cpp)
91
92
93			// Prototypes
94			static void net_func(void);
95
96
97			/*
98			* Send message to network process
99			*/
100
101			static int16 send_to_proc(uint32 what, uint32 pointer = 0, uint16 type = 0)
102			{
103			D(bug("sending %08lx to net_proc\n", what));
104			NetMessage msg(what, reply_port);
105			msg.pointer = pointer;
106			msg.type = type;
107			PutMsg(proc_port, &msg);
108			WaitPort(reply_port);
109			GetMsg(reply_port);
110			D(bug(" sent\n"));
111			return msg.result;
112			}
113
114
115			/*
116			* Initialization
117			*/
118
119			void EtherInit(void)
120			{
121			// Do nothing if no Ethernet device specified
122			if (PrefsFindString("ether") == NULL)
123			return;
124
125			// Initialize protocol list
126			NewList(&prot_list);
127
128			// Create message port
129			reply_port = CreateMsgPort();
130			if (reply_port == NULL)
131			goto open_error;
132			D(bug("signal mask %08lx\n", 1 << reply_port->mp_SigBit));
133
134			// Start process
135			proc_error = false;
136			SetSignal(0, SIGF_SINGLE);
137			net_proc = CreateNewProcTags(
138	cebix	1.2	NP_Entry, (ULONG)net_func,
139			NP_Name, (ULONG)"Basilisk II Ethernet Task",
140	cebix	1.1	NP_Priority, 1,
141			TAG_END
142			);
143			if (net_proc == NULL)
144			goto open_error;
145
146			// Wait for signal from process
147			Wait(SIGF_SINGLE);
148
149			// Initialization error? Then bail out
150			if (proc_error)
151			goto open_error;
152
153			// Everything OK
154			net_open = true;
155			return;
156
157			open_error:
158			net_proc = NULL;
159			if (reply_port) {
160			DeleteMsgPort(reply_port);
161			reply_port = NULL;
162			}
163			}
164
165
166			/*
167			* Deinitialization
168			*/
169
170			void EtherExit(void)
171			{
172			// Stop process
173			if (net_proc) {
174			SetSignal(0, SIGF_SINGLE);
175			Signal(&net_proc->pr_Task, SIGBREAKF_CTRL_C);
176			Wait(SIGF_SINGLE);
177			}
178
179			// Delete reply port
180			if (reply_port) {
181			DeleteMsgPort(reply_port);
182			reply_port = NULL;
183			}
184			}
185
186
187			/*
188			* Reset
189			*/
190
191			void EtherReset(void)
192			{
193			// Remove all protocols
194			if (net_open)
195			send_to_proc(MSG_CLEANUP);
196			}
197
198
199			/*
200			* Add multicast address
201			*/
202
203			int16 ether_add_multicast(uint32 pb)
204			{
205			return send_to_proc(MSG_ADD_MULTI, pb);
206			}
207
208
209			/*
210			* Delete multicast address
211			*/
212
213			int16 ether_del_multicast(uint32 pb)
214			{
215			return send_to_proc(MSG_DEL_MULTI, pb);
216			}
217
218
219			/*
220			* Attach protocol handler
221			*/
222
223			int16 ether_attach_ph(uint16 type, uint32 handler)
224			{
225			return send_to_proc(MSG_ATTACH_PH, handler, type);
226			}
227
228
229			/*
230			* Detach protocol handler
231			*/
232
233			int16 ether_detach_ph(uint16 type)
234			{
235			return send_to_proc(MSG_DETACH_PH, type);
236			}
237
238
239			/*
240			* Transmit raw ethernet packet
241			*/
242
243			int16 ether_write(uint32 wds)
244			{
245			send_to_proc(MSG_WRITE, wds);
246			return 1; // Command in progress
247			}
248
249
250			/*
251			* Remove protocol from protocol list
252			*/
253
254			static void remove_protocol(NetProtocol *p)
255			{
256			// Remove from list
257			Forbid();
258			Remove(p);
259			Permit();
260
261			// Cancel read requests
262			for (int i=0; i<NUM_READ_REQUESTS; i++) {
263			AbortIO((struct IORequest *)(p->read_io + i));
264			WaitIO((struct IORequest *)(p->read_io + i));
265			}
266
267			// Free protocol struct
268			FreeMem(p, sizeof(NetProtocol));
269			}
270
271
272			/*
273			* Remove all protocols
274			*/
275
276			static void remove_all_protocols(void)
277			{
278			NetProtocol n = (NetProtocol )prot_list.lh_Head, *next;
279			while ((next = (NetProtocol *)n->ln_Succ) != NULL) {
280			remove_protocol(n);
281			n = next;
282			}
283			}
284
285
286			/*
287			* Copy received network packet to Mac side
288			*/
289
290	cebix	1.2	static __saveds __regargs LONG copy_to_buff(uint8 to /a0/, uint8 from /a1/, uint32 packet_len /d0/)
291	cebix	1.1	{
292			D(bug("CopyToBuff to %08lx, from %08lx, size %08lx\n", to, from, packet_len));
293
294			// It would be more efficient (and take up less memory) if we
295			// could invoke the packet handler from here. But we don't know
296			// in what context we run, so calling Execute68k() would not be
297			// a good idea, and even worse, we might run inside a hardware
298			// interrupt, so we can't even trigger a Basilisk interrupt from
299			// here and wait for its completion.
300			CopyMem(from, to, packet_len);
301			#if MONITOR
302			bug("Receiving Ethernet packet:\n");
303			for (int i=0; i<packet_len; i++) {
304			bug("%02lx ", from[i]);
305			}
306			bug("\n");
307			#endif
308			return 1;
309			}
310
311
312			/*
313			* Copy data from Mac WDS to outgoing network packet
314			*/
315
316	cebix	1.2	static __saveds __regargs LONG copy_from_buff(uint8 to /a0/, char wds /a1/, uint32 packet_len /d0/)
317	cebix	1.1	{
318			D(bug("CopyFromBuff to %08lx, wds %08lx, size %08lx\n", to, wds, packet_len));
319			#if MONITOR
320			bug("Sending Ethernet packet:\n");
321			#endif
322			for (;;) {
323	cebix	1.2	int len = ReadMacInt16((uint32)wds);
324	cebix	1.1	if (len == 0)
325			break;
326			#if MONITOR
327	cebix	1.2	uint8 *adr = Mac2HostAddr(ReadMacInt32((uint32)wds + 2));
328	cebix	1.1	for (int i=0; i<len; i++) {
329			bug("%02lx ", adr[i]);
330			}
331			#endif
332	cebix	1.2	CopyMem(Mac2HostAddr(ReadMacInt32((uint32)wds + 2)), to, len);
333	cebix	1.1	to += len;
334			wds += 6;
335			}
336			#if MONITOR
337			bug("\n");
338			#endif
339			return 1;
340			}
341
342
343			/*
344			* Process for communication with the Ethernet device
345			*/
346
347			static __saveds void net_func(void)
348			{
349			struct MsgPort write_port = NULL, control_port = NULL;
350			struct IOSana2Req write_io = NULL, control_io = NULL;
351			bool opened = false;
352			ULONG read_mask = 0, write_mask = 0, proc_port_mask = 0;
353			struct Sana2DeviceQuery query_data = {sizeof(Sana2DeviceQuery)};
354			ULONG buffer_tags[] = {
355			S2_CopyToBuff, (uint32)copy_to_buff,
356			S2_CopyFromBuff, (uint32)copy_from_buff,
357			TAG_END
358			};
359
360			// Default: error occured
361			proc_error = true;
362
363			// Create message port for communication with main task
364			proc_port = CreateMsgPort();
365			if (proc_port == NULL)
366			goto quit;
367			proc_port_mask = 1 << proc_port->mp_SigBit;
368
369			// Create message ports for device I/O
370			read_port = CreateMsgPort();
371			if (read_port == NULL)
372			goto quit;
373			read_mask = 1 << read_port->mp_SigBit;
374			write_port = CreateMsgPort();
375			if (write_port == NULL)
376			goto quit;
377			write_mask = 1 << write_port->mp_SigBit;
378			control_port = CreateMsgPort();
379			if (control_port == NULL)
380			goto quit;
381
382			// Create control IORequest
383			control_io = (struct IOSana2Req *)CreateIORequest(control_port, sizeof(struct IOSana2Req));
384			if (control_io == NULL)
385			goto quit;
386			control_io->ios2_Req.io_Message.mn_Node.ln_Type = 0; // Avoid CheckIO() bug
387
388			// Parse device name
389			char dev_name[256];
390			ULONG dev_unit;
391			if (sscanf(PrefsFindString("ether"), "%[^/]/%ld", dev_name, &dev_unit) < 2)
392			goto quit;
393
394			// Open device
395			control_io->ios2_BufferManagement = buffer_tags;
396			if (OpenDevice((UBYTE )dev_name, dev_unit, (struct IORequest )control_io, 0) \|\| control_io->ios2_Req.io_Device == 0)
397			goto quit;
398			opened = true;
399
400			// Is it Ethernet?
401			control_io->ios2_Req.io_Command = S2_DEVICEQUERY;
402			control_io->ios2_StatData = (void *)&query_data;
403			DoIO((struct IORequest *)control_io);
404			if (control_io->ios2_Req.io_Error)
405			goto quit;
406			if (query_data.HardwareType != S2WireType_Ethernet) {
407			WarningAlert(GetString(STR_NOT_ETHERNET_WARN));
408			goto quit;
409			}
410
411			// Yes, create IORequest for writing
412			write_io = (struct IOSana2Req *)CreateIORequest(write_port, sizeof(struct IOSana2Req));
413			if (write_io == NULL)
414			goto quit;
415			memcpy(write_io, control_io, sizeof(struct IOSana2Req));
416			write_io->ios2_Req.io_Message.mn_Node.ln_Type = 0; // Avoid CheckIO() bug
417			write_io->ios2_Req.io_Message.mn_ReplyPort = write_port;
418
419			// Configure Ethernet
420			control_io->ios2_Req.io_Command = S2_GETSTATIONADDRESS;
421			DoIO((struct IORequest *)control_io);
422			memcpy(ether_addr, control_io->ios2_DstAddr, 6);
423			memcpy(control_io->ios2_SrcAddr, control_io->ios2_DstAddr, 6);
424			control_io->ios2_Req.io_Command = S2_CONFIGINTERFACE;
425			DoIO((struct IORequest *)control_io);
426			D(bug("Ethernet address %08lx %08lx\n", (uint32 )ether_addr, (uint16 )(ether_addr + 4)));
427
428			// Initialization went well, inform main task
429			proc_error = false;
430			Signal(MainTask, SIGF_SINGLE);
431
432			// Main loop
433			for (;;) {
434
435			// Wait for I/O and messages (CTRL_C is used for quitting the task)
436			ULONG sig = Wait(proc_port_mask \| read_mask \| write_mask \| SIGBREAKF_CTRL_C);
437
438			// Main task wants to quit us
439			if (sig & SIGBREAKF_CTRL_C)
440			break;
441
442			// Main task sent a command to us
443			if (sig & proc_port_mask) {
444			struct NetMessage *msg;
445			while (msg = (NetMessage *)GetMsg(proc_port)) {
446			D(bug("net_proc received %08lx\n", msg->what));
447			switch (msg->what) {
448			case MSG_CLEANUP:
449			remove_all_protocols();
450			break;
451
452			case MSG_ADD_MULTI:
453			control_io->ios2_Req.io_Command = S2_ADDMULTICASTADDRESS;
454	cebix	1.3	Mac2Host_memcpy(control_io->ios2_SrcAddr, msg->pointer + eMultiAddr, 6);
455	cebix	1.1	DoIO((struct IORequest *)control_io);
456			if (control_io->ios2_Req.io_Error == S2ERR_NOT_SUPPORTED) {
457			WarningAlert(GetString(STR_NO_MULTICAST_WARN));
458			msg->result = noErr;
459			} else if (control_io->ios2_Req.io_Error)
460			msg->result = eMultiErr;
461			else
462			msg->result = noErr;
463			break;
464
465			case MSG_DEL_MULTI:
466			control_io->ios2_Req.io_Command = S2_DELMULTICASTADDRESS;
467	cebix	1.3	Mac2Host_memcpy(control_io->ios2_SrcAddr, msg->pointer + eMultiAddr, 6);
468	cebix	1.1	DoIO((struct IORequest *)control_io);
469			if (control_io->ios2_Req.io_Error)
470			msg->result = eMultiErr;
471			else
472			msg->result = noErr;
473			break;
474
475			case MSG_ATTACH_PH: {
476			uint16 type = msg->type;
477			uint32 handler = msg->pointer;
478
479			// Protocol of that type already installed?
480			NetProtocol p = (NetProtocol )prot_list.lh_Head, *next;
481			while ((next = (NetProtocol *)p->ln_Succ) != NULL) {
482			if (p->type == type) {
483			msg->result = lapProtErr;
484			goto reply;
485			}
486			p = next;
487			}
488
489			// Allocate NetProtocol, set type and handler
490			p = (NetProtocol *)AllocMem(sizeof(NetProtocol), MEMF_PUBLIC);
491			if (p == NULL) {
492			msg->result = lapProtErr;
493			goto reply;
494			}
495			p->type = type;
496			p->handler = handler;
497
498			// Set up and submit read requests
499			for (int i=0; i<NUM_READ_REQUESTS; i++) {
500			memcpy(p->read_io + i, control_io, sizeof(struct IOSana2Req));
501			p->read_io[i].ios2_Req.io_Message.mn_Node.ln_Name = (char *)p; // Hide pointer to NetProtocol in node name
502			p->read_io[i].ios2_Req.io_Message.mn_Node.ln_Type = 0; // Avoid CheckIO() bug
503			p->read_io[i].ios2_Req.io_Message.mn_ReplyPort = read_port;
504			p->read_io[i].ios2_Req.io_Command = CMD_READ;
505			p->read_io[i].ios2_PacketType = type;
506			p->read_io[i].ios2_Data = p->read_buf[i];
507			p->read_io[i].ios2_Req.io_Flags = SANA2IOF_RAW;
508			BeginIO((struct IORequest *)(p->read_io + i));
509			}
510
511			// Add protocol to list
512			AddTail(&prot_list, p);
513
514			// Everything OK
515			msg->result = noErr;
516			break;
517			}
518
519			case MSG_DETACH_PH: {
520			uint16 type = msg->type;
521			msg->result = lapProtErr;
522			NetProtocol p = (NetProtocol )prot_list.lh_Head, *next;
523			while ((next = (NetProtocol *)p->ln_Succ) != NULL) {
524			if (p->type == type) {
525			remove_protocol(p);
526			msg->result = noErr;
527			break;
528			}
529			p = next;
530			}
531			break;
532			}
533
534			case MSG_WRITE: {
535			// Get pointer to Write Data Structure
536			uint32 wds = msg->pointer;
537			write_io->ios2_Data = (void *)wds;
538
539			// Calculate total packet length
540			long len = 0;
541			uint32 tmp = wds;
542			for (;;) {
543			int16 w = ReadMacInt16(tmp);
544			if (w == 0)
545			break;
546			len += w;
547			tmp += 6;
548			}
549			write_io->ios2_DataLength = len;
550
551			// Get destination address, set source address
552			uint32 hdr = ReadMacInt32(wds + 2);
553	cebix	1.3	Mac2Host_memcpy(write_io->ios2_DstAddr, hdr, 6);
554			Host2Mac_memcpy(hdr + 6, ether_addr, 6);
555	cebix	1.1
556			// Get packet type
557			uint32 type = ReadMacInt16(hdr + 12);
558			if (type <= 1500)
559			type = 0; // 802.3 packet
560			write_io->ios2_PacketType = type;
561
562			// Multicast/broadcard packet?
563			if (write_io->ios2_DstAddr[0] & 1) {
564			if ((uint32 )(write_io->ios2_DstAddr) == 0xffffffff && (uint16 )(write_io->ios2_DstAddr + 4) == 0xffff)
565			write_io->ios2_Req.io_Command = S2_BROADCAST;
566			else
567			write_io->ios2_Req.io_Command = S2_MULTICAST;
568			} else
569			write_io->ios2_Req.io_Command = CMD_WRITE;
570
571			// Send packet
572			write_done = false;
573			write_io->ios2_Req.io_Flags = SANA2IOF_RAW;
574			BeginIO((IORequest *)write_io);
575			break;
576			}
577			}
578			reply: D(bug(" net_proc replying\n"));
579			ReplyMsg(msg);
580			}
581			}
582
583			// Packet received
584			if (sig & read_mask) {
585			D(bug(" packet received, triggering Ethernet interrupt\n"));
586			SetInterruptFlag(INTFLAG_ETHER);
587			TriggerInterrupt();
588			}
589
590			// Packet write completed
591			if (sig & write_mask) {
592			GetMsg(write_port);
593			WriteMacInt32(ether_data + ed_Result, write_io->ios2_Req.io_Error ? excessCollsns : 0);
594			write_done = true;
595			D(bug(" packet write done, triggering Ethernet interrupt\n"));
596			SetInterruptFlag(INTFLAG_ETHER);
597			TriggerInterrupt();
598			}
599			}
600			quit:
601
602			// Close everything
603			remove_all_protocols();
604			if (opened) {
605			if (CheckIO((struct IORequest *)write_io) == 0) {
606			AbortIO((struct IORequest *)write_io);
607			WaitIO((struct IORequest *)write_io);
608			}
609			CloseDevice((struct IORequest *)control_io);
610			}
611			if (write_io)
612			DeleteIORequest(write_io);
613			if (control_io)
614			DeleteIORequest(control_io);
615			if (control_port)
616			DeleteMsgPort(control_port);
617			if (write_port)
618			DeleteMsgPort(write_port);
619			if (read_port)
620			DeleteMsgPort(read_port);
621
622			// Send signal to main task to confirm termination
623			Forbid();
624			Signal(MainTask, SIGF_SINGLE);
625			}
626
627
628			/*
629			* Ethernet interrupt - activate deferred tasks to call IODone or protocol handlers
630			*/
631
632			void EtherInterrupt(void)
633			{
634			D(bug("EtherIRQ\n"));
635
636			// Packet write done, enqueue DT to call IODone
637			if (write_done) {
638	cebix	1.2	EnqueueMac(ether_data + ed_DeferredTask, 0xd92);
639	cebix	1.1	write_done = false;
640			}
641
642			// Call protocol handler for received packets
643			IOSana2Req *io;
644			while (io = (struct IOSana2Req *)GetMsg(read_port)) {
645
646			// Get pointer to NetProtocol (hidden in node name)
647			NetProtocol p = (NetProtocol )io->ios2_Req.io_Message.mn_Node.ln_Name;
648
649			// No default handler
650			if (p->handler == 0)
651			continue;
652
653			// Copy header to RHA
654	cebix	1.3	Host2Mac_memcpy(ether_data + ed_RHA, io->ios2_Data, 14);
655	cebix	1.1	D(bug(" header %08lx%04lx %08lx%04lx %04lx\n", ReadMacInt32(ether_data + ed_RHA), ReadMacInt16(ether_data + ed_RHA + 4), ReadMacInt32(ether_data + ed_RHA + 6), ReadMacInt16(ether_data + ed_RHA + 10), ReadMacInt16(ether_data + ed_RHA + 12)));
656
657			// Call protocol handler
658			M68kRegisters r;
659			r.d[0] = (uint16 )((uint32)io->ios2_Data + 12); // Packet type
660			r.d[1] = io->ios2_DataLength - 18; // Remaining packet length (without header, for ReadPacket) (-18 because the CRC is also included)
661			r.a[0] = (uint32)io->ios2_Data + 14; // Pointer to packet (host address, for ReadPacket)
662			r.a[3] = ether_data + ed_RHA + 14; // Pointer behind header in RHA
663			r.a[4] = ether_data + ed_ReadPacket; // Pointer to ReadPacket/ReadRest routines
664			D(bug(" calling protocol handler %08lx, type %08lx, length %08lx, data %08lx, rha %08lx, read_packet %08lx\n", p->handler, r.d[0], r.d[1], r.a[0], r.a[3], r.a[4]));
665			Execute68k(p->handler, &r);
666
667			// Resend IORequest
668			io->ios2_Req.io_Flags = SANA2IOF_RAW;
669			BeginIO((struct IORequest *)io);
670			}
671			D(bug(" EtherIRQ done\n"));
672			}