1e72055b7SXin LI /*-
293b4e111SSepherosa Ziehau * Copyright (c) 2014,2016-2017 Microsoft Corp.
3e72055b7SXin LI * All rights reserved.
4e72055b7SXin LI *
5e72055b7SXin LI * Redistribution and use in source and binary forms, with or without
6e72055b7SXin LI * modification, are permitted provided that the following conditions
7e72055b7SXin LI * are met:
8e72055b7SXin LI * 1. Redistributions of source code must retain the above copyright
9e72055b7SXin LI * notice unmodified, this list of conditions, and the following
10e72055b7SXin LI * disclaimer.
11e72055b7SXin LI * 2. Redistributions in binary form must reproduce the above copyright
12e72055b7SXin LI * notice, this list of conditions and the following disclaimer in the
13e72055b7SXin LI * documentation and/or other materials provided with the distribution.
14e72055b7SXin LI *
15e72055b7SXin LI * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
16e72055b7SXin LI * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
17e72055b7SXin LI * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
18e72055b7SXin LI * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
19e72055b7SXin LI * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
20e72055b7SXin LI * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
21e72055b7SXin LI * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
22e72055b7SXin LI * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
23e72055b7SXin LI * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
24e72055b7SXin LI * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
25e72055b7SXin LI */
26e72055b7SXin LI
27e72055b7SXin LI /*
28e72055b7SXin LI * Author: Sainath Varanasi.
29e72055b7SXin LI * Date: 4/2012
30e72055b7SXin LI * Email: bsdic@microsoft.com
31e72055b7SXin LI */
32e72055b7SXin LI
33e72055b7SXin LI #include <sys/param.h>
34e72055b7SXin LI #include <sys/kernel.h>
35e72055b7SXin LI #include <sys/conf.h>
36e72055b7SXin LI #include <sys/uio.h>
37e72055b7SXin LI #include <sys/bus.h>
38e72055b7SXin LI #include <sys/malloc.h>
39e72055b7SXin LI #include <sys/mbuf.h>
40e72055b7SXin LI #include <sys/module.h>
41e72055b7SXin LI #include <sys/reboot.h>
42e72055b7SXin LI #include <sys/lock.h>
43e72055b7SXin LI #include <sys/taskqueue.h>
44f3b0813aSRoger Pau Monné #include <sys/selinfo.h>
45e72055b7SXin LI #include <sys/sysctl.h>
46e72055b7SXin LI #include <sys/poll.h>
47e72055b7SXin LI #include <sys/proc.h>
48e72055b7SXin LI #include <sys/kthread.h>
49e72055b7SXin LI #include <sys/syscallsubr.h>
50e72055b7SXin LI #include <sys/sysproto.h>
51e72055b7SXin LI #include <sys/un.h>
52e72055b7SXin LI #include <sys/endian.h>
53e72055b7SXin LI #include <sys/_null.h>
54eacbe924SSepherosa Ziehau #include <sys/sema.h>
55e72055b7SXin LI #include <sys/signal.h>
56e72055b7SXin LI #include <sys/syslog.h>
57da2f98a1SWei Hu #include <sys/systm.h>
58e72055b7SXin LI #include <sys/mutex.h>
597f9e539eSSepherosa Ziehau
60e72055b7SXin LI #include <dev/hyperv/include/hyperv.h>
615bf51473SSepherosa Ziehau #include <dev/hyperv/include/vmbus.h>
624cd995ffSSepherosa Ziehau #include <dev/hyperv/utilities/hv_utilreg.h>
635bf51473SSepherosa Ziehau #include <dev/hyperv/utilities/vmbus_icreg.h>
64ed8107d1SSepherosa Ziehau #include <dev/hyperv/utilities/vmbus_icvar.h>
65e72055b7SXin LI
66e72055b7SXin LI #include "unicode.h"
67e72055b7SXin LI #include "hv_kvp.h"
68884d26c8SSepherosa Ziehau #include "vmbus_if.h"
69e72055b7SXin LI
70e72055b7SXin LI /* hv_kvp defines */
71e72055b7SXin LI #define BUFFERSIZE sizeof(struct hv_kvp_msg)
72e72055b7SXin LI #define kvp_hdr hdr.kvp_hdr
73e72055b7SXin LI
745bf51473SSepherosa Ziehau #define KVP_FWVER_MAJOR 3
755bf51473SSepherosa Ziehau #define KVP_FWVER VMBUS_IC_VERSION(KVP_FWVER_MAJOR, 0)
765bf51473SSepherosa Ziehau
775bf51473SSepherosa Ziehau #define KVP_MSGVER_MAJOR 4
785bf51473SSepherosa Ziehau #define KVP_MSGVER VMBUS_IC_VERSION(KVP_MSGVER_MAJOR, 0)
795bf51473SSepherosa Ziehau
80e72055b7SXin LI /* hv_kvp debug control */
81e72055b7SXin LI static int hv_kvp_log = 0;
82e72055b7SXin LI
83e72055b7SXin LI #define hv_kvp_log_error(...) do { \
84e72055b7SXin LI if (hv_kvp_log > 0) \
85e72055b7SXin LI log(LOG_ERR, "hv_kvp: " __VA_ARGS__); \
86e72055b7SXin LI } while (0)
87e72055b7SXin LI
88e72055b7SXin LI #define hv_kvp_log_info(...) do { \
89e72055b7SXin LI if (hv_kvp_log > 1) \
90e72055b7SXin LI log(LOG_INFO, "hv_kvp: " __VA_ARGS__); \
91e72055b7SXin LI } while (0)
92e72055b7SXin LI
93c4b78a26SSepherosa Ziehau static const struct vmbus_ic_desc vmbus_kvp_descs[] = {
94c4b78a26SSepherosa Ziehau {
95c4b78a26SSepherosa Ziehau .ic_guid = { .hv_guid = {
96c4b78a26SSepherosa Ziehau 0xe7, 0xf4, 0xa0, 0xa9, 0x45, 0x5a, 0x96, 0x4d,
97c4b78a26SSepherosa Ziehau 0xb8, 0x27, 0x8a, 0x84, 0x1e, 0x8c, 0x3, 0xe6 } },
98c4b78a26SSepherosa Ziehau .ic_desc = "Hyper-V KVP"
99c4b78a26SSepherosa Ziehau },
100c4b78a26SSepherosa Ziehau VMBUS_IC_DESC_END
101c4b78a26SSepherosa Ziehau };
1020bc2abddSSepherosa Ziehau
103e72055b7SXin LI /* character device prototypes */
104e72055b7SXin LI static d_open_t hv_kvp_dev_open;
105e72055b7SXin LI static d_close_t hv_kvp_dev_close;
106e72055b7SXin LI static d_read_t hv_kvp_dev_daemon_read;
107e72055b7SXin LI static d_write_t hv_kvp_dev_daemon_write;
108e72055b7SXin LI static d_poll_t hv_kvp_dev_daemon_poll;
109e72055b7SXin LI
110e72055b7SXin LI /* hv_kvp character device structure */
111e72055b7SXin LI static struct cdevsw hv_kvp_cdevsw =
112e72055b7SXin LI {
113e72055b7SXin LI .d_version = D_VERSION,
114e72055b7SXin LI .d_open = hv_kvp_dev_open,
115e72055b7SXin LI .d_close = hv_kvp_dev_close,
116e72055b7SXin LI .d_read = hv_kvp_dev_daemon_read,
117e72055b7SXin LI .d_write = hv_kvp_dev_daemon_write,
118e72055b7SXin LI .d_poll = hv_kvp_dev_daemon_poll,
119e72055b7SXin LI .d_name = "hv_kvp_dev",
120e72055b7SXin LI };
121e72055b7SXin LI
122f3b0813aSRoger Pau Monné
123e72055b7SXin LI /*
124e72055b7SXin LI * Global state to track and synchronize multiple
125e72055b7SXin LI * KVP transaction requests from the host.
126e72055b7SXin LI */
1270bc2abddSSepherosa Ziehau typedef struct hv_kvp_sc {
1281eb6d711SSepherosa Ziehau struct vmbus_ic_softc util_sc;
129ca871fb7SSepherosa Ziehau device_t dev;
130e72055b7SXin LI
131e72055b7SXin LI /* Unless specified the pending mutex should be
132453130d9SPedro F. Giffuni * used to alter the values of the following parameters:
133e72055b7SXin LI * 1. req_in_progress
134e72055b7SXin LI * 2. req_timed_out
135e72055b7SXin LI */
136e72055b7SXin LI struct mtx pending_mutex;
137e72055b7SXin LI
1380bc2abddSSepherosa Ziehau struct task task;
1390bc2abddSSepherosa Ziehau
140e72055b7SXin LI /* To track if transaction is active or not */
141e72055b7SXin LI boolean_t req_in_progress;
142e72055b7SXin LI /* Tracks if daemon did not reply back in time */
143e72055b7SXin LI boolean_t req_timed_out;
144e72055b7SXin LI /* Tracks if daemon is serving a request currently */
145e72055b7SXin LI boolean_t daemon_busy;
146e72055b7SXin LI
147e72055b7SXin LI /* Length of host message */
148e72055b7SXin LI uint32_t host_msg_len;
149e72055b7SXin LI
150e72055b7SXin LI /* Host message id */
151e72055b7SXin LI uint64_t host_msg_id;
152e72055b7SXin LI
153e72055b7SXin LI /* Current kvp message from the host */
154e72055b7SXin LI struct hv_kvp_msg *host_kvp_msg;
155e72055b7SXin LI
156e72055b7SXin LI /* Current kvp message for daemon */
157e72055b7SXin LI struct hv_kvp_msg daemon_kvp_msg;
158e72055b7SXin LI
159e72055b7SXin LI /* Rcv buffer for communicating with the host*/
160e72055b7SXin LI uint8_t *rcv_buf;
161e72055b7SXin LI
162e72055b7SXin LI /* Device semaphore to control communication */
163e72055b7SXin LI struct sema dev_sema;
164e72055b7SXin LI
165e72055b7SXin LI /* Indicates if daemon registered with driver */
166e72055b7SXin LI boolean_t register_done;
167e72055b7SXin LI
168e72055b7SXin LI /* Character device status */
169e72055b7SXin LI boolean_t dev_accessed;
170e72055b7SXin LI
1710bc2abddSSepherosa Ziehau struct cdev *hv_kvp_dev;
1720bc2abddSSepherosa Ziehau
1730bc2abddSSepherosa Ziehau struct proc *daemon_task;
1740bc2abddSSepherosa Ziehau
1750bc2abddSSepherosa Ziehau struct selinfo hv_kvp_selinfo;
1760bc2abddSSepherosa Ziehau } hv_kvp_sc;
1770bc2abddSSepherosa Ziehau
1780bc2abddSSepherosa Ziehau /* hv_kvp prototypes */
1790bc2abddSSepherosa Ziehau static int hv_kvp_req_in_progress(hv_kvp_sc *sc);
1800bc2abddSSepherosa Ziehau static void hv_kvp_transaction_init(hv_kvp_sc *sc, uint32_t, uint64_t, uint8_t *);
1810bc2abddSSepherosa Ziehau static void hv_kvp_send_msg_to_daemon(hv_kvp_sc *sc);
1820bc2abddSSepherosa Ziehau static void hv_kvp_process_request(void *context, int pending);
183e72055b7SXin LI
184e72055b7SXin LI /*
185e72055b7SXin LI * hv_kvp low level functions
186e72055b7SXin LI */
187e72055b7SXin LI
188e72055b7SXin LI /*
189e72055b7SXin LI * Check if kvp transaction is in progres
190e72055b7SXin LI */
191e72055b7SXin LI static int
hv_kvp_req_in_progress(hv_kvp_sc * sc)1920bc2abddSSepherosa Ziehau hv_kvp_req_in_progress(hv_kvp_sc *sc)
193e72055b7SXin LI {
194e72055b7SXin LI
1950bc2abddSSepherosa Ziehau return (sc->req_in_progress);
196e72055b7SXin LI }
197e72055b7SXin LI
198e72055b7SXin LI
199e72055b7SXin LI /*
200e72055b7SXin LI * This routine is called whenever a message is received from the host
201e72055b7SXin LI */
202e72055b7SXin LI static void
hv_kvp_transaction_init(hv_kvp_sc * sc,uint32_t rcv_len,uint64_t request_id,uint8_t * rcv_buf)2030bc2abddSSepherosa Ziehau hv_kvp_transaction_init(hv_kvp_sc *sc, uint32_t rcv_len,
204e72055b7SXin LI uint64_t request_id, uint8_t *rcv_buf)
205e72055b7SXin LI {
206e72055b7SXin LI
207e72055b7SXin LI /* Store all the relevant message details in the global structure */
208e72055b7SXin LI /* Do not need to use mutex for req_in_progress here */
2090bc2abddSSepherosa Ziehau sc->req_in_progress = true;
2100bc2abddSSepherosa Ziehau sc->host_msg_len = rcv_len;
2110bc2abddSSepherosa Ziehau sc->host_msg_id = request_id;
2120bc2abddSSepherosa Ziehau sc->rcv_buf = rcv_buf;
2130bc2abddSSepherosa Ziehau sc->host_kvp_msg = (struct hv_kvp_msg *)&rcv_buf[
214e72055b7SXin LI sizeof(struct hv_vmbus_pipe_hdr) +
215e72055b7SXin LI sizeof(struct hv_vmbus_icmsg_hdr)];
216e72055b7SXin LI }
217e72055b7SXin LI
218e72055b7SXin LI /*
219e72055b7SXin LI * Convert ip related info in umsg from utf8 to utf16 and store in hmsg
220e72055b7SXin LI */
221e72055b7SXin LI static int
hv_kvp_convert_utf8_ipinfo_to_utf16(struct hv_kvp_msg * umsg,struct hv_kvp_ip_msg * host_ip_msg)222e72055b7SXin LI hv_kvp_convert_utf8_ipinfo_to_utf16(struct hv_kvp_msg *umsg,
223e72055b7SXin LI struct hv_kvp_ip_msg *host_ip_msg)
224e72055b7SXin LI {
225e72055b7SXin LI int err_ip, err_subnet, err_gway, err_dns, err_adap;
226e72055b7SXin LI int UNUSED_FLAG = 1;
227e72055b7SXin LI
228e72055b7SXin LI utf8_to_utf16((uint16_t *)host_ip_msg->kvp_ip_val.ip_addr,
229e72055b7SXin LI MAX_IP_ADDR_SIZE,
230e72055b7SXin LI (char *)umsg->body.kvp_ip_val.ip_addr,
231e72055b7SXin LI strlen((char *)umsg->body.kvp_ip_val.ip_addr),
232e72055b7SXin LI UNUSED_FLAG,
233e72055b7SXin LI &err_ip);
234e72055b7SXin LI utf8_to_utf16((uint16_t *)host_ip_msg->kvp_ip_val.sub_net,
235e72055b7SXin LI MAX_IP_ADDR_SIZE,
236e72055b7SXin LI (char *)umsg->body.kvp_ip_val.sub_net,
237e72055b7SXin LI strlen((char *)umsg->body.kvp_ip_val.sub_net),
238e72055b7SXin LI UNUSED_FLAG,
239e72055b7SXin LI &err_subnet);
240e72055b7SXin LI utf8_to_utf16((uint16_t *)host_ip_msg->kvp_ip_val.gate_way,
241e72055b7SXin LI MAX_GATEWAY_SIZE,
242e72055b7SXin LI (char *)umsg->body.kvp_ip_val.gate_way,
243e72055b7SXin LI strlen((char *)umsg->body.kvp_ip_val.gate_way),
244e72055b7SXin LI UNUSED_FLAG,
245e72055b7SXin LI &err_gway);
246e72055b7SXin LI utf8_to_utf16((uint16_t *)host_ip_msg->kvp_ip_val.dns_addr,
247e72055b7SXin LI MAX_IP_ADDR_SIZE,
248e72055b7SXin LI (char *)umsg->body.kvp_ip_val.dns_addr,
249e72055b7SXin LI strlen((char *)umsg->body.kvp_ip_val.dns_addr),
250e72055b7SXin LI UNUSED_FLAG,
251e72055b7SXin LI &err_dns);
252e72055b7SXin LI utf8_to_utf16((uint16_t *)host_ip_msg->kvp_ip_val.adapter_id,
253fe167cceSSepherosa Ziehau MAX_ADAPTER_ID_SIZE,
254e72055b7SXin LI (char *)umsg->body.kvp_ip_val.adapter_id,
255e72055b7SXin LI strlen((char *)umsg->body.kvp_ip_val.adapter_id),
256e72055b7SXin LI UNUSED_FLAG,
257e72055b7SXin LI &err_adap);
258e72055b7SXin LI
259e72055b7SXin LI host_ip_msg->kvp_ip_val.dhcp_enabled = umsg->body.kvp_ip_val.dhcp_enabled;
260e72055b7SXin LI host_ip_msg->kvp_ip_val.addr_family = umsg->body.kvp_ip_val.addr_family;
261e72055b7SXin LI
262e72055b7SXin LI return (err_ip | err_subnet | err_gway | err_dns | err_adap);
263e72055b7SXin LI }
264e72055b7SXin LI
265e72055b7SXin LI
266e72055b7SXin LI /*
267e72055b7SXin LI * Convert ip related info in hmsg from utf16 to utf8 and store in umsg
268e72055b7SXin LI */
269e72055b7SXin LI static int
hv_kvp_convert_utf16_ipinfo_to_utf8(struct hv_kvp_ip_msg * host_ip_msg,struct hv_kvp_msg * umsg)270e72055b7SXin LI hv_kvp_convert_utf16_ipinfo_to_utf8(struct hv_kvp_ip_msg *host_ip_msg,
271e72055b7SXin LI struct hv_kvp_msg *umsg)
272e72055b7SXin LI {
273e72055b7SXin LI int err_ip, err_subnet, err_gway, err_dns, err_adap;
274e72055b7SXin LI int UNUSED_FLAG = 1;
275e72055b7SXin LI device_t *devs;
276e72055b7SXin LI int devcnt;
277e72055b7SXin LI
278e72055b7SXin LI /* IP Address */
279e72055b7SXin LI utf16_to_utf8((char *)umsg->body.kvp_ip_val.ip_addr,
280e72055b7SXin LI MAX_IP_ADDR_SIZE,
281e72055b7SXin LI (uint16_t *)host_ip_msg->kvp_ip_val.ip_addr,
282e72055b7SXin LI MAX_IP_ADDR_SIZE,
283e72055b7SXin LI UNUSED_FLAG,
284e72055b7SXin LI &err_ip);
285e72055b7SXin LI
286e72055b7SXin LI /* Adapter ID : GUID */
287e72055b7SXin LI utf16_to_utf8((char *)umsg->body.kvp_ip_val.adapter_id,
288e72055b7SXin LI MAX_ADAPTER_ID_SIZE,
289e72055b7SXin LI (uint16_t *)host_ip_msg->kvp_ip_val.adapter_id,
290e72055b7SXin LI MAX_ADAPTER_ID_SIZE,
291e72055b7SXin LI UNUSED_FLAG,
292e72055b7SXin LI &err_adap);
293e72055b7SXin LI
294e72055b7SXin LI if (devclass_get_devices(devclass_find("hn"), &devs, &devcnt) == 0) {
295e72055b7SXin LI for (devcnt = devcnt - 1; devcnt >= 0; devcnt--) {
2962d19acf7SSepherosa Ziehau device_t dev = devs[devcnt];
29782b8a879SSepherosa Ziehau struct vmbus_channel *chan;
2982d19acf7SSepherosa Ziehau char buf[HYPERV_GUID_STRLEN];
29974decee8SSepherosa Ziehau int n;
30074decee8SSepherosa Ziehau
30174decee8SSepherosa Ziehau chan = vmbus_get_channel(dev);
30274decee8SSepherosa Ziehau n = hyperv_guid2str(vmbus_chan_guid_inst(chan), buf,
30374decee8SSepherosa Ziehau sizeof(buf));
304e72055b7SXin LI
3052d19acf7SSepherosa Ziehau /*
30674decee8SSepherosa Ziehau * The string in the 'kvp_ip_val.adapter_id' has
30774decee8SSepherosa Ziehau * braces around the GUID; skip the leading brace
30874decee8SSepherosa Ziehau * in 'kvp_ip_val.adapter_id'.
3092d19acf7SSepherosa Ziehau */
31074decee8SSepherosa Ziehau if (strncmp(buf,
31174decee8SSepherosa Ziehau ((char *)&umsg->body.kvp_ip_val.adapter_id) + 1,
31274decee8SSepherosa Ziehau n) == 0) {
3137f9e539eSSepherosa Ziehau strlcpy((char *)umsg->body.kvp_ip_val.adapter_id,
314eacbe924SSepherosa Ziehau device_get_nameunit(dev), MAX_ADAPTER_ID_SIZE);
315e72055b7SXin LI break;
316e72055b7SXin LI }
317e72055b7SXin LI }
318e72055b7SXin LI free(devs, M_TEMP);
319e72055b7SXin LI }
320e72055b7SXin LI
321e72055b7SXin LI /* Address Family , DHCP , SUBNET, Gateway, DNS */
322e72055b7SXin LI umsg->kvp_hdr.operation = host_ip_msg->operation;
323e72055b7SXin LI umsg->body.kvp_ip_val.addr_family = host_ip_msg->kvp_ip_val.addr_family;
324e72055b7SXin LI umsg->body.kvp_ip_val.dhcp_enabled = host_ip_msg->kvp_ip_val.dhcp_enabled;
325e72055b7SXin LI utf16_to_utf8((char *)umsg->body.kvp_ip_val.sub_net, MAX_IP_ADDR_SIZE,
326e72055b7SXin LI (uint16_t *)host_ip_msg->kvp_ip_val.sub_net,
327e72055b7SXin LI MAX_IP_ADDR_SIZE,
328e72055b7SXin LI UNUSED_FLAG,
329e72055b7SXin LI &err_subnet);
330e72055b7SXin LI
331e72055b7SXin LI utf16_to_utf8((char *)umsg->body.kvp_ip_val.gate_way, MAX_GATEWAY_SIZE,
332e72055b7SXin LI (uint16_t *)host_ip_msg->kvp_ip_val.gate_way,
333e72055b7SXin LI MAX_GATEWAY_SIZE,
334e72055b7SXin LI UNUSED_FLAG,
335e72055b7SXin LI &err_gway);
336e72055b7SXin LI
337e72055b7SXin LI utf16_to_utf8((char *)umsg->body.kvp_ip_val.dns_addr, MAX_IP_ADDR_SIZE,
338e72055b7SXin LI (uint16_t *)host_ip_msg->kvp_ip_val.dns_addr,
339e72055b7SXin LI MAX_IP_ADDR_SIZE,
340e72055b7SXin LI UNUSED_FLAG,
341e72055b7SXin LI &err_dns);
342e72055b7SXin LI
343e72055b7SXin LI return (err_ip | err_subnet | err_gway | err_dns | err_adap);
344e72055b7SXin LI }
345e72055b7SXin LI
346e72055b7SXin LI
347e72055b7SXin LI /*
348e72055b7SXin LI * Prepare a user kvp msg based on host kvp msg (utf16 to utf8)
349e72055b7SXin LI * Ensure utf16_utf8 takes care of the additional string terminating char!!
350e72055b7SXin LI */
351e72055b7SXin LI static void
hv_kvp_convert_hostmsg_to_usermsg(struct hv_kvp_msg * hmsg,struct hv_kvp_msg * umsg)3520bc2abddSSepherosa Ziehau hv_kvp_convert_hostmsg_to_usermsg(struct hv_kvp_msg *hmsg, struct hv_kvp_msg *umsg)
353e72055b7SXin LI {
354e72055b7SXin LI int utf_err = 0;
355e72055b7SXin LI uint32_t value_type;
3560bc2abddSSepherosa Ziehau struct hv_kvp_ip_msg *host_ip_msg;
357e72055b7SXin LI
3580bc2abddSSepherosa Ziehau host_ip_msg = (struct hv_kvp_ip_msg*)hmsg;
359e72055b7SXin LI memset(umsg, 0, sizeof(struct hv_kvp_msg));
360e72055b7SXin LI
361e72055b7SXin LI umsg->kvp_hdr.operation = hmsg->kvp_hdr.operation;
362e72055b7SXin LI umsg->kvp_hdr.pool = hmsg->kvp_hdr.pool;
363e72055b7SXin LI
364e72055b7SXin LI switch (umsg->kvp_hdr.operation) {
365e72055b7SXin LI case HV_KVP_OP_SET_IP_INFO:
366e72055b7SXin LI hv_kvp_convert_utf16_ipinfo_to_utf8(host_ip_msg, umsg);
367e72055b7SXin LI break;
368e72055b7SXin LI
369e72055b7SXin LI case HV_KVP_OP_GET_IP_INFO:
370e72055b7SXin LI utf16_to_utf8((char *)umsg->body.kvp_ip_val.adapter_id,
371e72055b7SXin LI MAX_ADAPTER_ID_SIZE,
372e72055b7SXin LI (uint16_t *)host_ip_msg->kvp_ip_val.adapter_id,
373e72055b7SXin LI MAX_ADAPTER_ID_SIZE, 1, &utf_err);
374e72055b7SXin LI
375e72055b7SXin LI umsg->body.kvp_ip_val.addr_family =
376e72055b7SXin LI host_ip_msg->kvp_ip_val.addr_family;
377e72055b7SXin LI break;
378e72055b7SXin LI
379e72055b7SXin LI case HV_KVP_OP_SET:
380e72055b7SXin LI value_type = hmsg->body.kvp_set.data.value_type;
381e72055b7SXin LI
382e72055b7SXin LI switch (value_type) {
383e72055b7SXin LI case HV_REG_SZ:
384e72055b7SXin LI umsg->body.kvp_set.data.value_size =
385e72055b7SXin LI utf16_to_utf8(
386e72055b7SXin LI (char *)umsg->body.kvp_set.data.msg_value.value,
387e72055b7SXin LI HV_KVP_EXCHANGE_MAX_VALUE_SIZE - 1,
388e72055b7SXin LI (uint16_t *)hmsg->body.kvp_set.data.msg_value.value,
389e72055b7SXin LI hmsg->body.kvp_set.data.value_size,
390e72055b7SXin LI 1, &utf_err);
391e72055b7SXin LI /* utf8 encoding */
392e72055b7SXin LI umsg->body.kvp_set.data.value_size =
393e72055b7SXin LI umsg->body.kvp_set.data.value_size / 2;
394e72055b7SXin LI break;
395e72055b7SXin LI
396e72055b7SXin LI case HV_REG_U32:
397e72055b7SXin LI umsg->body.kvp_set.data.value_size =
398e72055b7SXin LI sprintf(umsg->body.kvp_set.data.msg_value.value, "%d",
399e72055b7SXin LI hmsg->body.kvp_set.data.msg_value.value_u32) + 1;
400e72055b7SXin LI break;
401e72055b7SXin LI
402e72055b7SXin LI case HV_REG_U64:
403e72055b7SXin LI umsg->body.kvp_set.data.value_size =
404e72055b7SXin LI sprintf(umsg->body.kvp_set.data.msg_value.value, "%llu",
405e72055b7SXin LI (unsigned long long)
406e72055b7SXin LI hmsg->body.kvp_set.data.msg_value.value_u64) + 1;
407e72055b7SXin LI break;
408e72055b7SXin LI }
409e72055b7SXin LI
410e72055b7SXin LI umsg->body.kvp_set.data.key_size =
411e72055b7SXin LI utf16_to_utf8(
412e72055b7SXin LI umsg->body.kvp_set.data.key,
413e72055b7SXin LI HV_KVP_EXCHANGE_MAX_KEY_SIZE - 1,
414e72055b7SXin LI (uint16_t *)hmsg->body.kvp_set.data.key,
415e72055b7SXin LI hmsg->body.kvp_set.data.key_size,
416e72055b7SXin LI 1, &utf_err);
417e72055b7SXin LI
418e72055b7SXin LI /* utf8 encoding */
419e72055b7SXin LI umsg->body.kvp_set.data.key_size =
420e72055b7SXin LI umsg->body.kvp_set.data.key_size / 2;
421e72055b7SXin LI break;
422e72055b7SXin LI
423e72055b7SXin LI case HV_KVP_OP_GET:
424e72055b7SXin LI umsg->body.kvp_get.data.key_size =
425e72055b7SXin LI utf16_to_utf8(umsg->body.kvp_get.data.key,
426e72055b7SXin LI HV_KVP_EXCHANGE_MAX_KEY_SIZE - 1,
427e72055b7SXin LI (uint16_t *)hmsg->body.kvp_get.data.key,
428e72055b7SXin LI hmsg->body.kvp_get.data.key_size,
429e72055b7SXin LI 1, &utf_err);
430e72055b7SXin LI /* utf8 encoding */
431e72055b7SXin LI umsg->body.kvp_get.data.key_size =
432e72055b7SXin LI umsg->body.kvp_get.data.key_size / 2;
433e72055b7SXin LI break;
434e72055b7SXin LI
435e72055b7SXin LI case HV_KVP_OP_DELETE:
436e72055b7SXin LI umsg->body.kvp_delete.key_size =
437e72055b7SXin LI utf16_to_utf8(umsg->body.kvp_delete.key,
438e72055b7SXin LI HV_KVP_EXCHANGE_MAX_KEY_SIZE - 1,
439e72055b7SXin LI (uint16_t *)hmsg->body.kvp_delete.key,
440e72055b7SXin LI hmsg->body.kvp_delete.key_size,
441e72055b7SXin LI 1, &utf_err);
442e72055b7SXin LI /* utf8 encoding */
443e72055b7SXin LI umsg->body.kvp_delete.key_size =
444e72055b7SXin LI umsg->body.kvp_delete.key_size / 2;
445e72055b7SXin LI break;
446e72055b7SXin LI
447e72055b7SXin LI case HV_KVP_OP_ENUMERATE:
448e72055b7SXin LI umsg->body.kvp_enum_data.index =
449e72055b7SXin LI hmsg->body.kvp_enum_data.index;
450e72055b7SXin LI break;
451e72055b7SXin LI
452e72055b7SXin LI default:
453e72055b7SXin LI hv_kvp_log_info("%s: daemon_kvp_msg: Invalid operation : %d\n",
454e72055b7SXin LI __func__, umsg->kvp_hdr.operation);
455e72055b7SXin LI }
456e72055b7SXin LI }
457e72055b7SXin LI
458e72055b7SXin LI
459e72055b7SXin LI /*
460e72055b7SXin LI * Prepare a host kvp msg based on user kvp msg (utf8 to utf16)
461e72055b7SXin LI */
462e72055b7SXin LI static int
hv_kvp_convert_usermsg_to_hostmsg(struct hv_kvp_msg * umsg,struct hv_kvp_msg * hmsg)4630bc2abddSSepherosa Ziehau hv_kvp_convert_usermsg_to_hostmsg(struct hv_kvp_msg *umsg, struct hv_kvp_msg *hmsg)
464e72055b7SXin LI {
465e72055b7SXin LI int hkey_len = 0, hvalue_len = 0, utf_err = 0;
466e72055b7SXin LI struct hv_kvp_exchg_msg_value *host_exchg_data;
467e72055b7SXin LI char *key_name, *value;
468e72055b7SXin LI
469e72055b7SXin LI struct hv_kvp_ip_msg *host_ip_msg = (struct hv_kvp_ip_msg *)hmsg;
470e72055b7SXin LI
471e72055b7SXin LI switch (hmsg->kvp_hdr.operation) {
472e72055b7SXin LI case HV_KVP_OP_GET_IP_INFO:
473e72055b7SXin LI return (hv_kvp_convert_utf8_ipinfo_to_utf16(umsg, host_ip_msg));
474e72055b7SXin LI
475e72055b7SXin LI case HV_KVP_OP_SET_IP_INFO:
476e72055b7SXin LI case HV_KVP_OP_SET:
477e72055b7SXin LI case HV_KVP_OP_DELETE:
47830c90f01SSepherosa Ziehau return (0);
479e72055b7SXin LI
480e72055b7SXin LI case HV_KVP_OP_ENUMERATE:
481e72055b7SXin LI host_exchg_data = &hmsg->body.kvp_enum_data.data;
482e72055b7SXin LI key_name = umsg->body.kvp_enum_data.data.key;
483e72055b7SXin LI hkey_len = utf8_to_utf16((uint16_t *)host_exchg_data->key,
484e72055b7SXin LI ((HV_KVP_EXCHANGE_MAX_KEY_SIZE / 2) - 2),
485e72055b7SXin LI key_name, strlen(key_name),
486e72055b7SXin LI 1, &utf_err);
487e72055b7SXin LI /* utf16 encoding */
488e72055b7SXin LI host_exchg_data->key_size = 2 * (hkey_len + 1);
489e72055b7SXin LI value = umsg->body.kvp_enum_data.data.msg_value.value;
490e72055b7SXin LI hvalue_len = utf8_to_utf16(
491e72055b7SXin LI (uint16_t *)host_exchg_data->msg_value.value,
492e72055b7SXin LI ((HV_KVP_EXCHANGE_MAX_VALUE_SIZE / 2) - 2),
493e72055b7SXin LI value, strlen(value),
494e72055b7SXin LI 1, &utf_err);
495e72055b7SXin LI host_exchg_data->value_size = 2 * (hvalue_len + 1);
496e72055b7SXin LI host_exchg_data->value_type = HV_REG_SZ;
497e72055b7SXin LI
498e72055b7SXin LI if ((hkey_len < 0) || (hvalue_len < 0))
49930c90f01SSepherosa Ziehau return (EINVAL);
500e72055b7SXin LI
50130c90f01SSepherosa Ziehau return (0);
502e72055b7SXin LI
503e72055b7SXin LI case HV_KVP_OP_GET:
504e72055b7SXin LI host_exchg_data = &hmsg->body.kvp_get.data;
505e72055b7SXin LI value = umsg->body.kvp_get.data.msg_value.value;
506e72055b7SXin LI hvalue_len = utf8_to_utf16(
507e72055b7SXin LI (uint16_t *)host_exchg_data->msg_value.value,
508e72055b7SXin LI ((HV_KVP_EXCHANGE_MAX_VALUE_SIZE / 2) - 2),
509e72055b7SXin LI value, strlen(value),
510e72055b7SXin LI 1, &utf_err);
511e72055b7SXin LI /* Convert value size to uft16 */
512e72055b7SXin LI host_exchg_data->value_size = 2 * (hvalue_len + 1);
513e72055b7SXin LI /* Use values by string */
514e72055b7SXin LI host_exchg_data->value_type = HV_REG_SZ;
515e72055b7SXin LI
5161e851378SSepherosa Ziehau if (hvalue_len < 0)
51730c90f01SSepherosa Ziehau return (EINVAL);
518e72055b7SXin LI
51930c90f01SSepherosa Ziehau return (0);
520e72055b7SXin LI
521e72055b7SXin LI default:
52230c90f01SSepherosa Ziehau return (EINVAL);
523e72055b7SXin LI }
524e72055b7SXin LI }
525e72055b7SXin LI
526e72055b7SXin LI
527e72055b7SXin LI /*
528e72055b7SXin LI * Send the response back to the host.
529e72055b7SXin LI */
530e72055b7SXin LI static void
hv_kvp_respond_host(hv_kvp_sc * sc,uint32_t error)53130c90f01SSepherosa Ziehau hv_kvp_respond_host(hv_kvp_sc *sc, uint32_t error)
532e72055b7SXin LI {
533e72055b7SXin LI struct hv_vmbus_icmsg_hdr *hv_icmsg_hdrp;
534e72055b7SXin LI
535e72055b7SXin LI hv_icmsg_hdrp = (struct hv_vmbus_icmsg_hdr *)
5360bc2abddSSepherosa Ziehau &sc->rcv_buf[sizeof(struct hv_vmbus_pipe_hdr)];
537e72055b7SXin LI
538e72055b7SXin LI hv_icmsg_hdrp->status = error;
5395bf51473SSepherosa Ziehau hv_icmsg_hdrp->icflags = HV_ICMSGHDRFLAG_TRANSACTION |
5405bf51473SSepherosa Ziehau HV_ICMSGHDRFLAG_RESPONSE;
541e72055b7SXin LI
542ca871fb7SSepherosa Ziehau error = vmbus_chan_send(vmbus_get_channel(sc->dev),
54312140675SSepherosa Ziehau VMBUS_CHANPKT_TYPE_INBAND, 0, sc->rcv_buf, sc->host_msg_len,
54412140675SSepherosa Ziehau sc->host_msg_id);
545e72055b7SXin LI if (error)
546e72055b7SXin LI hv_kvp_log_info("%s: hv_kvp_respond_host: sendpacket error:%d\n",
547e72055b7SXin LI __func__, error);
548e72055b7SXin LI }
549e72055b7SXin LI
550e72055b7SXin LI
551e72055b7SXin LI /*
552e72055b7SXin LI * This is the main kvp kernel process that interacts with both user daemon
553e72055b7SXin LI * and the host
554e72055b7SXin LI */
555e72055b7SXin LI static void
hv_kvp_send_msg_to_daemon(hv_kvp_sc * sc)5560bc2abddSSepherosa Ziehau hv_kvp_send_msg_to_daemon(hv_kvp_sc *sc)
557e72055b7SXin LI {
5580bc2abddSSepherosa Ziehau struct hv_kvp_msg *hmsg = sc->host_kvp_msg;
5590bc2abddSSepherosa Ziehau struct hv_kvp_msg *umsg = &sc->daemon_kvp_msg;
5600bc2abddSSepherosa Ziehau
561e72055b7SXin LI /* Prepare kvp_msg to be sent to user */
5620bc2abddSSepherosa Ziehau hv_kvp_convert_hostmsg_to_usermsg(hmsg, umsg);
563e72055b7SXin LI
564e72055b7SXin LI /* Send the msg to user via function deamon_read - setting sema */
5650bc2abddSSepherosa Ziehau sema_post(&sc->dev_sema);
566f3b0813aSRoger Pau Monné
567f3b0813aSRoger Pau Monné /* We should wake up the daemon, in case it's doing poll() */
5680bc2abddSSepherosa Ziehau selwakeup(&sc->hv_kvp_selinfo);
569e72055b7SXin LI }
570e72055b7SXin LI
571e72055b7SXin LI
572e72055b7SXin LI /*
573e72055b7SXin LI * Function to read the kvp request buffer from host
574e72055b7SXin LI * and interact with daemon
575e72055b7SXin LI */
576e72055b7SXin LI static void
hv_kvp_process_request(void * context,int pending)577f11ef33fSSepherosa Ziehau hv_kvp_process_request(void *context, int pending)
578e72055b7SXin LI {
579e72055b7SXin LI uint8_t *kvp_buf;
58082b8a879SSepherosa Ziehau struct vmbus_channel *channel;
581e72055b7SXin LI uint32_t recvlen = 0;
582e72055b7SXin LI uint64_t requestid;
583e72055b7SXin LI struct hv_vmbus_icmsg_hdr *icmsghdrp;
5845bf51473SSepherosa Ziehau int ret = 0, error;
5850bc2abddSSepherosa Ziehau hv_kvp_sc *sc;
586e72055b7SXin LI
587e72055b7SXin LI hv_kvp_log_info("%s: entering hv_kvp_process_request\n", __func__);
5880bc2abddSSepherosa Ziehau
5890bc2abddSSepherosa Ziehau sc = (hv_kvp_sc*)context;
5901eb6d711SSepherosa Ziehau kvp_buf = sc->util_sc.ic_buf;
591ca871fb7SSepherosa Ziehau channel = vmbus_get_channel(sc->dev);
5920bc2abddSSepherosa Ziehau
5939b6306f2SSepherosa Ziehau recvlen = sc->util_sc.ic_buflen;
5947c557248SSepherosa Ziehau ret = vmbus_chan_recv(channel, kvp_buf, &recvlen, &requestid);
5957c557248SSepherosa Ziehau KASSERT(ret != ENOBUFS, ("hvkvp recvbuf is not large enough"));
5967c557248SSepherosa Ziehau /* XXX check recvlen to make sure that it contains enough data */
597e72055b7SXin LI
5980bc2abddSSepherosa Ziehau while ((ret == 0) && (recvlen > 0)) {
599e72055b7SXin LI icmsghdrp = (struct hv_vmbus_icmsg_hdr *)
600e72055b7SXin LI &kvp_buf[sizeof(struct hv_vmbus_pipe_hdr)];
601e72055b7SXin LI
6020bc2abddSSepherosa Ziehau hv_kvp_transaction_init(sc, recvlen, requestid, kvp_buf);
603e72055b7SXin LI if (icmsghdrp->icmsgtype == HV_ICMSGTYPE_NEGOTIATE) {
6045bf51473SSepherosa Ziehau error = vmbus_ic_negomsg(&sc->util_sc,
6055bf51473SSepherosa Ziehau kvp_buf, &recvlen, KVP_FWVER, KVP_MSGVER);
6065bf51473SSepherosa Ziehau /* XXX handle vmbus_ic_negomsg failure. */
60730c90f01SSepherosa Ziehau if (!error)
60830c90f01SSepherosa Ziehau hv_kvp_respond_host(sc, HV_S_OK);
60930c90f01SSepherosa Ziehau else
61030c90f01SSepherosa Ziehau hv_kvp_respond_host(sc, HV_E_FAIL);
611e72055b7SXin LI /*
612e72055b7SXin LI * It is ok to not acquire the mutex before setting
613e72055b7SXin LI * req_in_progress here because negotiation is the
614e72055b7SXin LI * first thing that happens and hence there is no
615e72055b7SXin LI * chance of a race condition.
616e72055b7SXin LI */
617e72055b7SXin LI
6180bc2abddSSepherosa Ziehau sc->req_in_progress = false;
619e72055b7SXin LI hv_kvp_log_info("%s :version negotiated\n", __func__);
620e72055b7SXin LI
621e72055b7SXin LI } else {
6220bc2abddSSepherosa Ziehau if (!sc->daemon_busy) {
623e72055b7SXin LI
624e72055b7SXin LI hv_kvp_log_info("%s: issuing qury to daemon\n", __func__);
6250bc2abddSSepherosa Ziehau mtx_lock(&sc->pending_mutex);
6260bc2abddSSepherosa Ziehau sc->req_timed_out = false;
6270bc2abddSSepherosa Ziehau sc->daemon_busy = true;
6280bc2abddSSepherosa Ziehau mtx_unlock(&sc->pending_mutex);
629e72055b7SXin LI
6300bc2abddSSepherosa Ziehau hv_kvp_send_msg_to_daemon(sc);
631e72055b7SXin LI hv_kvp_log_info("%s: waiting for daemon\n", __func__);
632e72055b7SXin LI }
633e72055b7SXin LI
634e72055b7SXin LI /* Wait 5 seconds for daemon to respond back */
6350bc2abddSSepherosa Ziehau tsleep(sc, 0, "kvpworkitem", 5 * hz);
636e72055b7SXin LI hv_kvp_log_info("%s: came out of wait\n", __func__);
637e72055b7SXin LI }
638e72055b7SXin LI
6390bc2abddSSepherosa Ziehau mtx_lock(&sc->pending_mutex);
640e72055b7SXin LI
641e72055b7SXin LI /* Notice that once req_timed_out is set to true
642e72055b7SXin LI * it will remain true until the next request is
643e72055b7SXin LI * sent to the daemon. The response from daemon
644e72055b7SXin LI * is forwarded to host only when this flag is
645e72055b7SXin LI * false.
646e72055b7SXin LI */
6470bc2abddSSepherosa Ziehau sc->req_timed_out = true;
648e72055b7SXin LI
649e72055b7SXin LI /*
650e72055b7SXin LI * Cancel request if so need be.
651e72055b7SXin LI */
6520bc2abddSSepherosa Ziehau if (hv_kvp_req_in_progress(sc)) {
653e72055b7SXin LI hv_kvp_log_info("%s: request was still active after wait so failing\n", __func__);
65430c90f01SSepherosa Ziehau hv_kvp_respond_host(sc, HV_E_FAIL);
6550bc2abddSSepherosa Ziehau sc->req_in_progress = false;
656e72055b7SXin LI }
657e72055b7SXin LI
6580bc2abddSSepherosa Ziehau mtx_unlock(&sc->pending_mutex);
659e72055b7SXin LI
660e72055b7SXin LI /*
661e72055b7SXin LI * Try reading next buffer
662e72055b7SXin LI */
6639b6306f2SSepherosa Ziehau recvlen = sc->util_sc.ic_buflen;
6647c557248SSepherosa Ziehau ret = vmbus_chan_recv(channel, kvp_buf, &recvlen, &requestid);
6657c557248SSepherosa Ziehau KASSERT(ret != ENOBUFS, ("hvkvp recvbuf is not large enough"));
6667c557248SSepherosa Ziehau /* XXX check recvlen to make sure that it contains enough data */
6677c557248SSepherosa Ziehau
6680bc2abddSSepherosa Ziehau hv_kvp_log_info("%s: read: context %p, ret =%d, recvlen=%d\n",
6690bc2abddSSepherosa Ziehau __func__, context, ret, recvlen);
670e72055b7SXin LI }
671e72055b7SXin LI }
672e72055b7SXin LI
673e72055b7SXin LI
674e72055b7SXin LI /*
675e72055b7SXin LI * Callback routine that gets called whenever there is a message from host
676e72055b7SXin LI */
6770bc2abddSSepherosa Ziehau static void
hv_kvp_callback(struct vmbus_channel * chan __unused,void * context)67882b8a879SSepherosa Ziehau hv_kvp_callback(struct vmbus_channel *chan __unused, void *context)
679e72055b7SXin LI {
6800bc2abddSSepherosa Ziehau hv_kvp_sc *sc = (hv_kvp_sc*)context;
6810bc2abddSSepherosa Ziehau /*
6820bc2abddSSepherosa Ziehau The first request from host will not be handled until daemon is registered.
6830bc2abddSSepherosa Ziehau when callback is triggered without a registered daemon, callback just return.
6840bc2abddSSepherosa Ziehau When a new daemon gets regsitered, this callbcak is trigged from _write op.
6850bc2abddSSepherosa Ziehau */
6860bc2abddSSepherosa Ziehau if (sc->register_done) {
687e72055b7SXin LI hv_kvp_log_info("%s: Queuing work item\n", __func__);
6880bc2abddSSepherosa Ziehau taskqueue_enqueue(taskqueue_thread, &sc->task);
689e72055b7SXin LI }
690e72055b7SXin LI }
691e72055b7SXin LI
692e72055b7SXin LI static int
hv_kvp_dev_open(struct cdev * dev,int oflags,int devtype,struct thread * td)693e72055b7SXin LI hv_kvp_dev_open(struct cdev *dev, int oflags, int devtype,
694e72055b7SXin LI struct thread *td)
695e72055b7SXin LI {
6960bc2abddSSepherosa Ziehau hv_kvp_sc *sc = (hv_kvp_sc*)dev->si_drv1;
697e72055b7SXin LI
698e72055b7SXin LI hv_kvp_log_info("%s: Opened device \"hv_kvp_device\" successfully.\n", __func__);
6990bc2abddSSepherosa Ziehau if (sc->dev_accessed)
700e72055b7SXin LI return (-EBUSY);
701e72055b7SXin LI
7020bc2abddSSepherosa Ziehau sc->daemon_task = curproc;
7030bc2abddSSepherosa Ziehau sc->dev_accessed = true;
7040bc2abddSSepherosa Ziehau sc->daemon_busy = false;
705e72055b7SXin LI return (0);
706e72055b7SXin LI }
707e72055b7SXin LI
708e72055b7SXin LI
709e72055b7SXin LI static int
hv_kvp_dev_close(struct cdev * dev __unused,int fflag __unused,int devtype __unused,struct thread * td __unused)710e72055b7SXin LI hv_kvp_dev_close(struct cdev *dev __unused, int fflag __unused, int devtype __unused,
711e72055b7SXin LI struct thread *td __unused)
712e72055b7SXin LI {
7130bc2abddSSepherosa Ziehau hv_kvp_sc *sc = (hv_kvp_sc*)dev->si_drv1;
714e72055b7SXin LI
715e72055b7SXin LI hv_kvp_log_info("%s: Closing device \"hv_kvp_device\".\n", __func__);
7160bc2abddSSepherosa Ziehau sc->dev_accessed = false;
7170bc2abddSSepherosa Ziehau sc->register_done = false;
718e72055b7SXin LI return (0);
719e72055b7SXin LI }
720e72055b7SXin LI
721e72055b7SXin LI
722e72055b7SXin LI /*
723e72055b7SXin LI * hv_kvp_daemon read invokes this function
724e72055b7SXin LI * acts as a send to daemon
725e72055b7SXin LI */
726e72055b7SXin LI static int
hv_kvp_dev_daemon_read(struct cdev * dev,struct uio * uio,int ioflag __unused)7270bc2abddSSepherosa Ziehau hv_kvp_dev_daemon_read(struct cdev *dev, struct uio *uio, int ioflag __unused)
728e72055b7SXin LI {
729e72055b7SXin LI size_t amt;
730e72055b7SXin LI int error = 0;
7310bc2abddSSepherosa Ziehau struct hv_kvp_msg *hv_kvp_dev_buf;
7320bc2abddSSepherosa Ziehau hv_kvp_sc *sc = (hv_kvp_sc*)dev->si_drv1;
733e72055b7SXin LI
73430c90f01SSepherosa Ziehau /* Read is not allowed util registering is done. */
7350bc2abddSSepherosa Ziehau if (!sc->register_done)
73630c90f01SSepherosa Ziehau return (EPERM);
737e72055b7SXin LI
7380bc2abddSSepherosa Ziehau sema_wait(&sc->dev_sema);
739e72055b7SXin LI
7400bc2abddSSepherosa Ziehau hv_kvp_dev_buf = malloc(sizeof(*hv_kvp_dev_buf), M_TEMP, M_WAITOK);
7410bc2abddSSepherosa Ziehau memcpy(hv_kvp_dev_buf, &sc->daemon_kvp_msg, sizeof(struct hv_kvp_msg));
742e72055b7SXin LI
743e72055b7SXin LI amt = MIN(uio->uio_resid, uio->uio_offset >= BUFFERSIZE + 1 ? 0 :
744e72055b7SXin LI BUFFERSIZE + 1 - uio->uio_offset);
745e72055b7SXin LI
746e72055b7SXin LI if ((error = uiomove(hv_kvp_dev_buf, amt, uio)) != 0)
747e72055b7SXin LI hv_kvp_log_info("%s: hv_kvp uiomove read failed!\n", __func__);
748e72055b7SXin LI
7490bc2abddSSepherosa Ziehau free(hv_kvp_dev_buf, M_TEMP);
750e72055b7SXin LI return (error);
751e72055b7SXin LI }
752e72055b7SXin LI
753e72055b7SXin LI
754e72055b7SXin LI /*
755e72055b7SXin LI * hv_kvp_daemon write invokes this function
756453130d9SPedro F. Giffuni * acts as a receive from daemon
757e72055b7SXin LI */
758e72055b7SXin LI static int
hv_kvp_dev_daemon_write(struct cdev * dev,struct uio * uio,int ioflag __unused)7590bc2abddSSepherosa Ziehau hv_kvp_dev_daemon_write(struct cdev *dev, struct uio *uio, int ioflag __unused)
760e72055b7SXin LI {
761e72055b7SXin LI size_t amt;
762e72055b7SXin LI int error = 0;
7630bc2abddSSepherosa Ziehau struct hv_kvp_msg *hv_kvp_dev_buf;
7640bc2abddSSepherosa Ziehau hv_kvp_sc *sc = (hv_kvp_sc*)dev->si_drv1;
765e72055b7SXin LI
766e72055b7SXin LI uio->uio_offset = 0;
7670bc2abddSSepherosa Ziehau hv_kvp_dev_buf = malloc(sizeof(*hv_kvp_dev_buf), M_TEMP, M_WAITOK);
768e72055b7SXin LI
769e72055b7SXin LI amt = MIN(uio->uio_resid, BUFFERSIZE);
770e72055b7SXin LI error = uiomove(hv_kvp_dev_buf, amt, uio);
771e72055b7SXin LI
7720bc2abddSSepherosa Ziehau if (error != 0) {
7730bc2abddSSepherosa Ziehau free(hv_kvp_dev_buf, M_TEMP);
774e72055b7SXin LI return (error);
775e72055b7SXin LI }
7760bc2abddSSepherosa Ziehau memcpy(&sc->daemon_kvp_msg, hv_kvp_dev_buf, sizeof(struct hv_kvp_msg));
7770bc2abddSSepherosa Ziehau
7780bc2abddSSepherosa Ziehau free(hv_kvp_dev_buf, M_TEMP);
7790bc2abddSSepherosa Ziehau if (sc->register_done == false) {
7800bc2abddSSepherosa Ziehau if (sc->daemon_kvp_msg.kvp_hdr.operation == HV_KVP_OP_REGISTER) {
7810bc2abddSSepherosa Ziehau sc->register_done = true;
782ca871fb7SSepherosa Ziehau hv_kvp_callback(vmbus_get_channel(sc->dev), dev->si_drv1);
783e72055b7SXin LI }
784e72055b7SXin LI else {
785e72055b7SXin LI hv_kvp_log_info("%s, KVP Registration Failed\n", __func__);
78630c90f01SSepherosa Ziehau return (EINVAL);
787e72055b7SXin LI }
788e72055b7SXin LI } else {
789e72055b7SXin LI
7900bc2abddSSepherosa Ziehau mtx_lock(&sc->pending_mutex);
791e72055b7SXin LI
7920bc2abddSSepherosa Ziehau if(!sc->req_timed_out) {
7930bc2abddSSepherosa Ziehau struct hv_kvp_msg *hmsg = sc->host_kvp_msg;
7940bc2abddSSepherosa Ziehau struct hv_kvp_msg *umsg = &sc->daemon_kvp_msg;
795e72055b7SXin LI
79630c90f01SSepherosa Ziehau error = hv_kvp_convert_usermsg_to_hostmsg(umsg, hmsg);
79730c90f01SSepherosa Ziehau hv_kvp_respond_host(sc, umsg->hdr.error);
7980bc2abddSSepherosa Ziehau wakeup(sc);
7990bc2abddSSepherosa Ziehau sc->req_in_progress = false;
80030c90f01SSepherosa Ziehau if (umsg->hdr.error != HV_S_OK)
80130c90f01SSepherosa Ziehau hv_kvp_log_info("%s, Error 0x%x from daemon\n",
80230c90f01SSepherosa Ziehau __func__, umsg->hdr.error);
80330c90f01SSepherosa Ziehau if (error)
80430c90f01SSepherosa Ziehau hv_kvp_log_info("%s, Error from convert\n", __func__);
805e72055b7SXin LI }
806e72055b7SXin LI
8070bc2abddSSepherosa Ziehau sc->daemon_busy = false;
8080bc2abddSSepherosa Ziehau mtx_unlock(&sc->pending_mutex);
809e72055b7SXin LI }
810e72055b7SXin LI
811e72055b7SXin LI return (error);
812e72055b7SXin LI }
813e72055b7SXin LI
814e72055b7SXin LI
815e72055b7SXin LI /*
816e72055b7SXin LI * hv_kvp_daemon poll invokes this function to check if data is available
817e72055b7SXin LI * for daemon to read.
818e72055b7SXin LI */
819e72055b7SXin LI static int
hv_kvp_dev_daemon_poll(struct cdev * dev,int events,struct thread * td)8200bc2abddSSepherosa Ziehau hv_kvp_dev_daemon_poll(struct cdev *dev, int events, struct thread *td)
821e72055b7SXin LI {
822e72055b7SXin LI int revents = 0;
8230bc2abddSSepherosa Ziehau hv_kvp_sc *sc = (hv_kvp_sc*)dev->si_drv1;
824e72055b7SXin LI
8250bc2abddSSepherosa Ziehau mtx_lock(&sc->pending_mutex);
826e72055b7SXin LI /*
827e72055b7SXin LI * We check global flag daemon_busy for the data availiability for
828e72055b7SXin LI * userland to read. Deamon_busy is set to true before driver has data
829e72055b7SXin LI * for daemon to read. It is set to false after daemon sends
830e72055b7SXin LI * then response back to driver.
831e72055b7SXin LI */
8320bc2abddSSepherosa Ziehau if (sc->daemon_busy == true)
833e72055b7SXin LI revents = POLLIN;
834f3b0813aSRoger Pau Monné else
8350bc2abddSSepherosa Ziehau selrecord(td, &sc->hv_kvp_selinfo);
836f3b0813aSRoger Pau Monné
8370bc2abddSSepherosa Ziehau mtx_unlock(&sc->pending_mutex);
838e72055b7SXin LI
839e72055b7SXin LI return (revents);
840e72055b7SXin LI }
841e72055b7SXin LI
8420bc2abddSSepherosa Ziehau static int
hv_kvp_probe(device_t dev)8430bc2abddSSepherosa Ziehau hv_kvp_probe(device_t dev)
844e72055b7SXin LI {
8450fc8db6eSSepherosa Ziehau
846c4b78a26SSepherosa Ziehau return (vmbus_ic_probe(dev, vmbus_kvp_descs));
8470bc2abddSSepherosa Ziehau }
848e72055b7SXin LI
8490bc2abddSSepherosa Ziehau static int
hv_kvp_attach(device_t dev)8500bc2abddSSepherosa Ziehau hv_kvp_attach(device_t dev)
8510bc2abddSSepherosa Ziehau {
8520bc2abddSSepherosa Ziehau int error;
8530bc2abddSSepherosa Ziehau struct sysctl_oid_list *child;
8540bc2abddSSepherosa Ziehau struct sysctl_ctx_list *ctx;
8550bc2abddSSepherosa Ziehau
8560bc2abddSSepherosa Ziehau hv_kvp_sc *sc = (hv_kvp_sc*)device_get_softc(dev);
8570bc2abddSSepherosa Ziehau
858ca871fb7SSepherosa Ziehau sc->dev = dev;
8590bc2abddSSepherosa Ziehau sema_init(&sc->dev_sema, 0, "hv_kvp device semaphore");
8600bc2abddSSepherosa Ziehau mtx_init(&sc->pending_mutex, "hv-kvp pending mutex",
861e72055b7SXin LI NULL, MTX_DEF);
862e72055b7SXin LI
8630bc2abddSSepherosa Ziehau ctx = device_get_sysctl_ctx(dev);
8640bc2abddSSepherosa Ziehau child = SYSCTL_CHILDREN(device_get_sysctl_tree(dev));
8650bc2abddSSepherosa Ziehau
8660bc2abddSSepherosa Ziehau SYSCTL_ADD_INT(ctx, child, OID_AUTO, "hv_kvp_log",
86730c90f01SSepherosa Ziehau CTLFLAG_RWTUN, &hv_kvp_log, 0, "Hyperv KVP service log level");
8680bc2abddSSepherosa Ziehau
8690bc2abddSSepherosa Ziehau TASK_INIT(&sc->task, 0, hv_kvp_process_request, sc);
8700bc2abddSSepherosa Ziehau
8710bc2abddSSepherosa Ziehau /* create character device */
8720bc2abddSSepherosa Ziehau error = make_dev_p(MAKEDEV_CHECKNAME | MAKEDEV_WAITOK,
8730bc2abddSSepherosa Ziehau &sc->hv_kvp_dev,
8740bc2abddSSepherosa Ziehau &hv_kvp_cdevsw,
8750bc2abddSSepherosa Ziehau 0,
8760bc2abddSSepherosa Ziehau UID_ROOT,
8770bc2abddSSepherosa Ziehau GID_WHEEL,
8780bc2abddSSepherosa Ziehau 0640,
8790bc2abddSSepherosa Ziehau "hv_kvp_dev");
8800bc2abddSSepherosa Ziehau
8810bc2abddSSepherosa Ziehau if (error != 0)
882e72055b7SXin LI return (error);
8830bc2abddSSepherosa Ziehau sc->hv_kvp_dev->si_drv1 = sc;
8840bc2abddSSepherosa Ziehau
8851eb6d711SSepherosa Ziehau return (vmbus_ic_attach(dev, hv_kvp_callback));
886e72055b7SXin LI }
887e72055b7SXin LI
8880bc2abddSSepherosa Ziehau static int
hv_kvp_detach(device_t dev)8890bc2abddSSepherosa Ziehau hv_kvp_detach(device_t dev)
890e72055b7SXin LI {
8910bc2abddSSepherosa Ziehau hv_kvp_sc *sc = (hv_kvp_sc*)device_get_softc(dev);
892e72055b7SXin LI
8930bc2abddSSepherosa Ziehau if (sc->daemon_task != NULL) {
8940bc2abddSSepherosa Ziehau PROC_LOCK(sc->daemon_task);
8950bc2abddSSepherosa Ziehau kern_psignal(sc->daemon_task, SIGKILL);
8960bc2abddSSepherosa Ziehau PROC_UNLOCK(sc->daemon_task);
897e72055b7SXin LI }
8980bc2abddSSepherosa Ziehau
8990bc2abddSSepherosa Ziehau destroy_dev(sc->hv_kvp_dev);
9001eb6d711SSepherosa Ziehau return (vmbus_ic_detach(dev));
9010bc2abddSSepherosa Ziehau }
9020bc2abddSSepherosa Ziehau
9030bc2abddSSepherosa Ziehau static device_method_t kvp_methods[] = {
9040bc2abddSSepherosa Ziehau /* Device interface */
9050bc2abddSSepherosa Ziehau DEVMETHOD(device_probe, hv_kvp_probe),
9060bc2abddSSepherosa Ziehau DEVMETHOD(device_attach, hv_kvp_attach),
9070bc2abddSSepherosa Ziehau DEVMETHOD(device_detach, hv_kvp_detach),
9080bc2abddSSepherosa Ziehau { 0, 0 }
9090bc2abddSSepherosa Ziehau };
9100bc2abddSSepherosa Ziehau
9110bc2abddSSepherosa Ziehau static driver_t kvp_driver = { "hvkvp", kvp_methods, sizeof(hv_kvp_sc)};
9120bc2abddSSepherosa Ziehau
913c1cef544SJohn Baldwin DRIVER_MODULE(hv_kvp, vmbus, kvp_driver, NULL, NULL);
9140bc2abddSSepherosa Ziehau MODULE_VERSION(hv_kvp, 1);
9150bc2abddSSepherosa Ziehau MODULE_DEPEND(hv_kvp, vmbus, 1, 1, 1);
916