dapan1121
|
e527f2fd0b
|
fix: validate function return value
|
2024-07-12 15:22:39 +08:00 |
Haojun Liao
|
c71413c2aa
|
fix(stream): discard the repeat send consensus-checkpointId msg.
|
2024-07-09 14:52:15 +08:00 |
|
Haojun Liao
|
50a2ef08bd
|
fix(stream): update some logs.
|
2024-07-08 17:10:34 +08:00 |
|
Haojun Liao
|
56b7ec3d89
|
fix(stream): update some logs.
|
2024-07-08 15:10:00 +08:00 |
|
Haojun Liao
|
6e15c16cf7
|
fix(stream): check the set consensus-checkpointId ts.
|
2024-07-08 14:33:28 +08:00 |
|
Haojun Liao
|
647f9f47ef
|
refactor: do some internal refactor.
|
2024-07-08 10:32:23 +08:00 |
|
Haojun Liao
|
ce4153b6fc
|
fix(stream): use hb to send the consens-checkpointid req.
|
2024-07-08 09:05:33 +08:00 |
|
Haojun Liao
|
8e6bb176c2
|
fix(stream): use trans to set the consensus-checkpoint id
|
2024-07-05 16:17:20 +08:00 |
|
Haojun Liao
|
653f7a1a43
|
fix(stream): refactor the checkpoint consensus policy.
|
2024-07-04 13:55:50 +08:00 |
|
Haojun Liao
|
27cb3638c2
|
fix(stream): add more check before launching update stream task nodeEp
|
2024-07-03 09:20:37 +08:00 |
|
Haojun Liao
|
c73a003ee3
|
fix(stream): set the initial checkpointId for a new created stream.
|
2024-07-02 19:13:20 +08:00 |
|
Haojun Liao
|
c7d4f45b7f
|
fix(stream): remove invalid assert.
|
2024-07-02 15:33:25 +08:00 |
|
Haojun Liao
|
025437df0c
|
fix(stream): fix error in checkpoint consensus.
|
2024-06-27 19:25:18 +08:00 |
|
Haojun Liao
|
1818edcb2b
|
fix(stream): consensus the start checkpoint id, and extract the streamhb related functions into a new file.
|
2024-06-26 10:18:32 +08:00 |
|
Haojun Liao
|
d06e1549f1
|
fix(stream): add fill-history task id in msg.
|
2024-06-12 15:27:19 +08:00 |
|
Haojun Liao
|
dc2497791a
|
fix(stream): accept invalid vgroup id error code when handling the update checkpoint info.
|
2024-06-12 10:11:55 +08:00 |
|
Haojun Liao
|
3b537367c9
|
fix(stream): fix memory leak.
|
2024-06-11 15:21:48 +08:00 |
|
Haojun Liao
|
d6e252513e
|
fix(stream):fix syntax error.
|
2024-06-11 14:33:59 +08:00 |
|
Haojun Liao
|
0245d82e54
|
fix(stream): make sure that the unit test case can work.
|
2024-06-11 14:26:29 +08:00 |
|
Haojun Liao
|
00eb621825
|
fix(stream): do scan checkpoint-report in write queue.
|
2024-06-11 14:09:50 +08:00 |
|
Haojun Liao
|
68aac5dee1
|
other: fix syntax error.
|
2024-06-11 11:12:24 +08:00 |
|
Haojun Liao
|
cbf8b363fc
|
fix(stream): update checkpoint info by using trans.
|
2024-06-10 00:46:01 +08:00 |
|
Haojun Liao
|
d0675a660e
|
fix(stream): init the node list and task list when starting mnode.
|
2024-06-07 17:53:53 +08:00 |
|
Haojun Liao
|
34205ba62c
|
refactor: do some internal refactor.
|
2024-06-07 10:09:40 +08:00 |
|
Haojun Liao
|
88e77d6bc6
|
fix(stream): remove expired stream in buf.
|
2024-06-06 23:54:48 +08:00 |
|
Haojun Liao
|
29648be30d
|
fix(stream): add the new node info when adding stream tasks.
|
2024-06-04 23:28:08 +08:00 |
|
Haojun Liao
|
ee4e4c0e6d
|
refactor: do some internal refactor.
|
2024-05-31 09:17:20 +08:00 |
|
Haojun Liao
|
fabb986aa8
|
fix(stream): fix stack overflow, caused by print epset.
|
2024-04-10 19:54:33 +08:00 |
|
Haojun Liao
|
3de1413974
|
test(stream): add some test cases to inc coverage.
|
2024-03-08 13:38:51 +08:00 |
|
Haojun Liao
|
cdfbbc2985
|
fix(stream): set the dest epset from mnode, and set the retry error code for trans.
|
2024-03-05 13:28:34 +08:00 |
|
Haojun Liao
|
03bc2d7c6d
|
test(stream): add unit test cases.
|
2024-02-20 10:27:02 +08:00 |
|
Haojun Liao
|
739485a419
|
test(stream): add unit test case for the mnode stream module.
|
2024-02-05 09:10:04 +08:00 |
|
Haojun Liao
|
11c9c7d936
|
refactor: do some internal refactor.
|
2024-01-30 09:17:02 +08:00 |
|
Haojun Liao
|
b714c70434
|
refactor: do some internal refactor.
|
2024-01-29 13:46:33 +08:00 |
|
Haojun Liao
|
9087a0d9d0
|
feat(stream): drop orphan tasks.
|
2024-01-29 11:03:50 +08:00 |
|
Haojun Liao
|
9b3b03caab
|
refactor: do some internal refactor.
|
2024-01-26 10:22:16 +08:00 |
|
Haojun Liao
|
bd1d1cddaf
|
refactor: do some internal refactor.
|
2024-01-26 10:03:54 +08:00 |
|
Haojun Liao
|
43c035678f
|
refactor: do some internal refactor.
|
2024-01-25 16:55:05 +08:00 |