| /external/perfetto/ui/src/trace_processor/ |
| D | http_rpc_engine.ts | 32 private websocket?: WebSocket;
45 if (this.websocket === undefined) {
48 this.websocket = new WebSocket(wsUrl);
49 this.websocket.onopen = () => this.onWebsocketConnected();
50 this.websocket.onmessage = (e) => this.onWebsocketMessage(e);
51 this.websocket.onclose = (e) => this.onWebsocketClosed(e);
52 this.websocket.onerror = (e) =>
59 this.websocket.send(data);
69 assertExists(this.websocket).send(queuedMsg);
80 this.websocket = undefined;
[all …]
|
| /external/pigweed/pw_docgen/py/pw_docgen/ |
| D | docserver.py | 163 async def _register_connection(self, websocket) -> None: argument
165 self._connections.add(websocket)
166 _LOG.info("Client connection established: %s", websocket.id)
175 self._drop_lost_connection(websocket),
183 async def _drop_lost_connection(self, websocket) -> None: argument
187 if websocket.closed:
188 self._connections.remove(websocket)
189 _LOG.info("Client connection dropped: %s", websocket.id)
192 _LOG.debug("Client connection heartbeat active: %s", websocket.id)
296 …async with websockets.connect(f"ws://{address}:{port}") as websocket: # type: ignore # pylint: di…
[all …]
|
| /external/perfetto/src/websocket_bridge/ |
| D | websocket_bridge.cc | 152 base::HttpServerConnection* websocket = GetWebsocket(sock); in OnDataAvailable() local
153 PERFETTO_CHECK(websocket); in OnDataAvailable()
158 websocket->SendWebsocketMessage(buf, static_cast<size_t>(rsize)); in OnDataAvailable()
162 websocket->Close(); in OnDataAvailable()
167 void WSBridge::OnHttpConnectionClosed(base::HttpServerConnection* websocket) { in OnHttpConnectionClosed() argument
169 auto it = conns_.find(websocket); in OnHttpConnectionClosed()
174 conns_.erase(websocket); in OnHttpConnectionClosed()
178 base::HttpServerConnection* websocket = GetWebsocket(sock); in OnDisconnect() local
179 if (!websocket) in OnDisconnect()
181 websocket->Close(); in OnDisconnect()
[all …]
|
| /external/nanohttpd/websocket/src/test/java/fi/iki/elonen/samples/echo/ |
| D | SimpleEchoSocket.java | 42 import org.eclipse.jetty.websocket.api.Session;
43 import org.eclipse.jetty.websocket.api.StatusCode;
44 import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
45 import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
46 import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
47 import org.eclipse.jetty.websocket.api.annotations.WebSocket;
|
| /external/python/bumble/bumble/transport/ |
| D | ws_client.py | 39 websocket = await websockets.client.connect(spec)
44 await websocket.close()
47 PumpedPacketSource(websocket.recv),
48 PumpedPacketSink(websocket.send),
|
| /external/python/bumble/bumble/ |
| D | link.py | 399 self.websocket = asyncio.get_running_loop().create_future()
428 await self.websocket
450 websocket = await websockets.connect(self.uri)
451 self.websocket.set_result(websocket)
455 message = await websocket.recv()
465 if self.websocket.done():
467 websocket = self.websocket.result()
468 asyncio.create_task(websocket.close())
552 websocket = await self.websocket
559 await websocket.send(command)
[all …]
|
| /external/cronet/stable/net/data/fuzzer_data/http_server_requests/ |
| D | websocket.bin | 5 Upgrade: websocket
6 sec-websocket-version: 13
7 sec-websocket-key: noncense
|
| /external/cronet/tot/net/data/fuzzer_data/http_server_requests/ |
| D | websocket.bin | 5 Upgrade: websocket
6 sec-websocket-version: 13
7 sec-websocket-key: noncense
|
| /external/python/bumble/apps/link_relay/ |
| D | link_relay.py | 68 def __init__(self, room, websocket): argument
70 self.websocket = websocket
76 return await self.websocket.send(message)
86 message = await self.websocket.recv()
231 async def serve(self, websocket, path): argument
239 return await self.serve_as_controller(Connection('', websocket))
248 connection = Connection(room, websocket)
|
| /external/curl/tests/http/testenv/ |
| D | ws_echo_server.py | 35 async def echo(websocket): argument
37 async for message in websocket:
38 await websocket.send(message)
|
| /external/rust/android-crates-io/crates/tungstenite/examples/ |
| D | server.rs | 28 let mut websocket = accept_hdr(stream.unwrap(), callback).unwrap(); in main() localVariable
31 let msg = websocket.read().unwrap(); in main()
33 websocket.send(msg).unwrap(); in main()
|
| D | srv_accept_unmasked_frames.rs | 38 let mut websocket = accept_hdr_with_config(stream.unwrap(), callback, config).unwrap(); in main() localVariable
41 let msg = websocket.read().unwrap(); in main()
|
| /external/python/bumble/examples/ |
| D | run_hfp_handsfree.py | 146 async def serve(websocket: websockets.WebSocketServerProtocol, _path):
148 ws = websocket
149 async for message in websocket:
163 await websocket.send(response)
167 await websocket.send(response)
|
| D | run_vcp_renderer.py | 165 async def serve(websocket: websockets.WebSocketServerProtocol, _path):
167 await websocket.send(
170 ws = websocket
171 async for message in websocket:
|
| D | run_mcp_client.py | 176 async def serve(websocket: websockets.WebSocketServerProtocol, _path):
178 ws = websocket
179 async for message in websocket:
|
| /external/cronet/tot/net/data/fuzzer_dictionaries/ |
| D | net_http_server_fuzzer.dict | 42 "Connection: upgrade\x0D\x0Asec-websocket-version: 13\x0D\x0Asec-websocket-key: abcd"
44 "sec-websocket-extensions: permessage-deflate"
|
| /external/cronet/stable/net/data/fuzzer_dictionaries/ |
| D | net_http_server_fuzzer.dict | 42 "Connection: upgrade\x0D\x0Asec-websocket-version: 13\x0D\x0Asec-websocket-key: abcd"
44 "sec-websocket-extensions: permessage-deflate"
|
| /external/curl/tests/data/ |
| D | test2304 | 14 Upgrade: websocket
56 User-Agent: websocket/2304
58 Upgrade: websocket
|
| D | test2300 | 14 Upgrade: websocket
52 Upgrade: websocket
|
| D | test2301 | 14 Upgrade: websocket
57 Upgrade: websocket
|
| D | test2307 | 14 Upgrade: websocket
58 Upgrade: websocket
|
| D | test2302 | 14 Upgrade: websocket
58 Upgrade: websocket
|
| D | test2310 | 14 Upgrade: websocket
57 Upgrade: websocket
|
| /external/curl/tests/libtest/ |
| D | lib2305.c | 41 static void websocket(CURL *curl) in websocket() function
98 websocket(curl); in test()
|
| /external/curl/docs/examples/ |
| D | websocket.c | 94 static void websocket(CURL *curl) in websocket() function
128 websocket(curl); in main()
|