1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
#!/usr/bin/env python
"""
SWIG generation server. Listens for connections from swig generation clients
and runs swig in the requested fashion, sending back the results.
"""
# Future imports
from __future__ import absolute_import
from __future__ import print_function
# Python modules
import argparse
import logging
import os
import socket
import struct
import sys
import traceback
# LLDB modules
import use_lldb_suite
from lldbsuite.support import sockutil
# package imports
from . import local
default_port = 8537
def process_args(args):
# Setup the parser arguments that are accepted.
parser = argparse.ArgumentParser(description='SWIG generation server.')
parser.add_argument(
"--port",
action="store",
default=default_port,
help=("The local port to bind to"))
# Process args.
return parser.parse_args(args)
def initialize_listening_socket(options):
logging.debug("Creating socket...")
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
logging.info("Binding to ip address '', port {}".format(options.port))
s.bind(('', options.port))
logging.debug("Putting socket in listen mode...")
s.listen()
return s
def accept_once(sock, options):
logging.debug("Waiting for connection...")
client, addr = sock.accept()
logging.info("Received connection from {}".format(addr))
data_size = struct.unpack("!I", sockutil.recvall(client, 4))[0]
logging.debug("Expecting {} bytes of data from client".format(data_size))
data = sockutil.recvall(client, data_size)
logging.info("Received {} bytes of data from client".format(len(data)))
logging.info("Sending {} byte response".format(len(data)))
client.sendall(struct.pack("!I", len(data)))
client.sendall(data)
def accept_loop(sock, options):
while True:
try:
accept_once(sock, options)
except Exception as e:
error = traceback.format_exc()
logging.error("An error occurred while processing the connection.")
logging.error(error)
def run(args):
options = process_args(args)
sock = initialize_listening_socket(options)
accept_loop(sock, options)
return options
|
