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);
310 struct hmdfs_peer *peer = info->conn;
314 old_cred = hmdfs_override_creds(peer->sbi->cred);
315 err = hmdfs_remote_do_writepage(peer, ctx);
318 hmdfs_client_writepage_err(peer, info, ctx, err);
324 void hmdfs_writepage_cb(struct hmdfs_peer *peer, const struct hmdfs_req *req,
332 trace_hmdfs_writepage_cb_enter(peer, info->remote_ino, page_index, ret);
340 if (hmdfs_client_redo_writepage(peer->sbi, ctx, ret)) {
341 ret = hmdfs_remote_do_writepage(peer, ctx);
347 hmdfs_client_writepage_err(peer, info, ctx, ret);
355 trace_hmdfs_writepage_cb_exit(peer, info->remote_ino, page_index, ret);
409 hmdfs_client_resp_statis(async_work->head.peer->sbi, F_READPAGE,
412 trace_hmdfs_client_recv_readpage(async_work->head.peer,
989 void hmdfs_recv_syncfs_cb(struct hmdfs_peer *peer, const struct hmdfs_req *req,
992 struct hmdfs_sb_info *sbi = peer->sbi;
1000 le64_to_cpu(syncfs_req->version), peer->device_id,
1011 resp->ret_code, peer->device_id);
1017 atomic64_cmpxchg(&peer->sb_dirty_count,
1018 peer->old_sb_dirty_count, 0);
1051 static void *hmdfs_get_msg_next(struct hmdfs_peer *peer, int *id)
1055 spin_lock(&peer->idr_lock);
1056 head = idr_get_next(&peer->msg_idr, id);
1060 spin_unlock(&peer->idr_lock);