Home
last modified time | relevance | path

Searched refs:hmdfs_peer (Results 1 – 25 of 35) sorted by relevance

12

/kernel/linux/linux-5.10/fs/hmdfs/
Dhmdfs_server.h23 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 …]
Dhmdfs_client.h34 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 …]
Dfile_root.c27 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()
Dinode.h70 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,
Dhmdfs_client.c32 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 …]
Dstash.c67 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 …]
Dhmdfs_device_view.h75 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,
Dhmdfs_server.c35 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 …]
Dinode_remote.c71 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 …]
Dhmdfs_dentryfile.h177 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);
Dfile_remote.h17 void hmdfs_remote_del_wr_opened_inode(struct hmdfs_peer *conn,
20 void hmdfs_remote_add_wr_opened_inode_nolock(struct hmdfs_peer *conn,
Dstash.h19 extern int hmdfs_stash_writepage(struct hmdfs_peer *conn,
22 extern void hmdfs_remote_init_stash_status(struct hmdfs_peer *conn,
Dinode.c61 struct hmdfs_peer *peer;
210 struct hmdfs_peer *peer, in hmdfs_iget5_locked_remote()
233 struct hmdfs_peer *peer) in hmdfs_iget_locked_root()
Dfile_remote.c160 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/
Dconnection.h58 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 …]
Dsocket_adapter.h27 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 …]
Dconnection.c411 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 …]
Ddevice_node.h80 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()
Dnode_cb.h24 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,
Dsocket_adapter.c27 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 …]
Dtransport.h64 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);
Ddevice_node.c32 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 …]
Dmessage_verify.h24 int hmdfs_message_verify(struct hmdfs_peer *con, struct hmdfs_head_cmd *head,
Dtransport.c79 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()
Dnode_cb.c58 void hmdfs_node_call_evt_cb(struct hmdfs_peer *conn, int evt, bool sync, in hmdfs_node_call_evt_cb()

12