43 lines
691 B
C
43 lines
691 B
C
|
#include <stdio.h>
|
||
|
|
#include <sbthread.h>
|
||
|
|
#include <err.h>
|
||
|
|
|
||
|
|
int
|
||
|
|
worker_main(sbthread_t *th)
|
||
|
|
{
|
||
|
|
sbmsgq_t *msgq;
|
||
|
|
void *data;
|
||
|
|
size_t len;
|
||
|
|
|
||
|
|
msgq = sbthread_msgq(th);
|
||
|
|
while ((data = sbmsgq_wait(msgq, &len, -1, -1)) != NULL) {
|
||
|
|
int msg = *(int *)data;
|
||
|
|
E_INFO("Got message: %d\n", msg);
|
||
|
|
if (msg == 32)
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
return 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
int
|
||
|
|
main(int argc, char *argv[])
|
||
|
|
{
|
||
|
|
sbthread_t *worker;
|
||
|
|
int i;
|
||
|
|
|
||
|
|
worker = sbthread_start(NULL, worker_main, NULL);
|
||
|
|
for (i = 0; i <= 32; ++i) {
|
||
|
|
int ii[128];
|
||
|
|
E_INFO("Sending message: %d\n", i);
|
||
|
|
ii[0] = i;
|
||
|
|
if (sbthread_send(worker, sizeof(ii), &ii) < 0) {
|
||
|
|
E_ERROR("sbthread_send failed\n");
|
||
|
|
return 1;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
sbthread_free(worker);
|
||
|
|
|
||
|
|
return 0;
|
||
|
|
}
|