.jV/ ZdZddlZddlmcmZddlZddlZddl Z ddl Z e e j dre j ddZdZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%Gddej&Z'Gddej&Z(Gdd ej&Z)Gd!d"ej&Z*Gd#d$ej&Z+Gd%d&ej&Z,ej-Z.e.e'Z/dZ0e/e0kZ1e1sej2d'e1fd(e/e0fd)ej3vsej4erej5end)ej5e.dej3vsej4e'rej5e'ndej5e/ej5e0d*zZ6ej7d+ej-e'd,d-zd.e6izZ8e9ej:e8dxZ.xZ/xZ1Z0ej-Z.e.e(Z/d/Z0e/e0kZ1e1sej2d'e1fd(e/e0fd)ej3vsej4erej5end)ej5e.dej3vsej4e(rej5e(ndej5e/ej5e0d*zZ6ej7d0ej-e(d,d-zd.e6izZ8e9ej:e8dxZ.xZ/xZ1Z0ej-Z.e.e)Z/d1Z0e/e0kZ1e1sej2d'e1fd(e/e0fd)ej3vsej4erej5end)ej5e.d ej3vsej4e)rej5e)nd ej5e/ej5e0d*zZ6ej7d2ej-e)d,d-zd.e6izZ8e9ej:e8dxZ.xZ/xZ1Z0ej-Z.e.e*Z/dZ0e/e0kZ1e1sej2d'e1fd(e/e0fd)ej3vsej4erej5end)ej5e.d"ej3vsej4e*rej5e*nd"ej5e/ej5e0d*zZ6ej7d3ej-e*d,d-zd.e6izZ8e9ej:e8dxZ.xZ/xZ1Z0ej-Z.e.e,Z/d4Z0e/e0kZ1e1sej2d'e1fd(e/e0fd)ej3vsej4erej5end)ej5e.d&ej3vsej4e,rej5e,nd&ej5e/ej5e0d*zZ6ej7d5ej-e,d,d-zd.e6izZ8e9ej:e8dxZ.xZ/xZ1Z0ej-Z.e.e+Z/d6Z0e/e0kZ1e1sej2d'e1fd(e/e0fd)ej3vsej4erej5end)ej5e.d$ej3vsej4e+rej5e+nd$ej5e/ej5e0d*zZ6ej7d7ej-e+d,d-zd.e6izZ8e9ej:e8dxZ.xZ/xZ1Z0e'j;Z.e.j<Z=dZ1e=e1kZ>e>sej2d'e>fd8e=e1fdej3vsej4e'rej5e'ndej5e.ej5e=ej5e1d9zZ?d:d;e?izZ@e9ej:e@dxZ.xZ=xZ>Z1e'jAZ.e.j<Z=de>sej2d'e>fd=e=e1fdej3vsej4e'rej5e'ndej5e.ej5e=ej5e1d9zZ?d:d;e?izZ@e9ej:e@dxZ.xZ=xZ>Z1e'jBZ.e.j<Z=d>Z1e=e1kZ>e>sej2d'e>fd?e=e1fdej3vsej4e'rej5e'ndej5e.ej5e=ej5e1d9zZ?d:d;e?izZ@e9ej:e@dxZ.xZ=xZ>Z1e'jCZ.e.j<Z=dZ1e=e1kZ>e>sej2d'e>fd@e=e1fdej3vsej4e'rej5e'ndej5e.ej5e=ej5e1d9zZ?d:d;e?izZ@e9ej:e@dxZ.xZ=xZ>Z1e'jDZ.e.j<Z=d Z1e=e1kZ>e>sej2d'e>fdAe=e1fdej3vsej4e'rej5e'ndej5e.ej5e=ej5e1d9zZ?d:d;e?izZ@e9ej:e@dxZ.xZ=xZ>Z1e'jEZ.e.j<Z=d Z1e=e1kZ>e>sej2d'e>fdBe=e1fdej3vsej4e'rej5e'ndej5e.ej5e=ej5e1d9zZ?d:d;e?izZ@e9ej:e@dxZ.xZ=xZ>Z1e'jFZ.e.j<Z=dCZ1e=e1kZ>e>sej2d'e>fdDe=e1fdej3vsej4e'rej5e'ndej5e.ej5e=ej5e1d9zZ?d:d;e?izZ@e9ej:e@dxZ.xZ=xZ>Z1e'jGZ.e.j<Z=d Z1e=e1kZ>e>sej2d'e>fdEe=e1fdej3vsej4e'rej5e'ndej5e.ej5e=ej5e1d9zZ?d:d;e?izZ@e9ej:e@dxZ.xZ=xZ>Z1e'jHZ.e.j<Z=dFZ1e=e1kZ>e>sej2d'e>fdGe=e1fdej3vsej4e'rej5e'ndej5e.ej5e=ej5e1d9zZ?d:d;e?izZ@e9ej:e@dxZ.xZ=xZ>Z1dHeIdIeIfdJZJdWdKeIfdLZK dXdNeIdOeLdPeLdQeLdReIf dSZMdYdTZNdIeOfdUZPeQdVkr ePZRe jSeRrdnddSdS)Zur Test IPC Bridge v1.1 giữa Python Agent và C++ Core Engine - Telemetry: Seqlock double-buffer (2 slot ping-pong, chống torn-read) - Command : Hàng đợi vòng SPSC 16 slot (Agent produce, Core consume) - Heartbeat: Agent cập nhật nhịp tim để Core watchdog giám sát Cách chạy: khởi động bin/AutoPOE2_Core.exe trước, rồi chạy script này. N reconfigurezutf-8)encodingzLocal\POE2_Auto_SharedMem_v1i@ 0iii0@lOTz`abcc eZdZdZdejfdejfdejfdejfdejfdejfdejfd ejfd ejfg Zd S) SharedMemoryHeaderr magicprotocolVersion isRunningtelemetrySequencecommandSequencecommandReadIndexlastCoreHeartbeatlastAgentHeartbeatreservedN)__name__ __module__ __qualname___pack_ctypesc_uint64c_uint32_fields_/C:\Projects\AutoPOE2\scripts\test_ipc_bridge.pyrr0st F &/" FO, fo& fo. FO, V_- fo. v/ V_% HHHr(rcFeZdZdZdejfdejfdejfdejfdejfdejfdejfd ejfd ejfd ejfd ejfd ejfdejfdejfdejfdejfdejfdejfdejfgZdS)PlayerTelemetryDatar playerAddrposXposYposZyawpitch currentHPmaxHP currentManamaxMana currentESmaxES currentWardmaxWard currentSpirit maxSpiritactiveWeaponSet movementFlags debuffMaskN) rr r!r"r#r$c_floatr%r&r'r(r)r+r+?s F v'     &.! fo& &/" ( FO$ fo& &/" ( FO$ &/* fo& FO, &/* v''HHHr(r+ceZdZdZdejfdejfdejfdejfdejfdejfdejfd ejfd ejfd ejfd ejfd ejfdejdzfg Z dS)EntityTelemetryDatar idtyperarityr-r.r/distanceToPlayerr2r3staggerProgresscurrentAnimationId extraFlagsnamerN) rr r!r"r#r%c_uint16r?c_charr&r'r(r)rArAXs F v ! 6?#    V^, fo& &/" FO, v/ v' #$HHHr(rAcreZdZdZdejfdejfdejfdejdzfdejdzfgZd S) AreaTelemetryDatar areaLoadTimestampMs areaLevelareaSeedareaCoderareaNamerN) rr r!r"r#r$r%rKr&r'r(r)rMrMksV F 0 fo& V_% V]R'( V]R'( HHHr(rMcteZdZdZdejfdejfdefdejfdedzfdej d zfd e fgZ d S) TelemetryPacketr snapshotId timestampplayer entityCountentitiesterrainWalkabilityi@areaN) rr r!r"r#r$r+r%rAc_uint8rMr&r'r(r)rTrTvsg F v' fo& &' ( (3./ v~;< "#HHHr(rTc eZdZdZdejfdejfdejfdejfdejfdejfdejfd ejfgZd S) CommandPacketr commandIdopCodetargetXtargetYtargetZtargetEntityIdpriority timeoutMsN) rr r!r"r#r$r%r?r&r'r(r)r_r_sj F fo& 6?# FN# FN# FN# 6?+ V_% fo& HHHr(r_)==)zL%(py5)s {%(py5)s = %(py2)s {%(py2)s = %(py0)s.sizeof }(%(py3)s) } == %(py8)sr#)py0py2py3py5py8zSharedMemoryHeader != 64B ()z >assert %(py10)spy10TzPlayerTelemetryData != 84B (XzEntityTelemetryData != 88B (zAreaTelemetryData != 96B ($zCommandPacket != 36B (iȘzTelemetryPacket != 39112B ()zI%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.magic }.offset } == %(py7)s)rirjpy4py7zassert %(py9)spy9)zS%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.protocolVersion }.offset } == %(py7)s )zM%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.isRunning }.offset } == %(py7)s)zU%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.telemetrySequence }.offset } == %(py7)s)zS%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.commandSequence }.offset } == %(py7)s)zT%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.commandReadIndex }.offset } == %(py7)s()zU%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.lastCoreHeartbeat }.offset } == %(py7)s)zV%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.lastAgentHeartbeat }.offset } == %(py7)s8)zL%(py4)s {%(py4)s = %(py2)s {%(py2)s = %(py0)s.reserved }.offset } == %(py7)soffsetreturnc||t|ddS)Nrvlittle)seekint from_bytesread)shmrzs r)read_u64rs2HHV >>#((1++x 0 00r(retriesct|D]}t|t}|dkrdS|dz}|t|t zzt z|tj t}t|t}||kr|t |fcSdS)u}Đọc snapshot telemetry chống rách theo giao thức seqlock. Trả về (sequence, PlayerTelemetryData) hoặc None.rNr ) ranger SEQ_OFFSETr~TELEMETRY_SLOT0_OFFSETTELEMETRY_SLOT_STRIDEPLAYER_OFFSET_IN_PKTrr#sizeofr+from_buffer_copy)rr_s1slot player_bytess2s r) seqlock_readrs7^^ J J c: & & 7744Av '$1F*FFI]]^^^xx .A B BCC c: & & 88*;;LIII I I I  4r(op_codexyz entity_idc^t|t}t|t}||z tkrt ddSt }|dz|_||_||_||_ ||_ ||_ d|_ d|_ |t|tzt zz|t%||t||dzdd|jS)u<Đẩy lệnh vào SPSC Command Ring (producer phía Agent).u9[Command] Hàng đợi đầy - bỏ qua lần gửi nàyNr i rvr})rCMD_WRITE_OFFSETCMD_READ_OFFSETCOMMAND_QUEUE_CAPACITYprintr_r`rarbrcrdrerfrgr~COMMAND_QUEUE_OFFSETCOMMAND_SLOT_STRIDEwritebytesto_bytes) rrrrrrwrcmds r)publish_commandrs  &''Ao&&A1u&&& IJJJt //CECMCJCKCKCK"CCLCMHH !Q)?%?CV$V VWWWIIeCjjHH IIq1uq(++,,, =r(c|t|tt jdzdddS)Nrvr})r~AGENT_HEARTBEAT_OFFSETrrtimer)rs r)update_agent_heartbeatrsPHH #$$$IIc$)++$%%..q(;;<<<<} d} t jdz}t j|krYt/|t=|t>| z d,krd-} n+t jdt j|kY| std.dStd/t=|d0} t=|t@} tCt jd1z}td2|| z d3|| z d4td5td6d-S)7Nz2==================================================z2 AutoPOE2 IPC Bridge Test (Protocol v1.1) r)tagnameaccessu][Error] Không tìm thấy Shared Memory. Hãy chắc chắn CoreEngine đang chạy! Lỗi: F r g?uB[FAIL] Core không phản hồi hoặc magic header không khớp!z - Magic Header: 0xXu (Chuẩn: 0xrnu - Phiên bản Giao thức: 0xu - Trạng thái Core: uHOẠT ĐỘNGuTẮTu2 [1] Đọc telemetry qua Seqlock double-buffer...rg?uD[FAIL] Không đọc được snapshot telemetry nào trong 5 giây!z - Snapshot seq=z | Player HP: /z | Spirit: uD[FAIL] Telemetry sequence không tăng - Core có thể đã dừng!u - Sequence tăng liên tục: z -> z (Core publish 120Hz OK)u- [2] Gửi 3 lệnh vào SPSC Command Ring...g@g@i90)rc3K|]}|duV dS)Nr').0cs r) zmain..s& # #19 # # # # # #r(u![FAIL] Gửi lệnh thất bại!u - Đã gửi lệnh #z (NAVIGATE 1280,720), #z (ENGAGE), #r z (PICKUP)u* [3] Chờ Core rút lệnh (SPSC FIFO)...r Tu4[FAIL] Core không tiêu thụ lệnh trong 5 giây!uO - Core đã tiêu thụ cả 3 lệnh theo đúng FIFO (readIndex tăng >= 3)rxru [4] Nhịp tim: Core lệch ums | Agent lệch msuQ[SUCCESS] Thử nghiệm IPC v1.1 (Seqlock + SPSC Ring + Heartbeat) THÀNH CÔNG!ua[Info] Script kết thúc -> Core sẽ tự ngắt sau 5s mất nhịp tim Agent (watchdog demo).)"rmmapSHARED_MEM_SIZESHARED_MEM_NAME ACCESS_WRITE Exceptionrr~rrrr#rrSHARED_MEM_MAGICrsleeprrr2r3r:r;rappendrOP_NAVIGATE_TO_COORDOP_ENGAGE_TARGETOP_PICKUP_ITEManyrrrr)reheaderdeadlinehresultseq1rWresult2sent start_readconsumedcore_hbagent_hbnow_mss r)mainrso >??? >??? >???i?ODL]^^^  qnoqqrrruuuuu Fy{{RH )++    / /GY9Z9Z0[0[ \ \ 7& & &1;!+;+;F  3 )++ ~ RSSSu S S S S>N S S S STTT GV-C G G GHHH ]9IQ9N9N%5%5T[ ] ]^^^ ?@@@ Fy{{QH )++ c""    4 )++ ~ TUUUuLD&  Bd B B&2B B BV\ B B, B B/5/? B BCCC JsOOO33G'!*,, TUUUu [T [ [wqz [ [ [\\\ :;;; DKK%965IIJJJKK%5GGGHHHKK^44555 # #d # # ### 1222u kDG k kDG k kY]^_Y` k k klll 7888#//JHy{{QH )++ s### C ) )J 6! ; ;H  4 )++   DEEEu [\\\sD!!G344H t# $ $F d6G+; d dvX`O` d d deee ]^^^ mnnn 4s,A B&A>>B__main__)r)rrrr)r{N)T__doc__builtins @py_builtins_pytest.assertion.rewrite assertionrewrite @pytest_arr#rsysrhasattrstdoutrrrrrrrrrrrrrrOP_IDLErrrOP_CAST_EMERGENCY_PORTALOP_EXECUTE_STASH_ROUTINEOP_EXECUTE_VENDOR_ROUTINEOP_TRIGGER_WORLD_MAP_TRAVELOP_TRIGGER_AUTO_LOGINOP_RECALIBRATE_XYZ OP_PANIC_STOP Structurerr+rArMrTr_r @py_assert1 @py_assert4 @py_assert7 @py_assert6_call_reprcomparelocals_should_repr_global_name _saferepr @py_format9_format_assertmsg @py_format11AssertionError_format_explanationrrz @py_assert3 @py_assert5 @py_format8 @py_format10rrrrrrrrrrrfloatrrboolrrsuccessexitr'r(r)rs}  73:}%%-JG,,,1! %        )   &*2&*&(     f&        F$   "}r}}'((rBr(B.rrrrrrrrrr(Brrrrrrrrrrrrrrvrrrrrrvrrrrrrr}rrrrrrrrrrrrr'rrrrrr'rrrrrrr(rrrrrBrrrrrrrrr0rmfm\nNoNo0r0r0rrrrrrrrrrrrrrrrrrrrrrrrrrrrr }u}}())uRu)R/uuuuuuuuuu)Ruuuuuuuuuuuuuuvuuuuuuvuuuuuuu}uuuuuuuuuuuuu(uuuuuu(uuuuuuu)uuuuuRuuuuuuuuu1uP]PVP]^qPrPr1u1u1uuuuuuuuuuuuuuuuuuuuuuuuuuuuu }u}}())uRu)R/uuuuuuuuuu)Ruuuuuuuuuuuuuuvuuuuuuvuuuuuuu}uuuuuuuuuuuuu(uuuuuu(uuuuuuu)uuuuuRuuuuuuuuu1uP]PVP]^qPrPr1u1u1uuuuuuuuuuuuuuuuuuuuuuuuuuuuu }o}}&''o2o'2-oooooooooo'2oooooooooooooovoooooovooooooo}ooooooooooooo&oooooo&ooooooo'ooooo2ooooooooo/oMFMZkLlLl/o/o/ooooooooooooooooooooooooooooo }c}}]##crc#r)cccccccccc#rccccccccccccccvccccccvccccccc}ccccccccccccc]cccccc]ccccccc#cccccrccccccccc+cMFMR_D`D`+c+c+ccccccccccccccccccccccccccccc }o}}_%%oo%.oooooooooo%oooooooooooooovoooooovooooooo}ooooooooooooo_oooooo_ooooooo%oooooooooooooo0omfm\kNlNl0o0o0ooooooooooooooooooooooooooooo+&+!+&!+++++++++++&!++++++++++++++++++++++++++++++++&+++++!+++++++++++++++++++++++++++++++)5)05A50A555555555550A555555555555555555555555555)55555055555A5555555555555555555555555555555#0#*0b0*b00000000000*b000000000000000000000000000#00000*00000b0000000000000000000000000000000+8+28b82b888888888882b888888888888888888888888888+88888288888b8888888888888888888888888888888)6)06B60B666666666660B666666666666666666666666666)66666066666B6666666666666666666666666666666*7*17R71R777777777771R777777777777777777777777777*77777177777R7777777777777777777777777777777+8+28b82b888888888882b888888888888888888888888888+88888288888b8888888888888888888888888888888,9,39r93r999999999993r999999999999999999999999999,99999399999r9999999999999999999999999999999"/")/R/)R///////////)R///////////////////////////"/////)/////R///////////////////////////////1#1#1111  s     CF56#%%/24==== [d[[[[| zdffG CH' QQq!!!!!r(