| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
| mux_client_for_testing.py | 99 channel_id = ord(data[offset])
101 if channel_id & 0xe0 == 0xe0:
104 channel_id = struct.unpack('!L',
107 elif channel_id & 0xc0 == 0xc0:
110 channel_id = (((channel_id & 0x1f) << 16) +
113 elif channel_id & 0x80 == 0x80:
116 channel_id = struct.unpack('!H', data[offset:offset+2])[0] & 0x3fff
119 return channel_id, channel_id_length
167 channel_id, advance = _parse_channel_id(data, pos
[all...] |
| test_mux.py | 110 channel_id = parser.read_channel_id()
111 if channel_id == mux._CONTROL_CHANNEL_ID:
115 if not channel_id in self._channel_data:
116 self._channel_data[channel_id] = _OutgoingChannelData()
117 channel_data = self._channel_data[channel_id]
148 def get_written_messages(self, channel_id):
149 return self._channel_data[channel_id].messages
151 def get_written_control_messages(self, channel_id):
152 return self._channel_data[channel_id].control_messages
189 self.channel_events[request.channel_id] = _ChannelEvent(
[all...] |
| /external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/ |
| mux.py | 109 def _encode_channel_id(channel_id):
110 if channel_id < 0:
111 raise ValueError('Channel id %d must not be negative' % channel_id)
113 if channel_id < 2 ** 7:
114 return chr(channel_id)
115 if channel_id < 2 ** 14:
116 return struct.pack('!H', 0x8000 + channel_id)
117 if channel_id < 2 ** 21:
118 first = chr(0xc0 + (channel_id >> 16))
119 return first + struct.pack('!H', channel_id & 0xffff
[all...] |
| /external/chromium/chrome/browser/nacl_host/ |
| nacl_broker_service_win.h | 31 void OnLoaderLaunched(const std::wstring& channel_id,
|
| nacl_broker_service_win.cc | 42 void NaClBrokerService::OnLoaderLaunched(const std::wstring& channel_id,
45 PendingLaunchesMap::iterator it = pending_launches_.find(channel_id);
|
| nacl_broker_host_win.cc | 42 cmd_line->AppendSwitchASCII(switches::kProcessChannelID, channel_id());
|
| nacl_process_host.cc | 148 cmd_line->AppendSwitchASCII(switches::kProcessChannelID, channel_id());
156 this, ASCIIToWide(channel_id()));
|
| /hardware/libhardware/include/hardware/ |
| bt_hl.h | 81 typedef void (* bthl_channel_state_callback)(int app_id, bt_bdaddr_t *bd_addr, int mdep_cfg_index, int channel_id, bthl_channel_state_t state, int fd);
110 bt_status_t (*connect_channel)(int app_id, bt_bdaddr_t *bd_addr, int mdep_cfg_index, int *channel_id);
113 bt_status_t (*destroy_channel)(int channel_id);
|
| /external/chromium/chrome/browser/extensions/ |
| extension_message_service.cc | 27 #define GET_CHANNEL_OPENER_ID(channel_id) ((channel_id) * 2)
28 #define GET_CHANNEL_RECEIVERS_ID(channel_id) ((channel_id) * 2 + 1)
100 int channel_id = g_next_channel_id.GetNext(); local
101 int port1_id = channel_id * 2;
102 int port2_id = channel_id * 2 + 1;
109 DCHECK(GET_CHANNEL_ID(port1_id) == channel_id);
110 DCHECK(GET_CHANNEL_OPENER_ID(channel_id) == port1_id);
111 DCHECK(GET_CHANNEL_RECEIVERS_ID(channel_id) == port2_id)
[all...] |
| /external/bluetooth/bluedroid/btif/include/ |
| btif_hl.h | 125 int channel_id; member in struct:__anon2905
178 int channel_id; member in struct:__anon2909
183 int channel_id; member in struct:__anon2910
219 int channel_id; member in struct:__anon2912
270 int channel_id; member in struct:__anon2916
|
| /external/bluetooth/bluedroid/btif/src/ |
| btif_hl.c | 182 BOOLEAN btif_hl_if_channel_setup_pending(int channel_id, UINT8 *p_app_idx, UINT8 *p_mcl_idx)
197 p_mcb->is_connected && p_mcb->pcb.channel_id == channel_id )
209 BTIF_TRACE_DEBUG5("%s found=%d channel_id=0x%08x",
210 __FUNCTION__, found, channel_id, *p_app_idx, *p_mcl_idx);
759 btif_hl_pend_dch_op_t op, int *channel_id){
785 *channel_id =
786 p_pcb->channel_id = (int) btif_hl_get_next_channel_id(app_id);
895 btif_hl_pend_dch_op_t op, int *channel_id){
940 *channel_id
1650 int channel_id; local
[all...] |
| btif_media_task.c | [all...] |
| /external/qemu/android/ |
| hw-qemud.h | 93 int channel_id,
|
| hw-qemud.c | 891 * NOTE: channel_id valie is used as a selector between serial and pipe clients.
892 * Since channel_id < 0 is an invalid value for a serial client, it would
895 qemud_client_alloc( int channel_id,
909 if (channel_id < 0) {
918 c->ProtocolSelector.Serial.channel = channel_id;
944 int channel_id,
1469 int channel_id = hex2int(msg+11, 2); local
[all...] |
| /packages/apps/Bluetooth/jni/ |
| com_android_bluetooth_hdp.cpp | 63 int channel_id, bthl_channel_state_t state, int fd) {
87 mdep_cfg_index, channel_id, (jint) state, fileDescriptor);
257 static jboolean disconnectChannelNative(JNIEnv *env, jobject object, jint channel_id) {
261 if ( (status = sBluetoothHdpInterface->destroy_channel(channel_id)) !=
|
| /external/chromium/chrome/browser/importer/ |
| profile_import_process_host.cc | 94 cmd_line->AppendSwitchASCII(switches::kProcessChannelID, channel_id());
|
| /external/chromium/chrome/browser/ui/ |
| browser_init.h | 56 static bool CreateAutomationProvider(const std::string& channel_id,
|
| browser_init.cc | [all...] |
| /external/chromium/chrome/browser/ |
| utility_process_host.cc | 140 cmd_line->AppendSwitchASCII(switches::kProcessChannelID, channel_id());
|
| /external/chromium/chrome/browser/service/ |
| service_process_control.cc | 50 const IPC::ChannelHandle channel_id = GetServiceProcessChannel(); local
52 new IPC::SyncChannel(channel_id, IPC::Channel::MODE_NAMED_CLIENT, this,
|
| /external/chromium/chrome/browser/automation/ |
| automation_provider.cc | 141 bool AutomationProvider::InitializeChannel(const std::string& channel_id) {
144 channel_id_ = channel_id;
145 std::string effective_channel_id = channel_id;
147 // If the channel_id starts with kNamedInterfacePrefix, create a named IPC
150 channel_id.find(automation::kNamedInterfacePrefix) == 0;
152 effective_channel_id = channel_id.substr(
[all...] |
| automation_provider.h | 92 // If channel_id starts with kNamedInterfacePrefix, it will act
93 // as a server, create a named IPC socket with channel_id as its
95 // If channel_id does not, it will act as a client and establish
98 bool InitializeChannel(const std::string& channel_id) WARN_UNUSED_RESULT;
|
| /external/openssh/ |
| serverloop.c | 250 int channel_id; local
262 if ((channel_id = channel_find_open()) == -1) {
267 channel_request_start(channel_id, "keepalive@openssh.com", 1);
[all...] |
| /external/openssl/ssl/ |
| s3_srvr.c | 682 char channel_id = 0; local
687 channel_id = s->s3->tlsext_channel_id_valid;
692 else if (channel_id)
[all...] |
| /external/openssl/include/openssl/ |
| ssl.h | [all...] |
