Lines Matching refs:peer
180 static void hmdfs_client_writepage_err(struct hmdfs_peer *peer,
193 page->index, ctx->fid.id, err, peer->device_id);
309 struct hmdfs_peer *peer = info->conn;
313 old_cred = hmdfs_override_creds(peer->sbi->cred);
314 err = hmdfs_remote_do_writepage(peer, ctx);
317 hmdfs_client_writepage_err(peer, info, ctx, err);
323 void hmdfs_writepage_cb(struct hmdfs_peer *peer, const struct hmdfs_req *req,
331 trace_hmdfs_writepage_cb_enter(peer, info->remote_ino, page_index, ret);
339 if (hmdfs_client_redo_writepage(peer->sbi, ctx, ret)) {
340 ret = hmdfs_remote_do_writepage(peer, ctx);
346 hmdfs_client_writepage_err(peer, info, ctx, ret);
354 trace_hmdfs_writepage_cb_exit(peer, info->remote_ino, page_index, ret);
408 hmdfs_client_resp_statis(async_work->head.peer->sbi, F_READPAGE,
411 trace_hmdfs_client_recv_readpage(async_work->head.peer,
988 void hmdfs_recv_syncfs_cb(struct hmdfs_peer *peer, const struct hmdfs_req *req,
991 struct hmdfs_sb_info *sbi = peer->sbi;
999 le64_to_cpu(syncfs_req->version), peer->device_id,
1010 resp->ret_code, peer->device_id);
1016 atomic64_cmpxchg(&peer->sb_dirty_count,
1017 peer->old_sb_dirty_count, 0);
1050 static void *hmdfs_get_msg_next(struct hmdfs_peer *peer, int *id)
1054 spin_lock(&peer->idr_lock);
1055 head = idr_get_next(&peer->msg_idr, id);
1059 spin_unlock(&peer->idr_lock);