objectClient

java.lang.Object

bbflow_network.objectClient

public class objectClient extends Object

class to manage connection to server socket in order to send data through TCP channel Auto-reconnection in case of fault is implemented

Field Summary

Fields

Modifier and Type

Field

Description

(package private) clientThread

cc

(package private) Thread

ccThread

(package private) int

connPort

static long

flushThreshold

delay in Output Stream flushing in nanoseconds.

(package private) String

host

(package private) long

lastFlush

(package private) int

serverPort
Constructor Summary

Constructors

Constructor

Description

objectClient(int connectionId, String host)
Method Summary

Modifier and Type

Method

Description

void

put(Object i)

void

put(Object i, boolean flush)

void

setEOS()

void

tryToPut(Object i, boolean flush)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- serverPort
  
  int serverPort
- connPort
  
  int connPort
- host
  
  String host
- cc
  
  clientThread cc
- ccThread
  
  Thread ccThread
- flushThreshold
  
  public static long flushThreshold
  
  delay in Output Stream flushing in nanoseconds.
- lastFlush
  
  long lastFlush
Constructor Details
- objectClient
  
  public objectClient(int connectionId, String host) throws IOException, InterruptedException
  
  Throws:
  
  IOException
  
  InterruptedException
Method Details
- put
  
  public void put(Object i, boolean flush) throws InterruptedException
  
  Throws:
  
  InterruptedException
- put
  
  public void put(Object i) throws InterruptedException
  
  Throws:
  
  InterruptedException
- tryToPut
  
  public void tryToPut(Object i, boolean flush) throws IOException, InterruptedException
  
  Throws:
  
  IOException
  
  InterruptedException
- setEOS
  
  public void setEOS() throws InterruptedException
  
  Throws:
  
  InterruptedException