| /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...] |
| /kernel/linux/linux-6.6/kernel/trace/rv/ |
| H A D | rv_reactors.c | 5 * Runtime reactor interface.
19 * A RV reactor is registered via:
20 * int rv_register_reactor(struct rv_reactor *reactor)
22 * int rv_unregister_reactor(struct rv_reactor *reactor)
48 * reactor.
49 * - Writing the name of an reactor enables it to the given
69 * Interface for the reactor register.
78 if (strcmp(name, r->reactor->name) == 0) in get_reactor_rdef_by_name()
91 seq_printf(m, "%s\n", rea_def->reactor->name); in reactors_show()
137 * Monitor's reactor fil
278 __rv_register_reactor(struct rv_reactor *reactor) __rv_register_reactor() argument
307 rv_register_reactor(struct rv_reactor *reactor) rv_register_reactor() argument
329 rv_unregister_reactor(struct rv_reactor *reactor) rv_unregister_reactor() argument
[all...] |
| H A D | rv.h | 28 struct rv_reactor *reactor; member
|
| /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...] |
| /kernel/linux/linux-6.6/include/linux/ |
| H A D | rv.h | 65 int rv_unregister_reactor(struct rv_reactor *reactor);
66 int rv_register_reactor(struct rv_reactor *reactor);
|
| /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()
|
| /kernel/linux/linux-6.6/tools/verification/rv/src/ |
| H A D | in_kernel.c | 164 * ikm_write_reactor - switch the reactor to *reactor
168 static int ikm_write_reactor(char *monitor_name, char *reactor) in ikm_write_reactor() argument
174 retval = tracefs_instance_file_write(NULL, path, reactor); in ikm_write_reactor()
175 debug_msg("ikm: write \"%s\" reactors: %d\n", reactor, retval); in ikm_write_reactor()
202 * ikm_get_current_reactor - get the current enabled reactor
205 * [reactor].
208 * reactor. NULL otherwise.
237 debug_msg("ikm: read current reactor %s\n", curr_reactor); in ikm_get_current_reactor()
538 " -h/--help: print this menu and the reactor lis in ikm_usage()
[all...] |