Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
diff --git a/postfix_mta_sts_resolver/responder.py b/postfix_mta_sts_resolver/responder.py
index 841210d..80e79b9 100644
--- a/postfix_mta_sts_resolver/responder.py
+++ b/postfix_mta_sts_resolver/responder.py
@@ -158,7 +158,7 @@ class STSSocketmapResponder(object):
async def handler(self, reader, writer):
# Construct netstring parser
- self._decoder = pynetstring.Decoder()
+ decoder = pynetstring.Decoder()
# Construct queue for responses ordering
queue = asyncio.Queue(QUEUE_LIMIT, loop=self._loop)
@@ -188,7 +188,7 @@ class STSSocketmapResponder(object):
raise EndOfStream()
self._logger.debug("Read: %s", repr(part))
try:
- requests = self._decoder.feed(part)
+ requests = decoder.feed(part)
except:
raise ParserInvokationError("Bad netstring protocol.")
pass
diff --git a/postfix_mta_sts_resolver/responder.py b/postfix_mta_sts_resolver/responder.py
index 10c49cc..7f7f53a 100644
--- a/postfix_mta_sts_resolver/responder.py
+++ b/postfix_mta_sts_resolver/responder.py
@@ -198,7 +198,7 @@ class STSSocketmapResponder(object):
async def handler(self, reader, writer):
# Construct netstring parser
- self._decoder = pynetstring.Decoder()
+ decoder = pynetstring.Decoder()
# Construct queue for responses ordering
queue = asyncio.Queue(QUEUE_LIMIT, loop=self._loop)
@@ -228,7 +228,7 @@ class STSSocketmapResponder(object):
raise EndOfStream()
self._logger.debug("Read: %s", repr(part))
try:
- requests = self._decoder.feed(part)
+ requests = decoder.feed(part)
except:
raise ParserInvokationError("Bad netstring protocol.")
diff --git a/postfix_mta_sts_resolver/responder.py b/postfix_mta_sts_resolver/responder.py
index 042d29c..0d58f2d 100644
--- a/postfix_mta_sts_resolver/responder.py
+++ b/postfix_mta_sts_resolver/responder.py
@@ -209,7 +209,7 @@ class STSSocketmapResponder(object):
async def handler(self, reader, writer):
# Construct netstring parser
- self._decoder = pynetstring.Decoder()
+ decoder = pynetstring.Decoder()
# Construct queue for responses ordering
queue = asyncio.Queue(QUEUE_LIMIT, loop=self._loop)
@@ -239,7 +239,7 @@ class STSSocketmapResponder(object):
raise EndOfStream()
self._logger.debug("Read: %s", repr(part))
try:
- requests = self._decoder.feed(part)
+ requests = decoder.feed(part)
except:
raise ParserInvokationError("Bad netstring protocol.")
diff --git a/postfix_mta_sts_resolver/responder.py b/postfix_mta_sts_resolver/responder.py
index 042d29c..0d58f2d 100644
--- a/postfix_mta_sts_resolver/responder.py
+++ b/postfix_mta_sts_resolver/responder.py
@@ -209,7 +209,7 @@ class STSSocketmapResponder(object):
async def handler(self, reader, writer):
# Construct netstring parser
- self._decoder = pynetstring.Decoder()
+ decoder = pynetstring.Decoder()
# Construct queue for responses ordering
queue = asyncio.Queue(QUEUE_LIMIT, loop=self._loop)
@@ -239,7 +239,7 @@ class STSSocketmapResponder(object):
raise EndOfStream()
self._logger.debug("Read: %s", repr(part))
try:
- requests = self._decoder.feed(part)
+ requests = decoder.feed(part)
except:
raise ParserInvokationError("Bad netstring protocol.")
diff --git a/postfix_mta_sts_resolver/responder.py b/postfix_mta_sts_resolver/responder.py
index 61d77d4..21596f0 100644
--- a/postfix_mta_sts_resolver/responder.py
+++ b/postfix_mta_sts_resolver/responder.py
@@ -221,7 +221,7 @@ class STSSocketmapResponder(object):
async def handler(self, reader, writer):
# Construct netstring parser
- self._decoder = pynetstring.Decoder()
+ decoder = pynetstring.Decoder()
# Construct queue for responses ordering
queue = asyncio.Queue(QUEUE_LIMIT, loop=self._loop)
@@ -251,7 +251,7 @@ class STSSocketmapResponder(object):
raise EndOfStream()
self._logger.debug("Read: %s", repr(part))
try:
- requests = self._decoder.feed(part)
+ requests = decoder.feed(part)
except:
raise ParserInvokationError("Bad netstring protocol.")
diff --git a/postfix_mta_sts_resolver/responder.py b/postfix_mta_sts_resolver/responder.py
index 61d77d4..21596f0 100644
--- a/postfix_mta_sts_resolver/responder.py
+++ b/postfix_mta_sts_resolver/responder.py
@@ -221,7 +221,7 @@ class STSSocketmapResponder(object):
async def handler(self, reader, writer):
# Construct netstring parser
- self._decoder = pynetstring.Decoder()
+ decoder = pynetstring.Decoder()
# Construct queue for responses ordering
queue = asyncio.Queue(QUEUE_LIMIT, loop=self._loop)
@@ -251,7 +251,7 @@ class STSSocketmapResponder(object):
raise EndOfStream()
self._logger.debug("Read: %s", repr(part))
try:
- requests = self._decoder.feed(part)
+ requests = decoder.feed(part)
except:
raise ParserInvokationError("Bad netstring protocol.")
diff --git a/postfix_mta_sts_resolver/responder.py b/postfix_mta_sts_resolver/responder.py
index 61d77d4..21596f0 100644
--- a/postfix_mta_sts_resolver/responder.py
+++ b/postfix_mta_sts_resolver/responder.py
@@ -221,7 +221,7 @@ class STSSocketmapResponder(object):
async def handler(self, reader, writer):
# Construct netstring parser
- self._decoder = pynetstring.Decoder()
+ decoder = pynetstring.Decoder()
# Construct queue for responses ordering
queue = asyncio.Queue(QUEUE_LIMIT, loop=self._loop)
@@ -251,7 +251,7 @@ class STSSocketmapResponder(object):
raise EndOfStream()
self._logger.debug("Read: %s", repr(part))
try:
- requests = self._decoder.feed(part)
+ requests = decoder.feed(part)
except:
raise ParserInvokationError("Bad netstring protocol.")
diff --git a/postfix_mta_sts_resolver/responder.py b/postfix_mta_sts_resolver/responder.py
index 61d77d4..21596f0 100644
--- a/postfix_mta_sts_resolver/responder.py
+++ b/postfix_mta_sts_resolver/responder.py
@@ -221,7 +221,7 @@ class STSSocketmapResponder(object):
async def handler(self, reader, writer):
# Construct netstring parser
- self._decoder = pynetstring.Decoder()
+ decoder = pynetstring.Decoder()
# Construct queue for responses ordering
queue = asyncio.Queue(QUEUE_LIMIT, loop=self._loop)
@@ -251,7 +251,7 @@ class STSSocketmapResponder(object):
raise EndOfStream()
self._logger.debug("Read: %s", repr(part))
try:
- requests = self._decoder.feed(part)
+ requests = decoder.feed(part)
except:
raise ParserInvokationError("Bad netstring protocol.")
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment