Home
last modified time | relevance | path

Searched refs:num_ports (Results 1 – 25 of 48) sorted by relevance

12

/external/libmojo/mojo/edk/system/ports/
Dmessage.cc55 if (event_data->num_ports > std::numeric_limits<uint16_t>::max()) in Parse()
59 event_data->num_ports * sizeof(PortDescriptor); in Parse()
60 *num_ports_bytes = event_data->num_ports * sizeof(PortName); in Parse()
74 Message::Message(size_t num_payload_bytes, size_t num_ports) in Message() argument
76 num_ports * sizeof(PortDescriptor), in Message()
77 num_payload_bytes, num_ports * sizeof(PortName)) { in Message()
78 num_ports_ = num_ports; in Message()
94 GetMutableEventData<UserEventData>(this)->num_ports = in InitializeUserMessageHeader()
Dports_unittest.cc44 size_t num_ports) { in NewUserMessage() argument
45 return ScopedMessage(new TestMessage(num_payload_bytes, num_ports)); in NewUserMessage()
48 TestMessage(size_t num_payload_bytes, size_t num_ports) in TestMessage() argument
49 : Message(num_payload_bytes, num_ports) { in TestMessage()
251 for (size_t i = 0; i < message->num_ports(); ++i) { in ClosePortsInMessage()
631 ASSERT_EQ(1u, message->num_ports()); in TEST_F()
698 ASSERT_EQ(1u, message->num_ports()); in TEST_F()
816 ASSERT_EQ(1u, message->num_ports()); in TEST_F()
827 ASSERT_EQ(1u, message->num_ports()); in TEST_F()
837 EXPECT_EQ(0u, message->num_ports()); in TEST_F()
[all …]
Dmessage.h57 size_t num_ports() const { return num_ports_bytes_ / sizeof(PortName); } in num_ports() function
64 Message(size_t num_payload_bytes, size_t num_ports);
Dmessage_queue.cc38 num_leaked_ports += message->num_ports(); in ~MessageQueue()
80 for (size_t i = 0; i < message->num_ports(); ++i) in GetReferencedPorts()
Dnode.cc292 for (size_t i = 0; i < (*message)->num_ports(); ++i) { in GetMessage()
315 for (size_t i = 0; i < message->num_ports(); ++i) { in SendMessage()
421 for (size_t i = 0; i < message->num_ports(); ++i) { in OnUserMessage()
440 for (size_t i = 0; i < message->num_ports(); ++i) { in OnUserMessage()
482 for (size_t i = 0; i < message->num_ports(); ++i) { in OnUserMessage()
816 for (size_t i = 0; i < m->num_ports(); ++i) { in SendMessageInternal()
1029 for (size_t i = 0; i < message->num_ports(); ++i) { in WillSendMessage_Locked()
1036 if (message->num_ports() > 0) { in WillSendMessage_Locked()
1041 ports.resize(message->num_ports()); in WillSendMessage_Locked()
1044 for (size_t i = 0; i < message->num_ports(); ++i) { in WillSendMessage_Locked()
[all …]
/external/libmojo/mojo/edk/system/
Dmessage_for_transit.cc35 uint32_t num_ports; in Create() member
43 size_t num_ports = 0; in Create() local
50 &dispatcher_info[i].num_ports, in Create()
53 num_ports += dispatcher_info[i].num_ports; in Create()
59 header_size + num_bytes, num_ports, num_handles); in Create()
98 dh->num_ports = info.num_ports; in Create()
111 port_index += info.num_ports; in Create()
Ddispatcher.cc131 uint32_t* num_ports, in StartSerialize() argument
134 *num_ports = 0; in StartSerialize()
157 size_t num_ports, in Deserialize() argument
163 bytes, num_bytes, ports, num_ports, platform_handles, in Deserialize()
167 bytes, num_bytes, ports, num_ports, platform_handles, in Deserialize()
171 bytes, num_bytes, ports, num_ports, platform_handles, in Deserialize()
175 bytes, num_bytes, ports, num_ports, platform_handles, in Deserialize()
179 bytes, num_bytes, ports, num_ports, platform_handles, in Deserialize()
Dports_message.cc16 size_t num_ports, in NewUserMessage() argument
19 new PortsMessage(num_payload_bytes, num_ports, num_handles)); in NewUserMessage()
25 size_t num_ports, in PortsMessage() argument
27 : ports::Message(num_payload_bytes, num_ports) { in PortsMessage()
Dplatform_handle_dispatcher.cc37 uint32_t* num_ports, in StartSerialize() argument
40 *num_ports = 0; in StartSerialize()
82 size_t num_ports, in Deserialize() argument
85 if (num_bytes || num_ports || num_handles != 1) in Deserialize()
Dplatform_handle_dispatcher_unittest.cc81 uint32_t num_ports = 0; in TEST() local
84 dispatcher->StartSerialize(&num_bytes, &num_ports, &num_handles); in TEST()
87 EXPECT_EQ(0u, num_ports); in TEST()
103 num_bytes, nullptr, num_ports, handles->data(), in TEST()
Dmessage_pipe_dispatcher.cc357 size_t next_port_index = port_index + dh.num_ports; in ReadMessage()
358 if (msg->num_ports() < next_port_index || next_port_index < port_index) in ReadMessage()
373 dh.num_ports, out_handles, dh.num_platform_handles); in ReadMessage()
459 uint32_t* num_ports, in StartSerialize() argument
462 *num_ports = 1; in StartSerialize()
507 size_t num_ports, in Deserialize() argument
510 if (num_ports != 1 || num_handles || num_bytes != sizeof(SerializedState)) in Deserialize()
Dplatform_handle_dispatcher.h29 uint32_t* num_ports,
42 size_t num_ports,
Dshared_buffer_dispatcher.cc118 size_t num_ports, in Deserialize() argument
134 if (!platform_handles || num_platform_handles != 1 || num_ports) { in Deserialize()
247 uint32_t* num_ports, in StartSerialize() argument
250 *num_ports = 0; in StartSerialize()
Dports_message.h24 size_t num_ports,
51 PortsMessage(size_t num_payload_bytes, size_t num_ports, size_t num_handles);
Dshared_buffer_dispatcher.h61 size_t num_ports,
81 uint32_t* num_ports,
Dmessage_pipe_dispatcher.h71 uint32_t* num_ports,
84 size_t num_ports,
Ddata_pipe_producer_dispatcher.h65 uint32_t* num_ports,
78 size_t num_ports,
Ddata_pipe_consumer_dispatcher.h65 uint32_t* num_ports,
78 size_t num_ports,
Ddata_pipe_producer_dispatcher.cc303 uint32_t* num_ports, in StartSerialize() argument
308 *num_ports = 1; in StartSerialize()
367 size_t num_ports, in Deserialize() argument
370 if (num_ports != 1 || num_handles != 1 || in Deserialize()
Ddispatcher.h200 uint32_t* num_ports,
236 size_t num_ports,
Ddata_pipe_consumer_dispatcher.cc325 uint32_t* num_ports, in StartSerialize() argument
330 *num_ports = 1; in StartSerialize()
389 size_t num_ports, in Deserialize() argument
392 if (num_ports != 1 || num_handles != 1 || in Deserialize()
/external/autotest/server/cros/servo/
Dpd_device.py632 num_ports = 0
635 num_ports += 1
636 return num_ports
742 num_ports = self._find_num_pd_ports(console)
745 for port in xrange(num_ports):
/external/iproute2/rdma/
Dlink.c294 for (port = 1; port < dev_map->num_ports + 1; port++) { in link_show()
305 if (!dev_map || port > dev_map->num_ports) { in link_show()
313 for (; rd->port_idx < dev_map->num_ports + 1; rd->port_idx++) { in link_show()
/external/syslinux/gpxe/src/drivers/infiniband/
Dhermon.c1703 if ( port >= hermon->cap.num_ports ) { in hermon_event_port_state_change()
2179 hermon->cap.num_ports = MLX_GET ( &dev_cap, num_ports ); in hermon_get_cap()
2183 if ( hermon->cap.num_ports > HERMON_MAX_PORTS ) { in hermon_get_cap()
2185 hermon, hermon->cap.num_ports, HERMON_MAX_PORTS ); in hermon_get_cap()
2186 hermon->cap.num_ports = HERMON_MAX_PORTS; in hermon_get_cap()
2631 for ( i = 0 ; i < hermon->cap.num_ports ; i++ ) { in hermon_probe()
2662 for ( i = 0 ; i < hermon->cap.num_ports ; i++ ) in hermon_probe()
2674 for ( i = 0 ; i < hermon->cap.num_ports ; i++ ) { in hermon_probe()
2679 for ( i = 0 ; i < hermon->cap.num_ports ; i++ ) { in hermon_probe()
2689 i = hermon->cap.num_ports; in hermon_probe()
[all …]
/external/syslinux/gpxe/src/net/
Dinfiniband.c724 int num_ports = 0; in ib_get_hca_info() local
732 if ( num_ports == 0 ) { in ib_get_hca_info()
736 num_ports++; in ib_get_hca_info()
738 return num_ports; in ib_get_hca_info()

12