View Issue Details

IDProjectCategoryView StatusLast Update
0006055SymmetricDSImprovementpublic2024-01-08 18:25
Reporterelong Assigned Toelong  
Prioritynormal 
Status closedResolutionfixed 
Product Version3.14.0 
Target Version3.14.10Fixed in Version3.14.10 
Summary0006055: Multi-threaded routing by channel
DescriptionCreate a simple, initial implementation to use multiple threads for routing by channel. Use parameters to enable using threads with a limit on how many threads can be running at the same time.

routing.use.channel.threads=false (defaults to false, set to true to enable)
routing.thread.per.server.count=5

The main router service thread will start a thread for each channel that has data, wait for the threads to complete, then finalize the gap detection. The router job will run and repeat the process. The user will need to set max data to route on each channel so that no single channel can hold up the others.
Tagsrouting

Relationships

related to 0006057 closedelong Multi-threaded routing by channel 

Activities

There are no notes attached to this issue.

Related Changesets

SymmetricDS: 3.14 2de9633b

2023-10-26 12:42:23

admin

Details Diff
0006055: Multi-threaded routing by channel Affected Issues
0006055
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromSymDataSource.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/NodeCommunication.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/RemoteNodeStatus.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/model/RemoteNodeStatuses.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/route/ChannelRouterContext.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapFastDetector.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapRouteReader.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/NodeCommunicationService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java Diff File
mod - symmetric-core/src/main/resources/symmetric-default.properties Diff File

SymmetricDS: 3.14 284fa4f8

2023-10-26 15:26:30

admin

Details Diff
0006055: Multi-threaded routing by channel Affected Issues
0006055
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromSymDataSource.java Diff File

SymmetricDS: 3.15 4b56b8a4

2023-10-26 15:26:30

admin

Details Diff
0006055: Multi-threaded routing by channel Affected Issues
0006055
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/extract/SelectFromSymDataSource.java Diff File

Issue History

Date Modified Username Field Change
2023-10-25 20:42 elong New Issue
2023-10-25 20:42 elong Status new => assigned
2023-10-25 20:42 elong Assigned To => elong
2023-10-25 20:42 elong Tag Attached: routing
2023-10-26 12:43 elong Status assigned => resolved
2023-10-26 12:43 elong Resolution open => fixed
2023-10-26 12:43 elong Fixed in Version => 3.14.10
2023-10-26 12:43 elong Issue cloned: 0006057
2023-10-26 12:43 elong Relationship added related to 0006057
2023-10-26 13:00 admin Changeset attached => SymmetricDS 3.14 2de9633b
2023-10-26 16:00 admin Changeset attached => SymmetricDS 3.14 284fa4f8
2023-10-26 16:00 admin Changeset attached => SymmetricDS 3.15 4b56b8a4
2023-10-27 20:06 admin Status resolved => closed
2024-01-08 18:25 elong Project SymmetricDS Pro => SymmetricDS