Skip to content

Commit c749c6b

Browse files
committed
refactor: clean some code
1 parent 572ef64 commit c749c6b

File tree

3 files changed

+19
-15
lines changed

3 files changed

+19
-15
lines changed

src/legacy/api/EventAPI.cpp

Lines changed: 17 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,9 @@ void EnableEventListener(int eventId) {
161161

162162
case EVENT_TYPES::onLeft:
163163
bus.emplaceListener<PlayerLeaveEvent>([](PlayerLeaveEvent& ev) {
164-
IF_LISTENED(EVENT_TYPES::onLeft) { CallEventVoid(EVENT_TYPES::onLeft, PlayerClass::newPlayer(&ev.self())); }
164+
IF_LISTENED(EVENT_TYPES::onLeft) {
165+
CallEventUncancelable(EVENT_TYPES::onLeft, PlayerClass::newPlayer(&ev.self()));
166+
}
165167
IF_LISTENED_END(EVENT_TYPES::onLeft);
166168
});
167169
break;
@@ -181,7 +183,7 @@ void EnableEventListener(int eventId) {
181183
case EVENT_TYPES::onPlayerSwing:
182184
bus.emplaceListener<PlayerSwingEvent>([](PlayerSwingEvent& ev) {
183185
IF_LISTENED(EVENT_TYPES::onPlayerSwing) {
184-
CallEventVoid(EVENT_TYPES::onPlayerSwing, PlayerClass::newPlayer(&ev.self()));
186+
CallEventUncancelable(EVENT_TYPES::onPlayerSwing, PlayerClass::newPlayer(&ev.self()));
185187
}
186188
IF_LISTENED_END(EVENT_TYPES::onPlayerSwing);
187189
});
@@ -211,7 +213,7 @@ void EnableEventListener(int eventId) {
211213
Actor* source = ll::service::getLevel()
212214
->getDimension(ev.self().getDimensionId())
213215
->fetchEntity(ev.source().getEntityUniqueID(), false);
214-
CallEventVoid(
216+
CallEventUncancelable(
215217
EVENT_TYPES::onPlayerDie,
216218
PlayerClass::newPlayer(&ev.self()),
217219
(source ? EntityClass::newEntity(source) : Local<Value>())
@@ -224,7 +226,7 @@ void EnableEventListener(int eventId) {
224226
case EVENT_TYPES::onRespawn:
225227
bus.emplaceListener<ll::event::PlayerRespawnEvent>([](ll::event::PlayerRespawnEvent& ev) {
226228
IF_LISTENED(EVENT_TYPES::onRespawn) {
227-
CallEventVoid(EVENT_TYPES::onRespawn, PlayerClass::newPlayer(&ev.self()));
229+
CallEventUncancelable(EVENT_TYPES::onRespawn, PlayerClass::newPlayer(&ev.self()));
228230
}
229231
IF_LISTENED_END(EVENT_TYPES::onRespawn)
230232
});
@@ -284,7 +286,7 @@ void EnableEventListener(int eventId) {
284286
case EVENT_TYPES::afterPlaceBlock:
285287
bus.emplaceListener<PlayerPlacedBlockEvent>([](PlayerPlacedBlockEvent& ev) {
286288
IF_LISTENED(EVENT_TYPES::afterPlaceBlock) {
287-
CallEventVoid(
289+
CallEventUncancelable(
288290
EVENT_TYPES::afterPlaceBlock,
289291
PlayerClass::newPlayer(&ev.self()),
290292
BlockClass::newBlock(ev.pos(), ev.self().getDimensionId())
@@ -307,7 +309,9 @@ void EnableEventListener(int eventId) {
307309

308310
case EVENT_TYPES::onJump:
309311
bus.emplaceListener<PlayerJumpEvent>([](PlayerJumpEvent& ev) {
310-
IF_LISTENED(EVENT_TYPES::onJump) { CallEventVoid(EVENT_TYPES::onJump, PlayerClass::newPlayer(&ev.self())); }
312+
IF_LISTENED(EVENT_TYPES::onJump) {
313+
CallEventUncancelable(EVENT_TYPES::onJump, PlayerClass::newPlayer(&ev.self()));
314+
}
311315
IF_LISTENED_END(EVENT_TYPES::onJump);
312316
});
313317
break;
@@ -426,7 +430,7 @@ void EnableEventListener(int eventId) {
426430
case EVENT_TYPES::onChangeSprinting:
427431
bus.emplaceListener<PlayerSprintingEvent>([](PlayerSprintingEvent& ev) {
428432
IF_LISTENED(EVENT_TYPES::onChangeSprinting) {
429-
CallEventVoid(
433+
CallEventUncancelable(
430434
EVENT_TYPES::onChangeSprinting,
431435
PlayerClass::newPlayer(&ev.self()),
432436
Boolean::newBoolean(true)
@@ -436,7 +440,7 @@ void EnableEventListener(int eventId) {
436440
});
437441
bus.emplaceListener<PlayerSprintedEvent>([](PlayerSprintedEvent& ev) {
438442
IF_LISTENED(EVENT_TYPES::onChangeSprinting) {
439-
CallEventVoid(
443+
CallEventUncancelable(
440444
EVENT_TYPES::onChangeSprinting,
441445
PlayerClass::newPlayer(&ev.self()),
442446
Boolean::newBoolean(false)
@@ -625,7 +629,7 @@ void EnableEventListener(int eventId) {
625629
if (ev.source().isChildEntitySource()) source = source->getOwner();
626630
}
627631

628-
CallEventVoid(
632+
CallEventUncancelable(
629633
EVENT_TYPES::onMobDie,
630634
EntityClass::newEntity(&ev.self()),
631635
(source ? EntityClass::newEntity(source) : Local<Value>()),
@@ -750,7 +754,7 @@ void EnableEventListener(int eventId) {
750754
case EVENT_TYPES::onBlockChanged:
751755
bus.emplaceListener<BlockChangedEvent>([](BlockChangedEvent& ev) {
752756
IF_LISTENED(EVENT_TYPES::onBlockChanged) {
753-
CallEventVoid(
757+
CallEventUncancelable(
754758
EVENT_TYPES::onBlockChanged,
755759
BlockClass::newBlock(&ev.previousBlock(), &ev.pos(), &ev.blockSource()),
756760
BlockClass::newBlock(&ev.newBlock(), &ev.pos(), &ev.blockSource())
@@ -790,7 +794,7 @@ void EnableEventListener(int eventId) {
790794
);
791795
bus.emplaceListener<SpawningMobEvent>([](SpawningMobEvent& ev) {
792796
IF_LISTENED(EVENT_TYPES::onMobSpawn) {
793-
CallEventVoid(
797+
CallEventUncancelable(
794798
EVENT_TYPES::onMobSpawn,
795799
String::newString(ev.identifier().getFullName()),
796800
FloatPos::newPos(ev.pos(), ev.blockSource().getDimensionId())
@@ -803,7 +807,7 @@ void EnableEventListener(int eventId) {
803807
case EVENT_TYPES::onMobTrySpawn:
804808
bus.emplaceListener<SpawningMobEvent>([](SpawningMobEvent& ev) {
805809
IF_LISTENED(EVENT_TYPES::onMobTrySpawn) {
806-
CallEventVoid(
810+
CallEvent(
807811
EVENT_TYPES::onMobTrySpawn,
808812
String::newString(ev.identifier().getFullName()),
809813
FloatPos::newPos(ev.pos(), ev.blockSource().getDimensionId())
@@ -816,7 +820,7 @@ void EnableEventListener(int eventId) {
816820
case EVENT_TYPES::onMobSpawned:
817821
bus.emplaceListener<SpawnedMobEvent>([](SpawnedMobEvent& ev) {
818822
IF_LISTENED(EVENT_TYPES::onMobSpawned) {
819-
CallEventVoid(
823+
CallEventUncancelable(
820824
EVENT_TYPES::onMobSpawned,
821825
EntityClass::newEntity(ev.mob().has_value() ? ev.mob().as_ptr() : nullptr),
822826
FloatPos::newPos(ev.pos(), ev.blockSource().getDimensionId())

src/legacy/engine/LocalShareData.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ std::vector<RegCmdQueue> toRegCmdQueue;
1414
// 线程池
1515
ll::thread::ThreadPool pool(LLSE_POOL_THREAD_COUNT);
1616

17-
std::mutex messageLoopLock;
17+
// std::mutex messageLoopLock;
1818

1919
void InitLocalShareData() {
2020
srand(clock());

src/legacy/engine/LocalShareData.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ extern std::vector<RegCmdQueue> toRegCmdQueue;
5656
// 线程池
5757
extern ll::thread::ThreadPool pool;
5858

59-
extern std::mutex messageLoopLock;
59+
// extern std::mutex messageLoopLock;
6060

6161
//////////////////// APIs ////////////////////
6262

0 commit comments

Comments
 (0)