PROTON-1651: Fix typos found by way of spell check (Thanks, Jiri)

bin/record-coverage.sh

@@ -12,7 +12,7 @@
 # - The second is the build tree: this is optional and if not specified is assumed to be the
 #   current directory.
 #
-# The output is in the form of an html report which will be found in the generated html direectory.
+# The output is in the form of an html report which will be found in the generated html directory.
 # - There will also be a number of intermediate files left in the current directory.
 #
 # The typical way to use it would be to use the "Coverage" build type to get instrumented

docs/markdown/index.md

@@ -18,7 +18,7 @@ globally federated topologies
 
 Proton is multi-lingual:
 
-- Proton-C - a C implementation with lanuage bindings in Python, Php, Perl,
+- Proton-C - a C implementation with language bindings in Python, Php, Perl,
 Ruby, and Java (via JNI).
 - Proton-J - a pure Java implementation
 

docs/markdown/messenger/message-disposition.md

@@ -58,7 +58,7 @@ must set a positive size for its incoming window:
 
         pn_messenger_set_incoming_window(messenger, N);
 
-You can implicity accept messages by simply letting enough
+You can implicitly accept messages by simply letting enough
 new messages arrive.  As older messages pass beyond the threshold
 of your incoming window size, they will be automatically
 accepted.  Thus, if you want to automatically accept all

examples/c/direct.c

