411 lines
14 KiB
Text
411 lines
14 KiB
Text
#include "etherShield.h"
|
|
|
|
// please modify the following lines. mac and ip have to be unique
|
|
// in your local area network. You can not have the same numbers in
|
|
// two devices:
|
|
static uint8_t mymac[6] = {0x54,0x55,0x58,0x10,0x00,0x24};
|
|
static uint8_t myip[4] = {192,168,1,88};
|
|
static uint16_t my_port = 1200; // client port
|
|
|
|
// client_ip - modify it when you have multiple client on the network
|
|
// for server to distinguish each ethershield client
|
|
static char client_ip[] = "192.168.1.88";
|
|
|
|
// server settings - modify the service ip to your own server
|
|
static uint8_t dest_ip[4]={192,168,1,4};
|
|
static uint8_t dest_mac[6];
|
|
|
|
enum CLIENT_STATE
|
|
{
|
|
IDLE, ARP_SENT, ARP_REPLY, SYNC_SENT
|
|
};
|
|
|
|
static CLIENT_STATE client_state;
|
|
|
|
static uint8_t client_data_ready;
|
|
|
|
static uint8_t syn_ack_timeout = 0;
|
|
|
|
|
|
#define BUFFER_SIZE 500
|
|
static uint8_t buf[BUFFER_SIZE+1];
|
|
|
|
char sensorData[10];
|
|
|
|
EtherShield es=EtherShield();
|
|
|
|
// prepare the webpage by writing the data to the tcp send buffer
|
|
uint16_t print_webpage(uint8_t *buf);
|
|
int8_t analyse_cmd(char *str);
|
|
// get current temperature
|
|
#define TEMP_PIN 3
|
|
void getCurrentTemp( char *temperature);
|
|
void client_process(void);
|
|
|
|
void setup(){
|
|
|
|
/*initialize enc28j60*/
|
|
es.ES_enc28j60Init(mymac);
|
|
es.ES_enc28j60clkout(2); // change clkout from 6.25MHz to 12.5MHz
|
|
delay(10);
|
|
|
|
/* Magjack leds configuration, see enc28j60 datasheet, page 11 */
|
|
// LEDA=greed LEDB=yellow
|
|
//
|
|
// 0x880 is PHLCON LEDB=on, LEDA=on
|
|
// enc28j60PhyWrite(PHLCON,0b0000 1000 1000 00 00);
|
|
es.ES_enc28j60PhyWrite(PHLCON,0x880);
|
|
delay(500);
|
|
//
|
|
// 0x990 is PHLCON LEDB=off, LEDA=off
|
|
// enc28j60PhyWrite(PHLCON,0b0000 1001 1001 00 00);
|
|
es.ES_enc28j60PhyWrite(PHLCON,0x990);
|
|
delay(500);
|
|
//
|
|
// 0x880 is PHLCON LEDB=on, LEDA=on
|
|
// enc28j60PhyWrite(PHLCON,0b0000 1000 1000 00 00);
|
|
es.ES_enc28j60PhyWrite(PHLCON,0x880);
|
|
delay(500);
|
|
//
|
|
// 0x990 is PHLCON LEDB=off, LEDA=off
|
|
// enc28j60PhyWrite(PHLCON,0b0000 1001 1001 00 00);
|
|
es.ES_enc28j60PhyWrite(PHLCON,0x990);
|
|
delay(500);
|
|
//
|
|
// 0x476 is PHLCON LEDA=links status, LEDB=receive/transmit
|
|
// enc28j60PhyWrite(PHLCON,0b0000 0100 0111 01 10);
|
|
es.ES_enc28j60PhyWrite(PHLCON,0x476);
|
|
delay(100);
|
|
|
|
//init the ethernet/ip layer:
|
|
es.ES_init_ip_arp_udp_tcp(mymac,myip,80);
|
|
|
|
// intialize varible;
|
|
syn_ack_timeout =0;
|
|
client_data_ready = 0;
|
|
client_state = IDLE;
|
|
// initialize DS18B20 datapin
|
|
digitalWrite(TEMP_PIN, LOW);
|
|
pinMode(TEMP_PIN, INPUT); // sets the digital pin as input (logic 1)
|
|
|
|
|
|
}
|
|
|
|
void loop(){
|
|
|
|
if(client_data_ready==0){
|
|
delay(60000UL); // delay 60s
|
|
getCurrentTemp(sensorData);
|
|
client_data_ready = 1;
|
|
}
|
|
client_process();
|
|
|
|
}
|
|
|
|
uint16_t gen_client_request(uint8_t *buf )
|
|
{
|
|
uint16_t plen;
|
|
byte i;
|
|
|
|
plen= es.ES_fill_tcp_data_p(buf,0, PSTR ( "GET /ethershield_log/save.php?pwd=secret&client=" ) );
|
|
for(i=0; client_ip[i]!='\0'; i++){
|
|
buf[TCP_DATA_P+plen]=client_ip[i];
|
|
plen++;
|
|
}
|
|
plen= es.ES_fill_tcp_data_p(buf,plen, PSTR ( "&status=temperature-" ) );
|
|
for(i=0; sensorData[i]!='\0'; i++){
|
|
|
|
buf[TCP_DATA_P+plen]=sensorData[i];
|
|
plen++;
|
|
}
|
|
|
|
|
|
plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( " HTTP/1.0\r\n" ));
|
|
plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "Host: 192.168.1.4\r\n" ));
|
|
plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "User-Agent: AVR ethernet\r\n" ));
|
|
plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "Accept: text/html\r\n" ));
|
|
plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "Keep-Alive: 300\r\n" ));
|
|
plen= es.ES_fill_tcp_data_p(buf, plen, PSTR ( "Connection: keep-alive\r\n\r\n" ));
|
|
|
|
return plen;
|
|
}
|
|
|
|
//*****************************************************************************************
|
|
//
|
|
// Function : client_process
|
|
// Description : send temparature to web server, this option is disabled by default.
|
|
// YOU MUST install webserver and server script before enable this option,
|
|
// I recommented Apache webserver and PHP script.
|
|
// More detail about Apache and PHP installation please visit http://www.avrportal.com/
|
|
//
|
|
//*****************************************************************************************
|
|
void client_process ( void )
|
|
{
|
|
uint16_t plen;
|
|
uint8_t i;
|
|
|
|
if (client_data_ready == 0) return; // nothing to send
|
|
|
|
if(client_state == IDLE){ // initialize ARP
|
|
es.ES_make_arp_request(buf, dest_ip);
|
|
|
|
client_state = ARP_SENT;
|
|
return;
|
|
}
|
|
|
|
|
|
if(client_state == ARP_SENT){
|
|
|
|
plen = es.ES_enc28j60PacketReceive(BUFFER_SIZE, buf);
|
|
|
|
// destination ip address was found on network
|
|
if ( plen!=0 )
|
|
{
|
|
if ( es.ES_arp_packet_is_myreply_arp ( buf ) ){
|
|
client_state = ARP_REPLY;
|
|
syn_ack_timeout=0;
|
|
return;
|
|
}
|
|
|
|
}
|
|
delay(10);
|
|
syn_ack_timeout++;
|
|
|
|
|
|
if(syn_ack_timeout== 100) { //timeout, server ip not found
|
|
client_state = IDLE;
|
|
client_data_ready =0;
|
|
syn_ack_timeout=0;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// send SYN packet to initial connection
|
|
if(client_state == ARP_REPLY){
|
|
// save dest mac
|
|
for(i=0; i<6; i++){
|
|
dest_mac[i] = buf[ETH_SRC_MAC+i];
|
|
}
|
|
|
|
es.ES_tcp_client_send_packet (
|
|
buf,
|
|
80,
|
|
1200,
|
|
TCP_FLAG_SYN_V, // flag
|
|
1, // (bool)maximum segment size
|
|
1, // (bool)clear sequence ack number
|
|
0, // 0=use old seq, seqack : 1=new seq,seqack no data : new seq,seqack with data
|
|
0, // tcp data length
|
|
dest_mac,
|
|
dest_ip
|
|
);
|
|
|
|
client_state = SYNC_SENT;
|
|
}
|
|
// get new packet
|
|
if(client_state == SYNC_SENT){
|
|
plen = es.ES_enc28j60PacketReceive(BUFFER_SIZE, buf);
|
|
|
|
// no new packet incoming
|
|
if ( plen == 0 )
|
|
{
|
|
return;
|
|
}
|
|
|
|
// check ip packet send to avr or not?
|
|
// accept ip packet only
|
|
if ( es.ES_eth_type_is_ip_and_my_ip(buf,plen)==0){
|
|
return;
|
|
}
|
|
|
|
// check SYNACK flag, after AVR send SYN server response by send SYNACK to AVR
|
|
if ( buf [ TCP_FLAGS_P ] == ( TCP_FLAG_SYN_V | TCP_FLAG_ACK_V ) )
|
|
{
|
|
|
|
// send ACK to answer SYNACK
|
|
|
|
es.ES_tcp_client_send_packet (
|
|
buf,
|
|
80,
|
|
1200,
|
|
TCP_FLAG_ACK_V, // flag
|
|
0, // (bool)maximum segment size
|
|
0, // (bool)clear sequence ack number
|
|
1, // 0=use old seq, seqack : 1=new seq,seqack no data : new seq,seqack with data
|
|
0, // tcp data length
|
|
dest_mac,
|
|
dest_ip
|
|
);
|
|
// setup http request to server
|
|
plen = gen_client_request( buf );
|
|
// send http request packet
|
|
// send packet with PSHACK
|
|
es.ES_tcp_client_send_packet (
|
|
buf,
|
|
80, // destination port
|
|
1200, // source port
|
|
TCP_FLAG_ACK_V | TCP_FLAG_PUSH_V, // flag
|
|
0, // (bool)maximum segment size
|
|
0, // (bool)clear sequence ack number
|
|
0, // 0=use old seq, seqack : 1=new seq,seqack no data : >1 new seq,seqack with data
|
|
plen, // tcp data length
|
|
dest_mac,
|
|
dest_ip
|
|
);
|
|
return;
|
|
}
|
|
// after AVR send http request to server, server response by send data with PSHACK to AVR
|
|
// AVR answer by send ACK and FINACK to server
|
|
if ( buf [ TCP_FLAGS_P ] == (TCP_FLAG_ACK_V|TCP_FLAG_PUSH_V) )
|
|
{
|
|
plen = es.ES_tcp_get_dlength( (uint8_t*)&buf );
|
|
|
|
// send ACK to answer PSHACK from server
|
|
es.ES_tcp_client_send_packet (
|
|
buf,
|
|
80, // destination port
|
|
1200, // source port
|
|
TCP_FLAG_ACK_V, // flag
|
|
0, // (bool)maximum segment size
|
|
0, // (bool)clear sequence ack number
|
|
plen, // 0=use old seq, seqack : 1=new seq,seqack no data : >1 new seq,seqack with data
|
|
0, // tcp data length
|
|
dest_mac,
|
|
dest_ip
|
|
);;
|
|
// send finack to disconnect from web server
|
|
|
|
es.ES_tcp_client_send_packet (
|
|
buf,
|
|
80, // destination port
|
|
1200, // source port
|
|
TCP_FLAG_FIN_V|TCP_FLAG_ACK_V, // flag
|
|
0, // (bool)maximum segment size
|
|
0, // (bool)clear sequence ack number
|
|
0, // 0=use old seq, seqack : 1=new seq,seqack no data : >1 new seq,seqack with data
|
|
0,
|
|
dest_mac,
|
|
dest_ip
|
|
);
|
|
|
|
return;
|
|
|
|
}
|
|
// answer FINACK from web server by send ACK to web server
|
|
if ( buf [ TCP_FLAGS_P ] == (TCP_FLAG_ACK_V|TCP_FLAG_FIN_V) )
|
|
{
|
|
// send ACK with seqack = 1
|
|
es.ES_tcp_client_send_packet(
|
|
|
|
buf,
|
|
80, // destination port
|
|
1200, // source port
|
|
TCP_FLAG_ACK_V, // flag
|
|
0, // (bool)maximum segment size
|
|
0, // (bool)clear sequence ack number
|
|
1, // 0=use old seq, seqack : 1=new seq,seqack no data : >1 new seq,seqack with data
|
|
0,
|
|
dest_mac,
|
|
dest_ip
|
|
);
|
|
client_state = IDLE; // return to IDLE state
|
|
client_data_ready =0; // client data sent
|
|
}
|
|
}
|
|
}
|
|
|
|
void OneWireReset(int Pin) // reset. Should improve to act as a presence pulse
|
|
{
|
|
digitalWrite(Pin, LOW);
|
|
pinMode(Pin, OUTPUT); // bring low for 500 us
|
|
delayMicroseconds(500);
|
|
pinMode(Pin, INPUT);
|
|
delayMicroseconds(500);
|
|
}
|
|
|
|
void OneWireOutByte(int Pin, byte d) // output byte d (least sig bit first).
|
|
{
|
|
byte n;
|
|
|
|
for(n=8; n!=0; n--)
|
|
{
|
|
if ((d & 0x01) == 1) // test least sig bit
|
|
{
|
|
digitalWrite(Pin, LOW);
|
|
pinMode(Pin, OUTPUT);
|
|
delayMicroseconds(5);
|
|
pinMode(Pin, INPUT);
|
|
delayMicroseconds(60);
|
|
}
|
|
else
|
|
{
|
|
digitalWrite(Pin, LOW);
|
|
pinMode(Pin, OUTPUT);
|
|
delayMicroseconds(60);
|
|
pinMode(Pin, INPUT);
|
|
}
|
|
|
|
d=d>>1; // now the next bit is in the least sig bit position.
|
|
}
|
|
|
|
}
|
|
|
|
byte OneWireInByte(int Pin) // read byte, least sig byte first
|
|
{
|
|
byte d, n, b;
|
|
|
|
for (n=0; n<8; n++)
|
|
{
|
|
digitalWrite(Pin, LOW);
|
|
pinMode(Pin, OUTPUT);
|
|
delayMicroseconds(5);
|
|
pinMode(Pin, INPUT);
|
|
delayMicroseconds(5);
|
|
b = digitalRead(Pin);
|
|
delayMicroseconds(50);
|
|
d = (d >> 1) | (b<<7); // shift d to right and insert b in most sig bit position
|
|
}
|
|
return(d);
|
|
}
|
|
|
|
|
|
void getCurrentTemp(char *temp)
|
|
{
|
|
int HighByte, LowByte, TReading, Tc_100, sign, whole, fract;
|
|
|
|
OneWireReset(TEMP_PIN);
|
|
OneWireOutByte(TEMP_PIN, 0xcc);
|
|
OneWireOutByte(TEMP_PIN, 0x44); // perform temperature conversion, strong pullup for one sec
|
|
|
|
OneWireReset(TEMP_PIN);
|
|
OneWireOutByte(TEMP_PIN, 0xcc);
|
|
OneWireOutByte(TEMP_PIN, 0xbe);
|
|
|
|
LowByte = OneWireInByte(TEMP_PIN);
|
|
HighByte = OneWireInByte(TEMP_PIN);
|
|
TReading = (HighByte << 8) + LowByte;
|
|
sign = TReading & 0x8000; // test most sig bit
|
|
if (sign) // negative
|
|
{
|
|
TReading = (TReading ^ 0xffff) + 1; // 2's comp
|
|
}
|
|
Tc_100 = (6 * TReading) + TReading / 4; // multiply by (100 * 0.0625) or 6.25
|
|
|
|
whole = Tc_100 / 100; // separate off the whole and fractional portions
|
|
fract = Tc_100 % 100;
|
|
|
|
if(sign) temp[0]='-';
|
|
else temp[0]='+';
|
|
|
|
|
|
temp[1]= (whole-(whole/100)*100)/10 +'0' ;
|
|
temp[2]= whole-(whole/10)*10 +'0';
|
|
|
|
temp[3]='.';
|
|
temp[4]=fract/10 +'0';
|
|
temp[5]=fract-(fract/10)*10 +'0';
|
|
|
|
temp[6] = '\0';
|
|
}
|