Home
last modified time | relevance | path

Searched full:receiver (Results 1 – 25 of 188) sorted by relevance

12345678

/openbmc/sdbusplus/include/sdbusplus/async/
H A Dfdio.hpp84 // Implementation (templated based on Receiver) of fdio_completion.
85 template <execution::receiver Receiver>
88 fdio_operation(fdio& fdioInstance, Receiver r) : in fdio_operation()
89 fdio_completion(fdioInstance), receiver(std::move(r)) in fdio_operation()
95 execution::set_value(std::move(receiver)); in complete()
100 execution::set_error(std::move(receiver), exceptionPtr); in error()
105 execution::set_stopped(std::move(receiver)); in stop()
108 Receiver receiver; member
127 template <execution::receiver R>
H A Dmatch.hpp67 /** Signal completion if there is an awaiting Receiver.
78 // Virtual class to handle the match Receiver completions.
98 // Implementation (templated based on Receiver) of match_completion.
99 template <execution::receiver Receiver>
102 match_operation(match& m, Receiver r) : in match_operation()
103 match_completion(m), receiver(std::move(r)) in match_operation()
109 execution::set_value(std::move(receiver), std::move(msg)); in complete()
114 execution::set_stopped(std::move(receiver)); in stop()
117 Receiver receiver; member
133 template <execution::receiver R>
H A Dmutex.hpp97 // Implementation (templated based on Receiver) of mutex_completion.
98 template <execution::receiver Receiver>
101 mutex_operation(mutex& mutexInstance, Receiver r) : in mutex_operation()
102 mutex_completion(mutexInstance), receiver(std::move(r)) in mutex_operation()
108 execution::set_value(std::move(receiver)); in complete()
113 execution::set_stopped(std::move(receiver)); in stop()
116 Receiver receiver; member
133 template <execution::receiver R>
H A Dtimer.hpp29 * On callback, completes the Receiver.
31 template <execution::receiver R>
38 context_ref(ctx), time(time), receiver(std::move(r)) in sleep_operation()
44 execution::set_value(std::move(self->receiver)); in handler()
57 execution::set_error(std::move(receiver), std::current_exception()); in start()
69 R receiver; member
93 template <execution::receiver R>
H A Dcallback.hpp60 template <takes_msg_handler Init, execution::receiver R>
67 init(std::move(init)), receiver(std::move(r)) in callback_operation()
92 execution::set_value(std::move(self.receiver), std::move(msg)); in handler()
96 execution::set_error(std::move(self.receiver), in handler()
115 execution::set_error(std::move(receiver), std::current_exception()); in start()
121 R receiver; member
143 template <execution::receiver R>
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/
H A D__diagnostics.hpp218 "A sender must provide a `connect` member function that takes a receiver as an\n" \
228 " template <class Receiver>\n" \
239 " Receiver rcvr_;\n" \
242 " template <stdexec::receiver Receiver>\n" \
243 " auto connect(Receiver rcvr) -> MyOpState<Receiver>\n" \
245 " return MyOpState<Receiver>{std::move(rcvr)};\n" \
257 "receiver.\n" STDEXEC_ERROR_CANNOT_CONNECT_SENDER_TO_RECEIVER
H A D__receiver_ref.hpp78 // The __ref_rcvr function and its helpers are used to avoid wrapping a receiver in a
81 // 1. If the receiver is an instance of __rcvr_ref, return it.
83 // receiver.
84 // 3. If the receiver is nothrow copy constructible, return it.
85 // 4. Otherwise, return a __rcvr_ref wrapping the receiver.
H A D__connect_awaitable.hpp132 // Pass through the get_env receiver query
141 template <receiver _Receiver>
144 template <receiver _Receiver>
200 template <receiver _Receiver, class _Awaitable>
H A D__shared.hpp52 // the internal receiver will always be completed. The ensure_started
123 // receiver to which it is connected. in operator ()()
205 // The receiver does not hold a reference to the shared state.
236 // state created by connecting a split/ensure_started sender to a receiver.
238 // start has been called but before the receiver's completion functions have
373 // See https://github.com/cplusplus/sender-receiver/issues/23
451 // underlying operation has not yet been started, and the receiver's stop token is already
463 // Start the shared op. As an optimization, skip it if the receiver's stop token has already
H A D__debug.hpp168 // receiver is nigh impossible in the current design due to limitations in
185 // to a receiver, pass it to `__debug_sender`, optionally with an
188 // To find out why a sender will not connect to a receiver of a particular
201 // receiver. This will recurse until it hits the `tag_invoke` call that is
/openbmc/sdbusplus/src/async/
H A Dcontext.cpp25 * handling for the Sender (to get it back to the Receiver, ie. the worker).
46 /* The completion template based on receiver type.
49 * a template, so we need a sub-class of completion to hold the receiver.
51 template <execution::receiver R>
55 wait_process_completion(ctx), receiver(std::move(r)) in wait_process_operation()
62 execution::set_value(std::move(this->receiver)); in complete()
68 // so treat it as if the receiver completed. in stop()
69 execution::set_value(std::move(this->receiver)); in stop()
72 R receiver; member
86 template <execution::receiver R>
H A Dmatch.cpp47 // Set ourselves as the awaiting Receiver and see if there is a message in start()
74 // completion (Receiver + message). in handle_match()
84 // If there is no match_completion, there is no awaiting Receiver. in handle_completion()
86 // Receiver isn't complete. in handle_completion()
/openbmc/pldm/requester/
H A Dhandler.hpp466 * @tparam stdexec::receiver - Execute receiver
468 template <class RequestInterface, stdexec::receiver R>
476 handler(handler), request(std::move(request)), receiver(std::move(r)) in SendRecvMsgOperation()
493 * receiver. If stopping is possible, sets up a stop callback.
501 auto stopToken = stdexec::get_stop_token(stdexec::get_env(op.receiver)); in tag_invoke()
506 return stdexec::set_stopped(std::move(op.receiver)); in tag_invoke()
516 return stdexec::set_value(std::move(op.receiver), rc, in tag_invoke()
530 * receiver.
536 return stdexec::set_stopped(std::move(receiver)); in onStop()
540 * and sets either an error or a value on the receiver.
[all …]
/openbmc/openpower-proc-control/procedures/p9/
H A Dcleanup_pcie.cpp36 * @brief Disables PCIE drivers and receiver in the PCIE root ctrl 1 register
47 // Disable the PCIE drivers and receiver on all CPUs in cleanupPcie()
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/
H A Dsequence_senders.hpp59 // This is a sequence-receiver CPO that is used to apply algorithms on an input sender and it
61 // connected to a receiver. Since calling `set_next` usually involves constructing senders it
65 template <receiver _Receiver, sender _Item>
73 template <receiver _Receiver, sender _Item>
375 concept sequence_receiver_of = stdexec::receiver<_Receiver>
414 concept sequence_receiver_from = stdexec::receiver<_Receiver>
446 receiver<_Receiver> && sender_in<_Sender, env_of_t<_Receiver>>
453 receiver<_Receiver> && sequence_sender_in<_Sequence, env_of_t<_Receiver>>
463 concept __subscribable_with_member = receiver<_Receiver>
474 concept __subscribable_with_tag_invoke = receiver<_Receiver>
[all …]
/openbmc/u-boot/include/linux/
H A Dserial_reg.h23 #define UART_IER_RLSI 0x04 /* Enable receiver line status interrupt */
25 #define UART_IER_RDI 0x01 /* Enable receiver data interrupt */
36 #define UART_IIR_RDI 0x04 /* Receiver data interrupt */
37 #define UART_IIR_RLSI 0x06 /* Receiver line status interrupt */
131 #define UART_LSR_DR 0x01 /* Receiver data ready */
227 #define UART_IER_RTOIE 0x10 /* Receiver Time Out Interrupt Enable */
259 #define UART_RFL 0x03 /* Receiver FIFO level */
269 #define UART_RTL 0x05 /* Receiver Interrupt Trigger Level */
283 #define UART_ACR_RXDIS 0x01 /* Receiver disable */
H A Dnetdevice.h43 unsigned long rx_over_errors; /* receiver ring buff overflow */
47 unsigned long rx_missed_errors; /* receiver missed packet */
/openbmc/qemu/docs/
H A Drdma.txt151 infiniband receiver side, whereas RDMA messages (used
162 on the receiver side is registered and pinned, we're
170 receiver must have reserved space (using a receive
178 1. Receiver and Sender are started (command line or libvirt):
180 3. Receiver does listen()
182 5. Receiver accept()
245 from the receiver to tell us that the receiver
362 the sender and the receiver populate the list of RAMBlocks
/openbmc/u-boot/include/
H A Dns16550.h120 #define UART_FCR_RXSR 0x02 /* Receiver soft reset */
192 #define UART_IIR_RDI 0x04 /* Receiver data interrupt */
193 #define UART_IIR_RLSI 0x06 /* Receiver line status interrupt */
199 #define UART_IER_RLSI 0x04 /* Enable receiver line status interrupt */
201 #define UART_IER_RDI 0x01 /* Enable receiver data interrupt */
/openbmc/u-boot/drivers/net/
H A D8390.h79 #define ENISR_RX 0x01 /* Receiver, no error */
81 #define ENISR_RX_ERR 0x04 /* Receiver, with error */
83 #define ENISR_OVER 0x10 /* Receiver overwrote the ring */
109 #define ENRSR_DIS 0x40 /* receiver disable. set in monitor mode */
H A Dcs8900.h77 #define PP_RxCFG 0x0102 /* Receiver configuration */
88 #define PP_RxCTL 0x0104 /* Receiver control */
130 #define PP_LineCTL_Rx 0x0040 /* Enable receiver */
137 #define PP_LineCTL_LoRxSquelch 0x4000 /* Reduce receiver squelch threshold */
197 #define PP_RxMiss 0x0130 /* Receiver miss counter */
/openbmc/qemu/hw/char/
H A Dstm32l4x5_usart.c2 * STM32L4X5 USART (Universal Synchronous Asynchronous Receiver Transmitter)
38 FIELD(CR1, RTOIE, 26, 1) /* Receiver timeout interrupt enable */
45 FIELD(CR1, WAKE, 11, 1) /* Receiver wakeup method */
54 FIELD(CR1, RE, 2, 1) /* Receiver enable */
60 FIELD(CR2, RTOEN, 23, 1) /* Receiver timeout enable */
93 FIELD(CR3, DMAR, 6, 1) /* DMA enable receiver */
107 FIELD(RTOR, RTO, 0, 24) /* Receiver timeout value */
119 FIELD(ISR, RWU, 19, 1) /* Receiver wakeup from Mute mode */
126 FIELD(ISR, RTOF, 11, 1) /* Receiver timeout */
142 FIELD(ICR, RTOCF, 11, 1) /* Receiver timeout clear flag */
/openbmc/qemu/include/hw/char/
H A Dimx_serial.h43 #define USR1_RRDY (1<<9) /* receiver ready */
46 #define USR1_RXDS (1<<6) /* Receiver is idle */
74 #define UCR2_RXEN (1<<1) /* Receiver enable */
/openbmc/qemu/net/
H A Dfilter-buffer.c49 * for the next filter or receiver to notify us that it can receive in filter_buffer_release_timer()
75 * For some reason, receiver could not receive more packets in filter_buffer_receive_iov()
79 * the packets without caring about the receiver. This is suboptimal. in filter_buffer_receive_iov()
/openbmc/qemu/tests/qtest/
H A Dstm32l4x5_usart-test.c195 /* Enable the transmitter, the receiver and the USART. */ in init_uart()
314 /* Disable the transmitter and receiver. */ in test_ack()
318 /* Test ISR ACK for transmitter and receiver disabled */ in test_ack()
323 /* Enable the transmitter and receiver. */ in test_ack()
327 /* Test ISR ACK for transmitter and receiver disabled */ in test_ack()

12345678