You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by al...@apache.org on 2017/10/26 01:21:13 UTC
[10/13] nifi-minifi-cpp git commit: MINIFICPP-263: Move merge content
to an extension. Also remove circular dependencies
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/libminifi/test/unit/MergeFileTests.cpp
----------------------------------------------------------------------
diff --git a/libminifi/test/unit/MergeFileTests.cpp b/libminifi/test/unit/MergeFileTests.cpp
deleted file mode 100644
index a3ac139..0000000
--- a/libminifi/test/unit/MergeFileTests.cpp
+++ /dev/null
@@ -1,1061 +0,0 @@
-/**
- *
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#define CATCH_CONFIG_MAIN // This tells Catch to provide a main() - only do this in one cpp file
-#include <uuid/uuid.h>
-#include <fstream>
-#include <map>
-#include <memory>
-#include <utility>
-#include <string>
-#include <set>
-#include "FlowController.h"
-#include "../TestBase.h"
-#include "core/Core.h"
-#include "../../include/core/FlowFile.h"
-#include "../unit/ProvenanceTestHelper.h"
-#include "core/Processor.h"
-#include "core/ProcessContext.h"
-#include "core/ProcessSession.h"
-#include "core/ProcessorNode.h"
-#include "processors/MergeContent.h"
-#include <sstream>
-#include <iostream>
-
-static const char* FLOW_FILE = "/tmp/minifi-mergecontent";
-static const char* EXPECT_MERGE_CONTENT_FIRST = "/tmp/minifi-expect-mergecontent1.txt";
-static const char* EXPECT_MERGE_CONTENT_SECOND = "/tmp/minifi-expect-mergecontent2.txt";
-static const char* HEADER_FILE = "/tmp/minifi-mergecontent.header";
-static const char* FOOTER_FILE = "/tmp/minifi-mergecontent.footer";
-static const char* DEMARCATOR_FILE = "/tmp/minifi-mergecontent.demarcator";
-
-class ReadCallback: public org::apache::nifi::minifi::InputStreamCallback {
- public:
- explicit ReadCallback(uint64_t size) :
- read_size_(0) {
- buffer_size_ = size;
- buffer_ = new uint8_t[buffer_size_];
- archive_buffer_num_ = 0;
- }
- ~ReadCallback() {
- if (buffer_)
- delete[] buffer_;
- for (int i = 0; i < archive_buffer_num_; i++) {
- delete[] archive_buffer_[i];
- }
- }
- int64_t process(std::shared_ptr<org::apache::nifi::minifi::io::BaseStream> stream) {
- int64_t ret = 0;
- ret = stream->read(buffer_, buffer_size_);
- if (!stream)
- read_size_ = stream->getSize();
- else
- read_size_ = buffer_size_;
- return ret;
- }
- void archive_read() {
- struct archive *a;
- a = archive_read_new();
- archive_read_support_format_all(a);
- archive_read_support_filter_all(a);
- archive_read_open_memory(a, buffer_, read_size_);
- struct archive_entry *ae;
-
- while (archive_read_next_header(a, &ae) == ARCHIVE_OK && archive_buffer_num_ < 10) {
- int size = archive_entry_size(ae);
- archive_buffer_[archive_buffer_num_] = new char[size];
- archive_buffer_size_[archive_buffer_num_] = size;
- archive_read_data(a, archive_buffer_[archive_buffer_num_], size);
- archive_buffer_num_++;
- }
- }
-
- uint8_t *buffer_;
- uint64_t buffer_size_;
- uint64_t read_size_;
- char *archive_buffer_[10];
- int archive_buffer_size_[10];
- int archive_buffer_num_;
-};
-
-TEST_CASE("MergeFileDefragment", "[mergefiletest1]") {
- try {
- std::ofstream expectfileFirst;
- std::ofstream expectfileSecond;
-
- expectfileFirst.open(EXPECT_MERGE_CONTENT_FIRST);
- expectfileSecond.open(EXPECT_MERGE_CONTENT_SECOND);
-
- // Create and write to the test file
- for (int i = 0; i < 6; i++) {
- std::ofstream tmpfile;
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- tmpfile.open(flowFileName.c_str());
- for (int j = 0; j < 32; j++) {
- tmpfile << std::to_string(i);
- if (i < 3)
- expectfileFirst << std::to_string(i);
- else
- expectfileSecond << std::to_string(i);
- }
- tmpfile.close();
- }
- expectfileFirst.close();
- expectfileSecond.close();
-
- TestController testController;
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::MergeContent>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::LogAttribute>();
- LogTestController::getInstance().setTrace<core::ProcessSession>();
- LogTestController::getInstance().setTrace<core::repository::VolatileContentRepository>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinFiles>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::Bin>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinManager>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::Connection>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::core::Connectable>();
-
- std::shared_ptr<TestRepository> repo = std::make_shared<TestRepository>();
-
- std::shared_ptr<core::Processor> processor = std::make_shared<org::apache::nifi::minifi::processors::MergeContent>("mergecontent");
- std::shared_ptr<core::Processor> logAttributeProcessor = std::make_shared<org::apache::nifi::minifi::processors::LogAttribute>("logattribute");
-
- uuid_t processoruuid;
- REQUIRE(true == processor->getUUID(processoruuid));
- uuid_t logAttributeuuid;
- REQUIRE(true == logAttributeProcessor->getUUID(logAttributeuuid));
-
- std::shared_ptr<core::ContentRepository> content_repo = std::make_shared<core::repository::VolatileContentRepository>();
- content_repo->initialize(std::make_shared<org::apache::nifi::minifi::Configure>());
- // connection from merge processor to log attribute
- std::shared_ptr<minifi::Connection> connection = std::make_shared<minifi::Connection>(repo, content_repo, "logattributeconnection");
- connection->setRelationship(core::Relationship("merged", "Merge successful output"));
- connection->setSource(processor);
- connection->setDestination(logAttributeProcessor);
- connection->setSourceUUID(processoruuid);
- connection->setDestinationUUID(logAttributeuuid);
- processor->addConnection(connection);
- // connection to merge processor
- std::shared_ptr<minifi::Connection> mergeconnection = std::make_shared<minifi::Connection>(repo, content_repo, "mergeconnection");
- mergeconnection->setDestination(processor);
- mergeconnection->setDestinationUUID(processoruuid);
- processor->addConnection(mergeconnection);
-
- std::set<core::Relationship> autoTerminatedRelationships;
- core::Relationship original("original", "");
- core::Relationship failure("failure", "");
- autoTerminatedRelationships.insert(original);
- autoTerminatedRelationships.insert(failure);
- processor->setAutoTerminatedRelationships(autoTerminatedRelationships);
-
- processor->incrementActiveTasks();
- processor->setScheduledState(core::ScheduledState::RUNNING);
- logAttributeProcessor->incrementActiveTasks();
- logAttributeProcessor->setScheduledState(core::ScheduledState::RUNNING);
-
- std::shared_ptr<core::ProcessorNode> node = std::make_shared<core::ProcessorNode>(processor);
- std::shared_ptr<core::controller::ControllerServiceProvider> controller_services_provider = nullptr;
- auto context = std::make_shared<core::ProcessContext>(node, controller_services_provider, repo, repo, content_repo);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeFormat, MERGE_FORMAT_CONCAT_VALUE);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeStrategy, MERGE_STRATEGY_DEFRAGMENT);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::DelimiterStratgey, DELIMITER_STRATEGY_TEXT);
-
- core::ProcessSession sessionGenFlowFile(context);
- std::shared_ptr<core::FlowFile> record[6];
-
- // Generate 6 flowfiles, first threes merged to one, second thress merged to one
- std::shared_ptr<core::Connectable> income = node->getNextIncomingConnection();
- std::shared_ptr<minifi::Connection> income_connection = std::static_pointer_cast<minifi::Connection>(income);
- for (int i = 0; i < 6; i++) {
- std::shared_ptr<core::FlowFile> flow = std::static_pointer_cast < core::FlowFile > (sessionGenFlowFile.create());
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- sessionGenFlowFile.import(flowFileName, flow, true, 0);
- // three bundle
- if (i < 3)
- flow->setAttribute(processors::BinFiles::FRAGMENT_ID_ATTRIBUTE, std::to_string(0));
- else
- flow->setAttribute(processors::BinFiles::FRAGMENT_ID_ATTRIBUTE, std::to_string(1));
- if (i < 3)
- flow->setAttribute(processors::BinFiles::FRAGMENT_INDEX_ATTRIBUTE, std::to_string(i));
- else
- flow->setAttribute(processors::BinFiles::FRAGMENT_INDEX_ATTRIBUTE, std::to_string(i-3));
- flow->setAttribute(processors::BinFiles::FRAGMENT_COUNT_ATTRIBUTE, std::to_string(3));
- record[i] = flow;
- }
- income_connection->put(record[0]);
- income_connection->put(record[2]);
- income_connection->put(record[5]);
- income_connection->put(record[4]);
- income_connection->put(record[1]);
- income_connection->put(record[3]);
-
- REQUIRE(processor->getName() == "mergecontent");
- auto factory = std::make_shared<core::ProcessSessionFactory>(context);
- processor->onSchedule(context, factory);
- for (int i = 0; i < 6; i++) {
- auto session = std::make_shared<core::ProcessSession>(context);
- processor->onTrigger(context, session);
- session->commit();
- }
- // validate the merge content
- std::set<std::shared_ptr<core::FlowFile>> expiredFlowRecords;
- std::shared_ptr<core::FlowFile> flow1 = connection->poll(expiredFlowRecords);
- std::shared_ptr<core::FlowFile> flow2 = connection->poll(expiredFlowRecords);
- REQUIRE(flow1->getSize() == 96);
- {
- ReadCallback callback(flow1->getSize());
- sessionGenFlowFile.read(flow1, &callback);
- std::ifstream file1;
- file1.open(EXPECT_MERGE_CONTENT_FIRST, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file1)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.buffer_), callback.read_size_);
- REQUIRE(expectContents == contents);
- file1.close();
- }
- REQUIRE(flow2->getSize() == 96);
- {
- ReadCallback callback(flow2->getSize());
- sessionGenFlowFile.read(flow2, &callback);
- std::ifstream file2;
- file2.open(EXPECT_MERGE_CONTENT_SECOND, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file2)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.buffer_), callback.read_size_);
- REQUIRE(expectContents == contents);
- file2.close();
- }
- LogTestController::getInstance().reset();
- for (int i = 0; i < 6; i++) {
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- unlink(flowFileName.c_str());
- }
- unlink(EXPECT_MERGE_CONTENT_FIRST);
- unlink(EXPECT_MERGE_CONTENT_SECOND);
- } catch (...) {
- }
-}
-
-TEST_CASE("MergeFileDefragmentDelimiter", "[mergefiletest2]") {
- try {
- std::ofstream expectfileFirst;
- std::ofstream expectfileSecond;
- std::ofstream headerfile, footerfile, demarcatorfile;
- expectfileFirst.open(EXPECT_MERGE_CONTENT_FIRST);
- expectfileSecond.open(EXPECT_MERGE_CONTENT_SECOND);
- headerfile.open(HEADER_FILE);
- headerfile << "header";
- expectfileFirst << "header";
- expectfileSecond << "header";
- headerfile.close();
- footerfile.open(FOOTER_FILE);
- footerfile << "footer";
- footerfile.close();
- demarcatorfile.open(DEMARCATOR_FILE);
- demarcatorfile << "demarcator";
- demarcatorfile.close();
-
- // Create and write to the test file
- for (int i = 0; i < 6; i++) {
- if (i != 0 && i <= 2)
- expectfileFirst << "demarcator";
- if (i != 3 && i >= 4)
- expectfileSecond << "demarcator";
- std::ofstream tmpfile;
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- tmpfile.open(flowFileName.c_str());
- for (int j = 0; j < 32; j++) {
- tmpfile << std::to_string(i);
- if (i < 3)
- expectfileFirst << std::to_string(i);
- else
- expectfileSecond << std::to_string(i);
- }
- tmpfile.close();
- }
- expectfileFirst << "footer";
- expectfileSecond << "footer";
- expectfileFirst.close();
- expectfileSecond.close();
-
- TestController testController;
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::MergeContent>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::LogAttribute>();
- LogTestController::getInstance().setTrace<core::ProcessSession>();
- LogTestController::getInstance().setTrace<core::repository::VolatileContentRepository>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinFiles>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::Bin>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinManager>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::Connection>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::core::Connectable>();
-
- std::shared_ptr<TestRepository> repo = std::make_shared<TestRepository>();
-
- std::shared_ptr<core::Processor> processor = std::make_shared<org::apache::nifi::minifi::processors::MergeContent>("mergecontent");
- std::shared_ptr<core::Processor> logAttributeProcessor = std::make_shared<org::apache::nifi::minifi::processors::LogAttribute>("logattribute");
-
- uuid_t processoruuid;
- REQUIRE(true == processor->getUUID(processoruuid));
- uuid_t logAttributeuuid;
- REQUIRE(true == logAttributeProcessor->getUUID(logAttributeuuid));
-
- std::shared_ptr<core::ContentRepository> content_repo = std::make_shared<core::repository::VolatileContentRepository>();
- content_repo->initialize(std::make_shared<org::apache::nifi::minifi::Configure>());
- // connection from merge processor to log attribute
- std::shared_ptr<minifi::Connection> connection = std::make_shared<minifi::Connection>(repo, content_repo, "logattributeconnection");
- connection->setRelationship(core::Relationship("merged", "Merge successful output"));
- connection->setSource(processor);
- connection->setDestination(logAttributeProcessor);
- connection->setSourceUUID(processoruuid);
- connection->setDestinationUUID(logAttributeuuid);
- processor->addConnection(connection);
- // connection to merge processor
- std::shared_ptr<minifi::Connection> mergeconnection = std::make_shared<minifi::Connection>(repo, content_repo, "mergeconnection");
- mergeconnection->setDestination(processor);
- mergeconnection->setDestinationUUID(processoruuid);
- processor->addConnection(mergeconnection);
-
- std::set<core::Relationship> autoTerminatedRelationships;
- core::Relationship original("original", "");
- core::Relationship failure("failure", "");
- autoTerminatedRelationships.insert(original);
- autoTerminatedRelationships.insert(failure);
- processor->setAutoTerminatedRelationships(autoTerminatedRelationships);
-
- processor->incrementActiveTasks();
- processor->setScheduledState(core::ScheduledState::RUNNING);
- logAttributeProcessor->incrementActiveTasks();
- logAttributeProcessor->setScheduledState(core::ScheduledState::RUNNING);
-
- std::shared_ptr<core::ProcessorNode> node = std::make_shared<core::ProcessorNode>(processor);
- std::shared_ptr<core::controller::ControllerServiceProvider> controller_services_provider = nullptr;
- auto context = std::make_shared<core::ProcessContext>(node, controller_services_provider, repo, repo, content_repo);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeFormat, MERGE_FORMAT_CONCAT_VALUE);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeStrategy, MERGE_STRATEGY_DEFRAGMENT);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::DelimiterStratgey, DELIMITER_STRATEGY_FILENAME);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::Header, "/tmp/minifi-mergecontent.header");
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::Footer, "/tmp/minifi-mergecontent.footer");
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::Demarcator, "/tmp/minifi-mergecontent.demarcator");
-
- core::ProcessSession sessionGenFlowFile(context);
- std::shared_ptr<core::FlowFile> record[6];
-
- // Generate 6 flowfiles, first threes merged to one, second thress merged to one
- std::shared_ptr<core::Connectable> income = node->getNextIncomingConnection();
- std::shared_ptr<minifi::Connection> income_connection = std::static_pointer_cast<minifi::Connection>(income);
- for (int i = 0; i < 6; i++) {
- std::shared_ptr<core::FlowFile> flow = std::static_pointer_cast < core::FlowFile > (sessionGenFlowFile.create());
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- sessionGenFlowFile.import(flowFileName, flow, true, 0);
- // three bundle
- if (i < 3)
- flow->setAttribute(processors::BinFiles::FRAGMENT_ID_ATTRIBUTE, std::to_string(0));
- else
- flow->setAttribute(processors::BinFiles::FRAGMENT_ID_ATTRIBUTE, std::to_string(1));
- if (i < 3)
- flow->setAttribute(processors::BinFiles::FRAGMENT_INDEX_ATTRIBUTE, std::to_string(i));
- else
- flow->setAttribute(processors::BinFiles::FRAGMENT_INDEX_ATTRIBUTE, std::to_string(i-3));
- flow->setAttribute(processors::BinFiles::FRAGMENT_COUNT_ATTRIBUTE, std::to_string(3));
- record[i] = flow;
- }
- income_connection->put(record[0]);
- income_connection->put(record[2]);
- income_connection->put(record[5]);
- income_connection->put(record[4]);
- income_connection->put(record[1]);
- income_connection->put(record[3]);
-
- REQUIRE(processor->getName() == "mergecontent");
- auto factory = std::make_shared<core::ProcessSessionFactory>(context);
- processor->onSchedule(context, factory);
- for (int i = 0; i < 6; i++) {
- auto session = std::make_shared<core::ProcessSession>(context);
- processor->onTrigger(context, session);
- session->commit();
- }
- // validate the merge content
- std::set<std::shared_ptr<core::FlowFile>> expiredFlowRecords;
- std::shared_ptr<core::FlowFile> flow1 = connection->poll(expiredFlowRecords);
- std::shared_ptr<core::FlowFile> flow2 = connection->poll(expiredFlowRecords);
- REQUIRE(flow1->getSize() == 128);
- {
- ReadCallback callback(flow1->getSize());
- sessionGenFlowFile.read(flow1, &callback);
- std::ifstream file1;
- file1.open(EXPECT_MERGE_CONTENT_FIRST, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file1)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.buffer_), callback.read_size_);
- REQUIRE(expectContents == contents);
- file1.close();
- }
- REQUIRE(flow2->getSize() == 128);
- {
- ReadCallback callback(flow2->getSize());
- sessionGenFlowFile.read(flow2, &callback);
- std::ifstream file2;
- file2.open(EXPECT_MERGE_CONTENT_SECOND, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file2)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.buffer_), callback.read_size_);
- REQUIRE(expectContents == contents);
- file2.close();
- }
- LogTestController::getInstance().reset();
- for (int i = 0; i < 6; i++) {
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- unlink(flowFileName.c_str());
- }
- unlink(EXPECT_MERGE_CONTENT_FIRST);
- unlink(EXPECT_MERGE_CONTENT_SECOND);
- unlink(FOOTER_FILE);
- unlink(HEADER_FILE);
- unlink(DEMARCATOR_FILE);
- } catch (...) {
- }
-}
-
-TEST_CASE("MergeFileDefragmentDropFlow", "[mergefiletest3]") {
- try {
- std::ofstream expectfileFirst;
- std::ofstream expectfileSecond;
-
- expectfileFirst.open(EXPECT_MERGE_CONTENT_FIRST);
- expectfileSecond.open(EXPECT_MERGE_CONTENT_SECOND);
-
- // Create and write to the test file, drop record 4
- for (int i = 0; i < 6; i++) {
- if (i == 4)
- continue;
- std::ofstream tmpfile;
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- tmpfile.open(flowFileName.c_str());
- for (int j = 0; j < 32; j++) {
- tmpfile << std::to_string(i);
- if (i < 3)
- expectfileFirst << std::to_string(i);
- else
- expectfileSecond << std::to_string(i);
- }
- tmpfile.close();
- }
- expectfileFirst.close();
- expectfileSecond.close();
-
- TestController testController;
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::MergeContent>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::LogAttribute>();
- LogTestController::getInstance().setTrace<core::ProcessSession>();
- LogTestController::getInstance().setTrace<core::repository::VolatileContentRepository>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinFiles>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::Bin>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinManager>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::Connection>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::core::Connectable>();
-
- std::shared_ptr<TestRepository> repo = std::make_shared<TestRepository>();
-
- std::shared_ptr<core::Processor> processor = std::make_shared<org::apache::nifi::minifi::processors::MergeContent>("mergecontent");
- std::shared_ptr<core::Processor> logAttributeProcessor = std::make_shared<org::apache::nifi::minifi::processors::LogAttribute>("logattribute");
-
- uuid_t processoruuid;
- REQUIRE(true == processor->getUUID(processoruuid));
- uuid_t logAttributeuuid;
- REQUIRE(true == logAttributeProcessor->getUUID(logAttributeuuid));
-
- std::shared_ptr<core::ContentRepository> content_repo = std::make_shared<core::repository::VolatileContentRepository>();
- content_repo->initialize(std::make_shared<org::apache::nifi::minifi::Configure>());
- // connection from merge processor to log attribute
- std::shared_ptr<minifi::Connection> connection = std::make_shared<minifi::Connection>(repo, content_repo, "logattributeconnection");
- connection->setRelationship(core::Relationship("merged", "Merge successful output"));
- connection->setSource(processor);
- connection->setDestination(logAttributeProcessor);
- connection->setSourceUUID(processoruuid);
- connection->setDestinationUUID(logAttributeuuid);
- processor->addConnection(connection);
- // connection to merge processor
- std::shared_ptr<minifi::Connection> mergeconnection = std::make_shared<minifi::Connection>(repo, content_repo, "mergeconnection");
- mergeconnection->setDestination(processor);
- mergeconnection->setDestinationUUID(processoruuid);
- processor->addConnection(mergeconnection);
-
- std::set<core::Relationship> autoTerminatedRelationships;
- core::Relationship original("original", "");
- core::Relationship failure("failure", "");
- autoTerminatedRelationships.insert(original);
- autoTerminatedRelationships.insert(failure);
- processor->setAutoTerminatedRelationships(autoTerminatedRelationships);
-
- processor->incrementActiveTasks();
- processor->setScheduledState(core::ScheduledState::RUNNING);
- logAttributeProcessor->incrementActiveTasks();
- logAttributeProcessor->setScheduledState(core::ScheduledState::RUNNING);
-
- std::shared_ptr<core::ProcessorNode> node = std::make_shared<core::ProcessorNode>(processor);
- std::shared_ptr<core::controller::ControllerServiceProvider> controller_services_provider = nullptr;
- auto context = std::make_shared<core::ProcessContext>(node, controller_services_provider, repo, repo, content_repo);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeFormat, MERGE_FORMAT_CONCAT_VALUE);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeStrategy, MERGE_STRATEGY_DEFRAGMENT);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::DelimiterStratgey, DELIMITER_STRATEGY_TEXT);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MaxBinAge, "1 sec");
-
- core::ProcessSession sessionGenFlowFile(context);
- std::shared_ptr<core::FlowFile> record[6];
-
- // Generate 6 flowfiles, first threes merged to one, second thress merged to one
- std::shared_ptr<core::Connectable> income = node->getNextIncomingConnection();
- std::shared_ptr<minifi::Connection> income_connection = std::static_pointer_cast<minifi::Connection>(income);
- for (int i = 0; i < 6; i++) {
- if (i == 4)
- continue;
- std::shared_ptr<core::FlowFile> flow = std::static_pointer_cast < core::FlowFile > (sessionGenFlowFile.create());
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- sessionGenFlowFile.import(flowFileName, flow, true, 0);
- // three bundle
- if (i < 3)
- flow->setAttribute(processors::BinFiles::FRAGMENT_ID_ATTRIBUTE, std::to_string(0));
- else
- flow->setAttribute(processors::BinFiles::FRAGMENT_ID_ATTRIBUTE, std::to_string(1));
- if (i < 3)
- flow->setAttribute(processors::BinFiles::FRAGMENT_INDEX_ATTRIBUTE, std::to_string(i));
- else
- flow->setAttribute(processors::BinFiles::FRAGMENT_INDEX_ATTRIBUTE, std::to_string(i-3));
- flow->setAttribute(processors::BinFiles::FRAGMENT_COUNT_ATTRIBUTE, std::to_string(3));
- record[i] = flow;
- }
- income_connection->put(record[0]);
- income_connection->put(record[2]);
- income_connection->put(record[5]);
- income_connection->put(record[1]);
- income_connection->put(record[3]);
-
- REQUIRE(processor->getName() == "mergecontent");
- auto factory = std::make_shared<core::ProcessSessionFactory>(context);
- processor->onSchedule(context, factory);
- for (int i = 0; i < 6; i++) {
- if (i == 4)
- continue;
- auto session = std::make_shared<core::ProcessSession>(context);
- processor->onTrigger(context, session);
- session->commit();
- }
- std::this_thread::sleep_for(std::chrono::milliseconds(2000));
- {
- auto session = std::make_shared<core::ProcessSession>(context);
- processor->onTrigger(context, session);
- }
- // validate the merge content
- std::set<std::shared_ptr<core::FlowFile>> expiredFlowRecords;
- std::shared_ptr<core::FlowFile> flow1 = connection->poll(expiredFlowRecords);
- std::shared_ptr<core::FlowFile> flow2 = connection->poll(expiredFlowRecords);
- REQUIRE(flow1->getSize() == 96);
- {
- ReadCallback callback(flow1->getSize());
- sessionGenFlowFile.read(flow1, &callback);
- std::ifstream file1;
- file1.open(EXPECT_MERGE_CONTENT_FIRST, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file1)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.buffer_), callback.read_size_);
- REQUIRE(expectContents == contents);
- file1.close();
- }
- REQUIRE(flow2->getSize() == 64);
- {
- ReadCallback callback(flow2->getSize());
- sessionGenFlowFile.read(flow2, &callback);
- std::ifstream file2;
- file2.open(EXPECT_MERGE_CONTENT_SECOND, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file2)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.buffer_), callback.read_size_);
- REQUIRE(expectContents == contents);
- file2.close();
- }
- LogTestController::getInstance().reset();
- for (int i = 0; i < 6; i++) {
- if (i == 4)
- continue;
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- unlink(flowFileName.c_str());
- }
- unlink(EXPECT_MERGE_CONTENT_FIRST);
- unlink(EXPECT_MERGE_CONTENT_SECOND);
- } catch (...) {
- }
-}
-
-TEST_CASE("MergeFileBinPack", "[mergefiletest4]") {
- try {
- std::ofstream expectfileFirst;
- std::ofstream expectfileSecond;
- expectfileFirst.open(EXPECT_MERGE_CONTENT_FIRST);
- expectfileSecond.open(EXPECT_MERGE_CONTENT_SECOND);
-
- // Create and write to the test file
- for (int i = 0; i < 6; i++) {
- std::ofstream tmpfile;
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- tmpfile.open(flowFileName.c_str());
- for (int j = 0; j < 32; j++) {
- tmpfile << std::to_string(i);
- if (i < 3)
- expectfileFirst << std::to_string(i);
- else
- expectfileSecond << std::to_string(i);
- }
- tmpfile.close();
- }
- expectfileFirst.close();
- expectfileSecond.close();
-
- TestController testController;
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::MergeContent>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::LogAttribute>();
- LogTestController::getInstance().setTrace<core::ProcessSession>();
- LogTestController::getInstance().setTrace<core::repository::VolatileContentRepository>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinFiles>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::Bin>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinManager>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::Connection>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::core::Connectable>();
-
- std::shared_ptr<TestRepository> repo = std::make_shared<TestRepository>();
-
- std::shared_ptr<core::Processor> processor = std::make_shared<org::apache::nifi::minifi::processors::MergeContent>("mergecontent");
- std::shared_ptr<core::Processor> logAttributeProcessor = std::make_shared<org::apache::nifi::minifi::processors::LogAttribute>("logattribute");
-
- uuid_t processoruuid;
- REQUIRE(true == processor->getUUID(processoruuid));
- uuid_t logAttributeuuid;
- REQUIRE(true == logAttributeProcessor->getUUID(logAttributeuuid));
-
- std::shared_ptr<core::ContentRepository> content_repo = std::make_shared<core::repository::VolatileContentRepository>();
- content_repo->initialize(std::make_shared<org::apache::nifi::minifi::Configure>());
- // connection from merge processor to log attribute
- std::shared_ptr<minifi::Connection> connection = std::make_shared<minifi::Connection>(repo, content_repo, "logattributeconnection");
- connection->setRelationship(core::Relationship("merged", "Merge successful output"));
- connection->setSource(processor);
- connection->setDestination(logAttributeProcessor);
- connection->setSourceUUID(processoruuid);
- connection->setDestinationUUID(logAttributeuuid);
- processor->addConnection(connection);
- // connection to merge processor
- std::shared_ptr<minifi::Connection> mergeconnection = std::make_shared<minifi::Connection>(repo, content_repo, "mergeconnection");
- mergeconnection->setDestination(processor);
- mergeconnection->setDestinationUUID(processoruuid);
- processor->addConnection(mergeconnection);
-
- std::set<core::Relationship> autoTerminatedRelationships;
- core::Relationship original("original", "");
- core::Relationship failure("failure", "");
- autoTerminatedRelationships.insert(original);
- autoTerminatedRelationships.insert(failure);
- processor->setAutoTerminatedRelationships(autoTerminatedRelationships);
-
- processor->incrementActiveTasks();
- processor->setScheduledState(core::ScheduledState::RUNNING);
- logAttributeProcessor->incrementActiveTasks();
- logAttributeProcessor->setScheduledState(core::ScheduledState::RUNNING);
-
- std::shared_ptr<core::ProcessorNode> node = std::make_shared<core::ProcessorNode>(processor);
- std::shared_ptr<core::controller::ControllerServiceProvider> controller_services_provider = nullptr;
- auto context = std::make_shared<core::ProcessContext>(node, controller_services_provider, repo, repo, content_repo);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeFormat, MERGE_FORMAT_CONCAT_VALUE);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeStrategy, MERGE_STRATEGY_BIN_PACK);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::DelimiterStratgey, DELIMITER_STRATEGY_TEXT);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MinSize, "96");
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::CorrelationAttributeName, "tag");
-
- core::ProcessSession sessionGenFlowFile(context);
- std::shared_ptr<core::FlowFile> record[6];
-
- // Generate 6 flowfiles, first threes merged to one, second thress merged to one
- std::shared_ptr<core::Connectable> income = node->getNextIncomingConnection();
- std::shared_ptr<minifi::Connection> income_connection = std::static_pointer_cast<minifi::Connection>(income);
- for (int i = 0; i < 6; i++) {
- std::shared_ptr<core::FlowFile> flow = std::static_pointer_cast < core::FlowFile > (sessionGenFlowFile.create());
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- sessionGenFlowFile.import(flowFileName, flow, true, 0);
- flow->setAttribute("tag", "tag");
- record[i] = flow;
- }
- income_connection->put(record[0]);
- income_connection->put(record[1]);
- income_connection->put(record[2]);
- income_connection->put(record[3]);
- income_connection->put(record[4]);
- income_connection->put(record[5]);
-
- REQUIRE(processor->getName() == "mergecontent");
- auto factory = std::make_shared<core::ProcessSessionFactory>(context);
- processor->onSchedule(context, factory);
- for (int i = 0; i < 6; i++) {
- auto session = std::make_shared<core::ProcessSession>(context);
- processor->onTrigger(context, session);
- session->commit();
- }
- // validate the merge content
- std::set<std::shared_ptr<core::FlowFile>> expiredFlowRecords;
- std::shared_ptr<core::FlowFile> flow1 = connection->poll(expiredFlowRecords);
- std::shared_ptr<core::FlowFile> flow2 = connection->poll(expiredFlowRecords);
- REQUIRE(flow1->getSize() == 96);
- {
- ReadCallback callback(flow1->getSize());
- sessionGenFlowFile.read(flow1, &callback);
- std::ifstream file1;
- file1.open(EXPECT_MERGE_CONTENT_FIRST, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file1)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.buffer_), callback.read_size_);
- REQUIRE(expectContents == contents);
- file1.close();
- }
- REQUIRE(flow2->getSize() == 96);
- {
- ReadCallback callback(flow2->getSize());
- sessionGenFlowFile.read(flow2, &callback);
- std::ifstream file2;
- file2.open(EXPECT_MERGE_CONTENT_SECOND, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file2)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.buffer_), callback.read_size_);
- REQUIRE(expectContents == contents);
- file2.close();
- }
- LogTestController::getInstance().reset();
- for (int i = 0; i < 6; i++) {
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- unlink(flowFileName.c_str());
- }
- unlink(EXPECT_MERGE_CONTENT_FIRST);
- unlink(EXPECT_MERGE_CONTENT_SECOND);
- } catch (...) {
- }
-}
-
-
-TEST_CASE("MergeFileTar", "[mergefiletest4]") {
- try {
- std::ofstream expectfileFirst;
- std::ofstream expectfileSecond;
- expectfileFirst.open(EXPECT_MERGE_CONTENT_FIRST);
- expectfileSecond.open(EXPECT_MERGE_CONTENT_SECOND);
-
- // Create and write to the test file
- for (int i = 0; i < 6; i++) {
- std::ofstream tmpfile;
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- tmpfile.open(flowFileName.c_str());
- for (int j = 0; j < 32; j++) {
- tmpfile << std::to_string(i);
- if (i < 3)
- expectfileFirst << std::to_string(i);
- else
- expectfileSecond << std::to_string(i);
- }
- tmpfile.close();
- }
- expectfileFirst.close();
- expectfileSecond.close();
-
- TestController testController;
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::MergeContent>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::LogAttribute>();
- LogTestController::getInstance().setTrace<core::ProcessSession>();
- LogTestController::getInstance().setTrace<core::repository::VolatileContentRepository>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinFiles>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::Bin>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinManager>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::Connection>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::core::Connectable>();
-
- std::shared_ptr<TestRepository> repo = std::make_shared<TestRepository>();
-
- std::shared_ptr<core::Processor> processor = std::make_shared<org::apache::nifi::minifi::processors::MergeContent>("mergecontent");
- std::shared_ptr<core::Processor> logAttributeProcessor = std::make_shared<org::apache::nifi::minifi::processors::LogAttribute>("logattribute");
-
- uuid_t processoruuid;
- REQUIRE(true == processor->getUUID(processoruuid));
- uuid_t logAttributeuuid;
- REQUIRE(true == logAttributeProcessor->getUUID(logAttributeuuid));
-
- std::shared_ptr<core::ContentRepository> content_repo = std::make_shared<core::repository::VolatileContentRepository>();
- content_repo->initialize(std::make_shared<org::apache::nifi::minifi::Configure>());
- // connection from merge processor to log attribute
- std::shared_ptr<minifi::Connection> connection = std::make_shared<minifi::Connection>(repo, content_repo, "logattributeconnection");
- connection->setRelationship(core::Relationship("merged", "Merge successful output"));
- connection->setSource(processor);
- connection->setDestination(logAttributeProcessor);
- connection->setSourceUUID(processoruuid);
- connection->setDestinationUUID(logAttributeuuid);
- processor->addConnection(connection);
- // connection to merge processor
- std::shared_ptr<minifi::Connection> mergeconnection = std::make_shared<minifi::Connection>(repo, content_repo, "mergeconnection");
- mergeconnection->setDestination(processor);
- mergeconnection->setDestinationUUID(processoruuid);
- processor->addConnection(mergeconnection);
-
- std::set<core::Relationship> autoTerminatedRelationships;
- core::Relationship original("original", "");
- core::Relationship failure("failure", "");
- autoTerminatedRelationships.insert(original);
- autoTerminatedRelationships.insert(failure);
- processor->setAutoTerminatedRelationships(autoTerminatedRelationships);
-
- processor->incrementActiveTasks();
- processor->setScheduledState(core::ScheduledState::RUNNING);
- logAttributeProcessor->incrementActiveTasks();
- logAttributeProcessor->setScheduledState(core::ScheduledState::RUNNING);
-
- std::shared_ptr<core::ProcessorNode> node = std::make_shared<core::ProcessorNode>(processor);
- std::shared_ptr<core::controller::ControllerServiceProvider> controller_services_provider = nullptr;
- auto context = std::make_shared<core::ProcessContext>(node, controller_services_provider, repo, repo, content_repo);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeFormat, MERGE_FORMAT_TAR_VALUE);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeStrategy, MERGE_STRATEGY_BIN_PACK);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::DelimiterStratgey, DELIMITER_STRATEGY_TEXT);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MinSize, "96");
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::CorrelationAttributeName, "tag");
-
- core::ProcessSession sessionGenFlowFile(context);
- std::shared_ptr<core::FlowFile> record[6];
-
- // Generate 6 flowfiles, first threes merged to one, second thress merged to one
- std::shared_ptr<core::Connectable> income = node->getNextIncomingConnection();
- std::shared_ptr<minifi::Connection> income_connection = std::static_pointer_cast<minifi::Connection>(income);
- for (int i = 0; i < 6; i++) {
- std::shared_ptr<core::FlowFile> flow = std::static_pointer_cast < core::FlowFile > (sessionGenFlowFile.create());
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- sessionGenFlowFile.import(flowFileName, flow, true, 0);
- flow->setAttribute("tag", "tag");
- record[i] = flow;
- }
- income_connection->put(record[0]);
- income_connection->put(record[1]);
- income_connection->put(record[2]);
- income_connection->put(record[3]);
- income_connection->put(record[4]);
- income_connection->put(record[5]);
-
- REQUIRE(processor->getName() == "mergecontent");
- auto factory = std::make_shared<core::ProcessSessionFactory>(context);
- processor->onSchedule(context, factory);
- for (int i = 0; i < 6; i++) {
- auto session = std::make_shared<core::ProcessSession>(context);
- processor->onTrigger(context, session);
- session->commit();
- }
- // validate the merge content
- std::set<std::shared_ptr<core::FlowFile>> expiredFlowRecords;
- std::shared_ptr<core::FlowFile> flow1 = connection->poll(expiredFlowRecords);
- std::shared_ptr<core::FlowFile> flow2 = connection->poll(expiredFlowRecords);
- REQUIRE(flow1->getSize() > 0);
- {
- ReadCallback callback(flow1->getSize());
- sessionGenFlowFile.read(flow1, &callback);
- callback.archive_read();
- REQUIRE(callback.archive_buffer_num_ == 3);
- for (int i = 0; i < 3; i++) {
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- std::ifstream file1;
- file1.open(flowFileName, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file1)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.archive_buffer_[i]), callback.archive_buffer_size_[i]);
- REQUIRE(expectContents == contents);
- file1.close();
- }
- }
- REQUIRE(flow2->getSize() > 0);
- {
- ReadCallback callback(flow2->getSize());
- sessionGenFlowFile.read(flow2, &callback);
- callback.archive_read();
- REQUIRE(callback.archive_buffer_num_ == 3);
- for (int i = 3; i < 6; i++) {
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- std::ifstream file1;
- file1.open(flowFileName, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file1)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.archive_buffer_[i-3]), callback.archive_buffer_size_[i-3]);
- REQUIRE(expectContents == contents);
- file1.close();
- }
- }
- LogTestController::getInstance().reset();
- for (int i = 0; i < 6; i++) {
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- unlink(flowFileName.c_str());
- }
- unlink(EXPECT_MERGE_CONTENT_FIRST);
- unlink(EXPECT_MERGE_CONTENT_SECOND);
- } catch (...) {
- }
-}
-
-TEST_CASE("MergeFileZip", "[mergefiletest5]") {
- try {
- std::ofstream expectfileFirst;
- std::ofstream expectfileSecond;
- expectfileFirst.open(EXPECT_MERGE_CONTENT_FIRST);
- expectfileSecond.open(EXPECT_MERGE_CONTENT_SECOND);
-
- // Create and write to the test file
- for (int i = 0; i < 6; i++) {
- std::ofstream tmpfile;
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- tmpfile.open(flowFileName.c_str());
- for (int j = 0; j < 32; j++) {
- tmpfile << std::to_string(i);
- if (i < 3)
- expectfileFirst << std::to_string(i);
- else
- expectfileSecond << std::to_string(i);
- }
- tmpfile.close();
- }
- expectfileFirst.close();
- expectfileSecond.close();
-
- TestController testController;
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::MergeContent>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::LogAttribute>();
- LogTestController::getInstance().setTrace<core::ProcessSession>();
- LogTestController::getInstance().setTrace<core::repository::VolatileContentRepository>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinFiles>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::Bin>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::processors::BinManager>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::Connection>();
- LogTestController::getInstance().setTrace<org::apache::nifi::minifi::core::Connectable>();
-
- std::shared_ptr<TestRepository> repo = std::make_shared<TestRepository>();
-
- std::shared_ptr<core::Processor> processor = std::make_shared<org::apache::nifi::minifi::processors::MergeContent>("mergecontent");
- std::shared_ptr<core::Processor> logAttributeProcessor = std::make_shared<org::apache::nifi::minifi::processors::LogAttribute>("logattribute");
-
- uuid_t processoruuid;
- REQUIRE(true == processor->getUUID(processoruuid));
- uuid_t logAttributeuuid;
- REQUIRE(true == logAttributeProcessor->getUUID(logAttributeuuid));
-
- std::shared_ptr<core::ContentRepository> content_repo = std::make_shared<core::repository::VolatileContentRepository>();
- content_repo->initialize(std::make_shared<org::apache::nifi::minifi::Configure>());
- // connection from merge processor to log attribute
- std::shared_ptr<minifi::Connection> connection = std::make_shared<minifi::Connection>(repo, content_repo, "logattributeconnection");
- connection->setRelationship(core::Relationship("merged", "Merge successful output"));
- connection->setSource(processor);
- connection->setDestination(logAttributeProcessor);
- connection->setSourceUUID(processoruuid);
- connection->setDestinationUUID(logAttributeuuid);
- processor->addConnection(connection);
- // connection to merge processor
- std::shared_ptr<minifi::Connection> mergeconnection = std::make_shared<minifi::Connection>(repo, content_repo, "mergeconnection");
- mergeconnection->setDestination(processor);
- mergeconnection->setDestinationUUID(processoruuid);
- processor->addConnection(mergeconnection);
-
- std::set<core::Relationship> autoTerminatedRelationships;
- core::Relationship original("original", "");
- core::Relationship failure("failure", "");
- autoTerminatedRelationships.insert(original);
- autoTerminatedRelationships.insert(failure);
- processor->setAutoTerminatedRelationships(autoTerminatedRelationships);
-
- processor->incrementActiveTasks();
- processor->setScheduledState(core::ScheduledState::RUNNING);
- logAttributeProcessor->incrementActiveTasks();
- logAttributeProcessor->setScheduledState(core::ScheduledState::RUNNING);
-
- std::shared_ptr<core::ProcessorNode> node = std::make_shared<core::ProcessorNode>(processor);
- std::shared_ptr<core::controller::ControllerServiceProvider> controller_services_provider = nullptr;
- auto context = std::make_shared<core::ProcessContext>(node, controller_services_provider, repo, repo, content_repo);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeFormat, MERGE_FORMAT_ZIP_VALUE);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MergeStrategy, MERGE_STRATEGY_BIN_PACK);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::DelimiterStratgey, DELIMITER_STRATEGY_TEXT);
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::MinSize, "96");
- context->setProperty(org::apache::nifi::minifi::processors::MergeContent::CorrelationAttributeName, "tag");
-
- core::ProcessSession sessionGenFlowFile(context);
- std::shared_ptr<core::FlowFile> record[6];
-
- // Generate 6 flowfiles, first threes merged to one, second thress merged to one
- std::shared_ptr<core::Connectable> income = node->getNextIncomingConnection();
- std::shared_ptr<minifi::Connection> income_connection = std::static_pointer_cast<minifi::Connection>(income);
- for (int i = 0; i < 6; i++) {
- std::shared_ptr<core::FlowFile> flow = std::static_pointer_cast < core::FlowFile > (sessionGenFlowFile.create());
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- sessionGenFlowFile.import(flowFileName, flow, true, 0);
- flow->setAttribute("tag", "tag");
- record[i] = flow;
- }
- income_connection->put(record[0]);
- income_connection->put(record[1]);
- income_connection->put(record[2]);
- income_connection->put(record[3]);
- income_connection->put(record[4]);
- income_connection->put(record[5]);
-
- REQUIRE(processor->getName() == "mergecontent");
- auto factory = std::make_shared<core::ProcessSessionFactory>(context);
- processor->onSchedule(context, factory);
- for (int i = 0; i < 6; i++) {
- auto session = std::make_shared<core::ProcessSession>(context);
- processor->onTrigger(context, session);
- session->commit();
- }
- // validate the merge content
- std::set<std::shared_ptr<core::FlowFile>> expiredFlowRecords;
- std::shared_ptr<core::FlowFile> flow1 = connection->poll(expiredFlowRecords);
- std::shared_ptr<core::FlowFile> flow2 = connection->poll(expiredFlowRecords);
- REQUIRE(flow1->getSize() > 0);
- {
- ReadCallback callback(flow1->getSize());
- sessionGenFlowFile.read(flow1, &callback);
- callback.archive_read();
- REQUIRE(callback.archive_buffer_num_ == 3);
- for (int i = 0; i < 3; i++) {
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- std::ifstream file1;
- file1.open(flowFileName, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file1)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.archive_buffer_[i]), callback.archive_buffer_size_[i]);
- REQUIRE(expectContents == contents);
- file1.close();
- }
- }
- REQUIRE(flow2->getSize() > 0);
- {
- ReadCallback callback(flow2->getSize());
- sessionGenFlowFile.read(flow2, &callback);
- callback.archive_read();
- REQUIRE(callback.archive_buffer_num_ == 3);
- for (int i = 3; i < 6; i++) {
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- std::ifstream file1;
- file1.open(flowFileName, std::ios::in);
- std::string contents((std::istreambuf_iterator<char>(file1)), std::istreambuf_iterator<char>());
- std::string expectContents(reinterpret_cast<char *> (callback.archive_buffer_[i-3]), callback.archive_buffer_size_[i-3]);
- REQUIRE(expectContents == contents);
- file1.close();
- }
- }
- LogTestController::getInstance().reset();
- for (int i = 0; i < 6; i++) {
- std::string flowFileName = std::string(FLOW_FILE) + "." + std::to_string(i) + ".txt";
- unlink(flowFileName.c_str());
- }
- unlink(EXPECT_MERGE_CONTENT_FIRST);
- unlink(EXPECT_MERGE_CONTENT_SECOND);
- } catch (...) {
- }
-}
-
-
-
-
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/main/CMakeLists.txt
----------------------------------------------------------------------
diff --git a/main/CMakeLists.txt b/main/CMakeLists.txt
index daa1e13..e984dee 100644
--- a/main/CMakeLists.txt
+++ b/main/CMakeLists.txt
@@ -23,7 +23,7 @@ IF(POLICY CMP0048)
CMAKE_POLICY(SET CMP0048 OLD)
ENDIF(POLICY CMP0048)
-include_directories(../libminifi/include ../libminifi/include/c2 ../libminifi/include/c2/protocols/ ../libminifi/include/core/state ./libminifi/include/core/statemanagement/metrics ../libminifi/include/core/yaml ../libminifi/include/core ../thirdparty/spdlog-20170710/include ../thirdparty/concurrentqueue ../thirdparty/yaml-cpp-yaml-cpp-0.5.3/include ../thirdparty/civetweb-1.9.1/include ../thirdparty/jsoncpp/include ../thirdparty/libarchive-3.3.2/libarchive ../thirdparty/)
+include_directories(../libminifi/include ../libminifi/include/c2 ../libminifi/include/c2/protocols/ ../libminifi/include/core/state ./libminifi/include/core/statemanagement/metrics ../libminifi/include/core/yaml ../libminifi/include/core ../thirdparty/spdlog-20170710/include ../thirdparty/concurrentqueue ../thirdparty/yaml-cpp-yaml-cpp-20171024/include ../thirdparty/civetweb-1.9.1/include ../thirdparty/jsoncpp/include ../thirdparty/)
include(CheckCXXCompilerFlag)
CHECK_CXX_COMPILER_FLAG("-std=c++11" COMPILER_SUPPORTS_CXX11)
@@ -36,9 +36,6 @@ else()
message(STATUS "The compiler ${CMAKE_CXX_COMPILER} has no C++11 support. Please use a different C++ compiler.")
endif()
-find_package(Boost REQUIRED)
-include_directories(${Boost_INCLUDE_DIRS})
-
add_executable(minifiexe MiNiFiMain.cpp)
if(THREADS_HAVE_PTHREAD_ARG)
target_compile_options(PUBLIC minifiexe "-pthread")
@@ -55,7 +52,7 @@ find_package(OpenSSL REQUIRED)
include_directories(${OPENSSL_INCLUDE_DIR})
# Link against minifi, yaml-cpp, civetweb-cpp, uuid, openssl, jsoncpp and rocksdb
-target_link_libraries(minifiexe minifi yaml-cpp c-library civetweb-cpp ${JSON_CPP_LIB} ${UUID_LIBRARIES} ${OPENSSL_LIBRARIES} archive)
+target_link_libraries(minifiexe core-minifi minifi yaml-cpp c-library civetweb-cpp ${JSON_CPP_LIB} ${UUID_LIBRARIES} ${OPENSSL_LIBRARIES})
if (APPLE)
if (HTTP-CURL)
@@ -64,6 +61,9 @@ if (APPLE)
if (ROCKSDB-REPOS)
target_link_libraries (minifiexe -Wl,-all_load ${ROCKSDB-REPOS})
endif()
+ if (ARCHIVE-EXTENSIONS)
+ target_link_libraries (minifiexe -Wl,-all_load ${ARCHIVE-EXTENSIONS})
+ endif()
else ()
if (HTTP-CURL)
@@ -71,6 +71,9 @@ else ()
endif()
if (ROCKSDB-REPOS)
target_link_libraries (minifiexe -Wl,--whole-archive ${ROCKSDB-REPOS} -Wl,--no-whole-archive)
+ endif()
+ if (ARCHIVE-EXTENSIONS)
+ target_link_libraries (minifiexe -Wl,--whole-archive ${ARCHIVE-EXTENSIONS} -Wl,--no-whole-archive)
endif()
endif ()
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/.clang-format
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/.clang-format b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/.clang-format
deleted file mode 100644
index d6e1b22..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/.clang-format
+++ /dev/null
@@ -1,47 +0,0 @@
----
-# BasedOnStyle: Google
-AccessModifierOffset: -1
-ConstructorInitializerIndentWidth: 4
-AlignEscapedNewlinesLeft: true
-AlignTrailingComments: true
-AllowAllParametersOfDeclarationOnNextLine: true
-AllowShortIfStatementsOnASingleLine: false
-AllowShortLoopsOnASingleLine: false
-AlwaysBreakTemplateDeclarations: true
-AlwaysBreakBeforeMultilineStrings: true
-BreakBeforeBinaryOperators: false
-BreakBeforeTernaryOperators: true
-BreakConstructorInitializersBeforeComma: false
-BinPackParameters: true
-ColumnLimit: 80
-ConstructorInitializerAllOnOneLineOrOnePerLine: true
-DerivePointerBinding: true
-ExperimentalAutoDetectBinPacking: false
-IndentCaseLabels: true
-MaxEmptyLinesToKeep: 1
-NamespaceIndentation: None
-ObjCSpaceBeforeProtocolList: false
-PenaltyBreakBeforeFirstCallParameter: 1
-PenaltyBreakComment: 60
-PenaltyBreakString: 1000
-PenaltyBreakFirstLessLess: 120
-PenaltyExcessCharacter: 1000000
-PenaltyReturnTypeOnItsOwnLine: 200
-PointerBindsToType: true
-SpacesBeforeTrailingComments: 2
-Cpp11BracedListStyle: true
-Standard: Auto
-IndentWidth: 2
-TabWidth: 8
-UseTab: Never
-BreakBeforeBraces: Attach
-IndentFunctionDeclarationAfterType: true
-SpacesInParentheses: false
-SpacesInAngles: false
-SpaceInEmptyParentheses: false
-SpacesInCStyleCastParentheses: false
-SpaceAfterControlStatementKeyword: true
-SpaceBeforeAssignmentOperators: true
-ContinuationIndentWidth: 4
-...
-
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/.gitignore
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/.gitignore b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/.gitignore
deleted file mode 100644
index 567609b..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/.gitignore
+++ /dev/null
@@ -1 +0,0 @@
-build/
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/CMakeLists.txt
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/CMakeLists.txt b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/CMakeLists.txt
deleted file mode 100644
index a54c48d..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/CMakeLists.txt
+++ /dev/null
@@ -1,337 +0,0 @@
-###
-### CMake settings
-###
-## Due to Mac OSX we need to keep compatibility with CMake 2.6
-# see http://www.cmake.org/Wiki/CMake_Policies
-cmake_minimum_required(VERSION 2.6)
-# see http://www.cmake.org/cmake/help/cmake-2-8-docs.html#policy:CMP0012
-if(POLICY CMP0012)
- cmake_policy(SET CMP0012 OLD)
-endif()
-# see http://www.cmake.org/cmake/help/cmake-2-8-docs.html#policy:CMP0015
-if(POLICY CMP0015)
- cmake_policy(SET CMP0015 OLD)
-endif()
-
-include(CheckCXXCompilerFlag)
-
-
-###
-### Project settings
-###
-project(YAML_CPP)
-
-set(YAML_CPP_VERSION_MAJOR "0")
-set(YAML_CPP_VERSION_MINOR "5")
-set(YAML_CPP_VERSION_PATCH "3")
-set(YAML_CPP_VERSION "${YAML_CPP_VERSION_MAJOR}.${YAML_CPP_VERSION_MINOR}.${YAML_CPP_VERSION_PATCH}")
-
-
-###
-### Project options
-###
-## Project stuff
-option(YAML_CPP_BUILD_TOOLS "Enable testing and parse tools" ON)
-option(YAML_CPP_BUILD_CONTRIB "Enable contrib stuff in library" ON)
-
-## Build options
-# --> General
-# see http://www.cmake.org/cmake/help/cmake2.6docs.html#variable:BUILD_SHARED_LIBS
-# http://www.cmake.org/cmake/help/cmake2.6docs.html#command:add_library
-option(BUILD_SHARED_LIBS "Build Shared Libraries" OFF)
-
-# --> Apple
-option(APPLE_UNIVERSAL_BIN "Apple: Build universal binary" OFF)
-
-# --> Microsoft Visual C++
-# see http://msdn.microsoft.com/en-us/library/aa278396(v=VS.60).aspx
-# http://msdn.microsoft.com/en-us/library/2kzt1wy3(v=VS.71).aspx
-option(MSVC_SHARED_RT "MSVC: Build with shared runtime libs (/MD)" ON)
-option(MSVC_STHREADED_RT "MSVC: Build with single-threaded static runtime libs (/ML until VS .NET 2003)" OFF)
-
-###
-### Sources, headers, directories and libs
-###
-
-# From http://www.cmake.org/pipermail/cmake/2010-March/035992.html:
-# function to collect all the sources from sub-directories
-# into a single list
-function(add_sources)
- get_property(is_defined GLOBAL PROPERTY SRCS_LIST DEFINED)
- if(NOT is_defined)
- define_property(GLOBAL PROPERTY SRCS_LIST
- BRIEF_DOCS "List of source files"
- FULL_DOCS "List of all source files in the entire project")
- endif()
- # make absolute paths
- set(SRCS)
- foreach(s IN LISTS ARGN)
- if(NOT IS_ABSOLUTE "${s}")
- get_filename_component(s "${s}" ABSOLUTE)
- endif()
- list(APPEND SRCS "${s}")
- endforeach()
- # append to global list
- set_property(GLOBAL APPEND PROPERTY SRCS_LIST "${SRCS}")
-endfunction(add_sources)
-
-set(header_directory "include/yaml-cpp/")
-
-file(GLOB sources "src/[a-zA-Z]*.cpp")
-file(GLOB_RECURSE public_headers "include/yaml-cpp/[a-zA-Z]*.h")
-file(GLOB private_headers "src/[a-zA-Z]*.h")
-
-if(YAML_CPP_BUILD_CONTRIB)
- file(GLOB contrib_sources "src/contrib/[a-zA-Z]*.cpp")
- file(GLOB contrib_public_headers "include/yaml-cpp/contrib/[a-zA-Z]*.h")
- file(GLOB contrib_private_headers "src/contrib/[a-zA-Z]*.h")
-else()
- add_definitions(-DYAML_CPP_NO_CONTRIB)
-endif()
-
-set(library_sources
- ${sources}
- ${public_headers}
- ${private_headers}
- ${contrib_sources}
- ${contrib_public_headers}
- ${contrib_private_headers}
-)
-add_sources(${library_sources})
-
-if(VERBOSE)
- message(STATUS "sources: ${sources}")
- message(STATUS "public_headers: ${public_headers}")
- message(STATUS "private_headers: ${private_headers}")
- message(STATUS "contrib_sources: ${contrib_sources}")
- message(STATUS "contrib_public_headers: ${contrib_public_headers}")
- message(STATUS "contrib_private_headers: ${contrib_private_headers}")
-endif()
-
-include_directories(${YAML_CPP_SOURCE_DIR}/src)
-include_directories(${YAML_CPP_SOURCE_DIR}/include)
-
-find_package(Boost REQUIRED)
-include_directories(${Boost_INCLUDE_DIRS})
-
-
-###
-### General compilation settings
-###
-set(yaml_c_flags ${CMAKE_C_FLAGS})
-set(yaml_cxx_flags ${CMAKE_CXX_FLAGS})
-
-if(BUILD_SHARED_LIBS)
- set(LABEL_SUFFIX "shared")
-else()
- set(LABEL_SUFFIX "static")
-endif()
-
-if(APPLE)
- if(APPLE_UNIVERSAL_BIN)
- set(CMAKE_OSX_ARCHITECTURES ppc;i386)
- endif()
-endif()
-
-if(IPHONE)
- set(CMAKE_OSX_SYSROOT "iphoneos4.2")
- set(CMAKE_OSX_ARCHITECTURES "armv6;armv7")
-endif()
-
-if(WIN32)
- if(BUILD_SHARED_LIBS)
- add_definitions(-D${PROJECT_NAME}_DLL) # use or build Windows DLL
- endif()
- if(CMAKE_INSTALL_PREFIX_INITIALIZED_TO_DEFAULT)
- set(CMAKE_INSTALL_PREFIX "C:/")
- endif()
-endif()
-
-# GCC or Clang specialities
-if("${CMAKE_CXX_COMPILER_ID}" MATCHES "GNU" OR
- "${CMAKE_CXX_COMPILER_ID}" MATCHES "Clang")
- ### General stuff
- if(WIN32)
- set(CMAKE_SHARED_LIBRARY_PREFIX "") # DLLs do not have a "lib" prefix
- set(CMAKE_IMPORT_LIBRARY_PREFIX "") # same for DLL import libs
- set(CMAKE_LINK_DEF_FILE_FLAG "") # CMake workaround (2.8.3)
- endif()
-
- ### Project stuff
- if(NOT CMAKE_CONFIGURATION_TYPES AND NOT CMAKE_BUILD_TYPE)
- set(CMAKE_BUILD_TYPE Release)
- endif()
- #
- set(CMAKE_CXX_FLAGS_RELEASE "-O2")
- set(CMAKE_CXX_FLAGS_RELWITHDEBINFO "-O2 -g")
- set(CMAKE_CXX_FLAGS_DEBUG "-g")
- set(CMAKE_CXX_FLAGS_MINSIZEREL "-Os")
- #
- set(GCC_EXTRA_OPTIONS "")
- #
- set(FLAG_TESTED "-Wextra")
- check_cxx_compiler_flag(${FLAG_TESTED} FLAG_WEXTRA)
- if(FLAG_WEXTRA)
- set(GCC_EXTRA_OPTIONS "${GCC_EXTRA_OPTIONS} ${FLAG_TESTED}")
- endif()
- #
- set(yaml_cxx_flags "-Wall ${GCC_EXTRA_OPTIONS} -pedantic -Wno-long-long ${yaml_cxx_flags}")
-
- ### Make specific
- if(${CMAKE_BUILD_TOOL} MATCHES make OR ${CMAKE_BUILD_TOOL} MATCHES gmake)
- add_custom_target(debuggable $(MAKE) clean
- COMMAND ${CMAKE_COMMAND} -DCMAKE_BUILD_TYPE=Debug ${CMAKE_SOURCE_DIR}
- COMMENT "Adjusting settings for debug compilation"
- VERBATIM)
- add_custom_target(releasable $(MAKE) clean
- COMMAND ${CMAKE_COMMAND} -DCMAKE_BUILD_TYPE=Release ${CMAKE_SOURCE_DIR}
- COMMENT "Adjusting settings for release compilation"
- VERBATIM)
- endif()
-endif()
-
-# Microsoft VisualC++ specialities
-if(MSVC)
- ### General stuff
- # a) Change MSVC runtime library settings (/MD[d], /MT[d], /ML[d] (single-threaded until VS 2003))
- # plus set lib suffix for later use and project label accordingly
- # see http://msdn.microsoft.com/en-us/library/aa278396(v=VS.60).aspx
- # http://msdn.microsoft.com/en-us/library/2kzt1wy3(v=VS.71).aspx
- set(LIB_RT_SUFFIX "md") # CMake defaults to /MD for MSVC
- set(LIB_RT_OPTION "/MD")
- #
- if(NOT MSVC_SHARED_RT) # User wants to have static runtime libraries (/MT, /ML)
- if(MSVC_STHREADED_RT) # User wants to have old single-threaded static runtime libraries
- set(LIB_RT_SUFFIX "ml")
- set(LIB_RT_OPTION "/ML")
- if(NOT ${MSVC_VERSION} LESS 1400)
- message(FATAL_ERROR "Single-threaded static runtime libraries (/ML) only available until VS .NET 2003 (7.1).")
- endif()
- else()
- set(LIB_RT_SUFFIX "mt")
- set(LIB_RT_OPTION "/MT")
- endif()
-
- # correct linker options
- foreach(flag_var yaml_c_flags yaml_cxx_flags)
- foreach(config_name "" DEBUG RELEASE MINSIZEREL RELWITHDEBINFO)
- set(var_name "${flag_var}")
- if(NOT "${config_name}" STREQUAL "")
- set(var_name "${var_name}_${config_name}")
- endif()
- string(REPLACE "/MD" "${LIB_RT_OPTION}" ${var_name} "${${var_name}}")
- endforeach()
- endforeach()
- endif()
- #
- set(LABEL_SUFFIX "${LABEL_SUFFIX} ${LIB_RT_SUFFIX}")
-
- # b) Change prefix for static libraries
- set(CMAKE_STATIC_LIBRARY_PREFIX "lib") # to distinguish static libraries from DLL import libs
-
- # c) Correct suffixes for static libraries
- if(NOT BUILD_SHARED_LIBS)
- ### General stuff
- set(LIB_TARGET_SUFFIX "${LIB_SUFFIX}${LIB_RT_SUFFIX}")
- endif()
-
- ### Project stuff
- # /W3 = set warning level; see http://msdn.microsoft.com/en-us/library/thxezb7y.aspx
- # /wd4127 = disable warning C4127 "conditional expression is constant"; see http://msdn.microsoft.com/en-us/library/6t66728h.aspx
- # /wd4355 = disable warning C4355 "'this' : used in base member initializer list"; http://msdn.microsoft.com/en-us/library/3c594ae3.aspx
- set(yaml_cxx_flags "/W3 /wd4127 /wd4355 ${yaml_cxx_flags}")
-endif()
-
-
-###
-### General install settings
-###
-if(WIN32)
- set(_library_dir bin) # .dll are in PATH, like executables
-else()
- set(_library_dir lib)
-endif()
-
-set(INCLUDE_INSTALL_ROOT_DIR include)
-
-set(INCLUDE_INSTALL_DIR ${INCLUDE_INSTALL_ROOT_DIR}/yaml-cpp)
-set(LIB_INSTALL_DIR "${_library_dir}${LIB_SUFFIX}")
-
-set(_INSTALL_DESTINATIONS
- RUNTIME DESTINATION bin
- LIBRARY DESTINATION ${LIB_INSTALL_DIR}
- ARCHIVE DESTINATION "lib${LIB_SUFFIX}"
-)
-
-
-###
-### Library
-###
-add_library(yaml-cpp ${library_sources})
-set_target_properties(yaml-cpp PROPERTIES
- COMPILE_FLAGS "${yaml_c_flags} ${yaml_cxx_flags}"
-)
-
-set_target_properties(yaml-cpp PROPERTIES
- VERSION "${YAML_CPP_VERSION}"
- SOVERSION "${YAML_CPP_VERSION_MAJOR}.${YAML_CPP_VERSION_MINOR}"
- PROJECT_LABEL "yaml-cpp ${LABEL_SUFFIX}"
-)
-
-if(IPHONE)
- set_target_properties(yaml-cpp PROPERTIES
- XCODE_ATTRIBUTE_IPHONEOS_DEPLOYMENT_TARGET "3.0"
- )
-endif()
-
-if(MSVC)
- if(NOT BUILD_SHARED_LIBS)
- # correct library names
- set_target_properties(yaml-cpp PROPERTIES
- DEBUG_POSTFIX "${LIB_TARGET_SUFFIX}d"
- RELEASE_POSTFIX "${LIB_TARGET_SUFFIX}"
- MINSIZEREL_POSTFIX "${LIB_TARGET_SUFFIX}"
- RELWITHDEBINFO_POSTFIX "${LIB_TARGET_SUFFIX}"
- )
- endif()
-endif()
-
-install(TARGETS yaml-cpp ${_INSTALL_DESTINATIONS})
-install(
- DIRECTORY ${header_directory}
- DESTINATION ${INCLUDE_INSTALL_DIR}
- FILES_MATCHING PATTERN "*.h"
-)
-
-export(
- TARGETS yaml-cpp
- FILE "${PROJECT_BINARY_DIR}/yaml-cpp-targets.cmake")
-export(PACKAGE yaml-cpp)
-set(EXPORT_TARGETS yaml-cpp CACHE INTERNAL "export targets")
-
-set(CONFIG_INCLUDE_DIRS "${YAML_CPP_SOURCE_DIR}/include")
-configure_file(${CMAKE_CURRENT_SOURCE_DIR}/yaml-cpp-config.cmake.in
- "${PROJECT_BINARY_DIR}/yaml-cpp-config.cmake" @ONLY)
-configure_file(${CMAKE_CURRENT_SOURCE_DIR}/yaml-cpp-config-version.cmake.in
- "${PROJECT_BINARY_DIR}/yaml-cpp-config-version.cmake" @ONLY)
-
-if(UNIX)
- set(PC_FILE ${CMAKE_BINARY_DIR}/yaml-cpp.pc)
- configure_file("yaml-cpp.pc.cmake" ${PC_FILE} @ONLY)
- install(FILES ${PC_FILE} DESTINATION ${LIB_INSTALL_DIR}/pkgconfig)
-endif()
-
-
-###
-### Extras
-###
-if(YAML_CPP_BUILD_TOOLS)
- add_subdirectory(util)
-endif()
-
-### Formatting
-get_property(all_sources GLOBAL PROPERTY SRCS_LIST)
-add_custom_target(format
- COMMAND clang-format --style=file -i ${all_sources}
- COMMENT "Running clang-format"
- VERBATIM)
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/CONTRIBUTING.md
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/CONTRIBUTING.md b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/CONTRIBUTING.md
deleted file mode 100644
index 41f50dc..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/CONTRIBUTING.md
+++ /dev/null
@@ -1,17 +0,0 @@
-# Style
-
-This project is formatted with [clang-format][fmt] using the style file at the root of the repository. Please run clang-format before sending a pull request.
-
-In general, try to follow the style of surrounding code.
-
-[fmt]: http://clang.llvm.org/docs/ClangFormat.html
-
-# Tests
-
-Please verify the tests pass by running the target `tests/run_tests`.
-
-If you are adding functionality, add tests accordingly.
-
-# Pull request process
-
-Every pull request undergoes a code review. Unfortunately, github's code review process isn't great, but we'll manage. During the code review, if you make changes, add new commits to the pull request for each change. Once the code review is complete, rebase against the master branch and squash into a single commit.
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/LICENSE
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/LICENSE b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/LICENSE
deleted file mode 100644
index 991fdbb..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/LICENSE
+++ /dev/null
@@ -1,19 +0,0 @@
-Copyright (c) 2008-2015 Jesse Beder.
-
-Permission is hereby granted, free of charge, to any person obtaining a copy
-of this software and associated documentation files (the "Software"), to deal
-in the Software without restriction, including without limitation the rights
-to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
-copies of the Software, and to permit persons to whom the Software is
-furnished to do so, subject to the following conditions:
-
-The above copyright notice and this permission notice shall be included in
-all copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
-IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
-FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
-AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
-LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
-THE SOFTWARE.
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/README.md
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/README.md b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/README.md
deleted file mode 100644
index 54263ef..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/README.md
+++ /dev/null
@@ -1,52 +0,0 @@
-# yaml-cpp
-
-yaml-cpp is a [YAML](http://www.yaml.org/) parser and emitter in C++ matching the [YAML 1.2 spec](http://www.yaml.org/spec/1.2/spec.html).
-
-To get a feel for how it can be used, see the [Tutorial](https://github.com/jbeder/yaml-cpp/wiki/Tutorial) or [How to Emit YAML](https://github.com/jbeder/yaml-cpp/wiki/How-To-Emit-YAML). For the old API (version < 0.5.0), see [How To Parse A Document](https://github.com/jbeder/yaml-cpp/wiki/How-To-Parse-A-Document-(Old-API)).
-
-
-# Problems? #
-
-If you find a bug, post an [issue](https://github.com/jbeder/yaml-cpp/issues)! If you have questions about how to use yaml-cpp, please post it on http://stackoverflow.com and tag it `yaml-cpp`.
-
-# How to Build #
-
-yaml-cpp uses [CMake](http://www.cmake.org) to support cross-platform building. The basic steps to build are:
-
-1. Download and install [CMake](http://www.cmake.org) (Resources -> Download).
-
-**Note:** If you don't use the provided installer for your platform, make sure that you add CMake's bin folder to your path.
-
-2. Navigate into the source directory, and type:
-
-```
-mkdir build
-cd build
-```
-
-3. Run CMake. The basic syntax is:
-
-```
-cmake [-G generator] [-DBUILD_SHARED_LIBS=ON|OFF] ..
-```
-
- * The `generator` is whatever type of build system you'd like to use. To see a full list of generators on your platform, just run `cmake` (with no arguments). For example:
- * On Windows, you might use "Visual Studio 12 2013" to generate a Visual Studio 2013 solution
- * On OS X, you might use "Xcode" to generate an Xcode project
- * On a UNIX-y system, simply omit the option to generate a makefile
-
- * yaml-cpp defaults to building a static library, but you may build a shared library by specifying `-DBUILD_SHARED_LIBS=ON`.
-
- * For more options on customizing the build, see the [CMakeLists.txt](https://github.com/jbeder/yaml-cpp/blob/master/CMakeLists.txt) file.
-
-4. Build it!
-
-5. To clean up, just remove the `build` directory.
-
-# Recent Release #
-
-[yaml-cpp 0.5.2](https://github.com/jbeder/yaml-cpp/releases/tag/release-0.5.2) has been released! This is a bug fix release.
-
-[yaml-cpp 0.3.0](https://github.com/jbeder/yaml-cpp/releases/tag/release-0.3.0) is still available if you want the old API.
-
-**The old API will continue to be supported, and will still receive bugfixes!** The 0.3.x and 0.4.x versions will be old API releases, and 0.5.x and above will all be new API releases.
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/anchor.h
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/anchor.h b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/anchor.h
deleted file mode 100644
index 06759c7..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/anchor.h
+++ /dev/null
@@ -1,17 +0,0 @@
-#ifndef ANCHOR_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-#define ANCHOR_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-
-#if defined(_MSC_VER) || \
- (defined(__GNUC__) && (__GNUC__ == 3 && __GNUC_MINOR__ >= 4) || \
- (__GNUC__ >= 4)) // GCC supports "pragma once" correctly since 3.4
-#pragma once
-#endif
-
-#include <cstddef>
-
-namespace YAML {
-typedef std::size_t anchor_t;
-const anchor_t NullAnchor = 0;
-}
-
-#endif // ANCHOR_H_62B23520_7C8E_11DE_8A39_0800200C9A66
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/binary.h
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/binary.h b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/binary.h
deleted file mode 100644
index 29d5dbd..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/binary.h
+++ /dev/null
@@ -1,67 +0,0 @@
-#ifndef BASE64_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-#define BASE64_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-
-#if defined(_MSC_VER) || \
- (defined(__GNUC__) && (__GNUC__ == 3 && __GNUC_MINOR__ >= 4) || \
- (__GNUC__ >= 4)) // GCC supports "pragma once" correctly since 3.4
-#pragma once
-#endif
-
-#include <string>
-#include <vector>
-
-#include "yaml-cpp/dll.h"
-
-namespace YAML {
-YAML_CPP_API std::string EncodeBase64(const unsigned char *data,
- std::size_t size);
-YAML_CPP_API std::vector<unsigned char> DecodeBase64(const std::string &input);
-
-class YAML_CPP_API Binary {
- public:
- Binary() : m_unownedData(0), m_unownedSize(0) {}
- Binary(const unsigned char *data_, std::size_t size_)
- : m_unownedData(data_), m_unownedSize(size_) {}
-
- bool owned() const { return !m_unownedData; }
- std::size_t size() const { return owned() ? m_data.size() : m_unownedSize; }
- const unsigned char *data() const {
- return owned() ? &m_data[0] : m_unownedData;
- }
-
- void swap(std::vector<unsigned char> &rhs) {
- if (m_unownedData) {
- m_data.swap(rhs);
- rhs.clear();
- rhs.resize(m_unownedSize);
- std::copy(m_unownedData, m_unownedData + m_unownedSize, rhs.begin());
- m_unownedData = 0;
- m_unownedSize = 0;
- } else {
- m_data.swap(rhs);
- }
- }
-
- bool operator==(const Binary &rhs) const {
- const std::size_t s = size();
- if (s != rhs.size())
- return false;
- const unsigned char *d1 = data();
- const unsigned char *d2 = rhs.data();
- for (std::size_t i = 0; i < s; i++) {
- if (*d1++ != *d2++)
- return false;
- }
- return true;
- }
-
- bool operator!=(const Binary &rhs) const { return !(*this == rhs); }
-
- private:
- std::vector<unsigned char> m_data;
- const unsigned char *m_unownedData;
- std::size_t m_unownedSize;
-};
-}
-
-#endif // BASE64_H_62B23520_7C8E_11DE_8A39_0800200C9A66
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/contrib/anchordict.h
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/contrib/anchordict.h b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/contrib/anchordict.h
deleted file mode 100644
index b4677e2..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/contrib/anchordict.h
+++ /dev/null
@@ -1,37 +0,0 @@
-#ifndef ANCHORDICT_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-#define ANCHORDICT_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-
-#if defined(_MSC_VER) || \
- (defined(__GNUC__) && (__GNUC__ == 3 && __GNUC_MINOR__ >= 4) || \
- (__GNUC__ >= 4)) // GCC supports "pragma once" correctly since 3.4
-#pragma once
-#endif
-
-#include <vector>
-
-#include "../anchor.h"
-
-namespace YAML {
-/// AnchorDict
-/// . An object that stores and retrieves values correlating to anchor_t
-/// values.
-/// . Efficient implementation that can make assumptions about how anchor_t
-/// values are assigned by the Parser class.
-template <class T>
-class AnchorDict {
- public:
- void Register(anchor_t anchor, T value) {
- if (anchor > m_data.size()) {
- m_data.resize(anchor);
- }
- m_data[anchor - 1] = value;
- }
-
- T Get(anchor_t anchor) const { return m_data[anchor - 1]; }
-
- private:
- std::vector<T> m_data;
-};
-}
-
-#endif // ANCHORDICT_H_62B23520_7C8E_11DE_8A39_0800200C9A66
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/contrib/graphbuilder.h
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/contrib/graphbuilder.h b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/contrib/graphbuilder.h
deleted file mode 100644
index 7c2159b..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/contrib/graphbuilder.h
+++ /dev/null
@@ -1,147 +0,0 @@
-#ifndef GRAPHBUILDER_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-#define GRAPHBUILDER_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-
-#if defined(_MSC_VER) || \
- (defined(__GNUC__) && (__GNUC__ == 3 && __GNUC_MINOR__ >= 4) || \
- (__GNUC__ >= 4)) // GCC supports "pragma once" correctly since 3.4
-#pragma once
-#endif
-
-#include "yaml-cpp/mark.h"
-#include <string>
-
-namespace YAML {
-class Parser;
-
-// GraphBuilderInterface
-// . Abstraction of node creation
-// . pParentNode is always NULL or the return value of one of the NewXXX()
-// functions.
-class GraphBuilderInterface {
- public:
- // Create and return a new node with a null value.
- virtual void *NewNull(const Mark &mark, void *pParentNode) = 0;
-
- // Create and return a new node with the given tag and value.
- virtual void *NewScalar(const Mark &mark, const std::string &tag,
- void *pParentNode, const std::string &value) = 0;
-
- // Create and return a new sequence node
- virtual void *NewSequence(const Mark &mark, const std::string &tag,
- void *pParentNode) = 0;
-
- // Add pNode to pSequence. pNode was created with one of the NewXxx()
- // functions and pSequence with NewSequence().
- virtual void AppendToSequence(void *pSequence, void *pNode) = 0;
-
- // Note that no moew entries will be added to pSequence
- virtual void SequenceComplete(void *pSequence) { (void)pSequence; }
-
- // Create and return a new map node
- virtual void *NewMap(const Mark &mark, const std::string &tag,
- void *pParentNode) = 0;
-
- // Add the pKeyNode => pValueNode mapping to pMap. pKeyNode and pValueNode
- // were created with one of the NewXxx() methods and pMap with NewMap().
- virtual void AssignInMap(void *pMap, void *pKeyNode, void *pValueNode) = 0;
-
- // Note that no more assignments will be made in pMap
- virtual void MapComplete(void *pMap) { (void)pMap; }
-
- // Return the node that should be used in place of an alias referencing
- // pNode (pNode by default)
- virtual void *AnchorReference(const Mark &mark, void *pNode) {
- (void)mark;
- return pNode;
- }
-};
-
-// Typesafe wrapper for GraphBuilderInterface. Assumes that Impl defines
-// Node, Sequence, and Map types. Sequence and Map must derive from Node
-// (unless Node is defined as void). Impl must also implement function with
-// all of the same names as the virtual functions in GraphBuilderInterface
-// -- including the ones with default implementations -- but with the
-// prototypes changed to accept an explicit Node*, Sequence*, or Map* where
-// appropriate.
-template <class Impl>
-class GraphBuilder : public GraphBuilderInterface {
- public:
- typedef typename Impl::Node Node;
- typedef typename Impl::Sequence Sequence;
- typedef typename Impl::Map Map;
-
- GraphBuilder(Impl &impl) : m_impl(impl) {
- Map *pMap = NULL;
- Sequence *pSeq = NULL;
- Node *pNode = NULL;
-
- // Type consistency checks
- pNode = pMap;
- pNode = pSeq;
- }
-
- GraphBuilderInterface &AsBuilderInterface() { return *this; }
-
- virtual void *NewNull(const Mark &mark, void *pParentNode) {
- return CheckType<Node>(m_impl.NewNull(mark, AsNode(pParentNode)));
- }
-
- virtual void *NewScalar(const Mark &mark, const std::string &tag,
- void *pParentNode, const std::string &value) {
- return CheckType<Node>(
- m_impl.NewScalar(mark, tag, AsNode(pParentNode), value));
- }
-
- virtual void *NewSequence(const Mark &mark, const std::string &tag,
- void *pParentNode) {
- return CheckType<Sequence>(
- m_impl.NewSequence(mark, tag, AsNode(pParentNode)));
- }
- virtual void AppendToSequence(void *pSequence, void *pNode) {
- m_impl.AppendToSequence(AsSequence(pSequence), AsNode(pNode));
- }
- virtual void SequenceComplete(void *pSequence) {
- m_impl.SequenceComplete(AsSequence(pSequence));
- }
-
- virtual void *NewMap(const Mark &mark, const std::string &tag,
- void *pParentNode) {
- return CheckType<Map>(m_impl.NewMap(mark, tag, AsNode(pParentNode)));
- }
- virtual void AssignInMap(void *pMap, void *pKeyNode, void *pValueNode) {
- m_impl.AssignInMap(AsMap(pMap), AsNode(pKeyNode), AsNode(pValueNode));
- }
- virtual void MapComplete(void *pMap) { m_impl.MapComplete(AsMap(pMap)); }
-
- virtual void *AnchorReference(const Mark &mark, void *pNode) {
- return CheckType<Node>(m_impl.AnchorReference(mark, AsNode(pNode)));
- }
-
- private:
- Impl &m_impl;
-
- // Static check for pointer to T
- template <class T, class U>
- static T *CheckType(U *p) {
- return p;
- }
-
- static Node *AsNode(void *pNode) { return static_cast<Node *>(pNode); }
- static Sequence *AsSequence(void *pSeq) {
- return static_cast<Sequence *>(pSeq);
- }
- static Map *AsMap(void *pMap) { return static_cast<Map *>(pMap); }
-};
-
-void *BuildGraphOfNextDocument(Parser &parser,
- GraphBuilderInterface &graphBuilder);
-
-template <class Impl>
-typename Impl::Node *BuildGraphOfNextDocument(Parser &parser, Impl &impl) {
- GraphBuilder<Impl> graphBuilder(impl);
- return static_cast<typename Impl::Node *>(
- BuildGraphOfNextDocument(parser, graphBuilder));
-}
-}
-
-#endif // GRAPHBUILDER_H_62B23520_7C8E_11DE_8A39_0800200C9A66
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1d6b2416/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/dll.h
----------------------------------------------------------------------
diff --git a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/dll.h b/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/dll.h
deleted file mode 100644
index 827e0f1..0000000
--- a/thirdparty/yaml-cpp-yaml-cpp-0.5.3/include/yaml-cpp/dll.h
+++ /dev/null
@@ -1,37 +0,0 @@
-#ifndef DLL_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-#define DLL_H_62B23520_7C8E_11DE_8A39_0800200C9A66
-
-#if defined(_MSC_VER) || \
- (defined(__GNUC__) && (__GNUC__ == 3 && __GNUC_MINOR__ >= 4) || \
- (__GNUC__ >= 4)) // GCC supports "pragma once" correctly since 3.4
-#pragma once
-#endif
-
-// The following ifdef block is the standard way of creating macros which make
-// exporting
-// from a DLL simpler. All files within this DLL are compiled with the
-// yaml_cpp_EXPORTS
-// symbol defined on the command line. this symbol should not be defined on any
-// project
-// that uses this DLL. This way any other project whose source files include
-// this file see
-// YAML_CPP_API functions as being imported from a DLL, whereas this DLL sees
-// symbols
-// defined with this macro as being exported.
-#undef YAML_CPP_API
-
-#ifdef YAML_CPP_DLL // Using or Building YAML-CPP DLL (definition defined
- // manually)
-#ifdef yaml_cpp_EXPORTS // Building YAML-CPP DLL (definition created by CMake
- // or defined manually)
-// #pragma message( "Defining YAML_CPP_API for DLL export" )
-#define YAML_CPP_API __declspec(dllexport)
-#else // yaml_cpp_EXPORTS
-// #pragma message( "Defining YAML_CPP_API for DLL import" )
-#define YAML_CPP_API __declspec(dllimport)
-#endif // yaml_cpp_EXPORTS
-#else // YAML_CPP_DLL
-#define YAML_CPP_API
-#endif // YAML_CPP_DLL
-
-#endif // DLL_H_62B23520_7C8E_11DE_8A39_0800200C9A66