mirror of https://github.com/xemu-project/xemu.git
9pfs: fixes and cleanup
* Fifth patch fixes a 9pfs server crash that happened on some systems due to incorrect (system dependant) handling of struct dirent size. * Tests: Second patch fixes a test error that happened on some systems due mkdir() being called twice for creating the test directory for the 9p 'local' tests. * Tests: Third patch fixes a memory leak. * Tests: The remaining two patches are code cleanup. -----BEGIN PGP SIGNATURE----- iQJLBAABCgA1FiEEltjREM96+AhPiFkBNMK1h2Wkc5UFAmIOdY0XHHFlbXVfb3Nz QGNydWRlYnl0ZS5jb20ACgkQNMK1h2Wkc5Xygg/9G0Ag4LIQsFxcAdTlC1hsnfer 5GOCpWQsDqUpWScfe+FiaHNdNen328m/2VxF8+V+nSgIJ3qKcGRswesYOPh45//4 v6dVBJG20c6QtRcHrDj75RNwsoRXMIbTs9bg9rYZc1NU9GxdMS8/JZ/2jWxuxvSb 4yhuEdP9VVNGFqqzb0jLcHvvUY5jejlhzYlh4TkTrS/sYiG3m/4Dt0vJw+aO2+cw HJcLnd7z8I9Oz4IOo/P/CkfLaPc+m97xcVTZk5NZaApHBqRA6Mpz4qkDM00TJ7vr dmfOfzZtU+ssYk0YatHltYJ4g/G2kG7YAz/M8IMePOQFzQ8rDKc77N+8gI+45fxU GbSDXoPThRGTQUxIGmOJRF0IuYMuM282xHXwhR9nvZvKcRo/SEFzwgMEubz4V9iR 1SpoPHV8cJsKxy1aQqofOEDHIllBeznkSbRMfJP5icFSnxWMoOZh4hqNi5GcVQ4w 17tCATb6GXOmJnzewKWiyrUooWjCxUBF5De077VbNxdg53dQyUkhZbRaS0LY3GII K6MZFlODr2XtFpiBTZKhV5c0WDLMET0J12LAHSNDKANW3EplOVTVrtTFSJvKQbaY 2CWye+4cqYNwCTcRZzqEA2UmRjYqFd2eztdasVa6p4rafHt5d4QmqfoYugTi01/2 D3cwreDyCS3TkWehKKs= =qfMH -----END PGP SIGNATURE----- Merge remote-tracking branch 'remotes/cschoenebeck/tags/pull-9p-20220217' into staging 9pfs: fixes and cleanup * Fifth patch fixes a 9pfs server crash that happened on some systems due to incorrect (system dependant) handling of struct dirent size. * Tests: Second patch fixes a test error that happened on some systems due mkdir() being called twice for creating the test directory for the 9p 'local' tests. * Tests: Third patch fixes a memory leak. * Tests: The remaining two patches are code cleanup. # gpg: Signature made Thu 17 Feb 2022 16:19:25 GMT # gpg: using RSA key 96D8D110CF7AF8084F88590134C2B58765A47395 # gpg: issuer "qemu_oss@crudebyte.com" # gpg: Good signature from "Christian Schoenebeck <qemu_oss@crudebyte.com>" [unknown] # gpg: WARNING: This key is not certified with a trusted signature! # gpg: There is no indication that the signature belongs to the owner. # Primary key fingerprint: ECAB 1A45 4014 1413 BA38 4926 30DB 47C3 A012 D5F4 # Subkey fingerprint: 96D8 D110 CF7A F808 4F88 5901 34C2 B587 65A4 7395 * remotes/cschoenebeck/tags/pull-9p-20220217: 9pfs: Fix segfault in do_readdir_many caused by struct dirent overread tests/9pfs: Use g_autofree and g_autoptr where possible tests/9pfs: Fix leak of local_test_path tests/9pfs: fix mkdir() being called twice tests/9pfs: use g_autofree where possible Signed-off-by: Peter Maydell <peter.maydell@linaro.org>
This commit is contained in:
commit
439346ce8f
|
@ -182,7 +182,12 @@ static int synth_opendir(FsContext *ctx,
|
||||||
V9fsSynthOpenState *synth_open;
|
V9fsSynthOpenState *synth_open;
|
||||||
V9fsSynthNode *node = *(V9fsSynthNode **)fs_path->data;
|
V9fsSynthNode *node = *(V9fsSynthNode **)fs_path->data;
|
||||||
|
|
||||||
synth_open = g_malloc(sizeof(*synth_open));
|
/*
|
||||||
|
* V9fsSynthOpenState contains 'struct dirent' which have OS-specific
|
||||||
|
* properties, thus it's zero cleared on allocation here and below
|
||||||
|
* in synth_open.
|
||||||
|
*/
|
||||||
|
synth_open = g_new0(V9fsSynthOpenState, 1);
|
||||||
synth_open->node = node;
|
synth_open->node = node;
|
||||||
node->open_count++;
|
node->open_count++;
|
||||||
fs->private = synth_open;
|
fs->private = synth_open;
|
||||||
|
@ -220,7 +225,14 @@ static void synth_rewinddir(FsContext *ctx, V9fsFidOpenState *fs)
|
||||||
static void synth_direntry(V9fsSynthNode *node,
|
static void synth_direntry(V9fsSynthNode *node,
|
||||||
struct dirent *entry, off_t off)
|
struct dirent *entry, off_t off)
|
||||||
{
|
{
|
||||||
strcpy(entry->d_name, node->name);
|
size_t sz = strlen(node->name) + 1;
|
||||||
|
/*
|
||||||
|
* 'entry' is always inside of V9fsSynthOpenState which have NAME_MAX
|
||||||
|
* back padding. Ensure we do not overflow it.
|
||||||
|
*/
|
||||||
|
g_assert(sizeof(struct dirent) + NAME_MAX >=
|
||||||
|
offsetof(struct dirent, d_name) + sz);
|
||||||
|
memcpy(entry->d_name, node->name, sz);
|
||||||
entry->d_ino = node->attr->inode;
|
entry->d_ino = node->attr->inode;
|
||||||
entry->d_off = off + 1;
|
entry->d_off = off + 1;
|
||||||
}
|
}
|
||||||
|
@ -266,7 +278,7 @@ static int synth_open(FsContext *ctx, V9fsPath *fs_path,
|
||||||
V9fsSynthOpenState *synth_open;
|
V9fsSynthOpenState *synth_open;
|
||||||
V9fsSynthNode *node = *(V9fsSynthNode **)fs_path->data;
|
V9fsSynthNode *node = *(V9fsSynthNode **)fs_path->data;
|
||||||
|
|
||||||
synth_open = g_malloc(sizeof(*synth_open));
|
synth_open = g_new0(V9fsSynthOpenState, 1);
|
||||||
synth_open->node = node;
|
synth_open->node = node;
|
||||||
node->open_count++;
|
node->open_count++;
|
||||||
fs->private = synth_open;
|
fs->private = synth_open;
|
||||||
|
|
|
@ -41,6 +41,11 @@ typedef struct V9fsSynthOpenState {
|
||||||
off_t offset;
|
off_t offset;
|
||||||
V9fsSynthNode *node;
|
V9fsSynthNode *node;
|
||||||
struct dirent dent;
|
struct dirent dent;
|
||||||
|
/*
|
||||||
|
* Ensure there is enough space for 'dent' above, some systems have a
|
||||||
|
* d_name size of just 1, which would cause a buffer overrun.
|
||||||
|
*/
|
||||||
|
char dent_trailing_space[NAME_MAX];
|
||||||
} V9fsSynthOpenState;
|
} V9fsSynthOpenState;
|
||||||
|
|
||||||
int qemu_v9fs_synth_mkdir(V9fsSynthNode *parent, int mode,
|
int qemu_v9fs_synth_mkdir(V9fsSynthNode *parent, int mode,
|
||||||
|
|
|
@ -143,8 +143,7 @@ static int do_readdir_many(V9fsPDU *pdu, V9fsFidState *fidp,
|
||||||
} else {
|
} else {
|
||||||
e = e->next = g_malloc0(sizeof(V9fsDirEnt));
|
e = e->next = g_malloc0(sizeof(V9fsDirEnt));
|
||||||
}
|
}
|
||||||
e->dent = g_malloc0(sizeof(struct dirent));
|
e->dent = qemu_dirent_dup(dent);
|
||||||
memcpy(e->dent, dent, sizeof(struct dirent));
|
|
||||||
|
|
||||||
/* perform a full stat() for directory entry if requested by caller */
|
/* perform a full stat() for directory entry if requested by caller */
|
||||||
if (dostat) {
|
if (dostat) {
|
||||||
|
|
|
@ -805,6 +805,19 @@ static inline int platform_does_not_support_system(const char *command)
|
||||||
}
|
}
|
||||||
#endif /* !HAVE_SYSTEM_FUNCTION */
|
#endif /* !HAVE_SYSTEM_FUNCTION */
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Duplicate directory entry @dent.
|
||||||
|
*
|
||||||
|
* It is highly recommended to use this function instead of open coding
|
||||||
|
* duplication of @c dirent objects, because the actual @c struct @c dirent
|
||||||
|
* size may be bigger or shorter than @c sizeof(struct dirent) and correct
|
||||||
|
* handling is platform specific (see gitlab issue #841).
|
||||||
|
*
|
||||||
|
* @dent - original directory entry to be duplicated
|
||||||
|
* @returns duplicated directory entry which should be freed with g_free()
|
||||||
|
*/
|
||||||
|
struct dirent *qemu_dirent_dup(struct dirent *dent);
|
||||||
|
|
||||||
#ifdef __cplusplus
|
#ifdef __cplusplus
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|
|
@ -37,31 +37,23 @@ static char *concat_path(const char* a, const char* b)
|
||||||
return g_build_filename(a, b, NULL);
|
return g_build_filename(a, b, NULL);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void init_local_test_path(void)
|
void virtio_9p_create_local_test_dir(void)
|
||||||
{
|
{
|
||||||
char *pwd = g_get_current_dir();
|
g_assert(local_test_path == NULL);
|
||||||
|
struct stat st;
|
||||||
|
g_autofree char *pwd = g_get_current_dir();
|
||||||
|
/*
|
||||||
|
* template gets cached into local_test_path and freed in
|
||||||
|
* virtio_9p_remove_local_test_dir().
|
||||||
|
*/
|
||||||
char *template = concat_path(pwd, "qtest-9p-local-XXXXXX");
|
char *template = concat_path(pwd, "qtest-9p-local-XXXXXX");
|
||||||
|
|
||||||
local_test_path = mkdtemp(template);
|
local_test_path = mkdtemp(template);
|
||||||
if (!local_test_path) {
|
if (!local_test_path) {
|
||||||
g_test_message("mkdtemp('%s') failed: %s", template, strerror(errno));
|
g_test_message("mkdtemp('%s') failed: %s", template, strerror(errno));
|
||||||
}
|
}
|
||||||
g_assert(local_test_path);
|
|
||||||
g_free(pwd);
|
|
||||||
}
|
|
||||||
|
|
||||||
void virtio_9p_create_local_test_dir(void)
|
|
||||||
{
|
|
||||||
struct stat st;
|
|
||||||
int res;
|
|
||||||
|
|
||||||
init_local_test_path();
|
|
||||||
|
|
||||||
g_assert(local_test_path != NULL);
|
g_assert(local_test_path != NULL);
|
||||||
res = mkdir(local_test_path, 0777);
|
|
||||||
if (res < 0) {
|
|
||||||
g_test_message("mkdir('%s') failed: %s", local_test_path,
|
|
||||||
strerror(errno));
|
|
||||||
}
|
|
||||||
|
|
||||||
/* ensure test directory exists now ... */
|
/* ensure test directory exists now ... */
|
||||||
g_assert(stat(local_test_path, &st) == 0);
|
g_assert(stat(local_test_path, &st) == 0);
|
||||||
|
@ -72,12 +64,13 @@ void virtio_9p_create_local_test_dir(void)
|
||||||
void virtio_9p_remove_local_test_dir(void)
|
void virtio_9p_remove_local_test_dir(void)
|
||||||
{
|
{
|
||||||
g_assert(local_test_path != NULL);
|
g_assert(local_test_path != NULL);
|
||||||
char *cmd = g_strdup_printf("rm -fr '%s'\n", local_test_path);
|
g_autofree char *cmd = g_strdup_printf("rm -fr '%s'\n", local_test_path);
|
||||||
int res = system(cmd);
|
int res = system(cmd);
|
||||||
if (res < 0) {
|
if (res < 0) {
|
||||||
/* ignore error, dummy check to prevent compiler error */
|
/* ignore error, dummy check to prevent compiler error */
|
||||||
}
|
}
|
||||||
g_free(cmd);
|
g_free(local_test_path);
|
||||||
|
local_test_path = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
char *virtio_9p_test_path(const char *path)
|
char *virtio_9p_test_path(const char *path)
|
||||||
|
@ -221,8 +214,8 @@ static void *virtio_9p_pci_create(void *pci_bus, QGuestAllocator *t_alloc,
|
||||||
static void regex_replace(GString *haystack, const char *pattern,
|
static void regex_replace(GString *haystack, const char *pattern,
|
||||||
const char *replace_fmt, ...)
|
const char *replace_fmt, ...)
|
||||||
{
|
{
|
||||||
GRegex *regex;
|
g_autoptr(GRegex) regex = NULL;
|
||||||
char *replace, *s;
|
g_autofree char *replace = NULL, *s = NULL;
|
||||||
va_list argp;
|
va_list argp;
|
||||||
|
|
||||||
va_start(argp, replace_fmt);
|
va_start(argp, replace_fmt);
|
||||||
|
@ -232,9 +225,6 @@ static void regex_replace(GString *haystack, const char *pattern,
|
||||||
regex = g_regex_new(pattern, 0, 0, NULL);
|
regex = g_regex_new(pattern, 0, 0, NULL);
|
||||||
s = g_regex_replace(regex, haystack->str, -1, 0, replace, 0, NULL);
|
s = g_regex_replace(regex, haystack->str, -1, 0, replace, 0, NULL);
|
||||||
g_string_assign(haystack, s);
|
g_string_assign(haystack, s);
|
||||||
g_free(s);
|
|
||||||
g_regex_unref(regex);
|
|
||||||
g_free(replace);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void virtio_9p_assign_local_driver(GString *cmd_line, const char *args)
|
void virtio_9p_assign_local_driver(GString *cmd_line, const char *args)
|
||||||
|
|
|
@ -84,7 +84,7 @@ static void pci_config(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
size_t tag_len = qvirtio_config_readw(v9p->vdev, 0);
|
size_t tag_len = qvirtio_config_readw(v9p->vdev, 0);
|
||||||
char *tag;
|
g_autofree char *tag = NULL;
|
||||||
int i;
|
int i;
|
||||||
|
|
||||||
g_assert_cmpint(tag_len, ==, strlen(MOUNT_TAG));
|
g_assert_cmpint(tag_len, ==, strlen(MOUNT_TAG));
|
||||||
|
@ -94,7 +94,6 @@ static void pci_config(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
tag[i] = qvirtio_config_readb(v9p->vdev, i + 2);
|
tag[i] = qvirtio_config_readb(v9p->vdev, i + 2);
|
||||||
}
|
}
|
||||||
g_assert_cmpmem(tag, tag_len, MOUNT_TAG, tag_len);
|
g_assert_cmpmem(tag, tag_len, MOUNT_TAG, tag_len);
|
||||||
g_free(tag);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#define P9_MAX_SIZE 4096 /* Max size of a T-message or R-message */
|
#define P9_MAX_SIZE 4096 /* Max size of a T-message or R-message */
|
||||||
|
@ -580,7 +579,7 @@ static void do_version(QVirtio9P *v9p)
|
||||||
{
|
{
|
||||||
const char *version = "9P2000.L";
|
const char *version = "9P2000.L";
|
||||||
uint16_t server_len;
|
uint16_t server_len;
|
||||||
char *server_version;
|
g_autofree char *server_version = NULL;
|
||||||
P9Req *req;
|
P9Req *req;
|
||||||
|
|
||||||
req = v9fs_tversion(v9p, P9_MAX_SIZE, version, P9_NOTAG);
|
req = v9fs_tversion(v9p, P9_MAX_SIZE, version, P9_NOTAG);
|
||||||
|
@ -588,8 +587,6 @@ static void do_version(QVirtio9P *v9p)
|
||||||
v9fs_rversion(req, &server_len, &server_version);
|
v9fs_rversion(req, &server_len, &server_version);
|
||||||
|
|
||||||
g_assert_cmpmem(server_version, server_len, version, strlen(version));
|
g_assert_cmpmem(server_version, server_len, version, strlen(version));
|
||||||
|
|
||||||
g_free(server_version);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* utility function: walk to requested dir and return fid for that dir */
|
/* utility function: walk to requested dir and return fid for that dir */
|
||||||
|
@ -637,7 +634,7 @@ static void fs_walk(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
char *wnames[P9_MAXWELEM];
|
char *wnames[P9_MAXWELEM];
|
||||||
uint16_t nwqid;
|
uint16_t nwqid;
|
||||||
v9fs_qid *wqid;
|
g_autofree v9fs_qid *wqid = NULL;
|
||||||
int i;
|
int i;
|
||||||
P9Req *req;
|
P9Req *req;
|
||||||
|
|
||||||
|
@ -655,8 +652,6 @@ static void fs_walk(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
for (i = 0; i < P9_MAXWELEM; i++) {
|
for (i = 0; i < P9_MAXWELEM; i++) {
|
||||||
g_free(wnames[i]);
|
g_free(wnames[i]);
|
||||||
}
|
}
|
||||||
|
|
||||||
g_free(wqid);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static bool fs_dirents_contain_name(struct V9fsDirent *e, const char* name)
|
static bool fs_dirents_contain_name(struct V9fsDirent *e, const char* name)
|
||||||
|
@ -872,9 +867,9 @@ static void fs_readdir(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
g_assert_cmpint(fs_dirents_contain_name(entries, "."), ==, true);
|
g_assert_cmpint(fs_dirents_contain_name(entries, "."), ==, true);
|
||||||
g_assert_cmpint(fs_dirents_contain_name(entries, ".."), ==, true);
|
g_assert_cmpint(fs_dirents_contain_name(entries, ".."), ==, true);
|
||||||
for (int i = 0; i < QTEST_V9FS_SYNTH_READDIR_NFILES; ++i) {
|
for (int i = 0; i < QTEST_V9FS_SYNTH_READDIR_NFILES; ++i) {
|
||||||
char *name = g_strdup_printf(QTEST_V9FS_SYNTH_READDIR_FILE, i);
|
g_autofree char *name =
|
||||||
|
g_strdup_printf(QTEST_V9FS_SYNTH_READDIR_FILE, i);
|
||||||
g_assert_cmpint(fs_dirents_contain_name(entries, name), ==, true);
|
g_assert_cmpint(fs_dirents_contain_name(entries, name), ==, true);
|
||||||
g_free(name);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
v9fs_free_dirents(entries);
|
v9fs_free_dirents(entries);
|
||||||
|
@ -984,7 +979,8 @@ static void fs_walk_dotdot(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
char *const wnames[] = { g_strdup("..") };
|
char *const wnames[] = { g_strdup("..") };
|
||||||
v9fs_qid root_qid, *wqid;
|
v9fs_qid root_qid;
|
||||||
|
g_autofree v9fs_qid *wqid = NULL;
|
||||||
P9Req *req;
|
P9Req *req;
|
||||||
|
|
||||||
do_version(v9p);
|
do_version(v9p);
|
||||||
|
@ -998,7 +994,6 @@ static void fs_walk_dotdot(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
|
|
||||||
g_assert_cmpmem(&root_qid, 13, wqid[0], 13);
|
g_assert_cmpmem(&root_qid, 13, wqid[0], 13);
|
||||||
|
|
||||||
g_free(wqid);
|
|
||||||
g_free(wnames[0]);
|
g_free(wnames[0]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1027,7 +1022,7 @@ static void fs_write(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
static const uint32_t write_count = P9_MAX_SIZE / 2;
|
static const uint32_t write_count = P9_MAX_SIZE / 2;
|
||||||
char *const wnames[] = { g_strdup(QTEST_V9FS_SYNTH_WRITE_FILE) };
|
char *const wnames[] = { g_strdup(QTEST_V9FS_SYNTH_WRITE_FILE) };
|
||||||
char *buf = g_malloc0(write_count);
|
g_autofree char *buf = g_malloc0(write_count);
|
||||||
uint32_t count;
|
uint32_t count;
|
||||||
P9Req *req;
|
P9Req *req;
|
||||||
|
|
||||||
|
@ -1045,7 +1040,6 @@ static void fs_write(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
v9fs_rwrite(req, &count);
|
v9fs_rwrite(req, &count);
|
||||||
g_assert_cmpint(count, ==, write_count);
|
g_assert_cmpint(count, ==, write_count);
|
||||||
|
|
||||||
g_free(buf);
|
|
||||||
g_free(wnames[0]);
|
g_free(wnames[0]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1125,7 +1119,7 @@ static void fs_flush_ignored(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
|
|
||||||
static void do_mkdir(QVirtio9P *v9p, const char *path, const char *cname)
|
static void do_mkdir(QVirtio9P *v9p, const char *path, const char *cname)
|
||||||
{
|
{
|
||||||
char *const name = g_strdup(cname);
|
g_autofree char *name = g_strdup(cname);
|
||||||
uint32_t fid;
|
uint32_t fid;
|
||||||
P9Req *req;
|
P9Req *req;
|
||||||
|
|
||||||
|
@ -1134,15 +1128,13 @@ static void do_mkdir(QVirtio9P *v9p, const char *path, const char *cname)
|
||||||
req = v9fs_tmkdir(v9p, fid, name, 0750, 0, 0);
|
req = v9fs_tmkdir(v9p, fid, name, 0750, 0, 0);
|
||||||
v9fs_req_wait_for_reply(req, NULL);
|
v9fs_req_wait_for_reply(req, NULL);
|
||||||
v9fs_rmkdir(req, NULL);
|
v9fs_rmkdir(req, NULL);
|
||||||
|
|
||||||
g_free(name);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* create a regular file with Tlcreate and return file's fid */
|
/* create a regular file with Tlcreate and return file's fid */
|
||||||
static uint32_t do_lcreate(QVirtio9P *v9p, const char *path,
|
static uint32_t do_lcreate(QVirtio9P *v9p, const char *path,
|
||||||
const char *cname)
|
const char *cname)
|
||||||
{
|
{
|
||||||
char *const name = g_strdup(cname);
|
g_autofree char *name = g_strdup(cname);
|
||||||
uint32_t fid;
|
uint32_t fid;
|
||||||
P9Req *req;
|
P9Req *req;
|
||||||
|
|
||||||
|
@ -1152,7 +1144,6 @@ static uint32_t do_lcreate(QVirtio9P *v9p, const char *path,
|
||||||
v9fs_req_wait_for_reply(req, NULL);
|
v9fs_req_wait_for_reply(req, NULL);
|
||||||
v9fs_rlcreate(req, NULL, NULL);
|
v9fs_rlcreate(req, NULL, NULL);
|
||||||
|
|
||||||
g_free(name);
|
|
||||||
return fid;
|
return fid;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1160,8 +1151,8 @@ static uint32_t do_lcreate(QVirtio9P *v9p, const char *path,
|
||||||
static void do_symlink(QVirtio9P *v9p, const char *path, const char *clink,
|
static void do_symlink(QVirtio9P *v9p, const char *path, const char *clink,
|
||||||
const char *to)
|
const char *to)
|
||||||
{
|
{
|
||||||
char *const name = g_strdup(clink);
|
g_autofree char *name = g_strdup(clink);
|
||||||
char *const dst = g_strdup(to);
|
g_autofree char *dst = g_strdup(to);
|
||||||
uint32_t fid;
|
uint32_t fid;
|
||||||
P9Req *req;
|
P9Req *req;
|
||||||
|
|
||||||
|
@ -1170,9 +1161,6 @@ static void do_symlink(QVirtio9P *v9p, const char *path, const char *clink,
|
||||||
req = v9fs_tsymlink(v9p, fid, name, dst, 0, 0);
|
req = v9fs_tsymlink(v9p, fid, name, dst, 0, 0);
|
||||||
v9fs_req_wait_for_reply(req, NULL);
|
v9fs_req_wait_for_reply(req, NULL);
|
||||||
v9fs_rsymlink(req, NULL);
|
v9fs_rsymlink(req, NULL);
|
||||||
|
|
||||||
g_free(dst);
|
|
||||||
g_free(name);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/* create a hard link named @a clink in directory @a path pointing to @a to */
|
/* create a hard link named @a clink in directory @a path pointing to @a to */
|
||||||
|
@ -1193,7 +1181,7 @@ static void do_hardlink(QVirtio9P *v9p, const char *path, const char *clink,
|
||||||
static void do_unlinkat(QVirtio9P *v9p, const char *atpath, const char *rpath,
|
static void do_unlinkat(QVirtio9P *v9p, const char *atpath, const char *rpath,
|
||||||
uint32_t flags)
|
uint32_t flags)
|
||||||
{
|
{
|
||||||
char *const name = g_strdup(rpath);
|
g_autofree char *name = g_strdup(rpath);
|
||||||
uint32_t fid;
|
uint32_t fid;
|
||||||
P9Req *req;
|
P9Req *req;
|
||||||
|
|
||||||
|
@ -1202,8 +1190,6 @@ static void do_unlinkat(QVirtio9P *v9p, const char *atpath, const char *rpath,
|
||||||
req = v9fs_tunlinkat(v9p, fid, name, flags, 0);
|
req = v9fs_tunlinkat(v9p, fid, name, flags, 0);
|
||||||
v9fs_req_wait_for_reply(req, NULL);
|
v9fs_req_wait_for_reply(req, NULL);
|
||||||
v9fs_runlinkat(req);
|
v9fs_runlinkat(req);
|
||||||
|
|
||||||
g_free(name);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void fs_readdir_split_128(void *obj, void *data,
|
static void fs_readdir_split_128(void *obj, void *data,
|
||||||
|
@ -1235,8 +1221,8 @@ static void fs_create_dir(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
struct stat st;
|
struct stat st;
|
||||||
char *root_path = virtio_9p_test_path("");
|
g_autofree char *root_path = virtio_9p_test_path("");
|
||||||
char *new_dir = virtio_9p_test_path("01");
|
g_autofree char *new_dir = virtio_9p_test_path("01");
|
||||||
|
|
||||||
g_assert(root_path != NULL);
|
g_assert(root_path != NULL);
|
||||||
|
|
||||||
|
@ -1247,9 +1233,6 @@ static void fs_create_dir(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
g_assert(stat(new_dir, &st) == 0);
|
g_assert(stat(new_dir, &st) == 0);
|
||||||
/* ... and is actually a directory */
|
/* ... and is actually a directory */
|
||||||
g_assert((st.st_mode & S_IFMT) == S_IFDIR);
|
g_assert((st.st_mode & S_IFMT) == S_IFDIR);
|
||||||
|
|
||||||
g_free(new_dir);
|
|
||||||
g_free(root_path);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void fs_unlinkat_dir(void *obj, void *data, QGuestAllocator *t_alloc)
|
static void fs_unlinkat_dir(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
|
@ -1257,8 +1240,8 @@ static void fs_unlinkat_dir(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
struct stat st;
|
struct stat st;
|
||||||
char *root_path = virtio_9p_test_path("");
|
g_autofree char *root_path = virtio_9p_test_path("");
|
||||||
char *new_dir = virtio_9p_test_path("02");
|
g_autofree char *new_dir = virtio_9p_test_path("02");
|
||||||
|
|
||||||
g_assert(root_path != NULL);
|
g_assert(root_path != NULL);
|
||||||
|
|
||||||
|
@ -1273,9 +1256,6 @@ static void fs_unlinkat_dir(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
do_unlinkat(v9p, "/", "02", AT_REMOVEDIR);
|
do_unlinkat(v9p, "/", "02", AT_REMOVEDIR);
|
||||||
/* directory should be gone now */
|
/* directory should be gone now */
|
||||||
g_assert(stat(new_dir, &st) != 0);
|
g_assert(stat(new_dir, &st) != 0);
|
||||||
|
|
||||||
g_free(new_dir);
|
|
||||||
g_free(root_path);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void fs_create_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
static void fs_create_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
|
@ -1283,7 +1263,7 @@ static void fs_create_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
struct stat st;
|
struct stat st;
|
||||||
char *new_file = virtio_9p_test_path("03/1st_file");
|
g_autofree char *new_file = virtio_9p_test_path("03/1st_file");
|
||||||
|
|
||||||
do_attach(v9p);
|
do_attach(v9p);
|
||||||
do_mkdir(v9p, "/", "03");
|
do_mkdir(v9p, "/", "03");
|
||||||
|
@ -1293,8 +1273,6 @@ static void fs_create_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
g_assert(stat(new_file, &st) == 0);
|
g_assert(stat(new_file, &st) == 0);
|
||||||
/* ... and is a regular file */
|
/* ... and is a regular file */
|
||||||
g_assert((st.st_mode & S_IFMT) == S_IFREG);
|
g_assert((st.st_mode & S_IFMT) == S_IFREG);
|
||||||
|
|
||||||
g_free(new_file);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void fs_unlinkat_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
static void fs_unlinkat_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
|
@ -1302,7 +1280,7 @@ static void fs_unlinkat_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
struct stat st;
|
struct stat st;
|
||||||
char *new_file = virtio_9p_test_path("04/doa_file");
|
g_autofree char *new_file = virtio_9p_test_path("04/doa_file");
|
||||||
|
|
||||||
do_attach(v9p);
|
do_attach(v9p);
|
||||||
do_mkdir(v9p, "/", "04");
|
do_mkdir(v9p, "/", "04");
|
||||||
|
@ -1316,8 +1294,6 @@ static void fs_unlinkat_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
do_unlinkat(v9p, "04", "doa_file", 0);
|
do_unlinkat(v9p, "04", "doa_file", 0);
|
||||||
/* file should be gone now */
|
/* file should be gone now */
|
||||||
g_assert(stat(new_file, &st) != 0);
|
g_assert(stat(new_file, &st) != 0);
|
||||||
|
|
||||||
g_free(new_file);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void fs_symlink_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
static void fs_symlink_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
|
@ -1325,8 +1301,8 @@ static void fs_symlink_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
struct stat st;
|
struct stat st;
|
||||||
char *real_file = virtio_9p_test_path("05/real_file");
|
g_autofree char *real_file = virtio_9p_test_path("05/real_file");
|
||||||
char *symlink_file = virtio_9p_test_path("05/symlink_file");
|
g_autofree char *symlink_file = virtio_9p_test_path("05/symlink_file");
|
||||||
|
|
||||||
do_attach(v9p);
|
do_attach(v9p);
|
||||||
do_mkdir(v9p, "/", "05");
|
do_mkdir(v9p, "/", "05");
|
||||||
|
@ -1338,9 +1314,6 @@ static void fs_symlink_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
|
|
||||||
/* check if created link exists now */
|
/* check if created link exists now */
|
||||||
g_assert(stat(symlink_file, &st) == 0);
|
g_assert(stat(symlink_file, &st) == 0);
|
||||||
|
|
||||||
g_free(symlink_file);
|
|
||||||
g_free(real_file);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void fs_unlinkat_symlink(void *obj, void *data,
|
static void fs_unlinkat_symlink(void *obj, void *data,
|
||||||
|
@ -1349,8 +1322,8 @@ static void fs_unlinkat_symlink(void *obj, void *data,
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
struct stat st;
|
struct stat st;
|
||||||
char *real_file = virtio_9p_test_path("06/real_file");
|
g_autofree char *real_file = virtio_9p_test_path("06/real_file");
|
||||||
char *symlink_file = virtio_9p_test_path("06/symlink_file");
|
g_autofree char *symlink_file = virtio_9p_test_path("06/symlink_file");
|
||||||
|
|
||||||
do_attach(v9p);
|
do_attach(v9p);
|
||||||
do_mkdir(v9p, "/", "06");
|
do_mkdir(v9p, "/", "06");
|
||||||
|
@ -1364,9 +1337,6 @@ static void fs_unlinkat_symlink(void *obj, void *data,
|
||||||
do_unlinkat(v9p, "06", "symlink_file", 0);
|
do_unlinkat(v9p, "06", "symlink_file", 0);
|
||||||
/* symlink should be gone now */
|
/* symlink should be gone now */
|
||||||
g_assert(stat(symlink_file, &st) != 0);
|
g_assert(stat(symlink_file, &st) != 0);
|
||||||
|
|
||||||
g_free(symlink_file);
|
|
||||||
g_free(real_file);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void fs_hardlink_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
static void fs_hardlink_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
|
@ -1374,8 +1344,8 @@ static void fs_hardlink_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
struct stat st_real, st_link;
|
struct stat st_real, st_link;
|
||||||
char *real_file = virtio_9p_test_path("07/real_file");
|
g_autofree char *real_file = virtio_9p_test_path("07/real_file");
|
||||||
char *hardlink_file = virtio_9p_test_path("07/hardlink_file");
|
g_autofree char *hardlink_file = virtio_9p_test_path("07/hardlink_file");
|
||||||
|
|
||||||
do_attach(v9p);
|
do_attach(v9p);
|
||||||
do_mkdir(v9p, "/", "07");
|
do_mkdir(v9p, "/", "07");
|
||||||
|
@ -1391,9 +1361,6 @@ static void fs_hardlink_file(void *obj, void *data, QGuestAllocator *t_alloc)
|
||||||
g_assert((st_link.st_mode & S_IFMT) == S_IFREG);
|
g_assert((st_link.st_mode & S_IFMT) == S_IFREG);
|
||||||
g_assert(st_link.st_dev == st_real.st_dev);
|
g_assert(st_link.st_dev == st_real.st_dev);
|
||||||
g_assert(st_link.st_ino == st_real.st_ino);
|
g_assert(st_link.st_ino == st_real.st_ino);
|
||||||
|
|
||||||
g_free(hardlink_file);
|
|
||||||
g_free(real_file);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void fs_unlinkat_hardlink(void *obj, void *data,
|
static void fs_unlinkat_hardlink(void *obj, void *data,
|
||||||
|
@ -1402,8 +1369,8 @@ static void fs_unlinkat_hardlink(void *obj, void *data,
|
||||||
QVirtio9P *v9p = obj;
|
QVirtio9P *v9p = obj;
|
||||||
alloc = t_alloc;
|
alloc = t_alloc;
|
||||||
struct stat st_real, st_link;
|
struct stat st_real, st_link;
|
||||||
char *real_file = virtio_9p_test_path("08/real_file");
|
g_autofree char *real_file = virtio_9p_test_path("08/real_file");
|
||||||
char *hardlink_file = virtio_9p_test_path("08/hardlink_file");
|
g_autofree char *hardlink_file = virtio_9p_test_path("08/hardlink_file");
|
||||||
|
|
||||||
do_attach(v9p);
|
do_attach(v9p);
|
||||||
do_mkdir(v9p, "/", "08");
|
do_mkdir(v9p, "/", "08");
|
||||||
|
@ -1419,9 +1386,6 @@ static void fs_unlinkat_hardlink(void *obj, void *data,
|
||||||
g_assert(stat(hardlink_file, &st_link) != 0);
|
g_assert(stat(hardlink_file, &st_link) != 0);
|
||||||
/* and old file should still exist */
|
/* and old file should still exist */
|
||||||
g_assert(stat(real_file, &st_real) == 0);
|
g_assert(stat(real_file, &st_real) == 0);
|
||||||
|
|
||||||
g_free(hardlink_file);
|
|
||||||
g_free(real_file);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void *assign_9p_local_driver(GString *cmd_line, void *arg)
|
static void *assign_9p_local_driver(GString *cmd_line, void *arg)
|
||||||
|
|
21
util/osdep.c
21
util/osdep.c
|
@ -33,6 +33,7 @@
|
||||||
extern int madvise(char *, size_t, int);
|
extern int madvise(char *, size_t, int);
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
#include <dirent.h>
|
||||||
#include "qemu-common.h"
|
#include "qemu-common.h"
|
||||||
#include "qemu/cutils.h"
|
#include "qemu/cutils.h"
|
||||||
#include "qemu/sockets.h"
|
#include "qemu/sockets.h"
|
||||||
|
@ -615,3 +616,23 @@ writev(int fd, const struct iovec *iov, int iov_cnt)
|
||||||
return readv_writev(fd, iov, iov_cnt, true);
|
return readv_writev(fd, iov, iov_cnt, true);
|
||||||
}
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
struct dirent *
|
||||||
|
qemu_dirent_dup(struct dirent *dent)
|
||||||
|
{
|
||||||
|
size_t sz = 0;
|
||||||
|
#if defined _DIRENT_HAVE_D_RECLEN
|
||||||
|
/* Avoid use of strlen() if platform supports d_reclen. */
|
||||||
|
sz = dent->d_reclen;
|
||||||
|
#endif
|
||||||
|
/*
|
||||||
|
* Test sz for zero even if d_reclen is available
|
||||||
|
* because some drivers may set d_reclen to zero.
|
||||||
|
*/
|
||||||
|
if (sz == 0) {
|
||||||
|
/* Fallback to the most portable way. */
|
||||||
|
sz = offsetof(struct dirent, d_name) +
|
||||||
|
strlen(dent->d_name) + 1;
|
||||||
|
}
|
||||||
|
return g_memdup(dent, sz);
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in New Issue