GitHub user shoukunhuai opened a pull request:
https://github.com/apache/activemq-artemis/pull/1742
ARTEMIS-1570 Flush appendExecutor before take journal snapshot
When live start replication, it must make sure there is
no pending write in message & bindings journal, or we
Github user shoukunhuai commented on the issue:
https://github.com/apache/activemq-artemis/pull/1742
@clebertsuconic That will be great if we can avoid wait.
Please do not merge, i will push my test.
---
Github user shoukunhuai commented on the issue:
https://github.com/apache/activemq-artemis/pull/1742
@clebertsuconic just pushed my test for your reference.
---
GitHub user shoukunhuai opened a pull request:
https://github.com/apache/activemq-artemis/pull/1747
[WIP] NO-JIRA DISCUSS Replica use operationcontext
This PR is used to discuss using `OperationContext` on backup side.
The original implementation of `ReplicationEndpoint
Github user shoukunhuai commented on the issue:
https://github.com/apache/activemq-artemis/pull/1747
@michaelandrepearce we want the guarantee that when we response to client,
any journal is wrote to both live and backup.
Say we set both syncNonTransactional and
Github user shoukunhuai closed the pull request at:
https://github.com/apache/activemq-artemis/pull/1747
---
Github user shoukunhuai commented on the issue:
https://github.com/apache/activemq-artemis/pull/1747
@jbertram sure, i will close it, and thanks all.
---
Github user shoukunhuai commented on the issue:
https://github.com/apache/activemq-artemis/pull/1742
@clebertsuconic sorry, almost forgot this, being busy on something else.
Looks like this issue was resolved?
---
GitHub user shoukunhuai opened a pull request:
https://github.com/apache/activemq-artemis/pull/1827
Improve paged message acknowledge
Cache `messageID`, `transactionID` and `isLargeMessage`
in PagedReference, so that when acknowledge, we do not have to
get
Github user shoukunhuai commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1827#discussion_r165050956
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/RefsOperation.java
---
@@ -152,14 +153,14 @@ protected
Github user shoukunhuai commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1827#discussion_r165284853
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/MessageReference.java
---
@@ -38,6 +38,10 @@ public static
Github user shoukunhuai commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1827#discussion_r16574
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/RefsOperation.java
---
@@ -152,14 +153,14 @@ protected
Github user shoukunhuai commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1827#discussion_r165955062
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/MessageReference.java
---
@@ -38,6 +38,10 @@ public static
Github user shoukunhuai commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1827#discussion_r165955807
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/RefsOperation.java
---
@@ -152,14 +153,14 @@ protected
Github user shoukunhuai commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1894#discussion_r170405082
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
Github user shoukunhuai commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1894#discussion_r170405300
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
Github user shoukunhuai commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1894#discussion_r170405747
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
Github user shoukunhuai commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1894#discussion_r170407785
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
Github user shoukunhuai commented on the issue:
https://github.com/apache/activemq-artemis/pull/1899
So it is a mistake to use global thread pool instead of io thread pool for
page cursor.
But this does not fix our problem, as you can see
```
"Thread-2
GitHub user shoukunhuai opened a pull request:
https://github.com/apache/activemq-artemis/pull/1929
ARTEMIS-1728 Reclaim memory when page cursor complete
Free hash set used to hold page position for acks and removed refs.
The two set is cleared, but they still hold a big array
20 matches
Mail list logo
