Home
last modified time | relevance | path

Searched defs:consumer (Results 1 – 8 of 8) sorted by relevance

/f-stack/freebsd/mips/mediatek/
H A Dfdt_reset.c53 assert_deassert_all(device_t consumer, boolean_t assert) in assert_deassert_all()
98 fdt_reset_assert_all(device_t consumer) in fdt_reset_assert_all()
105 fdt_reset_deassert_all(device_t consumer) in fdt_reset_deassert_all()
/f-stack/app/redis-5.0.5/src/
H A Dt_stream.c898 … *start, streamID *end, size_t count, int rev, streamCG *group, streamConsumer *consumer, int flag… in streamReplyWithRange()
1013 …PEL(client *c, stream *s, streamID *start, streamID *end, size_t count, streamConsumer *consumer) { in streamReplyWithRangeFromConsumerPEL()
1519 streamConsumer *consumer = NULL; in xreadCommand() local
1592 streamNACK *streamCreateNACK(streamConsumer *consumer) { in streamCreateNACK()
1655 streamConsumer *consumer = raxFind(cg->consumers,(unsigned char*)name, in streamLookupConsumer() local
1673 streamConsumer *consumer = streamLookupConsumer(cg,name,0); in streamDelConsumer() local
1995 streamConsumer *consumer = ri.data; in xpendingCommand() local
2008 streamConsumer *consumer = consumername ? in xpendingCommand() local
2225 streamConsumer *consumer = streamLookupConsumer(group,c->argv[3]->ptr,1); in xclaimCommand() local
2479 streamConsumer *consumer = ri.data; in xinfoCommand() local
H A Dstream.h85 streamConsumer *consumer; /* The consumer this message was delivered to member
H A Dblocked.c425 streamConsumer *consumer = NULL; in handleClientsBlockedOnKeys() local
H A Daof.c1139 …rio *r, robj *key, const char *groupname, size_t groupname_len, streamConsumer *consumer, unsigned… in rioWriteStreamPendingEntry()
1232 streamConsumer *consumer = ri_cons.data; in rewriteStreamObject() local
H A Drdb.c729 streamConsumer *consumer = ri.data; in rdbSaveStreamConsumers() local
1728 streamConsumer *consumer = streamLookupConsumer(cgroup,cname, in rdbLoadObject() local
H A Dobject.c917 streamConsumer *consumer = cri.data; in objectComputeSize() local
/f-stack/freebsd/contrib/ck/include/
H A Dck_ring.h95 unsigned int consumer, producer, delta; in _ck_ring_enqueue_sp() local
140 unsigned int consumer, producer; in _ck_ring_dequeue_sc() local
174 unsigned int producer, consumer, delta; in _ck_ring_enqueue_mp() local
274 unsigned int consumer, producer; in _ck_ring_trydequeue_mc() local
299 unsigned int consumer, producer; in _ck_ring_dequeue_mc() local