Mindboards

Code: Select all

ReceiveRemoteString(INBOX, bDELETE, MSG_STRING);

Code: Select all

// master
task ReceiveSlaveData()    // master 
{
   string _msg;

   while(true)   {
       until(ReceiveRemoteString(2, true, _msg) == NO_ERR); // for COMM 1
       // do something with the  _msg of slave 1);
       Wait(10);

       until(ReceiveRemoteString(5, true, _msg) == NO_ERR); // for COMM 2
       // do something with the  _msg of slave 2);
       Wait(10);

       until(ReceiveRemoteString(8, true, _msg) == NO_ERR); // for COMM 3
       // do something with the  _msg of slave 3);
       Wait(10);
      }
     Wait(10);
   }
}

Code: Select all

// slave
task SlavePuttingDataIntoMailbox() { 
  string out;
  char OUTBOX; //slave 1:OUTBOX=2 , slave 2:OUTBOX=5, slave 3:OUTBOX=8

  while (true) { 
    out= ... // random/changing anything over/during time

    // what to do...if now or before requested by master... 
    // to clear all old and/or unread messages in mailbox or queue 
    // before putting in just the newest / latest string value?
    
    SendResponseString(OUTBOX, out); 
    Wait(20);
  }
}

Code: Select all

inline void ClearResponseMailbox(byte mailbox)
{
  MessageReadType args;
  args.QueueID = mailbox + 10;
  args.Remove = true;
  args.Result = NO_ERR;
  while (args.Result != STAT_MSG_EMPTY_MAILBOX)
    SysMessageRead(args);
}

Code: Select all

do {Wait(1);} while (BluetoothStatus(ID) == STAT_COMM_PENDING);

Code: Select all

Wait(10);

Code: Select all

//++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
task BTMasterTask()    // NOS = Number of Slaves
//++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
{
   string slvmsg;
   string pollmsg="¦¦";
   int ack, ch;
   char ID;

   pollmsg[0]=0xff; pollmsg[1]=0xff;
   while(true)   {
     if (_NOS_>=1) {
       ID=1;
       SendRemoteString(ID,OUTBOX_1,pollmsg);
       do {Wait(1);} while (BluetoothStatus(ID) == STAT_COMM_PENDING);
       //Wait(10);
       ReceiveRemoteString(INBOX_11, true, slvmsg);
       ParseBTResponseMsg(ID-1, slvmsg) ;
       Wait(10);
     }

     if (_NOS_>=2) {
       ID=2;
       SendRemoteString(ID,OUTBOX_2,pollmsg);
       do {Wait(1);} while (BluetoothStatus(ID) == STAT_COMM_PENDING);
       //Wait(10);
       ReceiveRemoteString(INBOX_21, true, slvmsg);
       ParseBTResponseMsg(ID-1, slvmsg) ;
       Wait(10);
     }

     if (_NOS_>=3) {
       ID=3;
       SendRemoteString(ID,OUTBOX_3,pollmsg);
       do {Wait(1);} while (BluetoothStatus(ID) == STAT_COMM_PENDING);
       //Wait(10);
       ReceiveRemoteString(INBOX_31, true, slvmsg);
       ParseBTResponseMsg(ID-1, slvmsg) ;
       Wait(10);
     }
      
      ack=0;
      if (_OUT_ != "") {
        ch=checksum(_OUT_);
        while(ack!=ch)  {
            SendRemoteString(_ID_, _OUTBOX_, _OUT_);
            do {Wait(1);} while (BluetoothStatus(_ID_) == STAT_COMM_PENDING);
            //Wait(10);
            ReceiveRemoteNumber(_INBOX_, true, ack);
            Wait(10);
        }
        _OUT_="";
      }
      
      Wait(5);
   }
}

Code: Select all

//++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
task BTSlaveTask() {   // slave
//++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
  string in;
  int ack, len;

  string sp, sn, svv;
  string fmtstr, buf, out;
  int i, dec;

  while(true)   {
  
    in= "";

    if (ReceiveRemoteString(INBOX, true, in) != STAT_MSG_EMPTY_MAILBOX)   {

       if((in[0]!=0xff)&&(in[1]!=0xff))  {    // ack for ExecCmd
         ack=checksum(in);
         SendResponseNumber(OUTBOX_2, ack);   // error check
         Wait(1);
         __cmd=in;
         ExecCmd();
       }
       else
       {
          out="";                // return value string
          for(i=0; i<11; i++) {  // Sensorports: 0...3  plus virtual ports
            GetSensorValues(i);
            Wait(1);

            dec=SensorValueDecimals[i];
            sn=NumToStr(dec);                          // value decimals
            fmtstr=StrCat("%",NumToStr(dec),"d");
            svv=FormatNum(fmtstr,SensorCurrArr);

            out = StrCat(out, sn, svv);

          } //  for port i=...

          if (StrLen(out)>58) strncpy(out,out,58);     // 58 = max msg length
          SendResponseString(OUTBOX_1, out);
          Wait(1);
#ifdef debug
          //TextOut(0, 0, out);
#endif
       }
    }   // != STAT_MSG_EMPTY_MAILBOX
    
    ClearResponseMailbox(OUTBOX_1);
    Wait(10);
  }  // while(true)
}