Changeset 61
- Timestamp:
- Jan 4, 2010, 3:23:54 PM (14 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
proiecte/ptvs/src/vnsim/core/Engine.java
r55 r61 242 242 catch (IOException e) 243 243 { 244 System.err.println("Error reading scenario; file error" 245 + Globals.inFile); 244 System.err.println("Error reading scenario; file error"+ Globals.inFile); 246 245 e.printStackTrace(); 247 246 System.exit(0); … … 304 303 } 305 304 305 // cod comentat deaorece vroiam sa vad daca se calculeaza cum trebuie intersectia cea mai apropiata 306 // si partea asta face ca semafoarele din toate intersectiile sa genereze evenimente 307 306 308 /* Szekeres A. START_MODIFY - add broadcast event for each traffic light*/ 307 for(int i=0;i<Globals.map.allIntersections.size();i++) {309 /*for(int i=0;i<Globals.map.allIntersections.size();i++) { 308 310 Intersection sender = Globals.map.allIntersections.get(i); 309 311 if (sender instanceof EmissionsTrafficLight) 310 312 { 311 313 ((EmissionsTrafficLight)sender).init(); 314 System.out.println("add in the queue.."); 312 315 schedEvent(new SendEvent(4, (EmissionsTrafficLight)sender, (int)Globals.PROT_TL_FEEDBACK)); 313 316 } 314 } 317 } */ 315 318 /* Szekeres A. STOP_MODIFY */ 316 319 } … … 662 665 // extrag un eveniment din coada !!!!! acum doar il extrag.. cand intru in playEvent il si scot cu remove(0) 663 666 Event e = (Event) eventQueue.get(0); 664 System.out.println(" --- noof events in the queue:"+eventQueue.size() );667 System.out.println("\n----------- number of events in the queue:"+eventQueue.size() ); 665 668 666 669 /** … … 715 718 */ 716 719 717 if(e instanceof SendEvent){718 System.out.print("SendEvent: ");719 processingThreads[indexClosestIntersection] = new SendEventProcessingThread(e,crtTime);720 }721 else {722 System.out.print("ReceiveEvent: ");723 processingThreads[indexClosestIntersection] = new ReceiveEventProcessingThread(e,crtTime);724 }725 726 720 // nu e bine cu apelul lui run pt ca practic nu se porneste un thread nou ci 727 721 // se apeleaza metoda run ca orice alta metoda dintr-o clasa, executia este secventiala.. 728 722 729 723 if (e.getTime() == crtTime) { 724 725 if(e instanceof SendEvent){ 726 727 System.out.print("SendEvent: "); 728 processingThreads[indexClosestIntersection] = new SendEventProcessingThread(e,crtTime); 729 } 730 else { 731 System.out.print("ReceiveEvent: "); 732 processingThreads[indexClosestIntersection] = new ReceiveEventProcessingThread(e,crtTime); 733 } 734 730 735 System.out.println("Processing thread "+indexClosestIntersection+" from intersection "+intersectii.get(indexClosestIntersection)); 731 736 //processingThreads[indexClosestIntersection].start();// cu start nu merge ... why???? … … 1351 1356 ReceiveEvent re = (ReceiveEvent) e; 1352 1357 ReceiveEvent existing = re.receiver.getReceiveEventForTime(e.getTime()); 1358 //getReceiveEventForTime returneaza evenimentele receive petrecute la momentul e.getTime() 1359 1353 1360 if (existing == null){ 1354 1361 re.receiver.addReceiveEventForTime(re); … … 1359 1366 } 1360 1367 1368 // cauta evenimetul in coada, ii gaseste pozitia corecta in lista de evenimente si il adauga 1369 // ce face de fapt? de ce cauta un eveniment si il readauga tot pe el in lista??? 1361 1370 int idx = Collections.binarySearch(eventQueue, e); 1362 1371 synchronized (eventQueue) {
Note: See TracChangeset
for help on using the changeset viewer.