target/iscsi/iscsi_target_datain_values.c

22 	struct iscsi_datain_req *dr;
24 	dr = kmem_cache_zalloc(lio_dr_cache, GFP_ATOMIC);
25 	if (!dr) {
30 	INIT_LIST_HEAD(&dr->cmd_datain_node);
32 	return dr;
35 void iscsit_attach_datain_req(struct iscsit_cmd *cmd, struct iscsi_datain_req *dr)
38 	list_add_tail(&dr->cmd_datain_node, &cmd->datain_list);
42 void iscsit_free_datain_req(struct iscsit_cmd *cmd, struct iscsi_datain_req *dr)
45 	list_del(&dr->cmd_datain_node);
48 	kmem_cache_free(lio_dr_cache, dr);
53 	struct iscsi_datain_req *dr, *dr_tmp;
56 	list_for_each_entry_safe(dr, dr_tmp, &cmd->datain_list, cmd_datain_node) {
57 		list_del(&dr->cmd_datain_node);
58 		kmem_cache_free(lio_dr_cache, dr);
84 	struct iscsi_datain_req *dr;
86 	dr = iscsit_get_datain_req(cmd);
87 	if (!dr)
90 	if (dr->recovery && dr->generate_recovery_values) {
92 					cmd, dr) < 0)
95 		dr->generate_recovery_values = 0;
98 	next_burst_len = (!dr->recovery) ?
99 			cmd->next_burst_len : dr->next_burst_len;
100 	read_data_done = (!dr->recovery) ?
101 			cmd->read_data_done : dr->read_data_done;
136 	datain->data_sn = (!dr->recovery) ? cmd->data_sn++ : dr->data_sn++;
139 	if (!dr->recovery) {
143 		dr->next_burst_len = next_burst_len;
144 		dr->read_data_done += datain->length;
147 	if (!dr->recovery) {
149 			dr->dr_complete = DATAIN_COMPLETE_NORMAL;
151 		return dr;
154 	if (!dr->runlength) {
156 			dr->dr_complete =
157 			    (dr->recovery == DATAIN_WITHIN_COMMAND_RECOVERY) ?
162 		if ((dr->begrun + dr->runlength) == dr->data_sn) {
163 			dr->dr_complete =
164 			    (dr->recovery == DATAIN_WITHIN_COMMAND_RECOVERY) ?
170 	return dr;
182 	struct iscsi_datain_req *dr;
185 	dr = iscsit_get_datain_req(cmd);
186 	if (!dr)
189 	if (dr->recovery && dr->generate_recovery_values) {
191 					cmd, dr) < 0)
194 		dr->generate_recovery_values = 0;
197 	read_data_done = (!dr->recovery) ?
198 			cmd->read_data_done : dr->read_data_done;
199 	seq_send_order = (!dr->recovery) ?
200 			cmd->seq_send_order : dr->seq_send_order;
215 	if (!dr->recovery && !seq->next_burst_len)
257 	datain->data_sn = (!dr->recovery) ? cmd->data_sn++ : dr->data_sn++;
258 	if (!dr->recovery) {
262 		dr->seq_send_order = seq_send_order;
263 		dr->read_data_done += datain->length;
266 	if (!dr->recovery) {
270 			dr->dr_complete = DATAIN_COMPLETE_NORMAL;
272 		return dr;
275 	if (!dr->runlength) {
277 			dr->dr_complete =
278 			    (dr->recovery == DATAIN_WITHIN_COMMAND_RECOVERY) ?
283 		if ((dr->begrun + dr->runlength) == dr->data_sn) {
284 			dr->dr_complete =
285 			    (dr->recovery == DATAIN_WITHIN_COMMAND_RECOVERY) ?
291 	return dr;
303 	struct iscsi_datain_req *dr;
306 	dr = iscsit_get_datain_req(cmd);
307 	if (!dr)
310 	if (dr->recovery && dr->generate_recovery_values) {
312 					cmd, dr) < 0)
315 		dr->generate_recovery_values = 0;
318 	next_burst_len = (!dr->recovery) ?
319 			cmd->next_burst_len : dr->next_burst_len;
320 	read_data_done = (!dr->recovery) ?
321 			cmd->read_data_done : dr->read_data_done;
327 		return dr;
332 		return dr;
353 	pdu->data_sn = (!dr->recovery) ? cmd->data_sn++ : dr->data_sn++;
354 	if (!dr->recovery) {
358 		dr->next_burst_len = next_burst_len;
359 		dr->read_data_done += pdu->length;
367 	if (!dr->recovery) {
369 			dr->dr_complete = DATAIN_COMPLETE_NORMAL;
371 		return dr;
374 	if (!dr->runlength) {
376 			dr->dr_complete =
377 			    (dr->recovery == DATAIN_WITHIN_COMMAND_RECOVERY) ?
382 		if ((dr->begrun + dr->runlength) == dr->data_sn) {
383 			dr->dr_complete =
384 			    (dr->recovery == DATAIN_WITHIN_COMMAND_RECOVERY) ?
390 	return dr;
402 	struct iscsi_datain_req *dr;
406 	dr = iscsit_get_datain_req(cmd);
407 	if (!dr)
410 	if (dr->recovery && dr->generate_recovery_values) {
412 					cmd, dr) < 0)
415 		dr->generate_recovery_values = 0;
418 	read_data_done = (!dr->recovery) ?
419 			cmd->read_data_done : dr->read_data_done;
420 	seq_send_order = (!dr->recovery) ?
421 			cmd->seq_send_order : dr->seq_send_order;
436 	if (!dr->recovery && !seq->next_burst_len)
456 	pdu->data_sn = (!dr->recovery) ? cmd->data_sn++ : dr->data_sn++;
457 	if (!dr->recovery) {
461 		dr->seq_send_order = seq_send_order;
462 		dr->read_data_done += pdu->length;
470 	if (!dr->recovery) {
474 			dr->dr_complete = DATAIN_COMPLETE_NORMAL;
476 		return dr;
479 	if (!dr->runlength) {
481 			dr->dr_complete =
482 			    (dr->recovery == DATAIN_WITHIN_COMMAND_RECOVERY) ?
487 		if ((dr->begrun + dr->runlength) == dr->data_sn) {
488 			dr->dr_complete =
489 			    (dr->recovery == DATAIN_WITHIN_COMMAND_RECOVERY) ?
495 	return dr;