?? main.c
字號:
// 本程序的晶體為 22.1184mHz
// 本程序的缺省IP 192.168.0.7
// 本程序的缺省mask 255.255.255.0
// 本程序的缺省mac 0x1234567890ab
// 本程序的缺省gate 0.0.0.0(無網關)
// 本程序的缺省端口號port 9000
// 本程序的缺省remote_ip 192.168.0.1
//#include <reg52.h>
#include <absacc.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <intrins.h>
#include "24c02.h"
#include "ethernet.h"
#include "ip.h"
#include "udp.h"
//波特率 是在smod=1 的情況下計算的
#define FALSE 0
#define TRUE 1
#define false 0
#define true 1
#define BPS600 0x40
#define BPS1200 0xA0
#define BPS2400 0xD0
#define BPS4800 0xE8
#define BPS9600 0xF4
#define BPS14400 0xF8
#define BPS19200 0xFA
#define BPS28800 0xFC
#define BPS38400 0xFD
#define timer_5ms_value 0xDC00
#define timer_10ms_value 0xB800
#define timer_20ms_value 0x7000
#define rom_ip 0x00
#define rom_mask 0x04
#define rom_gate 0x08
#define rom_remote_ip 0x0c
#define rom_mac 0x10
#define rom_port 0x16
#define ARP_TX 1 /* Client state: sending ARP */
#define ARP_RX 2 /* received ARP */
#define CLIENT_DONE 3 /* completed */
#define HIGH(x) (x &0xff00)>>8
#define LOW(x) (x &0xff)
sbit watch_dog=0xb5;
#define BCASTADDR 0xff,0xff,0xff,0xff,0xff,0xff // broadcast address
BYTE bcast[MACLEN]={BCASTADDR}; // 該變量為源廣播地址mac
BYTE code default_mac[MACLEN]={0x12,0x34,0x56,0x78,0x90,0xab};
bit uart_receive_enable; // 串口接收允許標志
bit uart_receiving; // 串口正在接收標志
bit uart_received_finished; // 串口接收完成標志
bit uart_trans_willing; // 串口將要發送標志
bit uart_trans_finished; // 串口發送完成標志，表示串口處于發送空閑狀態
unsigned char uart_receive_buf[250]; // 接收緩沖區
unsigned char uart_trans_buf[250]; // 發送緩沖區
unsigned char uart_trans_count; // 發送數據計數器
unsigned char uart_receive_count; // 接收的數據計數器
unsigned char uart_trans_length; // 將要發送的數據長度
unsigned char uart_char_space; // 串口幀內間隔計數器(10ms) 最大為60ms
unsigned char uart_frame_space; // 串口幀間間隔計數器(10ms) 最小為80ms
unsigned char data dog; // 看門狗計數器(10ms) 最大為120 ms
#define clear_watchdog() watch_dog=1; _nop_();_nop_();_nop_();_nop_();dog=0;watch_dog=0
bit being_echo; // 網絡要求遠端返回數據標志，表示要判斷網絡超時
bit remote_echo;
bit first_arp;
unsigned int net_overtime_count; // 網絡發送超時計數器
ETHERFRAME etherframe;
NODE locnode; /* My Ethernet and IP addresses */
NODE remnode; /* Remote node */
extern BYTE mymac[MACLEN]; // 該變量為ethernet.c 用源地址mac
void system_init(void);
void flush_gate_mac();
void do_uart_process(void);
int do_net_process(ETHERFRAME *efp,int rxlen);
int udp_receive(ETHERFRAME *efp, int len);
void send_ip(void);
unsigned long runtime;
void system_init(void)
{
EA=0;
SCON=0xD2; // SM0,SM1,SM2,REN,TB,RB,TI,RI
// 9位數據位,一位停止位,允許串行中斷
PCON=0x80; // SMOD=1, 波特率加倍
TMOD=0x21; // GATE C/T M1 M0 GATE C/T M1 M0
// 定時器1在自動裝入方式,0 位16位方式
TCON=0x50; // TF1 TR1 TF0 TR0 IE1 IT1 IE0 IT0
// 定時器運行狀態，不允許外部中斷
TH1=BPS4800;
TL1=BPS4800;
TH0=HIGH(timer_10ms_value); //16位10ms 定時器
TL0=LOW(timer_10ms_value);
IE=0x92; // EA ? ? ES ET1 EX1 ET0 EX0
IP=0x02;
clear_watchdog();
}
void main(void)
{
int rxlen;
int ret;
unsigned char temp[6];
clear_watchdog();
delay_ms(2);
system_init(); //設置單片機的定時器 T0 (10ms),及 串口的波特率4800bps
uart_receiving=FALSE; // 串口正在接收標志 為 false
uart_receive_enable=TRUE; // 串口接收允許為 TRUE
uart_received_finished=FALSE; // 串口接收完成標志 為 false
uart_trans_count=0; // 串口發送完成字節數
uart_trans_willing=0; // 串口將要發送請求標志
uart_trans_finished=TRUE; // 串口發送完成，處于發送空閑狀態
uart_char_space=0;
uart_frame_space=0;
// 因為8051 單片機的Keil C編譯器編譯結果整數高位字節在前
// 在讀取24c02 中的數據時，讀一個整數為順序讀取其中連續的2個字節
// 讀一個長整數為順序讀取其中連續的4個字節
read24c02(temp,rom_ip,4); //讀取本機的ip
locnode.ip=*((LWORD*)temp);
//如果IP未設置，設置IP為 192.168.0.7
if (locnode.ip==0xffffffff || locnode.ip==0x0) locnode.ip=0xc0a80007;
read24c02(temp,rom_mask,4); //讀取本機的ip掩碼
locnode.mask=*((LWORD*)temp);
//如果IP掩碼未設置，設置IP掩碼為 255.255.255.0
if (locnode.mask==0xffffffff ||locnode.mask==0x00) locnode.mask=0xffffff00;
read24c02(temp,rom_gate,4); //讀取本機的缺省網關的ip
locnode.gate=*((LWORD*)temp);
//如果IP網關未設置，設置IP網關為 0.0.0.0(不存在網關)
if (locnode.gate==0xffffffff) locnode.gate=0x0;
read24c02(mymac,rom_mac,6); //讀取本機的網卡物理地址
//如果mac未設置，設置mac 為 0x1234567890ab
if (!memcmp(mymac,bcast,6))
memcpy(mymac,default_mac,6);
memcpy(locnode.mac,mymac,6);
read24c02(temp,rom_port,2); //讀取本機的UDP端口號
locnode.port=temp[0]*256+temp[1];
if ((locnode.port==0xffff)||(locnode.port==0x0000))
locnode.port=9000;
remnode.port=locnode.port;
read24c02(temp,rom_remote_ip,4); //讀取本機的控制中心的ip,主動報警時用
remnode.ip=*((LWORD*)temp);
if (remnode.ip==0xffffffff || remnode.ip==0x0) remnode.ip=0xc0a80002;
uart_trans_length=0;
clear_watchdog();
resetnic();
net_overtime_count=0;
runtime=0;
first_arp=1;
flush_gate_mac();
while (1)
{
if (dog>=60) { clear_watchdog(); }
if (uart_received_finished)
do_uart_process();
// 只在串口發送完成后才處理網絡接收
// 旨在保證在單發送緩沖區情況下不會覆蓋，
// 在多發送緩沖區的情況下不會溢出。
if (uart_trans_finished)
if ((rxlen=get_ethernet(ðerframe))>0)
{
ret=do_net_process(ðerframe,rxlen);
if (ret==ARP_RX)
{
being_echo=false; // 表示ARP全過程完成,對方返回了其MAC
net_overtime_count=0; // 清除等待網絡響應延時計數器,為下一次處理初始化
}
if (ret==CLIENT_DONE) // 表示應用的UDP數據包接收完成
{
}
}
if (runtime>=120000) //120000 *10ms =20 minute
{
runtime=0;
first_arp=1;
flush_gate_mac(); //刷新網關的物理地址mac
}
}
}
/*************************************************************************/
// 通過計數器uart_char_space 判斷串口60MS沒有新數據到達就認為一幀數據接收完成
// 在網絡要求遠端返回數據狀態下，網絡超時計數器加 1(10ms)
/*************************************************************************/
void timer0_interrupt(void) interrupt 1
{
TL0=TL0+LOW(timer_10ms_value); //reload timer0
TH0=TH0+HIGH(timer_10ms_value);
if (uart_receiving)
{
if (uart_char_space<6)
uart_char_space++;
else
{
uart_receiving=false;
uart_receive_enable=false;
uart_received_finished=true;
uart_frame_space=0;
}
uart_frame_space=0;
}
else
{
if (!uart_receive_enable)
{
uart_frame_space++;
if (uart_frame_space>8)
{
uart_frame_space=0;
uart_receive_enable=true;
}
}
}
if (uart_trans_willing)
{
uart_trans_willing=false;
TI=1;
}
if (being_echo)
{
net_overtime_count++;
if (net_overtime_count>18000)
{
being_echo=0;
if (first_arp)
first_arp=0;
else
remote_echo=1;
net_overtime_count=0;
}
}
runtime++;
dog++;
}
/*************************************************************************/
// 串口中斷程序，該程序在認為串口的接收是終端在響應串口的發送
// 在串口未發送完成之前，不處理完羅接收的數據
/*************************************************************************/
void uart_interrupt(void) interrupt 4
{
if (RI)
{
RI=0;
if ((!uart_received_finished)&& uart_receive_enable)
{
if (!uart_receiving)
{
uart_receiving=1;
uart_receive_count=0;
uart_receive_buf[uart_receive_count++]=SBUF;
}
else
{
uart_char_space=0;
uart_receive_buf[uart_receive_count++]=SBUF;
}
}
}
if (TI)
{
TI=0;
if (uart_trans_count<uart_trans_length)
{
ACC=uart_trans_buf[uart_trans_count++];
TB8=P;
SBUF=ACC;
}
else
{
uart_trans_finished=1;
uart_trans_count=0;
uart_trans_length=0;
}
}
}
//*******************************************************************************
/* Receive a UDP datagram: return non-0 if client state-change */
int udp_receive(ETHERFRAME *efp, int len)
{
UDPKT *udp;
int ret=0;
NODE loc, rem;
udp = (UDPKT *)efp->edata;
getudp_srce(efp, &rem); /* Get srce & dest nodes */
getudp_locdest(efp, &loc);
if (loc.port == locnode.port) /* Client response */
{
// UDP 將數據拷貝至串口接收緩沖區，置接收完成標志(在合并方式)
// UDP 將數據拷貝至串口發送緩沖區，置發送標志(在模塊方式)
EA=0;
memcpy(uart_trans_buf+uart_trans_length,udp->udpdata,len);
uart_trans_length=uart_trans_length+len;
uart_trans_finished=0;
if (uart_trans_count==0)
uart_trans_willing=1;
EA=1;
ret = CLIENT_DONE; /* ..and exit */
}
else if (loc.port == ECHOPORT) /* Echo req: resend data */
udp_transmit(efp, &loc, &rem, udp->udpdata, len);
return(ret);
}
/*****************************************************************/
//本機的網絡處理子程序
//
/*****************************************************************/
int do_net_process(ETHERFRAME *efp,int rxlen)
{
ARPKT *arp;
IPKT *ip;
ICMPKT *icmp;
NODE node;
int txlen;
int len;
int ret=0;
ip=(IPKT *)efp->edata;
if (is_arp(efp,rxlen))
{
arp = (ARPKT *)efp->edata;
if (arp->op==ARPREQ && arp->dip==locnode.ip)
{ /* ARP request? */
node.ip = arp->sip; /* Make ARP response */
memcpy(node.mac, arp->smac, MACLEN);
txlen = make_arp(efp, &locnode, &node, ARPRESP);
put_ethernet(efp, txlen); /* Send packet */
}
if (arp->op==ARPRESP && arp->dip==locnode.ip)
{ /* ARP response? */
memcpy(remnode.mac,arp->smac, MACLEN);
being_echo=0;
if (first_arp)
first_arp=0;
else
remote_echo=1;
ret = ARP_RX;
}
}
else if ((rxlen=is_ip(efp, rxlen))!=0) /* IP datagram? */
if (ip->i.dip==locnode.ip || ip->i.dip==BCASTIP)
{
getip_srce(efp, &node);
if ((len=is_icmp(ip, rxlen))!=0) /* ICMP? */
{
icmp = (ICMPKT *)ip;
if (icmp->c.type == ICREQ) /* Echo request? */
{
len = (WORD)max(len, 0); /* Make response */
txlen = make_icmp(efp, &locnode, &node, ICREP,
icmp->c.codetype, (WORD)len);
put_ethernet(efp, txlen); /* Send packet */
}
// else if (icmp->c.type == ICUNREACH)
// printf("\r\nICMP: destination unreachable\r\n");
}
else if ((len=is_udp(ip, rxlen))!=0) /* UDP? */
{
ret = udp_receive(efp, max(len, 0));
}
}
return (ret);
}
//**********************************
void flush_gate_mac()
{
int ret;
remote_echo=0;
remnode.mac[0]=0xff;
remnode.mac[1]=0xff;
remnode.mac[2]=0xff;
remnode.mac[3]=0xff;
remnode.mac[4]=0xff;
remnode.mac[5]=0xff;
ret=make_arp(ðerframe,&locnode, &remnode, ARPREQ); //請求網關或控制主機的物理地址
put_ethernet(ðerframe,ret);
being_echo=1;
}
//************************************************
void do_uart_process(void)
{
if (being_echo==0) // 1 arp wait response
{
if (remote_echo==0)
{
if (!memcmp(remnode.mac, bcast, MACLEN))
flush_gate_mac();
else
send_ip();
}
else
{
remote_echo=0;
send_ip();
}
}
}
//************************************************
void send_ip(void)
{
int ret;
memcpy((BYTE *)ðerframe+sizeof(ETHERHDR)+sizeof(IPHDR)+sizeof(UDPHDR),uart_receive_buf,uart_receive_count);
remnode.port=locnode.port;
ret=make_udp(ðerframe, &locnode,&remnode,(WORD)(uart_receive_count));
uart_received_finished=0;
uart_receive_count=0;
put_ethernet(ðerframe,ret);
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -