(self)
| 327 | ' of PyWebIO.\nData content: %s', e, msg) |
| 328 | |
| 329 | def open(self): |
| 330 | if SingleSessionWSHandler.session is None: |
| 331 | SingleSessionWSHandler.instance = self |
| 332 | session_info = get_session_info_from_headers(self.request.headers) |
| 333 | session_info['user_ip'] = self.request.remote_ip |
| 334 | session_info['request'] = self.request |
| 335 | session_info['backend'] = 'tornado' |
| 336 | session_info['protocol'] = 'websocket' |
| 337 | self.session = SingleSessionWSHandler.session = ScriptModeSession( |
| 338 | thread, session_info=session_info, |
| 339 | on_task_command=self.send_msg_to_client, |
| 340 | loop=asyncio.get_event_loop()) |
| 341 | websocket_conn_opened.set() |
| 342 | else: |
| 343 | self.close() |
| 344 | |
| 345 | def on_message(self, data): |
| 346 | if isinstance(data, bytes): |
nothing calls this directly
no test coverage detected