WebSVN – HelenOS – Diff – /branches/network/uspace/srv/net/module.c


/*
 * Copyright (c) 2009 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 net
 *  @{
 */
 
/** @file
 */
 
#include <async.h>
#include <stdio.h>
#include <task.h>
 
#include <ipc/ipc.h>
 
#include "err.h"
 
extern int  module_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count );
extern void module_print_name( void );
extern int  module_start( async_client_conn_t client_connection );
 
void    client_connection( ipc_callid_t iid, ipc_call_t * icall );
int main( int argc, char * argv[] );
 
/** Default thread for new connections.
 */
void client_connection( ipc_callid_t iid, ipc_call_t * icall ){
    ipc_callid_t    callid;
    ipc_call_t  call;
    ipc_call_t  answer;
    int     count;
    int     res;
 
    /*
     * Accept the connection
     *  - Answer the first IPC_M_CONNECT_ME_TO call.
     */
    ipc_answer_0( iid, EOK );
 
    while( true ){
        // refresh data
        count = 0;
        IPC_SET_RETVAL( answer, 0 );
        // just to be precize
        IPC_SET_RETVAL( 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 );
        res = module_message( callid, & call, & answer, & count );
 
        switch( count ){
            case 0:     ipc_answer_0( callid, res );
                    continue;
            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 ));
                    continue;
            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 ));
                    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 ));
                    continue;
        }
    }
}
 
/** Starts the module.
 *  Parameters are ignored.
 */
int main( int argc, char * argv[] ){
    ERROR_DECLARE;
 
    printf("\nTask %d - ", task_get_id());
    module_print_name();
    if( ERROR_OCCURRED( module_start( client_connection ))){
        printf( " - ERROR %i", ERROR_CODE );
        return ERROR_CODE;
    }
    return EOK;
}
 
/** @}
 */
 

