/openbmc/qemu/net/ |
H A D | queue.c | 45 NetClientState *sender; member 94 NetClientState *sender, in qemu_net_queue_append() argument 106 packet->sender = sender; in qemu_net_queue_append() 117 NetClientState *sender, in qemu_net_queue_append_iov() argument 135 packet->sender = sender; in qemu_net_queue_append_iov() 152 NetClientState *sender, in qemu_net_queue_deliver() argument 164 ret = queue->deliver(sender, flags, &iov, 1, queue->opaque); in qemu_net_queue_deliver() 171 NetClientState *sender, in qemu_net_queue_deliver_iov() argument 179 ret = queue->deliver(sender, flags, iov, iovcnt, queue->opaque); in qemu_net_queue_deliver_iov() 197 NetClientState *sender, in qemu_net_queue_send() argument [all …]
|
H A D | filter.c | 30 NetClientState *sender, in qemu_netfilter_receive() argument 42 nf, sender, flags, iov, iovcnt, sent_cb); in qemu_netfilter_receive() 64 ssize_t qemu_netfilter_pass_to_next(NetClientState *sender, in qemu_netfilter_pass_to_next() argument 75 if (!sender || !sender->peer) { in qemu_netfilter_pass_to_next() 76 /* no receiver, or sender been deleted, no need to pass it further */ in qemu_netfilter_pass_to_next() 81 if (sender == nf->netdev) { in qemu_netfilter_pass_to_next() 96 * to the sender, so sent_cb shouldn't be called later, just in qemu_netfilter_pass_to_next() 99 ret = qemu_netfilter_receive(next, direction, sender, flags, iov, in qemu_netfilter_pass_to_next() 109 * Do the valid check again in case sender or receiver been in qemu_netfilter_pass_to_next() 112 if (sender && sender->peer) { in qemu_netfilter_pass_to_next() [all …]
|
H A D | net.c | 257 static ssize_t qemu_deliver_packet_iov(NetClientState *sender, 613 int qemu_can_send_packet(NetClientState *sender) in qemu_can_send_packet() argument 621 if (!sender->peer) { in qemu_can_send_packet() 625 return qemu_can_receive_packet(sender->peer); in qemu_can_send_packet() 630 NetClientState *sender, in filter_receive_iov() argument 641 ret = qemu_netfilter_receive(nf, direction, sender, flags, iov, in filter_receive_iov() 649 ret = qemu_netfilter_receive(nf, direction, sender, flags, iov, in filter_receive_iov() 662 NetClientState *sender, in filter_receive() argument 673 return filter_receive_iov(nc, direction, sender, flags, &iov, 1, sent_cb); in filter_receive() 710 static ssize_t qemu_send_packet_async_with_flags(NetClientState *sender, in qemu_send_packet_async_with_flags() argument [all …]
|
/openbmc/linux/drivers/s390/net/ |
H A D | smsgiucv_app.c | 43 static char *sender; variable 44 module_param(sender, charp, 0400); 45 MODULE_PARM_DESC(sender, "z/VM user ID from which CP SMSGs are accepted"); 89 /* setting up environment: sender, prefix name, and message text */ in smsg_app_event_alloc() 126 * the configured sender. */ in smsg_app_callback() 127 if (sender && strlen(sender) > 0 && strcmp(from, sender) != 0) in smsg_app_callback() 184 /* convert sender to uppercase characters */ in smsgiucv_app_init() 185 if (sender) { in smsgiucv_app_init() 186 int len = strlen(sender); in smsgiucv_app_init() 188 sender[len] = toupper(sender[len]); in smsgiucv_app_init()
|
H A D | smsgiucv.c | 57 unsigned char sender[9]; in smsg_message_pending() local 69 memcpy(sender, buffer, 8); in smsg_message_pending() 70 sender[8] = 0; in smsg_message_pending() 71 /* Remove trailing whitespace from the sender name. */ in smsg_message_pending() 73 if (sender[i] != ' ' && sender[i] != '\t') in smsg_message_pending() 75 sender[i] = 0; in smsg_message_pending() 80 cb->callback(sender, buffer + 8); in smsg_message_pending()
|
/openbmc/sdbusplus/include/sdbusplus/async/ |
H A D | callback.hpp | 25 /** Create a sd_bus-callback Sender. 29 * into a Sender. 35 * For example, `sd_bus_call_async` could be turned into a Sender with a 47 * @returns A Sender which completes when sd-bus calls the callback and yields 59 /** The operation which handles the Sender completion. */ 102 // Call the init function upon Sender start. 126 /** The Sender for a callback. 128 * The basically just holds the Init function until the Sender is connected 139 // This Sender yields a message_t.
|
H A D | timer.hpp | 10 /** sleep_for Sender 12 * This Sender performs the equivalent of `std::this_thread::sleep_for`, 18 * @return A sender which completes after time. 74 /** The delay Sender. 104 // Run the delay sender and then switch back to the worker thread. in sleep_for()
|
H A D | context.hpp | 55 /** Spawn a Sender to run on the context. 57 * @param[in] sender - The Sender to run. 60 void spawn(Snd&& sender) in spawn() argument 65 execution::starts_on(loop.get_scheduler(), std::move(sender)))); in spawn()
|
/openbmc/linux/net/netfilter/ |
H A D | nf_conntrack_proto_tcp.c | 110 * equivalent with the ones of the sender/receiver. We always 111 * try to guess the state of the current sender. 297 td_maxwin += seq + len - sender.td_maxend 298 if seq + len > sender.td_maxend 301 I. Upper bound for valid data: seq <= sender.td_maxend 302 II. Lower bound for valid data: seq + len >= sender.td_end - receiver.td_maxwin 326 #define MAXACKWINDOW(sender) \ argument 327 ((sender)->td_maxwin > MAXACKWINCONST ? (sender)->td_maxwin \ 455 static void tcp_init_sender(struct ip_ct_tcp_state *sender, in tcp_init_sender() argument 466 sender->td_end = in tcp_init_sender() [all …]
|
/openbmc/linux/tools/testing/selftests/net/mptcp/ |
H A D | mptcp_connect.sh | 890 for sender in "$ns1" "$ns2" "$ns3" "$ns4";do 891 do_ping "$ns1" $sender 10.0.1.1 892 do_ping "$ns1" $sender dead:beef:1::1 894 do_ping "$ns2" $sender 10.0.1.2 895 do_ping "$ns2" $sender dead:beef:1::2 896 do_ping "$ns2" $sender 10.0.2.1 897 do_ping "$ns2" $sender dead:beef:2::1 899 do_ping "$ns3" $sender 10.0.2.2 900 do_ping "$ns3" $sender dead:beef:2::2 901 do_ping "$ns3" $sender 10.0.3.2 [all …]
|
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/__detail/ |
H A D | __let.hpp | 44 // sender doesn't have a completion scheduler. 94 "In stdexec::let_value(Sender, Function)..."}; 98 "In stdexec::let_error(Sender, Function)..."}; 102 "In stdexec::let_stopped(Sender, Function)..."}; 145 // If the input sender knows its completion scheduler, make it the current 146 // scheduler in the environment seen by the result sender. 165 "The function must return a valid sender for the current environment"_mstr>, 175 "The function must return a valid sender for the current environment"_mstr>, 181 sender_in<_Sender, _Env...> || (sender<_Sender> && (sizeof...(_Env) == 0)); 189 // A metafunction that computes the result sender type for a given set of [all …]
|
H A D | __sender_adaptor_closure.hpp | 44 && sender<__decay_t<_Sender>> // 46 && sender<__call_result_t<_Tp, __decay_t<_Sender>>>; 58 template <sender _Sender> 69 template <sender _Sender> 84 template <sender _Sender, __sender_adaptor_closure_for<_Sender> _Closure> 143 template <sender _Sender> 165 template <sender _Sender>
|
H A D | __sync_wait.hpp | 181 "The argument to stdexec::sync_wait() is a sender that can complete successfully in more " 222 "The stdexec::sender_in<Sender, Environment> concept check has failed."_mstr; in __diagnose_error() 234 "Failed to connect the given sender to sync_wait's internal receiver. " in __diagnose_error() 235 "The stdexec::connect(Sender, Receiver) expression is ill-formed."_mstr; in __diagnose_error() 283 /// @brief Synchronously wait for the result of a sender, blocking the 286 /// `sync_wait` connects and starts the given sender, and then drives a 287 /// `run_loop` instance until the sender completes. Additional work 292 /// @pre The sender must have a exactly one value completion signature. That 314 // Launch the sender with a continuation that will fill in the __result in apply_sender()
|
/openbmc/qemu/ui/ |
H A D | cocoa.m | 328 - (void) setFullGrab:(id)sender; 739 - (void) setFullGrab:(id)sender 1262 - (void)doToggleFullScreen:(id)sender; 1263 - (void)showQEMUDoc:(id)sender; 1264 - (void)zoomToFit:(id) sender; 1265 - (void)displayConsole:(id)sender; 1266 - (void)pauseQEMU:(id)sender; 1267 - (void)resumeQEMU:(id)sender; 1270 - (void)restartQEMU:(id)sender; 1271 - (void)powerDownQEMU:(id)sender; [all …]
|
/openbmc/linux/tools/testing/vsock/ |
H A D | vsock_perf.c | 258 printf("Run as sender\n"); in run_sender() 310 .name = "sender", 347 "It runs in two modes: sender or receiver. In sender mode, it\n" in usage() 352 " --sender <cid> Sender mode (receiver default)\n" in usage() 356 " --buf-size <bytes>KMG Data buffer size (default %d). In sender mode\n" in usage() 385 bool sender = false; in main() local 409 case 'S': /* Sender mode. CID to connect to. */ in main() 411 sender = true; in main() 421 if (!sender) in main()
|
H A D | README | 42 sender/receiver modes: sender connect to peer at the specified port and 47 # run as sender 49 ./vsock_perf --sender 2 --port 1234 --bytes 1G --buf-size 1M
|
/openbmc/qemu/include/net/ |
H A D | queue.h | 31 typedef void (NetPacketSent) (NetClientState *sender, ssize_t ret); 41 typedef ssize_t (NetQueueDeliverFunc)(NetClientState *sender, 50 NetClientState *sender, 63 NetClientState *sender, 70 NetClientState *sender,
|
/openbmc/linux/Documentation/driver-api/md/ |
H A D | md-cluster.rst | 75 Messages can be broadcast to all nodes, and the sender waits for all 153 sender receiver receiver 156 2. sender get EX on "token", 157 sender get EX on "message":: 159 sender receiver receiver 164 Sender checks that it still needs to send a message. Messages 168 3. sender writes LVB 170 sender down-convert "message" from EX to CW 172 sender try to get EX of "ack" 186 sender receiver receiver [all …]
|
/openbmc/linux/drivers/media/pci/cx18/ |
H A D | cx18-mailbox.h | 41 /* The sender sets a handle in 'request' after he fills the command. The 42 'request' should be different than 'ack'. The sender, also, generates 43 an interrupt on XPU2YPU_irq where XPU is the sender and YPU is the 48 generates an interrupt on YPU2XPU_irq where XPU is the sender and YPU 64 receiver to the sender. 'req' will be returned in args[0] */
|
/openbmc/linux/arch/s390/mm/ |
H A D | cmm.c | 29 static char *sender; variable 30 module_param(sender, charp, 0400); 31 MODULE_PARM_DESC(sender, 360 if (strlen(sender) > 0 && strcmp(from, sender) != 0) in cmm_smsg_target() 402 /* convert sender to uppercase characters */ in cmm_init() 403 if (sender) in cmm_init() 404 string_upper(sender, sender); in cmm_init() 406 sender = cmm_default_sender; in cmm_init()
|
/openbmc/linux/net/dccp/ |
H A D | ccid.h | 31 * @ccid_hc_{r,t}x_slab: memory pool for the receiver/sender half-connection 32 * @ccid_hc_{r,t}x_obj_size: size of the receiver/sender half-connection socket 39 * @ccid_hc_tx_packet_recv: implements feedback processing for the HC-sender 40 * @ccid_hc_tx_send_packet: implements the sending part of the HC-sender 41 * @ccid_hc_tx_packet_sent: does accounting for packets in flight by HC-sender 42 * @ccid_hc_{r,t}x_get_info: INET_DIAG information for HC-receiver/sender 43 * @ccid_hc_{r,t}x_getsockopt: socket options specific to HC-receiver/sender 208 * ccid_hc_rx_parse_options - Parse CCID-specific options sent by the sender
|
/openbmc/openbmc-tools/dbus-vis/ |
H A D | dbus_timeline_vis.js | 40 'Sender': 3, property in IDXES 48 // It is independent of the "group_by" of the meta-data (sender/destination/ 60 const sender = msg[IDXES["Sender"]]; 62 if (sender == "s" || sender == "sss") { 81 if (ret == undefined && cxn_occ[sender] <= 10) { 105 const cxn = pp[IDXES["Sender"]];
|
H A D | dbus_pcap_loader.js | 215 let serial, path, member, iface, destination, sender, signature = ''; 229 sender = fixed_header[1][idx][1]; 232 if (sender == "s" || sender == "sss") { 233 sender = packet[1][0]; 262 'sig', timestamp, serial, sender, destination, path, iface, member, 281 sender = fixed_header[1][5][1]; 284 sender = fixed_header[1][4][1]; 287 'mc', timestamp, serial, sender, destination, path, iface, member,
|
/openbmc/linux/include/uapi/linux/netfilter/ |
H A D | nf_conntrack_tcp.h | 28 /* Window scaling is advertised by the sender */ 31 /* SACK is permitted by the sender */ 34 /* This sender sent FIN first */
|
/openbmc/sdbusplus/include/sdbusplus/async/stdexec/ |
H A D | sequence_senders.hpp | 47 // This concept checks if a given sender satisfies the requirements to be 57 // sender and it returns a next-sender. `set_next` is usually called in a 58 // context where a sender will be connected to a receiver. Since calling 61 // returned object is a sender that can complete with `set_value_t()` or 65 template <receiver _Receiver, sender _Item> 73 "The sender returned from set_next is required to complete with set_value_t() or " in operator ()() 414 template <sender _Sender, receiver _Receiver> 433 "stdexec::connect(sender, receiver) must return a type that " 449 "exec::subscribe(sender, receiver) must return a type that "
|