PC Toledo

Código: Selecionar todos

// TCPIP.C
// bcc -c -ml -w tcpip.c
// blinker ... search blxclp53 ...

#include <string.h>
#include <extend.api>
#include <blx286.h>

#define BUFF_SIZE 0x2000
#define PROTOCOL_TCP 6

#define NO_ERROR 0
#define ERR_SOCKET 100
#define ERR_NO_SOCKET 101
#define ERR_PARAMETERS 102
#define ERR_BLINKX_API 103
#define ERR_NO_TCP_STACK 104
#define ERR_POINTER 105
#define ERR_NO_POINTER 106

typedef struct
{
BYTE _dummy1[21], function, socket, error_code;
WORD port;
BYTE ip[4];
WORD _dummy2, length_of_packet, pointer;
BYTEP rm_buff;
WORD length_of_buffer;
BYTE _dummy3[120 /* ? */];
} RCB, *RCBP; // Request Control Block

extern FARP _xalloclow(WORD);
extern void _xfreelow(FARP);
extern FARP _bset(FARP, int, WORD);

HIDE REALPTR TCPIPstack_entry_point = NULL;
HIDE RCBP pm_rcb = NULL, rm_rcb;
HIDE BYTEP pm_buff, rm_buff;
HIDE BYTE socket = 0, error_code = NO_ERROR;

HIDE void near ndot2ip(BYTEP ip, BYTEP pdot)
{
int i, ch;

_bset(ip, 0, 4);
for(i = 0; i < 4; i++) do
{
if((ch = *pdot++) == '\0') return;
if(ch >= '0' && ch <= '9') ip[i] = ip[i] * 10 + ch - '0';
} while(ch != '.');
}

HIDE BOOL near rm_call(void)
{
REGS16 regs16;

pm_rcb->socket = socket;
pm_rcb->error_code = 0xff;
_bset((void*) regs16, 0, sizeof(REGS16));
regs16.es = SELECTOROF(rm_rcb);
regs16.si = OFFSETOF (rm_rcb);
if(DosRealFarCall(TCPIPstack_entry_point
, regs16, NULL, 0) != 0)
{error_code = ERR_BLINKX_API; return FALSE;}
return (error_code = pm_rcb->error_code) == 0;

HIDE BYTE near _TCP_open(void)
{
REGS16 regs16;

error_code = NO_ERROR;
if(socket != 0) return ERR_SOCKET;
if(PCOUNT < 2 || !ISCHAR(1) || !ISNUM(2)) return ERR_PARAMETERS;

regs16.ax = 0x7a40;
if(DosRealIntr(0x2f, regs16, NULL, 0) != 0) return ERR_BLINKX_API;
if((BYTE)regs16.ax != 0xff) return ERR_NO_TCP_STACK;
if((TCPIPstack_entry_point =
(REALPTR)MK_FP(regs16.es, regs16.di)) == NULL) return ERR_NO_POINTER;

if(pm_rcb != NULL) return ERR_POINTER;
if((pm_rcb = (RCBP)_xalloclow(sizeof(RCB) + BUFF_SIZE)) == NULL)
return ERR_NO_POINTER;
rm_rcb = (RCBP)DosProtToReal(pm_rcb);
pm_buff = (BYTEP)pm_rcb + sizeof(RCB);
rm_buff = (BYTEP)rm_rcb + sizeof(RCB);

_bset(pm_rcb, 0, sizeof(RCB));
pm_rcb->function = 0x11;
pm_rcb->port = PROTOCOL_TCP;
if(!rm_call()) return error_code;
if((socket = pm_rcb->socket) == 0) return ERR_NO_SOCKET;

_bset(pm_rcb, 0, sizeof(RCB));
pm_rcb->function = 4;
pm_rcb->port = ((WORD)_parni(2) >> 8) + (_parni(2) << 8);
ndot2ip(pm_rcb->ip, (BYTEP)_parc(1));
if(!rm_call()) return error_code;

return NO_ERROR;
}

HIDE void near _TCP_close(void)
{
if(socket == 0) return;
_bset(pm_rcb, 0, sizeof(RCB));
pm_rcb->function = 3;
rm_call();
socket = 0;
}

HIDE void near _TCP_free(void)
{
if(pm_rcb == NULL) return;
_xfreelow(pm_rcb);
pm_rcb = NULL;
}

CLIPPER TCP_open(void)
{
BYTE old_socket = socket, result;
RCBP old_pm_rcb = pm_rcb;

if((result = _TCP_open()) != NO_ERROR)
{
if(old_socket == 0 ) _TCP_close();
if(old_pm_rcb == NULL) _TCP_free();
}
_retni((int)(error_code = result));
}

CLIPPER TCP_read(void) // return: string + "\r\n"
{
if(socket == 0) {error_code = ERR_NO_SOCKET; _retc((BYTEP)""); return;}
_bset(pm_rcb, 0, sizeof(RCB));
pm_rcb->function = 0x12;
pm_rcb->length_of_packet = BUFF_SIZE;
pm_rcb->pointer = 1;
pm_rcb->rm_buff = rm_buff;
pm_rcb->length_of_buffer = BUFF_SIZE;
if(!rm_call()) pm_rcb->length_of_packet = 0;
pm_buff[pm_rcb->length_of_packet] = '\0';
_retc(pm_buff);
}

CLIPPER TCP_write(void)
{
if(socket == 0) {error_code = ERR_NO_SOCKET; return;}
if(PCOUNT < 1 || !ISCHAR(1)) {error_code = ERR_PARAMETERS; return;}
strcpy((char*)pm_buff, _parc(1));
_bset(pm_rcb, 0, sizeof(RCB));
pm_rcb->function = 0x14;
pm_rcb->length_of_packet = BUFF_SIZE;
pm_rcb->pointer = 1;
pm_rcb->rm_buff = rm_buff;
pm_rcb->length_of_buffer = strlen((char*)pm_buff);
rm_call();
}

CLIPPER TCP_close(void)
{
if(socket == 0) {error_code = ERR_NO_SOCKET; return;}
_TCP_close();
_TCP_free();
}

CLIPPER TCP_error(void)
{
_retni((int)error_code);
}