WebSVN – HelenOS-historic – Diff – /kernel/trunk/generic/include/ipc/ipc.h


/*
 * Copyright (C) 2006 Ondrej Palkovsky
 * 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.
 */
 
#ifndef __IPC_H__
#define __IPC_H__
 
/* Length of data being transfered with IPC call */
/* - the uspace may not be able to utilize full length */
#define IPC_CALL_LEN    4
 
/** Maximum active async calls per thread */
#define IPC_MAX_ASYNC_CALLS  4
 
/* Flags for calls */
#define IPC_CALL_ANSWERED      1 /**< This is answer to a call */
#define IPC_CALL_STATIC_ALLOC  2 /**< This call will not be freed on error */
 
/* Flags for ipc_wait_for_call */
#define IPC_WAIT_NONBLOCKING   1
 
/* Flags of callid */
#define IPC_CALLID_ANSWERED  1
 
/* Return values from IPC_ASYNC */
#define IPC_CALLRET_FATAL         -1
#define IPC_CALLRET_TEMPORARY     -2
 
 
/* Macros for manipulating calling data */
#define IPC_SET_RETVAL(data, retval)   ((data)[0] = (retval))
#define IPC_SET_METHOD(data, val)   ((data)[0] = (val))
#define IPC_SET_ARG1(data, val)   ((data)[1] = (val))
#define IPC_SET_ARG2(data, val)   ((data)[2] = (val))
#define IPC_SET_ARG3(data, val)   ((data)[3] = (val))
 
#define IPC_GET_METHOD(data)           ((data)[0])
#define IPC_GET_RETVAL(data)           ((data)[0])
 
#define IPC_GET_ARG1(data)              ((data)[1])
#define IPC_GET_ARG2(data)              ((data)[2])
#define IPC_GET_ARG3(data)              ((data)[3])
 
/* Well known phone descriptors */
#define PHONE_NS              0
 
/* System-specific methods - only through special syscalls
 * These methods have special behaviour
 */
 
/** Protocol for CONNECT - TO - ME
 *
 * Calling process asks the callee to create a callback connection,
 * so that it can start initiating new messages.
 *
 * The protocol for negotiating is:
 * - sys_connecttome - sends a message IPC_M_CONNECTTOME
 * - sys_wait_for_call - upon receipt tries to allocate new phone
 *                       - if it fails, responds with ELIMIT
 *                     - passes call to userspace. If userspace
 *                       responds with error, phone is deallocated and
 *                       error is sent back to caller. Otherwise
 *                       the call is accepted and the response is sent back.
 *                     - the allocated phoneid is passed to userspace
 *                       (on the receiving sid) as ARG3 of the call.
 *                     - the caller obtains taskid of the called thread
 */
#define IPC_M_CONNECTTOME     1
/** Protocol for CONNECT - ME - TO
 *
 * Calling process asks the callee to create for him a new connection.
 * E.g. the caller wants a name server to connect him to print server.
 *
 * The protocol for negotiating is:
 * - sys_connect_me_to - send a synchronous message to name server
 *                       indicating that it wants to be connected to some
 *                       service
 *   recepient         -  if ipc_answer == 0, then accept connection
 *                     -  otherwise connection refused
 *                     -  recepient may forward message. Forwarding
 *                        system message
 *
 */
#define IPC_M_CONNECTMETO     2
/* Control messages that the server sends to the processes
 * about their connections.
 */
 
 
/* Well-known methods */
#define IPC_M_LAST_SYSTEM     511
#define IPC_M_PING            512
/* User methods */
#define FIRST_USER_METHOD     1024
 
#ifdef KERNEL
 
#include <synch/mutex.h>
#include <synch/condvar.h>
#include <adt/list.h>
 
#define IPC_MAX_PHONES  16
 
typedef struct answerbox answerbox_t;
typedef __native ipc_data_t[IPC_CALL_LEN];
 
typedef struct {
    link_t list;
    answerbox_t *callerbox;
    int flags;
    task_t *sender;
    ipc_data_t data;
} call_t;
 
struct answerbox {
    SPINLOCK_DECLARE(lock);
 
