Dualroids: Class ServerModelConnector

Package

Class

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: INNER | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

dualroids
Class ServerModelConnector

java.lang.Object
  |
  +--dualroids.ServerModelConnector

All Implemented Interfaces:: Runnable

public final class ServerModelConnector
extends Object
implements Runnable

The server-side interface to network. ServerModelConnector acts as both the reader and the writer interface. The reader interface is run in an independent thread. The methods which write to ObjectOutputStream are synchronized and named as writeFoo().

Field Summary

private Arena arena
          the server's arena

(package private) static int OC_ARENA
          opcodes for the network protocol

(package private) static int OC_ASTEROID_LOCATION_AND_ANGLE
          opcodes for the network protocol

(package private) static int OC_BLOW_UP_ASTEROID
          opcodes for the network protocol

(package private) static int OC_BLOW_UP_SHIP
          opcodes for the network protocol

(package private) static int OC_BULLET_FIRED
          opcodes for the network protocol

(package private) static int OC_CLIENT_CLOSE
          opcodes for the network protocol

(package private) static int OC_EOF
          opcodes for the network protocol

(package private) static int OC_GAME_OVER
          opcodes for the network protocol

(package private) static int OC_INIT_BULLET
          opcodes for the network protocol

(package private) static int OC_INVALIDATE_BULLET
          opcodes for the network protocol

(package private) static int OC_PLAYER_NAME
          opcodes for the network protocol

(package private) static int OC_SCORE
          opcodes for the network protocol

(package private) static int OC_SERVER_CLOSE
          opcodes for the network protocol

(package private) static int OC_SHIP_STATE
          opcodes for the network protocol

(package private) static int OC_SHIPS_LEFT
          opcodes for the network protocol

private ObjectInputStream ois
          the ObjectInputStream for this connector

private ObjectOutputStream oos
          the ObjectOutputStream for this connector

private ServerModelConnector otherConnector
          the other ServerModelConnector

private String playerName
          The players' name of the client to which this connector is connected

private Socket s
          the socket this connector uses

(package private) static int SERVER_PORT
          server listens on this port

private int shipIndex
          The index of the ship owned by the client to which this connector is connected.

Constructor Summary

private ServerModelConnector(Socket s, int shipIndex)
          The constructor initializes streams from the given socket.

Method Summary

private void close(int opCode)
          Closes the output stream, if it's not already closed and calls the other connector to close its streams too.

static ServerModelConnector[] createServerModelConnectors(String playerName)
          This method should be called to initialize the two connectors.

private void echoPing()
          The client sends us the clientTime, and we send the time difference back The echoPing() method should be called only from the createServerModelConnectors() factory method.

void flush()
          Flushes the network output stream

private void internalClose(int opCode)
          Closes the output stream, if it's not already closed and calls the other connector to close its streams too.

private void readBulletFired()
          Tells the server that a bullet has been fired by the ship controlled by this client.

private void readPlayerName()
          Read the player name of the client connected to this connector and save it temporarily to the this.playerName field.

private void readShipState()
          Reads the state of the space ship controlled by this connector's client, forwards the information to the other connector's client and updates the information to the model.

void run()
          JVM runs this method when start() is called for this thread.

void writeArena(Arena arena)
          Sends the whole Arena object to the client

void writeAsteroidLocationAndAngle(int index, double locationX, double locationY, double angle, long timestamp)
          Tells the client the location and angle of asteroid number index

void writeBlowUpAsteroid(int index, double locationX, double locationY, long timestamp)
          Tells the client to blow up asteroid number index

void writeBlowUpShip(int shipIndex, long newAppears)
          Tells the client that the ship at shipIndex has blown up.

void writeGameOver()
          A public method for initiating the game over procedure from outside this connector

private void writeInitBullet(int shipIndex, int bulletIndex, double locationX, double locationY, double velocityX, double velocityY, double lineDeltaX, double lineDeltaY, long timestamp, long expires)
          Tells the client that a bullet has been fired by the ship controlled by the other client.

void writeInvalidateBullet(int shipIndex, int bulletIndex)
          Marks a bullet non-flying (not visible).

private void writePlayerName(int shipIndex, String playerName)
          Write the given playerName of the given shipIndex.

void writeScore(int shipIndex, int score)
          Inform the client of the new scores of a player.

void writeShipsLeft(int shipIndex, int shipsLeft)
          Tells the client the number of ships a player has left.

private void writeShipState(int shipIndex, double locationX, double locationY, double velocityX, double velocityY, double angle, long timestamp)
          Sends the state of the space ship to the client.

Methods inherited from class java.lang.Object

, clone, equals, finalize, getClass, hashCode, notify, notifyAll, registerNatives, toString, wait, wait, wait

Field Detail

SERVER_PORT

static final int SERVER_PORT

server listens on this port