loader/net/iSCSITarget.cpp

191 	scsi_res_read_capacity resp;
193 		true, false, sizeof(resp),
194 		&resp, 0, sizeof(resp));
199 	TRACE("lba = %lu, block size = %lu\n", resp.lba, resp.block_size);
200 	fLastLBA = resp.lba;
201 	fBlockSize = resp.block_size;
414 	iscsi_login_response resp;
416 	error = fSocket->Read(&resp, sizeof(resp), &bytesRead, 10000000LL);
423 		resp.opcode, resp.statusClass, resp.statusDetail, resp.transit, resp.dataSegmentLength);
424 	if (resp.dataSegmentLength > 0) {
425 		error = fSocket->Read(data, resp.dataSegmentLength, &bytesRead, 1000000LL);
431 		if (resp.dataSegmentLength % ISCSI_ALIGNMENT) {
432 			error = fSocket->Read(NULL, ISCSI_PADDING(resp.dataSegmentLength), &bytesRead, 100000LL);
439 		for (char* pair = data; pair < data + resp.dataSegmentLength; pair += strlen(pair) + 1) {
446 	fStatusSequenceNumber = resp.statSN;
447 	if (resp.statusClass != 0) {
475 	iscsi_logout_response resp;
476 	TRACE("resp size = %lu\n", sizeof(resp));
478 	error = fSocket->Read(&resp, sizeof(resp), &bytesRead, 10000000LL);
485 		resp.opcode, resp.response);
486 	fStatusSequenceNumber = resp.statSN;
487 	if (resp.response != 0) {
532 	iscsi_logout_response resp;
534 	error = fSocket->Read(&resp, sizeof(resp), &bytesRead, 10000000LL);
541 		resp.opcode);
542 	*response = (char*)malloc(resp.dataSegmentLength);
545 	error = fSocket->Read(*response, resp.dataSegmentLength, &bytesRead, 10000000LL);
551 	*responseLength = resp.dataSegmentLength;
552 	if ((resp.dataSegmentLength % ISCSI_ALIGNMENT) != 0) {
553 		error = fSocket->Read(NULL, ISCSI_PADDING(resp.dataSegmentLength), &bytesRead, 1000000LL);
559 	fStatusSequenceNumber = resp.statSN;
560 	if (resp.opcode != ISCSI_OPCODE_TEXT_RESPONSE) {
613 	struct iscsi_basic_header_segment resp;
614 	error = _ReadResponse(&resp);
619 	while (r && resp.opcode != ISCSI_OPCODE_SCSI_RESPONSE) {
620 		if (resp.opcode != ISCSI_OPCODE_SCSI_DATA_IN)
621 			PANIC("response opcode %x unexpected\n", resp.opcode);
622 		iscsi_scsi_data_in* dataIn = (iscsi_scsi_data_in*)&resp;
623 		TRACE("A=%u, S=%u, bufferOffset=%lu, length = %lu\n", dataIn->acknowledge, dataIn->S, dataIn->bufferOffset, resp.dataSegmentLength);
624 		if (resp.dataSegmentLength > 0) {
625 			size_t toRead = resp.dataSegmentLength;
628 				toSkip = MIN(responseOffset - dataIn->bufferOffset, resp.dataSegmentLength);
638 				if (dataIn->bufferOffset + resp.dataSegmentLength > responseOffset + responseLength) {
640 					toRead = MIN(expectedDataTransferLength - cutOff - dataIn->bufferOffset, resp.dataSegmentLength) - toSkip;
648 			size_t toCutOff = resp.dataSegmentLength - toSkip - toRead;
656 			if (toSkip + toRead + toCutOff != resp.dataSegmentLength)
659 		if ((resp.dataSegmentLength % ISCSI_ALIGNMENT) != 0) {
660 			error = _Read(NULL, ISCSI_PADDING(resp.dataSegmentLength));
672 		error = _ReadResponse(&resp);
680 		resp.opcode, resp.totalAHSLength, resp.dataSegmentLength);
681 	if (resp.opcode != ISCSI_OPCODE_SCSI_RESPONSE) {
685 	iscsi_scsi_response* scsiResp = (iscsi_scsi_response*)&resp;
688 	if (resp.dataSegmentLength > 0) {
691 			buffer = malloc(resp.dataSegmentLength);
692 		error = _Read(buffer, resp.dataSegmentLength);
706 	if ((resp.dataSegmentLength % ISCSI_ALIGNMENT) != 0) {
707 		error = _Read(NULL, ISCSI_PADDING(resp.dataSegmentLength));
722 iSCSIConnection::_ReadResponse(iscsi_basic_header_segment* resp, bigtime_t timeout)
724 	if (resp == NULL)
727 	status_t error = _Read(resp, sizeof(iscsi_basic_header_segment), timeout);
733 	if (resp->reserved == true) {
741 	while (resp->opcode == ISCSI_OPCODE_NOP_IN) {
742 		iscsi_nop_in* nopIn = (iscsi_nop_in*)resp;
799 		error = _Read(resp, sizeof(iscsi_basic_header_segment), timeout);