@@ -207,7 +207,7 @@ static void handle_send(app_data_t* app, pn_event_t* event) {
    }
 
    case PN_DELIVERY: {
-     /* We received acknowledgedment from the peer that a message was delivered. */
+     /* We received acknowledgement from the peer that a message was delivered. */
      pn_delivery_t* d = pn_event_delivery(event);
      if (pn_delivery_remote_state(d) == PN_ACCEPTED) {
        if (++app->acknowledged == app->message_count) {

examples/c/example_test.py

@@ -58,7 +58,7 @@ def __exit__(self, *args):
 class CExampleTest(ProcTestCase):
 
     def runex(self, name, port, messages=MESSAGES):
-        """Run an example with standard arugments, return output"""
+        """Run an example with standard arguments, return output"""
         return self.proc([name, "", str(port), "xtest", str(messages)]).wait_exit()
 
     def test_send_receive(self):

examples/c/send-abort.c

@@ -156,7 +156,7 @@ static bool handle(app_data_t* app, pn_event_t* event) {
    }
 
    case PN_DELIVERY: {
-     /* We received acknowledgedment from the peer that a message was delivered. */
+     /* We received acknowledgement from the peer that a message was delivered. */
      pn_delivery_t* d = pn_event_delivery(event);
      fprintf(stderr, "Aborted deliveries should not receive delivery events. Delivery state %d\n", (int)pn_delivery_remote_state(d));
      pn_connection_close(pn_event_connection(event));

examples/c/send-ssl.c

@@ -149,7 +149,7 @@ static bool handle(app_data_t* app, pn_event_t* event) {
    }
 
    case PN_DELIVERY: {
-     /* We received acknowledgedment from the peer that a message was delivered. */
+     /* We received acknowledgement from the peer that a message was delivered. */
      pn_delivery_t* d = pn_event_delivery(event);
      if (pn_delivery_remote_state(d) == PN_ACCEPTED) {
        if (++app->acknowledged == app->message_count) {

examples/c/send.c

@@ -126,7 +126,7 @@ static bool handle(app_data_t* app, pn_event_t* event) {
    }
 
    case PN_DELIVERY: {
-     /* We received acknowledgedment from the peer that a message was delivered. */
+     /* We received acknowledgement from the peer that a message was delivered. */
      pn_delivery_t* d = pn_event_delivery(event);
      if (pn_delivery_remote_state(d) == PN_ACCEPTED) {
        if (++app->acknowledged == app->message_count) {

examples/cpp/README.dox

@@ -103,7 +103,7 @@ alternatives.
 /** @example broker.cpp
 
 A broker using the `proton::container`. You can use this to run other examples
-that reqiure an intermediary, or you can use any AMQP 1.0 broker. This broker
+that require an intermediary, or you can use any AMQP 1.0 broker. This broker
 creates queues automatically when a client tries to send or subscribe.
 
 */

examples/cpp/encode_decode.cpp

@@ -175,7 +175,7 @@ int main(int, char**) {
 
 // print_next prints the next value from values by recursively descending into complex values.
 //
-// NOTE this is for example puroses only: There is a built in ostream operator<< for values.
+// NOTE this is for example purposes only: There is a built in ostream operator<< for values.
 //
 //
 static void print_next(proton::codec::decoder& d) {

examples/cpp/example_test.py

@@ -159,7 +159,7 @@ def test_flow_control(self):
         want="""success: Example 1: simple credit
 success: Example 2: basic drain
 success: Example 3: drain without credit
-success: Exmaple 4: high/low watermark
+success: Example 4: high/low watermark
 """
         with TestPort() as tp:
             self.assertMultiLineEqual(want, self.proc(["flow_control", "--address", tp.addr, "--quiet"]).wait_exit())

examples/cpp/flow_control.cpp

@@ -163,7 +163,7 @@ class flow_receiver : public proton::messaging_handler {
                 return;
             }
 
-            verify(received == 25 && r.credit() == 0, "Exmaple 4: high/low watermark");
+            verify(received == 25 && r.credit() == 0, "Example 4: high/low watermark");
             r.connection().close();
             break;
 

examples/cpp/multithreaded_client.cpp

@@ -47,7 +47,7 @@
 #include <string>
 #include <thread>
 
-// Lock output from threads to avoid scramblin
+// Lock output from threads to avoid scrambling
 std::mutex out_lock;
 #define OUT(x) do { std::lock_guard<std::mutex> l(out_lock); x; } while (false)
 
@@ -100,7 +100,7 @@ class client : public proton::messaging_handler {
         return work_queue_;
     }
 
-    // == messaging_handler overrides, only called in proton hander thread
+    // == messaging_handler overrides, only called in proton handler thread
 
     // Note: this example creates a connection when the container starts.
     // To create connections after the container has started, use

examples/cpp/multithreaded_client_flow_control.cpp

@@ -57,7 +57,7 @@
 #include <string>
 #include <thread>
 
-// Lock output from threads to avoid scramblin
+// Lock output from threads to avoid scrambling
 std::mutex out_lock;
 #define OUT(x) do { std::lock_guard<std::mutex> l(out_lock); x; } while (false)
 
@@ -106,7 +106,7 @@ class sender : private proton::messaging_handler {
         return work_queue_;
     }
 
-    // == messaging_handler overrides, only called in proton hander thread
+    // == messaging_handler overrides, only called in proton handler thread
 
     void on_sender_open(proton::sender& s) override {
         // Make sure sender_ and work_queue_ are set atomically

examples/cpp/ssl_client_cert.cpp

@@ -96,7 +96,7 @@ class hello_world_direct : public proton::messaging_handler {
         // Configure client.
         ssl_certificate client_cert = platform_certificate("tclient", "tclientpw");
         std::string server_CA = platform_CA("tserver");
-        // Since the test certifcate's credentials are unlikely to match this host's name, downgrade the verification
+        // Since the test certificate's credentials are unlikely to match this host's name, downgrade the verification
         // from VERIFY_PEER_NAME to VERIFY_PEER.
         ssl_client_options ssl_cli(client_cert, server_CA, proton::ssl::VERIFY_PEER);
         connection_options client_opts;

examples/cpp/tutorial.dox

@@ -1,7 +1,7 @@
 // -*-markdown-*-
 // NOTE: doxygen can include markdown pages directly but there seems to be a bug
 // that shows messed-up line numbers in \skip \until code extracts. This file
-// is markdown wrapped in a doxygen comment - which works. The file is best viewed/editied
+// is markdown wrapped in a doxygen comment - which works. The file is best viewed/edited
 // as markdown.
 
 /**

examples/go/README.md

@@ -118,7 +118,7 @@ messages and the sender link for available credit.
 [electron/broker.go](electron/broker.go) does not need any "upside-down"
 event-driven code, it is implemented as straightforward loops. The broker is a
 loop listening for connections. Each connection is a loop accepting for incoming
-sender or recdiver links. Each receiving link is a loop that receives a message
+sender or receiver links. Each receiving link is a loop that receives a message
 and pushes it to a queue.  Each sending link is a loop that pops a message from
 a queue and sends it.
 

examples/go/electron/broker.go

@@ -111,7 +111,7 @@ func (b *broker) run() error {
 	}
 }
 
-// State for a broker connectoin
+// State for a broker connection
 type connection struct {
 	broker     *broker
 	connection electron.Connection

examples/go/electron/send.go

@@ -64,7 +64,7 @@ func main() {
 	wait.Add(len(urls)) // Wait for one goroutine per URL.
 
 	container := electron.NewContainer(fmt.Sprintf("send[%v]", os.Getpid()))
-	connections := make(chan electron.Connection, len(urls)) // Connctions to close on exit
+	connections := make(chan electron.Connection, len(urls)) // Connections to close on exit
 
 	// Start a goroutine for each URL to send messages.
 	for _, urlStr := range urls {

examples/go/proton/broker.go

@@ -24,7 +24,7 @@ under the License.
 // messages to queues or subscribe to receive messages from them.
 //
 
-// TODO: show how to handle acknowledgedments from receivers and put rejected or
+// TODO: show how to handle acknowledgements from receivers and put rejected or
 // un-acknowledged messages back on their queues.
 
 package main
@@ -44,7 +44,7 @@ import (
 func usage() {
 	fmt.Fprintf(os.Stderr, `
 Usage: %s
-A simple broker-like demo. Queues are created automatically for sender or receiver addrsses.
+A simple broker-like demo. Queues are created automatically for sender or receiver addresses.
 `, os.Args[0])
 	flag.PrintDefaults()
 }

examples/python/README

@@ -16,7 +16,7 @@ helloworld.py
 Basic example that connects to an intermediary on localhost:5672,
 establishes a subscription from the 'examples' node on that
 intermediary, then creates a sending link to the same node and sends
-one message. On receving the message back via the subcription, the
+one message. On receiving the message back via the subscription, the
 connection is closed.
 
 helloworld_blocking.py
@@ -79,7 +79,7 @@ db_ctrl.py
 
 A utility for setting up the database tables for the two examples
 above. Takes two arguments, the action to perform and the name of the
-database on which to perfom it. The database used by db_send.py is
+database on which to perform it. The database used by db_send.py is
 src_db, that by db_recv.py is dst_db. The valid actions are 'init',
 which creates the table, 'list' which displays the contents and
 'insert' which inserts records from standard-in and is used to

examples/python/sync_client.py

@@ -20,7 +20,7 @@
 
 """
 Demonstrates the client side of the synchronous request-response pattern
-(also known as RPC or Remote Procecure Call) using proton.
+(also known as RPC or Remote Procedure Call) using proton.
 
 """
 from __future__ import print_function, unicode_literals

proton-c/bindings/cpp/include/proton/container.hpp

@@ -265,7 +265,7 @@ class PN_CPP_CLASS_EXTERN container {
     PN_CPP_EXTERN std::string id() const;
 
     /// Connection options applied to outgoing connections. These are
-    /// applied first and then overriden by any options provided in
+    /// applied first and then overridden by any options provided in
     /// `connect()` or `messaging_handler::on_connection_open()`.
     PN_CPP_EXTERN void client_connection_options(const connection_options& conn_opts);
 

proton-c/bindings/cpp/include/proton/message.hpp

@@ -302,7 +302,7 @@ class message {
     /// be modified in place.
     PN_CPP_EXTERN annotation_map& message_annotations();
 
-    /// Examine the meessage annotations map.
+    /// Examine the message annotations map.
     PN_CPP_EXTERN const annotation_map& message_annotations() const;
 
     /// Get the delivery annotations map.  It can

proton-c/bindings/cpp/include/proton/source_options.hpp

@@ -63,7 +63,7 @@ class source_options {
     /// ignored.
     PN_CPP_EXTERN source_options& dynamic(bool);
 
-    /// Control whether messsages are browsed or consumed.  The
+    /// Control whether messages are browsed or consumed.  The
     /// default is source::MOVE, meaning consumed.
     PN_CPP_EXTERN source_options& distribution_mode(enum source::distribution_mode);
 

proton-c/bindings/cpp/include/proton/tracker.hpp

@@ -49,9 +49,9 @@ class tracker : public transfer {
     /// Get the sender for this tracker.
     PN_CPP_EXTERN class sender sender() const;
 
-    // @cond INTERNAL
+    /// @cond INTERNAL
   friend class internal::factory<tracker>;
-    // @endcond
+    /// @endcond
 };
 
 } // proton

proton-c/bindings/cpp/include/proton/uuid.hpp

@@ -52,12 +52,12 @@ class uuid : public byte_array<16> {
     PN_CPP_EXTERN static uuid random();
 
     /// UUID standard string format: 8-4-4-4-12 (36 chars, 32
-    /// alphanumeric chars and 4 hypens).
+    /// alphanumeric chars and 4 hyphens).
     PN_CPP_EXTERN std::string str()  const;
 };
 
 /// UUID standard format: 8-4-4-4-12 (36 chars, 32 alphanumeric chars
-/// and 4 hypens).
+/// and 4 hyphens).
 PN_CPP_EXTERN std::ostream& operator<<(std::ostream&, const uuid&);
 
 } // proton

proton-c/bindings/cpp/src/interop_test.cpp

@@ -57,8 +57,8 @@ void test_data_ostream() {
     ASSERT_EQUAL("true, false, 42, 42, -42, 12345, -12345, 12345, -12345, 0.125, 0.125", str(dt));
 }
 
-// Test extracting to exact AMQP types works corectly, extrating to invalid types fails.
-void test_decoder_primitves_exact() {
+// Test extracting to exact AMQP types works correctly, extracting to invalid types fails.
+void test_decoder_primitives_exact() {
     value dv;
     decoder d(dv);
     d.decode(read("primitives"));
@@ -109,7 +109,7 @@ int main(int argc, char** argv) {
     tests_dir = argv[1];
 
     RUN_TEST(failed, test_data_ostream());
-    RUN_TEST(failed, test_decoder_primitves_exact());
+    RUN_TEST(failed, test_decoder_primitives_exact());
     RUN_TEST(failed, test_encoder_primitives());
     return failed;
 }

proton-c/bindings/cpp/src/messaging_adapter.cpp

@@ -175,7 +175,7 @@ void on_delivery(messaging_handler& handler, pn_event_t* event) {
     }
 }
 
-bool is_remote_unititialised(pn_state_t state) {
+bool is_remote_uninitialized(pn_state_t state) {
     return state & PN_REMOTE_UNINIT;
 }
 
@@ -275,7 +275,7 @@ void on_transport_closed(messaging_handler& handler, pn_event_t* event) {
     // If the connection isn't open generate on_transport_open event
     // because we didn't generate it yet and the events won't match.
     pn_connection_t *conn = pn_event_connection(event);
-    if (!conn || is_remote_unititialised(pn_connection_state(conn))) {
+    if (!conn || is_remote_uninitialized(pn_connection_state(conn))) {
         handler.on_transport_open(t);
     }
 

proton-c/bindings/cpp/src/proactor_container_impl.cpp

@@ -198,13 +198,13 @@ pn_connection_t* container::impl::make_connection_lh(
 
 // Takes ownership of pnc
 //
-// NOTE: After the call to start_connecton() pnc is active in a proactor thread,
+// NOTE: After the call to start_connection() pnc is active in a proactor thread,
 // and may even have been freed already. It is undefined to use pnc (or any
 // object belonging to it) except in appropriate handlers.
 //
 // SUBTLE NOTE: There must not be any proton::object wrappers in scope when
-// start_connecton() is called. The wrapper destructor will call pn_decref()
-// after start_connecton() which is undefined!
+// start_connection() is called. The wrapper destructor will call pn_decref()
+// after start_connection() which is undefined!
 //
 void container::impl::start_connection(const url& url, pn_connection_t *pnc) {
     char caddr[PN_MAX_ADDR];

proton-c/bindings/cpp/src/test_port.hpp

@@ -150,7 +150,7 @@ class test_port {
 
     std::string url(const std::string& host="") const {
         std::ostringstream url;
-        url << "amp://" << host << ":" << port_;
+        url << "amqp://" << host << ":" << port_;
         return url.str();
     }
 };

proton-c/bindings/cpp/src/uuid.cpp

@@ -85,7 +85,7 @@ uuid uuid::random() {
     return bytes;
 }
 
-/// UUID standard format: 8-4-4-4-12 (36 chars, 32 alphanumeric and 4 hypens)
+/// UUID standard format: 8-4-4-4-12 (36 chars, 32 alphanumeric and 4 hyphens)
 std::ostream& operator<<(std::ostream& o, const uuid& u) {
     ios_guard restore_flags(o);
     o << std::hex << std::setfill('0');

proton-c/bindings/go/genwrap.go

@@ -267,7 +267,7 @@ var (
 func event(out io.Writer) {
 	event_h := readHeader("event")
 
-	// Event is implented by hand in wrappers.go
+	// Event is implemented by hand in wrappers.go
 
 	// Get all the pn_event_type_t enum values
 	var etypes []eventType

proton-c/bindings/go/src/qpid.apache.org/README.md

@@ -6,7 +6,7 @@ available at: <http://godoc.org/?q=qpid.apache.org>
 
 They require the
 [proton-C library and header files](http://qpid.apache.org/proton) to be
-installed.  On many platforms it is avaialable pre-packaged, for example on
+installed.  On many platforms it is available pre-packaged, for example on
 Fedora
 
     dnf install qpid-proton-c-devel

proton-c/bindings/go/src/qpid.apache.org/amqp/message.go

@@ -99,7 +99,7 @@ type Message interface {
 	ContentEncoding() string
 	SetContentEncoding(string)
 
-	// ExpiryTime indicates an absoulte time when the message may be dropped.
+	// ExpiryTime indicates an absolute time when the message may be dropped.
 	// A Zero time (i.e. t.isZero() == true) indicates a message never expires.
 	ExpiryTime() time.Time
 	SetExpiryTime(time.Time)
@@ -146,7 +146,7 @@ type Message interface {
 	// Unmarshal the message body into the value pointed to by v. See amqp.Unmarshal() for details.
 	Unmarshal(interface{})
 
-	// Body value resulting from the default unmarshalling of message body as interface{}
+	// Body value resulting from the default unmarshaling of message body as interface{}
 	Body() interface{}
 
 	// Encode encodes the message as AMQP data. If buffer is non-nil and is large enough