ziver/hal
1
1
Fork 0
Code Pull requests Releases Activity

fixed warnings

Browse source
This commit is contained in:
Ziver Koc 2010-08-14 15:38:56 +00:00
parent 2693a9eb4e
commit 93b14283c2
5 changed files with 20 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

15
src/zutil/network/nio/worker/grid/GridClient.java
View file

@ -17,6 +17,7 @@ import zutil.network.nio.worker.WorkerDataEvent;
*
* @author Ziver
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
public class GridClient extends ThreadedEventWorker {
private static LinkedList<GridJob> jobQueue;
private static GridThread thread;
@ -43,7 +44,7 @@ public class GridClient extends ThreadedEventWorker {
*/
public void initiate() throws IOException{
network.setDefaultWorker(this);
network.send(new GridMessage<Object>(GridMessage.REGISTER));
network.send(new GridMessage(GridMessage.REGISTER));
for(int i=0; i<Runtime.getRuntime().availableProcessors() ;i++){
Thread t = new Thread(thread);
@ -55,14 +56,14 @@ public class GridClient extends ThreadedEventWorker {
public void messageEvent(WorkerDataEvent e) {
// ignores other messages than GridMessage
if(e.data instanceof GridMessage){
GridMessage<?> msg = (GridMessage<?>)e.data;
GridMessage msg = (GridMessage)e.data;
switch(msg.messageType()){
// Receive data from Server
case GridMessage.INIT_DATA:
thread.setInitData(msg.getData());
break;
case GridMessage.COMP_DATA:
jobQueue.add(new GridJob(msg.getJobQueueID(), (Queue<?>)msg.getData()));
jobQueue.add(new GridJob(msg.getJobQueueID(), (Queue)msg.getData()));
break;
}
}
@ -78,9 +79,9 @@ public class GridClient extends ThreadedEventWorker {
*/
public static void jobDone(int jobID, boolean correct, Object result) throws IOException{
if(correct)
network.send(new GridMessage<Object>(GridMessage.COMP_SUCCESSFUL, jobID, result));
network.send(new GridMessage(GridMessage.COMP_SUCCESSFUL, jobID, result));
else
network.send(new GridMessage<Object>(GridMessage.COMP_INCORRECT, jobID, result));
network.send(new GridMessage(GridMessage.COMP_INCORRECT, jobID, result));
}
/**
@ -91,7 +92,7 @@ public class GridClient extends ThreadedEventWorker {
*/
public static void jobError(int jobID){
try{
network.send(new GridMessage<Object>(GridMessage.COMP_SUCCESSFUL, jobID));
network.send(new GridMessage(GridMessage.COMP_SUCCESSFUL, jobID));
}catch(Exception e){e.printStackTrace();}
}
@ -101,7 +102,7 @@ public class GridClient extends ThreadedEventWorker {
*/
public static synchronized GridJob getNextJob() throws IOException{
if(jobQueue.isEmpty()){
network.send(new GridMessage<Object>(GridMessage.NEW_DATA));
network.send(new GridMessage(GridMessage.NEW_DATA));
while(jobQueue.isEmpty()){
try{Thread.sleep(100);}catch(Exception e){}
}

14
src/zutil/network/nio/worker/grid/GridServerWorker.java
View file

@ -14,18 +14,18 @@ import zutil.network.nio.worker.WorkerDataEvent;
*
* @author Ziver
*/
@SuppressWarnings({ "unchecked", "rawtypes" })
public class GridServerWorker extends ThreadedEventWorker{
// Job timeout after 30 min
public static int JOB_TIMEOUT = 1000*60*30;
private HashMap<Integer, GridJob> jobs; // contains all the ongoing jobs
private Queue<GridJob> reSendjobQueue; // Contains all the jobs that will be recalculated
private GridJobGenerator<?> jobGenerator; // The job generator
private GridResultHandler<Object> resHandler;
private GridJobGenerator jobGenerator; // The job generator
private GridResultHandler resHandler;
private int nextJobID;
public GridServerWorker(GridResultHandler<Object> resHandler, GridJobGenerator<?> jobGenerator){
public GridServerWorker(GridResultHandler resHandler, GridJobGenerator jobGenerator){
this.resHandler = resHandler;
this.jobGenerator = jobGenerator;
nextJobID = 0;
@ -41,12 +41,12 @@ public class GridServerWorker extends ThreadedEventWorker{
try {
// ignores other messages than GridMessage
if(e.data instanceof GridMessage){
GridMessage<?> msg = (GridMessage<?>)e.data;
GridMessage msg = (GridMessage)e.data;
GridJob job = null;
switch(msg.messageType()){
case GridMessage.REGISTER:
e.network.send(e.socket, new GridMessage<Object>(GridMessage.INIT_DATA, 0, jobGenerator.initValues()));
e.network.send(e.socket, new GridMessage(GridMessage.INIT_DATA, 0, jobGenerator.initValues()));
break;
// Sending new data to compute to the client
case GridMessage.NEW_DATA:
@ -60,7 +60,7 @@ public class GridServerWorker extends ThreadedEventWorker{
jobs.put(job.jobID, job);
nextJobID++;
}
GridMessage<Object> newMsg = new GridMessage<Object>(GridMessage.COMP_DATA, job.jobID, job.job);
GridMessage newMsg = new GridMessage(GridMessage.COMP_DATA, job.jobID, job.job);
e.network.send(e.socket, newMsg);
break;