1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
/* $Id$ */
#if PACE_LYNXOS != 0x300
#include "pace/stdio.h"
#include "pace/fcntl.h"
#include "pace/mqueue.h"
#include "pace/stdlib.h"
#include "pace/signal.h"
#include "pace/string.h"
/* Most of this code is borowed from Konstantin Knizhnik <http://www.ispras.ru/~knizhnik/posix1b/> */
pace_mqd_t mqdes;
void
msg_handler (int handler_arg)
{
char buf[1024];
unsigned int priority;
int len = pace_mq_receive(mqdes, buf, sizeof buf, &priority);
PACE_UNUSED_ARG (handler_arg);
if (len < 0)
{
perror("mq_receive");
}
pace_printf("\nReceive message with priority %d: %s\n", priority, buf);
}
#define QUEUE_NAME "/testmsg1"
int
main (int argc, char** argv)
{
#if PACE_LYNXOS
pace_printf ("mqueue_test not supported on LynxOS.\n");
PACE_UNUSED_ARG (argc);
PACE_UNUSED_ARG (argv);
return EXIT_SUCCESS;
#else /* ! PACE_LYNXOS */
char buf[1024];
int choice, len;
unsigned int priority;
pace_sigevent notification;
static pace_sigaction_s sa;
int one = 1;
mqdes = pace_mq_open(QUEUE_NAME, O_CREAT | O_RDWR, 0777, 0);
if (mqdes == (pace_mqd_t)-1)
{
perror("mq_open");
return EXIT_FAILURE;
}
notification.sigev_notify = SIGEV_SIGNAL;
notification.sigev_signo = SIGUSR1;
sa.sa_handler = msg_handler;
sa.sa_flags = SA_RESTART;
pace_sigaction(SIGUSR1, &sa, NULL);
while (one)
{
printf("\t1. Send\n"
"\t2. Asynchronouse receive\n"
"\t3. Synchronouse receive\n"
"\t4. Close queue and exit\n"
"\t5. Remove queue and exit\n"
"> ");
if (!pace_fgets(buf, sizeof buf, stdin))
{
return EXIT_FAILURE;
}
if (pace_sscanf(buf, "%d", &choice) != 1)
{
pace_printf("Please select 1..5\n");
continue;
}
switch (choice)
{
case 1:
do
{
pace_printf("Message priority: ");
pace_fgets(buf, sizeof buf, stdin);
} while (pace_sscanf(buf, "%d", &priority) != 1);
pace_printf("Message to send: ");
pace_fgets(buf, sizeof buf, stdin);
if (pace_mq_send(mqdes, buf, pace_strlen(buf)+1, priority) == -1)
{
perror("mq_send");
return EXIT_FAILURE;
}
break;
case 2:
pace_mq_notify(mqdes, ¬ification);
pace_printf("Waiting for notifications...\n");
break;
case 3:
len = pace_mq_receive(mqdes, buf, sizeof buf, &priority);
if (len < 0)
{
perror("mq_receive");
}
pace_printf("Receive message with priority %d: %s\n", priority, buf);
break;
case 4:
pace_mq_close(mqdes);
return EXIT_SUCCESS;
case 5:
pace_mq_close(mqdes);
pace_mq_unlink(QUEUE_NAME);
return EXIT_SUCCESS;
default:
pace_printf("Please select 1..5\n");
}
}
PACE_UNUSED_ARG (argc);
PACE_UNUSED_ARG (argv);
return EXIT_SUCCESS;
#endif /* ! PACE_LYNXOS */
}
#else
int
main (int argc, char **argv)
{
printf("PACE does not support LynxOS 3.0.0.\n");
}
#endif /* PACE_LYNXOS == 0x300 */
|
