diff options
author | Marcel Müller <neikos@neikos.email> | 2022-07-05 16:13:46 +0200 |
---|---|---|
committer | Marcel Müller <neikos@neikos.email> | 2022-07-05 16:16:57 +0200 |
commit | f5310908557281f85d994c94ebe7531c05b58ee9 (patch) | |
tree | 45df21fcabc639acaee53e3330bab52577c39c73 | |
parent | 207d32d8e242bfe9ac4c0b34e5c29572bcc33909 (diff) |
Add missing MPL license notices
Signed-off-by: Marcel Müller <neikos@neikos.email>
-rw-r--r-- | mqtt-format/src/lib.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/connect_return.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/errors.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/header.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/identifier.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/mod.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/packet.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/qos.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/strings.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/subscription_acks.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/subscription_request.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/unsubscription_request.rs | 6 | ||||
-rw-r--r-- | mqtt-format/src/v3/will.rs | 6 | ||||
-rw-r--r-- | src/bin/cloudmqtt-client.rs | 6 | ||||
-rw-r--r-- | src/client_stream.rs | 6 | ||||
-rw-r--r-- | src/error.rs | 6 | ||||
-rw-r--r-- | src/lib.rs | 6 | ||||
-rw-r--r-- | src/packet_stream.rs | 6 |
18 files changed, 108 insertions, 0 deletions
diff --git a/mqtt-format/src/lib.rs b/mqtt-format/src/lib.rs index 3c0bc30..1bc674c 100644 --- a/mqtt-format/src/lib.rs +++ b/mqtt-format/src/lib.rs @@ -1 +1,7 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + pub mod v3; diff --git a/mqtt-format/src/v3/connect_return.rs b/mqtt-format/src/v3/connect_return.rs index f392b0f..732e2e3 100644 --- a/mqtt-format/src/v3/connect_return.rs +++ b/mqtt-format/src/v3/connect_return.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use nom::error::FromExternalError; use super::{errors::MPacketHeaderError, MSResult}; diff --git a/mqtt-format/src/v3/errors.rs b/mqtt-format/src/v3/errors.rs index 99ab323..cb961f7 100644 --- a/mqtt-format/src/v3/errors.rs +++ b/mqtt-format/src/v3/errors.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + #[derive(Debug, thiserror::Error)] pub enum MPacketHeaderError { #[error("An invalid Quality of Service (Qos) was supplied: {}", .0)] diff --git a/mqtt-format/src/v3/header.rs b/mqtt-format/src/v3/header.rs index 2d7de56..3a02c18 100644 --- a/mqtt-format/src/v3/header.rs +++ b/mqtt-format/src/v3/header.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use nom::{ bits, bytes::complete::take_while_m_n, diff --git a/mqtt-format/src/v3/identifier.rs b/mqtt-format/src/v3/identifier.rs index 91e4164..bd006bd 100644 --- a/mqtt-format/src/v3/identifier.rs +++ b/mqtt-format/src/v3/identifier.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use futures::{AsyncWrite, AsyncWriteExt}; use nom::{number::complete::be_u16, Parser}; diff --git a/mqtt-format/src/v3/mod.rs b/mqtt-format/src/v3/mod.rs index 5814719..724ac62 100644 --- a/mqtt-format/src/v3/mod.rs +++ b/mqtt-format/src/v3/mod.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use nom::IResult; pub mod connect_return; diff --git a/mqtt-format/src/v3/packet.rs b/mqtt-format/src/v3/packet.rs index f736314..4bb7099 100644 --- a/mqtt-format/src/v3/packet.rs +++ b/mqtt-format/src/v3/packet.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use std::pin::Pin; use futures::AsyncWriteExt; diff --git a/mqtt-format/src/v3/qos.rs b/mqtt-format/src/v3/qos.rs index f1855c6..302dfe1 100644 --- a/mqtt-format/src/v3/qos.rs +++ b/mqtt-format/src/v3/qos.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use futures::{AsyncWrite, AsyncWriteExt}; use super::errors::{MPacketHeaderError, MPacketWriteError}; diff --git a/mqtt-format/src/v3/strings.rs b/mqtt-format/src/v3/strings.rs index 0fd239e..efab4a5 100644 --- a/mqtt-format/src/v3/strings.rs +++ b/mqtt-format/src/v3/strings.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use futures::{AsyncWrite, AsyncWriteExt}; use nom::{bytes::complete::take, number::complete::be_u16, IResult, Parser}; use nom_supreme::ParserExt; diff --git a/mqtt-format/src/v3/subscription_acks.rs b/mqtt-format/src/v3/subscription_acks.rs index 994d2c6..010a46c 100644 --- a/mqtt-format/src/v3/subscription_acks.rs +++ b/mqtt-format/src/v3/subscription_acks.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use nom::{error::FromExternalError, multi::many1_count}; use super::{errors::MPacketHeaderError, MSResult}; diff --git a/mqtt-format/src/v3/subscription_request.rs b/mqtt-format/src/v3/subscription_request.rs index 00d85a8..9770a8b 100644 --- a/mqtt-format/src/v3/subscription_request.rs +++ b/mqtt-format/src/v3/subscription_request.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use futures::{AsyncWrite, AsyncWriteExt}; use nom::{multi::many1_count, Parser}; use nom_supreme::ParserExt; diff --git a/mqtt-format/src/v3/unsubscription_request.rs b/mqtt-format/src/v3/unsubscription_request.rs index 0412bba..87004bf 100644 --- a/mqtt-format/src/v3/unsubscription_request.rs +++ b/mqtt-format/src/v3/unsubscription_request.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use nom::{multi::many1_count, Parser}; use super::{ diff --git a/mqtt-format/src/v3/will.rs b/mqtt-format/src/v3/will.rs index 1154c7e..65420d3 100644 --- a/mqtt-format/src/v3/will.rs +++ b/mqtt-format/src/v3/will.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use super::{qos::MQualityOfService, strings::MString}; #[derive(Debug, Clone, Copy, PartialEq, Eq)] diff --git a/src/bin/cloudmqtt-client.rs b/src/bin/cloudmqtt-client.rs index f8d9a33..05e4db5 100644 --- a/src/bin/cloudmqtt-client.rs +++ b/src/bin/cloudmqtt-client.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use clap::Parser; use cloudmqtt::{packet_stream::Acknowledge, MqttClient, MqttConnectionParams}; use futures::StreamExt; diff --git a/src/client_stream.rs b/src/client_stream.rs index 292cbf5..7855d3d 100644 --- a/src/client_stream.rs +++ b/src/client_stream.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use tokio::io::{AsyncRead, AsyncWrite}; pub enum MqttClientStream { diff --git a/src/error.rs b/src/error.rs index 5ccb462..c19e4c5 100644 --- a/src/error.rs +++ b/src/error.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use mqtt_format::v3::connect_return::MConnectReturnCode; #[derive(Debug, thiserror::Error)] @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use std::{pin::Pin, sync::Arc, time::Duration}; use bytes::{BufMut, Bytes, BytesMut}; diff --git a/src/packet_stream.rs b/src/packet_stream.rs index 882f2f3..810cace 100644 --- a/src/packet_stream.rs +++ b/src/packet_stream.rs @@ -1,3 +1,9 @@ +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. +// + use std::future::Ready; use crate::{error::MqttError, MqttClient, MqttPacket}; |