/*
 *  DNET.H
 *
 *  DNET (c)Copyright 1988, Matthew Dillon, All Rights Reserved.
 *
 */

#define DNET_H

#ifdef LATTICE
#include <exec/types.h>
#include <exec/nodes.h>
#include <exec/lists.h>
#include <exec/ports.h>
#include <exec/libraries.h>
#include <exec/devices.h>
#include <exec/io.h>
#include <exec/memory.h>
#include <exec/interrupts.h>
#include <intuition/intuition.h>
#include <devices/console.h>
#include <devices/timer.h>
#include <libraries/dos.h>
#include <libraries/dosextens.h>
#include <libraries/filehandler.h>
#include <string.h>
#include <stdlib.h>
#include <proto/exec.h>
#include <proto/dos.h>

#define U_ARGS(a) a

#else

#define U_ARGS(a) ()    /* No support for prototypes - oh well */

#endif


typedef unsigned char	ubyte;
typedef unsigned short	uword;
typedef unsigned long	ulong;

typedef struct MsgPort	    PORT;
typedef struct timerequest  IOT;
typedef struct IOStdReq     IOR;
typedef struct List	    LIST;
typedef struct Node	    NODE;
typedef struct Process	    PROC;
typedef struct Message	    MSG;

#include "channel.h"

#ifndef MAX(a,b)
#define MAX(a,b) (((a)>(b))?(a):(b))
#endif

#define PKT struct _PKT
#define PNODE	struct _PNODE

#define BTOC(yow)           ((ubyte *)((long)(yow) << 2))
#define DNETPORTNAME	    "DNET.UNIT."
#define OFFSET(ptr,elem)    ((long)((char *)&(ptr)->elem - (char *)(ptr)))

#define EMPTY	0	/*  empty (sent)                    */
#define READY	1	/*  data ready (not sent yet)       */

#define MAXCHAN 128	/*  Max # of channels supported     */
#define SYNC	0xFF	/*  SYNC character		    */
#define MAXPKT	200	/*  maximum packet size 	    */
#define MINPKT	32	/*  minimum maximum packet size
			    (for priority scheme)           */

#define OVERHEAD    7	/*  for packets with data	    */

PNODE {
    NODE    node;
    char    name[32];
    ulong   seg;
};

PKT {
    uword   iolength;	/*  send: length of packet, recv: length of data    */
    ubyte   state;	/*  EMPTY, READY     */

    ubyte   sync;	/*  THE PACKET	    */
    ubyte   ctl;
    ubyte   cchk;
    ubyte   lenh;
    ubyte   lenl;
    ubyte   data[MAXPKT+2];
};

/*  RECEIVER STATES    */
#define RS_SYNC 0	    /*	Waiting for sync		*/
#define RS_CTL	1	    /*	Waiting for command		*/
#define RS_CCHK 2	    /*	Waiting for check byte		*/
#define RS_LEN1 3	    /*	Waiting for MSB length byte	*/
#define RS_LEN2 4	    /*	Waiting for LSB length byte	*/
#define RS_DATA 5	    /*	Waiting for data & checksum	*/

#define DNCMD_OPEN	32  /*	Application open		*/
#define DNCMD_SOPEN	33  /*	Server open			*/
#define DNCMD_CLOSE	34  /*	Close a channel 		*/
#define DNCMD_EOF	35  /*	Will no longer write to channel */

#define DNCMD_WRITE	36  /*	Write data to a channel 	*/
#define DNCMD_QUIT	37  /*	Kill the DNET server		*/
#define DNCMD_IOCTL	38

/*  REQUEST TYPES    */
#define RTO_REQ 	1   /*	Network read timeout		*/
#define WTO_REQ 	2   /*	Network write-ack timeout	*/
#define RNET_REQ	3   /*	Network read data		*/
#define WNET_REQ	4   /*	Network write data sent 	*/
#define PKT_REQ 	5   /*	Returned packets from servers	*/
#define OPEN_REQ	6
#define IGWNET_REQ	7

/* PACKET CONTROL BYTE */
#define PKF_SEQUENCE	0xE0	/*  Sequence #			*/
#define PKF_DATA	0x10	/*  1-65535 bytes		*/
#define PKF_RESERVED	0x08	/*  reserved bit		*/
#define PKF_MASK	0x07	/*  command mask		*/

