| /external/chromium_org/ipc/ |
| ipc_sync_message_filter.h | 37 virtual void OnFilterAdded(Channel* channel) OVERRIDE;
50 // The channel to which this filter was added.
51 Channel* channel_;
56 // The message loop where the Channel lives.
|
| ipc_channel_nacl.cc | 38 contents->data.resize(Channel::kReadBufferSize);
64 class Channel::ChannelImpl::ReaderThreadRunner
93 Channel::ChannelImpl::ReaderThreadRunner::ReaderThreadRunner(
104 void Channel::ChannelImpl::ReaderThreadRunner::Run() {
120 Channel::ChannelImpl::ChannelImpl(const IPC::ChannelHandle& channel_handle,
137 Channel::ChannelImpl::~ChannelImpl() {
141 bool Channel::ChannelImpl::Connect() {
143 DLOG(INFO) << "Channel creation failed: " << pipe_name_;
147 // Note that Connect is called on the "Channel" thread (i.e., the same thread
148 // where Channel::Send will be called, and the same thread that should receiv
[all...] |
| ipc_channel_proxy.cc | 25 void ChannelProxy::MessageFilter::OnFilterAdded(Channel* channel) {}
61 const Channel::Mode& mode) {
64 channel_.reset(new Channel(handle, mode, this));
86 // Called on the IPC::Channel thread
94 // Called on the IPC::Channel thread
105 // Called on the IPC::Channel thread
123 // Called on the IPC::Channel thread
133 // Called on the IPC::Channel thread
150 // Called on the IPC::Channel threa
397 Channel* channel = context_.get()->channel_.get(); local
406 Channel* channel = context_.get()->channel_.get(); local
415 Channel* channel = context_.get()->channel_.get(); local
[all...] |
| /external/chromium_org/remoting/protocol/ |
| channel_factory.h | 22 // TODO(sergeyu): Specify connection error code when channel
32 // when then new channel is created and connected. The callback is called with
44 // operation for the named channel. If the channel creation already
46 // this method must be called for each channel pending creation.
|
| /external/chromium_org/third_party/WebKit/Source/modules/mediastream/ |
| RTCDataChannelEvent.cpp | 37 PassRefPtr<RTCDataChannelEvent> RTCDataChannelEvent::create(const AtomicString& type, bool canBubble, bool cancelable, PassRefPtr<RTCDataChannel> channel)
39 return adoptRef(new RTCDataChannelEvent(type, canBubble, cancelable, channel));
48 RTCDataChannelEvent::RTCDataChannelEvent(const AtomicString& type, bool canBubble, bool cancelable, PassRefPtr<RTCDataChannel> channel)
50 , m_channel(channel)
59 RTCDataChannel* RTCDataChannelEvent::channel() const function in class:WebCore::RTCDataChannelEvent
|
| /external/chromium_org/third_party/libjingle/source/talk/media/base/ |
| audiorenderer.h | 33 // Abstract interface for holding the voice channel IDs.
36 // Add the WebRtc VoE channel to the renderer.
38 // renderer. While for remote stream, only one WebRtc VoE channel can be
42 // Remove the WebRtc VoE channel from the renderer.
43 // This method is called when the VoE channel is going away.
|
| /external/ganymed-ssh2/src/main/java/ch/ethz/ssh2/channel/ |
| StreamForwarder.java | 5 package ch.ethz.ssh2.channel;
15 * then one can be configured to shutdown the underlying channel/socket
25 byte[] buffer = new byte[Channel.CHANNEL_BUFFER_SIZE];
26 Channel c;
31 StreamForwarder(Channel c, StreamForwarder sibling, Socket s, InputStream is, OutputStream os, String mode)
|
| Channel.java | 5 package ch.ethz.ssh2.channel;
8 * Channel.
11 * @version $Id: Channel.java 14 2011-05-27 14:28:21Z dkocher@sudo.ch $
13 public class Channel
37 * ====> Always keep that in mind when modifying the Channel/ChannelManger
59 // These two fields will only be written while the Channel is in state
63 // Therefore, if you know that the Channel is in state STATE_OPEN, then you
64 // can read these two fields without synchronizing on the Channel. However, make
66 // object). However, to be on the safe side, you can lock the channel.
76 * we cannot keep a lock on the Channel during the send operation (thi
[all...] |
| /external/chromium_org/chrome/installer/linux/rpm/ |
| build.sh | 19 # release channel packages.
21 if [ "$CHANNEL" = "trunk" ] || [ "$CHANNEL" = "asan" ]; then
22 local INSTALLDIR="${INSTALLDIR}-${CHANNEL}"
23 PACKAGE_FILENAME="${PACKAGE}-${CHANNEL}"
24 local MENUNAME="${MENUNAME} (${CHANNEL})"
40 if [ "$CHANNEL" != "stable" ]; then
46 local SXS_USER_DATA_DIR="\${XDG_CONFIG_HOME:-\${HOME}/.config}/${PACKAGE}-${CHANNEL}"
55 if [ "$CHANNEL" = "trunk" ] || [ "$CHANNEL" = "asan" ]; the
[all...] |
| /external/antlr/antlr-3.4/runtime/CSharp2/Sources/Antlr3.Runtime/Antlr.Runtime/ |
| CommonTokenStream.cs | 41 * and tokens are prefiltered for a certain channel (the parser will only
42 * see these tokens and cannot change the filter channel number during the
50 /** Skip tokens on any channel but this one; this is how we skip whitespace... */
60 public CommonTokenStream(ITokenSource tokenSource, int channel)
62 this._channel = channel;
65 public int Channel {
82 /** Always leave p on an on-channel token. */
88 while (_tokens[_p].Channel != _channel) {
102 // skip off-channel tokens
122 // skip off-channel token
[all...] |
| /external/chromium_org/components/nacl/loader/ |
| nacl_ipc_adapter.h | 31 class Channel;
39 // Adapts a Chrome IPC channel to an IPC channel that we expose to Native
43 // we implement that as sending IPC messages on the channel.
77 // NaClIPCAdapter is constructed, or the NaClIPCAdapter's channel will not be
81 // Initializes with a given channel that's already created for testing
82 // purposes. This function will take ownership of the given channel.
83 NaClIPCAdapter(scoped_ptr<IPC::Channel> channel, base::TaskRunner* runner);
85 // Connect the channel. This must be called after the constructor that accept
[all...] |
| /libcore/luni/src/main/java/java/nio/channels/ |
| ServerSocketChannel.java | 32 * A server-socket channel is open but not bound when created by the {@code
50 * Creates an open and unbound server-socket channel.
52 * This channel is created by calling {@code openServerSocketChannel} method
55 * @return the new channel which is open but unbound.
64 * Gets the valid operations of this channel. Server-socket channels support
69 * @return the operations supported by this channel.
77 * Return the server-socket assigned this channel, which does not declare
80 * @return the server-socket assigned to this channel.
85 * Accepts a connection to this server-socket channel.
87 * This method returns {@code null} when this channel is non-blocking and n
[all...] |
| ScatteringByteChannel.java | 30 * Reads bytes from this channel into the specified array of buffers.
38 * if the channel is closed by another thread during this read
43 * thread is set and the channel is closed.
45 * if the channel is closed.
49 * if the channel has not been opened in a mode that permits
70 * if the channel is closed by another thread during this read
75 * thread is set and the channel is closed.
77 * if the channel is closed.
85 * if the channel has not been opened in a mode that permits
|
| /libcore/luni/src/main/java/java/nio/channels/spi/ |
| AbstractInterruptibleChannel.java | 22 import java.nio.channels.Channel;
30 * The basic usage pattern for an interruptible channel is to invoke
36 public abstract class AbstractInterruptibleChannel implements Channel, InterruptibleChannel {
60 * Closes an open channel. If the channel is already closed then this method
64 * If an attempt is made to perform an operation on a closed channel then a
67 * If multiple threads attempt to simultaneously close a channel, then only
72 * if a problem occurs while closing this channel.
73 * @see java.nio.channels.Channel#close()
103 * if this channel is closed by another thread while this metho
[all...] |
| /external/chromium_org/media/base/ |
| audio_buffer_unittest.cc | 75 VerifyResult(bus->channel(0), frames, 0.0f, 4.0f / 127.0f);
76 VerifyResult(bus->channel(1), frames, 1.0f / 127.0f, 4.0f / 127.0f);
77 VerifyResult(bus->channel(2), frames, 2.0f / 127.0f, 4.0f / 127.0f);
78 VerifyResult(bus->channel(3), frames, 3.0f / 127.0f, 4.0f / 127.0f);
94 VerifyResult(bus->channel(0), 6, 1.0f / kint16max, 2.0f / kint16max);
95 VerifyResult(bus->channel(1), 6, 2.0f / kint16max, 2.0f / kint16max);
102 VerifyResult(bus->channel(0), frames, 1.0f / kint16max, 2.0f / kint16max);
103 VerifyResult(bus->channel(1), frames, 2.0f / kint16max, 2.0f / kint16max);
119 VerifyResult(bus->channel(0), frames, 1.0f / kint32max, 2.0f / kint32max);
120 VerifyResult(bus->channel(1), frames, 2.0f / kint32max, 2.0f / kint32max)
[all...] |
| audio_hash_unittest.cc | 23 // Fill each channel in each bus with unique data.
33 // Since FakeAudioRenderCallback generates only a single channel of unique
34 // audio data, we need to fill each channel manually.
36 wrapped_bus->SetChannelData(0, audio_bus->channel(ch));
68 std::swap(bus_one_->channel(0)[0], bus_one_->channel(0)[1]);
76 // Ensure channel order matters to the hash.
81 // Reverse channel order for the same sample data.
86 swapped_ch_bus->SetChannelData(channels - (i + 1), bus_one_->channel(i));
137 half_bus->SetChannelData(i, bus_one_->channel(i) + half_frames)
149 float* channel = bus_one_->channel(0); local
[all...] |
| /external/chromium_org/third_party/mesa/src/src/gallium/auxiliary/util/ |
| u_format_parse.py | 52 class Channel:
53 '''Describe the channel of a color channel.'''
132 for channel in self.channels:
133 size += channel.size
138 for channel in self.channels:
139 if channel.size:
147 for channel in self.channels[1:]:
148 if channel.size and (channel.size != ref_channel.size or channel.size % 8)
[all...] |
| /external/mesa3d/src/gallium/auxiliary/util/ |
| u_format_parse.py | 52 class Channel:
53 '''Describe the channel of a color channel.'''
132 for channel in self.channels:
133 size += channel.size
138 for channel in self.channels:
139 if channel.size:
147 for channel in self.channels[1:]:
148 if channel.size and (channel.size != ref_channel.size or channel.size % 8)
[all...] |
| /external/arduino/hardware/arduino/cores/arduino/ |
| wiring_analog.c | 45 if (pin >= 54) pin -= 54; // allow for channel or pin numbers
47 if (pin >= 14) pin -= 14; // allow for channel or pin numbers
57 // channel (low 4 bits). this also sets ADLAR (left-adjust result)
63 // without a delay, we seem to read from the wrong channel
124 // connect pwm to pin on timer 0, channel A
132 // connect pwm to pin on timer 0, channel B
140 // connect pwm to pin on timer 1, channel A
148 // connect pwm to pin on timer 1, channel B
164 // connect pwm to pin on timer 2, channel A
172 // connect pwm to pin on timer 2, channel
[all...] |
| /external/antlr/antlr-3.4/runtime/JavaScript/src/org/antlr/runtime/ |
| CommonTokenStream.js | 2 * and tokens are prefiltered for a certain channel (the parser will only
3 * see these tokens and cannot change the filter channel number during the
8 org.antlr.runtime.CommonTokenStream = function(tokenSource, channel) {
10 this.channel = org.antlr.runtime.Token.DEFAULT_CHANNEL;
15 this.channel = channel;
30 this.channel = org.antlr.runtime.Token.DEFAULT_CHANNEL;
35 * set some token type / channel overrides before filling buffer.
46 // is there a channel override for token type?
58 t.getChannel()!=this.channel )
[all...] |
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| transportchannelproxy.cc | 74 ASSERT(impl_ != NULL); // should not be used until channel is writable
85 void TransportChannelProxy::OnReadableState(TransportChannel* channel) {
86 ASSERT(channel == impl_);
90 void TransportChannelProxy::OnWritableState(TransportChannel* channel) {
91 ASSERT(channel == impl_);
95 void TransportChannelProxy::OnReadPacket(TransportChannel* channel,
97 ASSERT(channel == impl_);
101 void TransportChannelProxy::OnRouteChange(TransportChannel* channel,
103 ASSERT(channel == impl_);
|
| /external/chromium_org/chrome/browser/extensions/api/messaging/ |
| message_service.h | 47 // - Another context calls "runtime.connect()" to open a channel to the
49 // open a channel to the content scripts for the given tab. The EMS notifies
52 // - Once the channel is established, either side can call postMessage to send
53 // a message to the opposite side of the channel, which may have multiple
57 // channel: connection between two ports
65 // A messaging channel. Note that the opening port can be the same as the
74 // Notify the port that the channel has been opened.
83 // Notify the port that the channel has been closed. If |error_message| is
120 // Given an extension's ID, opens a channel between the given renderer "port"
131 // Same as above, but opens a channel to the tab with the given ID. Message
[all...] |
| /external/chromium_org/components/variations/ |
| variations_seed_processor.h | 30 // specified configuration (locale, current date, version and channel).
35 Study_Channel channel,
67 // channel dev/canary. If so, forcing flag and variation id can both be set.
78 Study_Channel channel,
88 // Checks whether a study is applicable for the given |channel| per |filter|.
89 bool CheckStudyChannel(const Study_Filter& filter, Study_Channel channel);
119 // |reference_date| for the start date check and |channel| for channel
125 Study_Channel channel,
|
| /external/chromium_org/content/child/npapi/ |
| np_channel_base.cc | 64 const IPC::ChannelHandle& channel_handle, IPC::Channel::Mode mode,
75 scoped_refptr<NPChannelBase> channel; local
79 channel = factory();
81 channel = iter->second;
84 DCHECK(channel.get() != NULL);
86 if (!channel->channel_valid()) {
87 channel->channel_handle_ = channel_handle;
91 if (mode & IPC::Channel::MODE_SERVER_FLAG) {
92 channel->channel_handle_.name =
93 IPC::Channel::GenerateVerifiedChannelID(channel_key)
[all...] |
| /external/libnfc-nci/src/udrv/include/ |
| uamp_api.h | 45 #define UAMP_CH_HCI_CMD 0 /* HCI Command channel */
46 #define UAMP_CH_HCI_EVT 1 /* HCI Event channel */
47 #define UAMP_CH_HCI_DATA 2 /* HCI ACL Data channel */
52 tUAMP_CH channel; /* UAMP_EVT_RX_READY: channel for which rx occured */ member in union:__anon20934
126 ** channel: UAMP_CH_HCI_ACL, or UAMP_CH_HCI_CMD
131 BT_API UINT16 UAMP_Write(tUAMP_ID amp_id, UINT8 *p_buf, UINT16 num_bytes, tUAMP_CH channel);
157 ** channel: UAMP_CH_HCI_ACL, or UAMP_CH_HCI_EVT
162 BT_API UINT16 UAMP_Read(tUAMP_ID amp_id, UINT8 *p_buf, UINT16 buf_size, tUAMP_CH channel);
|
