Created
May 27, 2019 18:57
-
-
Save Snawoot/b9da85d6b26dea5460673b29df1adc6b to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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.") | |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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.") | |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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.") | |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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.") | |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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.") | |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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.") | |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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