fucksocks.server.io

Class SocketPipe

java.lang.Object

fucksocks.server.io.SocketPipe

All Implemented Interfaces:

Pipe

public class SocketPipe
extends Object
implements Pipe

The class SocketPipe represents pipe that can transfer data from one socket to another socket. The tow socket should be connected sockets. If any of the them occurred error the pipe will close all of them.

Version:

1.0

Author:

Youchao Feng

date

Apr 15, 2015 10:46:03 AM

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	logger Logger

Constructor Summary

Constructors

Constructor and Description
SocketPipe(Socket socket1, Socket socket2) Constructs SocketPipe instance by tow connected sockets.

Method Summary

Methods

Modifier and Type	Method and Description
void	addPipeListener(PipeListener pipeListener) Adds pipe listener.
boolean	close() Close pipe.
int	getBufferSize() GEts the buffer size.
String	getName() Returns pipe's name.
boolean	isRunning() If the pipe is running.
void	removePipeListener(PipeListener pipeListener) Removes pipe listener.
void	setBufferSize(int bufferSize) Sets buffer size.
void	setName(String name) Sets pipe's name.
boolean	start() Start the pipe, the pipe will work with a new thread.
boolean	stop() Stop the pipe, the pipe will stop transferring data.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final org.slf4j.Logger logger

Logger

Constructor Detail

SocketPipe

public SocketPipe(Socket socket1,
          Socket socket2)
           throws IOException

Constructs SocketPipe instance by tow connected sockets.

Parameters:

socket1 - A connected socket.

socket2 - Another connected socket.

Throws:

IOException - If an I/O error occurred.

Method Detail

start

public boolean start()

Description copied from interface: Pipe

Start the pipe, the pipe will work with a new thread.

Specified by:

start in interface Pipe

Returns:

TODO

stop

public boolean stop()

Description copied from interface: Pipe

Stop the pipe, the pipe will stop transferring data.

Specified by:

stop in interface Pipe

Returns:

TODO

close

public boolean close()

Description copied from interface: Pipe

Close pipe. if pipe is closed, it can't be started again.

Specified by:

close in interface Pipe

Returns:

true if it closed.

getBufferSize

public int getBufferSize()

Description copied from interface: Pipe

GEts the buffer size.

Specified by:

getBufferSize in interface Pipe

Returns:

Buffer size.

setBufferSize

public void setBufferSize(int bufferSize)

Description copied from interface: Pipe

Sets buffer size.

Specified by:

setBufferSize in interface Pipe

Parameters:

bufferSize - Buffer size.

isRunning

public boolean isRunning()

Description copied from interface: Pipe

If the pipe is running.

Specified by:

isRunning in interface Pipe

Returns:

true if the pipe is running.

addPipeListener

public void addPipeListener(PipeListener pipeListener)

Description copied from interface: Pipe

Adds pipe listener.

Specified by:

addPipeListener in interface Pipe

Parameters:

pipeListener - Pipe listener.

removePipeListener

public void removePipeListener(PipeListener pipeListener)

Description copied from interface: Pipe

Removes pipe listener.

Specified by:

removePipeListener in interface Pipe

Parameters:

pipeListener - Pipe listener.

getName

public String getName()

Description copied from interface: Pipe

Returns pipe's name.

Specified by:

getName in interface Pipe

Returns:

Name of pipe.

setName

public void setName(String name)

Description copied from interface: Pipe

Sets pipe's name.

Specified by:

setName in interface Pipe

Parameters:

name - Name of pipe.