Lines Matching defs:mtask
367 struct iscsi_mgmt_task *mtask;
403 mtask = session->mgmt_cmds[itt - ISCSI_MGMT_ITT_OFFSET];
406 opcode, conn->id, mtask->itt, datalen);
429 list_del(&mtask->running);
430 if (conn->login_mtask != mtask)
432 (void*)&mtask, sizeof(void*));
451 list_del(&mtask->running);
452 if (conn->login_mtask != mtask)
454 (void*)&mtask, sizeof(void*));
583 struct iscsi_hdr *hdr = conn->mtask->hdr;
591 rc = conn->session->tt->xmit_mgmt_task(conn, conn->mtask);
595 /* done with this in-progress mtask */
596 conn->mtask = NULL;
628 * 1) un-finished xmit (ctask or mtask)
638 BUG_ON(conn->ctask && conn->mtask);
649 if (conn->mtask) {
657 while (__kfifo_get(conn->immqueue, (void*)&conn->mtask,
660 list_add_tail(&conn->mtask->running,
698 while (__kfifo_get(conn->mgmtqueue, (void*)&conn->mtask,
701 list_add_tail(&conn->mtask->running,
813 ctask->mtask = NULL;
865 struct iscsi_mgmt_task *mtask;
877 * Same mtask can be used. Same ITT must be used.
880 mtask = conn->login_mtask;
887 (void*)&mtask, sizeof(void*))) {
897 hdr->itt = build_itt(mtask->itt, conn->id, session->age);
907 memcpy(mtask->data, data, data_size);
908 mtask->data_count = data_size;
910 mtask->data_count = 0;
912 INIT_LIST_HEAD(&mtask->running);
913 memcpy(mtask->hdr, hdr, sizeof(struct iscsi_hdr));
915 session->tt->init_mgmt_task(conn, mtask, data, data_size);
927 __kfifo_put(conn->immqueue, (void*)&mtask, sizeof(void*));
929 __kfifo_put(conn->mgmtqueue, (void*)&mtask, sizeof(void*));
1062 ctask->mtask = (struct iscsi_mgmt_task *)
1127 if (!ctask->mtask)
1130 if (!iscsi_remove_mgmt_task(conn->immqueue, ctask->mtask->itt))
1131 list_del(&ctask->mtask->running);
1132 __kfifo_put(session->mgmtpool.queue, (void*)&ctask->mtask,
1134 ctask->mtask = NULL;
1411 struct iscsi_mgmt_task *mtask = session->mgmt_cmds[cmd_i];
1414 mtask->dd_data = &mtask[1];
1415 mtask->itt = ISCSI_MGMT_ITT_OFFSET + cmd_i;
1416 INIT_LIST_HEAD(&mtask->running);
1671 struct iscsi_mgmt_task *mtask, *tmp;
1674 while (__kfifo_get(conn->immqueue, (void*)&mtask, sizeof(void*)) ||
1675 __kfifo_get(conn->mgmtqueue, (void*)&mtask, sizeof(void*))) {
1676 if (mtask == conn->login_mtask)
1678 debug_scsi("flushing pending mgmt task itt 0x%x\n", mtask->itt);
1679 __kfifo_put(session->mgmtpool.queue, (void*)&mtask,
1684 list_for_each_entry_safe(mtask, tmp, &conn->mgmt_run_list, running) {
1685 debug_scsi("flushing running mgmt task itt 0x%x\n", mtask->itt);
1686 list_del(&mtask->running);
1688 if (mtask == conn->login_mtask)
1690 __kfifo_put(session->mgmtpool.queue, (void*)&mtask,
1694 conn->mtask = NULL;