import java.util.LinkedList;
import java.util.Iterator;

//此類實(shí)現(xiàn)系統(tǒng)進(jìn)程2的功能，包括檢測(cè)輸入井是否有作業(yè)，內(nèi)存空間是否足以存放一個(gè)作業(yè)程序，
//若兩者均滿足，則將作業(yè)JCB項(xiàng)改為已調(diào)試（值為0），且在PCB就緒隊(duì)列添加此作業(yè)；
public class MosP2 {
	MosMM mm = null;
	MosDisk disk = null;
	MosChannel3 chan3 = null;
	LinkedList que_jcb_ready = null;
	LinkedList que_jcb_start = null;
	LinkedList que_pcb_ready = null;
	MosJCB mj = null;
	MosPCB mp = null;
	MosBlock mb = null;
	MosVar var = null;
	int p2_interrupt = 0;
	int page_size = 0;
	long chan3_time = 0;
	byte[] block_table = null;
	byte[] page_table = null;
	MosCPU cpu = null;
	MosP1 p1 = null;
	byte[] mm_data = new byte[4];
	byte[] disk_data = new byte[40];
	String s1 = "";
	
	public MosP2(MosMM mm,MosDisk disk,MosChannel3 chan3,LinkedList que_jcb_ready,
			LinkedList que_jcb_start,LinkedList que_pcb_ready,MosVar var,
			MosCPU cpu,MosP1 p1) {
		this.mm = mm;
		this.disk = disk;
		this.chan3 = chan3;
		this.que_jcb_ready = que_jcb_ready;
		this.que_jcb_start = que_jcb_start;
		this.que_pcb_ready = que_pcb_ready;
		this.var = var;
		this.cpu = cpu;
		this.p1 = p1;
	}
	
	public void p2Start() {
//		p2_interrupt為０為檢測(cè)que_jcb_ready隊(duì)列是否為空；
		if(this.p2_interrupt == 0) {
			mj = test();
			if(null != mj) {
				mb = mj.getJcbInputTable();
				block_table = mb.getBlockTable();
				this.p2_interrupt = 1;
			}
		}
//		p2_interrupt為１表示申請(qǐng)內(nèi)存空間；
		if(this.p2_interrupt == 1) {
			page_table = mm.mmMalloc((byte)block_table.length);
			if(null != this.page_table) {
				this.page_size = 0;
				this.p2_interrupt = 2;
			}
		}
//		p2_interrupt為２表示檢測(cè)通道３是否為忙；
		if(this.p2_interrupt == 2) {
			if(chan3.getMosChst() == FinalVar.CHST_STAT_FREE) {
				chan3.setMosChst(FinalVar.CHST_STAT_BUSY);
				this.chan3_time = var.getTime();
				this.p2_interrupt = 3;
			}
		}
//		p2_interrupt為３表示本進(jìn)程啟動(dòng)通道３后，檢測(cè)是否一個(gè)時(shí)間片已到，若到達(dá)則傳送數(shù)據(jù)；
		if(this.p2_interrupt == 3) {
			if(var.getTime() >= (this.chan3_time + 1)) {
				chan3.startChannel3(FinalVar.CHST3_WRITE, block_table[this.page_size], page_table[this.page_size]);
				chan3.setMosChst(FinalVar.CHST_STAT_FREE);
				this.page_size++;
				this.p2_interrupt = 4;
			}
		}
//		p2_interrupt為４時(shí)表示檢測(cè)是否一個(gè)作業(yè)已經(jīng)傳送完畢；
		if(this.p2_interrupt == 4) {
			if(this.page_size == this.block_table.length) {
//				釋放輸入井資源；
				disk.diskFree((byte)block_table.length, block_table[0]);
				que_jcb_start.add(mj);
				var.incJobCount();
//				在PCB就緒隊(duì)列添加此作業(yè)PCB的ID號(hào)為作業(yè)ID加10，以便處理；
				mp = new MosPCB((byte)(mj.getJcbId()+10),FinalVar.CPUMODE_USER,
						new MosPage(page_table),FinalVar.PCB_READY);
				mp.setTheName(chgStr(mj.getJcbName()));
				mp.setHaddr(mj.getHaddr());
				que_pcb_ready.add(mp);
				var.getMain().proMalloc(mp.getPcbId(),chgStr(mj.getJcbName()),mp.getHaddr()+1);
				var.getMain().jobnum_label.setText("" + String.valueOf(que_jcb_start.size()));
				this.p2_interrupt = 0;
			}
			else {
				this.p2_interrupt = 2;
			}
		}
	}
	
//	檢測(cè)內(nèi)存空間是否足以存放用戶作業(yè)；
	private MosJCB test() {
		Iterator iter = que_jcb_ready.iterator();
		while(iter.hasNext()) {
			MosJCB jcb = (MosJCB)iter.next();
			byte[] aa = null;
			aa = jcb.getJcbName();
//			for(int i = 0;i < 4;i++)
//				System.out.print((char)aa[i]);
//			System.out.println("");
			que_jcb_ready.remove(jcb);
//			將作業(yè)PCB的ID號(hào)為作業(yè)ID加10，作為JCB中所生成PCB的ID；
			jcb.setJcbPcId((byte)(jcb.getJcbId()+10));
			jcb.setJcbInTime(cpu.getTime());
			return jcb;
		}
		return null;
	}
	
	private String chgStr(byte[] a)
	{
		String str = null;
		int i;
		for(i = 0;i < a.length;i++)
		{
			if(a[i] == 0)break;
		}
		try
		{
			str = new String(a,0,i,"ISO8859-1");
		}
		catch(Exception e){}
		return str;
	}
	
	
}