WebSVN – HelenOS – Blame – //branches/dd/uspace/srv/ns/ns.c

Rev	Author	Line No.	Line
4419	trochtova	1	/*
		2	* Copyright (c) 2006 Ondrej Palkovsky
		3	* All rights reserved.
		4	*
		5	* Redistribution and use in source and binary forms, with or without
		6	* modification, are permitted provided that the following conditions
		7	* are met:
		8	*
		9	* - Redistributions of source code must retain the above copyright
		10	* notice, this list of conditions and the following disclaimer.
		11	* - Redistributions in binary form must reproduce the above copyright
		12	* notice, this list of conditions and the following disclaimer in the
		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
		15	* derived from this software without specific prior written permission.
		16	*
		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
		19	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
		20	* IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
		21	* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
		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
		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
		26	* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
		27	*/
		28
		29	/** @addtogroup ns
		30	* @{
		31	*/
		32
		33	/**
		34	* @file ns.c
		35	* @brief Naming service for HelenOS IPC.
		36	*/
		37
		38	#include <ipc/ipc.h>
4537	trochtova	39	#include <ipc/services.h>
4419	trochtova	40	#include <ipc/ns.h>
4537	trochtova	41	#include <unistd.h>
4419	trochtova	42	#include <stdio.h>
		43	#include <errno.h>
4537	trochtova	44	#include <as.h>
		45	#include <ddi.h>
		46	#include <event.h>
		47	#include <macros.h>
4419	trochtova	48	#include <sysinfo.h>
4537	trochtova	49	#include "ns.h"
		50	#include "service.h"
		51	#include "clonable.h"
		52	#include "task.h"
4419	trochtova	53
		54	static void *clockaddr = NULL;
		55	static void *klogaddr = NULL;
		56
4537	trochtova	57	static void get_as_area(ipc_callid_t callid, ipc_call_t call, void ph_addr,
		58	size_t pages, void **addr)
4419	trochtova	59	{
		60	if (ph_addr == NULL) {
		61	ipc_answer_0(callid, ENOENT);
		62	return;
		63	}
		64
		65	if (*addr == NULL) {
		66	addr = as_get_mappable_page(pages PAGE_SIZE);
		67
		68	if (*addr == NULL) {
		69	ipc_answer_0(callid, ENOENT);
		70	return;
		71	}
		72
		73	if (physmem_map(ph_addr, *addr, pages,
		74	AS_AREA_READ \| AS_AREA_CACHEABLE) != 0) {
		75	ipc_answer_0(callid, ENOENT);
		76	return;
		77	}
		78	}
		79
		80	ipc_answer_2(callid, EOK, (ipcarg_t) *addr, AS_AREA_READ);
		81	}
		82
		83	int main(int argc, char **argv)
		84	{
		85	printf(NAME ": HelenOS IPC Naming Service\n");
		86
4537	trochtova	87	int rc = service_init();
		88	if (rc != EOK)
		89	return rc;
4419	trochtova	90
4537	trochtova	91	rc = clonable_init();
		92	if (rc != EOK)
		93	return rc;
4419	trochtova	94
4537	trochtova	95	rc = task_init();
		96	if (rc != EOK)
		97	return rc;
		98
4419	trochtova	99	printf(NAME ": Accepting connections\n");
4537	trochtova	100
4419	trochtova	101	while (true) {
4537	trochtova	102	process_pending_conn();
		103	process_pending_wait();
4419	trochtova	104
		105	ipc_call_t call;
		106	ipc_callid_t callid = ipc_wait_for_call(&call);
4537	trochtova	107
		108	task_id_t id;
4419	trochtova	109	ipcarg_t retval;
		110
4537	trochtova	111	if (callid & IPC_CALLID_NOTIFICATION) {
		112	id = (task_id_t)
		113	MERGE_LOUP32(IPC_GET_ARG2(call), IPC_GET_ARG3(call));
		114	wait_notification((wait_type_t) IPC_GET_ARG1(call), id);
		115	continue;
		116	}
		117
4419	trochtova	118	switch (IPC_GET_METHOD(call)) {
		119	case IPC_M_SHARE_IN:
		120	switch (IPC_GET_ARG3(call)) {
		121	case SERVICE_MEM_REALTIME:
4537	trochtova	122	get_as_area(callid, &call,
		123	(void *) sysinfo_value("clock.faddr"),
		124	1, &clockaddr);
4419	trochtova	125	break;
		126	case SERVICE_MEM_KLOG:
4537	trochtova	127	get_as_area(callid, &call,
		128	(void *) sysinfo_value("klog.faddr"),
		129	sysinfo_value("klog.pages"), &klogaddr);
4419	trochtova	130	break;
		131	default:
		132	ipc_answer_0(callid, ENOENT);
		133	}
		134	continue;
		135	case IPC_M_PHONE_HUNGUP:
		136	retval = EOK;
		137	break;
		138	case IPC_M_CONNECT_TO_ME:
		139	/*
		140	* Server requests service registration.
		141	*/
		142	if (service_clonable(IPC_GET_ARG1(call))) {
		143	register_clonable(IPC_GET_ARG1(call),
		144	IPC_GET_ARG5(call), &call, callid);
		145	continue;
		146	} else {
		147	retval = register_service(IPC_GET_ARG1(call),
		148	IPC_GET_ARG5(call), &call);
		149	}
		150	break;
		151	case IPC_M_CONNECT_ME_TO:
		152	/*
		153	* Client requests to be connected to a service.
		154	*/
		155	if (service_clonable(IPC_GET_ARG1(call))) {
		156	connect_to_clonable(IPC_GET_ARG1(call),
		157	&call, callid);
		158	continue;
		159	} else {
		160	connect_to_service(IPC_GET_ARG1(call), &call,
		161	callid);
		162	continue;
		163	}
		164	break;
4537	trochtova	165	case NS_PING:
		166	retval = EOK;
		167	break;
		168	case NS_TASK_WAIT:
		169	id = (task_id_t)
		170	MERGE_LOUP32(IPC_GET_ARG1(call), IPC_GET_ARG2(call));
		171	wait_for_task(id, &call, callid);
		172	continue;
4419	trochtova	173	default:
		174	retval = ENOENT;
		175	break;
		176	}
		177
		178	if (!(callid & IPC_CALLID_NOTIFICATION))
		179	ipc_answer_0(callid, retval);
		180	}
		181
		182	/* Not reached */
		183	return 0;
		184	}
		185
		186	/**
		187	* @}
		188	*/

Subversion Repositories HelenOS

(root)//branches/dd/uspace/srv/ns/ns.c – Rev 4537