Start RPC proxy server on a separate process. Python implementation based on PopenWorker. Parameters ---------- host : str The host url of the server. port : int The TCP port to be bind to port_end : int, optional The end TCP port to search we
| 583 | |
| 584 | |
| 585 | class Proxy: |
| 586 | """Start RPC proxy server on a separate process. |
| 587 | |
| 588 | Python implementation based on PopenWorker. |
| 589 | |
| 590 | Parameters |
| 591 | ---------- |
| 592 | host : str |
| 593 | The host url of the server. |
| 594 | |
| 595 | port : int |
| 596 | The TCP port to be bind to |
| 597 | |
| 598 | port_end : int, optional |
| 599 | The end TCP port to search |
| 600 | |
| 601 | web_port : int, optional |
| 602 | The http/websocket port of the server. |
| 603 | |
| 604 | timeout_client : float, optional |
| 605 | Timeout of client until it sees a matching connection. |
| 606 | |
| 607 | timeout_server : float, optional |
| 608 | Timeout of server until it sees a matching connection. |
| 609 | |
| 610 | tracker_addr: Tuple (str, int) , optional |
| 611 | The address of RPC Tracker in tuple (host, ip) format. |
| 612 | If is not None, the server will register itself to the tracker. |
| 613 | |
| 614 | index_page : str, optional |
| 615 | Path to an index page that can be used to display at proxy index. |
| 616 | |
| 617 | resource_files : str, optional |
| 618 | Path to local resources that can be included in the http request |
| 619 | """ |
| 620 | |
| 621 | def __init__( |
| 622 | self, |
| 623 | host, |
| 624 | port=9091, |
| 625 | port_end=9199, |
| 626 | web_port=0, |
| 627 | timeout_client=600, |
| 628 | timeout_server=600, |
| 629 | tracker_addr=None, |
| 630 | index_page=None, |
| 631 | resource_files=None, |
| 632 | ): |
| 633 | self.proc = PopenWorker() |
| 634 | # send the function |
| 635 | self.proc.send( |
| 636 | _popen_start_proxy_server, |
| 637 | [ |
| 638 | host, |
| 639 | port, |
| 640 | port_end, |
| 641 | web_port, |
| 642 | timeout_client, |
no outgoing calls
searching dependent graphs…