Message

Reply | Reply all

Date Prev | Date Next | Thread Prev | Thread Next Date Index | Thread Index

From: cvs at opencores.org<cvs@o...>
Date: Wed Jul 23 10:46:03 CEST 2008
Subject: [cvs-checkins] MODIFIED: jop ...
Date: 00/08/07 23:10:46

Modified: jop/java/target/src/test/cmp RtHelloCMP.java
Log:
New scheduler to allow CMP scheulding.


Revision Changes Path
1.3 jop/java/target/src/test/cmp/RtHelloCMP.java

http://www.opencores.org/cvsweb.shtml/jop/java/target/src/test/cmp/RtHelloCMP.java.diff?r1=1.2&r2=1.3

(In the diff below, changes in quantity of whitespace are not shown.)

Index: RtHelloCMP.java
===================================================================
RCS file: /cvsroot/martin/jop/java/target/src/test/cmp/RtHelloCMP.java,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -b -r1.2 -r1.3
--- RtHelloCMP.java 24 Jun 2008 13:02:15 -0000 1.2
+++ RtHelloCMP.java 23 Jul 2008 08:46:02 -0000 1.3
@@ -30,6 +30,7 @@

import com.jopdesign.io.IOFactory;
import com.jopdesign.io.SysDevice;
+import com.jopdesign.sys.Native;

/**
* A real-time threaded version of Hello World for CMP
@@ -47,7 +48,7 @@

public static Vector msg;

- final static int NR_THREADS = 5;
+ final static int NR_THREADS = 50;

/**
* @param args
@@ -62,7 +63,7 @@
for (int i=0; i<NR_THREADS; ++i) {
RtHelloCMP th = new RtHelloCMP(1, 1000*1000);
th.id = i;
-// th.setProcessor(i%sys.nrCpu);
+ th.setProcessor(i%sys.nrCpu);
}

System.out.println("Start mission");
@@ -72,12 +73,15 @@

// print their messages
for (;;) {
- System.out.print("*");
- RtThread.sleepMs(100);
+ RtThread.sleepMs(5);
int size = msg.size();
if (size!=0) {
StringBuffer sb = (StringBuffer) msg.remove(0);
- System.out.print(sb);
+ // System.out.print(sb);
+ // converts StringBuffer to a String and creates garbage
+ for (int i=0; i<sb.length(); ++i) {
+ System.out.print(sb.charAt(i));
+ }
}
}
}
@@ -85,16 +89,20 @@
public void run() {

StringBuffer sb = new StringBuffer();
- sb.append("Thread start on CPU ");
+ StringBuffer ping = new StringBuffer();
+
+ sb.append("Thread ");
+ sb.append((char) ('A'+id));
+ sb.append(" start on CPU ");
sb.append(IOFactory.getFactory().getSysDevice().cpuId);
sb.append("\r\n");
msg.addElement(sb);
- StringBuffer ping = new StringBuffer();
+ waitForNextPeriod();
+
for (;;) {
ping.setLength(0);
ping.append((char) ('A'+id));
msg.addElement(ping);
- System.out.println("ping");
waitForNextPeriod();
}
}