Subversion Repositories HelenOS

Rev

Rev 4618 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
1335 jermar 1
/*
2071 jermar 2
 * Copyright (c) 2006 Ondrej Palkovsky
1335 jermar 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
 
1740 jermar 29
/** @addtogroup ns
1649 cejka 30
 * @{
4008 decky 31
 */
1649 cejka 32
 
1335 jermar 33
/**
4008 decky 34
 * @file  ns.c
35
 * @brief Naming service for HelenOS IPC.
1335 jermar 36
 */
37
 
1353 jermar 38
#include <ipc/ipc.h>
4459 decky 39
#include <ipc/services.h>
1353 jermar 40
#include <ipc/ns.h>
4459 decky 41
#include <unistd.h>
1030 palkovsky 42
#include <stdio.h>
43
#include <errno.h>
4459 decky 44
#include <as.h>
1435 palkovsky 45
#include <ddi.h>
4459 decky 46
#include <event.h>
47
#include <macros.h>
4496 decky 48
#include <sysinfo.h>
4459 decky 49
#include "ns.h"
50
#include "service.h"
51
#include "clonable.h"
52
#include "task.h"
1335 jermar 53
 
4008 decky 54
static void *clockaddr = NULL;
55
static void *klogaddr = NULL;
56
 
4459 decky 57
static void get_as_area(ipc_callid_t callid, ipc_call_t *call, void *ph_addr,
58
    size_t pages, void **addr)
3896 svoboda 59
{
4253 decky 60
    if (ph_addr == NULL) {
61
        ipc_answer_0(callid, ENOENT);
62
        return;
63
    }
3908 decky 64
 
4253 decky 65
    if (*addr == NULL) {
66
        *addr = as_get_mappable_page(pages * PAGE_SIZE);
67
 
68
        if (*addr == NULL) {
2619 jermar 69
            ipc_answer_0(callid, ENOENT);
1435 palkovsky 70
            return;
71
        }
4253 decky 72
 
73
        if (physmem_map(ph_addr, *addr, pages,
3908 decky 74
            AS_AREA_READ | AS_AREA_CACHEABLE) != 0) {
75
            ipc_answer_0(callid, ENOENT);
76
            return;
77
        }
1435 palkovsky 78
    }
4253 decky 79
 
2619 jermar 80
    ipc_answer_2(callid, EOK, (ipcarg_t) *addr, AS_AREA_READ);
1435 palkovsky 81
}
82
 
1030 palkovsky 83
int main(int argc, char **argv)
84
{
3083 decky 85
    printf(NAME ": HelenOS IPC Naming Service\n");
86
 
4459 decky 87
    int rc = service_init();
88
    if (rc != EOK)
89
        return rc;
4008 decky 90
 
4459 decky 91
    rc = clonable_init();
92
    if (rc != EOK)
93
        return rc;
3083 decky 94
 
4459 decky 95
    rc = task_init();
96
    if (rc != EOK)
97
        return rc;
98
 
3083 decky 99
    printf(NAME ": Accepting connections\n");
4459 decky 100
 
4008 decky 101
    while (true) {
4459 decky 102
        process_pending_conn();
103
        process_pending_wait();
4008 decky 104
 
105
        ipc_call_t call;
106
        ipc_callid_t callid = ipc_wait_for_call(&call);
4459 decky 107
 
108
        task_id_t id;
4008 decky 109
        ipcarg_t retval;
110
 
1091 palkovsky 111
        switch (IPC_GET_METHOD(call)) {
2677 jermar 112
        case IPC_M_SHARE_IN:
1596 palkovsky 113
            switch (IPC_GET_ARG3(call)) {
114
            case SERVICE_MEM_REALTIME:
4459 decky 115
                get_as_area(callid, &call,
116
                    (void *) sysinfo_value("clock.faddr"),
117
                    1, &clockaddr);
1596 palkovsky 118
                break;
119
            case SERVICE_MEM_KLOG:
4459 decky 120
                get_as_area(callid, &call,
121
                    (void *) sysinfo_value("klog.faddr"),
122
                    sysinfo_value("klog.pages"), &klogaddr);
1596 palkovsky 123
                break;
124
            default:
2619 jermar 125
                ipc_answer_0(callid, ENOENT);
1596 palkovsky 126
            }
1435 palkovsky 127
            continue;
1089 palkovsky 128
        case IPC_M_PHONE_HUNGUP:
4618 svoboda 129
            retval = ns_task_disconnect(&call);
1089 palkovsky 130
            break;
1336 jermar 131
        case IPC_M_CONNECT_TO_ME:
1335 jermar 132
            /*
1336 jermar 133
             * Server requests service registration.
1335 jermar 134
             */
3896 svoboda 135
            if (service_clonable(IPC_GET_ARG1(call))) {
136
                register_clonable(IPC_GET_ARG1(call),
137
                    IPC_GET_ARG5(call), &call, callid);
138
                continue;
139
            } else {
140
                retval = register_service(IPC_GET_ARG1(call),
141
                    IPC_GET_ARG5(call), &call);
142
            }
1030 palkovsky 143
            break;
1089 palkovsky 144
        case IPC_M_CONNECT_ME_TO:
1336 jermar 145
            /*
146
             * Client requests to be connected to a service.
147
             */
3896 svoboda 148
            if (service_clonable(IPC_GET_ARG1(call))) {
149
                connect_to_clonable(IPC_GET_ARG1(call),
150
                    &call, callid);
151
                continue;
152
            } else {
4008 decky 153
                connect_to_service(IPC_GET_ARG1(call), &call,
154
                    callid);
155
                continue;
3896 svoboda 156
            }
1061 palkovsky 157
            break;
4459 decky 158
        case NS_PING:
159
            retval = EOK;
160
            break;
161
        case NS_TASK_WAIT:
162
            id = (task_id_t)
163
                MERGE_LOUP32(IPC_GET_ARG1(call), IPC_GET_ARG2(call));
164
            wait_for_task(id, &call, callid);
165
            continue;
4618 svoboda 166
        case NS_ID_INTRO:
167
            retval = ns_task_id_intro(&call);
168
            break;
4617 svoboda 169
        case NS_RETVAL:
170
            retval = ns_task_retval(&call);
171
            break;
1030 palkovsky 172
        default:
173
            retval = ENOENT;
174
            break;
175
        }
4008 decky 176
 
177
        if (!(callid & IPC_CALLID_NOTIFICATION))
2619 jermar 178
            ipc_answer_0(callid, retval);
1030 palkovsky 179
    }
3083 decky 180
 
181
    /* Not reached */
182
    return 0;
1030 palkovsky 183
}
1335 jermar 184
 
4008 decky 185
/**
1649 cejka 186
 * @}
187
 */