mirrors/cdt
1
0
Fork 0
mirror of https://github.com/eclipse-cdt/cdt synced 2025-07-22 00:15:25 +02:00
Code Issues Wiki Activity

[257666] [multithread] TCP/IP socket connection is not closed

Browse source 
[257666] modified original patch to simplify
This commit is contained in:
David McKnight 2008-12-09 16:24:36 +00:00
parent f6194a8283
commit cd82a6532a
1 changed files with 17 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
rse/plugins/org.eclipse.dstore.core/src/org/eclipse/dstore/core/server/ServerReceiver.java
View file

@ -15,10 +15,13 @@
* David McKnight (IBM) - [225507][api][breaking] RSE dstore API leaks non-API types * David McKnight (IBM) - [225507][api][breaking] RSE dstore API leaks non-API types
* Noriaki Takatsu (IBM) - [227905] prevent double invocations of finished in ConncetionEstablisher * Noriaki Takatsu (IBM) - [227905] prevent double invocations of finished in ConncetionEstablisher
* David McKnight (IBM) - [226561] [apidoc] Add API markup to RSE Javadocs where extend / implement is allowed * David McKnight (IBM) - [226561] [apidoc] Add API markup to RSE Javadocs where extend / implement is allowed
* Noriaki Takatsu (IBM) - [257666] [multithread] TCP/IP socket connection is not closed
* David McKnight (IBM) - [257666] modified original patch to simplify
*******************************************************************************/ *******************************************************************************/
package org.eclipse.dstore.core.server; package org.eclipse.dstore.core.server;
import java.io.IOException;
import java.net.Socket; import java.net.Socket;
import org.eclipse.dstore.core.model.DataElement; import org.eclipse.dstore.core.model.DataElement;
@ -82,6 +85,13 @@ public class ServerReceiver extends Receiver
_dataStore.setConnected(false); _dataStore.setConnected(false);
super.finish(); super.finish();
_connection.finished(this); _connection.finished(this);
try
{
socket().close();
}
catch (IOException e){
System.out.println(e);
}
} }
/** /**
@ -93,6 +103,13 @@ public class ServerReceiver extends Receiver
e.printStackTrace(); e.printStackTrace();
System.out.println(e); System.out.println(e);
_connection.finished(this); _connection.finished(this);
try
{
socket().close();
}
catch (IOException IOe){
System.out.println(IOe);
}
} }
} }