com.foxless.godfs.common

Class Bridge

java.lang.Object

com.foxless.godfs.common.Bridge

public class Bridge
extends Object

connection manager as a bridge. manage data transfer and connection validation.

Version:

1.0

Author:

hehety

Constructor Summary

Constructors

Constructor and Description
Bridge()
Bridge(Socket connection, long index)

Method Summary

Modifier and Type	Method and Description
void	close()
static long	convertBytes2Len(byte[] bs)
Socket	GetConn()
Socket	getConnection()
Long	getIndex()
String	getUuid()
Object	receiveResponse(Tracker tracker, Class<? extends IResponseHandler> responseHandler, IReader byteReceiver) receive response after send request.
void	sendRequest(int operation, Object operationMeta, long bodyLen, IWriter bodyWriterHandler) send request to server
void	setConnection(Socket connection)
void	setIndex(Long index)
void	setUuid(String uuid)
void	validateConnection(String secret)

Methods inherited from class java.lang.Object

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

Constructor Detail

Bridge

public Bridge()

Bridge

public Bridge(Socket connection,
              long index)

Method Detail

close

public void close()

GetConn

public Socket GetConn()

sendRequest

public void sendRequest(int operation,
                        Object operationMeta,
                        long bodyLen,
                        IWriter bodyWriterHandler)
                 throws Exception

send request to server

Parameters:

operation - operation defined in Const

operationMeta - custom request meta info defined in package com.foxless.godfs.bean.meta

bodyLen - request body length, if request contains no file, bodyLen = 0.

bodyWriterHandler - if request contains file, you need send the bytes by your own through interface IWriter.

Throws:

Exception

receiveResponse

public Object receiveResponse(Tracker tracker,
                              Class<? extends IResponseHandler> responseHandler,
                              IReader byteReceiver)
                       throws Exception

receive response after send request.

Parameters:

responseHandler - the handler for this response

Throws:

Exception - if there is something error occurs, the connection will be close.

validateConnection

public void validateConnection(String secret)
                        throws Exception

Throws:

Exception

convertBytes2Len

public static long convertBytes2Len(byte[] bs)

getConnection

public Socket getConnection()

setConnection

public void setConnection(Socket connection)

getUuid

public String getUuid()

setUuid

public void setUuid(String uuid)

getIndex

public Long getIndex()

setIndex

public void setIndex(Long index)