/dports/games/retroarch/RetroArch-1.9.7/wii/libogc/libogc/ |
H A D | lwp_messages.c | 8 ++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 D | lwp_messages.inl | 6 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 D | message.c | 48 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 D | README | 1 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 D | mqueue_lib.stub | 9 ;; 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 D | README.adoc | 9 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 D | handler.c | 46 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 D | messagepump.c | 73 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 D | lwp_messages.h | 61 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 D | lwp_messages.inc | 59 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 D | xycontroller.cpp | 43 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 D | gstmultiqueue.c | 120 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 D | mqueue.c | 35 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 D | mod.mk | 7 SRCS += mqueue/mqueue.c 10 SRCS += mqueue/win32/pipe.c
|
/dports/misc/shared-mime-info/shared-mime-info-ef58b2b2f7ad4070171c6e45e3b3764daa3ff2c1/tests/mime-detection/ |
H A D | systemd.mount | 9 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 D | check_child.c | 36 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 D | sendmail_mailqueue.in | 23 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 D | sendmail_mailqueue.in | 23 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 D | sendmail_mailqueue.in | 23 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 D | mlinkern.c | 112 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 D | re_mqueue.h | 7 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 D | movemail.conf | 9 /var/spool/mqueue/q1 10 /var/spool/mqueue/q2 11 /var/spool/mqueue/q3
|
/dports/databases/gigabase/gigabase/crypt/ |
H A D | makefile | 1 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 D | makefile.mvc | 1 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 D | child.c | 46 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 …]
|