    task_t *task;
 
 
    waitq_t wq;
 
    link_t connected_phones; /**< Phones connected to this answerbox */
    link_t calls;            /**< Received calls */
    link_t dispatched_calls; /* Should be hash table in the future */
 
    link_t answers;          /**< Answered calls */
};
 
typedef struct {
    SPINLOCK_DECLARE(lock);
    link_t list;
    answerbox_t *callee;
    int busy;
} phone_t;
 
extern void ipc_init(void);
extern call_t * ipc_wait_for_call(answerbox_t *box, int flags);
extern void ipc_answer(answerbox_t *box, call_t *request);
extern void ipc_call(phone_t *phone, call_t *request);
extern void ipc_call_sync(phone_t *phone, call_t *request);
extern void ipc_phone_destroy(phone_t *phone);
extern void ipc_phone_init(phone_t *phone);
extern void ipc_phone_connect(phone_t *phone, answerbox_t *box);
extern void ipc_call_free(call_t *call);
extern call_t * ipc_call_alloc(void);
extern void ipc_answerbox_init(answerbox_t *box);
 
extern void ipc_call_init(call_t *call);
extern void ipc_forward(call_t *call, answerbox_t *newbox,answerbox_t *oldbox);
 
extern answerbox_t *ipc_phone_0;
 
#endif
 
#endif
 

