]>
cvs.zerfleddert.de Git - hmcfgusb/blob - hmland.c
1 /* HM-CFG-LAN emulation for HM-CFG-USB
3 * Copyright (c) 2013 Michael Gernoth <michael@gernoth.net>
5 * Permission is hereby granted, free of charge, to any person obtaining a copy
6 * of this software and associated documentation files (the "Software"), to
7 * deal in the Software without restriction, including without limitation the
8 * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
9 * sell copies of the Software, and to permit persons to whom the Software is
10 * furnished to do so, subject to the following conditions:
12 * The above copyright notice and this permission notice shall be included in
13 * all copies or substantial portions of the Software.
15 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
18 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
20 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
33 #include <sys/types.h>
34 #include <sys/socket.h>
37 #include <netinet/in.h>
38 #include <arpa/inet.h>
39 #include <libusb-1.0/libusb.h>
44 #define PID_FILE "/var/run/hmland.pid"
48 static int impersonate_hmlanif
= 0;
50 static int verbose
= 0;
52 #define FLAG_LENGTH_BYTE (1<<0)
53 #define FLAG_FORMAT_HEX (1<<1)
54 #define FLAG_COMMA_BEFORE (1<<2)
55 #define FLAG_COMMA_AFTER (1<<3)
56 #define FLAG_NL (1<<4)
57 #define FLAG_IGNORE_COMMAS (1<<5)
59 #define CHECK_SPACE(x) if ((*outpos + x) > outend) { fprintf(stderr, "Not enough space!\n"); return 0; }
60 #define CHECK_AVAIL(x) if ((*inpos + x) > inend) { fprintf(stderr, "Not enough input available!\n"); return 0; }
62 static int format_part_out(uint8_t **inpos
, int inlen
, uint8_t **outpos
, int outlen
, int len
, int flags
)
64 const uint8_t nibble
[16] = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9',
65 'A', 'B', 'C', 'D', 'E', 'F'};
66 uint8_t *buf_out
= *outpos
;
67 uint8_t *outend
= *outpos
+ outlen
;
68 uint8_t *inend
= *inpos
+ inlen
;
71 if (flags
& FLAG_COMMA_BEFORE
) {
77 if (flags
& FLAG_LENGTH_BYTE
) {
83 if (flags
& FLAG_FORMAT_HEX
) {
86 for (i
= 0; i
< len
; i
++) {
87 **outpos
= nibble
[((**inpos
) & 0xf0) >> 4];
89 **outpos
= nibble
[((**inpos
) & 0xf)];
90 *inpos
+= 1; *outpos
+= 1;
95 memcpy(*outpos
, *inpos
, len
);
100 if (flags
& FLAG_COMMA_AFTER
) {
106 if (flags
& FLAG_NL
) {
114 return *outpos
- buf_out
;
117 static uint8_t ascii_to_nibble(uint8_t a
)
121 if ((a
>= '0') && (a
<= '9')) {
123 } else if ((a
>= 'A') && (a
<= 'F')) {
125 } else if ((a
>= 'a') && (a
<= 'f')) {
132 static int parse_part_in(uint8_t **inpos
, int inlen
, uint8_t **outpos
, int outlen
, int flags
)
134 uint8_t *buf_out
= *outpos
;
135 uint8_t *outend
= *outpos
+ outlen
;
136 uint8_t *inend
= *inpos
+ inlen
;
138 if (flags
& FLAG_LENGTH_BYTE
) {
146 if (!(flags
& FLAG_IGNORE_COMMAS
))
155 **outpos
= (len
/ 2);
159 while(*inpos
< inend
) {
160 if (**inpos
== ',') {
162 if (!(flags
& FLAG_IGNORE_COMMAS
))
171 **outpos
= ascii_to_nibble(**inpos
) << 4;
173 **outpos
|= ascii_to_nibble(**inpos
);
174 *inpos
+= 1; *outpos
+= 1;
177 return *outpos
- buf_out
;
180 static int hmlan_format_out(uint8_t *buf
, int buf_len
, void *data
)
185 int fd
= *((int*)data
);
191 memset(out
, 0, sizeof(out
));
195 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 1, 0);
198 if (impersonate_hmlanif
) {
203 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 0, FLAG_LENGTH_BYTE
);
204 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 2, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
205 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 0, FLAG_COMMA_BEFORE
| FLAG_LENGTH_BYTE
);
206 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 3, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
207 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 3, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
208 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 4, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
209 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 2, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
| FLAG_NL
);
213 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 3, FLAG_FORMAT_HEX
);
214 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 2, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
215 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 4, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
216 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 1, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
217 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 2, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
218 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 0, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
| FLAG_LENGTH_BYTE
| FLAG_NL
);
222 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 4, FLAG_FORMAT_HEX
);
223 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 2, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
224 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 4, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
225 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 1, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
226 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 2, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
227 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 0, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
| FLAG_LENGTH_BYTE
| FLAG_NL
);
231 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 1, FLAG_FORMAT_HEX
);
232 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 1, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
233 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 1, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
);
234 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 1, FLAG_FORMAT_HEX
| FLAG_COMMA_BEFORE
| FLAG_NL
);
238 format_part_out(&inpos
, (buf_len
-(inpos
-buf
)), &outpos
, (sizeof(out
)-(outpos
-out
)), buf_len
-1, FLAG_FORMAT_HEX
| FLAG_NL
);
239 hexdump(buf
, buf_len
, "Unknown> ");
243 fprintf(stderr
, "LAN < %s\n", out
);
245 w
= write(fd
, out
, outpos
-out
);
254 static int hmlan_parse_in(int fd
, void *data
)
256 struct hmcfgusb_dev
*dev
= data
;
258 uint8_t out
[0x40]; //FIXME!!!
265 memset(buf
, 0, sizeof(buf
));
267 r
= read(fd
, buf
, sizeof(buf
)-1);
269 uint8_t *inend
= buf
+ r
;
274 fprintf(stderr
, "\nLAN > %s", buf
);
276 while (inpos
< inend
) {
277 uint8_t *instart
= inpos
;
279 if ((*inpos
== '\r') || (*inpos
== '\n')) {
286 last
= inend
- inpos
;
288 for (i
= 0; i
< last
; i
++) {
289 if ((inpos
[i
] == '\r') || (inpos
[i
] == '\n')) {
298 memset(out
, 0, sizeof(out
));
299 *outpos
++ = *inpos
++;
303 parse_part_in(&inpos
, (last
-(inpos
-instart
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 0);
304 parse_part_in(&inpos
, (last
-(inpos
-instart
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 0);
305 parse_part_in(&inpos
, (last
-(inpos
-instart
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 0);
306 parse_part_in(&inpos
, (last
-(inpos
-instart
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 0);
307 parse_part_in(&inpos
, (last
-(inpos
-instart
)), &outpos
, (sizeof(out
)-(outpos
-out
)), 0);
308 parse_part_in(&inpos
, (last
-(inpos
-instart
)), &outpos
, (sizeof(out
)-(outpos
-out
)), FLAG_LENGTH_BYTE
);
311 parse_part_in(&inpos
, (last
-(inpos
-instart
)), &outpos
, (sizeof(out
)-(outpos
-out
)), FLAG_IGNORE_COMMAS
);
315 hmcfgusb_send(dev
, out
, sizeof(out
), 1);
327 static int comm(int fd_in
, int fd_out
, int master_socket
)
329 struct hmcfgusb_dev
*dev
;
332 hmcfgusb_set_debug(debug
);
334 dev
= hmcfgusb_init(hmlan_format_out
, &fd_out
);
336 fprintf(stderr
, "Can't initialize HM-CFG-USB!\n");
340 if (!hmcfgusb_add_pfd(dev
, fd_in
, POLLIN
)) {
341 fprintf(stderr
, "Can't add client to pollfd!\n");
346 if (master_socket
>= 0) {
347 if (!hmcfgusb_add_pfd(dev
, master_socket
, POLLIN
)) {
348 fprintf(stderr
, "Can't add master_socket to pollfd!\n");
354 hmcfgusb_send(dev
, (unsigned char*)"K", 1, 1);
359 fd
= hmcfgusb_poll(dev
, 3600);
361 if (fd
== master_socket
) {
364 client
= accept(master_socket
, NULL
, 0);
366 shutdown(client
, SHUT_RDWR
);
370 if (hmlan_parse_in(fd
, dev
) <= 0) {
374 } else if (fd
== -1) {
376 perror("hmcfgusb_poll");
386 void sigterm_handler(int sig
)
388 if (unlink(PID_FILE
) == -1)
389 perror("Can't remove PID file");
394 #define FLAG_DAEMON (1 << 0)
395 #define FLAG_PID_FILE (1 << 1)
397 static int socket_server(char *iface
, int port
, int flags
)
399 struct sigaction sact
;
400 struct sockaddr_in sin
;
405 if (flags
& FLAG_DAEMON
) {
406 FILE *pidfile
= NULL
;
408 if (flags
& FLAG_PID_FILE
) {
411 fd
= open(PID_FILE
, O_CREAT
| O_EXCL
| O_WRONLY
, 0644);
413 if (errno
== EEXIST
) {
415 pidfile
= fopen(PID_FILE
, "r");
417 perror("PID file " PID_FILE
" already exists, already running?");
421 if (fscanf(pidfile
, "%u", &old_pid
) != 1) {
423 fprintf(stderr
, "Can't read old PID from " PID_FILE
", already running?\n");
429 fprintf(stderr
, "Already running with PID %u according to " PID_FILE
"!\n", old_pid
);
432 perror("Can't create PID file " PID_FILE
);
436 pidfile
= fdopen(fd
, "w");
438 perror("Can't reopen PID file fd");
442 memset(&sact
, 0, sizeof(sact
));
443 sact
.sa_handler
= sigterm_handler
;
445 if (sigaction(SIGTERM
, &sact
, NULL
) == -1) {
446 perror("sigaction(SIGTERM)");
454 fprintf(pidfile
, "%u\n", pid
);
458 printf("Daemon with PID %u started!\n", pid
);
460 } else if (pid
< 0) {
469 memset(&sact
, 0, sizeof(sact
));
470 sact
.sa_handler
= SIG_IGN
;
472 if (sigaction(SIGPIPE
, &sact
, NULL
) == -1) {
473 perror("sigaction(SIGPIPE)");
477 impersonate_hmlanif
= 1;
479 sock
= socket(PF_INET
, SOCK_STREAM
, IPPROTO_TCP
);
481 perror("Can't open socket");
486 if (setsockopt(sock
, SOL_SOCKET
, SO_REUSEADDR
, &n
, sizeof(n
)) == -1) {
487 perror("Can't set socket options");
491 memset(&sin
, 0, sizeof(sin
));
492 sin
.sin_family
= AF_INET
;
493 sin
.sin_port
= htons(port
);
495 sin
.sin_addr
.s_addr
= htonl(INADDR_ANY
);
497 if (inet_pton(AF_INET
, iface
, &(sin
.sin_addr
.s_addr
)) != 1) {
503 if (bind(sock
, (struct sockaddr
*)&sin
, sizeof(sin
)) == -1) {
504 perror("Can't bind socket");
508 if (listen(sock
, 1) == -1) {
509 perror("Can't listen on socket");
514 struct sockaddr_in csin
;
517 in_addr_t client_addr
;
519 memset(&csin
, 0, sizeof(csin
));
520 csinlen
= sizeof(csin
);
521 client
= accept(sock
, (struct sockaddr
*)&csin
, &csinlen
);
523 perror("Couldn't accept client");
527 /* FIXME: getnameinfo... */
528 client_addr
= ntohl(csin
.sin_addr
.s_addr
);
531 printf("Client %d.%d.%d.%d connected!\n",
532 (client_addr
& 0xff000000) >> 24,
533 (client_addr
& 0x00ff0000) >> 16,
534 (client_addr
& 0x0000ff00) >> 8,
535 (client_addr
& 0x000000ff));
538 comm(client
, client
, sock
);
540 shutdown(client
, SHUT_RDWR
);
544 printf("Connection to %d.%d.%d.%d closed!\n",
545 (client_addr
& 0xff000000) >> 24,
546 (client_addr
& 0x00ff0000) >> 16,
547 (client_addr
& 0x0000ff00) >> 8,
548 (client_addr
& 0x000000ff));
556 static int interactive_server(void)
558 if (!comm(STDIN_FILENO
, STDOUT_FILENO
, -1))
564 void hmlan_syntax(char *prog
)
566 fprintf(stderr
, "Syntax: %s options\n\n", prog
);
567 fprintf(stderr
, "Possible options:\n");
568 fprintf(stderr
, "\t-D\tdebug mode\n");
569 fprintf(stderr
, "\t-d\tdaemon mode\n");
570 fprintf(stderr
, "\t-h\tthis help\n");
571 fprintf(stderr
, "\t-i\tinteractive mode (connect HM-CFG-USB to terminal)\n");
572 fprintf(stderr
, "\t-l ip\tlisten on given IP address only (for example 127.0.0.1)\n");
573 fprintf(stderr
, "\t-P\tcreate PID file " PID_FILE
" in daemon mode\n");
574 fprintf(stderr
, "\t-p n\tlisten on port n (default 1000)\n");
575 fprintf(stderr
, "\t-v\tverbose mode\n");
579 int main(int argc
, char **argv
)
588 while((opt
= getopt(argc
, argv
, "DdhiPp:l:v")) != -1) {
595 flags
|= FLAG_DAEMON
;
601 flags
|= FLAG_PID_FILE
;
604 port
= strtoul(optarg
, &ep
, 10);
606 fprintf(stderr
, "Can't parse port!\n");
620 hmlan_syntax(argv
[0]);
627 return interactive_server();
629 return socket_server(iface
, port
, flags
);