The Android Open Source Project | 9ca14dc | 2009-03-03 19:32:55 -0800 | [diff] [blame] | 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 | |
| 9 | static void |
| 10 | panic( const char* msg ) |
| 11 | { |
| 12 | fprintf(stderr, "PANIC: %s: %s\n", msg, strerror(errno)); |
| 13 | exit(1); |
| 14 | } |
| 15 | |
| 16 | static int |
| 17 | unix_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 | |
| 34 | static int |
| 35 | unix_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 | |
| 53 | int 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 | } |