You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@avro.apache.org by ie...@apache.org on 2020/06/01 15:46:49 UTC
[avro] 02/02: Typos and ortography fixes
This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/avro.git
commit 8f3b419b2d8085d068c85e034d2ad8983733f56c
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Mon Jun 1 16:46:17 2020 +0200
Typos and ortography fixes
---
doc/src/content/xdocs/sasl.xml | 18 +++++++++---------
lang/py/avro/test/mock_tether_parent.py | 8 ++++----
lang/py/avro/tether/tether_task_runner.py | 12 ++++++------
3 files changed, 19 insertions(+), 19 deletions(-)
diff --git a/doc/src/content/xdocs/sasl.xml b/doc/src/content/xdocs/sasl.xml
index 031ad17..514cca5 100644
--- a/doc/src/content/xdocs/sasl.xml
+++ b/doc/src/content/xdocs/sasl.xml
@@ -62,16 +62,16 @@
<li><code>2: FAIL</code> Terminates negotiation unsuccessfully.</li>
<li><code>3: COMPLETE</code> Terminates negotiation sucessfully.</li>
</ul>
-
+
<p>The format of a START message is:</p>
<source>| 0 | 4-byte mechanism name length | mechanism name | 4-byte payload length | payload data |</source>
-
+
<p>The format of a CONTINUE message is:</p>
<source>| 1 | 4-byte payload length | payload data |</source>
-
+
<p>The format of a FAIL message is:</p>
<source>| 2 | 4-byte message length | UTF-8 message |</source>
-
+
<p>The format of a COMPLETE message is:</p>
<source>| 3 | 4-byte payload length | payload data |</source>
</section>
@@ -81,19 +81,19 @@
<p>Negotiation is initiated by a client sending a START command
containing the client's chosen mechanism name and any
mechanism-specific payload data.</p>
-
+
<p>The server and client then interchange some number
(possibly zero) of CONTINUE messages. Each message contains
payload data that is processed by the security mechanism to
generate the next message.</p>
-
+
<p>Once either the client or server send a FAIL message then
negotiation has failed. UTF-8-encoded text is included in
the failure message. Once either a FAIL message has been
- sent or recieved, or any other error occurs in the
+ sent or received, or any other error occurs in the
negotiation, further communication on this connection must
cease.</p>
-
+
<p>Once either the client or server send a COMPLETE message
then negotiation has completed successfully. Session data
may now be transmitted over the connection until it is
@@ -132,7 +132,7 @@
<source>| 0 | 0009 | ANONYMOUS | 0000 |</source>
<p>If a server uses the anonymous mechanism, it should check
that the mechanism name in the start message prefixing the first
- request recieved is 'ANONYMOUS', then simply prefix its initial
+ request received is 'ANONYMOUS', then simply prefix its initial
response with a COMPLETE message of:</p>
<source>| 3 | 0000 |</source>
<p>If an anonymous server recieves some other mechanism name,
diff --git a/lang/py/avro/test/mock_tether_parent.py b/lang/py/avro/test/mock_tether_parent.py
index ac7a08d..710862b 100644
--- a/lang/py/avro/test/mock_tether_parent.py
+++ b/lang/py/avro/test/mock_tether_parent.py
@@ -45,14 +45,14 @@ class MockParentResponder(ipc.Responder):
def invoke(self, message, request):
if message.name == 'configure':
- print("MockParentResponder: Recieved 'configure': inputPort={0}".format(request["port"]))
+ print("MockParentResponder: Received 'configure': inputPort={0}".format(request["port"]))
elif message.name == 'status':
- print("MockParentResponder: Recieved 'status': message={0}".format(request["message"]))
+ print("MockParentResponder: Received 'status': message={0}".format(request["message"]))
elif message.name == 'fail':
- print("MockParentResponder: Recieved 'fail': message={0}".format(request["message"]))
+ print("MockParentResponder: Received 'fail': message={0}".format(request["message"]))
else:
- print("MockParentResponder: Recieved {0}".format(message.name))
+ print("MockParentResponder: Received {0}".format(message.name))
# flush the output so it shows up in the parent process
sys.stdout.flush()
diff --git a/lang/py/avro/tether/tether_task_runner.py b/lang/py/avro/tether/tether_task_runner.py
index c19f2f3..602625c 100644
--- a/lang/py/avro/tether/tether_task_runner.py
+++ b/lang/py/avro/tether/tether_task_runner.py
@@ -64,28 +64,28 @@ class TaskRunnerResponder(ipc.Responder):
def invoke(self, message, request):
try:
if message.name == 'configure':
- self.log.info("TetherTaskRunner: Recieved configure")
+ self.log.info("TetherTaskRunner: Received configure")
self.task.configure(request["taskType"], request["inSchema"], request["outSchema"])
elif message.name == 'partitions':
- self.log.info("TetherTaskRunner: Recieved partitions")
+ self.log.info("TetherTaskRunner: Received partitions")
try:
self.task.partitions = request["partitions"]
except Exception as e:
self.log.error("Exception occured while processing the partitions message: Message:\n" + traceback.format_exc())
raise
elif message.name == 'input':
- self.log.info("TetherTaskRunner: Recieved input")
+ self.log.info("TetherTaskRunner: Received input")
self.task.input(request["data"], request["count"])
elif message.name == 'abort':
- self.log.info("TetherTaskRunner: Recieved abort")
+ self.log.info("TetherTaskRunner: Received abort")
self.runner.close()
elif message.name == 'complete':
- self.log.info("TetherTaskRunner: Recieved complete")
+ self.log.info("TetherTaskRunner: Received complete")
self.task.complete()
self.task.close()
self.runner.close()
else:
- self.log.warning("TetherTaskRunner: recieved unknown message {0}".format(message.name))
+ self.log.warning("TetherTaskRunner: Received unknown message {0}".format(message.name))
except Exception as e:
self.log.error("Error occured while processing message: {0}".format(message.name))