#define PKCMD_WRITE	1	/*  A DATA packet		*/
#define PKCMD_CHECK	2	/*  Request ACK or NAK for win	*/
#define PKCMD_ACK	3	/*  ACK a window		*/
#define PKCMD_NAK	4	/*  NAK a window		*/
#define PKCMD_RESTART	5	/*  Restart			*/
#define PKCMD_ACKRSTART 6	/*  Restart Acknowledge 	*/
#define PKCMD_RESERVE3	7
/*  CHANNEL COMMANDS	*/
#define SCMD_SWITCH	0x00	/*  switch active channel #	*/
#define SCMD_OPEN	0x01	/*  open a channel		*/
#define SCMD_CLOSE	0x02	/*  close a channel		*/
#define SCMD_ACKCMD	0x03	/*  ack an open/close request	*/
#define SCMD_EOFCMD	0x04	/*  Reof or Weof		*/
#define SCMD_QUIT	0x05	/*  crash dnet			*/
#define SCMD_IOCTL	0x06	/*  ioctl			*/

#define SCMD_DATA	0x08	/*  stream command, DATA	*/

#define CHAN_FREE	0x01	/*  free channel		*/
#define CHAN_ROPEN	0x02	/*  remote open, wait port msg	*/
#define CHAN_LOPEN	0x03	/*  local open, wait reply	*/
#define CHAN_OPEN	0x04
#define CHAN_CLOSE	0x05	/*  see flags			*/
#define CHANF_ROK	0x01	/*  NOT read eof		*/
#define CHANF_WOK	0x02	/*  remote will accept data	*/
#define CHANF_LCLOSE	0x04
#define CHANF_RCLOSE	0x08

struct DChannel {
    PORT    port;	      /*  receive data, replies      */
    PORT    *dnetport;	      /* dnet's master port          */
    LIST    rdylist;	      /* ready to be read	     */
    uword   chan;	      /* channel # for open channels */
    ubyte   eof;	      /* channel remotely closed/eof */
    ubyte   filler;
    int     qlen;	      /* allowed write queue size    */
    int     queued;	      /* current # packets queued    */
};

extern void  *ArbitrateNext();

#ifndef NOEXT
extern IOT Rto; 	       /*  Read-Timeout/reset	       */
extern IOT Wto; 	       /*  Write-Timeout/retry	       */
extern IOR *RNet;	       /*  read-request 	       */
extern IOR *WNet;	       /*  write-request	       */
extern PKT Pkts[9];
extern PKT *Raux;	       /*  next packet in	       */
extern PKT *RPak[4];
extern PKT *WPak[4];
extern PORT *DNetPort;	       /*  Remote Command/Control in	   */
extern PORT *IOSink;	       /*  Return port for ALL IO	   */
extern CHAN Chan[MAXCHAN];
extern LIST TxList;	       /*  For pending DNCMD_WRITE reqs.   */
extern LIST SvList;
extern ubyte Rto_act;
extern ubyte Wto_act;
extern uword RChan;
extern uword WChan;
extern uword RPStart;
extern uword WPStart;
extern uword WPUsed;
extern uword RState;
extern ubyte DDebug;
extern ubyte Restart;
extern ubyte DeldQuit;
extern ubyte AutoHangup;
extern ulong NumCon;
extern ulong WTimeoutVal;
extern ulong RTimeoutVal;
extern long Baud;
extern char *HostName;	    /*	 The Amiga's HostName    */

extern ubyte RestartPkt[3];
extern ubyte AckPkt[8][3];
extern ubyte NakPkt[8][3];
extern ubyte CheckPkt[8][3];
#endif

#ifdef LATTICE
/* One #ifdef LATTICE is worth 1000 U_ARGS macros! */
PORT *DListen(uword);
void DUnListen(PORT *);
PORT *DAccept(PORT *);
DNAAccept(PORT *);
void DPri(struct DChannel *, int);
PORT *DOpen(char * /*host*/, uword /*portnum*/,
	    char /*txpri*/, char /*rxpri*/);
int DNRead(struct DChannel *, char *, int);
int DRead(struct DChannel *, char *, int);
void DQueue(struct DChannel *, int);
DWrite(struct DChannel *, char *, int);
void DEof(struct DChannel *);
void DIoctl(struct DChannel *, ubyte, uword, ubyte);
int DQuit(char *);
void DClose(struct DChannel *);
void WaitMsg(IOR *);
int WaitQueue(struct DChannel *, IOR *);

#endif