Lines Matching refs:pkg
86 struct receiving_pkg *pkg; in fill_pkg() local
98 list_for_each_entry(pkg, &receiving_list, list) { in fill_pkg()
99 if (rtn_seq != pkg->seq) in fill_pkg()
103 pkg->error = -msg->ack; in fill_pkg()
109 if (pkg->error != -EAGAIN) in fill_pkg()
110 *(pkg->data_size) = 0; in fill_pkg()
111 } else if (tfr->data_size > *(pkg->data_size)) { in fill_pkg()
113 tfr->request_type, tfr->data_size, *(pkg->data_size)); in fill_pkg()
115 *(pkg->data_size) = 0; in fill_pkg()
116 pkg->error = -ENOSPC; in fill_pkg()
118 pkg->error = tfr->error; in fill_pkg()
119 memcpy(pkg->data, tfr->data, tfr->data_size); in fill_pkg()
120 *(pkg->data_size) = tfr->data_size; in fill_pkg()
122 complete(&pkg->complete); in fill_pkg()
179 struct receiving_pkg pkg; in dm_consult_userspace() local
217 memset(&pkg, 0, sizeof(pkg)); in dm_consult_userspace()
218 init_completion(&pkg.complete); in dm_consult_userspace()
219 pkg.seq = tfr->seq; in dm_consult_userspace()
220 pkg.data_size = rdata_size; in dm_consult_userspace()
221 pkg.data = rdata; in dm_consult_userspace()
223 list_add(&(pkg.list), &receiving_list); in dm_consult_userspace()
234 list_del_init(&(pkg.list)); in dm_consult_userspace()
240 tmo = wait_for_completion_timeout(&(pkg.complete), DM_ULOG_RETRY_TIMEOUT); in dm_consult_userspace()
242 list_del_init(&(pkg.list)); in dm_consult_userspace()
248 request_type, pkg.seq); in dm_consult_userspace()
252 r = pkg.error; in dm_consult_userspace()