Easyelectronics.ru

for(int i=0; i < UART1.LData; i++) xQueueSend(UART1.RxQueue[UART1.Ch], &UART1.DATA[i], 1);

for( ; uxQueueMessagesWaiting(UART1.RxQueue[0])==0 ; )
        osDelay(1);

OTLFlag1 = uxQueueMessagesWaiting(UART1.RxQueue[0]);

void prvTask_Sender(void *pvParameters)
{
   static BaseType_t error = 0;   // состояние отправки
   static char *ptrbuf = buffer;   // указатель на буфер

   xQueueSender = xQueueCreate(SIZE_QUEUE, sizeof(char));

   for (;;)
   {
      while(*ptrbuf)  // пока не достиг конца текстовой строки,
      {
         /* байт отправляется в очередь */
         error = xQueueSend(xQueueSender, (void*)ptrbuf, portMAX_DELAY);

         /* и проверяется результат */
         if (error == pdPASS)
            ptrbuf++;   // если байт был отправлен, то указатель на следующ.элем.

      }
   }
}

void prvTask_Reciever(void *pvParameters)
{
   static BaseType_t error = 0;   // состояние отправки
   static char *ptrbuf = buffer2;   // указатель на буфер

   for (;;)
   {
      while(ptrbuf != (buffer2+100))
      {
         /* байт принимается из очередь */
         error = xQueueReceive(xQueueSender, (void*)ptrbuf, 1000);

         /* и проверяется результат */
         if (error == pdPASS)
            ptrbuf++;   // если байт был принят, то указатель на следующ.элем.

      }
   }
}//----------------------------------------------