(
self,
host="0.0.0.0",
port=9091,
port_end=9199,
is_proxy=False,
tracker_addr=None,
key="",
load_library=None,
custom_addr=None,
silent=False,
no_fork=False,
server_init_callback=None,
reuse_addr=True,
timeout=None,
)
| 502 | """ |
| 503 | |
| 504 | def __init__( |
| 505 | self, |
| 506 | host="0.0.0.0", |
| 507 | port=9091, |
| 508 | port_end=9199, |
| 509 | is_proxy=False, |
| 510 | tracker_addr=None, |
| 511 | key="", |
| 512 | load_library=None, |
| 513 | custom_addr=None, |
| 514 | silent=False, |
| 515 | no_fork=False, |
| 516 | server_init_callback=None, |
| 517 | reuse_addr=True, |
| 518 | timeout=None, |
| 519 | ): |
| 520 | try: |
| 521 | if _ffi_api.ServerLoop is None: |
| 522 | raise RuntimeError("Please compile with USE_RPC=1") |
| 523 | except NameError: |
| 524 | raise RuntimeError("Please compile with USE_RPC=1") |
| 525 | self.proc = PopenWorker() |
| 526 | # send the function |
| 527 | self.proc.send( |
| 528 | _popen_start_rpc_server, |
| 529 | [ |
| 530 | host, |
| 531 | port, |
| 532 | port_end, |
| 533 | is_proxy, |
| 534 | tracker_addr, |
| 535 | key, |
| 536 | load_library, |
| 537 | custom_addr, |
| 538 | silent, |
| 539 | no_fork, |
| 540 | server_init_callback, |
| 541 | reuse_addr, |
| 542 | timeout, |
| 543 | ], |
| 544 | ) |
| 545 | # receive the port |
| 546 | self.port = self.proc.recv() |
| 547 | self.host = host |
| 548 | |
| 549 | def terminate(self): |
| 550 | """Terminate the server process""" |
nothing calls this directly
no test coverage detected