nuttx-apps/testing/testsuites/kernel/fs/cases/fs_fsync_test.c
guohao15 4ac3732734 testing/fdcheck: fix fd close in other thread
Fix file descriptor leak issue where fd was stored in test_state for deferred close, but could fail when CONFIG_FDCHECK is enabled because fd cannot be closed in a different thread.

Signed-off-by: guohao15 <guohao15@xiaomi.com>
2026-01-28 10:37:52 -03:00

166 lines
4.4 KiB
C

/****************************************************************************
* apps/testing/testsuites/kernel/fs/cases/fs_fsync_test.c
*
* SPDX-License-Identifier: Apache-2.0
*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership. The
* ASF licenses this file to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance with the
* License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
* License for the specific language governing permissions and limitations
* under the License.
*
****************************************************************************/
/****************************************************************************
* Included Files
****************************************************************************/
#include <nuttx/config.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/stat.h>
#include <sys/statfs.h>
#include <time.h>
#include <fcntl.h>
#include <stdint.h>
#include <stdarg.h>
#include <stddef.h>
#include <setjmp.h>
#include <cmocka.h>
#include "fstest.h"
/****************************************************************************
* Pre-processor Definitions
****************************************************************************/
#define TESTFILE "FsyncTestFile"
#define BUF \
"testData123#$%*-=/ " \
"sdafasd37575sasdfasdf356345634563456ADSFASDFASDFQWREdf4as5df4as5dfs" \
"d ###"
/****************************************************************************
* Public Functions
****************************************************************************/
/****************************************************************************
* Name: test_nuttx_fs_fsync01
****************************************************************************/
void test_nuttx_fs_fsync01(FAR void **state)
{
/* clock_t start, finish; */
int fd;
int rval;
int ret;
/* open file */
fd = open(TESTFILE, O_RDWR | O_CREAT, 0700);
assert_true(fd > 0);
for (int i = 0; i < 20; i++)
{
/* do write */
rval = write(fd, BUF, sizeof(BUF));
assert_int_equal(rval, sizeof(BUF));
/* refresh to storage */
ret = fsync(fd);
assert_int_equal(ret, 0);
}
close(fd);
}
/****************************************************************************
* Public Functions
****************************************************************************/
/****************************************************************************
* Name: test_nuttx_fs_fsync02
****************************************************************************/
void test_nuttx_fs_fsync02(FAR void **state)
{
int fd;
int ret;
char *buf = NULL;
int bufsize = 4096;
ssize_t written = 0;
struct statfs statfsbuf;
struct fs_testsuites_state_s *test_state;
struct mallinfo mem_info;
memset(&mem_info, 0, sizeof(mem_info));
test_state = (struct fs_testsuites_state_s *)*state;
/* delete test file */
unlink(TESTFILE);
/* open file */
fd = open(TESTFILE, O_CREAT | O_RDWR, 0777);
assert_true(fd > 0);
/* call fstatfs() */
ret = fstatfs(fd, &statfsbuf);
assert_int_equal(ret, 0);
#ifdef CONFIG_ARCH_SIM
bufsize = statfsbuf.f_bsize;
#else
get_mem_info(&mem_info);
if (mem_info.mxordblk < statfsbuf.f_bsize)
{
bufsize = mem_info.mxordblk - 16;
}
else
{
bufsize = statfsbuf.f_bsize;
}
#endif
syslog(LOG_INFO, "the fbsize = %zu,buffer size=%d\n",
statfsbuf.f_bsize, bufsize);
/* malloc memory */
buf = malloc(bufsize * sizeof(char));
assert_non_null(buf);
test_state->ptr = buf;
/* set memory */
memset(buf, 0x66, bufsize);
/* do write */
written = write(fd, buf, bufsize);
assert_int_in_range(written, 1, bufsize);
/* refresh to storage */
fsync(fd);
/* call fstatfs() */
ret = fstatfs(fd, &statfsbuf);
assert_int_equal(ret, 0);
close(fd);
}