C / C++ / MFC

#include "stdafx.h"

using namespace System;
using namespace System::IO::Ports;

int main(array<System::String ^> ^args)
{
	
	String^ answer;
	String^ portName;
	int baudRate=9600;
	Console::WriteLine("Type in a port name and hit ENTER");
	portName=Console::ReadLine();
	// arduino settings
	SerialPort^ arduino;
	arduino = gcnew SerialPort(portName, baudRate);
	// open port
	try
	{
		arduino->Open();

		do
		{
			// ask on or off
			Console::WriteLine("Type \"on\" to turn the light on or \"off\" to turn it off");
			// get answer
			answer=Console::ReadLine();
			//check that user typed one of the options
			if(String::Compare(answer,"on")==0)
				arduino->WriteLine("1"); // send 1 to arduino
			else if(String::Compare(answer,"off")==0)
				arduino->WriteLine("0"); // send 0 to arduino
			else
				Console::WriteLine(answer+" was not an option");
			// ask user if he wants to continue
			Console::WriteLine("Try again? yes/no");
			// get answer
			answer=Console::ReadLine();
			// clear the screen
			Console::Clear();
		}while(String::Compare(answer,"yes")==0);
		// close port to arduino
		arduino->Close();
	}
	catch (IO::IOException^ e  ) 
	{ 
		Console::WriteLine(e->GetType()->Name+": Port is not ready");
	}
	catch (ArgumentException^ e)
	{
		Console::WriteLine(e->GetType()->Name+": incorrect port name syntax, must start with COM/com");
	}
	// end program
	Console::Write("Press enter to close the program");
	Console::Read();
    return 0;
}

int ledPin = 13;
int state=0;
void setup() {
    pinMode(ledPin, OUTPUT); // pin will be used to for output
    Serial.begin(9600); // same as in your c++ script
}

void loop() {
  if (Serial.available() > 0)
  {
    state = Serial.read(); // used to read incoming data
    
    switch(state)// see what was sent to the board
    {
      case '1': // if the the one was sent
        digitalWrite(ledPin,HIGH);
      break;
      case '0': // if 0 was sent
        digitalWrite(ledPin,LOW);
      break;
      default:
      break; 
    }
  }
}

#include "stdafx.h"

using namespace System;
using namespace System::IO::Ports;
int main()

{
	String^ answer;
	String^ portName;
	int baudRate=9600;
	Console::WriteLine("Type in a port name and hit ENTER");
	portName=Console::ReadLine();
	// arduino settings
	SerialPort^ arduino;
	arduino = gcnew SerialPort(portName, baudRate);
try
	{
		arduino->Open();

		do
		{
			// ask on or off
			Console::WriteLine("Type \"on\" to turn the light on or \"off\" to turn it off");
			// get answer
			answer=Console::ReadLine();
			//check that user typed one of the options

			if (((350<=x)&&(x<=550))&&((200<=y)&&(y<=300)) )
			{
			cout << "Left" ;
			arduino->WriteLine("76");

			cout << "\n" ;
			}
			if (((100<=x)&&(x<=250))&&((200<=y)&&(y<=300))){
				cout << "Right" ;
				arduino->WriteLine("82");
			cout << "\n" ;
			}if (((300<=x)&&(x<=350))&&((300<=y)&&(y<=400))){
				cout << "Back";
			arduino->WriteLine("66");
			cout << "\n" ;
			}
			if (((300<=x)&&(x<=350))&&((80<=y)&&(y<=200))){
				cout << "Froward" ;
			arduino->WriteLine("70");
			cout << "\n" ;
			}
		Console::WriteLine("Try again? yes/no");
			// get answer
			answer=Console::ReadLine();
			// clear the screen
			Console::Clear();
			
			}while(String::Compare(answer,"yes")==0);
		// close port to arduino
		arduino->Close();
	}
	catch (IO::IOException^ e  ) 
	{ 
		Console::WriteLine(e->GetType()->Name+": Port is not ready");
	}
	catch (ArgumentException^ e)
	{
		Console::WriteLine(e->GetType()->Name+": incorrect port name syntax, must start with COM/com");
	}
	// end program
	Console::Write("Press enter to close the program");
	Console::Read();
  
}

Manoj7390 wrote:

How to clock in C++/C for the function of digital blocks.

mbatra31 wrote:

It will be very helpful if you can provide me the sample code for the same scenario.

ForNow wrote:

IS this a strange occurence

 int i;
