home *** CD-ROM | disk | FTP | other *** search
-
- /*
- * 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
-
-