Lines Matching defs:conn
68 hmdfs_send_close(info->conn, &open_ret->fid);
160 struct hmdfs_peer *conn = info->conn;
171 err = hmdfs_send_open(conn, send_buf, file_type, &open_ret);
216 struct hmdfs_peer *conn = info->conn;
220 if (conn->status == NODE_STAT_OFFLINE)
249 hmdfs_send_close(conn, &fid);
288 hmdfs_send_close(info->conn, &fid);
305 void hmdfs_remote_del_wr_opened_inode(struct hmdfs_peer *conn,
308 spin_lock(&conn->wr_opened_inode_lock);
310 spin_unlock(&conn->wr_opened_inode_lock);
313 void hmdfs_remote_add_wr_opened_inode_nolock(struct hmdfs_peer *conn,
319 &conn->wr_opened_inode_list);
325 static void hmdfs_remote_add_wr_opened_inode(struct hmdfs_peer *conn,
328 spin_lock(&conn->wr_opened_inode_lock);
329 hmdfs_remote_add_wr_opened_inode_nolock(conn, info);
330 spin_unlock(&conn->wr_opened_inode_lock);
351 hmdfs_remote_add_wr_opened_inode(info->conn, info);
398 err = hmdfs_remote_getattr(info->conn, file_dentry(file), 0,
426 hmdfs_remote_del_wr_opened_inode(info->conn, info);
479 rtt = hmdfs_tcpi_rtt(info->conn) / 10000;
508 !hmdfs_is_node_online(info->conn);
579 struct hmdfs_peer *conn = info->conn;
583 trace_hmdfs_fsync_enter_remote(conn->sbi, conn->device_id,
601 err = hmdfs_send_fsync(conn, &fid, start, end, datasync);
606 trace_hmdfs_fsync_exit_remote(conn->sbi, conn->device_id,
608 get_cmd_timeout(conn->sbi, F_FSYNC), err);
661 return hmdfs_client_readpage(info->conn, &fid, page);
759 ret = hmdfs_remote_do_writepage(info->conn, param);
1030 if (info->conn) {
1031 if (!hmdfs_cache_revalidate(READ_ONCE(info->conn->conn_time),
1032 info->conn->device_id,
1035 info->conn);
1036 cache_item = hmdfs_find_cache_item(info->conn->device_id,