Skip to content
This repository has been archived by the owner on Aug 2, 2022. It is now read-only.

amqp_trx_plugin - transaction in, transaction_trace out #9181

Merged
merged 67 commits into from
Jun 22, 2020
Merged
Changes from 1 commit
Commits
Show all changes
67 commits
Select commit Hold shift + click to select a range
bb48710
WIP: initial outline of rabbitmq_trx_plugin
heifner May 18, 2020
96d520e
WIP: first cut at publish
heifner May 18, 2020
176d598
WIP: Add publish of drop of trx"
heifner May 18, 2020
b8654a2
WIP: Adding support to cleos
heifner May 19, 2020
d5e591d
Merge remote-tracking branch 'origin/develop' into rabbitmq-trx-dev
heifner May 22, 2020
a5d81c1
Simplify unpacking of message
heifner May 22, 2020
5e27754
Change logging and add quit() on error
heifner May 22, 2020
2b1f167
Add simple support for trx/trace rabbitmq
heifner May 22, 2020
3abc4dd
Merge remote-tracking branch 'origin/develop' into rabbitmq-trx-dev
heifner May 26, 2020
08e4a4f
Make rabbitmq exchange configurable
heifner May 26, 2020
ee0bb75
Implement rabbitmq_publish_all_traces option
heifner May 26, 2020
5627b0a
Use nomenclature AMQP instead of RabbitMQ
heifner May 27, 2020
a5b3f02
Add ability to test with rabbitmq
heifner May 28, 2020
36ca869
destroy amqp before thread_pool to fix crash. ack consumed traces.
heifner May 29, 2020
1e7d097
Better shutdown logic
heifner May 29, 2020
7d28362
Add integration test for rabbitmq
heifner May 29, 2020
d94fac9
Merge remote-tracking branch 'origin/develop' into rabbitmq-trx-dev
heifner May 29, 2020
5080366
Add new amqp_trx logger to example logging.json
heifner May 29, 2020
1be90c7
Turn on debug level logging for launcher for trace_api and ampq_trx l…
heifner May 29, 2020
dc19fed
Add support for empty "" default value
heifner May 29, 2020
ef410ef
Revert "Merge pull request #9134 from EOSIO/test-framework-archiving"
heifner May 29, 2020
f8116cc
Revert "Revert "Merge pull request #9134 from EOSIO/test-framework-ar…
heifner Jun 1, 2020
0dd804d
Populate amqp connection string and conditionally run rabbitmq test
parrinc Jun 3, 2020
8a4b06d
Merge branch 'develop-boxed' into rabbitmq-trx-dev
heifner Jun 4, 2020
754a9ee
Merge branch 'develop-boxed' into rabbitmq-trx-dev
heifner Jun 5, 2020
ef104ae
Drain application queue before disconnecting from transction singal
heifner Jun 5, 2020
299f841
Re-work shutdown logic
heifner Jun 5, 2020
e7a4d16
Don't ack message as other consumers may be interested in the trace
heifner Jun 5, 2020
14f08dd
Temp rm app().quit()
heifner Jun 9, 2020
98c993f
Add some info level logging
heifner Jun 10, 2020
7b01617
ioservice for send
heifner Jun 10, 2020
48026b1
Temp logging of publish result
heifner Jun 10, 2020
4cf9c9b
Revert "ioservice for send"
heifner Jun 11, 2020
eb53f95
Add cerr of amqp publish
heifner Jun 11, 2020
4491a8b
Remove debug output
heifner Jun 11, 2020
cd24672
Initial checkin of amqp_trace_plugin
heifner Jun 11, 2020
c662157
Use amqp_trace_plugin for publish of traces. Address peer review comm…
heifner Jun 11, 2020
8c8c24d
Add new amqp_trace_plugin needed for test
heifner Jun 11, 2020
ea3ca24
trx queue
heifner Jun 11, 2020
44f932d
Make amqp_trace_plugin depend on amqp_trx_plugin
heifner Jun 11, 2020
f08bbc2
Correct check for if amqp is in use
heifner Jun 11, 2020
56db06e
Guard agaisnt getting report of trace twice
heifner Jun 11, 2020
9e177e7
Stop thread pool before destroying amqp objects
heifner Jun 12, 2020
7665a7d
Enable debug level logging of default logger
heifner Jun 12, 2020
7420f95
Add extra debug logging
heifner Jun 12, 2020
a2644a8
Use diff thread pool (io_service) for each amqp as mixing causing issues
heifner Jun 12, 2020
0120831
Work around duplicate message handling in amqp integration test
heifner Jun 12, 2020
5d43e92
Fix description
heifner Jun 16, 2020
d18d39b
Move into same scope as eosio::amqp
heifner Jun 16, 2020
b9b43ec
add rabbit to cicd images
Jun 16, 2020
d03eea1
Merge remote-tracking branch 'origin/develop-boxed' into rabbitmq-trx…
heifner Jun 17, 2020
8b46cd0
Check state of amqp_trace_plugin instead of setting up dependency
heifner Jun 17, 2020
381069d
Remove duplicate code amqp_publish_hander
heifner Jun 17, 2020
7e79625
Verify queue ready before returning
heifner Jun 17, 2020
84ffede
Modify cleos with amqp to only submit trx and not try to report trace
heifner Jun 17, 2020
cd28210
Call declare queue on amqp thread
heifner Jun 18, 2020
3f111d3
Use raw promise to avoid race condition
heifner Jun 18, 2020
fc78974
Always startup amqp_trace_plugin before amqp_trx_plugin if specified
heifner Jun 18, 2020
259da4c
Handle shutdown in case of exception
heifner Jun 18, 2020
0de2a11
Use weak ptr to avoid keeping impl alive after shutdown
heifner Jun 18, 2020
f910787
No coordination between http_plugin posted tasks and amqp_trx_plugin …
heifner Jun 18, 2020
bfd69da
Merge remote-tracking branch 'origin/develop-boxed' into rabbitmq-trx…
heifner Jun 19, 2020
6366fe1
Make sure thread_pool is stopped if exception before amqp destroyed
heifner Jun 19, 2020
6b88873
Refactor amqp handler to encapsoluate thread and provide safer interface
heifner Jun 19, 2020
b8f7acb
Merge remote-tracking branch 'origin/develop' into rabbitmq-trx-dev
heifner Jun 19, 2020
aa67fb5
Merge remote-tracking branch 'origin/develop-boxed' into rabbitmq-trx…
heifner Jun 19, 2020
e3c26d3
Peer review changes and fix problem with multiple calls to stop()
heifner Jun 19, 2020
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Add support for empty "" default value
  • Loading branch information
heifner committed May 29, 2020
commit dc19fed862fb17ff943345098d13eab3ea44e9b0
2 changes: 1 addition & 1 deletion libraries/appbase/application.cpp
Original file line number Diff line number Diff line change
@@ -465,7 +465,7 @@ void application::print_default_config(std::ostream& os) {
else {
// The string is formatted "arg (=<interesting part>)"
example.erase(0, 6);
example.erase(example.length()-1);
if(!example.empty()) example.erase(example.length()-1);
os << "# " << od->long_name() << " = " << example << std::endl;
}
}