bosko lekovic
nova proba
Diff: TcpClients.cpp
- Revision:
- 27:0772451fb880
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/TcpClients.cpp Sun Jan 17 23:03:43 2021 +0100
@@ -0,0 +1,243 @@
+#include "mbed.h"
+#include "platform/mbed_thread.h"
+#include "clubbing.h"
+#include "EthernetSetup.h"
+#include "TcpClients.h"
+#include "doHTML.h"
+
+extern EthernetInterface *gp_eth;
+extern C_HTMLparse * gpc_html;
+
+
+
+struct SThreadParam
+{
+ Thread *p_Thread; // sopstveni pointer
+ void * p_param; // pointer za parametre thread-a, u ovom slucaju na socket koji je accept-van
+};
+
+volatile static struct S_EthernetAddress_Remote
+{
+ char ip[16];
+ int port;
+ int validy;
+ TCPSocket *p_tcpSocket;
+ Thread *p_tcpThread;
+ int txError;
+ int rxStatus;
+} s_EthAddRemote[NO_TCP] , *ps_ear[NO_TCP];//
+
+//static TCPSocket *gp_tcpSocket[NO_TCP] = {NULL};
+//static Thread *gp_tcpRxThread[NO_TCP] = {NULL};
+
+
+static int myTcpPort = 11000;
+
+void tcpRx_fun( int* par_i );
+
+/************* inicijalizacija parametara **********************/
+
+int get_rxStatus( int i )
+{
+ return s_EthAddRemote[i].rxStatus;
+}
+int get_rxValidy( int i )
+{
+ return s_EthAddRemote[i].validy;
+}
+
+void init_tcp_param( void )
+{
+ // printf("my tcp port = %s\n\r", gpc_html->get_myTcpPort( )); F
+
+ if( test_num(gpc_html->get_myTcpPort( ))) myTcpPort = atoi( gpc_html->get_myTcpPort( ));
+ printf( " myTcpPort = %d\n\r", myTcpPort);
+
+#if NO_TCP>0
+
+ for( int i=1; i<= NO_TCP; i++)
+ {
+ const char *sp, *sip=gpc_html->get_TcpIP(i);
+
+ // treba popraviti, IP(4) i IP(5) su opseg adresa
+ if( i < 5 ) sp = gpc_html->get_TcpPort(i);
+ else
+ {
+ sp = gpc_html->get_TcpPort(4);
+ }
+
+ ps_ear[i-1] = &(s_EthAddRemote[i-1]);
+
+ if( test_ip( sip ) && test_num( sp ) )
+ {
+ strncpy( (char *)ps_ear[i-1]->ip, sip, 16 );
+ ps_ear[i-1]->port = atoi( sp );
+ ps_ear[i-1]->validy = 1;
+ }
+ else
+ {
+ ps_ear[i-1]->validy = 0;
+ }
+
+ ps_ear[i-1]->rxStatus = 0;
+ // printf(" TCP IP adresa: %s port = %d validy=%d \n\r", ps_ear[i-1]->ip, ps_ear[i-1]->port, ps_ear[i-1]->validy );
+
+ }
+#endif
+}
+
+//
+
+void start_TcpClients( void )
+{
+ printf( "start tcp clients\n\r");
+
+ init_tcp_param( );
+
+ for( int i=0; i< NO_TCP; i++)
+ {
+ int *p_i = new int;
+ *p_i = i;
+ ps_ear[i]->p_tcpThread = new Thread;
+ ps_ear[i]->p_tcpThread->start(callback( tcpRx_fun, p_i));
+ //printf(" TCP Clients start: Thread[%d]=%d\n\r", i, ps_ear[i]->p_tcpThread );
+ }
+}
+
+
+/***************** Predaja na TCP ****************************/
+
+
+void sendTcpi( int i, char *buffer, int val )
+{
+#if NO_TCP>0
+
+ if( ps_ear[i]->p_tcpSocket && ps_ear[i]->validy && (ps_ear[i]->rxStatus == 3))
+ {
+ ps_ear[i]->txError = ps_ear[i]->p_tcpSocket->send(buffer, val);
+ // static int i = 0; printf("tcp %d\n\r", i++);
+ // printf(" TCPpaket ip=%s port=%d val=%d err=%d stat=%d\n\r", ps_ear[i]->ip, ps_ear[i]->port, val, ps_ear[i]->txError, getEthernetStatus( ) );
+ }
+ else printf("TCPsocket[%d] == NULL\n\r", i);
+#endif
+}
+
+void sendToTcp( char *buffer, int val )
+{
+
+#if NO_TCP>0
+ for( int i=0; i< NO_TCP; i++ )
+ if( ps_ear[i]->validy ) {sendTcpi( i, buffer, val ); ThisThread::yield(); /* thread_sleep_for(200);*/}
+
+#endif
+}
+
+
+
+/*************** Prijem na TCP socket i predaja na Serial com ***************/
+
+void tcpRx_fun( int* par_i )
+{
+ int i = *par_i;
+ delete par_i;
+
+ char inbuff[1500];
+ps_ear[i]->rxStatus = 0;
+ //printf("tcpClient[%d]: rx thread inicijalizovan \n\r",i);
+
+ while( !(ThisThread::flags_get( ) & 4) ) // flag za izlaz iz Thread-a
+ {
+ps_ear[i]->rxStatus=1;
+ nsapi_error_t err;
+
+ if(ps_ear[i]->validy)
+ {
+
+ TCPSocket *p_sock = ps_ear[i]->p_tcpSocket = new TCPSocket;
+ // printf("\n\rtcpClient[%d]: novi TCP socket %x\n\r", i, p_sock);
+
+ while( !(ThisThread::flags_get( ) & 2) ) // fleg za gasenje socket-a
+ {
+ps_ear[i]->rxStatus = 2;
+ if( (err = p_sock->open( gp_eth )) == NSAPI_ERROR_OK )
+ {
+ int port = ps_ear[i]->port;
+ char *ip = (char*)ps_ear[i]->ip;
+ p_sock->bind( port );
+ if( (err = p_sock->connect(ip, port)) == NSAPI_ERROR_OK)
+ {
+ printf("tcpClient[%d]:konektovan na ip=%s, port=%d\n\r",i, ip, port);
+ //!!! p_sock->set_timeout(100);
+ signed int n=0;
+ while(!(ThisThread::flags_get( ) & 1) ) // fleg za izlaz iz konekcije
+ {
+ps_ear[i]->rxStatus = 3;
+ if( (n>=0) )
+ {
+ n = p_sock->recv( inbuff, sizeof(inbuff));
+
+ if(n>0) { extern void sendToScom( char *buffer, int val ); sendToScom( inbuff, n); }
+ //!!! else if(n==-3001) n = 0; // nije prava greska, isteklo vreme timeouta
+ else {printf("\n\rtcpClient[%d]: break na receive err=%d\n\r", i,n); break; }
+ }
+
+ } //while 1
+ps_ear[i]->rxStatus = 2;
+ ThisThread::flags_clear(1);
+ //!!! p_sock->set_timeout(-1);
+ p_sock->close();
+ } // connected
+ else printf("tcpClient[%d]: greska konekcije rxThread %d\n\r", i, err);
+ } // open
+ else printf("tcpClient[%d]: greska otvaranja soketa err=%d \n\r",i, err);
+ thread_sleep_for(1000); // dremni pre ponovnog pokusaja konekcije
+ break; // izlaz iz while 2, brisanje socket-a i ponovno otvaranje
+ } // while 2
+ps_ear[i]->rxStatus = 1;
+ ThisThread::flags_clear(2);
+
+ printf("tcpClient[%d]:___zatvaranje TCP socket= %x\n\r",i, p_sock);
+ delete p_sock;
+ p_sock = NULL;
+ thread_sleep_for(1000); // dremni pre ponovnog konstrukcije socketa
+
+ } // if validy
+
+
+ }// while 4
+ ThisThread::flags_clear(4);
+ps_ear[i]->rxStatus = 0;
+
+ printf("tcpClient[%d]: izlaz iz rxThread\n\r", i);
+ fflush(stdout);
+
+}
+
+void restart_TcpClientConnection( int noClient, int restartType )
+{
+ if( (noClient < NO_TCP) && (restartType <= (1+2+4)) )
+ {
+ ps_ear[noClient]->p_tcpThread->flags_set(restartType);
+ if( restartType & 4 )
+ {
+ ps_ear[noClient]->p_tcpThread->join();
+ printf("TCP Client Thread[%d]=%d zavrsen\n\r",noClient, ps_ear[noClient]->p_tcpThread);
+ }
+ }
+}
+
+void restart_TcpClientsConnection( int restartType )
+{
+ init_tcp_param( );
+ for(int i=0; i<NO_TCP; i++)
+ {
+ if(ps_ear[i]->rxStatus)
+ restart_TcpClientConnection( i, restartType);
+ }
+}
+
+void restart_TcpClients( void )
+{
+ restart_TcpClientsConnection(7);
+ start_TcpClients();
+}