View Issue Details

IDProjectCategoryView StatusLast Update
0006057SymmetricDSImprovementpublic2024-01-08 18:36
Reporterelong Assigned Toelong  
Prioritynormal 
Status closedResolutionfixed 
Product Version3.15.0 
Target Version3.15.1Fixed in Version3.15.1 
Summary0006057: 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 0006055 closedelong Multi-threaded routing by channel 
related to 0006184 closedelong Multi-threaded routing and gap detection 

Activities

There are no notes attached to this issue.

Related Changesets

SymmetricDS: 3.15 2688b2e2

2023-10-26 12:42:23

admin

Details Diff
0006057: Multi-threaded routing by channel Affected Issues
0006057
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.15 bfaccd01

2023-11-02 18:33:25

admin

Details Diff
0006057: fix conflict win marker from becoming a gap Affected Issues
0006057
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/route/ChannelRouterContext.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PurgeService.java Diff File
mod - symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java Diff File
add - symmetric-core/src/test/java/org/jumpmind/symmetric/service/impl/PurgeServiceTest.java Diff File

Issue History

Date Modified Username Field Change
2023-10-26 12:43 elong New Issue
2023-10-26 12:43 elong Status new => assigned
2023-10-26 12:43 elong Assigned To => elong
2023-10-26 12:43 elong Tag Attached: routing
2023-10-26 12:43 elong Issue generated from: 0006055
2023-10-26 12:43 elong Relationship added related to 0006055
2023-10-26 12:45 elong Status assigned => resolved
2023-10-26 12:45 elong Resolution open => fixed
2023-10-26 12:45 elong Fixed in Version => 3.15.1
2023-10-26 13:00 admin Changeset attached => SymmetricDS 3.15 2688b2e2
2023-11-02 19:00 admin Changeset attached => SymmetricDS 3.15 bfaccd01
2023-11-14 21:10 admin Status resolved => closed
2024-01-08 18:25 elong Project SymmetricDS Pro => SymmetricDS
2024-01-08 18:36 elong Relationship added related to 0006184