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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
/*
* Copyright (c) 2006-2025 RT-Thread Development Team
*
* SPDX-License-Identifier: Apache-2.0
*
* Change Logs:
* Date Author Notes
* 2023-05-05 RTT Implement dentry in dfs v2.0
*/
#ifndef DFS_PAGE_CACHE_H__
#define DFS_PAGE_CACHE_H__
#include <rtthread.h>
#ifdef RT_USING_PAGECACHE
#include <dfs_file.h>
#include <avl.h>
#ifdef __cplusplus
extern "C"
{
#endif
struct rt_varea;
struct rt_aspace;
struct dfs_vnode;
struct dfs_dentry;
struct dfs_aspace;
/* Memory mapping structure for page cache */
struct dfs_mmap
{
rt_list_t mmap_node; /* List node for address space's mmap list */
struct rt_aspace *aspace; /* Address space this mapping belongs to */
void *vaddr; /* Virtual address where the page is mapped */
};
/* Page structure for file system page cache */
struct dfs_page
{
rt_list_t space_node; /* Node for address space's page list */
rt_list_t dirty_node; /* Node for dirty page list */
struct util_avl_struct avl_node; /* Node for AVL tree in address space */
rt_list_t mmap_head; /* Head of memory mappings list */
rt_atomic_t ref_count; /* Reference count for this page */
void *page; /* Pointer to physical page data */
off_t fpos; /* File position this page represents */
size_t size; /* Total size of the page */
size_t len; /* Valid data length in the page */
int is_dirty; /* Dirty flag indicating if page needs writeback */
rt_tick_t tick_ms; /* Last access timestamp */
struct dfs_aspace *aspace; /* Address space this page belongs to */
};
/* Address space operations interface */
struct dfs_aspace_ops
{
ssize_t (*read)(struct dfs_file *file, struct dfs_page *page); /* Read operation for page cache */
ssize_t (*write)(struct dfs_page *page); /* Write operation for page cache */
};
/* Address space structure for page cache management */
struct dfs_aspace
{
rt_list_t hash_node, cache_node; /* Nodes for hash table and cache lists */
char *fullpath, *pathname; /* Full path and relative path strings */
struct dfs_mnt *mnt; /* Mount point this space belongs to */
rt_list_t list_active, list_inactive; /* Active and inactive page lists */
rt_list_t list_dirty; /* Dirty page list */
size_t pages_count; /* Total pages in this space */
struct util_avl_root avl_root; /* AVL tree root for page lookup */
struct dfs_page *avl_page; /* Current AVL tree page */
rt_bool_t is_active; /* Active/inactive status flag */
struct rt_mutex lock; /* Mutex for thread safety */
rt_atomic_t ref_count; /* Reference counter */
struct dfs_vnode *vnode; /* Associated vnode */
const struct dfs_aspace_ops *ops; /* Operations interface */
};
#ifndef RT_PAGECACHE_HASH_NR
#define RT_PAGECACHE_HASH_NR 1024
#endif
/* Global page cache management structure */
struct dfs_pcache
{
rt_list_t head[RT_PAGECACHE_HASH_NR]; /* Hash table buckets for address spaces */
rt_list_t list_active, list_inactive; /* Active and inactive space lists */
rt_atomic_t pages_count; /* Total cached pages count */
struct rt_mutex lock; /* Global lock for thread safety */
struct rt_messagequeue *mqueue; /* Message queue for sending GC/WB command.*/
rt_tick_t last_time_wb; /* Last writeback timestamp */
};
struct dfs_aspace *dfs_aspace_create(struct dfs_dentry *dentry, struct dfs_vnode *vnode, const struct dfs_aspace_ops *ops);
int dfs_aspace_destroy(struct dfs_aspace *aspace);
int dfs_aspace_read(struct dfs_file *file, void *buf, size_t count, off_t *pos);
int dfs_aspace_write(struct dfs_file *file, const void *buf, size_t count, off_t *pos);
int dfs_aspace_flush(struct dfs_aspace *aspace);
int dfs_aspace_clean(struct dfs_aspace *aspace);
void *dfs_aspace_mmap(struct dfs_file *file, struct rt_varea *varea, void *vaddr);
int dfs_aspace_unmap(struct dfs_file *file, struct rt_varea *varea);
int dfs_aspace_page_unmap(struct dfs_file *file, struct rt_varea *varea, void *vaddr);
int dfs_aspace_page_dirty(struct dfs_file *file, struct rt_varea *varea, void *vaddr);
off_t dfs_aspace_fpos(struct rt_varea *varea, void *vaddr);
void *dfs_aspace_vaddr(struct rt_varea *varea, off_t fpos);
int dfs_aspace_mmap_read(struct dfs_file *file, struct rt_varea *varea, void *data);
int dfs_aspace_mmap_write(struct dfs_file *file, struct rt_varea *varea, void *data);
void dfs_pcache_release(size_t count);
void dfs_pcache_unmount(struct dfs_mnt *mnt);
void dfs_pcache_clean(struct dfs_mnt *mnt);
#ifdef __cplusplus
}
#endif
#endif
#endif
|
