bosko lekovic
EthTCPclient_05
Diff: main.cpp
- Revision:
- 0:b01306ccbbe1
- Child:
- 1:10e2a0bef1b4
diff -r 000000000000 -r b01306ccbbe1 main.cpp
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/main.cpp Wed Feb 12 20:25:05 2020 +0000
@@ -0,0 +1,220 @@
+/* mbed Microcontroller Library
+ * Copyright (c) 2019 ARM Limited
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+#include "mbed.h"
+#include "platform/mbed_thread.h"
+
+#include "EthernetInterface.h"
+
+#include <stdio.h>
+#include <string.h>
+#include "TCPSocket.h"
+
+
+void putOnDispNo(int broj, char boja);
+void putOnDisp(char *s, char boja);
+void slanjefun();
+
+#define IP_ADDR "192.168.2.11"
+#define NET_MASK "255.255.248.0"
+#define GATW_ADDR "192.168.1.1"
+#define IP_ADDR_R "192.168.1.9"
+
+
+
+EthernetInterface eth;
+nsapi_error_t err;
+
+
+int strcount( unsigned char *ps)
+{
+ int i=0;
+ for(i=0; ps[i] != 0; i++);
+ return i;
+}
+
+void tcpThread_fun( EthernetInterface *e);
+
+ DigitalOut tast(PTB19,0);
+//RawSerial rs485(PTC17,PTC16);
+RawSerial rs485(PTD3,PTD2);
+
+
+int main(void)
+{
+
+ rs485.format(8, mbed::RawSerial::Even, 1);
+
+ Thread t;
+ // t.start( slanjefun );
+
+
+
+ if( (err = eth.set_network(IP_ADDR,NET_MASK,GATW_ADDR))!= NSAPI_ERROR_OK ) { printf(" greska setovanja mreze %d \n\r", err); return 1; }
+ if( (err = eth.connect()) != NSAPI_ERROR_OK ) { printf(" greska konekcije %d \n\r", err); return 1; }
+
+ const char *ip = eth.get_ip_address() ;
+
+
+ printf( "MAC adresa: %s\n\r", eth.get_mac_address() );
+ printf( "IP adresa: %s\n\r", ip);
+ printf( "net mask: %s\n\r", eth.get_netmask() );
+ printf( "GW adresa: %s\n\r", eth.get_gateway() );
+
+ Thread TCPThread;
+ TCPThread.start( callback( tcpThread_fun, ð ));
+
+ int i=0;
+
+ while(true)
+ {
+ thread_sleep_for(20000);
+ printf("main %d\n\r",i++);
+ }
+ // printf("\n\rmain: Kraj, error=%d\n\r",err); fflush(stdout);
+}
+
+
+
+
+ unsigned char sendBuffer[]= "HTTP/1.1 200 OK\r\nConnection: close\r\nContent-Type: text/html\r\n\r\nMarko je ovde"; // HTTP Message Body, length = 11
+unsigned char sb[1000]="HTTP/1.1 200 OK\r\nConnection: close\r\nContent-Type: text/html\r\n\r\n";
+
+
+
+unsigned char txbuf[100]="test konekcije";
+unsigned char rxbuf[100];
+
+void tcpThread_fun( EthernetInterface *e)
+{
+
+ TCPSocket tcpSocket;
+ nsapi_error_t err=NULL;
+ SocketAddress sa("192.168.2.254", 12197);
+ printf("ip= %s, ver= %d, port= %d\n\r", sa.get_ip_address(), sa.get_ip_version(), sa.get_port() );
+ int i=1;
+
+ while(true)
+ {
+ if((err=tcpSocket.open( e )) ==0 )
+ {
+ if((err = tcpSocket.connect(sa)) == 0)
+ {
+ while( true)
+ {
+ printf("iteracija %d \n\r", i);
+ if(strcount(txbuf) )
+ {
+ printf(" za slanje %d bajtova: %s\n\r", strcount(txbuf), txbuf);
+ if( (err = tcpSocket.send(txbuf,strcount(txbuf))<0 ) ) { printf("send err %d\n\r", err); break; }
+ else(" poslano %d bajtova od: %s\n\r", err, txbuf);
+ memset(txbuf, 0, sizeof(txbuf) );
+ }
+ else
+ {
+ if( (err = tcpSocket.recv(rxbuf,sizeof(rxbuf)) <0 )) { printf("recv err %d\n\r", err); break; }
+ else
+ {
+
+ printf(" prim tel %d: %s\n\r", err, rxbuf) ;
+ {
+ extern void putOnDisp(char *, char );
+ putOnDisp((char*)rxbuf, 1);
+ }
+ memcpy(txbuf, rxbuf, sizeof(txbuf) );
+ memset(rxbuf, 0, sizeof(rxbuf));
+ }
+ }
+ printf("kraj iteracije %d \n\r", i++);
+ fflush(stdout);
+ }
+ }
+ else printf("greska otvaranja konekcije %d\n\r", err);
+ }
+ else printf("greska otvaranja socketa %d\n\r", err);
+
+ printf("zatvaranje konekcije\n\r");
+ tcpSocket.close();
+ thread_sleep_for(2000);
+ }
+}
+
+
+
+
+//
+//enum nsapi_error {
+// NSAPI_ERROR_OK = 0, /*!< no error */
+// NSAPI_ERROR_WOULD_BLOCK = -3001, /*!< no data is not available but call is non-blocking */
+// NSAPI_ERROR_UNSUPPORTED = -3002, /*!< unsupported functionality */
+// NSAPI_ERROR_PARAMETER = -3003, /*!< invalid configuration */
+// NSAPI_ERROR_NO_CONNECTION = -3004, /*!< not connected to a network */
+// NSAPI_ERROR_NO_SOCKET = -3005, /*!< socket not available for use */
+// NSAPI_ERROR_NO_ADDRESS = -3006, /*!< IP address is not known */
+// NSAPI_ERROR_NO_MEMORY = -3007, /*!< memory resource not available */
+// NSAPI_ERROR_NO_SSID = -3008, /*!< ssid not found */
+// NSAPI_ERROR_DNS_FAILURE = -3009, /*!< DNS failed to complete successfully */
+// NSAPI_ERROR_DHCP_FAILURE = -3010, /*!< DHCP failed to complete successfully */
+// NSAPI_ERROR_AUTH_FAILURE = -3011, /*!< connection to access point failed */
+// NSAPI_ERROR_DEVICE_ERROR = -3012, /*!< failure interfacing with the network processor */
+// NSAPI_ERROR_IN_PROGRESS = -3013, /*!< operation (eg connect) in progress */
+// NSAPI_ERROR_ALREADY = -3014, /*!< operation (eg connect) already in progress */
+// NSAPI_ERROR_IS_CONNECTED = -3015, /*!< socket is already connected */
+// NSAPI_ERROR_CONNECTION_LOST = -3016, /*!< connection lost */
+// NSAPI_ERROR_CONNECTION_TIMEOUT = -3017, /*!< connection timed out */
+//};
+
+
+
+
+
+void ev(int){tast=0;}
+
+unsigned char buf_tel[100] = {0x71,0x00,0x0D,0x71,0x43,0x01,0x1B,0x4A,0x01,0x01,0x1B,0x43,1,0x33,0xD5,0x16};
+void putOnDisp( char *s, char boja)
+{
+ int ubb = 13+strlen(s)+1+1-4-2;
+ unsigned char lh, ll;
+ ll=ubb;
+ lh=ubb>>8;
+
+ memcpy(buf_tel+13, s, strlen(s)+2);
+
+ int suma=0;
+ for(int i = 4; i < 13+strlen(s); i++) {
+ suma +=buf_tel[i];
+ }
+
+ buf_tel[13+strlen(s)] = suma;
+ buf_tel[13+strlen(s)+1] = 22;
+ buf_tel[1]=lh;
+ buf_tel[2]=ll;
+
+ fflush(stdout);
+
+ tast=1;
+ rs485.write(buf_tel, 21,ev);
+}
+void putOnDispNo(int broj, char boja)
+{
+ char s[10];
+ sprintf( s, "%d", broj);
+ putOnDisp( s, boja);
+}
+
+
+void slanjefun(){
+
+ int j=0;
+
+
+ while (true) {
+ // printf("disp thred %d\n\r",j);
+ if(j >10 && j<15 ) putOnDisp("des",1);
+ else putOnDispNo(j,1);
+ j++;
+ thread_sleep_for(1000);
+ }
+}