/*
* Copyright (c) 2008 Lukas Mejdrech
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* - Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* - Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* - The name of the author may not be used to endorse or promote products
* derived from this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
/** @addtogroup tcp
* @{
*/
/** @file
* \todo
*/
#include <async.h>
#include <stdio.h>
#include <ipc/ipc.h>
#include <ipc/services.h>
#include "../../err.h"
#include "../../messages.h"
#include "../../modules.h"
#include "../../structures/packet/packet_client.h"
#include "../../include/ip_client.h"
#include "../../include/ip_interface.h"
#include "../../include/ip_protocols.h"
#include "../tl_messages.h"
#include "tcp.h"
#include "tcp_module.h"
tcp_globals_t tcp_globals;
int tcp_received_msg( device_id_t device_id, packet_t packet, services_t receiver );
/** Initializes the module.
*/
int tcp_initialize( async_client_conn_t client_connection ){
// ERROR_DECLARE;
// ipcarg_t arg1, arg2;
// packet_t packet;
/* printf( "TCP - testing to send to IP:\n" );
ERROR_PROPAGATE( ip_echo( tcp_globals.ip_phone, 12, 34, 0, 0, 0, & arg1, & arg2, NULL, NULL, NULL ));
if(( arg1 != 12 ) || ( arg2 != 34 )) return EINVAL;
printf( "OK\n" );
*/
tcp_globals.ip_phone = ip_bind_service( SERVICE_IP, IPPROTO_TCP, SERVICE_TCP, client_connection, tcp_received_msg );
/* printf( "TCP - testing to send packet to IP:\n" );
packet = packet_get_4( tcp_globals.net_phone, 6, 20, 30, 20 );
if( ! packet ) return ENOMEM;
packet_copy_data( packet, "Hi, this is TCP", 16 );
ip_send_msg( tcp_globals.ip_phone, -1, packet, SERVICE_TCP );
printf( "OK\n" );
*/ return EOK;
}
int tcp_received_msg( device_id_t device_id, packet_t packet, services_t receiver ){
// TODO received
// TODO remove debug dump:
uint8_t * data;
data = packet_get_data( packet );
printf( "Receiving packet:\n\tid\t= %d\n\tlength\t= %d\n\tdata\t= %.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX\n\t\t%.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX:%.2hhX %.2hhX %.2hhX %.2hhX\n", packet_get_id
( packet
), packet_get_data_length
( packet
), data
[ 0 ], data
[ 1 ], data
[ 2 ], data
[ 3 ], data
[ 4 ], data
[ 5 ], data
[ 6 ], data
[ 7 ], data
[ 8 ], data
[ 9 ], data
[ 10 ], data
[ 11 ], data
[ 12 ], data
[ 13 ], data
[ 14 ], data
[ 15 ], data
[ 16 ], data
[ 17 ], data
[ 18 ], data
[ 19 ], data
[ 20 ], data
[ 21 ], data
[ 22 ], data
[ 23 ], data
[ 24 ], data
[ 25 ], data
[ 26 ], data
[ 27 ], data
[ 28 ], data
[ 29 ], data
[ 30 ], data
[ 31 ], data
[ 32 ], data
[ 33 ], data
[ 34 ], data
[ 35 ], data
[ 36 ], data
[ 37 ], data
[ 38 ], data
[ 39 ], data
[ 40 ], data
[ 41 ], data
[ 42 ], data
[ 43 ], data
[ 44 ], data
[ 45 ], data
[ 46 ], data
[ 47 ], data
[ 48 ], data
[ 49 ], data
[ 50 ], data
[ 51 ], data
[ 52 ], data
[ 53 ], data
[ 54 ], data
[ 55 ], data
[ 56 ], data
[ 57 ], data
[ 58 ], data
[ 59 ] );
pq_release( tcp_globals.net_phone, packet_get_id( packet ));
return EOK;
}
int tcp_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count ){
ERROR_DECLARE;
packet_t packet;
* answer_count = 0;
switch( IPC_GET_METHOD( * call )){
case IPC_M_PHONE_HUNGUP:
return EOK;
case NET_TL_RECEIVED:
ERROR_PROPAGATE( packet_translate( tcp_globals.net_phone, & packet, IPC_GET_PACKET( call )));
return tcp_received_msg( IPC_GET_DEVICE( call ), packet, 0 );
}
return ENOTSUP;
}
/** @}
*/