31,6 → 31,8 |
*/ |
|
/** @file |
* UDP module implementation. |
* @see udp.h |
*/ |
|
#include <async.h> |
65,24 → 67,130 |
#include "udp_header.h" |
#include "udp_module.h" |
|
/** Maximum UDP fragment size. |
*/ |
#define MAX_UDP_FRAGMENT_SIZE 65535 |
|
/** Free ports pool start. |
*/ |
#define UDP_FREE_PORTS_START 1025 |
|
/** Free ports pool end. |
*/ |
#define UDP_FREE_PORTS_END 65535 |
|
/** Processes the received UDP packet. |
* Is used as an entry point from the underlying IP module. |
* Releases the packet on error. |
* @param device_id The device identifier. Ignored parameter. |
* @param packet The received packet. Input/output parameter. |
* @param receiver The target service. Ignored parameter. |
* @returns EOK on success. |
* @returns Other error codes as defined for the udp_process_packet() function. |
*/ |
int udp_received_msg( device_id_t device_id, packet_t packet, services_t receiver ); |
|
/** Processes the received UDP packet. |
* Notifies the destination socket application. |
* @param packet The received packet. Input/output parameter. |
* @returns EOK on success. |
* @returns EINVAL if the packet is not valid. |
* @returns EINVAL if the stored packet address is not the an_addr_t. |
* @returns EINVAL if the packet does not contain any data. |
* @returns NO_DATA if the packet content is shorter than the user datagram header. |
* @returns ENOMEM if there is not enough memory left. |
* @returns EADDRNOTAVAIL if the destination socket does not exist. |
* @returns Other error codes as defined for the ip_client_process_packet() function. |
*/ |
int udp_process_packet( packet_t packet ); |
int process_client_messages( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count ); |
|
/** @name Socket messages processing functions |
*/ |
/*@{*/ |
|
/** Processes the socket client messages. |
* Runs until the client module disconnects. |
* @param callid The message identifier. Input parameter. |
* @param call The message parameters. Input parameter. |
* @returns EOK on success. |
* @see socket.h |
*/ |
int process_client_messages( ipc_callid_t callid, ipc_call_t call ); |
|
/** Sends data from the socket to the remote address. |
* Binds the socket to a free port if not already connected/bound. |
* Handles the NET_SOCKET_SENDTO message. |
* @param local_sockets The application local sockets. Input/output parameter. |
* @param socket_id Socket identifier. Input parameter. |
* @param addr The destination address. Input parameter. |
* @param addrlen The address length. Input parameter. |
* @param fragments The number of data fragments. Input parameter. |
* @param flags Various send flags. Input parameter. |
* @returns EOK on success. |
* @returns EAFNOTSUPPORT if the address family is not supported. |
* @returns ENOTSOCK if the socket is not found. |
* @returns EINVAL if the address is invalid. |
* @returns ENOTCONN if the sending socket is not and cannot be bound. |
* @returns ENOMEM if there is not enough memory left. |
* @returns Other error codes as defined for the socket_read_packet_data() function. |
* @returns Other error codes as defined for the ip_client_prepare_packet() function. |
* @returns Other error codes as defined for the ip_send_msg() function. |
*/ |
int udp_sendto_message( socket_cores_ref local_sockets, int socket_id, void * addr, size_t addrlen, int fragments, int flags ); |
|
/** Receives data to the socket. |
* Handles the NET_SOCKET_RECVFROM message. |
* @param local_sockets The application local sockets. Input parameter. |
* @param socket_id Socket identifier. Input parameter. |
* @param flags Various receive flags. Input parameter. |
* @returns The number of bytes received. |
* @returns ENOTSOCK if the socket is not found. |
* @returns NO_DATA if there are no received packets or data. |
* @returns ENOMEM if there is not enough memory left. |
* @returns EINVAL if the received address is not an IP address. |
* @returns Other error codes as defined for the packet_translate() function. |
* @returns Other error codes as defined for the socket_write_data() function. |
*/ |
int udp_recvfrom_message( socket_cores_ref local_sockets, int socket_id, int flags ); |
|
/*@}*/ |
|
/** Receives data from the socket. |
* The received data buffer is allocated and returned. |
* @param data The data buffer to be filled. Output parameter. |
* @param length The buffer length. Output parameter. |
* @returns EOK on success. |
* @returns EBADMEM if the data or the length parameter is NULL. |
* @returns EINVAL if the client does not send data. |
* @returns ENOMEM if there is not enough memory left. |
* @returns Other error codes as defined for the ipc_data_write_finalize() function. |
*/ |
int socket_read_data( void ** data, size_t * length ); |
|
/** Receives data from the socket into a packet. |
* @param packet The new created packet. Output parameter. |
* @param prefix Reserved packet data prefix length. Input parameter. |
* @param address_in The destination address to be set. Input parameter. |
* @returns Number of bytes received. |
* @returns EINVAL if the client does not send data. |
* @returns ENOMEM if there is not enough memory left. |
* @returns Other error codes as defined for the ipc_data_read_finalize() function. |
*/ |
int socket_read_packet_data( packet_ref packet, size_t prefix, struct sockaddr_in * address_in ); |
|
/** Replies the data to the socket. |
* @param data The data buffer to be sent. Input parameter. |
* @param data_length The buffer length. Input parameter. |
* @returns EOK on success. |
* @returns EINVAL if the client does not expect all the data. |
* @returns Other error codes as defined for the ipc_data_read_finalize() function. |
*/ |
int socket_write_data( void * data, size_t data_length ); |
|
/** UDP global data. |
*/ |
udp_globals_t udp_globals; |
|
/** Initializes the module. |
*/ |
int udp_initialize( async_client_conn_t client_connection ){ |
ERROR_DECLARE; |
|
129,18 → 237,12 |
|
// get packet data |
length = packet_get_addr( packet, & src, & dest ); |
if( length < 0 ) return length; |
if( length != sizeof( in_addr_t )) return EINVAL; |
// TODO received ipopts? |
// TODO process received ipopts? |
ERROR_PROPAGATE( ip_client_process_packet( packet, NULL, NULL, NULL, NULL, NULL )); |
|
// TODO remove debug dump: |
/* uint8_t * rdata; |
rdata = packet_get_data( packet ); |
printf( "Receiving udp 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 ), rdata[ 0 ], rdata[ 1 ], rdata[ 2 ], rdata[ 3 ], rdata[ 4 ], rdata[ 5 ], rdata[ 6 ], rdata[ 7 ], rdata[ 8 ], rdata[ 9 ], rdata[ 10 ], rdata[ 11 ], rdata[ 12 ], rdata[ 13 ], rdata[ 14 ], rdata[ 15 ], rdata[ 16 ], rdata[ 17 ], rdata[ 18 ], rdata[ 19 ], rdata[ 20 ], rdata[ 21 ], rdata[ 22 ], rdata[ 23 ], rdata[ 24 ], rdata[ 25 ], rdata[ 26 ], rdata[ 27 ], rdata[ 28 ], rdata[ 29 ], rdata[ 30 ], rdata[ 31 ], rdata[ 32 ], rdata[ 33 ], rdata[ 34 ], rdata[ 35 ], rdata[ 36 ], rdata[ 37 ], rdata[ 38 ], rdata[ 39 ], rdata[ 40 ], rdata[ 41 ], rdata[ 42 ], rdata[ 43 ], rdata[ 44 ], rdata[ 45 ], rdata[ 46 ], rdata[ 47 ], rdata[ 48 ], rdata[ 49 ], rdata[ 50 ], rdata[ 51 ], rdata[ 52 ], rdata[ 53 ], rdata[ 54 ], rdata[ 55 ], rdata[ 56 ], rdata[ 57 ], rdata[ 58 ], rdata[ 59 ] ); |
*/ |
length = packet_get_data_length( packet ); |
if( length < 0 ) return length; |
if( length <= 0 ) return EINVAL; |
if( length < sizeof( udp_header_t )) return NO_DATA; |
data = packet_get_data( packet ); |
if( ! data ) return NO_DATA; |
156,7 → 258,6 |
do{ |
++ fragments; |
length = packet_get_data_length( packet ); |
if( length < 0 ) return length; |
if( ! length ) return NO_DATA; |
if( total_length < length ){ |
// cut of the suffix if too long |
193,26 → 294,28 |
case NET_TL_RECEIVED: |
fibril_rwlock_read_lock( & udp_globals.lock ); |
if( ! ERROR_OCCURRED( packet_translate( udp_globals.net_phone, & packet, IPC_GET_PACKET( call )))){ |
ERROR_CODE = udp_received_msg( IPC_GET_DEVICE( call ), packet, 0 ); |
ERROR_CODE = udp_received_msg( IPC_GET_DEVICE( call ), packet, SERVICE_UDP ); |
} |
fibril_rwlock_read_unlock( & udp_globals.lock ); |
return ERROR_CODE; |
case IPC_M_CONNECT_TO_ME: |
return process_client_messages( callid, call, answer, answer_count ); |
return process_client_messages( callid, * call ); |
} |
return ENOTSUP; |
} |
|
int process_client_messages( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count ){ |
int process_client_messages( ipc_callid_t callid, ipc_call_t call ){ |
ERROR_DECLARE; |
|
int res; |
bool keep_on_going = true; |
socket_cores_t local_sockets; |
int app_phone = IPC_GET_PHONE( call ); |
int app_phone = IPC_GET_PHONE( & call ); |
void * addr; |
size_t addrlen; |
fibril_rwlock_t lock; |
ipc_call_t answer; |
int answer_count; |
|
/* |
* Accept the connection |
225,20 → 328,20 |
|
while( keep_on_going ){ |
// refresh data |
* answer_count = 0; |
IPC_SET_RETVAL( * answer, 0 ); |
answer_count = 0; |
IPC_SET_RETVAL( answer, 0 ); |
// just to be precize |
IPC_SET_METHOD( * answer, 0 ); |
IPC_SET_ARG1( * answer, 0 ); |
IPC_SET_ARG2( * answer, 0 ); |
IPC_SET_ARG3( * answer, 0 ); |
IPC_SET_ARG4( * answer, 0 ); |
IPC_SET_ARG5( * answer, 0 ); |
IPC_SET_METHOD( answer, 0 ); |
IPC_SET_ARG1( answer, 0 ); |
IPC_SET_ARG2( answer, 0 ); |
IPC_SET_ARG3( answer, 0 ); |
IPC_SET_ARG4( answer, 0 ); |
IPC_SET_ARG5( answer, 0 ); |
|
callid = async_get_call( call ); |
callid = async_get_call( & call ); |
// printf( "message %d\n", IPC_GET_METHOD( * call )); |
|
switch( IPC_GET_METHOD( * call )){ |
switch( IPC_GET_METHOD( call )){ |
case IPC_M_PHONE_HUNGUP: |
keep_on_going = false; |
res = EOK; |
249,7 → 352,7 |
fibril_rwlock_write_unlock( & lock ); |
* SOCKET_SET_HEADER_SIZE( answer ) = sizeof( udp_header_t ); |
* SOCKET_SET_DATA_FRAGMENT_SIZE( answer ) = MAX_UDP_FRAGMENT_SIZE; |
* answer_count = 3; |
answer_count = 3; |
break; |
case NET_SOCKET_BIND: |
if( ERROR_OCCURRED( socket_read_data( & addr, & addrlen ))){ |
262,7 → 365,7 |
fibril_rwlock_write_unlock( & udp_globals.lock ); |
fibril_rwlock_write_unlock( & lock ); |
free( addr ); |
break; |
break; |
case NET_SOCKET_SENDTO: |
if( ERROR_OCCURRED( socket_read_data( & addr, & addrlen ))){ |
res = ERROR_CODE; |
284,7 → 387,7 |
if( res > 0 ){ |
* SOCKET_SET_READ_DATA_LENGTH( answer ) = res; |
* SOCKET_SET_ADDRESS_LENGTH( answer ) = sizeof( struct sockaddr_in ); |
* answer_count = 2; |
answer_count = 2; |
res = EOK; |
} |
break; |
304,18 → 407,18 |
|
// printf( "res = %d\n", res ); |
|
switch( * answer_count ){ |
switch( answer_count ){ |
case 0: ipc_answer_0( callid, res ); |
continue; |
case 1: ipc_answer_1( callid, res, IPC_GET_ARG1( * answer )); |
case 1: ipc_answer_1( callid, res, IPC_GET_ARG1( answer )); |
continue; |
case 2: ipc_answer_2( callid, res, IPC_GET_ARG1( * answer ), IPC_GET_ARG2( * answer )); |
case 2: ipc_answer_2( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer )); |
continue; |
case 3: ipc_answer_3( callid, res, IPC_GET_ARG1( * answer ), IPC_GET_ARG2( * answer ), IPC_GET_ARG3( * answer )); |
case 3: ipc_answer_3( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer ), IPC_GET_ARG3( answer )); |
continue; |
case 4: ipc_answer_4( callid, res, IPC_GET_ARG1( * answer ), IPC_GET_ARG2( * answer ), IPC_GET_ARG3( * answer ), IPC_GET_ARG4( * answer )); |
case 4: ipc_answer_4( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer ), IPC_GET_ARG3( answer ), IPC_GET_ARG4( answer )); |
continue; |
default: ipc_answer_5( callid, res, IPC_GET_ARG1( * answer ), IPC_GET_ARG2( * answer ), IPC_GET_ARG3( * answer ), IPC_GET_ARG4( * answer ), IPC_GET_ARG5( * answer )); |
default: ipc_answer_5( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer ), IPC_GET_ARG3( answer ), IPC_GET_ARG4( answer ), IPC_GET_ARG5( answer )); |
continue; |
} |
} |
421,7 → 524,7 |
if( ! socket ) return ENOTSOCK; |
// get the next received packet |
packet_id = dyn_fifo_value( & socket->received ); |
if( packet_id < 0 ) return packet_id; |
if( packet_id < 0 ) return NO_DATA; |
ERROR_PROPAGATE( packet_translate( udp_globals.net_phone, & packet, packet_id )); |
// get udp header |
data = packet_get_data( packet ); |
506,7 → 609,7 |
if( !( data && length )) return EBADMEM; |
if( ! ipc_data_write_receive( & callid, length )) return EINVAL; |
* data = malloc( * length ); |
if( ! data ) return ENOMEM; |
if( !( * data )) return ENOMEM; |
if( ERROR_OCCURRED( ipc_data_write_finalize( callid, * data, * length ))){ |
free( data ); |
return ERROR_CODE; |