UINT start_port;

     // Sockevent.SetEvent();

        for (i = 0, start_port = 11007; i < 4; start_port++, i++)
   {
 #ifdef _DEBUG
	   msOld.Checkpoint();
 #endif

         threadptr[i] = new SockCLeintThread(start_port);
 #ifdef _DEBUG

		   msnew.Checkpoint();

 if( diffMemState.Difference(msOld, msnew))
 {
   diffMemState.DumpStatistics();
   diffMemState.DumpAllObjectsSince();
 }
 #endif
 

         
		 
         if (threadptr[i] == NULL)
  	        m_pMainWnd->MessageBox((LPCTSTR)"SockClientThreadFail",NULL,MB_ICONERROR);

	        threadptr[i]->CreateThread(CREATE_SUSPENDED,0,NULL);  
   
                 threadptr[i]->flags.is_connected = 0;
             
                 threadptr[i]->ipaddr = (LPCTSTR)"192.168.1.4";					// ip address
  
 			 threadptr[i]->flags.busy = 0;
 
 			 SetThreadName(threadptr[i]->m_nThreadID,thread[i]);
 					
               
 	
       	 //   threadptr[i]->SetThreadPriority(THREAD_PRIORITY_TIME_CRITICAL); 
 		threadptr[i]->ResumeThread();

		WaitForSingleObject(*pevent,INFINITE);   // wait for connection

//              threadptr[i]->SetThreadPriority(THREAD_PRIORITY_NORMAL);    
		
		}     

BOOL SockCLeintThread::InitInstance()
   {
int error_code, threadpri;
MSG m_msgCur;
extern void SetThreadName( DWORD dwThreadID, LPCSTR szThreadName);
HANDLE mysocket;
int val = sizeof(int);
int *val_ptr = &val;
//  CCriticalSection socklock;
  //         socklock.Lock();

	//	  threadpri = GetThreadPriority();
		    thisocket.Socket(SOCK_STREAM,FD_READ|FD_WRITE|FD_CONNECT,NULL,AF_INET);
			if(thisocket.Bind(thisocket.port,NULL) == 0)
				 error_code = GetLastError();
			int* len = new int;
			thisocket.herccmd= new SOCKADDR;
			if(thisocket.GetSockName(thisocket.herccmd,(int *)len) == 0)
				error_code = GetLastError();
			if(thisocket.GetSockOpt(SO_KEEPALIVE | SO_DEBUG, &thisocket.option,val_ptr,  SOL_SOCKET) == 0)
				 error_code = GetLastError();
		    if(thisocket.SetSockOpt(SO_KEEPALIVE | SO_DEBUG, &thisocket.option,val, SOL_SOCKET) == 0)
				 error_code = GetLastError(); 
		
			 

       //   	 	 if(thisocket.Create(thisocket.port,SOCK_STREAM,FD_READ|FD_WRITE|FD_CONNECT, NULL)== 0)
      //    {
       //                   error_code =  GetLastError();
        //           }
				  

				  if(thisocket.AsyncSelectFD_READ|FD_WRITE|FD_CONNECT|FD_CLOSE|FD_OOB|FD_ACCEPT) == 0) 
 			                   error_code =  GetLastError();
			 

       

         //   SetThreadPriority(THREAD_PRIORITY_HIGHEST); 

 


      //    WaitForSingleObject(Sockevent.m_hObject,INFINITE);

           if( thisocket.Connect(ipaddr,thisocket.port) == 0)
                  {
 		                         error_code =  GetLastError();
                   }
 		   else
 				 	  flags.is_connected = 1;
		  
		//   SetThreadPriority(threadpri);       // set it back
	         //		socklock.Unlock();   
                  // PeekMessage(&m_msgCur, NULL, NULL, NULL, PM_NOREMOVE);   // Create Message Queue



    return TRUE;                                                   // [11]
   }

