server

thufir@dur:~$
thufir@dur:~$
thufir@dur:~$ java -jar NetBeansProjects/Server/dist/Server.jar
Jul 05, 2014 9:02:19 PM dur.bounceme.net.server.controller.Driver startServer
INFO: started server
Jul 05, 2014 9:02:22 PM net.bounceme.dur.server.pools.WorkerRunnable run
INFO:
id  1
phone   0
title   created on Server.RecordQueue
state   undefined
Jul 05, 2014 9:02:22 PM net.bounceme.dur.server.pools.WorkerRunnable run
INFO: sent recordFromServer to objectOutputStream
Jul 05, 2014 9:02:22 PM net.bounceme.dur.server.pools.WorkerRunnable run
WARNING: why is there no record from client?

java.io.EOFException
    at java.io.ObjectInputStream$BlockDataInputStream.peekByte(ObjectInputStream.java:2598)
    at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1318)
    at java.io.ObjectInputStream.readObject(ObjectInputStream.java:370)
    at net.bounceme.dur.server.pools.WorkerRunnable.run(WorkerRunnable.java:36)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:744)

^Cthufir@dur:~$
thufir@dur:~$
thufir@dur:~$ cat NetBeansProjects/Server/src/net/bounceme/dur/server/pools/
MyProps.java              RecordsQueueWrapper.java  Server.java               WorkerRunnable.java
thufir@dur:~$ cat NetBeansProjects/Server/src/net/bounceme/dur/server/pools/WorkerRunnable.java
package net.bounceme.dur.server.pools;

import dur.bounceme.net.data.Title;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.NoSuchElementException;
import java.util.logging.Level;
import java.util.logging.Logger;

public class WorkerRunnable implements Runnable {

    private static final Logger log = Logger.getLogger(WorkerRunnable.class.getName());
    protected Socket socket = null;
    private RecordsQueueWrapper recordsQueue = null;

    public WorkerRunnable(Socket clientSocket, RecordsQueueWrapper recordsQueue) {
        this.socket = clientSocket;
        this.recordsQueue = recordsQueue;
    }

    @Override
    public void run() {
        Title recordFromServer = null;
        Title recordFromClient = null;
        boolean queueEmpty = false;
        try (ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
                ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream())) {
            do {
                try {
                    recordFromServer = recordsQueue.pop();
                    log.info(recordFromServer.toString());
                    objectOutputStream.writeObject(recordFromServer);
                    log.info("sent recordFromServer to objectOutputStream");
                    recordFromClient = (Title) objectInputStream.readObject();
                } catch (NoSuchElementException nse) {
                    queueEmpty = true;
                }
            } while (!queueEmpty);
        } catch (java.io.EOFException eofe) {
            log.log(Level.WARNING, "why is there no record from client?\n", eofe);
        } catch (IOException | ClassNotFoundException ex) {
            Logger.getLogger(WorkerRunnable.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}
thufir@dur:~$
thufir@dur:~$