diff options
Diffstat (limited to 'telephony/test2.c')
| -rw-r--r-- | telephony/test2.c | 215 |
1 files changed, 215 insertions, 0 deletions
diff --git a/telephony/test2.c b/telephony/test2.c new file mode 100644 index 0000000..a0cd66f --- /dev/null +++ b/telephony/test2.c @@ -0,0 +1,215 @@ +/* Copyright (C) 2007-2008 The Android Open Source Project +** +** This software is licensed under the terms of the GNU General Public +** License version 2, as published by the Free Software Foundation, and +** may be copied, distributed, and modified under those terms. +** +** This program is distributed in the hope that it will be useful, +** but WITHOUT ANY WARRANTY; without even the implied warranty of +** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +** GNU General Public License for more details. +*/ +#include "sysdeps.h" +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <errno.h> + +#define PORT 8000 +#define MAX_COUNTER 30 +#define INITIAL_DELAY 1000 +#define DELAY 5000 + +static int counter = 0; + +static void +timer_func( void* _timer ) +{ + SysTimer timer = _timer; + SysTime now = sys_time_ms(); + + ++counter; + printf( "tick %d/%d a %.2fs\n", counter, MAX_COUNTER, now/1000. ); + if (counter < MAX_COUNTER) + sys_timer_set( timer, now + DELAY, timer_func, timer ); + else + sys_timer_destroy( timer ); +} + +typedef struct { + SysChannel channel; + char in_buff[ 128 ]; + int in_pos; + + char out_buff[ 128 ]; + int out_pos; + int out_size; +} ClientRec, *Client; + +static Client +client_alloc( SysChannel channel ) +{ + Client client = calloc( sizeof(*client), 1 ); + + client->channel = channel; + return client; +} + +static void +client_free( Client client ) +{ + sys_channel_close( client->channel ); + client->channel = NULL; + free( client ); +} + +static void +client_append( Client client, const char* str, int len ); + +static void +client_handle_line( Client client, const char* cmd ) +{ + char temp[256]; + int nn, mm = 0; + + for (nn = 0; cmd[nn] != 0; nn++) { + int c = cmd[nn]; + if (c >= 32 && c <= 127) + temp[mm++] = c; + else if (c == '\n') { + strcat( temp+mm, "<LF>" ); + mm += 4; + } + else if (c == '\r') { + strcat( temp+mm, "<CR>" ); + mm += 4; + } + else { + sprintf( temp+mm, "\\x%02x", c ); + mm += strlen( temp+mm ); + } + } + temp[mm] = 0; + printf( "%p: << %s\n", client, temp ); + + if ( !strcmp( cmd, "quit" ) ) { + printf( "client %p quitting\n", client ); + client_free( client ); + return; + } + client_append( client, "type 'quit' to quit\n", -1 ); +} + +static void +client_handler( void* _client, int events ) +{ + Client client = _client; + + if (events & SYS_EVENT_READ) { + int ret; + /* read into buffer, one character at a time */ + ret = sys_channel_read( client->channel, client->in_buff + client->in_pos, 1 ); + if (ret != 1) { + fprintf(stderr, "client %p could not read byte, result = %d, error: %s\n", + client, ret, strerror(errno) ); + goto ExitClient; + } + if (client->in_buff[client->in_pos] == '\r' || + client->in_buff[client->in_pos] == '\n' ) { + const char* cmd = client->in_buff; + client->in_buff[client->in_pos] = 0; + + /* eat leading cr and lf, maybe left-overs from previous line */ + while (*cmd == '\r' || *cmd =='\n') + cmd++; + + client_handle_line( client, cmd ); + client->in_pos = 0; + } else + client->in_pos += 1; + } + + if (events & SYS_EVENT_WRITE) { + int ret; + /* write from output buffer, one char at a time */ + ret = sys_channel_write( client->channel, client->out_buff + client->out_pos, 1 ); + if (ret != 1) { + fprintf(stderr, "client %p could not write byte, result = %d, error: %s\n", + client, ret, strerror(errno) ); + goto ExitClient; + } + client->out_pos += 1; + if (client->out_pos == client->out_size) { + client->out_size = 0; + client->out_pos = 0; + /* we don't need to write */ + sys_channel_on( client->channel, SYS_EVENT_READ, client_handler, client ); + } + } + return; + +ExitClient: + printf( "client %p exiting\n", client ); + client_free( client ); +} + +static void +client_append( Client client, const char* str, int len ) +{ + int avail; + + if (len < 0) + len = strlen(str); + + avail = sizeof(client->out_buff) - client->out_size; + if (len > avail) + len = avail; + + memcpy( client->out_buff + client->out_size, str, len ); + if (client->out_size == 0) { + sys_channel_on( client->channel, SYS_EVENT_READ | SYS_EVENT_WRITE, client_handler, client ); + } + client->out_size += len; +} + + +static void +accept_func( void* _server, int events ) +{ + SysChannel server = _server; + SysChannel handler; + Client client; + + printf( "connection accepted for server channel, getting handler socket\n" ); + handler = sys_channel_create_tcp_handler( server ); + printf( "got one. creating client\n" ); + client = client_alloc( handler ); + + events=events; + sys_channel_on( handler, SYS_EVENT_READ, client_handler, client ); + client_append( client, "Welcome !\n", -1 ); +} + + +int main( void ) +{ + SysTimer timer; + SysChannel server_channel; + + /* initialize event subsystem */ + sys_main_init(); + + /* create timer and register it */ + timer = sys_timer_create(); + sys_timer_set( timer, sys_time_ms() + INITIAL_DELAY, timer_func, timer ); + + server_channel = sys_channel_create_tcp_server( PORT ); + printf( "listening on port %d with %p\n", PORT, server_channel ); + + sys_channel_on( server_channel, SYS_EVENT_READ, accept_func, server_channel ); + + printf("entering event loop\n"); + sys_main_loop(); + printf("exiting event loop\n" ); + return 0; +} |