Lines Matching refs:cur_from_user
159 struct message *cur_from_user; member
730 c->cur_from_user = &c->scratch_message_from_user; in channel_alloc()
757 if (c->cur_from_user != &c->scratch_message_from_user) in channel_free()
758 message_kill(c->cur_from_user, &c->target->message_pool); in channel_free()
912 WARN_ON(c->cur_from_user == NULL); in dev_write()
913 if (c->cur_from_user->posn_from_user < sizeof(struct dm_user_message)) { in dev_write()
916 processed = msg_copy_from_iov(c->cur_from_user, from); in dev_write()
930 if (unlikely(c->cur_from_user->posn_from_user < in dev_write()
934 old = c->cur_from_user; in dev_write()
936 msg = msg_get_from_user(c, c->cur_from_user->msg.seq); in dev_write()
951 c->cur_from_user = msg; in dev_write()
959 switch (c->cur_from_user->return_type) { in dev_write()
961 c->cur_from_user->bio->bi_status = BLK_STS_OK; in dev_write()
966 c->cur_from_user->bio->bi_status = BLK_STS_IOERR; in dev_write()
976 processed = msg_copy_from_iov(c->cur_from_user, from); in dev_write()
979 if (c->cur_from_user->posn_from_user < in dev_write()
980 c->cur_from_user->total_from_user) in dev_write()
989 WARN_ON(bio_size(c->cur_from_user->bio) != 0); in dev_write()
990 bio_endio(c->cur_from_user->bio); in dev_write()
997 WARN_ON(c->cur_from_user == &c->scratch_message_from_user); in dev_write()
998 mempool_free(c->cur_from_user, &c->target->message_pool); in dev_write()
1000 c->cur_from_user = &c->scratch_message_from_user; in dev_write()