// Project: Messaging - sender
// Function: test messaging
// Author: Mike McFarlane 21-09-12
// Version: 0-6
// Status: working
// v0-1:
// v0-3: try different strategy of clearing messages in buffer. Result: This runs faster.
// v0-4: finish for loop and send end of task message
// v0-5: speed up optimisation. Takes about 19 s for a 1 to 25 for loop. Can't reduce delays as programs starts missing messages.
// v0-6: speed up optimisation by waiting for next message rather than clearing queue. Result: about 8s for a 1 to 25 for loop

task main()
{

   ClearMessage();

   for(int i = 1; i <= 25; i++)
   {
      nxtDisplayBigTextLine (2, "Tx = %d", i);
      sendMessageWithParm(i, 0, 0);

      while (messageParm[0] != i)
      {
         //wait
         sendMessageWithParm(i, 0, 0);
         ClearMessage();
         wait1Msec(5);
      }
      ClearMessage();
      wait1Msec(30);  // Donít send messages too frequently.
   }
   //stop
   eraseDisplay();
   /*while (bQueuedMsgAvailable())
   {
   word temp;
   ClearMessage();
   temp = message;
   }*/

   sendMessageWithParm(-101, 0, 0);
   while (messageParm[0] != -101)
   {
      sendMessageWithParm(-101, 0, 0);
      nxtDisplayBigTextLine (4, "Wait 4 End",);
      wait1Msec(5);
      ClearMessage();
   }
   eraseDisplay();
   nxtDisplayBigTextLine (2,"Finished!",);
   wait1Msec(1000);
   StopAllTasks();
}

// Project: Messaging - receiver
// Function: test messaging
// Author: Mike McFarlane 21-09-12
// Version: 0-6
// Status: working
// v0-1:
// v0-3: try different strategy of clearing messages in buffer. Result: This runs faster.
// v0-4: finish for loop and send end of task message
// v0-5: speed up optimisation. Takes about 19 s for a 1 to 25 for loop. Can't reduce delays as programs starts missing messages.
// v0-6: speed up optimisation by waiting for next message rather than clearing queue. Result: about 8s for a 1 to 25 for loop


task main()
{

   ClearMessage();

   while (messageParm[0] != -101)
   {
      while (messageParm[0] == 0)
      {
         //wait
         ClearMessage();
         wait1Msec(5);
      }
      nxtDisplayBigTextLine (2, "Rx = %d", messageParm[0]);
      sendMessageWithParm (messageParm[0], 0, 0);
      ClearMessage();
      wait1Msec(30);
   }
   //stop
   eraseDisplay();
   wait1Msec(100);
   sendMessageWithParm (messageParm[0], 0, 0);
   nxtDisplayBigTextLine (2,"Finished!",);
   wait1Msec(1000);
   StopAllTasks();

}

#define LongTime 30      // time in ms
#define ShortTime 10   // time in ms

//global variable
int MessageArray [100];

task Display ()
{
   int CurrentMessage = 0;

   while (true)
   {
      eraseDisplay ();
      //move the values down the queue
      for (int i = 98; i >= 0; i--)
      {
         MessageArray [i+1] = MessageArray [i];
         nxtDrawLine ((i+1), 0, (i+1), MessageArray [i+1]);
      }
      CurrentMessage = messageParm[0];

      MessageArray[0] = (CurrentMessage * 2);   // scaling line to fit display

      // set an update rate, 50ms creates a nice graph with good update speed
      wait1Msec (20);
   }
}

task main()
{
   ClearTimer(T1);
   ClearMessage();
   StartTask (Display); // start display task with slightly lower priority than main task (default 7)

   for(int i = 1; i <= 50; i++)
   {
      // nxtDisplayBigTextLine (2, "Tx = %d", i);
      sendMessageWithParm(i, 0, 0);

      while (messageParm[0] != i)
      {
         //wait
         sendMessageWithParm(i, 0, 0);
         ClearMessage();
         wait1Msec(LongTime); // needs to run slightly slower than receiver so 35ms about right, 20ms ok but variable.
      }
      ClearMessage();
      wait1Msec(ShortTime);  // Donít send messages too frequently.
   }

   //stopping
   StopTask(Display);
   eraseDisplay();
   sendMessageWithParm(-101, 0, 0);
   // make sure the stop signal -101 is definetely received
   while (messageParm[0] != -101)
   {
      sendMessageWithParm(-101, 0, 0);
      nxtDisplayBigTextLine (4, "Wait 4 End",);
      wait1Msec(ShortTime);
      ClearMessage();
   }
   eraseDisplay();
   nxtDisplayBigTextLine (2,"Finished!",);
   nxtDisplayBigTextLine (4, "T1: %d", time1[T1]);
   wait1Msec(1000);
   StopAllTasks();
}

#define LongTime 30      // time in ms
#define ShortTime 10   // time in ms

task main()
{

   ClearMessage();

   // keep looping while the stop signal of -101 is not received
   while (messageParm[0] != -101)
   {
      /*if (messageParm[0] != 0) // do nothing if message is 0
      {
         nxtDisplayBigTextLine (2, "Rx = %d", messageParm[0]);
         sendMessageWithParm (messageParm[0], 0, 0);
         ClearMessage();
         wait1Msec(LongTime); // 30ms about optimal, less time eg 10ms can give faster result, but result variable between 4 and 6s.
         }*/
         while (messageParm[0] == 0)
            {wait1Msec(ShortTime);}
         nxtDisplayBigTextLine (2, "Rx = %d", messageParm[0]);
         sendMessageWithParm (messageParm[0], 0, 0);
         ClearMessage();
         wait1Msec(LongTime);
   }

   //stopping
   eraseDisplay();
   wait1Msec(100);
   sendMessageWithParm (messageParm[0], 0, 0);
   nxtDisplayBigTextLine (2,"Finished!",);
   wait1Msec(1000);
   StopAllTasks();

}