From fe3e636f154e8f93be27bfab26a688ca93594903 Mon Sep 17 00:00:00 2001
From: Carsten Patzke <carsten.patzke@desy.de>
Date: Wed, 2 Sep 2020 15:58:05 +0200
Subject: [PATCH] Added ForceNoRdma flag in python
---
consumer/api/python/asapo_consumer.pxd | 1 +
consumer/api/python/asapo_consumer.pyx.in | 2 ++
2 files changed, 3 insertions(+)
diff --git a/consumer/api/python/asapo_consumer.pxd b/consumer/api/python/asapo_consumer.pxd
index 429996ac0..1e0cd28fa 100644
--- a/consumer/api/python/asapo_consumer.pxd
+++ b/consumer/api/python/asapo_consumer.pxd
@@ -56,6 +56,7 @@ cdef extern from "asapo_consumer.h" namespace "asapo" nogil:
cdef cppclass DataBroker:
DataBroker() except +
void SetTimeout(uint64_t timeout_ms)
+ void ForceNoRdma()
NetworkConnectionType CurrentConnectionType()
Error GetNext(FileInfo* info, string group_id,string substream, FileData* data)
Error GetLast(FileInfo* info, string group_id,string substream, FileData* data)
diff --git a/consumer/api/python/asapo_consumer.pyx.in b/consumer/api/python/asapo_consumer.pyx.in
index b817b1431..5f20dbe3c 100644
--- a/consumer/api/python/asapo_consumer.pyx.in
+++ b/consumer/api/python/asapo_consumer.pyx.in
@@ -161,6 +161,8 @@ cdef class PyDataBroker:
return size
def set_timeout(self,timeout):
self.c_broker.SetTimeout(timeout)
+ def force_no_rdma(self):
+ self.c_broker.ForceNoRdma()
def current_connection_type(self):
cdef NetworkConnectionType connection_type = self.c_broker.CurrentConnectionType()
cdef int cased = <int>connection_type
--
GitLab