blob: a1e8c834f8247bb4ba29f6a17ce3c2102dd2dc5f (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
/* SPDX-License-Identifier: BSD-3-Clause
* Copyright(c) 2010-2018 Intel Corporation
*/
#include <unistd.h>
#include <string.h>
#include <rte_compat.h>
#include <rte_log.h>
#include <rte_vfio.h>
#include <rte_eal.h>
#include "eal_vfio.h"
/**
* @file
* VFIO socket for communication between primary and secondary processes.
*
* This file is only compiled if CONFIG_RTE_EAL_VFIO is set to "y".
*/
#ifdef VFIO_PRESENT
static int
vfio_mp_primary(const struct rte_mp_msg *msg, const void *peer)
{
int fd = -1;
int ret;
struct rte_mp_msg reply;
struct vfio_mp_param *r = (struct vfio_mp_param *)reply.param;
const struct vfio_mp_param *m =
(const struct vfio_mp_param *)msg->param;
if (msg->len_param != sizeof(*m)) {
RTE_LOG(ERR, EAL, "vfio received invalid message!\n");
return -1;
}
memset(&reply, 0, sizeof(reply));
switch (m->req) {
case SOCKET_REQ_GROUP:
r->req = SOCKET_REQ_GROUP;
r->group_num = m->group_num;
fd = rte_vfio_get_group_fd(m->group_num);
if (fd < 0)
r->result = SOCKET_ERR;
else if (fd == 0)
/* if VFIO group exists but isn't bound to VFIO driver */
r->result = SOCKET_NO_FD;
else {
/* if group exists and is bound to VFIO driver */
r->result = SOCKET_OK;
reply.num_fds = 1;
reply.fds[0] = fd;
}
break;
case SOCKET_REQ_CONTAINER:
r->req = SOCKET_REQ_CONTAINER;
fd = rte_vfio_get_container_fd();
if (fd < 0)
r->result = SOCKET_ERR;
else {
r->result = SOCKET_OK;
reply.num_fds = 1;
reply.fds[0] = fd;
}
break;
case SOCKET_REQ_DEFAULT_CONTAINER:
r->req = SOCKET_REQ_DEFAULT_CONTAINER;
fd = vfio_get_default_container_fd();
if (fd < 0)
r->result = SOCKET_ERR;
else {
r->result = SOCKET_OK;
reply.num_fds = 1;
reply.fds[0] = fd;
}
break;
default:
RTE_LOG(ERR, EAL, "vfio received invalid message!\n");
return -1;
}
strcpy(reply.name, EAL_VFIO_MP);
reply.len_param = sizeof(*r);
ret = rte_mp_reply(&reply, peer);
if (m->req == SOCKET_REQ_CONTAINER && fd >= 0)
close(fd);
return ret;
}
int
vfio_mp_sync_setup(void)
{
if (rte_eal_process_type() == RTE_PROC_PRIMARY)
return rte_mp_action_register(EAL_VFIO_MP, vfio_mp_primary);
return 0;
}
#endif
|
