/haiku-fatelf/src/libs/compat/freebsd_network/compat/netinet/ |
H A D | in_var.h | 9 #include <sys/queue.h>
|
/haiku-fatelf/src/add-ons/kernel/generic/dpc/ |
H A D | dpc.c | 21 // 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 D | queue.h | 14 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 D | 12-1.c | 34 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 D | 29-1.c | 10 * 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 D | 19-1.c | 10 * 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 D | 18-1.c | 30 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 D | 23-1.c | 11 * 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 D | 21-1.c | 14 * 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 D | 3-1.c | 11 * 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 D | 11-1.c | 11 * 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 D | 1-1.c | 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) { 43 if (mq_send(queue, msgptr, strlen(msgptr), 1) != 0) { 48 mq_close(queue);
|
H A D | 15-1.c | 10 * 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 D | 20-1.c | 10 * 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 D | dpc.h | 23 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 D | 18-1.c | 10 * 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 D | 18-2.c | 10 * 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 D | 1-1.c | 10 * 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 D | 3-1.c | 11 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 D | 4-1.c | 10 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 D | 2-2.c | 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 that do not start with /.\n"); 39 mq_close(queue); 42 printf("This implementation may support message queue\n");
|
H A D | 2-3.c | 10 * 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 D | 6-1.c | 32 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 D | 3-1.c | 10 * 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 D | 3-2.c | 10 * 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...] |