1/* a simple test program, connects to ADB server, and opens a track-devices session */
2#include <netdb.h>
3#include <sys/socket.h>
4#include <stdio.h>
5#include <stdlib.h>
6#include <errno.h>
7#include <memory.h>
8
9static void
10panic( const char*  msg )
11{
12    fprintf(stderr, "PANIC: %s: %s\n", msg, strerror(errno));
13    exit(1);
14}
15
16static int
17unix_write( int  fd, const char*  buf, int  len )
18{
19    int  result = 0;
20    while (len > 0) {
21        int  len2 = write(fd, buf, len);
22        if (len2 < 0) {
23            if (errno == EINTR || errno == EAGAIN)
24                continue;
25            return -1;
26        }
27        result += len2;
28        len -= len2;
29        buf += len2;
30    }
31    return  result;
32}
33
34static int
35unix_read( int  fd, char*  buf, int  len )
36{
37    int  result = 0;
38    while (len > 0) {
39        int  len2 = read(fd, buf, len);
40        if (len2 < 0) {
41            if (errno == EINTR || errno == EAGAIN)
42                continue;
43            return -1;
44        }
45        result += len2;
46        len -= len2;
47        buf += len2;
48    }
49    return  result;
50}
51
52
53int  main( void )
54{
55    int                  ret, s;
56    struct sockaddr_in   server;
57    char                 buffer[1024];
58    const char*          request = "host:track-devices";
59    int                  len;
60
61    memset( &server, 0, sizeof(server) );
62    server.sin_family      = AF_INET;
63    server.sin_port        = htons(5037);
64    server.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
65
66    s = socket( PF_INET, SOCK_STREAM, 0 );
67    ret = connect( s, (struct sockaddr*) &server, sizeof(server) );
68    if (ret < 0) panic( "could not connect to server" );
69
70    /* send the request */
71    len = snprintf( buffer, sizeof buffer, "%04x%s", strlen(request), request );
72    if (unix_write(s, buffer, len) < 0)
73        panic( "could not send request" );
74
75    /* read the OKAY answer */
76    if (unix_read(s, buffer, 4) != 4)
77        panic( "could not read request" );
78
79    printf( "server answer: %.*s\n", 4, buffer );
80
81    /* now loop */
82    for (;;) {
83        char  head[5] = "0000";
84
85        if (unix_read(s, head, 4) < 0)
86            panic("could not read length");
87
88        if ( sscanf( head, "%04x", &len ) != 1 )
89            panic("could not decode length");
90
91        if (unix_read(s, buffer, len) != len)
92            panic("could not read data");
93
94        printf( "received header %.*s (%d bytes):\n%.*s", 4, head, len, len, buffer );
95    }
96    close(s);
97}
98