Searched refs:reactor (Results 1 - 5 of 5) sorted by relevance
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
| H A D | reactor_linux.c | 16 #include "platform/include/reactor.h"
40 Reactor *reactor; member
56 void ReactorSetThreadId(Reactor *reactor, unsigned long threadId) in ReactorSetThreadId() argument
58 reactor->threadId = (pthread_t)threadId; in ReactorSetThreadId()
63 Reactor *reactor = (Reactor *)calloc(1, sizeof(Reactor)); in ReactorCreate() local
64 reactor->epollFd = -1; in ReactorCreate()
65 reactor->stopFd = -1; in ReactorCreate()
88 reactor->movedItems = ListCreate(NULL); in ReactorCreate()
89 if (reactor->movedItems == NULL) { in ReactorCreate()
92 reactor in ReactorCreate()
106 ReactorDelete(Reactor *reactor) ReactorDelete() argument
119 ReactorStart(Reactor *reactor) ReactorStart() argument
175 ReactorStop(const Reactor *reactor) ReactorStop() argument
181 ReactorRegister( Reactor *reactor, int fd, void *context, void (*onReadReady)(void *context), void (*onWriteReady)(void *context)) ReactorRegister() argument
[all...] |
| H A D | thread_linux.c | 27 #include "platform/include/reactor.h"
38 Reactor *reactor; member
73 ReactorSetThreadId(thread->reactor, (unsigned long)pthread_self()); in ThreadStartFunc()
78 ReactorItem *reactorItem = ReactorRegister(thread->reactor, fd, (void *)thread->taskQueue, ReadyToRead, NULL); in ThreadStartFunc()
80 // Start Running reactor. in ThreadStartFunc()
81 if (ReactorStart(thread->reactor) != 0) { in ThreadStartFunc()
116 ReactorStop(thread->reactor); in ThreadStop()
130 thread->reactor = ReactorCreate(); in ThreadCreate()
131 if (thread->reactor == NULL) { in ThreadCreate()
169 ReactorDelete(thread->reactor); in ThreadCreate()
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/include/ |
| H A D | reactor.h | 44 * @param reactor Reactor pointer.
47 void ReactorDelete(Reactor *reactor);
52 * @param reactor Reactor pointer.
56 int32_t ReactorStart(Reactor *reactor);
61 * @param reactor Reactor pointer.
64 void ReactorStop(const Reactor *reactor);
69 * @param reactor Reactor pointer.
73 void ReactorSetThreadId(Reactor *reactor, unsigned long threadId);
76 * @brief Register item into reactor
78 * @param reactor Reacto
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/ |
| H A D | hci.c | 26 #include "platform/include/reactor.h"
99 Reactor *reactor = ThreadGetReactor(g_hciTxThread); in HciInitQueue() local
101 ReactorRegister(reactor, QueueGetDequeueFd(g_hciTxQueue), NULL, HciSendPacketCallback, NULL); in HciInitQueue()
108 Reactor *reactor = ThreadGetReactor(BTM_GetProcessingThread()); in HciInitQueue() local
110 ReactorRegister(reactor, QueueGetDequeueFd(g_hciRxQueue), NULL, HciRecvPacketCallback, NULL); in HciInitQueue()
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_thread.c | 76 Reactor *reactor = ThreadGetReactor(g_processingThread); in AllocProcessingQueue() local
77 block->reactorItem = ReactorRegister(reactor, QueueGetDequeueFd(block->queue), block->queue, RunTask, NULL); in AllocProcessingQueue()
|
Completed in 5 milliseconds