source: mainline/uspace/lib/c/generic/ns.c@ b688fd8

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since b688fd8 was b688fd8, checked in by Martin Decky <martin@…>, 10 years ago

gradually introduce async ports, initial phase

The initial phase is to reimplement the traditional async client connections as an untyped fallback port. This creates the possibility to introduce ports typed by interface type gradually in later changesets.

  • Property mode set to 100644
File size: 4.2 KB
Line 
1/*
2 * Copyright (c) 2011 Martin Decky
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 libc
30 * @{
31 */
32/** @file
33 */
34
35#include <ns.h>
36#include <ipc/ns.h>
37#include <async.h>
38#include <macros.h>
39#include <errno.h>
40#include "private/ns.h"
41
42int service_register(sysarg_t service)
43{
44 async_exch_t *exch = async_exchange_begin(session_ns);
45 int rc = async_connect_to_me(exch, service, 0, 0, NULL, NULL);
46 async_exchange_end(exch);
47
48 return rc;
49}
50
51async_sess_t *service_connect(exch_mgmt_t mgmt, services_t service, sysarg_t arg2,
52 sysarg_t arg3)
53{
54 async_exch_t *exch = async_exchange_begin(session_ns);
55 if (!exch)
56 return NULL;
57
58 async_sess_t *sess =
59 async_connect_me_to(mgmt, exch, service, arg2, arg3);
60 async_exchange_end(exch);
61
62 if (!sess)
63 return NULL;
64
65 /*
66 * FIXME Ugly hack to work around limitation of implementing
67 * parallel exchanges using multiple connections. Shift out
68 * first argument for non-initial connections.
69 */
70 async_sess_args_set(sess, arg2, arg3, 0);
71
72 return sess;
73}
74
75async_sess_t *service_connect_blocking(exch_mgmt_t mgmt, services_t service,
76 sysarg_t arg2, sysarg_t arg3)
77{
78 async_exch_t *exch = async_exchange_begin(session_ns);
79 if (!exch)
80 return NULL;
81 async_sess_t *sess =
82 async_connect_me_to_blocking(mgmt, exch, service, arg2, arg3);
83 async_exchange_end(exch);
84
85 if (!sess)
86 return NULL;
87
88 /*
89 * FIXME Ugly hack to work around limitation of implementing
90 * parallel exchanges using multiple connections. Shift out
91 * first argument for non-initial connections.
92 */
93 async_sess_args_set(sess, arg2, arg3, 0);
94
95 return sess;
96}
97
98/** Create bidirectional connection with a service
99 *
100 * @param[in] service Service.
101 * @param[in] arg1 First parameter.
102 * @param[in] arg2 Second parameter.
103 * @param[in] arg3 Third parameter.
104 * @param[in] client_receiver Message receiver.
105 *
106 * @return Session to the service.
107 * @return Other error codes as defined by async_connect_to_me().
108 *
109 */
110async_sess_t *service_bind(services_t service, sysarg_t arg1, sysarg_t arg2,
111 sysarg_t arg3, async_port_handler_t client_receiver)
112{
113 /* Connect to the needed service */
114 async_sess_t *sess =
115 service_connect_blocking(EXCHANGE_SERIALIZE, service, 0, 0);
116 if (sess != NULL) {
117 /* Request callback connection */
118 async_exch_t *exch = async_exchange_begin(sess);
119 int rc = async_connect_to_me(exch, arg1, arg2, arg3,
120 client_receiver, NULL);
121 async_exchange_end(exch);
122
123 if (rc != EOK) {
124 async_hangup(sess);
125 errno = rc;
126 return NULL;
127 }
128 }
129
130 return sess;
131}
132
133int ns_ping(void)
134{
135 async_exch_t *exch = async_exchange_begin(session_ns);
136 int rc = async_req_0_0(exch, NS_PING);
137 async_exchange_end(exch);
138
139 return rc;
140}
141
142int ns_intro(task_id_t id)
143{
144 async_exch_t *exch = async_exchange_begin(session_ns);
145 int rc = async_req_2_0(exch, NS_ID_INTRO, LOWER32(id), UPPER32(id));
146 async_exchange_end(exch);
147
148 return rc;
149}
150
151/** @}
152 */
Note: See TracBrowser for help on using the repository browser.