remove unused, broken session limiter

Signed-off-by: Andrew Whitehead <[email protected]>
openwallet-foundation · Feb 8, 2022 · ea52011 · ea52011
1 parent 747b88c
commit ea52011
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 9 deletions.
diff --git a/aries_cloudagent/transport/inbound/manager.py b/aries_cloudagent/transport/inbound/manager.py
@@ -1,6 +1,5 @@
 """Inbound transport manager."""
 
-import asyncio
 import logging
 import uuid
 from collections import OrderedDict
@@ -43,7 +42,6 @@ def __init__(
         self.registered_transports = {}
         self.running_transports = {}
         self.sessions = OrderedDict()
-        self.session_limit: asyncio.Semaphore = None
         self.task_queue = TaskQueue()
         self.undelivered_queue: DeliveryQueue = None
 
@@ -68,8 +66,6 @@ async def setup(self):
         if self.profile.context.settings.get("transport.enable_undelivered_queue"):
             self.undelivered_queue = DeliveryQueue()
 
-        # self.session_limit = asyncio.Semaphore(50)
-
     def register(self, config: InboundTransportConfiguration) -> str:
         """
         Register transport module.
@@ -163,8 +159,6 @@ async def create_session(
             client_info: An optional dict describing the client
             wire_format: Override the wire format for this session
         """
-        if self.session_limit:
-            await self.session_limit
         if not wire_format:
             wire_format = self.profile.context.inject(BaseWireFormat)
         session = InboundSession(
@@ -195,8 +189,6 @@ def closed_session(self, session: InboundSession):
         """
         if session.session_id in self.sessions:
             del self.sessions[session.session_id]
-            if self.session_limit:
-                self.session_limit.release()
         if session.response_buffer:
             if self.return_inbound:
                 self.return_inbound(session.profile, session.response_buffer)

diff --git a/aries_cloudagent/transport/inbound/tests/test_manager.py b/aries_cloudagent/transport/inbound/tests/test_manager.py
@@ -83,7 +83,6 @@ async def test_create_session(self):
         test_accept = True
         test_can_respond = True
         test_client_info = {"client": "info"}
-        mgr.session_limit = asyncio.Semaphore(16)
         session = await mgr.create_session(
             test_transport,
             accept_undelivered=test_accept,