.jV/ dZddlZddlZddlZddlZeejdrejddZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZGddej Z!Gddej Z"Gdd ej Z#Gd!d"ej Z$Gd#d$ej Z%Gd%d&ej Z&ej'e!dksJd'ej'e!d(ej'e"d)ksJd*ej'e"d(ej'e#d+ksJd,ej'e#d(ej'e$dksJd-ej'e$d(ej'e&d.ksJd/ej'e&d(ej'e%d0ksJd1ej'e%d(e!j(j)dksJe!j*j)d2ksJe!j+j)d3ksJe!j,j)dksJe!j-j)d ksJe!j.j)d ksJe!j/j)d4ksJe!j0j)d ksJe!j1j)d5ksJd6e2d7e2fd8Z3dEd9e2fd:Z4 dFde5d?e5d@e2f dAZ6dGdBZ7d7e8fdCZ9e:dDkr e9Z;ej<e;rdnddSdS)Hur 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_zSharedMemoryHeader != 64B ()TzPlayerTelemetryData != 84B (XzEntityTelemetryData != 88B (zAreaTelemetryData != 96B ($zCommandPacket != 36B (iȘzTelemetryPacket != 39112B ( (8offsetreturnc||t|ddS)Nrllittle)seekint from_bytesread)shmrps r)read_u64rys2HHV >>#((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 ) rangery SEQ_OFFSETrtTELEMETRY_SLOT0_OFFSETTELEMETRY_SLOT_STRIDEPLAYER_OFFSET_IN_PKTrwr#sizeofr+from_buffer_copy)rxrz_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 rlrs)ryCMD_WRITE_OFFSETCMD_READ_OFFSETCOMMAND_QUEUE_CAPACITYprintr_r`rarbrcrdrerfrgrtCOMMAND_QUEUE_OFFSETCOMMAND_SLOT_STRIDEwritebytesto_bytes) rxrrrrrwrcmds r)publish_commandrs  &''Ao&&A1u&&& IJJJt //CECMCJCKCKCK"CCLCMHH !Q)?%?CV$V VWWWIIeCjjHH IIq1uq(++,,, =r(c|t|tt jdzdddS)Nrlrs)rtAGENT_HEARTBEAT_OFFSETrrutimer)rxs 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: 0xrhu - 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)rnru [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 Exceptionrrtrrrwr#rrSHARED_MEM_MAGICrsleeprrr2r3r:r;rappendrOP_NAVIGATE_TO_COORDOP_ENGAGE_TARGETOP_PICKUP_ITEManyryrrru)rxeheaderdeadlinehresultseq1rWresult2sent 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)rqN)=__doc__r#rsysrhasattrstdoutrrrr}rrrr~rrrrrrOP_IDLErrrOP_CAST_EMERGENCY_PORTALOP_EXECUTE_STASH_ROUTINEOP_EXECUTE_VENDOR_ROUTINEOP_TRIGGER_WORLD_MAP_TRAVELOP_TRIGGER_AUTO_LOGINOP_RECALIBRATE_XYZ OP_PANIC_STOP Structurerr+rArMrTr_rrrprrrrrrrrruryrfloatrrboolrrsuccessexitr'r(r)rsN  73:}%%-JG,,,1! %        )   &*2&*&(     f&        F$   "v}'((B...0rmfm\nNoNo0r0r0r...v}())R///1uP]PVP]^qPrPr1u1u1u///v}())R///1uP]PVP]^qPrPr1u1u1u///v}&''2---/oMFMZkLlLl/o/o/o---v}]##r)))+cMFMR_D`D`+c+c+c)))v}_%%...0omfm\kNlNl0o0o0o...&!++++)0A5555#*b0000+2b8888)0B6666*1R7777+2b8888,3r9999")R////1#1#1111  s     CF56#%%/24==== [d[[[[| zdffG CH' QQq!!!!!r(