1 from getopt import getopt
2 from logging import getLogger, StreamHandler, DEBUG, INFO
3 from logging.handlers import SysLogHandler
4 from select import poll, POLLIN, POLLERR, POLLHUP, POLLPRI
5 from socket import socket, AF_INET, SOCK_STREAM, SOL_SOCKET, SO_REUSEADDR
9 from .config import readconfig
10 from .GT06mod import handle_packet, make_response, LOGIN, set_config
11 from .evstore import initdb, stow
13 CONF = "/etc/gps303.conf"
15 log = getLogger("gps303")
17 if __name__.endswith("__main__"):
18 opts, _ = getopt(sys.argv[1:], "c:d")
20 conf = readconfig(opts["-c"] if "-c" in opts else CONF)
22 if sys.stdout.isatty():
23 log.addHandler(StreamHandler(sys.stderr))
25 log.addHandler(SysLogHandler(address="/dev/log"))
26 log.setLevel(DEBUG if "-d" in opts else INFO)
27 log.info("starting with options: %s", opts)
29 initdb(conf.get("daemon", "dbfn"))
32 ctlsock = socket(AF_INET, SOCK_STREAM)
33 ctlsock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
34 ctlsock.bind(("", conf.getint("daemon", "port")))
36 ctlfd = ctlsock.fileno()
38 pollset.register(ctlfd, POLLIN | POLLERR | POLLHUP | POLLPRI)
42 events = pollset.poll(1000)
43 except KeyboardInterrupt:
49 clntsock, clntaddr = ctlsock.accept()
50 clntfd = clntsock.fileno()
51 clnt_dict[clntfd] = (clntsock, clntaddr, None)
53 clntfd, POLLIN | POLLERR | POLLHUP | POLLPRI
56 "accepted connection from %s as fd %d",
61 log.debug("unexpected event on ctlfd: %s", ev)
64 clntsock, clntaddr, imei = clnt_dict[fd]
65 except KeyError: # this socket closed already
68 packet = clntsock.recv(4096)
71 msg = handle_packet(packet, clntaddr, when)
72 log.debug("%s from %s fd %d", msg, clntaddr, fd)
73 if isinstance(msg, LOGIN):
75 clnt_dict[fd] = (clntsock, clntaddr, imei)
84 response = make_response(msg)
87 # Ignore possibility of blocking
88 clntsock.send(make_response(msg))
90 log.debug("sending to fd %d error %s", fd, e)
92 # TODO: Also disconnect on HIBERNATION
93 log.info("disconnect fd %d imei %s", fd, imei)
94 pollset.unregister(fd)
98 log.warning("unexpected event", ev, "on fd", fd)