Skip to content

MINIFICPP-1388 Introduce buffer for HTTP requests in ListenHTTP processor#921

Closed
lordgamez wants to merge 11 commits intoapache:mainfrom
lordgamez:listenhttp_buffer
Closed

MINIFICPP-1388 Introduce buffer for HTTP requests in ListenHTTP processor#921
lordgamez wants to merge 11 commits intoapache:mainfrom
lordgamez:listenhttp_buffer

Conversation

@lordgamez
Copy link
Contributor

Issue: https://issues.apache.org/jira/browse/MINIFICPP-1388


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 MINIFICPP-XXXX where XXXX 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 main)?

  • 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?
  • 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 GitHub Actions CI results for build issues and submit an update to your PR as soon as possible.

Copy link
Member

@szaszm szaszm left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I like your creative solution to testing the internal batching.

@lordgamez lordgamez marked this pull request as ready for review October 13, 2020 09:18
Copy link
Contributor

@fgerlits fgerlits left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks fine overall, added some suggestions.

std::unique_ptr<CivetServer> server_;
std::unique_ptr<Handler> handler_;
std::string listeningPort;
std::size_t batch_size_;
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I know it will be set in onSchedule(), but I think it would be better to initialize batch_size_, either here or in the constructor.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Fixed in 7813ee3

handler_.reset(new Handler(basePath, context, sessionFactory, std::move(authDNPattern), std::move(headersAsAttributesPattern)));

context->getProperty(BatchSize.getName(), batch_size_);
logger_->log_debug("ListenHTTP using %s: %d", BatchSize.getName(), batch_size_);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

this should be %zu, too

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Fixed in 7813ee3

@szaszm szaszm closed this in 7ed1a1c Oct 26, 2020
@lordgamez lordgamez deleted the listenhttp_buffer branch March 1, 2021 10:28
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants