nifi git commit: NIFI-3940 upgraded to latest jruby which resolves an apparent lgpl bunding issue

2017-05-18 Thread alopresto 
Repository: nifi
Updated Branches:
  refs/heads/master 28eadaa68 -> 3b98abbf4


NIFI-3940 upgraded to latest jruby which resolves an apparent lgpl bunding issue

This closes #1827.

Signed-off-by: Andy LoPresto 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/3b98abbf
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/3b98abbf
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/3b98abbf

Branch: refs/heads/master
Commit: 3b98abbf416974a7e94ef4e1ca3fc169bbf66393
Parents: 28eadaa
Author: joewitt 
Authored: Thu May 18 22:57:49 2017 -0400
Committer: Andy LoPresto 
Committed: Thu May 18 21:37:25 2017 -0700

--
 nifi-assembly/NOTICE  |  2 +-
 .../nifi-scripting-nar/src/main/resources/META-INF/NOTICE | 10 ++
 .../nifi-scripting-processors/pom.xml |  6 +++---
 3 files changed, 6 insertions(+), 12 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/3b98abbf/nifi-assembly/NOTICE
--
diff --git a/nifi-assembly/NOTICE b/nifi-assembly/NOTICE
index bd7ccc2..0873c21 100644
--- a/nifi-assembly/NOTICE
+++ b/nifi-assembly/NOTICE
@@ -1348,7 +1348,7 @@ The following binary components are provided under the 
Eclipse Public License 1.
 (EPL 1.0)(MPL 2.0) H2 Database (com.h2database:h2:jar:1.3.176 - 
http://www.h2database.com/html/license.html)
 (EPL 1.0)(LGPL 2.1) Logback Classic 
(ch.qos.logback:logback-classic:jar:1.2.3 - http://logback.qos.ch/)
 (EPL 1.0)(LGPL 2.1) Logback Core (ch.qos.logback:logback-core:jar:1.2.3 - 
http://logback.qos.ch/)
-(EPLv1.0)(GPL 2)(LGPL 2.1) JRuby (org.jruby:jruby-complete:9.0.4.0 - 
http://jruby.org).
+(EPLv1.0)(GPL 2)(LGPL 2.1) JRuby (org.jruby:jruby-complete:9.1.9.0 - 
http://jruby.org).
 (EPL 1.0) Eclipse Paho MQTT Client 
(org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.0.2 - 
https://github.com/eclipse/paho.mqtt.java)
 (EPL 1.0) Eclipse Link (org.eclipse.persistence:eclipselink:2.5.2 - 
http://www.eclipse.org/eclipselink/)
 (EPL 1.0) Common Service Data Objects 
(org.eclipse.persistence:commonj.sdo:2.1.1 - 
http://www.eclipse.org/eclipselink/)

http://git-wip-us.apache.org/repos/asf/nifi/blob/3b98abbf/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-nar/src/main/resources/META-INF/NOTICE
--
diff --git 
a/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-nar/src/main/resources/META-INF/NOTICE
 
b/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-nar/src/main/resources/META-INF/NOTICE
index b0f7909..219b534 100644
--- 
a/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-nar/src/main/resources/META-INF/NOTICE
+++ 
b/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-nar/src/main/resources/META-INF/NOTICE
@@ -53,11 +53,5 @@ Eclipse Public License v1.0
 
 The following binary components are provided under a EPL v1.0 license
 
-   (EPLv1.0) JRuby (org.jruby:jruby-complete:9.0.4.0 - http://jruby.org).
-
-JRuby is licensed under three licenses - the EPL 1.0, GPL 2 and LGPL 2.1. 
Apache NiFi uses the EPL v1.0 license.
-
-The following NOTICE information applies:
-Copyright (c) 2007-2015 The JRuby project
-
-   (EPLv1.0) Clojure (org.clojure:clojure:1.8.0 - http://clojure.org)
+(EPLv1.0)(GPL 2)(LGPL 2.1) JRuby (org.jruby:jruby-complete:9.1.9.0 - 
http://jruby.org).
+(EPLv1.0) Clojure (org.clojure:clojure:1.8.0 - http://clojure.org)

http://git-wip-us.apache.org/repos/asf/nifi/blob/3b98abbf/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/pom.xml
--
diff --git 
a/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/pom.xml 
b/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/pom.xml
index dbd1de6..6721d8a 100644
--- a/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/pom.xml
+++ b/nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/pom.xml
@@ -51,8 +51,8 @@
 groovy-all
 
 
-org.python
-jython-standalone
+org.scijava
+jython-shaded
 2.7.0
 
 
@@ -63,7 +63,7 @@
 
 org.jruby
 jruby-complete
-9.0.4.0
+9.1.9.0
 
 
 org.clojure

nifi git commit: NIFI-3911 Improve Controller Services and Reporting Task Documentation

2017-05-18 Thread alopresto 
Repository: nifi
Updated Branches:
  refs/heads/master 762293c01 -> 28eadaa68


NIFI-3911 Improve Controller Services and Reporting Task Documentation

This closes #1826.

Signed-off-by: Andy LoPresto 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/28eadaa6
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/28eadaa6
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/28eadaa6

Branch: refs/heads/master
Commit: 28eadaa683b41833987b6d20bd79d03f43d61259
Parents: 762293c
Author: Andrew Lim 
Authored: Thu May 18 19:58:29 2017 -0400
Committer: Andy LoPresto 
Committed: Thu May 18 19:20:39 2017 -0700

--
 .../images/add-controller-service-window.png| Bin 69681 -> 187532 bytes
 .../images/add-reporting-task-window.png| Bin 0 -> 170339 bytes
 .../configure-controller-service-properties.png | Bin 29047 -> 79361 bytes
 .../configure-controller-service-settings.png   | Bin 21781 -> 76193 bytes
 .../configure-reporting-task-properties.png | Bin 14008 -> 97484 bytes
 .../configure-reporting-task-settings.png   | Bin 39031 -> 70202 bytes
 .../images/controller-service-window.png| Bin 8934 -> 0 bytes
 .../images/controller-services-edit-buttons.png | Bin 8934 -> 0 bytes
 .../controller-services-information-buttons.png | Bin 4713 -> 0 bytes
 ...er-services-reporting-tasks-edit-buttons.png | Bin 0 -> 13647 bytes
 ...er-services-reporting-tasks-info-buttons.png | Bin 0 -> 14502 bytes
 .../asciidoc/images/controller-services-tab.png | Bin 46665 -> 95 bytes
 .../images/controller-settings-button.png   | Bin 18164 -> 0 bytes
 .../images/controller-settings-selection.png| Bin 0 -> 134853 bytes
 .../images/enable-controller-service-scope.png  | Bin 0 -> 48063 bytes
 nifi-docs/src/main/asciidoc/images/iconEdit.png | Bin 539 -> 652 bytes
 .../src/main/asciidoc/images/iconStart.png  | Bin 0 -> 483 bytes
 .../process-group-configuration-options.png | Bin 0 -> 185350 bytes
 .../process-group-configuration-window.png  | Bin 0 -> 75251 bytes
 .../process-group-controller-services-scope.png | Bin 0 -> 254911 bytes
 .../images/reporting-tasks-edit-buttons2.png| Bin 9921 -> 0 bytes
 .../asciidoc/images/reporting-tasks-tab.png | Bin 45765 -> 81978 bytes
 .../asciidoc/images/settings-general-tab.png| Bin 17887 -> 23701 bytes
 nifi-docs/src/main/asciidoc/user-guide.adoc | 115 ++-
 24 files changed, 58 insertions(+), 57 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/28eadaa6/nifi-docs/src/main/asciidoc/images/add-controller-service-window.png
--
diff --git 
a/nifi-docs/src/main/asciidoc/images/add-controller-service-window.png 
b/nifi-docs/src/main/asciidoc/images/add-controller-service-window.png
index a87d7e2..012ce72 100644
Binary files 
a/nifi-docs/src/main/asciidoc/images/add-controller-service-window.png and 
b/nifi-docs/src/main/asciidoc/images/add-controller-service-window.png differ

http://git-wip-us.apache.org/repos/asf/nifi/blob/28eadaa6/nifi-docs/src/main/asciidoc/images/add-reporting-task-window.png
--
diff --git a/nifi-docs/src/main/asciidoc/images/add-reporting-task-window.png 
b/nifi-docs/src/main/asciidoc/images/add-reporting-task-window.png
new file mode 100644
index 000..1c350d5
Binary files /dev/null and 
b/nifi-docs/src/main/asciidoc/images/add-reporting-task-window.png differ

http://git-wip-us.apache.org/repos/asf/nifi/blob/28eadaa6/nifi-docs/src/main/asciidoc/images/configure-controller-service-properties.png
--
diff --git 
a/nifi-docs/src/main/asciidoc/images/configure-controller-service-properties.png
 
b/nifi-docs/src/main/asciidoc/images/configure-controller-service-properties.png
index 6d2167a..8a20ff4 100644
Binary files 
a/nifi-docs/src/main/asciidoc/images/configure-controller-service-properties.png
 and 
b/nifi-docs/src/main/asciidoc/images/configure-controller-service-properties.png
 differ

http://git-wip-us.apache.org/repos/asf/nifi/blob/28eadaa6/nifi-docs/src/main/asciidoc/images/configure-controller-service-settings.png
--
diff --git 
a/nifi-docs/src/main/asciidoc/images/configure-controller-service-settings.png 
b/nifi-docs/src/main/asciidoc/images/configure-controller-service-settings.png
index 140272e..7680192 100644
Binary files 
a/nifi-docs/src/main/asciidoc/images/configure-controller-service-settings.png 
and 
b/nifi-docs/src/main/asciidoc/images/configure-controller-service-settings.png 
differ

svn commit: r19745 - /dev/nifi/nifi/nifi-0.7.3/ /release/nifi/0.7.3/

2017-05-18 Thread jskora 
Author: jskora
Date: Fri May 19 00:38:07 2017
New Revision: 19745

Log:
NIFI-3284

Added:
release/nifi/0.7.3/
  - copied from r19744, dev/nifi/nifi/nifi-0.7.3/
Removed:
dev/nifi/nifi/nifi-0.7.3/

svn commit: r19744 - /release/nifi/0.7.3/

2017-05-18 Thread jskora 
Author: jskora
Date: Fri May 19 00:37:11 2017
New Revision: 19744

Log:
Cleanup from deployment errors.


Removed:
release/nifi/0.7.3/

svn commit: r19743 - in /dev/nifi/nifi: ./ nifi-0.7.3/

2017-05-18 Thread jskora 
Author: jskora
Date: Fri May 19 00:32:34 2017
New Revision: 19743

Log:
Stage NIFI-3284

Added:
dev/nifi/nifi/
dev/nifi/nifi/nifi-0.7.3/
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz   (with props)
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.asc
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.md5
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.sha1
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.sha256
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip   (with props)
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip.asc
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip.md5
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip.sha1
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip.sha256
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-source-release.zip   (with props)
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-source-release.zip.asc
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-source-release.zip.md5
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-source-release.zip.sha1
dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-source-release.zip.sha256

Added: dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz
==
Binary file - no diff available.

Propchange: dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz
--
svn:mime-type = application/octet-stream

Added: dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.asc
==
--- dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.asc (added)
+++ dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.asc Fri May 19 00:32:34 2017
@@ -0,0 +1,17 @@
+-BEGIN PGP SIGNATURE-
+Version: GnuPG v2.0.22 (GNU/Linux)
+
+iQIcBAABCgAGBQJZGOUTAAoJEJdl0uDaAbepQKAQAI9NwhnL+6Tr3qB0RJsdoyNz
+ail/bTurUfRBmq1obOw5rKHC3swzKbL9nb67A2siQA/Q2CkRDUOHb/Ulzorpez03
+uRJ8c3JVtNOfGDy3CQRbR22Mh+H7v8C64VPkYoeY/UYQyS/1R3FeLPsX4SrmzqNI
+D/VAwCj8yfW7IZAyW5DLU+LRHcFLlFZCfCouoFmwHoUvGoRaATSndrxYombsxnwV
+XBqjvtPpd24Svl5bo1r1olipacYmk9V9hDYKMohtjgoJ0rHoLOKARaZPiamI2+Of
+7gxfv2bM9DshMlSwsnaKssiv7dp/xYPM0urIeP7OLIDe9+4vr03O7MwYWht1g/OS
+d9XACu9v2SEPcXf80dOfwif+E8jaZNURoMdLWdod5NFADqZiZ8Sdy8BVyV1VXr0J
+nOixiysG0TVMSQ3lpblRtNQIS4OE4AVp0Q9h8juZAXSV8pKiWvVbdYjbuKvN/cse
+vWZkOjJVFhJmU2O9y4VJHUCkQmJoK8wfsQQK5BtYZ4kqEjYlDp6Un/8UgYh7ro89
+Q/MwIcpkOQiGoVLnraxBvgZ6gOf048ILF6CtCd66Vzb6DUdoWPqPHAXVmCQIksvT
+YHbpV8+gT2Pwi7jLfvhH14RW6m3onkj1CJIXajSuwtPLMPrWzKd7b6be2DPL904d
+Sm425R0SafTlEORsM+IN
+=T0RM
+-END PGP SIGNATURE-

Added: dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.md5
==
--- dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.md5 (added)
+++ dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.md5 Fri May 19 00:32:34 2017
@@ -0,0 +1 @@
+0fc3f70e6cec56048cef72da9663e228

Added: dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.sha1
==
--- dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.sha1 (added)
+++ dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.sha1 Fri May 19 00:32:34 2017
@@ -0,0 +1 @@
+2c92dfe42fffd628532d6062036083608ed37b87

Added: dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.sha256
==
--- dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.sha256 (added)
+++ dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.tar.gz.sha256 Fri May 19 00:32:34 
2017
@@ -0,0 +1 @@
+b26e4920dd1e1e411bd62006623c44492c5307149b7b2deef23a8911f96ffdc8

Added: dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip
==
Binary file - no diff available.

Propchange: dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip
--
svn:mime-type = application/octet-stream

Added: dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip.asc
==
--- dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip.asc (added)
+++ dev/nifi/nifi/nifi-0.7.3/nifi-0.7.3-bin.zip.asc Fri May 19 00:32:34 2017
@@ -0,0 +1,17 @@
+-BEGIN PGP SIGNATURE-
+Version: GnuPG v2.0.22 (GNU/Linux)
+
+iQIcBAABCgAGBQJZGOUZAAoJEJdl0uDaAbepZSoQAIV+Ktt6NpYNq1XMJ1kiCidI
+gN5BQFX9dXNV5eYd2lj8F7IsbKtZhbLevq854NSPfB1u2UhiKTDPzpwT7mqluBoV
+DwCCYMOKyApXNIMJEFaHOH/6T+yteIy5Y/VRlnHMhxGOQezJ62HBnqyZj7B/0f2X
+b5EhWv7Fj4rRccg1KyyolrLHtD0rC/yuUuRgmPK05dbDmPXN20aQ0tnydmmS8PKi
+44b3WxBKrDOYV+4VTOOvPBVfschFwqndQr/euEkZCf1mXkL4Sf+CyQ6fbv4JHoG7
+SaiLpisfADaTkY92dcwsPlkECfhOygFLAVpuov441p7tL3oAqGCW5GpGD/MtNfxl
+W+G6z3W2ldDGcx6bHiwRBawXVJqT5LK2wQP2aB26oPsfOSy97QaW5aKb36N57I0F
+gQ8B1/hAdksX2ip+8rVBfzTO6oDACHPb8zl18mcqhajreyD0qWrOit9qxOcN1b8a
+B8D1cXV/EcJv07RNRcZGD/3NPACYe2QVo/N6XB/Sg2thPOOG9I9QI6d4NGmDvSy8
+ZCanVg/J/y/Hz2PI05J2oGQBgW8BmmCFezuNsSNB+5qF+QJyPWtyxOkrHU1ekgct

[jira] [Created] (MINIFI-322) Create MergeContent processor

2017-05-18 Thread Randy Gelhausen (JIRA) 
Randy Gelhausen created MINIFI-322:
--

 Summary: Create MergeContent processor
 Key: MINIFI-322
 URL: https://issues.apache.org/jira/browse/MINIFI-322
 Project: Apache NiFi MiNiFi
  Issue Type: Bug
  Components: C++, Extensions
Reporter: Randy Gelhausen


http://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.MergeContent/index.html

A primary use case for MiNiFi is flow management of high volume data at the 
edge of networks. Today, the S2S protocol provides compression for multiple 
flowfiles but this does not provide sufficient control over prioritization, 
rates, and sizes.

The addition of the MergeContent processor would provide significantly more 
end-user customization of how and when MiNiFi ships data to NiFi and other 
systems.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[nifi-minifi] Git Push Summary

2017-05-18 Thread aldrin 
Repository: nifi-minifi
Updated Tags:  refs/tags/rel/minifi-0.2.0 [created] 33ee88857

[jira] [Resolved] (MINIFI-309) Release MiNiFi (Java) 0.2.0

2017-05-18 Thread Aldrin Piri (JIRA) 

 [ 
https://issues.apache.org/jira/browse/MINIFI-309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aldrin Piri resolved MINIFI-309.

Resolution: Fixed

> Release MiNiFi (Java) 0.2.0
> ---
>
> Key: MINIFI-309
> URL: https://issues.apache.org/jira/browse/MINIFI-309
> Project: Apache NiFi MiNiFi
>  Issue Type: Task
>Reporter: Aldrin Piri
>Assignee: Aldrin Piri
> Fix For: 0.2.0
>
>
> Ticket to track progress and tasks for the release of MiNiFi Java 0.2.0.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[1/2] nifi-minifi git commit: MINIFI-309-RC1 prepare release minifi-0.2.0-RC1

2017-05-18 Thread aldrin 
Repository: nifi-minifi
Updated Branches:
  refs/heads/master 4dc0ce303 -> 78856d673


MINIFI-309-RC1 prepare release minifi-0.2.0-RC1


Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi/commit/1813e87c
Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi/tree/1813e87c
Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi/diff/1813e87c

Branch: refs/heads/master
Commit: 1813e87ccddffcc9ab75d25948c31901faf2f1ab
Parents: 4dc0ce3
Author: Aldrin Piri 
Authored: Mon May 15 11:09:32 2017 -0400
Committer: Aldrin Piri 
Committed: Mon May 15 11:09:32 2017 -0400

--
 minifi-api/pom.xml  |  2 +-
 minifi-assembly/pom.xml |  4 +-
 minifi-bootstrap/pom.xml|  2 +-
 minifi-c2/minifi-c2-api/pom.xml |  2 +-
 minifi-c2/minifi-c2-assembly/pom.xml|  8 ++--
 .../minifi-c2-cache-filesystem/pom.xml  |  2 +-
 minifi-c2/minifi-c2-cache/pom.xml   |  2 +-
 minifi-c2/minifi-c2-docker/pom.xml  |  4 +-
 minifi-c2/minifi-c2-integration-tests/pom.xml   |  5 +--
 minifi-c2/minifi-c2-jetty/pom.xml   |  2 +-
 .../minifi-c2-provider-cache/pom.xml|  2 +-
 .../minifi-c2-provider-delegating/pom.xml   |  2 +-
 .../minifi-c2-provider-nifi-rest/pom.xml|  2 +-
 .../minifi-c2-provider-util/pom.xml |  2 +-
 minifi-c2/minifi-c2-provider/pom.xml|  2 +-
 minifi-c2/minifi-c2-service/pom.xml |  2 +-
 minifi-c2/pom.xml   |  2 +-
 minifi-commons/minifi-commons-schema/pom.xml|  2 +-
 minifi-commons/minifi-utils/pom.xml |  2 +-
 minifi-commons/pom.xml  |  2 +-
 minifi-docker/pom.xml   |  4 +-
 minifi-docs/pom.xml |  2 +-
 minifi-integration-tests/pom.xml|  5 +--
 .../minifi-framework-nar/pom.xml|  2 +-
 .../minifi-framework-core/pom.xml   |  2 +-
 .../minifi-framework/minifi-nar-utils/pom.xml   |  2 +-
 .../minifi-framework/minifi-resources/pom.xml   |  2 +-
 .../minifi-framework/minifi-runtime/pom.xml |  2 +-
 .../minifi-framework/pom.xml|  2 +-
 .../minifi-framework-bundle/pom.xml |  2 +-
 .../minifi-provenance-reporting-nar/pom.xml |  2 +-
 .../minifi-provenance-reporting-bundle/pom.xml  |  2 +-
 .../pom.xml |  2 +-
 .../minifi-provenance-repository-nar/pom.xml|  2 +-
 .../minifi-provenance-repository-bundle/pom.xml |  2 +-
 .../minifi-ssl-context-service-nar/pom.xml  |  2 +-
 minifi-nar-bundles/minifi-standard-nar/pom.xml  |  2 +-
 .../minifi-update-attribute-nar/pom.xml |  2 +-
 minifi-nar-bundles/pom.xml  |  2 +-
 minifi-toolkit/minifi-toolkit-assembly/pom.xml  |  2 +-
 .../minifi-toolkit-configuration/pom.xml|  2 +-
 minifi-toolkit/pom.xml  |  2 +-
 pom.xml | 40 ++--
 43 files changed, 70 insertions(+), 72 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/1813e87c/minifi-api/pom.xml
--
diff --git a/minifi-api/pom.xml b/minifi-api/pom.xml
index e6a8dbf..a6bd1c2 100644
--- a/minifi-api/pom.xml
+++ b/minifi-api/pom.xml
@@ -20,7 +20,7 @@ limitations under the License.
 
 minifi
 org.apache.nifi.minifi
-0.2.0-SNAPSHOT
+0.2.0
 
 minifi-api
 jar

http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/1813e87c/minifi-assembly/pom.xml
--
diff --git a/minifi-assembly/pom.xml b/minifi-assembly/pom.xml
index f28ee89..38ffa7d 100644
--- a/minifi-assembly/pom.xml
+++ b/minifi-assembly/pom.xml
@@ -20,7 +20,7 @@ limitations under the License.
 
 minifi
 org.apache.nifi.minifi
-0.2.0-SNAPSHOT
+0.2.0
 
 minifi-assembly
 pom
@@ -139,7 +139,7 @@ limitations under the License.
 org.apache.nifi.minifi
 minifi-provenance-reporting-nar
 nar
-0.2.0-SNAPSHOT
+0.2.0
 
 
 

http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/1813e87c/minifi-bootstrap/pom.xml
--
diff --git a/minifi-bootstrap/pom.xml b/minifi-bootstrap/pom.xml
index cb57cb2..4ff447b 100644
--- a/minifi-bootstrap/pom.xml
+++ b/minifi-bootstrap/pom.xml
@@ -20,7 +20,7 @@ limitations under the License.
 
 minifi
 org.apache.nifi.minifi
-0.2.0-SNAPSHOT
+0.2.0

svn commit: r19741 - /dev/nifi/nifi-minifi/0.2.0/ /release/nifi/minifi/0.2.0/

2017-05-18 Thread aldrin 
Author: aldrin
Date: Thu May 18 21:34:08 2017
New Revision: 19741

Log:
MINIFI-309 Moving 0.2.0 artifacts to release.

Added:
release/nifi/minifi/0.2.0/
  - copied from r19740, dev/nifi/nifi-minifi/0.2.0/
Removed:
dev/nifi/nifi-minifi/0.2.0/

[jira] [Commented] (MINIFI-37) Native Volatile Content Repository implementation

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-37?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016426#comment-16016426
 ] 

ASF GitHub Bot commented on MINIFI-37:
--

Github user apiri commented on the issue:

https://github.com/apache/nifi-minifi-cpp/pull/98
  
@phrocker Thanks for the heads up.  Will look for that update. 


> Native Volatile Content Repository implementation
> -
>
> Key: MINIFI-37
> URL: https://issues.apache.org/jira/browse/MINIFI-37
> Project: Apache NiFi MiNiFi
>  Issue Type: Task
>  Components: C++, Core Framework
>Reporter: Aldrin Piri
>Assignee: marco polo
>Priority: Minor
>  Labels: native
>
> Given the constrained environments in which MiNiFi could operate, it would be 
> beneficial to provide a content repository that is strictly in memory for 
> those environments where disk storage may be limited or non-existent. 
> This implementation should consider configuration options around its 
> footprint such as number of entries held and/or sheer capacity.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-320) In cases where users run TLSSocket, the context will cause a realloc in multiple threads.

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016425#comment-16016425
 ] 

ASF GitHub Bot commented on MINIFI-320:
---

Github user phrocker commented on a diff in the pull request:

https://github.com/apache/nifi-minifi-cpp/pull/100#discussion_r117346816
  
--- Diff: libminifi/include/utils/ThreadPool.h ---
@@ -189,7 +195,8 @@ class ThreadPool {
 // atomic running boolean
   std::atomic running_;
 // worker queue of worker objects
-  std::queue worker_queue_;
+  //std::queue worker_queue_;
--- End diff --

remove comment


> In cases where users run TLSSocket, the context will cause a realloc in 
> multiple threads. 
> --
>
> Key: MINIFI-320
> URL: https://issues.apache.org/jira/browse/MINIFI-320
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Reporter: marco polo
>Priority: Blocker
> Fix For: cpp-0.3.0
>
>
> An example stacktrace. . We can either move *back* to a singleton of simply 
> move the ssl library initialization to a better place. 
> #0 0x10122d520 in wrap_realloc 
> (libclang_rt.asan_osx_dynamic.dylib:x86_64h+0x56520)
> #1 0x100fe80ae in CRYPTO_realloc (libcrypto.1.0.0.dylib:x86_64+0x20ae)
> #2 0x10109880c in lh_insert (libcrypto.1.0.0.dylib:x86_64+0xb280c)
> #3 0x100fea6e7 in OBJ_NAME_add (libcrypto.1.0.0.dylib:x86_64+0x46e7)
> #4 0x1010a5b41 in OpenSSL_add_all_ciphers 
> (libcrypto.1.0.0.dylib:x86_64+0xbfb41)
> #5 0x1010a58d1 in OPENSSL_add_all_algorithms_noconf 
> (libcrypto.1.0.0.dylib:x86_64+0xbf8d1)
> #6 0x10012ad40 in org::apache::nifi::minifi::io::TLSContext::initialize() 
> TLSSocket.cpp:60
> #7 0x100132255 in org::apache::nifi::minifi::io::TLSSocket::initialize() 
> TLSSocket.cpp:166
> #8 0x100677a68 in org::apache::nifi::minifi::Site2SitePeer::Open() 
> Site2SitePeer.cpp:42
> #9 0x100631543 in 
> org::apache::nifi::minifi::Site2SiteClientProtocol::establish() 
> Site2SiteClientProtocol.cpp:46
> #10 0x10063e9ff in 
> org::apache::nifi::minifi::Site2SiteClientProtocol::bootstrap() 
> Site2SiteClientProtocol.cpp:483
> #11 0x100600880 in 
> org::apache::nifi::minifi::RemoteProcessorGroupPort::onTrigger(org::apache::nifi::minifi::core::ProcessContext*,
>  org::apache::nifi::minifi::core::ProcessSession*) 
> RemoteProcessorGroupPort.cpp:148
> #12 0x1002c1a3a in 
> org::apache::nifi::minifi::core::Processor::onTrigger(org::apache::nifi::minifi::core::ProcessContext*,
>  org::apache::nifi::minifi::core::ProcessSessionFactory*) Processor.cpp:235
> #13 0x10062cc20 in 
> org::apache::nifi::minifi::SchedulingAgent::onTrigger(std::__1::shared_ptr,
>  org::apache::nifi::minifi::core::ProcessContext*, 
> org::apache::nifi::minifi::core::ProcessSessionFactory*) 
> SchedulingAgent.cpp:66
> #14 0x10069b933 in 
> org::apache::nifi::minifi::TimerDrivenSchedulingAgent::run(std::__1::shared_ptr,
>  org::apache::nifi::minifi::core::ProcessContext*, 
> org::apache::nifi::minifi::core::ProcessSessionFactory*) 
> TimerDrivenSchedulingAgent.cpp:37
> #15 0x100690205 in 
> org::apache::nifi::minifi::ThreadedSchedulingAgent::schedule(std::__1::shared_ptr)::$_0::operator()()
>  const ThreadedSchedulingAgent.cpp:97
> #16 0x10068f37d in void* 
> std::__1::__thread_proxy
>  >(void*) __functional_base:416
> #17 0x7fffb45cf9ae in _pthread_body 
> (libsystem_pthread.dylib:x86_64+0x39ae)
> #18 0x7fffb45cf8fa in _pthread_start 
> (libsystem_pthread.dylib:x86_64+0x38fa)
> #19 0x7fffb45cf100 in thread_start (libsystem_pthread.dylib:x86_64+0x3100)



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-320) In cases where users run TLSSocket, the context will cause a realloc in multiple threads.

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016424#comment-16016424
 ] 

ASF GitHub Bot commented on MINIFI-320:
---

Github user phrocker commented on a diff in the pull request:

https://github.com/apache/nifi-minifi-cpp/pull/100#discussion_r117346914
  
--- Diff: libminifi/test/unit/SocketTests.cpp ---
@@ -183,3 +196,42 @@ TEST_CASE("TestSocketWriteTestAfterClose", 
"[TestSocket6]") {
   server.closeStream();
 
 }
+
+std::atomic counter;
+std::mt19937_64 seed { std::random_device { }() };
+bool createSocket() {
+  int mine = counter++;
+  std::shared_ptr configuration = std::make_shared<
+  minifi::Configure>();
+
+  std::uniform_int_distribution<> distribution { 10, 100 };
+  std::this_thread::sleep_for(std::chrono::milliseconds { 
distribution(seed) });
+
+  for (int i = 0; i < 50; i++) {
+std::shared_ptr socketA = std::make_shared(
+configuration);
+socketA->initialize();
+  }
+
+  return true;
+}
--- End diff --

add some comments to why this exists. 


> In cases where users run TLSSocket, the context will cause a realloc in 
> multiple threads. 
> --
>
> Key: MINIFI-320
> URL: https://issues.apache.org/jira/browse/MINIFI-320
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Reporter: marco polo
>Priority: Blocker
> Fix For: cpp-0.3.0
>
>
> An example stacktrace. . We can either move *back* to a singleton of simply 
> move the ssl library initialization to a better place. 
> #0 0x10122d520 in wrap_realloc 
> (libclang_rt.asan_osx_dynamic.dylib:x86_64h+0x56520)
> #1 0x100fe80ae in CRYPTO_realloc (libcrypto.1.0.0.dylib:x86_64+0x20ae)
> #2 0x10109880c in lh_insert (libcrypto.1.0.0.dylib:x86_64+0xb280c)
> #3 0x100fea6e7 in OBJ_NAME_add (libcrypto.1.0.0.dylib:x86_64+0x46e7)
> #4 0x1010a5b41 in OpenSSL_add_all_ciphers 
> (libcrypto.1.0.0.dylib:x86_64+0xbfb41)
> #5 0x1010a58d1 in OPENSSL_add_all_algorithms_noconf 
> (libcrypto.1.0.0.dylib:x86_64+0xbf8d1)
> #6 0x10012ad40 in org::apache::nifi::minifi::io::TLSContext::initialize() 
> TLSSocket.cpp:60
> #7 0x100132255 in org::apache::nifi::minifi::io::TLSSocket::initialize() 
> TLSSocket.cpp:166
> #8 0x100677a68 in org::apache::nifi::minifi::Site2SitePeer::Open() 
> Site2SitePeer.cpp:42
> #9 0x100631543 in 
> org::apache::nifi::minifi::Site2SiteClientProtocol::establish() 
> Site2SiteClientProtocol.cpp:46
> #10 0x10063e9ff in 
> org::apache::nifi::minifi::Site2SiteClientProtocol::bootstrap() 
> Site2SiteClientProtocol.cpp:483
> #11 0x100600880 in 
> org::apache::nifi::minifi::RemoteProcessorGroupPort::onTrigger(org::apache::nifi::minifi::core::ProcessContext*,
>  org::apache::nifi::minifi::core::ProcessSession*) 
> RemoteProcessorGroupPort.cpp:148
> #12 0x1002c1a3a in 
> org::apache::nifi::minifi::core::Processor::onTrigger(org::apache::nifi::minifi::core::ProcessContext*,
>  org::apache::nifi::minifi::core::ProcessSessionFactory*) Processor.cpp:235
> #13 0x10062cc20 in 
> org::apache::nifi::minifi::SchedulingAgent::onTrigger(std::__1::shared_ptr,
>  org::apache::nifi::minifi::core::ProcessContext*, 
> org::apache::nifi::minifi::core::ProcessSessionFactory*) 
> SchedulingAgent.cpp:66
> #14 0x10069b933 in 
> org::apache::nifi::minifi::TimerDrivenSchedulingAgent::run(std::__1::shared_ptr,
>  org::apache::nifi::minifi::core::ProcessContext*, 
> org::apache::nifi::minifi::core::ProcessSessionFactory*) 
> TimerDrivenSchedulingAgent.cpp:37
> #15 0x100690205 in 
> org::apache::nifi::minifi::ThreadedSchedulingAgent::schedule(std::__1::shared_ptr)::$_0::operator()()
>  const ThreadedSchedulingAgent.cpp:97
> #16 0x10068f37d in void* 
> std::__1::__thread_proxy
>  >(void*) __functional_base:416
> #17 0x7fffb45cf9ae in _pthread_body 
> (libsystem_pthread.dylib:x86_64+0x39ae)
> #18 0x7fffb45cf8fa in _pthread_start 
> (libsystem_pthread.dylib:x86_64+0x38fa)
> #19 0x7fffb45cf100 in thread_start (libsystem_pthread.dylib:x86_64+0x3100)



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-37) Native Volatile Content Repository implementation

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-37?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016423#comment-16016423
 ] 

ASF GitHub Bot commented on MINIFI-37:
--

Github user phrocker commented on the issue:

https://github.com/apache/nifi-minifi-cpp/pull/98
  
@apiri after addressing your comments, above, I ran tests which made me 
rethink part of how this was tested. To cover my bases I'm going to test a 
little more and comment when it's ready again. 


> Native Volatile Content Repository implementation
> -
>
> Key: MINIFI-37
> URL: https://issues.apache.org/jira/browse/MINIFI-37
> Project: Apache NiFi MiNiFi
>  Issue Type: Task
>  Components: C++, Core Framework
>Reporter: Aldrin Piri
>Assignee: marco polo
>Priority: Minor
>  Labels: native
>
> Given the constrained environments in which MiNiFi could operate, it would be 
> beneficial to provide a content repository that is strictly in memory for 
> those environments where disk storage may be limited or non-existent. 
> This implementation should consider configuration options around its 
> footprint such as number of entries held and/or sheer capacity.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

svn commit: r19733 - /release/nifi/0.7.3/

2017-05-18 Thread jskora 
Author: jskora
Date: Thu May 18 19:03:42 2017
New Revision: 19733

Log:
NIFI-3824 - create directory


Added:
release/nifi/0.7.3/

[jira] [Commented] (MINIFI-37) Native Volatile Content Repository implementation

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-37?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016254#comment-16016254
 ] 

ASF GitHub Bot commented on MINIFI-37:
--

Github user apiri commented on a diff in the pull request:

https://github.com/apache/nifi-minifi-cpp/pull/98#discussion_r117326088
  
--- Diff: README.md ---
@@ -299,7 +299,19 @@ Additionally, users can utilize the MiNiFi Toolkit 
Converter (version 0.0.1 - sc
 
 if you do not want to enable client certificate base authorization
 nifi.security.need.ClientAuth=false
-
+
+### Configuring Volatile and NO-OP Repositories
+
+ in minifi.properties 
+ 
+ # For Volatile Repositories:
+ nifi.flow.repository.class.name=VolatileRepository
+ nifi.provenance.repository.class.name=VolatileRepository
+ 
+ # For NO-OP Repositories:
+nifi.flow.repository.class.name=NoOpRepository
--- End diff --

That sounds fair.  Happy to leave it be for the time being and we can 
adjust as needed later. 


> Native Volatile Content Repository implementation
> -
>
> Key: MINIFI-37
> URL: https://issues.apache.org/jira/browse/MINIFI-37
> Project: Apache NiFi MiNiFi
>  Issue Type: Task
>  Components: C++, Core Framework
>Reporter: Aldrin Piri
>Assignee: marco polo
>Priority: Minor
>  Labels: native
>
> Given the constrained environments in which MiNiFi could operate, it would be 
> beneficial to provide a content repository that is strictly in memory for 
> those environments where disk storage may be limited or non-existent. 
> This implementation should consider configuration options around its 
> footprint such as number of entries held and/or sheer capacity.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

svn commit: r19732 - /dev/nifi/KEYS

2017-05-18 Thread jskora 
Author: jskora
Date: Thu May 18 18:49:33 2017
New Revision: 19732

Log:
Added remove trailing newline to match source code repo.

Modified:
dev/nifi/KEYS

Modified: dev/nifi/KEYS
==
--- dev/nifi/KEYS (original)
+++ dev/nifi/KEYS Thu May 18 18:49:33 2017
@@ -1030,4 +1030,3 @@ MPAgOzZv7oS6t6ozbUPrHS7QHkQPEyCKBaGkhYXT
 1/p1MJwDY8kXnVOVaIik15rUPA==
 =4ktw
 -END PGP PUBLIC KEY BLOCK-
-

svn commit: r19731 - /release/nifi/KEYS

2017-05-18 Thread jskora 
Author: jskora
Date: Thu May 18 18:49:20 2017
New Revision: 19731

Log:
Added remove trailing newline to match source code repo.

Modified:
release/nifi/KEYS

Modified: release/nifi/KEYS
==
--- release/nifi/KEYS (original)
+++ release/nifi/KEYS Thu May 18 18:49:20 2017
@@ -1030,4 +1030,3 @@ MPAgOzZv7oS6t6ozbUPrHS7QHkQPEyCKBaGkhYXT
 1/p1MJwDY8kXnVOVaIik15rUPA==
 =4ktw
 -END PGP PUBLIC KEY BLOCK-
-

[jira] [Created] (MINIFI-321) Stub out properties with their defaults to minifi.properties

2017-05-18 Thread Aldrin Piri (JIRA) 
Aldrin Piri created MINIFI-321:
--

 Summary: Stub out properties with their defaults to 
minifi.properties
 Key: MINIFI-321
 URL: https://issues.apache.org/jira/browse/MINIFI-321
 Project: Apache NiFi MiNiFi
  Issue Type: Bug
  Components: Agent Configuration/Installation, C++
Reporter: Aldrin Piri


MINIFI-37 provided some additional implementations for repositories.  It would 
be helpful to have these stubbed out in minifi.properites with their defaults 
as well as similar other properties that a user may wish to change.  For 
properties not yet exposed we should do so and provide the relevant updates.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

nifi git commit: NIFI-3935 made the old persistent prov test more forgiving of timing issues and extended lucene test timeouts for slower environments. These should be integration tests really.

2017-05-18 Thread mattyb149 
Repository: nifi
Updated Branches:
  refs/heads/master be67f3552 -> 762293c01


NIFI-3935 made the old persistent prov test more forgiving of timing issues and 
extended lucene test timeouts for slower environments.  These should be 
integration tests really.

Signed-off-by: Matt Burgess 

This closes #1823


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/762293c0
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/762293c0
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/762293c0

Branch: refs/heads/master
Commit: 762293c01cc9b843abd5378f5de51f626050f498
Parents: be67f35
Author: joewitt 
Authored: Thu May 18 11:43:46 2017 -0400
Committer: Matt Burgess 
Committed: Thu May 18 14:42:46 2017 -0400

--
 .../TestPersistentProvenanceRepository.java |  5 +-
 .../index/lucene/TestLuceneEventIndex.java  | 98 ++--
 2 files changed, 50 insertions(+), 53 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/762293c0/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java
--
diff --git 
a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java
 
b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java
index 04a8c6d..5eeb7de 100644
--- 
a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java
+++ 
b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java
@@ -393,8 +393,9 @@ public class TestPersistentProvenanceRepository {
 repo.initialize(getEventReporter(), null, null, 
IdentifierLookup.EMPTY);
 final List recoveredRecords = 
repo.getEvents(0L, 12);
 
-assertEquals(10, recoveredRecords.size());
-for (int i = 0; i < 10; i++) {
+//just test however many were actually recovered since it is timing 
sensitive
+final int numRecovered = recoveredRecords.size();
+for (int i = 0; i < numRecovered; i++) {
 final ProvenanceEventRecord recovered = recoveredRecords.get(i);
 assertEquals(i, recovered.getEventId());
 assertEquals("nifi://unit-test", recovered.getTransitUri());

http://git-wip-us.apache.org/repos/asf/nifi/blob/762293c0/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/index/lucene/TestLuceneEventIndex.java
--
diff --git 
a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/index/lucene/TestLuceneEventIndex.java
 
b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/index/lucene/TestLuceneEventIndex.java
index 8cbfa6f..3079b87 100644
--- 
a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/index/lucene/TestLuceneEventIndex.java
+++ 
b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/index/lucene/TestLuceneEventIndex.java
@@ -14,7 +14,6 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
 package org.apache.nifi.provenance.index.lucene;
 
 import static org.junit.Assert.assertEquals;
@@ -82,7 +81,7 @@ public class TestLuceneEventIndex {
 return 
System.getProperty("os.name").toLowerCase().startsWith("windows");
 }
 
-@Test(timeout = 5000)
+@Test(timeout = 6)
 public void testGetMinimumIdToReindex() throws InterruptedException {
 assumeFalse(isWindowsEnvironment());
 final RepositoryConfiguration repoConfig = createConfig(1);
@@ -107,7 +106,7 @@ public class TestLuceneEventIndex {
 assertTrue(id >= 3L);
 }
 
-@Test(timeout = 5000)
+@Test(timeout = 6)
 public void testUnauthorizedEventsGetPlaceholdersForLineage() throws 
InterruptedException {
 assumeFalse(isWindowsEnvironment());
 final RepositoryConfiguration repoConfig = createConfig(1);
@@ -144,7 +143,7 @@ public class

svn commit: r19730 - /release/nifi/KEYS

2017-05-18 Thread jskora 
Author: jskora
Date: Thu May 18 18:40:35 2017
New Revision: 19730

Log:
Added Mike Moser's GPG Code Signing key.

Modified:
release/nifi/KEYS

Modified: release/nifi/KEYS
==
--- release/nifi/KEYS (original)
+++ release/nifi/KEYS Thu May 18 18:40:35 2017
@@ -971,3 +971,63 @@ rIweBoDK7maio9YZPLHo1EvnzPfCC53e/u/BSmla
 P7qGxBxqZV2gSuQbbUUx
 =JS1c
 -END PGP PUBLIC KEY BLOCK-
+
+pub   4096R/DA01B7A9 2017-05-13
+uid  Michael Moser (CODE SIGNING KEY) 
+sig 3DA01B7A9 2017-05-13  Michael Moser (CODE SIGNING KEY) 

+sub   4096R/E6689021 2017-05-13
+sig  DA01B7A9 2017-05-13  Michael Moser (CODE SIGNING KEY) 

+
+-BEGIN PGP PUBLIC KEY BLOCK-
+Version: GnuPG v2.0.22 (GNU/Linux)
+
+mQINBFkXnMcBEAC+o6+3z9agB/g6cc5pICoWXiceYZzhetWMdCPuzSHiMFJzYHcS
+J4rxFIJjUB6Zrc6NAYw2gGmczYs9MkQ8NymciQtp6/4KtvpkhExLEnaXwEZmrkGH
++Ts3qJtUEz8EIdyfSCY8XgPBMNjhqQpDp2t3Frn3bkKwaSaAsFZE+TX+SMNKQr/t
+OuOS/mHDdZhTJWXfXgx06mQtuPaeXsYrucP6xwa0t/p3jiZZVH8GpvC+5PMIezJc
+O0Jx1V/d3bjZZLglOVpuhXzMyfxDcxTinTQLrH10Vrjionv112ggp6ncgdiqrzZr
+jlY46qjPGQ2+GdOwbqxqI6mPFZU3YBL1LUJNakOq2T6/FdhEybX7ocpg1etIEWap
+YfwlfaGf4rhRbpOg9WfJG1pqcsC+03bvqvzCcCbO95w9ehrNhxTY9F3E5vw8RJLN
+8yRDSJGFRFofkpnzC3QYULGkIGnWMl9u+oHDQtx0JFRFPNi/XJp5jp0H9ET/fVcD
+kLICX97p1SDsElDUYa1AfNNuBrb/vANzf1Bko1hoGCS3mq51RGYckbgbat6cE8po
+xKwV0fCnLUoPxan08m2ni6WkgHnoWPoyYmQmK21k5axb0W+tcWFTkMF/jtA4XNt1
+DhMz3Plo6EHPYFpRHR79NnNPIZXrgwKn+cg2TITDAqIZr+OvCGINxdO7EwARAQAB
+tDVNaWNoYWVsIE1vc2VyIChDT0RFIFNJR05JTkcgS0VZKSA8bW9zZXJtd0BhcGFj
+aGUub3JnPokCNwQTAQoAIQUCWRecxwIbAwULCQgHAwUVCgkICwUWAgMBAAIeAQIX
+gAAKCRCXZdLg2gG3qQamD/0ZhV6/OahAlpCblyILMZq1o/04rS0L5lolSOzGeSdk
+0nUa/ejHecd2iGDvkuaqA48hRwAv9EgZIWQ8qIZtGJ7dOOS3m+QBX+/6z04PLQcz
+isRwtbmJba2zC+OMrpN6sfnU/YysI+d08BSgZ9JAx2WnQztzyyLkkk4/3UOiwTfi
+sE2yWjLWuZHN2U814dbf99YDBLXSo/X/k3QvXZfiPqskZEVsDbAK0nqvf8ScqiUi
+R++v+XM+GaK5bRbAAHrJSK0GLM1RF8vh5DD9576ZSGaAJ6mXWvj4v5KKiec2UFkC
+VLFQpXJuDR2M6hVwMFvlbiEJE9ib08mBcplmDRFxxWvazs3Gj1fA/w+DPVcEZeJd
+1R0ry72VGoLz14qXZOOwu49aASi7Dyjd3h63XsUNsnRxe5iFwicpej/0TNFT3qsX
+P24W7NKhobzun6yR3Az/O/Fp+UCRSwOfZB+IG6arU/zf/JUKMoV5rwhngjRKWGqQ
+5cyvfJNiv+Tfnch2nrHJMskcGJcgYbsUHjyLN0Qh8Am9/i+M4QQXIU2nPsCT3at8
+GE37l+PERHTcF6xQl4S9xh+wY38ERdEvvx50/n5Ha/w6EpCV8+OJWbtC69ygg0TS
+Hz+qkB63aSmz74PHz+GR7OlMZ1MD+ILTLYSK/lgmO+CvvQXtK6jzSKGykx+KrHka
+B7kCDQRZF5zHARAAn2MvP+SMYmcRRJWz+MwyI2lVccQUc65FAEMhE5WCBJtbAim5
+LS/PsLxQKqBYcospXP1+aWbu6WfFXfLesSz6CfEitCZgkHlWoXXymYoongMFA94j
+fgVobXbXwKC8DaMv7hQkkp1oEriyIGWU1w5b1OI9oYFRo7y/wSoo2x8l7ry23rM7
+HgtC7aGCUHjwDS+QLeSLBae0qcU3M3bX57zuFB2GoCpIy10SNc5JFAuyf1Lgv1nb
+axmb1tp0BsrdA1kjsjcMPEYxNo9ctV34pzOG1UT0doyvXQFby9SMCkMQXE+q9JH2
+u5W2dtarEil8MvcKJNUQcegomA26b1jipo2ey3ZEZsn4LY5s4Yfwy20kdqxqx5Xu
+FWn+0iIEahCTsIitbH4JCTwyzxEBO0tGo72PGHUmh7YIIAGwFdJcp4eTs270pLvl
+YZGcSYD/xOCHWr5xdxmsHo7AAlMUceCpuNTOSXZxY1dyTJ+oRUMZj2YUPP3TmKCz
+fI8RM1hcC4CzOEkuABdSnsSDiWfCyGVTNwcz9kbVuRxUBD8rayrzCejcwg+3VYd1
+ve9YYdvEcs+fZDK7bIwBIgqubfAT18DiWnsNSVs3ErYU8UG1EZBI5YemlBAG9My5
+9z0PFRhE+x/0cuhOmBsRspe1+zFl1R+3AkkJ3bTknD9u+evO/jRlPrfEte8AEQEA
+AYkCHwQYAQoACQUCWRecxwIbDAAKCRCXZdLg2gG3qQ5bD/sGlImu4P5RkDVI43a4
+OMzBGF3p00sLQlOpdK6qvi7U0+y5bMCoivJkcEHxrhetgkifpPb89aZmpf41UQ8J
+KY5F3FnNtdEKVlAFBM+AyzDGk0sIkrEo8420gc/iCo7y08/LloyLFx0Pra9gw9vh
+zNZ9BA/htOOAmY8jnKYKkoMd0ZItgki9dulmY4wnDh7qWleQG2YYWIcF3CnJtLTj
+ZAFqC84lrMRAO+ONZ597n8Wqxdk+f8DXMfHQOfQLMSZmGcuAdJfnoTQ9rijg6ugs
+VAAxWggqvcEUDUzvZdb6mejoNL7KbVC2/osmUbxlJCJe5wSaiGouplb3fXtA6JhH
+9fr8CYuTLGn9g/FaYtkuOe0QcJq2eQ8JzfaUS8xLWZJTPlSjVrzlQuUeScWnGTqC
+LZJewxjhy7h8XjNQTBRpuGl46fGvDkSZPgczV+l8uFJujLa7m2g13tYugFB3jRD2
+EbiSgBkrF+nr/CFCXVssQpyJcLpaXkkT47QjHwCI7Uq3nN+41TW33+W9fMEpssEy
+/+MfQA5QhhwCeUrn8muoaBTez4LfXnlV7wp0MJZZFBX4Y5ZxjVC1L/MbddgRY/JK
+MPAgOzZv7oS6t6ozbUPrHS7QHkQPEyCKBaGkhYXTbRjnYpYMLSbWBpEEOOFQAdbD
+1/p1MJwDY8kXnVOVaIik15rUPA==
+=4ktw
+-END PGP PUBLIC KEY BLOCK-
+

svn commit: r19729 - /dev/nifi/KEYS

2017-05-18 Thread jskora 
Author: jskora
Date: Thu May 18 18:39:11 2017
New Revision: 19729

Log:
Added Mike Moser's GPG Code Signing key.

Modified:
dev/nifi/KEYS

Modified: dev/nifi/KEYS
==
--- dev/nifi/KEYS (original)
+++ dev/nifi/KEYS Thu May 18 18:39:11 2017
@@ -971,3 +971,63 @@ rIweBoDK7maio9YZPLHo1EvnzPfCC53e/u/BSmla
 P7qGxBxqZV2gSuQbbUUx
 =JS1c
 -END PGP PUBLIC KEY BLOCK-
+
+pub   4096R/DA01B7A9 2017-05-13
+uid  Michael Moser (CODE SIGNING KEY) 
+sig 3DA01B7A9 2017-05-13  Michael Moser (CODE SIGNING KEY) 

+sub   4096R/E6689021 2017-05-13
+sig  DA01B7A9 2017-05-13  Michael Moser (CODE SIGNING KEY) 

+
+-BEGIN PGP PUBLIC KEY BLOCK-
+Version: GnuPG v2.0.22 (GNU/Linux)
+
+mQINBFkXnMcBEAC+o6+3z9agB/g6cc5pICoWXiceYZzhetWMdCPuzSHiMFJzYHcS
+J4rxFIJjUB6Zrc6NAYw2gGmczYs9MkQ8NymciQtp6/4KtvpkhExLEnaXwEZmrkGH
++Ts3qJtUEz8EIdyfSCY8XgPBMNjhqQpDp2t3Frn3bkKwaSaAsFZE+TX+SMNKQr/t
+OuOS/mHDdZhTJWXfXgx06mQtuPaeXsYrucP6xwa0t/p3jiZZVH8GpvC+5PMIezJc
+O0Jx1V/d3bjZZLglOVpuhXzMyfxDcxTinTQLrH10Vrjionv112ggp6ncgdiqrzZr
+jlY46qjPGQ2+GdOwbqxqI6mPFZU3YBL1LUJNakOq2T6/FdhEybX7ocpg1etIEWap
+YfwlfaGf4rhRbpOg9WfJG1pqcsC+03bvqvzCcCbO95w9ehrNhxTY9F3E5vw8RJLN
+8yRDSJGFRFofkpnzC3QYULGkIGnWMl9u+oHDQtx0JFRFPNi/XJp5jp0H9ET/fVcD
+kLICX97p1SDsElDUYa1AfNNuBrb/vANzf1Bko1hoGCS3mq51RGYckbgbat6cE8po
+xKwV0fCnLUoPxan08m2ni6WkgHnoWPoyYmQmK21k5axb0W+tcWFTkMF/jtA4XNt1
+DhMz3Plo6EHPYFpRHR79NnNPIZXrgwKn+cg2TITDAqIZr+OvCGINxdO7EwARAQAB
+tDVNaWNoYWVsIE1vc2VyIChDT0RFIFNJR05JTkcgS0VZKSA8bW9zZXJtd0BhcGFj
+aGUub3JnPokCNwQTAQoAIQUCWRecxwIbAwULCQgHAwUVCgkICwUWAgMBAAIeAQIX
+gAAKCRCXZdLg2gG3qQamD/0ZhV6/OahAlpCblyILMZq1o/04rS0L5lolSOzGeSdk
+0nUa/ejHecd2iGDvkuaqA48hRwAv9EgZIWQ8qIZtGJ7dOOS3m+QBX+/6z04PLQcz
+isRwtbmJba2zC+OMrpN6sfnU/YysI+d08BSgZ9JAx2WnQztzyyLkkk4/3UOiwTfi
+sE2yWjLWuZHN2U814dbf99YDBLXSo/X/k3QvXZfiPqskZEVsDbAK0nqvf8ScqiUi
+R++v+XM+GaK5bRbAAHrJSK0GLM1RF8vh5DD9576ZSGaAJ6mXWvj4v5KKiec2UFkC
+VLFQpXJuDR2M6hVwMFvlbiEJE9ib08mBcplmDRFxxWvazs3Gj1fA/w+DPVcEZeJd
+1R0ry72VGoLz14qXZOOwu49aASi7Dyjd3h63XsUNsnRxe5iFwicpej/0TNFT3qsX
+P24W7NKhobzun6yR3Az/O/Fp+UCRSwOfZB+IG6arU/zf/JUKMoV5rwhngjRKWGqQ
+5cyvfJNiv+Tfnch2nrHJMskcGJcgYbsUHjyLN0Qh8Am9/i+M4QQXIU2nPsCT3at8
+GE37l+PERHTcF6xQl4S9xh+wY38ERdEvvx50/n5Ha/w6EpCV8+OJWbtC69ygg0TS
+Hz+qkB63aSmz74PHz+GR7OlMZ1MD+ILTLYSK/lgmO+CvvQXtK6jzSKGykx+KrHka
+B7kCDQRZF5zHARAAn2MvP+SMYmcRRJWz+MwyI2lVccQUc65FAEMhE5WCBJtbAim5
+LS/PsLxQKqBYcospXP1+aWbu6WfFXfLesSz6CfEitCZgkHlWoXXymYoongMFA94j
+fgVobXbXwKC8DaMv7hQkkp1oEriyIGWU1w5b1OI9oYFRo7y/wSoo2x8l7ry23rM7
+HgtC7aGCUHjwDS+QLeSLBae0qcU3M3bX57zuFB2GoCpIy10SNc5JFAuyf1Lgv1nb
+axmb1tp0BsrdA1kjsjcMPEYxNo9ctV34pzOG1UT0doyvXQFby9SMCkMQXE+q9JH2
+u5W2dtarEil8MvcKJNUQcegomA26b1jipo2ey3ZEZsn4LY5s4Yfwy20kdqxqx5Xu
+FWn+0iIEahCTsIitbH4JCTwyzxEBO0tGo72PGHUmh7YIIAGwFdJcp4eTs270pLvl
+YZGcSYD/xOCHWr5xdxmsHo7AAlMUceCpuNTOSXZxY1dyTJ+oRUMZj2YUPP3TmKCz
+fI8RM1hcC4CzOEkuABdSnsSDiWfCyGVTNwcz9kbVuRxUBD8rayrzCejcwg+3VYd1
+ve9YYdvEcs+fZDK7bIwBIgqubfAT18DiWnsNSVs3ErYU8UG1EZBI5YemlBAG9My5
+9z0PFRhE+x/0cuhOmBsRspe1+zFl1R+3AkkJ3bTknD9u+evO/jRlPrfEte8AEQEA
+AYkCHwQYAQoACQUCWRecxwIbDAAKCRCXZdLg2gG3qQ5bD/sGlImu4P5RkDVI43a4
+OMzBGF3p00sLQlOpdK6qvi7U0+y5bMCoivJkcEHxrhetgkifpPb89aZmpf41UQ8J
+KY5F3FnNtdEKVlAFBM+AyzDGk0sIkrEo8420gc/iCo7y08/LloyLFx0Pra9gw9vh
+zNZ9BA/htOOAmY8jnKYKkoMd0ZItgki9dulmY4wnDh7qWleQG2YYWIcF3CnJtLTj
+ZAFqC84lrMRAO+ONZ597n8Wqxdk+f8DXMfHQOfQLMSZmGcuAdJfnoTQ9rijg6ugs
+VAAxWggqvcEUDUzvZdb6mejoNL7KbVC2/osmUbxlJCJe5wSaiGouplb3fXtA6JhH
+9fr8CYuTLGn9g/FaYtkuOe0QcJq2eQ8JzfaUS8xLWZJTPlSjVrzlQuUeScWnGTqC
+LZJewxjhy7h8XjNQTBRpuGl46fGvDkSZPgczV+l8uFJujLa7m2g13tYugFB3jRD2
+EbiSgBkrF+nr/CFCXVssQpyJcLpaXkkT47QjHwCI7Uq3nN+41TW33+W9fMEpssEy
+/+MfQA5QhhwCeUrn8muoaBTez4LfXnlV7wp0MJZZFBX4Y5ZxjVC1L/MbddgRY/JK
+MPAgOzZv7oS6t6ozbUPrHS7QHkQPEyCKBaGkhYXTbRjnYpYMLSbWBpEEOOFQAdbD
+1/p1MJwDY8kXnVOVaIik15rUPA==
+=4ktw
+-END PGP PUBLIC KEY BLOCK-
+

[jira] [Commented] (MINIFI-320) In cases where users run TLSSocket, the context will cause a realloc in multiple threads.

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016210#comment-16016210
 ] 

ASF GitHub Bot commented on MINIFI-320:
---

GitHub user phrocker opened a pull request:

https://github.com/apache/nifi-minifi-cpp/pull/100

MINIFI-320: Move instantion of OpenSSL to a singleton that's

lazily created. Added test. In order to make the test work as
expected I had to update thread pool to use a non blocking queue.

Thank you for submitting a contribution to Apache NiFi - MiNiFi C++.

In order to streamline the review of the contribution we ask you
to ensure the following steps have been taken:

### For all changes:
- [ ] Is there a JIRA ticket associated with this PR? Is it referenced
 in the commit message?

- [ ] Does your PR title start with MINIFI- where  is the JIRA 
number you are trying to resolve? Pay particular attention to the hyphen "-" 
character.

- [ ] Has your PR been rebased against the latest commit within the target 
branch (typically master)?

- [ ] Is your initial contribution a single, squashed commit?

### For code changes:
- [ ] If adding new dependencies to the code, are these dependencies 
licensed in a way that is compatible for inclusion under [ASF 
2.0](http://www.apache.org/legal/resolved.html#category-a)?
- [ ] If applicable, have you updated the LICENSE file?
- [ ] If applicable, have you updated the NOTICE file?

### For documentation related changes:
- [ ] Have you ensured that format looks appropriate for the output in 
which it is rendered?

### Note:
Please ensure that once the PR is submitted, you check travis-ci for build 
issues and submit an update to your PR as soon as possible.


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/phrocker/nifi-minifi-cpp MINIFI-320

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/nifi-minifi-cpp/pull/100.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #100


commit 68d7d6f14c96a73f89dead04e37895af6e1957fc
Author: Marc Parisi 
Date:   2017-05-18T18:21:16Z

MINIFI-320: Move instantion of OpenSSL to a singleton that's
lazily created. Added test. In order to make the test work as
expected I had to update thread pool to use a non blocking queue.




> In cases where users run TLSSocket, the context will cause a realloc in 
> multiple threads. 
> --
>
> Key: MINIFI-320
> URL: https://issues.apache.org/jira/browse/MINIFI-320
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Reporter: marco polo
>Priority: Blocker
> Fix For: cpp-0.3.0
>
>
> An example stacktrace. . We can either move *back* to a singleton of simply 
> move the ssl library initialization to a better place. 
> #0 0x10122d520 in wrap_realloc 
> (libclang_rt.asan_osx_dynamic.dylib:x86_64h+0x56520)
> #1 0x100fe80ae in CRYPTO_realloc (libcrypto.1.0.0.dylib:x86_64+0x20ae)
> #2 0x10109880c in lh_insert (libcrypto.1.0.0.dylib:x86_64+0xb280c)
> #3 0x100fea6e7 in OBJ_NAME_add (libcrypto.1.0.0.dylib:x86_64+0x46e7)
> #4 0x1010a5b41 in OpenSSL_add_all_ciphers 
> (libcrypto.1.0.0.dylib:x86_64+0xbfb41)
> #5 0x1010a58d1 in OPENSSL_add_all_algorithms_noconf 
> (libcrypto.1.0.0.dylib:x86_64+0xbf8d1)
> #6 0x10012ad40 in org::apache::nifi::minifi::io::TLSContext::initialize() 
> TLSSocket.cpp:60
> #7 0x100132255 in org::apache::nifi::minifi::io::TLSSocket::initialize() 
> TLSSocket.cpp:166
> #8 0x100677a68 in org::apache::nifi::minifi::Site2SitePeer::Open() 
> Site2SitePeer.cpp:42
> #9 0x100631543 in 
> org::apache::nifi::minifi::Site2SiteClientProtocol::establish() 
> Site2SiteClientProtocol.cpp:46
> #10 0x10063e9ff in 
> org::apache::nifi::minifi::Site2SiteClientProtocol::bootstrap() 
> Site2SiteClientProtocol.cpp:483
> #11 0x100600880 in 
> org::apache::nifi::minifi::RemoteProcessorGroupPort::onTrigger(org::apache::nifi::minifi::core::ProcessContext*,
>  org::apache::nifi::minifi::core::ProcessSession*) 
> RemoteProcessorGroupPort.cpp:148
> #12 0x1002c1a3a in 
> org::apache::nifi::minifi::core::Processor::onTrigger(org::apache::nifi::minifi::core::ProcessContext*,
>  org::apache::nifi::minifi::core::ProcessSessionFactory*) Processor.cpp:235
> #13 0x10062cc20 in 
> org::apache::nifi::minifi::SchedulingAgent::onTrigger(std::__1::shared_ptr,
>  org::apache::nifi::minifi::core::ProcessContext*, 
> org::apache::nifi::minifi::core::ProcessSessionFactory*) 
>

nifi git commit: NIFI-3853 fixing tests to properly encapsulate their environments

2017-05-18 Thread bbende 
Repository: nifi
Updated Branches:
  refs/heads/master 36e7bd616 -> be67f3552


NIFI-3853 fixing tests to properly encapsulate their environments

This closes #1822.

Signed-off-by: Bryan Bende 


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/be67f355
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/be67f355
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/be67f355

Branch: refs/heads/master
Commit: be67f3552ba9abbb98aa29ab48c06264b77ab661
Parents: 36e7bd6
Author: joewitt 
Authored: Thu May 18 09:31:56 2017 -0400
Committer: Bryan Bende 
Committed: Thu May 18 13:36:02 2017 -0400

--
 .../StandardFlowSynchronizerSpec.groovy |   5 +-
 .../nifi/controller/TestFlowController.java |  49 +++
 .../scheduling/TestProcessorLifecycle.java  |   7 +-
 .../TestStandardProcessScheduler.java   |  19 ++-
 .../StandardFlowSerializerTest.java |  25 ++--
 .../flowcontrollertest.nifi.properties  | 127 +++
 .../resources/lifecycletest.nifi.properties | 127 +++
 .../src/test/resources/nifi.properties  | 127 ---
 .../standardflowserializertest.nifi.properties  | 127 +++
 ...standardflowsynchronizerspec.nifi.properties | 127 +++
 ...standardprocessschedulertest.nifi.properties | 127 +++
 11 files changed, 695 insertions(+), 172 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi/blob/be67f355/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/groovy/org/apache/nifi/controller/StandardFlowSynchronizerSpec.groovy
--
diff --git 
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/groovy/org/apache/nifi/controller/StandardFlowSynchronizerSpec.groovy
 
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/groovy/org/apache/nifi/controller/StandardFlowSynchronizerSpec.groovy
index 098814a..e54bbe8 100644
--- 
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/groovy/org/apache/nifi/controller/StandardFlowSynchronizerSpec.groovy
+++ 
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/groovy/org/apache/nifi/controller/StandardFlowSynchronizerSpec.groovy
@@ -40,10 +40,9 @@ class StandardFlowSynchronizerSpec extends Specification {
 def systemBundle;
 
 def setupSpec() {
-def propFile = 
StandardFlowSynchronizerSpec.class.getResource("/nifi.properties").getFile()
-System.setProperty NiFiProperties.PROPERTIES_FILE_PATH, propFile
+def propFile = 
StandardFlowSynchronizerSpec.class.getResource("/standardflowsynchronizerspec.nifi.properties").getFile()
 
-def niFiProperties = NiFiProperties.createBasicNiFiProperties(null, 
null);
+def niFiProperties = 
NiFiProperties.createBasicNiFiProperties(propFile, null);
 systemBundle = SystemBundle.create(niFiProperties);
 ExtensionManager.discoverExtensions(systemBundle, 
Collections.emptySet());
 }

http://git-wip-us.apache.org/repos/asf/nifi/blob/be67f355/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/TestFlowController.java
--
diff --git 
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/TestFlowController.java
 
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/TestFlowController.java
index 1b51be6..31bf497 100644
--- 
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/TestFlowController.java
+++ 
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/java/org/apache/nifi/controller/TestFlowController.java
@@ -83,6 +83,7 @@ import java.util.Map;
 import java.util.Set;
 import java.util.UUID;
 import java.util.concurrent.TimeUnit;
+import org.apache.commons.io.FileUtils;
 
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
@@ -92,7 +93,6 @@ import static org.junit.Assert.assertTrue;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 
-
 public class TestFlowController {
 
 private FlowController controller;
@@ -104,10 +104,10 @@ public class TestFlowController {
 private Bundle systemBundle;
 private BulletinRepository bulletinRepo;
 private VariableRegistry variableRegistry;
+private volatile String propsFile =

[jira] [Commented] (MINIFI-270) some refactor to move site2site protocol out of processor

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016070#comment-16016070
 ] 

ASF GitHub Bot commented on MINIFI-270:
---

Github user asfgit closed the pull request at:

https://github.com/apache/nifi-minifi-cpp/pull/99


> some refactor to move site2site protocol out of processor
> -
>
> Key: MINIFI-270
> URL: https://issues.apache.org/jira/browse/MINIFI-270
> Project: Apache NiFi MiNiFi
>  Issue Type: Improvement
>  Components: C++
>Affects Versions: cpp-0.1.0
>Reporter: bqiu
>Assignee: marco polo
>Priority: Minor
> Fix For: cpp-0.3.0
>
>
> @@ -239,12 +242,21 @@ class Processor : public Connectable, public 
> ConfigurableComponent,
>// Trigger the Processor even if the incoming connection is empty
>std::atomic _triggerWhenEmpty;
>  
> - private:
> +  //! obtainSite2SiteProtocol for use
> +  std::shared_ptr 
> obtainSite2SiteProtocol(std::string host, uint16_t sport, uuid_t portId);
>   phrocker
> phrocker 5 hours ago Contributor
> @benqiu2016 Can you make a ticket to move this out of Processor? It should be 
> a separate component. If you make the ticket I'll make this particular change.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-270) some refactor to move site2site protocol out of processor

2017-05-18 Thread ASF subversion and git services (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016069#comment-16016069
 ] 

ASF subversion and git services commented on MINIFI-270:


Commit 082c85a866e355b08b1d47fcf3d2792983003cea in nifi-minifi-cpp's branch 
refs/heads/master from Marc Parisi
[ https://git-wip-us.apache.org/repos/asf?p=nifi-minifi-cpp.git;h=082c85a ]

MINIFI-270: Move Base RPG capabilities back into RemoteProcessGroupPort

This allows us to extend capabilities in RPG into other classes. Since
the same basic functions are the same we can bring the code up from
Processor into RemoteProcessGroupPort.h instead of a separate class.

Updated LICENSE and added concurrentqueue to locking for the object pool.

This closes #99.

Signed-off-by: Aldrin Piri 


> some refactor to move site2site protocol out of processor
> -
>
> Key: MINIFI-270
> URL: https://issues.apache.org/jira/browse/MINIFI-270
> Project: Apache NiFi MiNiFi
>  Issue Type: Improvement
>  Components: C++
>Affects Versions: cpp-0.1.0
>Reporter: bqiu
>Assignee: marco polo
>Priority: Minor
> Fix For: cpp-0.3.0
>
>
> @@ -239,12 +242,21 @@ class Processor : public Connectable, public 
> ConfigurableComponent,
>// Trigger the Processor even if the incoming connection is empty
>std::atomic _triggerWhenEmpty;
>  
> - private:
> +  //! obtainSite2SiteProtocol for use
> +  std::shared_ptr 
> obtainSite2SiteProtocol(std::string host, uint16_t sport, uuid_t portId);
>   phrocker
> phrocker 5 hours ago Contributor
> @benqiu2016 Can you make a ticket to move this out of Processor? It should be 
> a separate component. If you make the ticket I'll make this particular change.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Resolved] (MINIFI-270) some refactor to move site2site protocol out of processor

2017-05-18 Thread Aldrin Piri (JIRA) 

 [ 
https://issues.apache.org/jira/browse/MINIFI-270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aldrin Piri resolved MINIFI-270.

   Resolution: Fixed
Fix Version/s: cpp-0.3.0

> some refactor to move site2site protocol out of processor
> -
>
> Key: MINIFI-270
> URL: https://issues.apache.org/jira/browse/MINIFI-270
> Project: Apache NiFi MiNiFi
>  Issue Type: Improvement
>  Components: C++
>Affects Versions: cpp-0.1.0
>Reporter: bqiu
>Assignee: marco polo
>Priority: Minor
> Fix For: cpp-0.3.0
>
>
> @@ -239,12 +242,21 @@ class Processor : public Connectable, public 
> ConfigurableComponent,
>// Trigger the Processor even if the incoming connection is empty
>std::atomic _triggerWhenEmpty;
>  
> - private:
> +  //! obtainSite2SiteProtocol for use
> +  std::shared_ptr 
> obtainSite2SiteProtocol(std::string host, uint16_t sport, uuid_t portId);
>   phrocker
> phrocker 5 hours ago Contributor
> @benqiu2016 Can you make a ticket to move this out of Processor? It should be 
> a separate component. If you make the ticket I'll make this particular change.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[1/2] nifi-minifi-cpp git commit: MINIFI-270: Move Base RPG capabilities back into RemoteProcessGroupPort

2017-05-18 Thread aldrin 
Repository: nifi-minifi-cpp
Updated Branches:
  refs/heads/master 1498ec87a -> 082c85a86


http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/082c85a8/thirdparty/concurrentqueue/concurrentqueue.h
--
diff --git a/thirdparty/concurrentqueue/concurrentqueue.h 
b/thirdparty/concurrentqueue/concurrentqueue.h
new file mode 100644
index 000..d2350c3
--- /dev/null
+++ b/thirdparty/concurrentqueue/concurrentqueue.h
@@ -0,0 +1,3626 @@
+// Provides a C++11 implementation of a multi-producer, multi-consumer 
lock-free queue.
+// An overview, including benchmark results, is provided here:
+// 
http://moodycamel.com/blog/2014/a-fast-general-purpose-lock-free-queue-for-c++
+// The full design is also described in excruciating detail at:
+//http://moodycamel.com/blog/2014/detailed-design-of-a-lock-free-queue
+
+// Simplified BSD license:
+// Copyright (c) 2013-2016, Cameron Desrochers.
+// All rights reserved.
+//
+// Redistribution and use in source and binary forms, with or without 
modification,
+// are permitted provided that the following conditions are met:
+//
+// - Redistributions of source code must retain the above copyright notice, 
this list of
+// conditions and the following disclaimer.
+// - Redistributions in binary form must reproduce the above copyright notice, 
this list of
+// conditions and the following disclaimer in the documentation and/or other 
materials
+// provided with the distribution.
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" 
AND ANY
+// EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 
WARRANTIES OF
+// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO 
EVENT SHALL
+// THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 
INCIDENTAL,
+// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED 
TO, PROCUREMENT
+// OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 
INTERRUPTION)
+// HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 
LIABILITY, OR
+// TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 
OF THIS SOFTWARE,
+// EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+
+#pragma once
+
+#if defined(__GNUC__)
+// Disable -Wconversion warnings (spuriously triggered when Traits::size_t and
+// Traits::index_t are set to < 32 bits, causing integer promotion, causing 
warnings
+// upon assigning any computed values)
+#pragma GCC diagnostic push
+#pragma GCC diagnostic ignored "-Wconversion"
+
+#ifdef MCDBGQ_USE_RELACY
+#pragma GCC diagnostic ignored "-Wint-to-pointer-cast"
+#endif
+#endif
+
+#if defined(__APPLE__)
+#include "TargetConditionals.h"
+#endif
+
+#ifdef MCDBGQ_USE_RELACY
+#include "relacy/relacy_std.hpp"
+#include "relacy_shims.h"
+// We only use malloc/free anyway, and the delete macro messes up `= delete` 
method declarations.
+// We'll override the default trait malloc ourselves without a macro.
+#undef new
+#undef delete
+#undef malloc
+#undef free
+#else
+#include   // Requires C++11. Sorry VS2010.
+#include 
+#endif
+#include   // for max_align_t
+#include 
+#include 
+#include 
+#include 
+#include 
+#include 
+#include  // for CHAR_BIT
+#include 
+#include   // partly for __WINPTHREADS_VERSION if on 
MinGW-w64 w/ POSIX threading
+
+// Platform-specific definitions of a numeric thread ID type and an invalid 
value
+namespace moodycamel { namespace details {
+   template struct thread_id_converter {
+   typedef thread_id_t thread_id_numeric_size_t;
+   typedef thread_id_t thread_id_hash_t;
+   static thread_id_hash_t prehash(thread_id_t const& x) { return 
x; }
+   };
+} }
+#if defined(MCDBGQ_USE_RELACY)
+namespace moodycamel { namespace details {
+   typedef std::uint32_t thread_id_t;
+   static const thread_id_t invalid_thread_id  = 0xU;
+   static const thread_id_t invalid_thread_id2 = 0xFFFEU;
+   static inline thread_id_t thread_id() { return rl::thread_index(); }
+} }
+#elif defined(_WIN32) || defined(__WINDOWS__) || defined(__WIN32__)
+// No sense pulling in windows.h in a header, we'll manually declare the 
function
+// we use and rely on backwards-compatibility for this not to break
+extern "C" __declspec(dllimport) unsigned long __stdcall 
GetCurrentThreadId(void);
+namespace moodycamel { namespace details {
+   static_assert(sizeof(unsigned long) == sizeof(std::uint32_t), "Expected 
size of unsigned long to be 32 bits on Windows");
+   typedef std::uint32_t thread_id_t;
+   static const thread_id_t invalid_thread_id  = 0;
// See http://blogs.msdn.com/b/oldnewthing/archive/2004/02/23/78395.aspx
+   static const thread_id_t invalid_thread_id2 = 0xU;  // Not 
technically guaranteed to be invalid, but is

[2/2] nifi-minifi-cpp git commit: MINIFI-270: Move Base RPG capabilities back into RemoteProcessGroupPort

2017-05-18 Thread aldrin 
MINIFI-270: Move Base RPG capabilities back into RemoteProcessGroupPort

This allows us to extend capabilities in RPG into other classes. Since
the same basic functions are the same we can bring the code up from
Processor into RemoteProcessGroupPort.h instead of a separate class.

Updated LICENSE and added concurrentqueue to locking for the object pool.

This closes #99.

Signed-off-by: Aldrin Piri 


Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/commit/082c85a8
Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/082c85a8
Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/082c85a8

Branch: refs/heads/master
Commit: 082c85a866e355b08b1d47fcf3d2792983003cea
Parents: 1498ec8
Author: Marc Parisi 
Authored: Wed May 17 08:18:26 2017 -0400
Committer: Aldrin Piri 
Committed: Thu May 18 12:56:06 2017 -0400

--
 CMakeLists.txt  |3 +-
 LICENSE |   27 +
 libminifi/CMakeLists.txt|1 +
 libminifi/include/RemoteProcessorGroupPort.h|   22 +-
 libminifi/include/core/Processor.h  |   10 +-
 .../SiteToSiteProvenanceReportingTask.h |  112 +-
 libminifi/src/RemoteProcessorGroupPort.cpp  |  119 +-
 libminifi/src/core/Processor.cpp|   47 -
 .../SiteToSiteProvenanceReportingTask.cpp   |   52 +-
 main/CMakeLists.txt |2 +-
 thirdparty/concurrentqueue/concurrentqueue.h| 3626 ++
 11 files changed, 3837 insertions(+), 184 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/082c85a8/CMakeLists.txt
--
diff --git a/CMakeLists.txt b/CMakeLists.txt
index bf349a6..73222dd 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -105,6 +105,7 @@ set(JSONCPP_LIB 
"${JSONCPP_LIB_DIR}/lib/${prefix}jsoncpp${suffix}")
 set(CIVETWEB_ENABLE_CXX ON CACHE BOOL "Enable civet C++ library")
 add_subdirectory(thirdparty/yaml-cpp-yaml-cpp-0.5.3)
 add_subdirectory(thirdparty/civetweb-1.9.1)
+include_directories(thirdparty/concurrentqueue)
 add_subdirectory(libminifi)
 add_subdirectory(main)
 
@@ -144,7 +145,7 @@ set(CPACK_COMPONENTS_ALL bin)
 include(CPack)
 
 include(BuildTests)
-   
+
 include(BuildDocs)
 
 include(DockerConfig)

http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/082c85a8/LICENSE
--
diff --git a/LICENSE b/LICENSE
index 30be538..f67f624 100644
--- a/LICENSE
+++ b/LICENSE
@@ -401,6 +401,33 @@ ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 The views and conclusions contained in the software and documentation are 
those of the authors and
 should not be interpreted as representing official policies, either expressed 
or implied, of Dmitry Vyukov.
 
+
+This product bundles 'concurrentqueue' which is available a Boost Software 
License.
+
+Boost Software License - Version 1.0 - August 17th, 2003
+
+Permission is hereby granted, free of charge, to any person or organization
+obtaining a copy of the software and accompanying documentation covered by
+this license (the "Software") to use, reproduce, display, distribute,
+execute, and transmit the Software, and to prepare derivative works of the
+Software, and to permit third-parties to whom the Software is furnished to
+do so, all subject to the following:
+
+The copyright notices in the Software and this entire statement, including
+the above license grant, this restriction and the following disclaimer,
+must be included in all copies of the Software, in whole or in part, and
+all derivative works of the Software, unless such copies or derivative
+works are solely in the form of machine-executable object code generated by
+a source language processor.
+
+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, TITLE AND NON-INFRINGEMENT. IN NO EVENT
+SHALL THE COPYRIGHT HOLDERS OR ANYONE DISTRIBUTING THE SOFTWARE BE LIABLE
+FOR ANY DAMAGES OR OTHER LIABILITY, WHETHER IN CONTRACT, TORT OR OTHERWISE,
+ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+DEALINGS IN THE SOFTWARE.
+
 This product bundles 'Catch' which is available under a Boost Software License.
 
 Boost Software License - Version 1.0 - August 17th, 2003

http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/082c85a8/libminifi/CMakeLists.txt
--
diff --git a/libminifi/CMakeLists.txt b/libminifi/CMakeLists.txt
index a0ec75f..f674b68 100644
---

[jira] [Commented] (MINIFI-290) Enable resource files to be loaded easily in unit tests

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016027#comment-16016027
 ] 

ASF GitHub Bot commented on MINIFI-290:
---

Github user kevdoran commented on the issue:

https://github.com/apache/nifi-minifi-cpp/pull/95
  
Will do.


> Enable resource files to be loaded easily in unit tests
> ---
>
> Key: MINIFI-290
> URL: https://issues.apache.org/jira/browse/MINIFI-290
> Project: Apache NiFi MiNiFi
>  Issue Type: Improvement
>  Components: C++, Testing
>Reporter: Kevin Doran
>Assignee: Kevin Doran
>Priority: Minor
>
> As part of MINIFI-275, unit test cases were introduced that rely on YAML 
> configuration input. Currently, the YAML is defined as string constants in 
> the test cases (see [1]).
> During peer review of MINIFI-275, it was suggested by [~phrocker] to move the 
> YAML inputs to resource files and load them for the test. This ticket 
> captures that improvement which will cleanup the unit test code by making the 
> YAML input easier to locate and maintain.
> As part of this, we need a clean way to set resource file locations in CMAKE 
> so that they are easily available in ctest test cases. As the `test` target 
> which invokes ctest is a builtin/standard CMAKE generated target, it is more 
> limited in its configurability for items such as command line arguments [2] 
> and environment variables (SET (CTEST_ENVIRONMENT ...) apparently does not 
> work in CMakeLists.txt files, only when CMake is invoked via the CLI). This 
> needs some more experimenting / digging into with our specific version of 
> CMAKE before we decide on an approach for implementation.
> [1] https://github.com/apache/nifi-minifi-cpp/pull/85 
> [2] http://stackoverflow.com/a/16163137



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-290) Enable resource files to be loaded easily in unit tests

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016024#comment-16016024
 ] 

ASF GitHub Bot commented on MINIFI-290:
---

Github user apiri commented on the issue:

https://github.com/apache/nifi-minifi-cpp/pull/95
  
Hey @kevdoran,

#96 is now merged.  Would you be able to rebase and see if that solves the 
problem you were encountering before?


> Enable resource files to be loaded easily in unit tests
> ---
>
> Key: MINIFI-290
> URL: https://issues.apache.org/jira/browse/MINIFI-290
> Project: Apache NiFi MiNiFi
>  Issue Type: Improvement
>  Components: C++, Testing
>Reporter: Kevin Doran
>Assignee: Kevin Doran
>Priority: Minor
>
> As part of MINIFI-275, unit test cases were introduced that rely on YAML 
> configuration input. Currently, the YAML is defined as string constants in 
> the test cases (see [1]).
> During peer review of MINIFI-275, it was suggested by [~phrocker] to move the 
> YAML inputs to resource files and load them for the test. This ticket 
> captures that improvement which will cleanup the unit test code by making the 
> YAML input easier to locate and maintain.
> As part of this, we need a clean way to set resource file locations in CMAKE 
> so that they are easily available in ctest test cases. As the `test` target 
> which invokes ctest is a builtin/standard CMAKE generated target, it is more 
> limited in its configurability for items such as command line arguments [2] 
> and environment variables (SET (CTEST_ENVIRONMENT ...) apparently does not 
> work in CMakeLists.txt files, only when CMake is invoked via the CLI). This 
> needs some more experimenting / digging into with our specific version of 
> CMAKE before we decide on an approach for implementation.
> [1] https://github.com/apache/nifi-minifi-cpp/pull/85 
> [2] http://stackoverflow.com/a/16163137



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Assigned] (MINIFI-305) cmake/iOS.cmake needs apache license header

2017-05-18 Thread Aldrin Piri (JIRA) 

 [ 
https://issues.apache.org/jira/browse/MINIFI-305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aldrin Piri reassigned MINIFI-305:
--

Assignee: marco polo

> cmake/iOS.cmake needs apache license header
> ---
>
> Key: MINIFI-305
> URL: https://issues.apache.org/jira/browse/MINIFI-305
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Affects Versions: cpp-0.2.0
>Reporter: marco polo
>Assignee: marco polo
>Priority: Minor
>  Labels: docs
> Fix For: cpp-0.3.0
>
>
> cmake/iOS.cmake needs apache license header. cmake/FindUUID.cmake is an 
> example



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Updated] (MINIFI-305) cmake/iOS.cmake needs apache license header

2017-05-18 Thread Aldrin Piri (JIRA) 

 [ 
https://issues.apache.org/jira/browse/MINIFI-305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aldrin Piri updated MINIFI-305:
---
Fix Version/s: cpp-0.3.0

> cmake/iOS.cmake needs apache license header
> ---
>
> Key: MINIFI-305
> URL: https://issues.apache.org/jira/browse/MINIFI-305
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Affects Versions: cpp-0.2.0
>Reporter: marco polo
>Priority: Minor
>  Labels: docs
> Fix For: cpp-0.3.0
>
>
> cmake/iOS.cmake needs apache license header. cmake/FindUUID.cmake is an 
> example



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-306) Move docs into a separate module.

2017-05-18 Thread ASF subversion and git services (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016016#comment-16016016
 ] 

ASF subversion and git services commented on MINIFI-306:


Commit 1498ec87a67bc05632a3a99cf870828316fd6c01 in nifi-minifi-cpp's branch 
refs/heads/master from Marc Parisi
[ https://git-wip-us.apache.org/repos/asf?p=nifi-minifi-cpp.git;h=1498ec8 ]

MINIFI-304: Update testing strategy

MINIFI-306: Move Docs and Docker cmake code into a separate module.
this will clean-up the end of the file. We will continue to do cleanup
but this has a great impact to improve the readability of the root
cmake

MINIFI-305: Add header to iOS.cmake module

This closes #96.

Signed-off-by: Aldrin Piri 


> Move docs into a separate module. 
> --
>
> Key: MINIFI-306
> URL: https://issues.apache.org/jira/browse/MINIFI-306
> Project: Apache NiFi MiNiFi
>  Issue Type: Sub-task
>  Components: C++
>Reporter: marco polo
>Assignee: marco polo
>
> MINIFI-304 will move tests into a separate cmake module. we can move docs 
> into a separate cmake module to clean up the cmake file a bit. 



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-304) Test Failures manifested by logger initialization failures.

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016018#comment-16016018
 ] 

ASF GitHub Bot commented on MINIFI-304:
---

Github user asfgit closed the pull request at:

https://github.com/apache/nifi-minifi-cpp/pull/96


> Test Failures manifested by logger initialization failures. 
> 
>
> Key: MINIFI-304
> URL: https://issues.apache.org/jira/browse/MINIFI-304
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Reporter: marco polo
>Assignee: marco polo
> Fix For: cpp-0.3.0
>
>
> statics within spdlog would not be initialized in time depending on the order 
> of execution. As a result it is better to use no logging unless necessary. 
> There are examples which use logging, but unless explicitly needed ( and 
> captured into strings, for example ) we should instead turn logging off.
> Breaking this out into separate executables would be idea. This ticket will 
> involve editing the cmake file to move tests into a separate file. 



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-304) Test Failures manifested by logger initialization failures.

2017-05-18 Thread ASF subversion and git services (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016015#comment-16016015
 ] 

ASF subversion and git services commented on MINIFI-304:


Commit 1498ec87a67bc05632a3a99cf870828316fd6c01 in nifi-minifi-cpp's branch 
refs/heads/master from Marc Parisi
[ https://git-wip-us.apache.org/repos/asf?p=nifi-minifi-cpp.git;h=1498ec8 ]

MINIFI-304: Update testing strategy

MINIFI-306: Move Docs and Docker cmake code into a separate module.
this will clean-up the end of the file. We will continue to do cleanup
but this has a great impact to improve the readability of the root
cmake

MINIFI-305: Add header to iOS.cmake module

This closes #96.

Signed-off-by: Aldrin Piri 


> Test Failures manifested by logger initialization failures. 
> 
>
> Key: MINIFI-304
> URL: https://issues.apache.org/jira/browse/MINIFI-304
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Reporter: marco polo
>Assignee: marco polo
> Fix For: cpp-0.3.0
>
>
> statics within spdlog would not be initialized in time depending on the order 
> of execution. As a result it is better to use no logging unless necessary. 
> There are examples which use logging, but unless explicitly needed ( and 
> captured into strings, for example ) we should instead turn logging off.
> Breaking this out into separate executables would be idea. This ticket will 
> involve editing the cmake file to move tests into a separate file. 



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-305) cmake/iOS.cmake needs apache license header

2017-05-18 Thread ASF subversion and git services (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016017#comment-16016017
 ] 

ASF subversion and git services commented on MINIFI-305:


Commit 1498ec87a67bc05632a3a99cf870828316fd6c01 in nifi-minifi-cpp's branch 
refs/heads/master from Marc Parisi
[ https://git-wip-us.apache.org/repos/asf?p=nifi-minifi-cpp.git;h=1498ec8 ]

MINIFI-304: Update testing strategy

MINIFI-306: Move Docs and Docker cmake code into a separate module.
this will clean-up the end of the file. We will continue to do cleanup
but this has a great impact to improve the readability of the root
cmake

MINIFI-305: Add header to iOS.cmake module

This closes #96.

Signed-off-by: Aldrin Piri 


> cmake/iOS.cmake needs apache license header
> ---
>
> Key: MINIFI-305
> URL: https://issues.apache.org/jira/browse/MINIFI-305
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Affects Versions: cpp-0.2.0
>Reporter: marco polo
>Priority: Minor
>  Labels: docs
>
> cmake/iOS.cmake needs apache license header. cmake/FindUUID.cmake is an 
> example



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

nifi-minifi-cpp git commit: MINIFI-304: Update testing strategy

2017-05-18 Thread aldrin 
Repository: nifi-minifi-cpp
Updated Branches:
  refs/heads/master c9940e945 -> 1498ec87a


MINIFI-304: Update testing strategy

MINIFI-306: Move Docs and Docker cmake code into a separate module.
this will clean-up the end of the file. We will continue to do cleanup
but this has a great impact to improve the readability of the root
cmake

MINIFI-305: Add header to iOS.cmake module

This closes #96.

Signed-off-by: Aldrin Piri 


Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/commit/1498ec87
Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/1498ec87
Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/1498ec87

Branch: refs/heads/master
Commit: 1498ec87a67bc05632a3a99cf870828316fd6c01
Parents: c9940e9
Author: Marc Parisi 
Authored: Mon May 8 19:13:00 2017 -0400
Committer: Aldrin Piri 
Committed: Thu May 18 12:18:27 2017 -0400

--
 CMakeLists.txt | 195 +-
 cmake/BuildDocs.cmake  |  42 ++
 cmake/BuildTests.cmake |  90 +
 cmake/DockerConfig.cmake   |  28 ++
 cmake/iOS.cmake|  18 +
 libminifi/CMakeLists.txt   |   2 +-
 libminifi/test/integration/ProcessorTests.cpp  | 411 
 libminifi/test/integration/SocketTests.cpp | 185 -
 libminifi/test/resource/TestHTTPGet.yml|  73 
 libminifi/test/resource/TestHTTPPost.yml   |  87 +
 libminifi/test/unit/CRCTests.cpp   |   2 +
 libminifi/test/unit/ClassLoaderTests.cpp   |   5 +-
 libminifi/test/unit/ControllerServiceTests.cpp |   1 +
 libminifi/test/unit/InvokeHTTPTests.cpp|   2 +
 libminifi/test/unit/LoggerTests.cpp|   2 +-
 libminifi/test/unit/ProcessorTests.cpp | 411 
 libminifi/test/unit/PropertyTests.cpp  |   2 +-
 libminifi/test/unit/ProvenanceTests.cpp|   1 +
 libminifi/test/unit/RepoTests.cpp  |   2 +-
 libminifi/test/unit/SerializationTests.cpp |   2 +-
 libminifi/test/unit/Site2SiteTests.cpp |   1 +
 libminifi/test/unit/SocketTests.cpp| 185 +
 libminifi/test/unit/ThreadPoolTests.cpp|   1 +
 libminifi/test/unit/TimeUtilsTest.cpp  |  21 -
 libminifi/test/unit/YamlCongifurationTests.cpp |   2 +-
 25 files changed, 958 insertions(+), 813 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/1498ec87/CMakeLists.txt
--
diff --git a/CMakeLists.txt b/CMakeLists.txt
index e441c44..bf349a6 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -25,6 +25,7 @@ set(PROJECT_VERSION_MINOR 3)
 set(PROJECT_VERSION_PATCH 0)
 option(test "Build all tests." ON)
 
+
  Establish Project Configuration 
 # Enable usage of the VERSION specifier
 # https://cmake.org/cmake/help/v3.0/policy/CMP0048.html#policy:CMP0048
@@ -135,198 +136,16 @@ set(CPACK_PACKAGE_DESCRIPTION_FILE 
"${CMAKE_CURRENT_SOURCE_DIR}/README.md")
 set(CPACK_RESOURCE_FILE_LICENSE "${CMAKE_CURRENT_SOURCE_DIR}/LICENSE")
 set(CPACK_PACKAGE_FILE_NAME "${ASSEMBLY_BASE_NAME}")
 set(CPACK_BINARY_TGZ, "ON")
-
 set(CPACK_ARCHIVE_COMPONENT_INSTALL ON)
 set(CPACK_COMPONENTS_ALL bin)
 
-include(CPack)
-
-enable_testing(test)
-file(GLOB LIBMINIFI_TEST_SOURCES "libminifi/test/unit/*.cpp")
-add_executable(unit_tests ${LIBMINIFI_TEST_SOURCES} ${SPD_SOURCES})
-target_include_directories(unit_tests PRIVATE BEFORE "thirdparty/catch")
-target_include_directories(unit_tests PRIVATE BEFORE 
"thirdparty/yaml-cpp-yaml-cpp-0.5.3/include")
-target_include_directories(unit_tests PRIVATE BEFORE 
"thirdparty/jsoncpp/include")
-target_include_directories(unit_tests PRIVATE BEFORE 
${LEVELDB_INCLUDE_DIRS})
-target_include_directories(unit_tests PRIVATE BEFORE "include")
-target_include_directories(unit_tests PRIVATE BEFORE "libminifi/include/")
-target_include_directories(unit_tests PRIVATE BEFORE 
"libminifi/include/core")
-target_include_directories(unit_tests PRIVATE BEFORE 
"libminifi/include/core/controller")
-target_include_directories(unit_tests PRIVATE BEFORE 
"libminifi/include/core/repository")
-target_include_directories(unit_tests PRIVATE BEFORE 
"libminifi/include/core/yaml")
-target_include_directories(unit_tests PRIVATE BEFORE 
"libminifi/include/io")
-target_include_directories(unit_tests PRIVATE BEFORE 
"libminifi/include/utils")
-target_include_directories(unit_tests PRIVATE BEFORE 
"libminifi/include/processors")
-target_include_directories(unit_tests PRIVATE BEFORE 
"libminifi/include/provenance")
-

[jira] [Commented] (MINIFI-304) Test Failures manifested by logger initialization failures.

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16016006#comment-16016006
 ] 

ASF GitHub Bot commented on MINIFI-304:
---

Github user apiri commented on the issue:

https://github.com/apache/nifi-minifi-cpp/pull/96
  
Thanks for the rebase.  Ran through the usual battery of stuff and looks 
good.  Will get this merged.


> Test Failures manifested by logger initialization failures. 
> 
>
> Key: MINIFI-304
> URL: https://issues.apache.org/jira/browse/MINIFI-304
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Reporter: marco polo
>Assignee: marco polo
>
> statics within spdlog would not be initialized in time depending on the order 
> of execution. As a result it is better to use no logging unless necessary. 
> There are examples which use logging, but unless explicitly needed ( and 
> captured into strings, for example ) we should instead turn logging off.
> Breaking this out into separate executables would be idea. This ticket will 
> involve editing the cmake file to move tests into a separate file. 



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-304) Test Failures manifested by logger initialization failures.

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015726#comment-16015726
 ] 

ASF GitHub Bot commented on MINIFI-304:
---

Github user apiri commented on the issue:

https://github.com/apache/nifi-minifi-cpp/pull/96
  
@phrocker I got #83 in, would you be able to please rebase this on master? 


> Test Failures manifested by logger initialization failures. 
> 
>
> Key: MINIFI-304
> URL: https://issues.apache.org/jira/browse/MINIFI-304
> Project: Apache NiFi MiNiFi
>  Issue Type: Bug
>  Components: C++
>Reporter: marco polo
>Assignee: marco polo
>
> statics within spdlog would not be initialized in time depending on the order 
> of execution. As a result it is better to use no logging unless necessary. 
> There are examples which use logging, but unless explicitly needed ( and 
> captured into strings, for example ) we should instead turn logging off.
> Breaking this out into separate executables would be idea. This ticket will 
> involve editing the cmake file to move tests into a separate file. 



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Resolved] (MINIFI-226) Provide support for controller services

2017-05-18 Thread Aldrin Piri (JIRA) 

 [ 
https://issues.apache.org/jira/browse/MINIFI-226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aldrin Piri resolved MINIFI-226.

   Resolution: Done
Fix Version/s: cpp-0.3.0

> Provide support for controller services
> ---
>
> Key: MINIFI-226
> URL: https://issues.apache.org/jira/browse/MINIFI-226
> Project: Apache NiFi MiNiFi
>  Issue Type: New Feature
>  Components: C++, Core Framework
>Reporter: Aldrin Piri
>Assignee: marco polo
> Fix For: cpp-0.3.0
>
>
> To facilitate feature parity in the C++ implementation, we should also 
> provided Controller Services to the framework and associated configuration as 
> provided by MINIFI-154 for Java.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Resolved] (MINIFI-253) Make Processors pluggable

2017-05-18 Thread Aldrin Piri (JIRA) 

 [ 
https://issues.apache.org/jira/browse/MINIFI-253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aldrin Piri resolved MINIFI-253.

   Resolution: Done
 Assignee: marco polo
Fix Version/s: cpp-0.3.0

> Make Processors pluggable 
> --
>
> Key: MINIFI-253
> URL: https://issues.apache.org/jira/browse/MINIFI-253
> Project: Apache NiFi MiNiFi
>  Issue Type: Improvement
>  Components: C++
>Reporter: marco polo
>Assignee: marco polo
> Fix For: cpp-0.3.0
>
>
> Processors are currently Hardcoded and created within a large if statement 
> within FlowController. Once processors are contributed and can be removed, we 
> need to have the ability to a pluggable way to inject processors, be it from 
> a shared object, configuration file, or compiled in. 



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-226) Provide support for controller services

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015721#comment-16015721
 ] 

ASF GitHub Bot commented on MINIFI-226:
---

Github user asfgit closed the pull request at:

https://github.com/apache/nifi-minifi-cpp/pull/83


> Provide support for controller services
> ---
>
> Key: MINIFI-226
> URL: https://issues.apache.org/jira/browse/MINIFI-226
> Project: Apache NiFi MiNiFi
>  Issue Type: New Feature
>  Components: C++, Core Framework
>Reporter: Aldrin Piri
>Assignee: marco polo
>
> To facilitate feature parity in the C++ implementation, we should also 
> provided Controller Services to the framework and associated configuration as 
> provided by MINIFI-154 for Java.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-226) Provide support for controller services

2017-05-18 Thread ASF subversion and git services (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015719#comment-16015719
 ] 

ASF subversion and git services commented on MINIFI-226:


Commit c9940e9454b02408a75ac47daae78d99cb9ef13d in nifi-minifi-cpp's branch 
refs/heads/master from Marc Parisi
[ https://git-wip-us.apache.org/repos/asf?p=nifi-minifi-cpp.git;h=c9940e9 ]

MINIFI-226: Add controller services capabilities along with unit tests
Fix test failures
Update Travis YML
Update readme to link to MiNiFi licensing information

MINIFI-253 : Add basic Process Loader capability

This closes #83.

Signed-off-by: Aldrin Piri 


> Provide support for controller services
> ---
>
> Key: MINIFI-226
> URL: https://issues.apache.org/jira/browse/MINIFI-226
> Project: Apache NiFi MiNiFi
>  Issue Type: New Feature
>  Components: C++, Core Framework
>Reporter: Aldrin Piri
>Assignee: marco polo
>
> To facilitate feature parity in the C++ implementation, we should also 
> provided Controller Services to the framework and associated configuration as 
> provided by MINIFI-154 for Java.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[jira] [Commented] (MINIFI-253) Make Processors pluggable

2017-05-18 Thread ASF subversion and git services (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015720#comment-16015720
 ] 

ASF subversion and git services commented on MINIFI-253:


Commit c9940e9454b02408a75ac47daae78d99cb9ef13d in nifi-minifi-cpp's branch 
refs/heads/master from Marc Parisi
[ https://git-wip-us.apache.org/repos/asf?p=nifi-minifi-cpp.git;h=c9940e9 ]

MINIFI-226: Add controller services capabilities along with unit tests
Fix test failures
Update Travis YML
Update readme to link to MiNiFi licensing information

MINIFI-253 : Add basic Process Loader capability

This closes #83.

Signed-off-by: Aldrin Piri 


> Make Processors pluggable 
> --
>
> Key: MINIFI-253
> URL: https://issues.apache.org/jira/browse/MINIFI-253
> Project: Apache NiFi MiNiFi
>  Issue Type: Improvement
>  Components: C++
>Reporter: marco polo
>
> Processors are currently Hardcoded and created within a large if statement 
> within FlowController. Once processors are contributed and can be removed, we 
> need to have the ability to a pluggable way to inject processors, be it from 
> a shared object, configuration file, or compiled in. 



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

[4/5] nifi-minifi-cpp git commit: MINIFI-226: Add controller services capabilities along with unit tests Fix test failures Update Travis YML Update readme to link to MiNiFi licensing information

2017-05-18 Thread aldrin 
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/c9940e94/libminifi/include/core/controller/ControllerServiceProvider.h
--
diff --git a/libminifi/include/core/controller/ControllerServiceProvider.h 
b/libminifi/include/core/controller/ControllerServiceProvider.h
new file mode 100644
index 000..a749475
--- /dev/null
+++ b/libminifi/include/core/controller/ControllerServiceProvider.h
@@ -0,0 +1,306 @@
+/**
+ *
+ * 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.
+ */
+#ifndef LIBMINIFI_INCLUDE_CORE_CONTROLLER_CONTROLLERSERVICEPROVIDER_H_
+#define LIBMINIFI_INCLUDE_CORE_CONTROLLER_CONTROLLERSERVICEPROVIDER_H_
+
+#include 
+#include "core/Core.h"
+#include "ControllerServiceLookup.h"
+#include "core/ConfigurableComponent.h"
+#include "ControllerServiceNode.h"
+#include "ControllerServiceMap.h"
+#include "core/ClassLoader.h"
+
+namespace org {
+namespace apache {
+namespace nifi {
+namespace minifi {
+namespace core {
+namespace controller {
+
+class ControllerServiceProvider : public CoreComponent,
+public ConfigurableComponent, public ControllerServiceLookup {
+ public:
+
+  explicit ControllerServiceProvider(const std::string )
+  : CoreComponent(name),
+ConfigurableComponent(logging::Logger::getLogger()) {
+controller_map_ = std::make_shared();
+  }
+
+  explicit ControllerServiceProvider(
+  std::shared_ptr services)
+  : CoreComponent(core::getClassName()),
+ConfigurableComponent(logging::Logger::getLogger()),
+controller_map_(services) {
+  }
+
+  explicit ControllerServiceProvider(
+  const std::string , std::shared_ptr services)
+  : CoreComponent(name),
+ConfigurableComponent(logging::Logger::getLogger()),
+controller_map_(services) {
+  }
+
+  explicit ControllerServiceProvider(const ControllerServiceProvider &)
+  : CoreComponent(std::move(other)),
+ConfigurableComponent(std::move(other)),
+controller_map_(std::move(other.controller_map_)) {
+  }
+
+  virtual ~ControllerServiceProvider() {
+  }
+
+  /**
+   * Creates a controller service node wrapping the controller service
+   *
+   * @param type service type.
+   * @param id controller service identifier.
+   * @return shared pointer to the controller service node.
+   */
+  virtual std::shared_ptr createControllerService(
+  const std::string , const std::string ,
+  bool firstTimeAdded) = 0;
+  /**
+   * Gets a controller service node wrapping the controller service
+   *
+   * @param type service type.
+   * @param id controller service identifier.
+   * @return shared pointer to the controller service node.
+   */
+  virtual std::shared_ptr getControllerServiceNode(
+  const std::string ) {
+return controller_map_->getControllerServiceNode(id);
+  }
+
+  /**
+   * Removes a controller service.
+   * @param serviceNode controller service node.
+   */
+  virtual void removeControllerService(
+  const std::shared_ptr ) {
+controller_map_->removeControllerService(serviceNode);
+  }
+
+  /**
+   * Enables the provided controller service
+   * @param serviceNode controller service node.
+   */
+  virtual void enableControllerService(
+  std::shared_ptr ) = 0;
+
+  /**
+   * Enables the provided controller service nodes
+   * @param serviceNode controller service node.
+   */
+  virtual void enableControllerServices(
+  std::vector 
serviceNodes) = 0;
+
+  /**
+   * Disables the provided controller service node
+   * @param serviceNode controller service node.
+   */
+  virtual void disableControllerService(
+  std::shared_ptr ) = 
0;
+
+  /**
+   * Gets a list of all controller services.
+   */
+  virtual 
std::vector 
getAllControllerServices() {
+return controller_map_->getAllControllerServices();
+  }
+
+  /**
+   * Verifies that referencing components can be stopped for the controller 
service
+   */
+  virtual void verifyCanStopReferencingComponents(
+  std::shared_ptr ) = 
0;
+
+  /**
+   *  Unschedules referencing components.
+   */
+  virtual 
std::vector 
unscheduleReferencingComponents(
+  std::shared_ptr ) = 
0;
+
+  /**
+   *

[1/5] nifi-minifi-cpp git commit: MINIFI-226: Add controller services capabilities along with unit tests Fix test failures Update Travis YML Update readme to link to MiNiFi licensing information

2017-05-18 Thread aldrin 
Repository: nifi-minifi-cpp
Updated Branches:
  refs/heads/master 372f2d6f8 -> c9940e945


http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/c9940e94/libminifi/test/unit/InvokeHTTPTests.cpp
--
diff --git a/libminifi/test/unit/InvokeHTTPTests.cpp 
b/libminifi/test/unit/InvokeHTTPTests.cpp
index 6b96549..0200710 100644
--- a/libminifi/test/unit/InvokeHTTPTests.cpp
+++ b/libminifi/test/unit/InvokeHTTPTests.cpp
@@ -18,13 +18,13 @@
 #include 
 #include 
 #include "FlowController.h"
-#include "ProvenanceTestHelper.h"
 #include "../TestBase.h"
 #include "core/logging/LogAppenders.h"
 #include "core/logging/BaseLogger.h"
 #include "processors/GetFile.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"
@@ -35,7 +35,8 @@ TEST_CASE("HTTPTestsPostNoResourceClaim", "[httptest1]") {
   std::stringstream oss;
   std::unique_ptr outputLogger = std::unique_ptr<
   logging::BaseLogger>(
-  new 
org::apache::nifi::minifi::core::logging::OutputStreamAppender(oss,0));
+  new org::apache::nifi::minifi::core::logging::OutputStreamAppender(oss,
+ 0));
   std::shared_ptr logger = logging::Logger::getLogger();
   logger->updateLogger(std::move(outputLogger));
 
@@ -43,9 +44,7 @@ TEST_CASE("HTTPTestsPostNoResourceClaim", "[httptest1]") {
 
   testController.enableDebug();
 
-
-  std::shared_ptr repo = std::make_shared<
-  TestRepository>();
+  std::shared_ptr repo = std::make_shared();
 
   std::shared_ptr processor = std::make_shared<
   org::apache::nifi::minifi::processors::ListenHTTP>("listenhttp");
@@ -58,26 +57,23 @@ TEST_CASE("HTTPTestsPostNoResourceClaim", "[httptest1]") {
   uuid_t invokehttp_uuid;
   REQUIRE(true == invokehttp->getUUID(invokehttp_uuid));
 
-
   std::shared_ptr connection = std::make_shared<
-  minifi::Connection>(repo,"getfileCreate2Connection");
+  minifi::Connection>(repo, "getfileCreate2Connection");
   connection->setRelationship(core::Relationship("success", "description"));
 
   std::shared_ptr connection2 = std::make_shared<
-  minifi::Connection>(repo,"listenhttp");
+  minifi::Connection>(repo, "listenhttp");
 
   connection2->setRelationship(core::Relationship("No Retry", "description"));
 
   // link the connections so that we can test results at the end for this
   connection->setSource(processor);
 
-
   // link the connections so that we can test results at the end for this
   connection->setDestination(invokehttp);
 
   connection2->setSource(invokehttp);
 
-
   connection2->setSourceUUID(invokehttp_uuid);
   connection->setSourceUUID(processoruuid);
   connection->setDestinationUUID(invokehttp_uuid);
@@ -86,21 +82,23 @@ TEST_CASE("HTTPTestsPostNoResourceClaim", "[httptest1]") {
   invokehttp->addConnection(connection);
   invokehttp->addConnection(connection2);
 
-
   core::ProcessorNode node(processor);
   core::ProcessorNode node2(invokehttp);
 
-  core::ProcessContext context(node, repo);
-  core::ProcessContext context2(node2, repo);
+  std::shared_ptr 
controller_services_provider =
+  nullptr;
+  core::ProcessContext context(node, controller_services_provider, repo);
+  core::ProcessContext context2(node2, controller_services_provider, repo);
   context.setProperty(org::apache::nifi::minifi::processors::ListenHTTP::Port,
   "8685");
-  
context.setProperty(org::apache::nifi::minifi::processors::ListenHTTP::BasePath,
-"/testytesttest");
+  context.setProperty(
+  org::apache::nifi::minifi::processors::ListenHTTP::BasePath,
+  "/testytesttest");
 
-  
context2.setProperty(org::apache::nifi::minifi::processors::InvokeHTTP::Method,
-"POST");
+  context2.setProperty(
+  org::apache::nifi::minifi::processors::InvokeHTTP::Method, "POST");
   context2.setProperty(org::apache::nifi::minifi::processors::InvokeHTTP::URL,
-  "http://localhost:8685/testytesttest;);
+   "http://localhost:8685/testytesttest;);
   core::ProcessSession session();
   core::ProcessSession session2();
 
@@ -125,7 +123,6 @@ TEST_CASE("HTTPTestsPostNoResourceClaim", "[httptest1]") {
   REQUIRE(record == nullptr);
   REQUIRE(records.size() == 0);
 
-
   processor->incrementActiveTasks();
   processor->setScheduledState(core::ScheduledState::RUNNING);
   processor->onTrigger(, );
@@ -142,25 +139,24 @@ TEST_CASE("HTTPTestsPostNoResourceClaim", "[httptest1]") {
   session2.commit();
   records = reporter->getEvents();
 
-
-
   for (provenance::ProvenanceEventRecord *provEventRecord : records) {
 REQUIRE(provEventRecord->getComponentType() == processor->getName());
   }
   std::shared_ptr ffr = session2.get();
   std::string log_attribute_output = oss.str();

[5/5] nifi-minifi-cpp git commit: MINIFI-226: Add controller services capabilities along with unit tests Fix test failures Update Travis YML Update readme to link to MiNiFi licensing information

2017-05-18 Thread aldrin 
MINIFI-226: Add controller services capabilities along with unit tests
Fix test failures
Update Travis YML
Update readme to link to MiNiFi licensing information

MINIFI-253 : Add basic Process Loader capability

This closes #83.

Signed-off-by: Aldrin Piri 


Project: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/commit/c9940e94
Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/tree/c9940e94
Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/diff/c9940e94

Branch: refs/heads/master
Commit: c9940e9454b02408a75ac47daae78d99cb9ef13d
Parents: 372f2d6
Author: Marc Parisi 
Authored: Sat Apr 1 08:20:42 2017 -0400
Committer: Aldrin Piri 
Committed: Thu May 18 08:59:57 2017 -0400

--
 .gitignore  |   3 +-
 .travis.yml |   2 +-
 CMakeLists.txt  |  72 ++--
 README.md   |  31 ++
 libminifi/CMakeLists.txt|   3 +-
 libminifi/include/EventDrivenSchedulingAgent.h  |  10 +-
 libminifi/include/FlowController.h  | 132 +-
 libminifi/include/SchedulingAgent.h |  33 +-
 libminifi/include/ThreadedSchedulingAgent.h |  11 +-
 libminifi/include/TimerDrivenSchedulingAgent.h  |   7 +-
 .../include/controllers/SSLContextService.h | 174 
 libminifi/include/core/ClassLoader.h| 259 
 libminifi/include/core/ConfigurableComponent.h  |  11 +
 libminifi/include/core/ConfigurationFactory.h   |   7 +-
 libminifi/include/core/Connectable.h|  12 +-
 libminifi/include/core/Core.h   |   3 +-
 libminifi/include/core/FlowConfiguration.h  |  31 +-
 libminifi/include/core/ProcessContext.h |  59 ++-
 libminifi/include/core/ProcessGroup.h   |  23 ++
 libminifi/include/core/Property.h   |  29 +-
 libminifi/include/core/Resource.h   |  54 +++
 .../include/core/controller/ControllerService.h | 142 +++
 .../core/controller/ControllerServiceLookup.h   |  89 
 .../core/controller/ControllerServiceMap.h  | 120 ++
 .../core/controller/ControllerServiceNode.h | 133 ++
 .../core/controller/ControllerServiceProvider.h | 306 ++
 .../controller/StandardControllerServiceNode.h  | 107 +
 .../StandardControllerServiceProvider.h | 229 +++
 libminifi/include/core/yaml/YamlConfiguration.h |  54 ++-
 libminifi/include/io/StreamFactory.h|   6 +-
 libminifi/include/io/TLSSocket.h| 197 +
 libminifi/include/io/validation.h   |  14 +-
 libminifi/include/processors/AppendHostInfo.h   |   4 +
 libminifi/include/processors/ExecuteProcess.h   |   3 +
 libminifi/include/processors/GenerateFlowFile.h |   3 +
 libminifi/include/processors/GetFile.h  |   3 +
 libminifi/include/processors/InvokeHTTP.h   |  30 +-
 libminifi/include/processors/ListenHTTP.h   |   6 +-
 libminifi/include/processors/ListenSyslog.h |   3 +
 libminifi/include/processors/LoadProcessors.h   |  34 ++
 libminifi/include/processors/LogAttribute.h |   3 +
 libminifi/include/processors/PutFile.h  |   3 +
 libminifi/include/processors/TailFile.h |   6 +-
 libminifi/include/properties/Configure.h|  11 +-
 libminifi/include/utils/ThreadPool.h| 355 
 libminifi/src/Configure.cpp |  17 +-
 libminifi/src/EventDrivenSchedulingAgent.cpp|   4 +-
 libminifi/src/FlowController.cpp| 233 ++-
 libminifi/src/SchedulingAgent.cpp   |  35 +-
 libminifi/src/ThreadedSchedulingAgent.cpp   |  26 +-
 libminifi/src/TimerDrivenSchedulingAgent.cpp|   4 +-
 libminifi/src/controllers/SSLContextService.cpp | 226 ++
 libminifi/src/core/ClassLoader.cpp  |  70 
 libminifi/src/core/ConfigurableComponent.cpp|  42 +-
 libminifi/src/core/ConfigurationFactory.cpp |  13 +-
 libminifi/src/core/Connectable.cpp  |   6 +-
 libminifi/src/core/FlowConfiguration.cpp|  66 +--
 libminifi/src/core/ProcessGroup.cpp |  16 +
 libminifi/src/core/Processor.cpp|  20 +-
 libminifi/src/core/Property.cpp |  24 +-
 .../core/controller/ControllerServiceNode.cpp   |  49 +++
 .../controller/ControllerServiceProvider.cpp|  50 +++
 .../StandardControllerServiceNode.cpp   |  69 
 libminifi/src/core/yaml/YamlConfiguration.cpp   | 212 +++---
 libminifi/src/processors/GetFile.cpp|   4 +
 libminifi/src/processors/InvokeHTTP.cpp |  75 ++--
 libminifi/test/FlowFileRecordTest.cpp   |  28 --
 libminifi/test/HttpGetIntegrationTest.cpp   | 120 --

[3/5] nifi-minifi-cpp git commit: MINIFI-226: Add controller services capabilities along with unit tests Fix test failures Update Travis YML Update readme to link to MiNiFi licensing information

2017-05-18 Thread aldrin 
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/c9940e94/libminifi/src/controllers/SSLContextService.cpp
--
diff --git a/libminifi/src/controllers/SSLContextService.cpp 
b/libminifi/src/controllers/SSLContextService.cpp
new file mode 100644
index 000..51a7cc4
--- /dev/null
+++ b/libminifi/src/controllers/SSLContextService.cpp
@@ -0,0 +1,226 @@
+/**
+ *
+ * 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.
+ */
+
+#include "controllers/SSLContextService.h"
+#include 
+#include 
+#include 
+#include 
+#include 
+#include "core/Property.h"
+#include "io/validation.h"
+#include "properties/Configure.h"
+namespace org {
+namespace apache {
+namespace nifi {
+namespace minifi {
+namespace controllers {
+
+void SSLContextService::initialize() {
+  if (initialized_)
+return;
+
+  std::lock_guard lock(initialization_mutex_);
+
+  ControllerService::initialize();
+
+  initializeTLS();
+}
+
+std::unique_ptr SSLContextService::createSSLContext() {
+  SSL_library_init();
+  const SSL_METHOD *method;
+
+  OpenSSL_add_all_algorithms();
+  SSL_load_error_strings();
+  method = TLSv1_2_client_method();
+  SSL_CTX *ctx = SSL_CTX_new(method);
+
+  if (SSL_CTX_use_certificate_file(ctx, certificate.c_str(), SSL_FILETYPE_PEM)
+  <= 0) {
+logger_->log_error("Could not create load certificate, error : %s",
+   std::strerror(errno));
+return nullptr;
+  }
+  if (!IsNullOrEmpty(passphrase_)) {
+SSL_CTX_set_default_passwd_cb_userdata(ctx, _);
+SSL_CTX_set_default_passwd_cb(ctx, pemPassWordCb);
+  }
+
+  int retp = SSL_CTX_use_PrivateKey_file(ctx, private_key_.c_str(),
+ SSL_FILETYPE_PEM);
+  if (retp != 1) {
+logger_->log_error("Could not create load private key,%i on %s error : %s",
+   retp, private_key_, std::strerror(errno));
+return nullptr;
+  }
+
+  if (!SSL_CTX_check_private_key(ctx)) {
+logger_->log_error(
+"Private key does not match the public certificate, error : %s",
+std::strerror(errno));
+return nullptr;
+  }
+
+  retp = SSL_CTX_load_verify_locations(ctx, ca_certificate_.c_str(), 0);
+  if (retp == 0) {
+logger_->log_error("Can not load CA certificate, Exiting, error : %s",
+   std::strerror(errno));
+  }
+  return std::unique_ptr(new SSLContext(ctx));
+}
+
+const std::string ::getCertificateFile() {
+  std::lock_guard lock(initialization_mutex_);
+  return certificate;
+}
+
+const std::string ::getPassphrase() {
+  std::lock_guard lock(initialization_mutex_);
+  return passphrase_;
+}
+
+const std::string ::getPassphraseFile() {
+  std::lock_guard lock(initialization_mutex_);
+  return passphrase_file_;
+}
+
+const std::string ::getPrivateKeyFile() {
+  std::lock_guard lock(initialization_mutex_);
+  return private_key_;
+}
+
+const std::string ::getCACertificate() {
+  std::lock_guard lock(initialization_mutex_);
+  return ca_certificate_;
+}
+
+void SSLContextService::onEnable() {
+  valid_ = true;
+  core::Property property("Client Certificate", "Client Certificate");
+  core::Property privKey("Private Key", "Private Key file");
+  core::Property passphrase_prop(
+  "Passphrase", "Client passphrase. Either a file or unencrypted text");
+  core::Property caCert("CA Certificate", "CA certificate file");
+  std::string default_dir;
+  if (nullptr != configuration_)
+  configuration_->get(Configure::nifi_default_directory, default_dir);
+
+  logger_->log_trace("onEnable()");
+
+  if (getProperty(property.getName(), certificate)
+  && getProperty(privKey.getName(), private_key_)) {
+logger_->log_error(
+"Certificate and Private Key PEM file not configured, error: %s.",
+std::strerror(errno));
+
+std::ifstream cert_file(certificate);
+std::ifstream priv_file(private_key_);
+if (!cert_file.good()) {
+  logger_->log_info("%s not good", certificate);
+  std::string test_cert = default_dir + certificate;
+  std::ifstream cert_file_test(test_cert);
+  if (cert_file_test.good()) {
+certificate = test_cert;
+logger_->log_debug("%s now good", certificate);
+  } else {
+

[2/5] nifi-minifi-cpp git commit: MINIFI-226: Add controller services capabilities along with unit tests Fix test failures Update Travis YML Update readme to link to MiNiFi licensing information

2017-05-18 Thread aldrin 
http://git-wip-us.apache.org/repos/asf/nifi-minifi-cpp/blob/c9940e94/libminifi/test/TestExecuteProcess.cpp
--
diff --git a/libminifi/test/TestExecuteProcess.cpp 
b/libminifi/test/TestExecuteProcess.cpp
deleted file mode 100644
index 31509d7..000
--- a/libminifi/test/TestExecuteProcess.cpp
+++ /dev/null
@@ -1,131 +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.
- */
-
-#include 
-#include 
-#include "FlowController.h"
-#include "unit/ProvenanceTestHelper.h"
-#include "core/logging/LogAppenders.h"
-#include "core/logging/BaseLogger.h"
-#include "processors/GetFile.h"
-#include "core/Core.h"
-#include "core/FlowFile.h"
-#include "core/Processor.h"
-#include "core/ProcessContext.h"
-#include "core/ProcessSession.h"
-#include "core/ProcessorNode.h"
-
-int main(int argc, char  **argv)
-{
-
-  std::ostringstream oss;
-  std::unique_ptr outputLogger = std::unique_ptr<
-  logging::BaseLogger>(
-  new org::apache::nifi::minifi::core::logging::OutputStreamAppender(oss,
- 0));
-  std::shared_ptr logger = logging::Logger::getLogger();
-  logger->updateLogger(std::move(outputLogger));
-
-
-  outputLogger = std::unique_ptr(
-new org::apache::nifi::minifi::core::logging::NullAppender());
-logger->updateLogger(std::move(outputLogger));
-
-  std::shared_ptr processor = std::make_shared<
-  org::apache::nifi::minifi::processors::ExecuteProcess>("executeProcess");
-  processor->setMaxConcurrentTasks(1);
-
-  std::shared_ptr test_repo =
-  std::make_shared();
-
-  std::shared_ptr repo =
-  std::static_pointer_cast(test_repo);
-  std::shared_ptr controller = std::make_shared<
-  TestFlowController>(test_repo, test_repo);
-
-  uuid_t processoruuid;
-  assert(true == processor->getUUID(processoruuid));
-
-  std::shared_ptr connection = std::make_shared<
-  minifi::Connection>(test_repo, "executeProcessConnection");
-  connection->setRelationship(core::Relationship("success", "description"));
-
-  // link the connections so that we can test results at the end for this
-  connection->setSource(processor);
-  connection->setDestination(processor);
-
-  connection->setSourceUUID(processoruuid);
-  connection->setDestinationUUID(processoruuid);
-
-  processor->addConnection(connection);
-  assert(processor->getName() == "executeProcess");
-
-  std::shared_ptr record;
-  processor->setScheduledState(core::ScheduledState::RUNNING);
-
-  processor->initialize();
-
-  std::atomic is_ready(false);
-
-  std::vector processor_workers;
-
-  core::ProcessorNode node2(processor);
-  std::shared_ptr contextset = std::make_shared<
-  core::ProcessContext>(node2, test_repo);
-  core::ProcessSessionFactory factory(contextset.get());
-  processor->onSchedule(contextset.get(), );
-
-  for (int i = 0; i < 1; i++) {
-//
-processor_workers.push_back(
-std::thread(
-[processor,test_repo,_ready]()
-{
-  core::ProcessorNode node(processor);
-  std::shared_ptr context = 
std::make_shared(node, test_repo);
-  
context->setProperty(org::apache::nifi::minifi::processors::ExecuteProcess::Command,"sleep
 0.5");
-  
//context->setProperty(org::apache::nifi::minifi::processors::ExecuteProcess::CommandArguments,"
 1 >>" + ss.str());
-  std::shared_ptr session = 
std::make_shared(context.get());
-  while(!is_ready.load(std::memory_order_relaxed)) {
-
-  }
-
-  processor->onTrigger(context.get(), session.get());
-
-}));
-  }
-
-  is_ready.store(true, std::memory_order_relaxed);
-  //is_ready.store(true);
-
-  std::for_each(processor_workers.begin(), processor_workers.end(),
-[](std::thread )
-{
-  t.join();
-});
-
-outputLogger = std::unique_ptr(
-  new org::apache::nifi::minifi::core::logging::NullAppender());
-  logger->updateLogger(std::move(outputLogger));
-
-
-  std::shared_ptr execp 
=
-  std::static_pointer_cast<
-  org::apache::nifi::minifi::processors::ExecuteProcess>(processor);
-

[jira] [Commented] (MINIFI-226) Provide support for controller services

2017-05-18 Thread ASF GitHub Bot (JIRA) 

[ 
https://issues.apache.org/jira/browse/MINIFI-226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16015713#comment-16015713
 ] 

ASF GitHub Bot commented on MINIFI-226:
---

Github user apiri commented on the issue:

https://github.com/apache/nifi-minifi-cpp/pull/83
  
@phrocker Thanks for all the updates.  Build, docs, tests and license stuff 
looks good to go.  Did some testing of flows and verified associated 
functionality.  Will get this merged.  


> Provide support for controller services
> ---
>
> Key: MINIFI-226
> URL: https://issues.apache.org/jira/browse/MINIFI-226
> Project: Apache NiFi MiNiFi
>  Issue Type: New Feature
>  Components: C++, Core Framework
>Reporter: Aldrin Piri
>Assignee: marco polo
>
> To facilitate feature parity in the C++ implementation, we should also 
> provided Controller Services to the framework and associated configuration as 
> provided by MINIFI-154 for Java.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)