Skip to content

Instantly share code, notes, and snippets.

@Snawoot
Created May 27, 2019 18:57
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save Snawoot/b9da85d6b26dea5460673b29df1adc6b to your computer and use it in GitHub Desktop.
Save Snawoot/b9da85d6b26dea5460673b29df1adc6b to your computer and use it in GitHub Desktop.
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