5 float voltage; /* AD result of measured voltage */
6 float current; /* AD result of measured current */
7 uint32_t counter; /* A counter value */
10 osPoolDef(mpool, 16, message_t);
13 osMessageQDef(queue, 16, message_t);
16 void send_thread (void const *argument) {
19 i++; // fake data update
20 message_t *message = (message_t*)osPoolAlloc(mpool);
21 message->voltage = (i * 0.1) * 33;
22 message->current = (i * 0.1) * 11;
24 osMessagePut(queue, (uint32_t)message, osWaitForever);
29 osThreadDef(send_thread, osPriorityNormal, DEFAULT_STACK_SIZE);
32 mpool = osPoolCreate(osPool(mpool));
33 queue = osMessageCreate(osMessageQ(queue), NULL);
35 osThreadCreate(osThread(send_thread), NULL);
38 osEvent evt = osMessageGet(queue, osWaitForever);
39 if (evt.status == osEventMessage) {
40 message_t *message = (message_t*)evt.value.p;
41 printf("\nVoltage: %.2f V\n\r" , message->voltage);
42 printf("Current: %.2f A\n\r" , message->current);
43 printf("Number of cycles: %u\n\r", message->counter);
45 osPoolFree(mpool, message);