(self, url, max_messagesize=0, max_chunkcount=0)
| 178 | self.logger.info("Done closing socket: Receiving thread terminated, socket disconnected") |
| 179 | |
| 180 | def send_hello(self, url, max_messagesize=0, max_chunkcount=0): |
| 181 | hello = ua.Hello() |
| 182 | hello.EndpointUrl = url |
| 183 | hello.MaxMessageSize = max_messagesize |
| 184 | hello.MaxChunkCount = max_chunkcount |
| 185 | future = Future() |
| 186 | with self._lock: |
| 187 | self._callbackmap[0] = future |
| 188 | binmsg = uatcp_to_binary(ua.MessageType.Hello, hello) |
| 189 | self._socket.write(binmsg) |
| 190 | ack = future.result(self.timeout) |
| 191 | return ack |
| 192 | |
| 193 | def open_secure_channel(self, params): |
| 194 | self.logger.info("open_secure_channel") |
nothing calls this directly
no test coverage detected