From b691c43c44ff180d10e7d4a9afc83b98551ff586 Mon Sep 17 00:00:00 2001 From: daoge_cmd <3523206925@qq.com> Date: Sun, 1 Mar 2026 12:16:08 +0800 Subject: Initial commit --- .../Samples/MultiThreadedHook/IThread.h | 17 ++ .../MultiThreadedHook/MultiThreadedHookSample.cpp | 80 +++++++++ .../Samples/MultiThreadedHook/PS3/Main.cpp | 18 ++ .../PS3/MultiThreadedHookSample.vcproj | 191 +++++++++++++++++++++ .../PS3/MultiThreadedHookSample.vcxproj | 76 ++++++++ .../Samples/MultiThreadedHook/PS3/ThreadPS3.cpp | 41 +++++ .../Samples/MultiThreadedHook/PS3/Wait.cpp | 6 + 7 files changed, 429 insertions(+) create mode 100644 Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/IThread.h create mode 100644 Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/MultiThreadedHookSample.cpp create mode 100644 Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/Main.cpp create mode 100644 Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/MultiThreadedHookSample.vcproj create mode 100644 Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/MultiThreadedHookSample.vcxproj create mode 100644 Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/ThreadPS3.cpp create mode 100644 Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/Wait.cpp (limited to 'Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook') diff --git a/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/IThread.h b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/IThread.h new file mode 100644 index 00000000..9ac6dcf9 --- /dev/null +++ b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/IThread.h @@ -0,0 +1,17 @@ +#ifndef _MULTITHREADEDHOOKSAMPLE_ITHREAD_H_ +#define _MULTITHREADEDHOOKSAMPLE_ITHREAD_H_ + +typedef void(*ThreadFunction)(); + +class IThread +{ +public: + virtual ~IThread() {} + virtual void Fork(ThreadFunction a_Function) = 0; + virtual void Join() = 0; +}; + +IThread* CreateThread(); +void DestroyThread(IThread* a_Thread); + +#endif // _MULTITHREADEDHOOKSAMPLE_ITHREAD_H_ \ No newline at end of file diff --git a/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/MultiThreadedHookSample.cpp b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/MultiThreadedHookSample.cpp new file mode 100644 index 00000000..4c872680 --- /dev/null +++ b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/MultiThreadedHookSample.cpp @@ -0,0 +1,80 @@ +// ================================================================================================================================= +// This sample is more of a show-(and test) case for HeapInspector's. It demonstrates: +// 1) That HeapInspector is multithread safe. +// 2) HeapInspector's ability to deal with allocations prior to Initialise (although those allocations will not be tracked). +// 3) HeapInspector's ability to deal with API calls during static initialisation phase. +// +// In this sample, multiple threads are started that perform allocations for a set period of time. The +// application will wait for those threads to finish. After the time is passed and the application calls Shutdown, +// the client will disconnect. +// +// To switch between launching the threads during the static initalisation phase and launching the treads +// in main, flip the INIT_IN_STATIC_PHASE define. +// +// ================================================================================================================================= + +#include "IThread.h" +#include + +void Wait(int a_MilliSeconds); + +#define INIT_IN_STATIC_PHASE 0 +const int g_NumThreads = 4; + +class MultiThreadedAllocator +{ +public: + static void WorkerThread() + { + for (int i = 0; i != 1000; ++i) + { + void* mem1 = malloc(10); + Wait(10); + free(mem1); + Wait(10); + } + } + + MultiThreadedAllocator() + { + for (int i = 0; i != g_NumThreads; ++i) + { + m_Threads[i] = CreateThread(); + m_Threads[i]->Fork(WorkerThread); + } + } + + ~MultiThreadedAllocator() + { + WaitForThreads(); + for (int i = 0; i != g_NumThreads; ++i) + { + DestroyThread(m_Threads[i]); + } + } + +private: + void WaitForThreads() + { + for (int i = 0; i != g_NumThreads; ++i) + { + m_Threads[i]->Join(); + } + } + +private: + IThread* m_Threads[g_NumThreads]; +}; + +#if INIT_IN_STATIC_PHASE +static MultiThreadedAllocator* g_Allocator = new MultiThreadedAllocator(); +#endif + +void RunHeapInspectorServer() +{ +#if !INIT_IN_STATIC_PHASE + MultiThreadedAllocator* g_Allocator = new MultiThreadedAllocator(); +#endif + + delete g_Allocator; +} diff --git a/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/Main.cpp b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/Main.cpp new file mode 100644 index 00000000..e3417e42 --- /dev/null +++ b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/Main.cpp @@ -0,0 +1,18 @@ +#include "../../../Server/HeapInspectorServer.h" +#include "../../../Server/PS3/HeapHooks.hpp" + +void RunHeapInspectorServer(); + +extern "C" void* __real__malloc_init(); +extern "C" void* __wrap__malloc_init() +{ + void* result = __real__malloc_init(); + Initialise(HeapInspectorServer::GetDefaultHeapInfo(), 3000, HeapInspectorServer::WaitForConnection_Enabled); + return result; +} + +int main(int /*a_ArgC*/, const char* /*a_ArgV[]*/) +{ + RunHeapInspectorServer(); + HeapInspectorServer::Shutdown(); +} diff --git a/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/MultiThreadedHookSample.vcproj b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/MultiThreadedHookSample.vcproj new file mode 100644 index 00000000..76c17590 --- /dev/null +++ b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/MultiThreadedHookSample.vcproj @@ -0,0 +1,191 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/MultiThreadedHookSample.vcxproj b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/MultiThreadedHookSample.vcxproj new file mode 100644 index 00000000..69d3882c --- /dev/null +++ b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/MultiThreadedHookSample.vcxproj @@ -0,0 +1,76 @@ + + + + + Debug + PS3 + + + Release + PS3 + + + + + + + + + + + + + {E9BC25AD-CFFD-43B6-ABEC-CA516CADD296} + + + + Application + GCC + + + Application + GCC + + + + + + + + + + + + + $(ProjectDir)$(Platform)_$(Configuration)_VS2010\ + $(Platform)_$(Configuration)_VS2010\ + + + $(ProjectDir)$(Platform)_$(Configuration)_VS2010\ + $(Platform)_$(Configuration)_VS2010\ + + + + _DEBUG;__CELL_ASSERT__;%(PreprocessorDefinitions);;HEAPINSPECTOR_PS3=1 + true + + + "$(SCE_PS3_ROOT)\target\ppu\lib\libm.a";"$(SCE_PS3_ROOT)\target\ppu\lib\libio_stub.a";"..\..\..\Server\PS3\Debug\libHeapInspectorServer.a";"$(SCE_PS3_ROOT)\target\ppu\lib\libpthread.a";"$(SCE_PS3_ROOT)\target\ppu\lib\libnet_stub.a";"$(SCE_PS3_ROOT)\target\ppu\lib\libsysmodule_stub.a";%(AdditionalDependencies) + -Wl,--wrap=malloc,--wrap=free,--wrap=calloc,--wrap=memalign,--wrap=realloc,--wrap=reallocalign,--wrap=_malloc_init %(AdditionalOptions) + + + + + NDEBUG;%(PreprocessorDefinitions);;HEAPINSPECTOR_PS3=1 + Level2 + + + "..\..\..\Server\PS3\Release\libHeapInspectorServer.a";"$(SCE_PS3_ROOT)\target\ppu\lib\libpthread.a";"$(SCE_PS3_ROOT)\target\ppu\lib\libnet_stub.a";"$(SCE_PS3_ROOT)\target\ppu\lib\libsysmodule_stub.a";%(AdditionalDependencies) + -Wl,--wrap=malloc,--wrap=free,--wrap=calloc,--wrap=memalign,--wrap=realloc,--wrap=reallocalign,--wrap=_malloc_init %(AdditionalOptions) + + + + + + + \ No newline at end of file diff --git a/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/ThreadPS3.cpp b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/ThreadPS3.cpp new file mode 100644 index 00000000..ed27945a --- /dev/null +++ b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/ThreadPS3.cpp @@ -0,0 +1,41 @@ +#include +#include "../IThread.h" + +void* InternalThread(void* a_UserData) +{ + ThreadFunction function = (ThreadFunction)a_UserData; + function(); + + pthread_exit(0); + return 0; +} + +class ThreadPS3 : public IThread +{ +public: + virtual void Fork(ThreadFunction a_Function) + { + pthread_create(&m_Thread, 0, InternalThread, (void*)a_Function); + } + + virtual void Join() + { + void* threadResult; + pthread_join(m_Thread, &threadResult); + } + +private: + pthread_t m_Thread; +}; + + +IThread* CreateThread() +{ + return new ThreadPS3(); +} + +void DestroyThread(IThread* a_Thread) +{ + delete a_Thread; +} + diff --git a/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/Wait.cpp b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/Wait.cpp new file mode 100644 index 00000000..2c436c84 --- /dev/null +++ b/Minecraft.Client/PS3/PS3Extras/HeapInspector/Samples/MultiThreadedHook/PS3/Wait.cpp @@ -0,0 +1,6 @@ +#include + +void Wait(int a_Milliseconds) +{ + sys_timer_usleep(a_Milliseconds * 1000); +} \ No newline at end of file -- cgit v1.2.3