You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ab...@apache.org on 2020/06/15 15:01:13 UTC
[nifi-minifi-cpp] branch master updated (60c463e -> bd707e4)
This is an automated email from the ASF dual-hosted git repository.
aboda pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git.
from 60c463e MINIFICPP-1252 add gsl
add 2362fff MINIFICPP-1203 - Remove build/include suppression from linter, reorder corresponding .cpp files
add a72a394 MINIFICPP-1252 fix shared library build with gsl
add bd707e4 MINIFICPP-1257 don't leak kafka messages on failed send to broker
No new revisions were added by this update.
Summary of changes:
CPPLINT.cfg | 1 -
.../expression-language/ExpressionLoader.cpp | 3 -
extensions/http-curl/HTTPCurlLoader.cpp | 4 -
extensions/http-curl/client/HTTPClient.cpp | 16 ++-
extensions/http-curl/client/HTTPClient.h | 57 +++++----
extensions/librdkafka/KafkaConnection.cpp | 10 +-
extensions/librdkafka/KafkaConnection.h | 24 ++--
extensions/librdkafka/KafkaTopic.h | 18 +--
extensions/librdkafka/PublishKafka.cpp | 10 +-
extensions/librdkafka/PublishKafka.h | 68 +++++-----
extensions/librdkafka/RdKafkaLoader.h | 12 +-
extensions/standard-processors/CPPLINT.cfg | 2 -
.../controllers/UnorderedMapKeyValueStoreService.h | 40 +++---
...UnorderedMapPersistableKeyValueStoreService.cpp | 10 +-
.../UnorderedMapPersistableKeyValueStoreService.h | 44 +++----
.../processors/AppendHostInfo.h | 23 ++--
.../processors/ExecuteProcess.h | 50 ++++----
.../standard-processors/processors/ExtractText.cpp | 11 +-
.../standard-processors/processors/ExtractText.h | 41 +++---
.../processors/GenerateFlowFile.cpp | 10 +-
.../processors/GenerateFlowFile.h | 34 ++---
.../standard-processors/processors/GetFile.cpp | 10 +-
.../standard-processors/processors/GetFile.h | 27 ++--
extensions/standard-processors/processors/GetTCP.h | 33 +++--
.../standard-processors/processors/HashContent.cpp | 10 +-
.../standard-processors/processors/HashContent.h | 55 ++++----
.../standard-processors/processors/ListenSyslog.h | 48 ++++---
.../standard-processors/processors/LogAttribute.h | 32 ++---
.../standard-processors/processors/PutFile.h | 26 ++--
.../processors/RouteOnAttribute.h | 24 ++--
.../standard-processors/processors/TailFile.cpp | 10 +-
.../standard-processors/processors/TailFile.h | 22 ++--
.../processors/UpdateAttribute.h | 25 ++--
.../windows-event-log/ConsumeWindowsEventLog.cpp | 10 +-
.../windows-event-log/ConsumeWindowsEventLog.h | 10 +-
generateVersion.sh | 37 ++++--
libminifi/CMakeLists.txt | 20 +--
libminifi/include/Connection.h | 23 ++--
libminifi/include/CronDrivenSchedulingAgent.h | 25 ++--
libminifi/include/EventDrivenSchedulingAgent.h | 18 +--
libminifi/include/Exception.h | 25 ++--
libminifi/include/FlowControlProtocol.h | 42 ++++---
libminifi/include/FlowController.h | 58 ++++-----
libminifi/include/FlowFileRecord.h | 23 ++--
libminifi/include/RemoteProcessorGroupPort.h | 28 +++--
libminifi/include/ResourceClaim.h | 22 ++--
libminifi/include/SchedulingAgent.h | 17 +--
libminifi/include/ThreadedSchedulingAgent.h | 19 +--
libminifi/include/TimerDrivenSchedulingAgent.h | 16 +--
CPPLINT.cfg => libminifi/include/agent/CPPLINT.cfg | 2 +-
libminifi/include/agent/agent_docs.h | 22 ++--
libminifi/include/agent/build_description.h | 24 ++--
libminifi/include/c2/C2Agent.h | 20 +--
libminifi/include/c2/C2Payload.h | 14 ++-
libminifi/include/c2/C2Protocol.h | 22 ++--
libminifi/include/c2/C2Trigger.h | 19 +--
libminifi/include/c2/ControllerSocketProtocol.h | 23 ++--
libminifi/include/c2/HeartBeatReporter.h | 18 +--
libminifi/include/c2/PayloadParser.h | 25 ++--
libminifi/include/c2/PayloadSerializer.h | 33 ++---
libminifi/include/c2/protocols/RESTProtocol.h | 26 ++--
libminifi/include/c2/triggers/FileUpdateTrigger.h | 25 ++--
.../controllers/LinuxPowerManagementService.h | 18 +--
.../controllers/NetworkPrioritizerService.h | 15 +--
libminifi/include/controllers/SSLContextService.h | 27 ++--
.../include/controllers/ThreadManagementService.h | 18 ++-
.../controllers/UpdatePolicyControllerService.h | 14 +--
.../AbstractAutoPersistingKeyValueStoreService.h | 33 ++---
.../AbstractCoreComponentStateManagerProvider.h | 40 +++---
.../controllers/keyvalue/KeyValueStoreService.h | 30 ++---
.../keyvalue/PersistableKeyValueStoreService.h | 31 ++---
libminifi/include/core/ClassLoader.h | 74 ++++-------
libminifi/include/core/ConfigurableComponent.h | 36 +++---
libminifi/include/core/ConfigurationFactory.h | 15 ++-
libminifi/include/core/Connectable.h | 21 ++--
libminifi/include/core/ContentRepository.h | 21 ++--
libminifi/include/core/Core.h | 44 +++----
libminifi/include/core/CoreComponentState.h | 16 +--
libminifi/include/core/Deprecated.h | 6 +-
libminifi/include/core/FlowConfiguration.h | 20 +--
libminifi/include/core/FlowFile.h | 24 ++--
libminifi/include/core/ProcessContext.h | 20 +--
libminifi/include/core/ProcessContextBuilder.h | 19 +--
libminifi/include/core/ProcessGroup.h | 27 ++--
libminifi/include/core/ProcessSession.h | 25 ++--
libminifi/include/core/ProcessSessionFactory.h | 17 ++-
.../include/core/ProcessSessionReadCallback.h | 47 +++----
libminifi/include/core/Processor.h | 66 +++++-----
libminifi/include/core/ProcessorConfig.h | 15 ++-
libminifi/include/core/ProcessorNode.h | 31 ++---
libminifi/include/core/Property.h | 60 +++++----
libminifi/include/core/PropertyValidation.h | 56 ++++-----
libminifi/include/core/PropertyValue.h | 34 ++---
libminifi/include/core/Relationship.h | 18 ++-
libminifi/include/core/Repository.h | 25 ++--
libminifi/include/core/RepositoryFactory.h | 15 ++-
libminifi/include/core/Resource.h | 138 +++++++++++----------
libminifi/include/core/Scheduling.h | 13 +-
libminifi/include/core/SerializableComponent.h | 24 ++--
libminifi/include/core/StreamManager.h | 16 +--
libminifi/include/core/TraceableResource.h | 13 +-
libminifi/include/core/TypedValues.h | 30 +++--
libminifi/include/core/VariableRegistry.h | 19 ++-
libminifi/include/core/WeakReference.h | 20 ++-
.../include/core/controller/ControllerService.h | 27 ++--
.../core/controller/ControllerServiceLookup.h | 20 ++-
.../include/core/controller/ControllerServiceMap.h | 22 ++--
.../core/controller/ControllerServiceNode.h | 26 ++--
.../core/controller/ControllerServiceProvider.h | 36 +++---
.../controller/StandardControllerServiceNode.h | 19 +--
.../controller/StandardControllerServiceProvider.h | 27 ++--
libminifi/include/core/expect.h | 6 +-
libminifi/include/core/logging/Logger.h | 36 +++---
.../include/core/logging/LoggerConfiguration.h | 27 ++--
.../include/core/logging/WindowsEventLogSink.h | 29 +++--
.../reporting/SiteToSiteProvenanceReportingTask.h | 24 ++--
.../include/core/repository/AtomicRepoEntries.h | 52 ++++----
.../include/core/repository/FileSystemRepository.h | 26 ++--
.../core/repository/VolatileContentRepository.h | 26 ++--
.../core/repository/VolatileFlowFileRepository.h | 24 ++--
.../core/repository/VolatileProvenanceRepository.h | 22 ++--
.../include/core/repository/VolatileRepository.h | 41 +++---
libminifi/include/core/state/FlowIdentifier.h | 17 +--
libminifi/include/core/state/ProcessorController.h | 14 +--
libminifi/include/core/state/UpdateController.h | 41 +++---
libminifi/include/core/state/UpdatePolicy.h | 19 ++-
libminifi/include/core/state/Value.h | 39 +++---
.../include/core/state/nodes/AgentInformation.h | 92 ++++++--------
.../include/core/state/nodes/BuildInformation.h | 56 ++++-----
.../include/core/state/nodes/DeviceInformation.h | 80 ++++++------
.../include/core/state/nodes/FlowInformation.h | 49 ++++----
libminifi/include/core/state/nodes/MetricsBase.h | 40 +++---
.../include/core/state/nodes/ProcessMetrics.h | 32 ++---
libminifi/include/core/state/nodes/QueueMetrics.h | 23 ++--
.../include/core/state/nodes/RepositoryMetrics.h | 21 ++--
.../include/core/state/nodes/SchedulingNodes.h | 20 +--
libminifi/include/core/state/nodes/StateMonitor.h | 29 ++---
libminifi/include/core/state/nodes/SystemMetrics.h | 43 ++++---
.../include/core/state/nodes/TreeUpdateListener.h | 26 ++--
libminifi/include/core/yaml/YamlConfiguration.h | 34 ++---
libminifi/include/io/AtomicEntryStream.h | 18 ++-
libminifi/include/io/BaseStream.h | 24 ++--
libminifi/include/io/CRCStream.h | 33 +++--
libminifi/include/io/ClientSocket.h | 23 ++--
libminifi/include/io/DataStream.h | 19 ++-
libminifi/include/io/DescriptorStream.h | 17 ++-
libminifi/include/io/EndianCheck.h | 15 ++-
libminifi/include/io/FileStream.h | 19 +--
libminifi/include/io/NetworkPrioritizer.h | 13 +-
libminifi/include/io/NonConvertingStream.h | 30 ++---
libminifi/include/io/Serializable.h | 52 ++++----
libminifi/include/io/ServerSocket.h | 22 ++--
libminifi/include/io/Sockets.h | 6 +-
libminifi/include/io/StreamFactory.h | 25 ++--
libminifi/include/io/ZlibStream.h | 18 +--
libminifi/include/io/tls/SecureDescriptorStream.h | 31 ++---
libminifi/include/io/tls/TLSServerSocket.h | 31 ++---
libminifi/include/io/tls/TLSSocket.h | 35 +++---
libminifi/include/io/tls/TLSUtils.h | 20 +--
libminifi/include/io/validation.h | 32 ++---
libminifi/include/processors/ProcessorUtils.h | 37 ++++--
libminifi/include/properties/Configure.h | 15 +--
libminifi/include/properties/Properties.h | 23 ++--
libminifi/include/provenance/Provenance.h | 25 ++--
libminifi/include/sitetosite/Peer.h | 44 +++----
libminifi/include/sitetosite/RawSocketProtocol.h | 46 +++----
libminifi/include/sitetosite/SiteToSite.h | 30 ++---
libminifi/include/sitetosite/SiteToSiteClient.h | 56 ++++-----
libminifi/include/sitetosite/SiteToSiteFactory.h | 19 +--
libminifi/include/utils/BackTrace.h | 6 +-
libminifi/include/utils/ByteArrayCallback.h | 29 ++---
libminifi/include/utils/CallBackTimer.h | 21 ++--
libminifi/include/utils/Deleters.h | 16 +--
libminifi/include/utils/Environment.h | 13 +-
libminifi/include/utils/FailurePolicy.h | 13 +-
libminifi/include/utils/FileOutputCallback.h | 32 ++---
libminifi/include/utils/GeneralUtils.h | 18 +--
libminifi/include/utils/HTTPClient.h | 45 +++----
libminifi/include/utils/Id.h | 25 ++--
libminifi/include/utils/MinifiConcurrentQueue.h | 26 ++--
libminifi/include/utils/Monitors.h | 49 ++++----
libminifi/include/utils/RegexUtils.h | 18 +--
libminifi/include/utils/ScopeGuard.h | 19 +--
libminifi/include/utils/StringUtils.h | 83 ++++++-------
libminifi/include/utils/ThreadPool.h | 35 +++---
libminifi/include/utils/TimeUtil.h | 22 ++--
libminifi/include/utils/file/DiffUtils.h | 36 +++---
libminifi/include/utils/file/FileManager.h | 71 ++++++-----
libminifi/include/utils/file/FileUtils.h | 123 +++++++++---------
libminifi/include/utils/file/PathUtils.h | 20 +--
libminifi/include/utils/gsl.h | 14 +--
libminifi/src/CPPLINT.cfg | 2 +-
libminifi/src/Connection.cpp | 8 +-
libminifi/src/EventDrivenSchedulingAgent.cpp | 8 +-
libminifi/src/FlowControlProtocol.cpp | 8 +-
libminifi/src/FlowController.cpp | 8 +-
libminifi/src/SchedulingAgent.cpp | 8 +-
libminifi/src/c2/C2Agent.cpp | 10 +-
libminifi/src/c2/ControllerSocketProtocol.cpp | 10 +-
libminifi/src/c2/protocols/RESTProtocol.cpp | 10 +-
.../controllers/LinuxPowerManagementService.cpp | 10 +-
.../controllers/UpdatePolicyControllerService.cpp | 10 +-
.../AbstractCoreComponentStateManagerProvider.cpp | 10 +-
libminifi/src/core/ProcessSession.cpp | 10 +-
libminifi/src/core/ProcessSessionReadCallback.cpp | 10 +-
libminifi/src/core/Processor.cpp | 10 +-
.../core/repository/VolatileContentRepository.cpp | 12 +-
libminifi/src/io/CPPLINT.cfg | 3 +-
libminifi/src/io/StreamFactory.cpp | 10 +-
libminifi/src/io/tls/TLSServerSocket.cpp | 10 +-
libminifi/src/io/tls/TLSUtils.cpp | 12 +-
libminifi/src/utils/ClassUtils.cpp | 10 +-
libminifi/src/utils/Environment.cpp | 10 +-
libminifi/src/utils/OsUtils.cpp | 10 +-
libminifi/src/utils/file/PathUtils.cpp | 12 +-
libminifi/test/CPPLINT.cfg | 3 +-
libminifi/test/KamikazeProcessor.cpp | 10 +-
thirdparty/google-styleguide/run_linter.sh | 4 +-
218 files changed, 2820 insertions(+), 2822 deletions(-)
delete mode 100644 extensions/standard-processors/CPPLINT.cfg
copy CPPLINT.cfg => libminifi/include/agent/CPPLINT.cfg (69%)