void SockClient :: OnConnect(int nErrorCode)
  {
	   CAsyncSocket::OnConnect(nErrorCode);
	   CHERC_CMDApp* main_app;
	    main_app = (CHERC_CMDApp *) AfxGetApp(); 
	   	main_app->pevent->SetEvent();

	  if (0 != nErrorCode)
   {
      switch( nErrorCode )
      {
         case WSAEADDRINUSE: 
            AfxMessageBox("The specified address is already in use.\n");
            break;
         case WSAEADDRNOTAVAIL: 
            AfxMessageBox("The specified address is not available from the local machine.\n"); 
               break;
         case WSAEAFNOSUPPORT: 
            AfxMessageBox("Addresses in the specified family cannot be  used with this socket.\n");
              break;
         case WSAECONNREFUSED: 
            AfxMessageBox("The attempt to connect was forcefully rejected.\n");
             break;
         case WSAEDESTADDRREQ: 
            AfxMessageBox("A destination address is required.\n");
            break;
         case WSAEFAULT: 
            AfxMessageBox("The lpSockAddrLen argument is incorrect.\n");
            break;
         case WSAEINVAL: 
            AfxMessageBox("The socket is already bound to an  address.\n");
            break;
         case WSAEISCONN: 
            AfxMessageBox("The socket is already connected.\n");
            break;
         case WSAEMFILE: 
            AfxMessageBox("No more file descriptors are available.\n");
            break;
         case WSAENETUNREACH: 
            AfxMessageBox("The network cannot be reached from this host   at this time.\n");
              break;
         case WSAENOBUFS: 
            AfxMessageBox("No buffer space is available. The socket cannot be connected.\n");
              break;
         case WSAENOTCONN: 
            AfxMessageBox("The socket is not connected.\n");
            break;
         case WSAENOTSOCK: 
            AfxMessageBox("The descriptor is a file, not a socket.\n");
            break;
         case WSAETIMEDOUT: 
            AfxMessageBox("The attempt to connect timed out without establishing a connection. \n");
              break;
         default:
            TCHAR szError[256];
            wsprintf(szError, "OnConnect error: %d", nErrorCode);
            AfxMessageBox(szError);
            break;
      }
      AfxMessageBox("Please close the application");
   }
  // CAsyncSocket::OnConnect(nErrorCode);

             // mainapp thread
SockCLeintThread* threadptr;         // this SockCLeintThread

   // Get Main App
 
 
	 //   SockCLeintThread* current; 

	// if(nErrorcode != 0)
		// main_wnd->MessageBox((LPCTSTR)"Port Not Connected",(LPCTSTR)"Port",MB_ICONERROR);
	//	 Sockevent.SetEvent();
	 //  SockCLeintThread* current;
	  //   (CWinThread *) current = AfxGetThread();
      // UNREFERENCED_PARAMETER(nErrorcode);
        //  CAsyncSocket::OnConnect(nErrorCode);
		  threadptr = (SockCLeintThread *) AfxGetThread();
          threadptr->flags.is_connected = 1;       
  //    if(nErrorcode == WSAETIMEDOUT)
	//	  Connect(current->ipaddr,current->port);

        AsyncSelect(FD_WRITE);

	
   //    main_app->pevent->SetEvent();
  }

 class SockCLeintThread : public CWinThread {
   public:
	      DECLARE_DYNCREATE(SockCLeintThread)
        //		DECLARE_SERIAL(SockCLeintThread)
       //     IMPLEMENT_DYNAMIC(SockCLientThread)
        public:
			     SockCLeintThread();
			     SockCLeintThread(UINT myport);
				 ~SockCLeintThread();
                CWnd *sendwindow;
                CWnd *call_wnd;
       			char *thread_id;
				 SockClient thisocket;           <== // Socket to do ocommunication
				 void Sendit(WPARAM, LPARAM);
				void Receiveit(WPARAM, LPARAM);
			    LPCTSTR ipaddr;
                BOOL idle;				 // looking for work
		//	 allexceptions myallexception;
				 
				struct {
					unsigned int is_connected : 1;
					unsigned int busy : 1;
					unsigned int not_connected : 1;
				} flags;
				
protected:
	  virtual BOOL InitInstance();      // Just for starters
	//  virtual BOOL OnIdle(LONG lCount);
	//  virtual int Run();
           DECLARE_MESSAGE_MAP()

};

class SockClient : public CAsyncSocket
{      
	DECLARE_SERIAL(SockClient)
 public:
      // SockCleint(char *sockptr);
	    SockClient();
        SockClient(UINT myport);
		~SockClient();
        char *sockbuffer;		// send and receive buffer
		int num_buff;
	//	CWnd *send_wnd;
		int thread_no;
		UINT port;
		SOCKADDR* herccmd;                     // HERCMCD IP ADDRESS
		SOCKADDR MVS;		// MVS IP address
		int option;
	private:
		int busy;               // inuse
		               // port used by this class
   protected:
                         // window to send message to
        virtual void OnReceive(int nErrorCode);
        virtual void OnSend(int nErrorCode);
        virtual void OnConnect(int nErrorCode);
		virtual void OnClose(int nErrorCode);

		
		
};

ForNow wrote:

I know its not formatted that neatly