opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-30 18:10:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #6960] Added Slot formatting sketch comments (#6961)

Browse Source
This commit is contained in:
mxsm
2023-07-05 11:03:52 +08:00
committed by GitHub
parent 00fc42b8be
commit 4f840afcb0
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/timer/Slot.java
+9 -1
View File
@@ -16,9 +16,17 @@
*/
package org.apache.rocketmq.store.timer;
/**
* Represents a slot of timing wheel. Format:
* ┌────────────┬───────────┬───────────┬───────────┬───────────┐
* │delayed time│ first pos │ last pos │ num │ magic │
* ├────────────┼───────────┼───────────┼───────────┼───────────┤
* │ 8bytes │ 8bytes │ 8bytes │ 4bytes │ 4bytes │
* └────────────┴───────────┴───────────┴───────────┴───────────┘
*/
public class Slot {
public static final short SIZE = 32;
public final long timeMs;
public final long timeMs; //delayed time
public final long firstPos;
public final long lastPos;
public final int num;