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

[pepperjo]

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 <b...@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());