Rev 3846	Rev 3912
1	/*	1	/*
2	* Copyright (c) 2008 Lukas Mejdrech	2	* Copyright (c) 2009 Lukas Mejdrech
3	* All rights reserved.	3	* All rights reserved.
4	*	4	*
5	* Redistribution and use in source and binary forms, with or without	5	* Redistribution and use in source and binary forms, with or without
6	* modification, are permitted provided that the following conditions	6	* modification, are permitted provided that the following conditions
7	* are met:	7	* are met:
8	*	8	*
9	* - Redistributions of source code must retain the above copyright	9	* - Redistributions of source code must retain the above copyright
10	* notice, this list of conditions and the following disclaimer.	10	* notice, this list of conditions and the following disclaimer.
11	* - Redistributions in binary form must reproduce the above copyright	11	* - Redistributions in binary form must reproduce the above copyright
12	* notice, this list of conditions and the following disclaimer in the	12	* notice, this list of conditions and the following disclaimer in the
13	* documentation and/or other materials provided with the distribution.	13	* documentation and/or other materials provided with the distribution.
14	* - The name of the author may not be used to endorse or promote products	14	* - The name of the author may not be used to endorse or promote products
15	* derived from this software without specific prior written permission.	15	* derived from this software without specific prior written permission.
16	*	16	*
17	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR	17	* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES	18	* IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.	19	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,	20	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT	21	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,	22	* NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY	23	* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT	24	* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF	25	* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.	26	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27	*/	27	*/
28		28
29	/** @addtogroup net	29	/** @addtogroup net
30	* @{	30	* @{
31	*/	31	*/
32		32
33	/** @file	33	/** @file
34	*/	34	*/
35		35
36	#include <async.h>	36	#include <async.h>
37	#include <stdio.h>	37	#include <stdio.h>
38	#include <task.h>	38	#include <task.h>
39		39
40	#include <ipc/ipc.h>	40	#include <ipc/ipc.h>
41		41
42	#include "err.h"	42	#include "err.h"
43		43
44	extern int module_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count );	44	extern int module_message( ipc_callid_t callid, ipc_call_t * call, ipc_call_t * answer, int * answer_count );
45	extern void module_print_name( void );	45	extern void module_print_name( void );
46	extern int module_start( async_client_conn_t client_connection );	46	extern int module_start( async_client_conn_t client_connection );
47		47
48	void client_connection( ipc_callid_t iid, ipc_call_t * icall );	48	void client_connection( ipc_callid_t iid, ipc_call_t * icall );
49	int main( int argc, char * argv[] );	49	int main( int argc, char * argv[] );
50		50
51	/** Default thread for new connections.	51	/** Default thread for new connections.
52	*/	52	*/
53	void client_connection( ipc_callid_t iid, ipc_call_t * icall ){	53	void client_connection( ipc_callid_t iid, ipc_call_t * icall ){
54	ipc_callid_t callid;	54	ipc_callid_t callid;
55	ipc_call_t call;	55	ipc_call_t call;
56	ipc_call_t answer;	56	ipc_call_t answer;
57	int count;	57	int count;
58	int res;	58	int res;
59		59
60	/*	60	/*
61	* Accept the connection	61	* Accept the connection
62	* - Answer the first IPC_M_CONNECT_ME_TO call.	62	* - Answer the first IPC_M_CONNECT_ME_TO call.
63	*/	63	*/
64	ipc_answer_0( iid, EOK );	64	ipc_answer_0( iid, EOK );
65		65
66	while( true ){	66	while( true ){
67	// refresh data	67	// refresh data
68	count = 0;	68	count = 0;
69	IPC_SET_RETVAL( answer, 0 );	69	IPC_SET_RETVAL( answer, 0 );
70	// just to be precize	70	// just to be precize
71	IPC_SET_RETVAL( answer, 0 );	71	IPC_SET_RETVAL( answer, 0 );
72	IPC_SET_ARG1( answer, 0 );	72	IPC_SET_ARG1( answer, 0 );
73	IPC_SET_ARG2( answer, 0 );	73	IPC_SET_ARG2( answer, 0 );
74	IPC_SET_ARG3( answer, 0 );	74	IPC_SET_ARG3( answer, 0 );
75	IPC_SET_ARG4( answer, 0 );	75	IPC_SET_ARG4( answer, 0 );
76	IPC_SET_ARG5( answer, 0 );	76	IPC_SET_ARG5( answer, 0 );
77		77
78	callid = async_get_call( & call );	78	callid = async_get_call( & call );
79	res = module_message( callid, & call, & answer, & count );	79	res = module_message( callid, & call, & answer, & count );
80		80
81	switch( count ){	81	switch( count ){
82	case 0: ipc_answer_0( callid, res );	82	case 0: ipc_answer_0( callid, res );
83	continue;	83	continue;
84	case 1: ipc_answer_1( callid, res, IPC_GET_ARG1( answer ));	84	case 1: ipc_answer_1( callid, res, IPC_GET_ARG1( answer ));
85	continue;	85	continue;
86	case 2: ipc_answer_2( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer ));	86	case 2: ipc_answer_2( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer ));
87	continue;	87	continue;
88	case 3: ipc_answer_3( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer ), IPC_GET_ARG3( answer ));	88	case 3: ipc_answer_3( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer ), IPC_GET_ARG3( answer ));
89	continue;	89	continue;
90	case 4: ipc_answer_4( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer ), IPC_GET_ARG3( answer ), IPC_GET_ARG4( answer ));	90	case 4: ipc_answer_4( callid, res, IPC_GET_ARG1( answer ), IPC_GET_ARG2( answer ), IPC_GET_ARG3( answer ), IPC_GET_ARG4( answer ));
91	continue;	91	continue;
92	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 ));	92	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 ));
93	continue;	93	continue;
94	}	94	}
95	}	95	}
96	}	96	}
97		97
98	/** Starts the module.	98	/** Starts the module.
99	* Parameters are ignored.	99	* Parameters are ignored.
100	*/	100	*/
101	int main( int argc, char * argv[] ){	101	int main( int argc, char * argv[] ){
102	ERROR_DECLARE;	102	ERROR_DECLARE;
103		103
104	printf("\nTask %d - ", task_get_id());	104	printf("\nTask %d - ", task_get_id());
105	module_print_name();	105	module_print_name();
106	if( ERROR_OCCURED( module_start( client_connection ))){	106	if( ERROR_OCCURRED( module_start( client_connection ))){
107	printf( " - ERROR %i", ERROR_CODE );	107	printf( " - ERROR %i", ERROR_CODE );
108	return ERROR_CODE;	108	return ERROR_CODE;
109	}	109	}
110	return EOK;	110	return EOK;
111	}	111	}
112		112
113	/** @}	113	/** @}
114	*/	114	*/
115		115

Subversion Repositories HelenOS

(root)/branches/network/uspace/srv/net/module.c – Rev 3846 → 3912