Searched refs:queue (Results 1 - 25 of 161) sorted by relevance

1234567

/haiku-fatelf/src/libs/compat/freebsd_network/compat/netinet/
H A Din_var.h9 #include <sys/queue.h>
/haiku-fatelf/src/add-ons/kernel/generic/dpc/
H A Ddpc.c21 // Private DPC queue structures
45 dpc_queue *queue = arg; local
49 while (acquire_sem(queue->wakeup_sem) == B_OK) {
54 acquire_spinlock(&queue->lock);
56 dpc = queue->slots[queue->head];
57 queue->head = (queue->head + 1) % queue->size;
58 queue
86 dpc_queue *queue; local
130 dpc_queue *queue = handle; local
161 dpc_queue *queue = handle; local
[all...]
/haiku-fatelf/headers/private/kernel/util/
H A Dqueue.h14 typedef struct queue { struct
18 } queue; typedef in typeref:struct:queue
20 int queue_init(queue *q);
21 int queue_remove_item(queue *q, void *e);
22 int queue_enqueue(queue *q, void *e);
23 void *queue_dequeue(queue *q);
24 void *queue_peek(queue *q);
/haiku-fatelf/src/tests/system/libroot/posix/posixtestsuite/conformance/interfaces/mq_open/
H A D12-1.c34 mqd_t queue; local
39 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
40 if (queue == (mqd_t)-1) {
46 if (mq_getattr(queue, &attr) != 0) {
49 mq_close(queue);
54 mq_close(queue);
H A D29-1.c10 * Test that mq_open() fails with ENOENT if the named message queue does
29 mqd_t queue; local
33 queue = mq_open(qname, O_RDWR, S_IRUSR | S_IWUSR, NULL);
34 if (queue != (mqd_t)-1) {
37 mq_close(queue);
45 mq_close(queue);
H A D19-1.c10 * Test that mq_open() does not add messages to the queue or remove
11 * messages from the queue.
14 * - Call mq_open() for non-blocking queue
15 * - Verify mq_receive() fails (because nothing should be in the queue yet)
16 * - Call mq_send() to put something in the queue
17 * - Call mq_open() again for non-blocking queue
19 * still be in the queue).
42 mqd_t queue; local
52 queue = mq_open(qname, O_CREAT |O_RDWR|O_NONBLOCK,
54 if (queue
[all...]
H A D18-1.c30 mqd_t queue; local
34 queue = mq_open(qname, O_CREAT |O_RDWR | O_NONBLOCK,
36 if (queue == (mqd_t)-1) {
42 if (mq_send(queue, msgptr, strlen(msgptr), 1) != 0) {
45 /* close queue and exit */
46 mq_close(queue);
51 mq_close(queue);
H A D23-1.c11 * but the message queue already exists.
29 mqd_t queue, queue2; local
33 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
34 if (queue == (mqd_t)-1) {
41 * Open queue qname again with O_CREAT and O_EXCL set
47 printf("O_EXCL on an already opened queue.\n");
49 mq_close(queue);
62 mq_close(queue);
71 mq_close(queue);
H A D21-1.c14 * queue does not exist.
32 mqd_t queue; local
36 queue = mq_open(qname, O_RDWR, S_IRUSR | S_IWUSR, NULL);
37 if (queue != (mqd_t)-1) {
39 mq_close(queue);
H A D3-1.c11 * name does not refer to an already existing message queue.
28 mqd_t queue; local
32 queue = mq_open(qname, O_RDWR, S_IRUSR | S_IWUSR, NULL);
33 if (queue != (mqd_t)-1) {
36 mq_close(queue);
H A D11-1.c11 * a currently existing message queue, then the current call has no effect.
34 mqd_t queue, queue2; local
38 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
39 if (queue == (mqd_t)-1) {
45 if (mq_send(queue, msgptr, strlen(msgptr), 1) != 0) {
48 mq_close(queue);
60 mq_close(queue);
68 mq_close(queue);
74 mq_close(queue);
H A D1-1.c31 mqd_t queue; local
36 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
37 if (queue == (mqd_t)-1) {
43 if (mq_send(queue, msgptr, strlen(msgptr), 1) != 0) {
48 mq_close(queue);
H A D15-1.c10 * Test that if O_EXCL and O_CREAT are set and message queue name already
28 mqd_t queue, queue2; local
32 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
33 if (queue == (mqd_t)-1) {
40 * Open queue qname again with O_CREAT and O_EXCL set
46 printf("O_EXCL on an already opened queue.\n");
48 mq_close(queue);
54 mq_close(queue);
H A D20-1.c10 * Another basic test that mq_open() returns a valid message queue
14 * message queue descriptor returned.
39 mqd_t queue; local
46 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
47 if (queue == (mqd_t)-1) {
60 if (mq_notify(queue, &ev) != 0) {
65 mq_close(queue);
/haiku-fatelf/headers/os/drivers/
H A Ddpc.h23 status_t (*new_dpc_queue)(void **queue, const char *name, int32 priority);
24 status_t (*delete_dpc_queue)(void *queue);
25 status_t (*queue_dpc)(void *queue, dpc_func func, void *arg);
/haiku-fatelf/src/tests/system/libroot/posix/posixtestsuite/conformance/interfaces/mq_timedsend/
H A D18-1.c10 * Basic test that if the queue already has room, then mq_timedsend()
14 * on an empty queue. Should succeed.
35 mqd_t queue; local
39 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
40 if (queue == (mqd_t)-1) {
48 if (mq_timedsend(queue, msgptr, strlen(msgptr), 1, &ts) != 0) {
49 perror("mq_timedsend() did not return success on empty queue");
51 mq_close(queue);
56 mq_close(queue);
/haiku-fatelf/src/tests/system/libroot/posix/posixtestsuite/conformance/interfaces/mq_timedsend/speculative/
H A D18-2.c10 * Basic test that if the queue already has room, then mq_timedsend()
35 mqd_t queue; local
39 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
40 if (queue == (mqd_t)-1) {
48 if (mq_timedsend(queue, msgptr, strlen(msgptr), 1, &ts) == -1) {
50 mq_close(queue);
55 mq_close(queue);
/haiku-fatelf/src/tests/system/libroot/posix/posixtestsuite/conformance/interfaces/mq_close/
H A D1-1.c10 * mq_close test case that attempts to open a new message queue,
11 * close the message queue and verify that mq_close returns 0.
28 mqd_t queue; local
32 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
33 if (queue == (mqd_t)-1) {
38 if (mq_close(queue) != 0) {
H A D3-1.c11 1. Create a new message queue
12 2. Close the message queue, verify success
33 mqd_t queue; local
37 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
38 if (queue == (mqd_t)-1) {
43 if (mq_close(queue) == -1) {
54 if (mq_close(queue) != -1) {
H A D4-1.c10 Test that a closed message queue descriptor has been disassociated from
11 its message queue by attempting to set a notification on the descriptor
31 mqd_t queue; local
36 queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
37 if (queue == (mqd_t)-1) {
42 if (mq_close(queue) == -1) {
50 if (mq_notify(queue, &se) != -1) {
/haiku-fatelf/src/tests/system/libroot/posix/posixtestsuite/conformance/interfaces/mq_open/speculative/
H A D2-2.c28 mqd_t queue; local
32 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
33 if (queue == (mqd_t)-1) {
35 printf("message queue names that do not start with /.\n");
39 mq_close(queue);
42 printf("This implementation may support message queue\n");
H A D2-3.c10 * Test that if there are two /s in a message queue name, the behavior
28 mqd_t queue; local
32 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, NULL);
33 if (queue == (mqd_t)-1) {
35 printf("message queue names with two /s in them.\n");
39 mq_close(queue);
42 printf("This implementation may support message queue\n");
H A D6-1.c32 mqd_t queue; local
36 queue = mq_open(qname, O_CREAT |O_RDWR | O_WRONLY,
38 if (queue != (mqd_t)-1) {
41 mq_close(queue);
/haiku-fatelf/src/tests/system/libroot/posix/posixtestsuite/conformance/interfaces/mq_send/
H A D3-1.c10 * Test that mq_send() inserts messages into the message queue according
12 * Test by inserting multiple messages into the queue not in priority order.
50 mqd_t queue; local
59 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, &attr);
60 if (queue == (mqd_t)-1) {
65 if (mq_send(queue, msgptr3, strlen(msgptr3), PRI3) != 0) {
70 if (mq_send(queue, msgptr1, strlen(msgptr1), PRI1) != 0) {
75 if (mq_send(queue, msgptr4, strlen(msgptr4), PRI4) != 0) {
80 if (mq_send(queue, msgptr2, strlen(msgptr2), PRI2) != 0) {
85 if (mq_send(queue, msgptr
[all...]
H A D3-2.c10 * Test that mq_send() inserts messages into the message queue according
52 mqd_t queue; local
61 queue = mq_open(qname, O_CREAT |O_RDWR, S_IRUSR | S_IWUSR, &attr);
62 if (queue == (mqd_t)-1) {
67 if (mq_send(queue, msgptr3, strlen(msgptr3), PRI3) != 0) {
73 if (mq_send(queue, msgptr1, strlen(msgptr1), PRI1) != 0) {
79 if (mq_send(queue, msgptr4, strlen(msgptr4), PRI4) != 0) {
85 if (mq_send(queue, msgptr2, strlen(msgptr2), PRI2) != 0) {
91 if (mq_send(queue, msgptr5, strlen(msgptr5), PRI5) != 0) {
97 if (mq_receive(queue, msgrc
[all...]

Completed in 92 milliseconds

1234567