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
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:p:")
20 conf = readconfig(opts["c"] if "c" in opts else CONF)
22 if sys.stdout.isatty():
23 log.addHandler(StreamHandler(sys.stderr))
26 log.addHandler(SysLogHandler(address="/dev/log"))
29 initdb(conf.get("daemon", "dbfn"))
31 ctlsock = socket(AF_INET, SOCK_STREAM)
32 ctlsock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
33 ctlsock.bind(("", conf.getint("daemon", "port")))
35 ctlfd = ctlsock.fileno()
37 pollset.register(ctlfd, POLLIN | POLLERR | POLLHUP | POLLPRI)
41 events = pollset.poll(1000)
42 except KeyboardInterrupt:
48 clntsock, clntaddr = ctlsock.accept()
49 clntfd = clntsock.fileno()
50 clnt_dict[clntfd] = (clntsock, clntaddr, None)
52 clntfd, POLLIN | POLLERR | POLLHUP | POLLPRI
55 "accepted connection from %s as fd %d",
60 log.debug("unexpected event on ctlfd: %s", ev)
63 clntsock, clntaddr, imei = clnt_dict[fd]
64 except KeyError: # this socket closed already
67 packet = clntsock.recv(4096)
70 msg = handle_packet(packet, clntaddr, when)
71 log.debug("%s from %s fd %d'", msg, clntaddr, fd)
72 if isinstance(msg, LOGIN):
74 clnt_dict[fd] = (clntsock, clntaddr, imei)
75 stow(clntaddr, when, imei, msg.proto, msg.payload)
76 response = make_response(msg)
79 # Ignore possibility of blocking
80 clntsock.send(make_response(msg))
82 log.debug("sending to fd %d error %s", fd, e)
84 log.info("disconnect fd %d imei %s", fd, imei)
85 pollset.unregister(fd)
89 log.warning("unexpected event", ev, "on fd", fd)