source: mainline/uspace/srv/logger/ctl.c@ 8048931c

Last change on this file since 8048931c was f5837524, checked in by Jakub Jermar <jakub@…>, 7 years ago

Use user-defined labels instead of phone hashes

This commit changes the way how the async framework maps incomming calls
to connections. Instead of abusing the kernel addresses of attached
phones as identifiers, the IPC_M_CONNECT_TO_ME and IPC_M_CONNECT_ME_TO
messages allow the server to specify an arbitrary label which is
remembered in the connected phone and consequently imprinted on each
call which is routed through this phone.

The async framework uses the address of the connection structure as the
label. This removes the need for a connection hash table because each
incoming call already remembers the connection in its label.

To disambiguate this new label and the other user-defined label used for
answers, the call structure now has the request_label member for the
former and answer_label member for the latter.

This commit also moves the kernel definition of ipc_data_t to abi/ and
removes the uspace redefinition thereof. Finally, when forwarding the
IPC_M_CONNECT_TO_ME call, the phone capability and the kernel object
allocated in request_process are now correctly disposed of.

  • Property mode set to 100644
File size: 2.9 KB
Line 
1/*
2 * Copyright (c) 2012 Vojtech Horky
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/**
30 * @addtogroup logger
31 * @{
32 */
33
34/** @file
35 */
36
37#include <stdio.h>
38#include <stdlib.h>
39#include <errno.h>
40#include <io/logctl.h>
41#include <ipc/logger.h>
42#include <vfs/vfs.h>
43#include "logger.h"
44
45static errno_t handle_log_level_change(sysarg_t new_level)
46{
47 void *full_name;
48 errno_t rc = async_data_write_accept(&full_name, true, 0, 0, 0, NULL);
49 if (rc != EOK) {
50 return rc;
51 }
52
53 logger_log_t *log = find_log_by_name_and_lock(full_name);
54 free(full_name);
55 if (log == NULL)
56 return ENOENT;
57
58 log->logged_level = new_level;
59
60 log_unlock(log);
61
62 return EOK;
63}
64
65void logger_connection_handler_control(ipc_call_t *icall)
66{
67 errno_t rc;
68 int fd;
69
70 async_answer_5(icall, EOK, 0, 0, 0, 0, async_get_label());
71 logger_log("control: new client.\n");
72
73 while (true) {
74 ipc_call_t call;
75 async_get_call(&call);
76
77 if (!IPC_GET_IMETHOD(call)) {
78 async_answer_0(&call, EOK);
79 break;
80 }
81
82 switch (IPC_GET_IMETHOD(call)) {
83 case LOGGER_CONTROL_SET_DEFAULT_LEVEL:
84 rc = set_default_logging_level(IPC_GET_ARG1(call));
85 async_answer_0(&call, rc);
86 break;
87 case LOGGER_CONTROL_SET_LOG_LEVEL:
88 rc = handle_log_level_change(IPC_GET_ARG1(call));
89 async_answer_0(&call, rc);
90 break;
91 case LOGGER_CONTROL_SET_ROOT:
92 rc = vfs_receive_handle(true, &fd);
93 if (rc == EOK) {
94 rc = vfs_root_set(fd);
95 vfs_put(fd);
96 }
97 async_answer_0(&call, rc);
98 break;
99 default:
100 async_answer_0(&call, EINVAL);
101 break;
102 }
103 }
104
105 logger_log("control: client terminated.\n");
106}
107
108/**
109 * @}
110 */
Note: See TracBrowser for help on using the repository browser.