[incubator-crail] branch master updated: [storage-rdma] fix QP not destroyed

[pe...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pepperjo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-crail.git


The following commit(s) were added to refs/heads/master by this push:
     new 5c38bbd  [storage-rdma] fix QP not destroyed
5c38bbd is described below

commit 5c38bbdffe4c6863ef28995168a12260bc623dcc
Author: BernardMetzler <bm...@zurich.ibm.com>
AuthorDate: Thu Jul 4 12:50:53 2019 +0200

    [storage-rdma] fix QP not destroyed
    
    Close StorageServer client endpoint if client disconnected.
    Otherwise QP would persist in closed state.
---
 .../src/main/java/org/apache/crail/storage/rdma/RdmaStorageServer.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/storage-rdma/src/main/java/org/apache/crail/storage/rdma/RdmaStorageServer.java b/storage-rdma/src/main/java/org/apache/crail/storage/rdma/RdmaStorageServer.java
index 8c995c0..5393275 100644
--- a/storage-rdma/src/main/java/org/apache/crail/storage/rdma/RdmaStorageServer.java
+++ b/storage-rdma/src/main/java/org/apache/crail/storage/rdma/RdmaStorageServer.java
@@ -84,6 +84,7 @@ public class RdmaStorageServer implements Runnable, StorageServer {
 	public void close(RdmaEndpoint ep) {
 		try {
 			allEndpoints.remove(ep.getEndpointId());
+			ep.close();
 			LOG.info("removing endpoint, connCount " + allEndpoints.size());
 		} catch (Exception e){
 			LOG.info("error closing " + e.getMessage());