| Methods Summary |
|---|
| public synchronized void | connect()
try {
connectServer();
mCirThread = new Thread(this, "TcpCirChannel");
mCirThread.setDaemon(true);
mCirThread.start();
HeartbeatService heartbeatService
= SystemService.getDefault().getHeartbeatService();
if (heartbeatService != null) {
heartbeatService.startHeartbeat(this, PING_INTERVAL);
}
} catch (UnknownHostException e) {
throw new ImException(ImErrorInfo.UNKNOWN_SERVER,
"Can't find the TCP CIR server");
} catch (IOException e) {
throw new ImException(ImErrorInfo.CANT_CONNECT_TO_SERVER,
"Can't connect to the TCP CIR server");
}
|
| private synchronized void | connectServer()
if(!mDone) {
if (mSocket != null) {
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " TCP CIR: close previous socket");
}
try {
mSocket.close();
} catch (IOException e) {
// ignore
}
}
mSocket = new Socket(mAddress, mPort);
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " >> TCP CIR: HELO");
}
sendData("HELO " + mConnection.getSession().getID() + "\r\n");
if (mReader != null) {
try {
mReader.close();
} catch (IOException e) {
// ignore
}
}
mReader = new BufferedReader(
new InputStreamReader(mSocket.getInputStream(), "UTF-8"),
8192);
}
|
| private boolean | needSendPing(long inactiveTime)
return (PING_INTERVAL - inactiveTime) < 500;
|
| public void | reconnect()
synchronized (mReconnectLock) {
if (mReconnecting) {
return;
} else {
mReconnecting = true;
}
}
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " CIR channel reconnecting");
}
long waitTime = 3000;
while (!mDone) { // Keep trying to connect the server until shutdown
try {
try {
Thread.sleep(waitTime);
} catch (InterruptedException e) {
}
connectServer();
// Send a polling request to make sure we don't miss anything
// while CIR is down.
if(!mDone) {
mConnection.sendPollingRequest();
}
break;
} catch (IOException e) {
waitTime *= 3;
if(waitTime > 27000) {
waitTime = 3000;
if(!mDone){
mConnection.sendPollingRequest();
}
}
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " CIR channel reconnect fail, retry after "
+ waitTime / 1000 + " seconds");
}
}
}
synchronized (mReconnectLock) {
mReconnecting = false;
mReconnectLock.notify();
}
|
| private void | reconnectAndWait()
reconnect();
// in case reconnect() has already been called in another thread, wait
// for it to finish
while (!mDone) {
synchronized (mReconnectLock) {
if (mReconnecting) {
try {
mReconnectLock.wait();
} catch (InterruptedException e) {
// ignore
}
} else {
break;
}
}
}
|
| public void | run()
while (!mDone) {
try {
if (mWaitForOK && SystemClock.elapsedRealtime() - mLastActive
> OK_TIMEOUT) {
// OMA-TS-IMPS_CSP_Transport-V1_3-20070123-A 8.1.3:
// If client doesn't receive an "OK" message or detects
// that the connection is broken, it MUST open a new
// TCP/IP connection and send the "HELO" message again.
reconnectAndWait();
}
String line = mReader.readLine();
mLastActive = SystemClock.elapsedRealtime();
if (line == null) {
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " TCP CIR: socket closed by server.");
}
reconnectAndWait();
} else if ("OK".equals(line)) {
mWaitForOK = false;
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " << TCP CIR: OK Received");
}
// TODO: Since we just have one thread per TCP CIR
// connection now, the session cookie is ignored.
} else if (line.startsWith("WVCI")) {
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " << TCP CIR: CIR Received");
}
if (!mDone) {
mConnection.sendPollingRequest();
}
}
} catch (IOException e) {
ImpsLog.logError("TCP CIR channel get:" + e);
if(!mDone){
reconnectAndWait();
}
}
}
if (mReader != null) {
try {
mReader.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " CIR channel thread quit");
}
|
| private void | sendData(java.lang.String s)
mSocket.getOutputStream().write(s.getBytes("UTF-8"));
mWaitForOK = true;
mLastActive = SystemClock.elapsedRealtime();
|
| public synchronized long | sendHeartbeat()
if (mDone) {
return 0;
}
long inactiveTime = SystemClock.elapsedRealtime() - mLastActive;
if(needSendPing(inactiveTime)) {
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " >> TCP CIR: PING");
}
try {
sendData("PING \r\n");
} catch (IOException e) {
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log("Failed to send PING, try to reconnect");
}
reconnect();
}
return PING_INTERVAL;
} else {
return PING_INTERVAL - inactiveTime;
}
|
| public synchronized void | shutdown()
if (Log.isLoggable(ImpsLog.TAG, Log.DEBUG)) {
ImpsLog.log(mUser + " Shutting down CIR channel");
}
mDone = true;
synchronized (mReconnectLock) {
if (mReconnecting) {
mReconnecting = false;
mReconnectLock.notify();
}
}
try {
if(mSocket != null) {
mSocket.close();
}
} catch (IOException e) {
// ignore
}
HeartbeatService heartbeatService
= SystemService.getDefault().getHeartbeatService();
if (heartbeatService != null) {
heartbeatService.stopHeartbeat(this);
}
|
