Home
last modified time | relevance | path

Searched refs:mqueue (Results 1 – 25 of 602) sorted by relevance

12345678910>>...25

/dports/games/retroarch/RetroArch-1.9.7/wii/libogc/libogc/
H A Dlwp_messages.c8 ++mqueue->num_pendingmsgs; in __lwpmq_msg_insert()
17 __lwpmq_msg_append(mqueue,msg); in __lwpmq_msg_insert()
20 __lwpmq_msg_prepend(mqueue,msg); in __lwpmq_msg_insert()
28 header = &mqueue->pending_msgs; in __lwpmq_msg_insert()
43 if(mqueue->num_pendingmsgs==1 && mqueue->notify_handler) in __lwpmq_msg_insert()
44 mqueue->notify_handler(mqueue->notify_arg); in __lwpmq_msg_insert()
56 mqueue->num_pendingmsgs = 0; in __lwpmq_initialize()
90 --mqueue->num_pendingmsgs; in __lwpmq_seize()
138 if(size>mqueue->max_msgsize) in __lwpmq_submit()
151 if(mqueue->num_pendingmsgs<mqueue->max_pendingmsgs) { in __lwpmq_submit()
[all …]
H A Dlwp_messages.inl6 mqueue->notify_handler = handler;
7 mqueue->notify_arg = arg;
15 static __inline__ mq_buffercntrl* __lwpmq_allocate_msg(mq_cntrl *mqueue) argument
17 return (mq_buffercntrl*)__lwp_queue_get(&mqueue->inactive_msgs);
20 static __inline__ void __lwpmq_free_msg(mq_cntrl *mqueue,mq_buffercntrl *msg) argument
22 __lwp_queue_append(&mqueue->inactive_msgs,&msg->node);
28 printf("__lwpmq_msq_append(%p,%p,%p)\n",mqueue,&mqueue->inactive_msgs,msg);
30 __lwp_queue_append(&mqueue->pending_msgs,&msg->node);
36 printf("__lwpmq_msq_prepend(%p,%p,%p)\n",mqueue,&mqueue->inactive_msgs,msg);
38 __lwp_queue_prepend(&mqueue->pending_msgs,&msg->node);
[all …]
H A Dmessage.c48 mq_cntrl mqueue; member
95 if(!__lwpmq_initialize(&ret->mqueue,&attr,count,sizeof(mqmsg_t))) { in MQ_Init()
113 __lwpmq_close(&mbox->mqueue,0); in MQ_Close()
129 …if(__lwpmq_submit(&mbox->mqueue,mbox->object.id,(void*)&msg,sizeof(mqmsg_t),LWP_MQ_SEND_REQUEST,wa… in MQ_Send()
145 …if(__lwpmq_seize(&mbox->mqueue,mbox->object.id,(void*)msg,&tmp,wait,LWP_THREADQ_NOTIMEOUT)==LWP_MQ… in MQ_Receive()
161 …if(__lwpmq_submit(&mbox->mqueue,mbox->object.id,(void*)&msg,sizeof(mqmsg_t),LWP_MQ_SEND_URGENT,wai… in MQ_Jam()
/dports/net/kamailio/kamailio-5.4.5/src/modules/mqueue/
H A DREADME1 mqueue Module
129 3.2. mqueue (string)
151 3.2. mqueue (string)
176 modparam("mqueue", "mqueue", "name=myq;size=20;")
177 modparam("mqueue", "mqueue", "name=qaz")
227 If the mqueue is empty, the function returns -1. If the mqueue is not
239 mqueue
242 * $mq_size(mqueue) - the size of the specified mqueue
250 6.2. mqueue.fetch
252 6.1. mqueue.get_size
[all …]
/dports/lang/gauche/Gauche-0.9.10/examples/mqueue-cpp/
H A Dmqueue_lib.stub9 ;; Let the stub generator know about <mqueue> type.
28 (define-type <mqueue> "MQueue*" "mqueue"
31 (define-cproc make-mqueue (name::<const-cstring>) ::<mqueue>
34 (define-cproc mqueue-find (name::<const-cstring>) ::<mqueue>
37 (define-cproc mqueue-name (mq::<mqueue>) ::<const-cstring>
40 (define-cproc mqueue-empty? (mq::<mqueue>) ::<boolean>
43 (define-cproc mqueue-push! (mq::<mqueue> message::<const-cstring>
48 (define-cproc mqueue-pop! (mq::<mqueue>)
50 "Scm_Error(\"mqueue-pop!: %s\", e.reason.c_str());"))
H A DREADME.adoc9 The two files, link:mqueue.h[] and link:mqueue.cpp[], are our hypothetical
12 mqueue library, to write a Gauche binding for it.
23 link:example/mqueue-cpp.scm[]:: Scheme module definition
30 % gauche-package generate mqueue-cpp example.mqueue-cpp
78 #include "mqueue.h"
126 Scm_MakeForeignPointerClass(mod, "<mqueue>",
137 instance of `<mqueue>` is printed.
234 (define-type <mqueue> "MQueue*" "mqueue"
343 (define-cproc mqueue-pop! (mq::<mqueue>) ::<const-cstring>
361 Scm_Error("mqueue-pop!: %s", e.reason.c_str());
[all …]
/dports/audio/deadbeef/deadbeef-0.7.2/
H A Dhandler.c46 message_t *mqueue; member
55 h->mqueue = NULL; in handler_reset()
102 if (!h->mqueue) { in handler_push()
103 h->mqueue = msg; in handler_push()
125 if (!h->mqueue) { in handler_pop()
129 *id = h->mqueue->id; in handler_pop()
131 *p1 = h->mqueue->p1; in handler_pop()
132 *p2 = h->mqueue->p2; in handler_pop()
135 h->mfree = h->mqueue; in handler_pop()
136 h->mqueue = next; in handler_pop()
[all …]
H A Dmessagepump.c73 mqueue = NULL; in messagepump_reset()
99 if (!mqueue) { in messagepump_push()
100 mqueue = msg; in messagepump_push()
122 if (!mqueue) { in messagepump_pop()
126 *id = mqueue->id; in messagepump_pop()
127 *ctx = mqueue->ctx; in messagepump_pop()
128 *p1 = mqueue->p1; in messagepump_pop()
129 *p2 = mqueue->p2; in messagepump_pop()
132 mfree = mqueue; in messagepump_pop()
133 mqueue = next; in messagepump_pop()
[all …]
/dports/games/retroarch/RetroArch-1.9.7/wii/libogc/include/ogc/
H A Dlwp_messages.h61 u32 __lwpmq_initialize(mq_cntrl *mqueue,mq_attr *attrs,u32 max_pendingmsgs,u32 max_msgsize);
62 void __lwpmq_close(mq_cntrl *mqueue,u32 status);
63 u32 __lwpmq_seize(mq_cntrl *mqueue,u32 id,void *buffer,u32 *size,u32 wait,u64 timeout);
64 u32 __lwpmq_submit(mq_cntrl *mqueue,u32 id,void *buffer,u32 size,u32 type,u32 wait,u64 timeout);
65 u32 __lwpmq_broadcast(mq_cntrl *mqueue,void *buffer,u32 size,u32 id,u32 *count);
66 void __lwpmq_msg_insert(mq_cntrl *mqueue,mq_buffercntrl *msg,u32 type);
67 u32 __lwpmq_flush(mq_cntrl *mqueue);
68 u32 __lwpmq_flush_support(mq_cntrl *mqueue);
69 void __lwpmq_flush_waitthreads(mq_cntrl *mqueue);
/dports/lang/fpc-source/fpc-3.2.2/packages/libogcfpc/src/ogc/
H A Dlwp_messages.inc59 function __lwpmq_initialize(mqueue: Pmq_cntrl; attrs: Pmq_attr;
62 procedure __lwpmq_close(mqueue: Pmq_cntrl; status: cuint32); cdecl; external;
64 function __lwpmq_seize(mqueue: Pmq_cntrl; id: cuint32; buffer: pointer;
67 function __lwpmq_submit(mqueue: Pmq_cntrl; id: cuint32; buffer: pointer;
70 function __lwpmq_broadcast(mqueue: Pmq_cntrl; buffer: pointer;
73 procedure __lwpmq_msg_insert(mqueue: Pmq_cntrl; msg: Pmq_buffercntrl;
76 function __lwpmq_flush(mqueue: Pmq_cntrl): cuint32; cdecl; external;
78 function __lwpmq_flush_support(mqueue: Pmq_cntrl): cuint32; cdecl; external;
80 procedure __lwpmq_flush_waitthreads(mqueue: Pmq_cntrl); cdecl; external;
/dports/audio/carla/Carla-2.4.1/source/native-plugins/
H A Dxycontroller.cpp43 mqueue(), in XYControllerPlugin()
153 if (mqueue.isNotEmpty() && mqueueRT.tryToCopyDataFrom(mqueue)) in process()
185 const CarlaMutexLocker cml(mqueue.getMutex()); in msgReceived()
190 … if (! mqueue.put(uint8_t(MIDI_STATUS_CONTROL_CHANGE | (i & MIDI_CHANNEL_BIT)), cc, value)) in msgReceived()
205 const CarlaMutexLocker cml(mqueue.getMutex()); in msgReceived()
211 … if (! mqueue.put(uint8_t(MIDI_STATUS_CONTROL_CHANGE | (i & MIDI_CHANNEL_BIT)), cc1, value1)) in msgReceived()
213 … if (! mqueue.put(uint8_t(MIDI_STATUS_CONTROL_CHANGE | (i & MIDI_CHANNEL_BIT)), cc2, value2)) in msgReceived()
231 const CarlaMutexLocker cml(mqueue.getMutex()); in msgReceived()
236 if (! mqueue.put(uint8_t(status | (i & MIDI_CHANNEL_BIT)), note, velocity)) in msgReceived()
250 MIDIEventQueue<128> mqueue, mqueueRT; member in XYControllerPlugin
/dports/multimedia/gstreamer1/gstreamer-1.16.2/plugins/elements/
H A Dgstmultiqueue.c120 GstMultiQueue *mqueue; member
648 mqueue->nbqueues = 0; in gst_multi_queue_init()
668 mqueue->counter = 1; in gst_multi_queue_init()
669 mqueue->highid = -1; in gst_multi_queue_init()
976 mqueue->queues = g_list_delete_link (mqueue->queues, tmp); in gst_multi_queue_release_pad()
1795 mq = sq->mqueue; in gst_multi_queue_loop()
2103 mq = sq->mqueue; in gst_multi_queue_chain()
2494 mq = sq->mqueue; in gst_multi_queue_src_activate_mode()
2978 mqueue->nbqueues++; in gst_single_queue_new()
2983 mqueue->queues = g_list_insert_before (mqueue->queues, tmp, sq); in gst_single_queue_new()
[all …]
/dports/audio/re/re-0.5.8/src/mqueue/
H A Dmqueue.c35 struct mqueue { struct
50 struct mqueue *q = arg; in destructor() argument
63 struct mqueue *mq = arg; in event_handler()
99 int mqueue_alloc(struct mqueue **mqp, mqueue_h *h, void *arg) in mqueue_alloc()
101 struct mqueue *mq; in mqueue_alloc()
151 int mqueue_push(struct mqueue *mq, int id, void *data) in mqueue_push()
H A Dmod.mk7 SRCS += mqueue/mqueue.c
10 SRCS += mqueue/win32/pipe.c
/dports/misc/shared-mime-info/shared-mime-info-ef58b2b2f7ad4070171c6e45e3b3764daa3ff2c1/tests/mime-detection/
H A Dsystemd.mount9 ConditionPathExists=/proc/sys/fs/mqueue
12 What=mqueue
13 Where=/dev/mqueue
14 Type=mqueue
/dports/net/ladvd/ladvd-1.1.2/tests/
H A Dcheck_child.c36 extern struct mhead mqueue;
236 TAILQ_REMOVE(&mqueue, dmsg, entries); in START_TEST()
272 TAILQ_FOREACH(dmsg, &mqueue, entries) { in START_TEST()
300 TAILQ_FOREACH(dmsg, &mqueue, entries) { in START_TEST()
308 dmsg = TAILQ_FIRST(&mqueue); in START_TEST()
315 TAILQ_FOREACH(dmsg, &mqueue, entries) { in START_TEST()
322 dmsg = TAILQ_FIRST(&mqueue); in START_TEST()
328 TAILQ_FOREACH(dmsg, &mqueue, entries) { in START_TEST()
335 dmsg = TAILQ_FIRST(&mqueue); in START_TEST()
340 dmsg = TAILQ_FIRST(&mqueue); in START_TEST()
[all …]
/dports/sysutils/munin-common/munin-2.0.67/plugins/node.d/
H A Dsendmail_mailqueue.in23 env.mspqueue /var/spool/mqueue-client
24 env.mtaqueue /var/spool/mqueue
41 MSP_QUEUE=${mspqueue:-/var/spool/mqueue-client}
42 MTA_QUEUE=${mtaqueue:-/var/spool/mqueue}
/dports/sysutils/munin-master/munin-2.0.67/plugins/node.d/
H A Dsendmail_mailqueue.in23 env.mspqueue /var/spool/mqueue-client
24 env.mtaqueue /var/spool/mqueue
41 MSP_QUEUE=${mspqueue:-/var/spool/mqueue-client}
42 MTA_QUEUE=${mtaqueue:-/var/spool/mqueue}
/dports/sysutils/munin-node/munin-2.0.67/plugins/node.d/
H A Dsendmail_mailqueue.in23 env.mspqueue /var/spool/mqueue-client
24 env.mtaqueue /var/spool/mqueue
41 MSP_QUEUE=${mspqueue:-/var/spool/mqueue-client}
42 MTA_QUEUE=${mtaqueue:-/var/spool/mqueue}
/dports/math/concorde/concorde/EDGEGEN/
H A Dmlinkern.c112 typedef struct mqueue { struct
118 } mqueue; argument
142 put_q (data *D, mqueue *qu, int v),
143 init_q (mqueue *qu),
149 init_queue (data *D, mqueue *qu),
159 get_q (mqueue *qu),
160 non_empty_q (mqueue *qu),
306 static int get_q (mqueue *qu) in get_q()
311 static void init_q (mqueue *qu) in init_q()
317 static int non_empty_q (mqueue *qu) in non_empty_q()
[all …]
/dports/audio/re/re-0.5.8/include/
H A Dre_mqueue.h7 struct mqueue;
11 int mqueue_alloc(struct mqueue **mqp, mqueue_h *h, void *arg);
12 int mqueue_push(struct mqueue *mq, int id, void *data);
/dports/mail/libmilter/sendmail-8.16.1/contrib/
H A Dmovemail.conf9 /var/spool/mqueue/q1
10 /var/spool/mqueue/q2
11 /var/spool/mqueue/q3
/dports/databases/gigabase/gigabase/crypt/
H A Dmakefile1 OBJS = crypt_file.o md5.o arc4.o cryptlib.o filters.o misc.o mqueue.o queue.o
2 INCS = rc4/arc4.h rc4/config.h rc4/cryptlib.h rc4/misc.h rc4/mqueue.h rc4/pch.h rc4/queue.h rc4/wor…
43 mqueue.o: rc4/mqueue.cpp $(INCS)
44 $(CC) $(CFLAGS) rc4/mqueue.cpp
H A Dmakefile.mvc1 OBJS = crypt_file.obj md5.obj arc4.obj cryptlib.obj filters.obj misc.obj mqueue.obj queue.obj
2 INCS = rc4\arc4.h rc4\config.h rc4\cryptlib.h rc4\misc.h rc4\mqueue.h rc4\pch.h rc4\queue.h rc4\wor…
35 mqueue.obj: rc4\mqueue.cpp $(INCS)
36 $(CC) $(CFLAGS) rc4\mqueue.cpp
/dports/net/ladvd/ladvd-1.1.2/src/
H A Dchild.c46 struct mhead mqueue; variable
69 TAILQ_INIT(&mqueue); in child_init()
345 TAILQ_FOREACH(qmsg, &mqueue, entries) { in child_queue()
376 TAILQ_INSERT_AFTER(&mqueue, pmsg, msg, entries); in child_queue()
378 TAILQ_INSERT_TAIL(&mqueue, msg, entries); in child_queue()
394 netif_descr(subif, &mqueue); in child_queue()
436 TAILQ_REMOVE(&mqueue, msg, entries); in child_expire()
454 netif_protos(netif, &mqueue); in child_expire()
458 netif_descr(subif, &mqueue); in child_expire()
468 TAILQ_REMOVE(&mqueue, msg, entries); in child_free()
[all …]

12345678910>>...25