Home
last modified time | relevance | path

Searched refs:channel_id (Results 1 – 25 of 257) sorted by relevance

1234567891011

/external/webrtc/audio/voip/
Dvoip_core.cc126 ChannelId channel_id; in CreateChannel() local
142 channel_id = static_cast<ChannelId>(next_channel_id_); in CreateChannel()
143 channels_[channel_id] = channel; in CreateChannel()
151 channel->SetId(channel_id); in CreateChannel()
153 return channel_id; in CreateChannel()
156 VoipResult VoipCore::ReleaseChannel(ChannelId channel_id) { in ReleaseChannel() argument
165 auto iter = channels_.find(channel_id); in ReleaseChannel()
176 RTC_LOG(LS_WARNING) << "Channel " << channel_id << " not found"; in ReleaseChannel()
197 rtc::scoped_refptr<AudioChannel> VoipCore::GetChannel(ChannelId channel_id) { in GetChannel() argument
201 auto iter = channels_.find(channel_id); in GetChannel()
[all …]
Dvoip_core.h74 VoipResult ReleaseChannel(ChannelId channel_id) override;
75 VoipResult StartSend(ChannelId channel_id) override;
76 VoipResult StopSend(ChannelId channel_id) override;
77 VoipResult StartPlayout(ChannelId channel_id) override;
78 VoipResult StopPlayout(ChannelId channel_id) override;
82 ChannelId channel_id,
85 ChannelId channel_id,
89 VoipResult SetSendCodec(ChannelId channel_id,
93 ChannelId channel_id,
97 VoipResult RegisterTelephoneEventType(ChannelId channel_id,
[all …]
/external/pigweed/pw_rpc/
Dchannel_list.cc19 const Channel* ChannelList::Get(uint32_t channel_id) const { in Get()
21 if (channel.id() == channel_id) { in Get()
28 Status ChannelList::Add(uint32_t channel_id, ChannelOutput& output) { in Add() argument
29 if (Get(channel_id) != nullptr) { in Add()
34 channels_.emplace_back(channel_id, &output); in Add()
41 new_channel->Configure(channel_id, output); in Add()
47 Status ChannelList::Remove(uint32_t channel_id) { in Remove() argument
48 Channel* channel = Get(channel_id); in Remove()
Dserver.cc49 internal::Channel* channel = GetInternalChannel(packet.channel_id()); in ProcessPacket()
53 static_cast<unsigned>(packet.channel_id())); in ProcessPacket()
67 static_cast<unsigned>(packet.channel_id()), in ProcessPacket()
77 *this, packet.channel_id(), *service, *method, packet.call_id()); in ProcessPacket()
135 static_cast<unsigned>(packet.channel_id()), in HandleClientStreamPacket()
148 static_cast<unsigned>(packet.channel_id()), in HandleClientStreamPacket()
161 static_cast<unsigned>(packet.channel_id()), in HandleClientStreamPacket()
/external/pigweed/pw_rpc/raw/public/pw_rpc/raw/
Dclient_reader_writer.h39 using internal::Call::channel_id;
71 uint32_t channel_id, in RawClientReaderWriter() argument
77 channel_id, in RawClientReaderWriter()
92 using internal::StreamResponseClientCall::channel_id;
105 uint32_t channel_id, in RawClientReader() argument
110 channel_id, in RawClientReader()
125 using internal::UnaryResponseClientCall::channel_id;
143 uint32_t channel_id, in RawClientWriter() argument
148 channel_id, in RawClientWriter()
163 using internal::UnaryResponseClientCall::channel_id;
[all …]
Dserver_reader_writer.h59 uint32_t channel_id, in Open() argument
65 channel_id, in Open()
73 using internal::Call::channel_id;
123 uint32_t channel_id, in Open() argument
128 channel_id, in Open()
141 using RawServerReaderWriter::channel_id;
171 uint32_t channel_id, in Open() argument
176 channel_id, in Open()
189 using RawServerReaderWriter::channel_id;
220 uint32_t channel_id, in Open() argument
[all …]
/external/pigweed/pw_rpc/public/pw_rpc/internal/
Dfake_channel_output.h71 PayloadsView payloads(uint32_t channel_id = Channel::kUnassignedChannelId)
76 channel_id, in PW_LOCKS_EXCLUDED()
82 uint32_t channel_id, in payloads() argument
86 return PayloadsView(packets_, type, channel_id, service_id, method_id); in payloads()
91 size_t total_payloads(uint32_t channel_id = Channel::kUnassignedChannelId)
96 channel_id, in PW_LOCKS_EXCLUDED()
104 uint32_t channel_id, in total_payloads() argument
108 return PayloadsView(packets_, type, channel_id, service_id, method_id) in total_payloads()
121 StatusView completions(uint32_t channel_id = Channel::kUnassignedChannelId)
127 channel_id, in PW_LOCKS_EXCLUDED()
[all …]
Dclient_call.h50 uint32_t channel_id, in ClientCall() argument
54 : Call(client, channel_id, service_id, method_id, properties) {} in ClientCall()
77 uint32_t channel_id, in Start() argument
84 CallType call(client.ClaimLocked(), channel_id, service_id, method_id); in Start()
100 uint32_t channel_id, in UnaryResponseClientCall() argument
105 : ClientCall(client, channel_id, service_id, method_id, properties) {} in UnaryResponseClientCall()
149 uint32_t channel_id, in Start() argument
157 CallType call(client.ClaimLocked(), channel_id, service_id, method_id); in Start()
174 uint32_t channel_id, in StreamResponseClientCall() argument
179 : ClientCall(client, channel_id, service_id, method_id, properties) {} in StreamResponseClientCall()
Dchannel_list.h57 const Channel* Get(uint32_t channel_id) const; in ChannelList()
59 Channel* Get(uint32_t channel_id) { in ChannelList() argument
61 static_cast<const ChannelList&>(*this).Get(channel_id)); in ChannelList()
72 Status Add(uint32_t channel_id, ChannelOutput& output); in ChannelList()
79 Status Remove(uint32_t channel_id); in ChannelList()
Dpacket.h55 request.channel_id(),
67 packet.channel_id(), in ServerError()
79 packet.channel_id(), in ClientError()
93 uint32_t channel_id,
100 channel_id_(channel_id), in type_()
125 constexpr uint32_t channel_id() const { return channel_id_; } in channel_id() function
133 constexpr void set_channel_id(uint32_t channel_id) { in set_channel_id() argument
134 channel_id_ = channel_id; in set_channel_id()
Dcall_context.h38 uint32_t channel_id, in CallContext() argument
43 channel_id_(channel_id), in CallContext()
61 constexpr const uint32_t& channel_id() const { return channel_id_; } in channel_id() function
70 void set_channel_id(uint32_t channel_id) { channel_id_ = channel_id; } in set_channel_id() argument
Dtest_method_context.h42 void set_channel_id(uint32_t channel_id) { in set_channel_id() argument
43 PW_ASSERT(channel_id != Channel::kUnassignedChannelId); in set_channel_id()
48 PW_ASSERT(server_.CloseChannel(context_.channel_id()).ok()); in set_channel_id()
49 PW_ASSERT(server_.OpenChannel(channel_id, output_).ok()); in set_channel_id()
51 channel_ = Channel(channel_id, &output_); in set_channel_id()
52 context_.set_channel_id(channel_id); in set_channel_id()
114 uint32_t channel_id() const { return channel_.id(); } in channel_id() function
/external/tensorflow/tensorflow/compiler/mlir/xla/transforms/
Dlegalize_tf_collective.cc123 ChannelHandleAttr ConvertChannel(OpBuilder& builder, int64_t channel_id, in ConvertChannel() argument
129 /*handle=*/channel_id, in ConvertChannel()
133 LogicalResult ConvertAllReduce(OpBuilder& builder, int64_t channel_id, in ConvertAllReduce() argument
139 ChannelHandleAttr channel_handle = ConvertChannel(builder, channel_id, mode); in ConvertAllReduce()
185 CollectiveRewritePattern(MLIRContext* context, int64_t* channel_id) in CollectiveRewritePattern() argument
186 : OpRewritePattern<T>(context), channel_id_(*channel_id) {} in CollectiveRewritePattern()
237 int64_t channel_id = channel_id_++; in matchAndRewrite() local
238 return ConvertAllReduce(rewriter, channel_id, all_reduce.getType(), in matchAndRewrite()
279 int64_t channel_id = channel_id_++; in matchAndRewrite() local
287 return ConvertAllReduce(rewriter, channel_id, all_reduce.getType(), in matchAndRewrite()
[all …]
/external/tensorflow/tensorflow/compiler/xla/service/
Dhlo_module_group_metadata.cc86 for (HloInstruction* instr : GetAllReduceGroup(*hlo->channel_id())) { in Build()
227 int64_t channel_id) const { in GetChannel()
228 CHECK(channel_id_map_.find(channel_id) != channel_id_map_.end()); in GetChannel()
229 return channels_[channel_id_map_.at(channel_id)]; in GetChannel()
232 bool HloModuleGroupMetadata::HasChannel(int64_t channel_id) const { in HasChannel()
233 return channel_id_map_.find(channel_id) != channel_id_map_.end(); in HasChannel()
239 const Channel& channel = GetChannel(*instruction->channel_id()); in PeerComputation()
253 int64_t channel_id) const { in GetAllReduceGroup()
254 auto it = all_reduce_map_.find(channel_id); in GetAllReduceGroup()
336 TF_RET_CHECK(channel_id_map_.find(*hlo->channel_id()) == in RecordInstructions()
[all …]
Dreduce_scatter_decomposer.cc52 std::optional<int64_t> channel_id; in Run() local
53 if (rs->channel_id()) { in Run()
54 channel_id = next_channel_id++; in Run()
61 rs->replica_groups(), rs->constrain_layout(), channel_id, in Run()
67 GetCollectiveOpGroupMode(rs->channel_id().has_value(), in Run()
/external/webrtc/api/transport/
Ddata_channel_transport_interface.h65 virtual void OnDataReceived(int channel_id,
71 virtual void OnChannelClosing(int channel_id) = 0;
76 virtual void OnChannelClosed(int channel_id) = 0;
98 virtual RTCError OpenChannel(int channel_id) = 0;
103 virtual RTCError SendData(int channel_id,
110 virtual RTCError CloseChannel(int channel_id) = 0;
/external/libese/apps/weaver/
Dweaver.c71 session->channel_id = 0; in ese_weaver_session_init()
116 session->channel_id = rx_buf[rx_len - 3]; in ese_weaver_session_open()
119 uint8_t chan = kSelectApplet[0] | session->channel_id; in ese_weaver_session_open()
152 if (!session->active || session->channel_id == 0) { in ese_weaver_session_close()
158 close_channel[0] |= session->channel_id; in ese_weaver_session_close()
159 close_channel[3] |= session->channel_id; in ese_weaver_session_close()
173 session->channel_id = 0; in ese_weaver_session_close()
183 if (!session->active || session->channel_id == 0) { in ese_weaver_get_num_slots()
193 get_num_slots[0] |= session->channel_id; in ese_weaver_get_num_slots()
226 if (!session->active || session->channel_id == 0) { in ese_weaver_write()
[all …]
/external/arm-trusted-firmware/drivers/arm/css/scp/
Dcss_pm_scmi.c130 unsigned int lvl, channel_id, domain_id; in css_scp_suspend() local
159 &domain_id, &channel_id); in css_scp_suspend()
160 ret = scmi_pwr_state_set(scmi_handles[channel_id], in css_scp_suspend()
177 unsigned int lvl = 0, channel_id, domain_id; in css_scp_off() local
201 &domain_id, &channel_id); in css_scp_off()
202 ret = scmi_pwr_state_set(scmi_handles[channel_id], in css_scp_off()
217 unsigned int lvl = 0, channel_id, core_pos, domain_id; in css_scp_on() local
231 &channel_id); in css_scp_on()
232 ret = scmi_pwr_state_set(scmi_handles[channel_id], in css_scp_on()
249 unsigned int channel_id, cpu_idx, domain_id; in css_scp_get_power_state() local
[all …]
/external/webrtc/api/voip/
Dvoip_base.h75 virtual VoipResult ReleaseChannel(ChannelId channel_id) = 0;
83 virtual VoipResult StartSend(ChannelId channel_id) = 0;
91 virtual VoipResult StopSend(ChannelId channel_id) = 0;
100 virtual VoipResult StartPlayout(ChannelId channel_id) = 0;
106 virtual VoipResult StopPlayout(ChannelId channel_id) = 0;
/external/pigweed/pw_rpc/public/pw_rpc/
Dpayloads_view.h44 uint32_t channel_id, in PacketFilter() argument
49 channel_id_(channel_id), in PacketFilter()
57 packet.channel_id() == channel_id_) && in operator()
137 uint32_t channel_id) { in For() argument
142 channel_id, in For()
149 uint32_t channel_id, in PayloadsView() argument
155 channel_id, in PayloadsView()
162 uint32_t channel_id, in PayloadsView() argument
168 channel_id, in PayloadsView()
251 uint32_t channel_id, in StatusView() argument
[all …]
/external/pigweed/pw_rpc/py/pw_rpc/
Dpackets.py46 channel_id=channel,
58 channel_id=channel,
70 channel_id=channel,
80 channel_id=packet.channel_id,
92 channel_id=channel,
103 channel_id=channel,
/external/ComputeLibrary/src/core/NEON/kernels/
DNESpaceToDepthLayerKernel.cpp125 const size_t channel_id = id.z(); in run() local
126 … const size_t in_x = id.x() * _block_shape + (channel_id / channel_size) % _block_shape; in run()
127 … const size_t in_y = id.y() * _block_shape + (channel_id / channel_size) / _block_shape; in run()
128 const int z = channel_id % channel_size; in run()
144 const size_t channel_id = id.x(); in run() local
145 … const size_t in_x = id.y() * _block_shape + (channel_id / channel_size) % _block_shape; in run()
146 … const size_t in_y = id.z() * _block_shape + (channel_id / channel_size) / _block_shape; in run()
147 const int z = channel_id % channel_size; in run()
/external/pigweed/pw_rpc/pwpb/public/pw_rpc/pwpb/
Dserver_reader_writer.h199 uint32_t channel_id, in Open() argument
212 channel_id, in Open()
226 using internal::Call::channel_id;
275 uint32_t channel_id, in Open() argument
287 channel_id, in Open()
301 using internal::Call::channel_id;
346 uint32_t channel_id, in Open() argument
355 channel_id, in Open()
369 using internal::Call::channel_id;
416 uint32_t channel_id, in Open() argument
[all …]
/external/pigweed/pw_rpc/nanopb/public/pw_rpc/nanopb/
Dclient_reader_writer.h34 uint32_t channel_id, in Start() argument
44 client.ClaimLocked(), channel_id, service_id, method_id, serde); in Start()
62 uint32_t channel_id, in NanopbUnaryResponseClientCall() argument
69 client, channel_id, service_id, method_id, StructCallProps(type)), in NanopbUnaryResponseClientCall()
123 uint32_t channel_id, in Start() argument
134 client.ClaimLocked(), channel_id, service_id, method_id, serde); in Start()
167 uint32_t channel_id, in NanopbStreamResponseClientCall() argument
174 client, channel_id, service_id, method_id, StructCallProps(type)), in NanopbStreamResponseClientCall()
221 using internal::Call::channel_id;
285 using internal::Call::channel_id;
[all …]
Dserver_reader_writer.h150 uint32_t channel_id, in Open() argument
163 channel_id, in Open()
175 using internal::Call::channel_id;
221 uint32_t channel_id, in Open() argument
234 channel_id, in Open()
248 using internal::Call::channel_id;
282 uint32_t channel_id, in Open() argument
292 channel_id, in Open()
306 using internal::Call::channel_id;
347 uint32_t channel_id, in Open() argument
[all …]

1234567891011