Gracefully disconnect socket when acquisition stops

CMakeLists.txt

@@ -65,6 +65,7 @@ if(MSVC)
 	target_compile_options(${PLUGIN_NAME} PRIVATE /sdl- /W0)
 
 	install(TARGETS ${PLUGIN_NAME} RUNTIME DESTINATION ${GUI_BIN_DIR}/plugins  CONFIGURATIONS ${CMAKE_CONFIGURATION_TYPES})
+	install(FILES $<TARGET_PDB_FILE:${PLUGIN_NAME}> DESTINATION  ${GUI_BIN_DIR}/plugins OPTIONAL)
 
 	set(CMAKE_PREFIX_PATH ${CMAKE_CURRENT_SOURCE_DIR}/../libs)
 elseif(LINUX)

Resources/python-example-tcp.py

@@ -38,14 +38,14 @@
 oneCycle = np.concatenate((intList_1, intList_2))
 allData = np.tile(oneCycle, (numChannels, totalDuration)).T
 
+# ---- WAIT FOR USER INPUT ---- #
+value = input("Press enter key to start...")
+
 # ---- CREATE THE SOCKET SERVER ---- #
 tcpServer = socket.socket(family=socket.AF_INET, type=socket.SOCK_STREAM)
 tcpServer.bind(('localhost', 9001))
 tcpServer.listen(1)
 
-# ---- WAIT FOR USER INPUT ---- #
-value = input("Press enter key to start...")
-
 print("Waiting for external connection to start...")
 (tcpClient, address) = tcpServer.accept()
 print("Connected.")
@@ -75,3 +75,9 @@ def currentTime():
     print("Done")
 except BrokenPipeError:
     print("Connection closed by the server. Unable to send data. Exiting...")
+
+except ConnectionAbortedError:
+    print("Connection was aborted, unable to send data. Try disconnecting and reconnecting the remote client. Exiting...")
+
+except ConnectionResetError:
+    print("Connection was aborted, unable to send data. Try disconnecting and reconnecting the remote client. Exiting...")

Source/EphysSocket.cpp

@@ -46,6 +46,8 @@ void EphysSocket::registerParameters()
 
 void EphysSocket::disconnectSocket()
 {
+    socket.signalThreadShouldExit();
+    socket.waitForThreadToExit(1000);
     socket.disconnectSocket();
 
     getParameter ("port")->setEnabled (true);

Source/OpenEphysLib.cpp

@@ -38,7 +38,7 @@ extern "C" EXPORT void getLibInfo (Plugin::LibraryInfo* info)
 {
     info->apiVersion = PLUGIN_API_VER;
     info->name = "Ephys Socket";
-    info->libVersion = "0.5.0";
+    info->libVersion = "0.5.1";
     info->numPlugins = NUM_PLUGINS;
 }
 

Source/SocketThread.cpp

@@ -47,6 +47,11 @@ void SocketThread::startAcquisition()
 void SocketThread::stopAcquisition()
 {
     acquiring = false;
+
+    if (shouldReconnect)
+    {
+        processor->disconnectSocket();
+    }
 }
 
 bool SocketThread::connectSocket (int port, bool printOutput)