mirror of
https://github.com/espressif/esp-idf.git
synced 2026-10-02 11:10:54 +03:00
refactor(storage/stdio): remove fd table, forward opens to primary backend
This commit is contained in:
@@ -52,13 +52,7 @@ static void console_none_print(void)
|
||||
#endif
|
||||
|
||||
#if CONFIG_VFS_SUPPORT_IO
|
||||
#if CONFIG_ESP_STDIO_BASIC_MODE
|
||||
#define ESP_STDIO_RUN_OPEN_CLOSE_CHECK 1
|
||||
#elif CONFIG_ESP_STDIO_MAX_FDS > 3
|
||||
#define ESP_STDIO_RUN_OPEN_CLOSE_CHECK 1
|
||||
#else
|
||||
#define ESP_STDIO_RUN_OPEN_CLOSE_CHECK 0
|
||||
#endif
|
||||
|
||||
#if ESP_STDIO_RUN_OPEN_CLOSE_CHECK
|
||||
static void console_open_close_check(void)
|
||||
@@ -80,122 +74,26 @@ static void console_open_close_check(void)
|
||||
|
||||
static void stdio_fd_mode_behavior_check(void)
|
||||
{
|
||||
#if CONFIG_ESP_STDIO_BASIC_MODE
|
||||
printf("STDIO_TEST:MODE=BASIC\n");
|
||||
printf("STDIO_TEST:MODE=FORWARDING\n");
|
||||
|
||||
int fd0 = open("/dev/console", O_RDWR);
|
||||
int fd1 = open("/dev/console", O_RDWR);
|
||||
int fd2 = open("/dev/console", O_RDWR);
|
||||
assert(fd0 >= 0);
|
||||
assert(fd1 >= 0);
|
||||
assert(fd2 >= 0);
|
||||
printf("STDIO_TEST:BASIC:OPEN_OK\n");
|
||||
|
||||
const char *msg = "STDIO_TEST:BASIC:WRITE_OK\n";
|
||||
int fd1 = open("/dev/console", O_RDWR);
|
||||
assert(fd1 >= 0);
|
||||
assert(fd0 != fd1);
|
||||
printf("STDIO_TEST:UNIQUE_FDS_OK\n");
|
||||
|
||||
const char *msg = "STDIO_TEST:WRITE_OK\n";
|
||||
ssize_t wr = write(fd0, msg, strlen(msg));
|
||||
assert(wr == (ssize_t) strlen(msg));
|
||||
|
||||
/* Verify write return value matches actual bytes (primary sink propagation) */
|
||||
const char *short_msg = "ab";
|
||||
wr = write(fd1, short_msg, 2);
|
||||
assert(wr == 2);
|
||||
assert(fsync(fd0) == 0);
|
||||
printf("STDIO_TEST:FSYNC_OK\n");
|
||||
|
||||
assert(close(fd0) == 0);
|
||||
assert(close(fd1) == 0);
|
||||
assert(close(fd2) == 0);
|
||||
printf("STDIO_TEST:BASIC:CLOSE_OK\n");
|
||||
|
||||
errno = 0;
|
||||
assert(close(-1) < 0);
|
||||
assert(errno == EBADF);
|
||||
|
||||
errno = 0;
|
||||
assert(write(fd0, msg, strlen(msg)) < 0);
|
||||
assert(errno == EBADF);
|
||||
printf("STDIO_TEST:BASIC:EBADF_OK\n");
|
||||
#else
|
||||
printf("STDIO_TEST:MODE=NON_BASIC\n");
|
||||
|
||||
errno = 0;
|
||||
int fd0 = open("/dev/console", O_RDWR);
|
||||
if (fd0 < 0) {
|
||||
/* Small fd limits can be fully consumed by stdin/stdout/stderr. */
|
||||
assert(errno == ENFILE);
|
||||
printf("STDIO_TEST:NON_BASIC:SATURATED_OK\n");
|
||||
return;
|
||||
}
|
||||
|
||||
int fd1 = open("/dev/console", O_RDWR);
|
||||
int fd2 = open("/dev/console", O_RDWR);
|
||||
assert(fd0 >= 0);
|
||||
assert(fd1 >= 0);
|
||||
assert(fd2 >= 0);
|
||||
assert(fd0 != fd1 && fd1 != fd2 && fd0 != fd2);
|
||||
printf("STDIO_TEST:NON_BASIC:UNIQUE_OK\n");
|
||||
|
||||
assert(close(fd1) == 0);
|
||||
int fd_reused = open("/dev/console", O_RDWR);
|
||||
assert(fd_reused == fd1);
|
||||
printf("STDIO_TEST:NON_BASIC:REUSE_OK\n");
|
||||
assert(close(fd0) == 0);
|
||||
assert(close(fd2) == 0);
|
||||
assert(close(fd_reused) == 0);
|
||||
|
||||
int fd_ro = open("/dev/console", O_RDONLY);
|
||||
assert(fd_ro >= 0);
|
||||
errno = 0;
|
||||
assert(write(fd_ro, "x", 1) < 0);
|
||||
assert(errno == EBADF);
|
||||
assert(close(fd_ro) == 0);
|
||||
|
||||
int fd_wo = open("/dev/console", O_WRONLY);
|
||||
assert(fd_wo >= 0);
|
||||
errno = 0;
|
||||
char tmp = 0;
|
||||
assert(read(fd_wo, &tmp, 1) < 0);
|
||||
assert(errno == EBADF);
|
||||
assert(close(fd_wo) == 0);
|
||||
|
||||
int fd_rw = open("/dev/console", O_RDWR);
|
||||
assert(fd_rw >= 0);
|
||||
const char *wmsg = "z";
|
||||
ssize_t wret = write(fd_rw, wmsg, 1);
|
||||
assert(wret == 1);
|
||||
assert(close(fd_rw) == 0);
|
||||
printf("STDIO_TEST:NON_BASIC:FLAGS_OK\n");
|
||||
|
||||
int fd_fsync = open("/dev/console", O_RDWR);
|
||||
assert(fd_fsync >= 0);
|
||||
assert(fsync(fd_fsync) == 0);
|
||||
assert(close(fd_fsync) == 0);
|
||||
printf("STDIO_TEST:NON_BASIC:FSYNC_OK\n");
|
||||
|
||||
int fds[CONFIG_ESP_STDIO_MAX_FDS + 2];
|
||||
int opened = 0;
|
||||
while (opened < (int)(sizeof(fds) / sizeof(fds[0]))) {
|
||||
int fd = open("/dev/console", O_RDWR);
|
||||
if (fd < 0) {
|
||||
break;
|
||||
}
|
||||
fds[opened++] = fd;
|
||||
}
|
||||
assert(opened >= 0);
|
||||
assert(opened <= CONFIG_ESP_STDIO_MAX_FDS);
|
||||
errno = 0;
|
||||
assert(open("/dev/console", O_RDWR) < 0);
|
||||
assert(errno == ENFILE);
|
||||
printf("STDIO_TEST:NON_BASIC:LIMIT_OK\n");
|
||||
|
||||
for (int i = 0; i < opened; ++i) {
|
||||
assert(close(fds[i]) == 0);
|
||||
}
|
||||
|
||||
const char *msg = "x";
|
||||
errno = 0;
|
||||
assert(write(-1, msg, 1) < 0);
|
||||
assert(errno == EBADF);
|
||||
printf("STDIO_TEST:NON_BASIC:EBADF_OK\n");
|
||||
#endif
|
||||
printf("STDIO_TEST:CLOSE_OK\n");
|
||||
}
|
||||
|
||||
static void stdio_fd_init_check(void)
|
||||
|
||||
Reference in New Issue
Block a user