Rev 1027	Rev 1040
1	/*	1	/*
2	* Copyright (C) 2006 Ondrej Palkovsky	2	* Copyright (C) 2006 Ondrej Palkovsky
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	#ifndef __IPC_H__	29	#ifndef __IPC_H__
30	#define __IPC_H__	30	#define __IPC_H__
31		31
32	/* Length of data being transfered with IPC call */	32	/* Length of data being transfered with IPC call */
33	/* - the uspace may not be able to utilize full length */	33	/* - the uspace may not be able to utilize full length */
34	#define IPC_CALL_LEN 4	34	#define IPC_CALL_LEN 4
35		35
36	/** Maximum active async calls per thread */	36	/** Maximum active async calls per thread */
37	#define IPC_MAX_ASYNC_CALLS 4	37	#define IPC_MAX_ASYNC_CALLS 4
38		38
39	/* Flags for calls */	39	/* Flags for calls */
40	#define IPC_CALL_ANSWERED 1 /*< This is answer to a call /	40	#define IPC_CALL_ANSWERED 1 /*< This is answer to a call /
41	#define IPC_CALL_STATIC_ALLOC 2 /*< This call will not be freed on error /	41	#define IPC_CALL_STATIC_ALLOC 2 /*< This call will not be freed on error /
42		42
43	/* Flags for ipc_wait_for_call */	43	/* Flags for ipc_wait_for_call */
44	#define IPC_WAIT_NONBLOCKING 1	44	#define IPC_WAIT_NONBLOCKING 1
45		45
46	/* Flags of callid */	46	/* Flags of callid */
47	#define IPC_CALLID_ANSWERED 1	47	#define IPC_CALLID_ANSWERED 1
48		48
49	/* Return values from IPC_ASYNC */	49	/* Return values from IPC_ASYNC */
50	#define IPC_CALLRET_FATAL -1	50	#define IPC_CALLRET_FATAL -1
51	#define IPC_CALLRET_TEMPORARY -2	51	#define IPC_CALLRET_TEMPORARY -2
52		52
53		53
54	/* Macros for manipulating calling data */	54	/* Macros for manipulating calling data */
55	#define IPC_SET_RETVAL(data, retval) ((data)[0] = (retval))	55	#define IPC_SET_RETVAL(data, retval) ((data)[0] = (retval))
56	#define IPC_SET_METHOD(data, val) ((data)[0] = (val))	56	#define IPC_SET_METHOD(data, val) ((data)[0] = (val))
57	#define IPC_SET_ARG1(data, val) ((data)[1] = (val))	57	#define IPC_SET_ARG1(data, val) ((data)[1] = (val))
58	#define IPC_SET_ARG2(data, val) ((data)[2] = (val))	58	#define IPC_SET_ARG2(data, val) ((data)[2] = (val))
59	#define IPC_SET_ARG3(data, val) ((data)[3] = (val))	59	#define IPC_SET_ARG3(data, val) ((data)[3] = (val))
60		60
61	#define IPC_GET_METHOD(data) ((data)[0])	61	#define IPC_GET_METHOD(data) ((data)[0])
62	#define IPC_GET_RETVAL(data) ((data)[0])	62	#define IPC_GET_RETVAL(data) ((data)[0])
63		63
64	#define IPC_GET_ARG1(data) ((data)[1])	64	#define IPC_GET_ARG1(data) ((data)[1])
65	#define IPC_GET_ARG2(data) ((data)[2])	65	#define IPC_GET_ARG2(data) ((data)[2])
66	#define IPC_GET_ARG3(data) ((data)[3])	66	#define IPC_GET_ARG3(data) ((data)[3])
67		67
68	/* Well known phone descriptors */	68	/* Well known phone descriptors */
69	#define PHONE_NS 0	69	#define PHONE_NS 0
70		70
71	/* System-specific methods - only through special syscalls	71	/* System-specific methods - only through special syscalls
72	* These methods have special behaviour	72	* These methods have special behaviour
73	*/	73	*/
74	#define IPC_M_IAMCONNECTING 0	-
75	/** Protocol for CONNECT - TO - ME	74	/** Protocol for CONNECT - TO - ME
76	*	75	*
77	* Calling process asks the callee to create a callback connection,	76	* Calling process asks the callee to create a callback connection,
78	* so that it can start initiating new messages.	77	* so that it can start initiating new messages.
79	*	78	*
80	* The protocol for negotiating is as follows:	79	* The protocol for negotiating is:
81	* - sys_connecttome - sends a message IPC_M_CONNECTTOME	80	* - sys_connecttome - sends a message IPC_M_CONNECTTOME
82	* - sys_wait_for_call - upon receipt tries to allocate new phone	81	* - sys_wait_for_call - upon receipt tries to allocate new phone
83	* - if it fails, responds with ELIMIT	82	* - if it fails, responds with ELIMIT
84	* - passes call to userspace. If userspace	83	* - passes call to userspace. If userspace
85	* responds with error, phone is deallocated and	84	* responds with error, phone is deallocated and
86	* error is sent back to caller. Otherwise	85	* error is sent back to caller. Otherwise
87	* the call is accepted and the response is sent back.	86	* the call is accepted and the response is sent back.
88	* - the allocated phoneid is passed to userspace as	87	* - the allocated phoneid is passed to userspace
89	* ARG3 of the call.	88	* (on the receiving sid) as ARG3 of the call.
90	* - the caller obtains taskid of the called thread	89	* - the caller obtains taskid of the called thread
91	*/	90	*/
92	#define IPC_M_CONNECTTOME 1	91	#define IPC_M_CONNECTTOME 1
-		92	/** Protocol for CONNECT - ME - TO
-		93	*
-		94	* Calling process asks the callee to create for him a new connection.
-		95	* E.g. the caller wants a name server to connect him to print server.
-		96	*
-		97	* The protocol for negotiating is:
-		98	* - sys_connect_me_to - send a synchronous message to name server
-		99	* indicating that it wants to be connected to some
-		100	* service
-		101	* recepient - if ipc_answer == 0, then accept connection
-		102	* - otherwise connection refused
-		103	* - recepient may forward message. Forwarding
-		104	* system message
-		105	*
-		106	*/
93	#define IPC_M_CONNECTMETO 2	107	#define IPC_M_CONNECTMETO 2
-		108	/* Control messages that the server sends to the processes
-		109	* about their connections.
-		110	*/
94		111
95		112
96	/* Well-known methods */	113	/* Well-known methods */
97	#define IPC_M_FIRST_USER 512	114	#define IPC_M_LAST_SYSTEM 511
98	#define IPC_M_PING 512	115	#define IPC_M_PING 512
99	/* User methods */	116	/* User methods */
100	#define FIRST_USER_METHOD 1024	117	#define FIRST_USER_METHOD 1024
101		118
102	#ifdef KERNEL	119	#ifdef KERNEL
103		120
104	#include <synch/mutex.h>	121	#include <synch/mutex.h>
105	#include <synch/condvar.h>	122	#include <synch/condvar.h>
106	#include <adt/list.h>	123	#include <adt/list.h>
107		124
108	#define IPC_MAX_PHONES 16	125	#define IPC_MAX_PHONES 16
109		126
110	typedef struct answerbox answerbox_t;	127	typedef struct answerbox answerbox_t;
111	typedef __native ipc_data_t[IPC_CALL_LEN];	128	typedef __native ipc_data_t[IPC_CALL_LEN];
112		129
113	typedef struct {	130	typedef struct {
114	link_t list;	131	link_t list;
115	answerbox_t *callerbox;	132	answerbox_t *callerbox;
116	int flags;	133	int flags;
117	task_t *sender;	134	task_t *sender;
118	ipc_data_t data;	135	ipc_data_t data;
119	} call_t;	136	} call_t;
120		137
121	struct answerbox {	138	struct answerbox {
122	SPINLOCK_DECLARE(lock);	139	SPINLOCK_DECLARE(lock);
123		140
124	task_t *task;	141	task_t *task;
125		142
126	mutex_t mutex;	-
127	condvar_t cv;	143	waitq_t wq;
128		144
129	link_t connected_phones; /*< Phones connected to this answerbox /	145	link_t connected_phones; /*< Phones connected to this answerbox /
130	link_t calls; /*< Received calls /	146	link_t calls; /*< Received calls /
131	link_t dispatched_calls; /* Should be hash table in the future */	147	link_t dispatched_calls; /* Should be hash table in the future */
132		148
133	link_t answers; /*< Answered calls /	149	link_t answers; /*< Answered calls /
134	};	150	};
135		151
136	typedef struct {	152	typedef struct {
137	SPINLOCK_DECLARE(lock);	153	SPINLOCK_DECLARE(lock);
138	link_t list;	154	link_t list;
139	answerbox_t *callee;	155	answerbox_t *callee;
-		156	int busy;
140	} phone_t;	157	} phone_t;
141		158
142	extern void ipc_init(void);	159	extern void ipc_init(void);
143	extern call_t * ipc_wait_for_call(answerbox_t *box, int flags);	160	extern call_t * ipc_wait_for_call(answerbox_t *box, int flags);
144	extern void ipc_answer(answerbox_t box, call_t request);	161	extern void ipc_answer(answerbox_t box, call_t request);
145	extern void ipc_call(phone_t phone, call_t request);	162	extern void ipc_call(phone_t phone, call_t request);
146	extern void ipc_call_sync(phone_t phone, call_t request);	163	extern void ipc_call_sync(phone_t phone, call_t request);
147	extern void ipc_phone_destroy(phone_t *phone);	164	extern void ipc_phone_destroy(phone_t *phone);
-		165	extern void ipc_phone_init(phone_t *phone);
148	extern void ipc_phone_init(phone_t phone, answerbox_t box);	166	extern void ipc_phone_connect(phone_t phone, answerbox_t box);
149	extern void ipc_call_free(call_t *call);	167	extern void ipc_call_free(call_t *call);
150	extern call_t * ipc_call_alloc(void);	168	extern call_t * ipc_call_alloc(void);
151	extern void ipc_answerbox_init(answerbox_t *box);	169	extern void ipc_answerbox_init(answerbox_t *box);
152	extern void ipc_phone_init(phone_t phone, answerbox_t box);	-
153	extern void ipc_call_init(call_t *call);	170	extern void ipc_call_init(call_t *call);
-		171	extern void ipc_forward(call_t call, answerbox_t newbox,answerbox_t *oldbox);
154		172
155	extern answerbox_t *ipc_phone_0;	173	extern answerbox_t *ipc_phone_0;
156		174
157	#endif	175	#endif
158		176
159	#endif	177	#endif
160		178

Subversion Repositories HelenOS-historic

(root)/kernel/trunk/generic/include/ipc/ipc.h @ 1780 – Rev 1027 → 1040