/kernel/linux/linux-5.10/fs/hmdfs/ |
D | hmdfs_server.h | 23 static inline void hmdfs_send_err_response(struct hmdfs_peer *con, in hmdfs_send_err_response() 30 void hmdfs_server_open(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd, 32 void hmdfs_server_atomic_open(struct hmdfs_peer *con, 34 void hmdfs_server_fsync(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd, 36 void hmdfs_server_release(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd, 38 void hmdfs_server_readpage(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd, 40 void hmdfs_server_readpages(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd, 42 void hmdfs_server_readpages_open(struct hmdfs_peer *con, 44 void hmdfs_server_writepage(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd, 47 void hmdfs_server_readdir(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd, [all …]
|
D | hmdfs_client.h | 34 int hmdfs_client_start_readdir(struct hmdfs_peer *con, struct file *filp, 37 int hmdfs_client_start_mkdir(struct hmdfs_peer *con, 40 int hmdfs_client_start_create(struct hmdfs_peer *con, 44 int hmdfs_client_start_rmdir(struct hmdfs_peer *con, const char *path, 46 int hmdfs_client_start_unlink(struct hmdfs_peer *con, const char *path, 48 int hmdfs_client_start_rename(struct hmdfs_peer *con, const char *old_path, 81 void hmdfs_writepage_cb(struct hmdfs_peer *peer, const struct hmdfs_req *req, 83 int hmdfs_client_writepage(struct hmdfs_peer *con, 85 int hmdfs_remote_do_writepage(struct hmdfs_peer *con, 92 int hmdfs_send_open(struct hmdfs_peer *con, const char *send_buf, [all …]
|
D | file_root.c | 27 struct hmdfs_peer *get_next_con(struct hmdfs_sb_info *sbi, in get_next_con() 30 struct hmdfs_peer *con = NULL; in get_next_con() 31 struct hmdfs_peer *next_con = NULL; in get_next_con() 40 next_con = container_of(node, struct hmdfs_peer, list); in get_next_con() 52 next_con = container_of(node, struct hmdfs_peer, list); in get_next_con() 70 struct hmdfs_peer *next_con = NULL; in hmdfs_device_iterate() 72 struct hmdfs_peer *con = NULL; in hmdfs_device_iterate()
|
D | inode.h | 70 struct hmdfs_peer *conn; // for remote inode 170 struct hmdfs_peer *con; 226 struct hmdfs_peer *peer); 232 struct hmdfs_peer; 234 struct hmdfs_peer *peer,
|
D | hmdfs_client.c | 32 int hmdfs_send_open(struct hmdfs_peer *con, const char *send_buf, in hmdfs_send_open() 76 void hmdfs_send_close(struct hmdfs_peer *con, const struct hmdfs_fid *fid) in hmdfs_send_close() 96 int hmdfs_send_fsync(struct hmdfs_peer *con, const struct hmdfs_fid *fid, in hmdfs_send_fsync() 124 int hmdfs_client_readpage(struct hmdfs_peer *con, const struct hmdfs_fid *fid, in hmdfs_client_readpage() 174 static void hmdfs_client_writepage_err(struct hmdfs_peer *peer, in hmdfs_client_writepage_err() 273 int hmdfs_remote_do_writepage(struct hmdfs_peer *con, in hmdfs_remote_do_writepage() 304 struct hmdfs_peer *peer = info->conn; in hmdfs_remote_writepage_retry() 318 void hmdfs_writepage_cb(struct hmdfs_peer *peer, const struct hmdfs_req *req, in hmdfs_writepage_cb() 352 int hmdfs_client_writepage(struct hmdfs_peer *con, in hmdfs_client_writepage() 413 int hmdfs_client_start_readdir(struct hmdfs_peer *con, struct file *filp, in hmdfs_client_start_readdir() [all …]
|
D | stash.c | 67 struct hmdfs_peer *conn; 102 struct hmdfs_peer *conn; 143 struct hmdfs_peer *conn; 148 typedef int (*stash_operation_func)(struct hmdfs_peer *, 286 struct hmdfs_peer *conn = info->conn; in hmdfs_flush_stash_file_metadata() 337 static void hmdfs_wait_remote_writeback_once(struct hmdfs_peer *conn, in hmdfs_wait_remote_writeback_once() 359 static void hmdfs_reset_remote_write_err(struct hmdfs_peer *conn, in hmdfs_reset_remote_write_err() 397 static int hmdfs_flush_stash_file_data(struct hmdfs_peer *conn, in hmdfs_flush_stash_file_data() 523 static int hmdfs_close_stash_file(struct hmdfs_peer *conn, in hmdfs_close_stash_file() 559 hmdfs_new_file_cache(struct hmdfs_peer *conn, struct hmdfs_inode_info *info) in hmdfs_new_file_cache() [all …]
|
D | hmdfs_device_view.h | 75 extern int hmdfs_remote_getattr(struct hmdfs_peer *conn, struct dentry *dentry, 101 extern int hmdfs_dev_unlink_from_con(struct hmdfs_peer *conn, 103 extern int hmdfs_dev_readdir_from_con(struct hmdfs_peer *con, struct file *file, 110 int hmdfs_remote_unlink(struct hmdfs_peer *conn, struct dentry *dentry); 163 struct inode *fill_inode_remote(struct super_block *sb, struct hmdfs_peer *con, 166 struct hmdfs_lookup_ret *get_remote_inode_info(struct hmdfs_peer *con, 176 struct hmdfs_lookup_ret *hmdfs_lookup_by_con(struct hmdfs_peer *con,
|
D | hmdfs_server.c | 35 static int insert_file_into_conn(struct hmdfs_peer *conn, struct file *file) in insert_file_into_conn() 53 static struct file *get_file_from_conn(struct hmdfs_peer *conn, __u32 file_id) in get_file_from_conn() 66 void remove_file_from_conn(struct hmdfs_peer *conn, __u32 file_id) in remove_file_from_conn() 109 void hmdfs_server_offline_notify(struct hmdfs_peer *conn, int evt, in hmdfs_server_offline_notify() 176 static int check_sec_level(struct hmdfs_peer *node, const char *file_name) in check_sec_level() 228 static struct file *hmdfs_open_file(struct hmdfs_peer *con, in hmdfs_open_file() 300 static uint64_t hmdfs_server_pack_fid_ver(struct hmdfs_peer *con, in hmdfs_server_pack_fid_ver() 310 static struct file *get_file_by_fid_and_ver(struct hmdfs_peer *con, in get_file_by_fid_and_ver() 330 static void hmdfs_update_open_response(struct hmdfs_peer *con, in hmdfs_update_open_response() 372 static int hmdfs_get_open_info(struct hmdfs_peer *con, uint8_t file_type, in hmdfs_get_open_info() [all …]
|
D | inode_remote.c | 71 struct hmdfs_lookup_ret *get_remote_inode_info(struct hmdfs_peer *con, in get_remote_inode_info() 116 struct hmdfs_peer *con = rw->con; in hmdfs_remote_readdir_work() 138 struct hmdfs_peer *con) in get_remote_dentry_file_in_wq() 164 void get_remote_dentry_file_sync(struct dentry *dentry, struct hmdfs_peer *con) in get_remote_dentry_file_sync() 170 struct hmdfs_lookup_ret *hmdfs_lookup_by_con(struct hmdfs_peer *con, in hmdfs_lookup_by_con() 341 struct inode *fill_inode_remote(struct super_block *sb, struct hmdfs_peer *con, in fill_inode_remote() 416 struct hmdfs_peer *con = NULL; in hmdfs_lookup_remote_dentry() 533 int hmdfs_mkdir_remote_dentry(struct hmdfs_peer *conn, struct dentry *dentry, in hmdfs_mkdir_remote_dentry() 581 struct hmdfs_peer *con = info->conn; in hmdfs_mkdir_remote() 602 int hmdfs_create_remote_dentry(struct hmdfs_peer *conn, struct dentry *dentry, in hmdfs_create_remote_dentry() [all …]
|
D | hmdfs_dentryfile.h | 177 struct file *cache_file_persistent(struct hmdfs_peer *con, struct file *filp, 213 void hmdfs_add_remote_cache_list(struct hmdfs_peer *con, const char *dir_path); 216 struct hmdfs_peer *con; 248 void hmdfs_send_drop_push(struct hmdfs_peer *con, const char *path); 257 void hmdfs_remove_cache_filp(struct hmdfs_peer *con, struct dentry *dentry); 293 bool get_remote_dentry_file(struct dentry *dentry, struct hmdfs_peer *con); 294 void get_remote_dentry_file_sync(struct dentry *dentry, struct hmdfs_peer *con);
|
D | file_remote.h | 17 void hmdfs_remote_del_wr_opened_inode(struct hmdfs_peer *conn, 20 void hmdfs_remote_add_wr_opened_inode_nolock(struct hmdfs_peer *conn,
|
D | stash.h | 19 extern int hmdfs_stash_writepage(struct hmdfs_peer *conn, 22 extern void hmdfs_remote_init_stash_status(struct hmdfs_peer *conn,
|
D | inode.c | 61 struct hmdfs_peer *peer; 210 struct hmdfs_peer *peer, in hmdfs_iget5_locked_remote() 233 struct hmdfs_peer *peer) in hmdfs_iget_locked_root()
|
D | file_remote.c | 160 struct hmdfs_peer *conn = info->conn; in hmdfs_do_open_remote() 216 struct hmdfs_peer *conn = info->conn; in hmdfs_remote_file_reopen() 305 void hmdfs_remote_del_wr_opened_inode(struct hmdfs_peer *conn, in hmdfs_remote_del_wr_opened_inode() 313 void hmdfs_remote_add_wr_opened_inode_nolock(struct hmdfs_peer *conn, in hmdfs_remote_add_wr_opened_inode_nolock() 325 static void hmdfs_remote_add_wr_opened_inode(struct hmdfs_peer *conn, in hmdfs_remote_add_wr_opened_inode() 579 struct hmdfs_peer *conn = info->conn; in hmdfs_file_fsync_remote() 970 int hmdfs_dev_readdir_from_con(struct hmdfs_peer *con, struct file *file, in hmdfs_dev_readdir_from_con() 984 struct hmdfs_peer *con = NULL; in hmdfs_iterate_remote()
|
/kernel/linux/linux-5.10/fs/hmdfs/comm/ |
D | connection.h | 58 struct hmdfs_peer *node; 140 struct hmdfs_peer { struct 281 static inline bool hmdfs_is_node_online(const struct hmdfs_peer *node) in hmdfs_is_node_online() 286 static inline unsigned int hmdfs_node_inc_evt_seq(struct hmdfs_peer *node) in hmdfs_node_inc_evt_seq() 292 static inline unsigned int hmdfs_node_evt_seq(const struct hmdfs_peer *node) in hmdfs_node_evt_seq() 297 struct connection *get_conn_impl(struct hmdfs_peer *node, int connect_type); 299 void set_conn_sock_quickack(struct hmdfs_peer *node); 301 struct hmdfs_peer *hmdfs_get_peer(struct hmdfs_sb_info *sbi, uint8_t *cid, 304 struct hmdfs_peer *hmdfs_lookup_from_devid(struct hmdfs_sb_info *sbi, 306 struct hmdfs_peer *hmdfs_lookup_from_cid(struct hmdfs_sb_info *sbi, [all …]
|
D | socket_adapter.h | 27 void (*recvmsg)(struct hmdfs_peer *con, void *head, void *buf); 28 void (*recvpage)(struct hmdfs_peer *con, struct hmdfs_head_cmd *head, 33 int (*remote_unlink)(struct hmdfs_peer *con, struct dentry *dentry); 34 int (*remote_readdir)(struct hmdfs_peer *con, struct file *file, 36 struct hmdfs_lookup_ret *(*remote_lookup)(struct hmdfs_peer *con, 47 struct hmdfs_peer *peer; 54 struct hmdfs_peer *con; 66 int hmdfs_send_async_request(struct hmdfs_peer *peer, 68 int hmdfs_sendmessage_request(struct hmdfs_peer *con, 70 int hmdfs_sendpage_request(struct hmdfs_peer *con, [all …]
|
D | connection.c | 411 static int hmdfs_node_waiting_evt_sum(const struct hmdfs_peer *node) in hmdfs_node_waiting_evt_sum() 422 static int hmdfs_update_node_waiting_evt(struct hmdfs_peer *node, int evt, in hmdfs_update_node_waiting_evt() 464 static void hmdfs_run_evt_cb_verbosely(struct hmdfs_peer *node, int raw_evt, in hmdfs_run_evt_cb_verbosely() 479 struct hmdfs_peer *node = in hmdfs_node_evt_work() 480 container_of(work, struct hmdfs_peer, evt_dwork.work); in hmdfs_node_evt_work() 521 static void hmdfs_queue_raw_node_evt(struct hmdfs_peer *node, int evt) in hmdfs_queue_raw_node_evt() 571 void connection_handshake_notify(struct hmdfs_peer *node, int notify_type) in connection_handshake_notify() 582 void peer_online(struct hmdfs_peer *peer) in peer_online() 595 void connection_to_working(struct hmdfs_peer *node) in connection_to_working() 813 struct hmdfs_peer *peer = container_of(ref, struct hmdfs_peer, ref_cnt); in hmdfs_peer_release() [all …]
|
D | device_node.h | 80 void notify(struct hmdfs_peer *node, struct notify_param *param); 85 struct hmdfs_peer *peer); 86 void hmdfs_release_peer_sysfs(struct hmdfs_peer *peer); 105 static inline struct hmdfs_peer *to_peer(struct kobject *x) in to_peer() 107 return container_of(x, struct hmdfs_peer, kobj); in to_peer()
|
D | node_cb.h | 24 struct hmdfs_peer; 26 typedef void (*hmdfs_node_evt_cb)(struct hmdfs_peer *conn, 41 extern void hmdfs_node_call_evt_cb(struct hmdfs_peer *node, int evt, bool sync,
|
D | socket_adapter.c | 27 typedef void (*request_callback)(struct hmdfs_peer *, struct hmdfs_head_cmd *, 29 typedef void (*response_callback)(struct hmdfs_peer *, 57 typedef void (*file_request_callback)(struct hmdfs_peer *, 61 void (*on_wakeup)(struct hmdfs_peer *peer, const struct hmdfs_req *req, 73 struct hmdfs_peer *con; in msg_release() 101 static int msg_init(struct hmdfs_peer *con, struct sendmsg_wait_queue *msg_wq) in msg_init() 117 static inline void statistic_con_sb_dirty(struct hmdfs_peer *con, in statistic_con_sb_dirty() 124 int hmdfs_sendmessage(struct hmdfs_peer *node, struct hmdfs_send_data *msg) in hmdfs_sendmessage() 208 int hmdfs_sendmessage_response(struct hmdfs_peer *con, in hmdfs_sendmessage_response() 239 struct hmdfs_peer *peer = NULL; in mp_release() [all …]
|
D | transport.h | 64 void hmdfs_get_connection(struct hmdfs_peer *peer); 66 struct connection *hmdfs_get_conn_tcp(struct hmdfs_peer *node, int socket_fd, 69 uint32_t hmdfs_tcpi_rtt(struct hmdfs_peer *node);
|
D | device_node.c | 32 struct hmdfs_peer *conn; 42 struct hmdfs_peer *node = NULL; in ctrl_cmd_update_socket_handler() 80 struct hmdfs_peer *node = NULL; in ctrl_cmd_update_devsl_handler() 98 static inline void hmdfs_disconnect_node_marked(struct hmdfs_peer *conn) in hmdfs_disconnect_node_marked() 109 struct hmdfs_peer *node = NULL; in ctrl_cmd_off_line_handler() 140 struct hmdfs_peer *node = NULL; in ctrl_cmd_off_line_all_handler() 251 struct hmdfs_peer *peer = NULL; in sbi_status_show() 294 struct hmdfs_peer *peer = NULL; in sbi_stat_show() 325 struct hmdfs_peer *peer = NULL; in sbi_stat_store() 1042 struct hmdfs_peer *peer = NULL; in sbi_show_idr_stats() [all …]
|
D | message_verify.h | 24 int hmdfs_message_verify(struct hmdfs_peer *con, struct hmdfs_head_cmd *head,
|
D | transport.c | 79 uint32_t hmdfs_tcpi_rtt(struct hmdfs_peer *con) in hmdfs_tcpi_rtt() 220 struct hmdfs_peer *node = NULL; in tcp_recvpage_tls() 895 struct hmdfs_peer *node = NULL; in tcp_update_socket() 996 void hmdfs_get_connection(struct hmdfs_peer *peer) in hmdfs_get_connection() 1011 struct hmdfs_peer *peer = NULL; in connection_notify_to_close() 1081 lookup_conn_by_socketfd_unsafe(struct hmdfs_peer *node, struct socket *socket) in lookup_conn_by_socketfd_unsafe() 1107 struct connection *alloc_conn_tcp(struct hmdfs_peer *node, int socket_fd, in alloc_conn_tcp() 1140 static struct connection *add_conn_tcp_unsafe(struct hmdfs_peer *node, in add_conn_tcp_unsafe() 1161 struct connection *hmdfs_get_conn_tcp(struct hmdfs_peer *node, int fd, in hmdfs_get_conn_tcp()
|
D | node_cb.c | 58 void hmdfs_node_call_evt_cb(struct hmdfs_peer *conn, int evt, bool sync, in hmdfs_node_call_evt_cb()
|