WebSVN – HelenOS – Diff – /trunk/kernel/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__
 
#define IPC_CALL_LEN    2
 
/* Flags for calls */
#define IPC_CALL_ANSWERED    1
/* Flags for ipc_wait_for_call */
#define IPC_WAIT_NONBLOCKING 1
 
#ifdef KERNEL
 
#include <synch/waitq.h>
#include <synch/spinlock.h>
#include <adt/list.h>
 
#define IPC_MAX_PHONES  16
 
 
typedef struct answerbox answerbox_t;
 
typedef struct {
    link_t list;
    answerbox_t *callerbox;
    int flags;
    __native data[IPC_CALL_LEN];
} call_t;
 
struct answerbox {
    SPINLOCK_DECLARE(lock);
 
    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;
} phone_t;
 
extern void ipc_create_phonecompany(void);
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, answerbox_t *box);
extern void ipc_call_free(call_t *call);
extern call_t * ipc_call_alloc(void);
void ipc_answerbox_init(answerbox_t *box);
void ipc_phone_init(phone_t *phone, answerbox_t *box);
 
extern answerbox_t *ipc_central_box;
 
#endif
 
#endif
 

Rev 955	Rev 959
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	#define IPC_CALL_LEN 2	32	#define IPC_CALL_LEN 2
33		33
34	/* Flags for calls */	34	/* Flags for calls */
35	#define IPC_CALL_ANSWERED 1	35	#define IPC_CALL_ANSWERED 1
36	/* Flags for ipc_wait_for_call */	36	/* Flags for ipc_wait_for_call */
37	#define IPC_WAIT_NONBLOCKING 1	37	#define IPC_WAIT_NONBLOCKING 1
38		38
39	#ifdef KERNEL	39	#ifdef KERNEL
40		40
41	#include <synch/waitq.h>	41	#include <synch/waitq.h>
42	#include <synch/spinlock.h>	42	#include <synch/spinlock.h>
43	#include <adt/list.h>	43	#include <adt/list.h>
44		44
45	#define IPC_MAX_PHONES 16	45	#define IPC_MAX_PHONES 16
46		46
47		47
48	typedef struct answerbox answerbox_t;	48	typedef struct answerbox answerbox_t;
49		49
50	typedef struct {	50	typedef struct {
51	link_t list;	51	link_t list;
52	answerbox_t *callerbox;	52	answerbox_t *callerbox;
53	int flags;	53	int flags;
54	__native data[IPC_CALL_LEN];	54	__native data[IPC_CALL_LEN];
55	} call_t;	55	} call_t;
56		56
57	struct answerbox {	57	struct answerbox {
58	SPINLOCK_DECLARE(lock);	58	SPINLOCK_DECLARE(lock);
59		59
60	waitq_t wq;	60	waitq_t wq;
61		61
62	link_t connected_phones; /*< Phones connected to this answerbox /	62	link_t connected_phones; /*< Phones connected to this answerbox /
63	link_t calls; /*< Received calls /	63	link_t calls; /*< Received calls /
64	link_t dispatched_calls; /* Should be hash table in the future */	64	link_t dispatched_calls; /* Should be hash table in the future */
65		65
66	link_t answers; /*< Answered calls /	66	link_t answers; /*< Answered calls /
67	};	67	};
68		68
69	typedef struct {	69	typedef struct {
70	SPINLOCK_DECLARE(lock);	70	SPINLOCK_DECLARE(lock);
71	link_t list;	71	link_t list;
72	answerbox_t *callee;	72	answerbox_t *callee;
73	} phone_t;	73	} phone_t;
74		74
75	extern void ipc_create_phonecompany(void);	75	extern void ipc_create_phonecompany(void);
76	extern void ipc_init(void);	76	extern void ipc_init(void);
77	extern call_t * ipc_wait_for_call(answerbox_t *box, int flags);	77	extern call_t * ipc_wait_for_call(answerbox_t *box, int flags);
78	extern void ipc_answer(answerbox_t box, call_t request);	78	extern void ipc_answer(answerbox_t box, call_t request);
79	extern void ipc_call(phone_t phone, call_t request);	79	extern void ipc_call(phone_t phone, call_t request);
-		80	extern void ipc_call_sync(phone_t phone, call_t request);
80	extern void ipc_phone_destroy(phone_t *phone);	81	extern void ipc_phone_destroy(phone_t *phone);
81	extern void ipc_phone_init(phone_t phone, answerbox_t box);	82	extern void ipc_phone_init(phone_t phone, answerbox_t box);
82	extern void ipc_call_free(call_t *call);	83	extern void ipc_call_free(call_t *call);
83	extern call_t * ipc_call_alloc(void);	84	extern call_t * ipc_call_alloc(void);
84	void ipc_answerbox_init(answerbox_t *box);	85	void ipc_answerbox_init(answerbox_t *box);
85	void ipc_phone_init(phone_t phone, answerbox_t box);	86	void ipc_phone_init(phone_t phone, answerbox_t box);
86		87
87	extern answerbox_t *ipc_central_box;	88	extern answerbox_t *ipc_central_box;
88		89
89	#endif	90	#endif
90		91
91	#endif	92	#endif
92		93

Subversion Repositories HelenOS

(root)/trunk/kernel/generic/include/ipc/ipc.h @ 3395 – Rev 955 → 959