(cls, address, authkey)
| 3531 | |
| 3532 | @classmethod |
| 3533 | def _putter(cls, address, authkey): |
| 3534 | manager = QueueManager2( |
| 3535 | address=address, authkey=authkey, serializer=SERIALIZER, |
| 3536 | shutdown_timeout=SHUTDOWN_TIMEOUT) |
| 3537 | manager.connect() |
| 3538 | queue = manager.get_queue() |
| 3539 | # Note that xmlrpclib will deserialize object as a list not a tuple |
| 3540 | queue.put(tuple(cls.values)) |
| 3541 | |
| 3542 | @warnings_helper.ignore_fork_in_thread_deprecation_warnings() |
| 3543 | @support.skip_if_sanitizer('TSan: leaks threads', thread=True) |
nothing calls this directly
no test coverage detected