1. Paket hatası çözümü
  4. 1) aç input.cpp
  6. ara:
  8. bool CInputProcessor::Process(LPDESC lpDesc, const void * c_pvOrig, int iBytes, int & r_iBytesProceed)
  9. ..............
  10. ............
  11. ......
  12. return true;
  13. }
  17. değiştir :
  19. int g_iLastPacket[2] = { -1, -1 };
  20. bool CInputProcessor::Process(LPDESC lpDesc, const void * c_pvOrig, int iBytes, int & r_iBytesProceed)
  21. {
  22. const char * c_pData = (const char *) c_pvOrig;
  24. int iPacketLen;
  26. if (!m_pPacketInfo)
  27. {
  28. sys_err("No packet info has been binded to");
  29. return true;
  30. }
  32. for (m_iBufferLeft = iBytes; m_iBufferLeft > 0;)
  33. {
  34. BYTE bHeader = (BYTE) *(c_pData);
  35. const char * c_pszName;
  37. if (bHeader == 0)
  38. iPacketLen = 1;
  39. else if (!m_pPacketInfo->Get(bHeader, &iPacketLen, &c_pszName))
  40. {
  41. lpDesc->SetPhase(PHASE_CLOSE);
  42. return true;
  43. }
  45. if (m_iBufferLeft < iPacketLen)
  46. return true;
  48. int originalPacketSize = iPacketLen;
  49. BYTE preAnalyzeSeq = *(BYTE*)(c_pData + iPacketLen - sizeof(BYTE));
  51. if (bHeader)
  52. {
  53. if (test_server && bHeader != HEADER_CG_MOVE)
  54. sys_log(0, "Packet Analyze [Header %d][bufferLeft %d] ", bHeader, m_iBufferLeft);
  56. m_pPacketInfo->Start();
  58. int iExtraPacketSize = Analyze(lpDesc, bHeader, c_pData);
  60. if (iExtraPacketSize < 0)
  61. {
  62. #ifdef ENABLE_ANTI_PACKET_FLOOD
  63. sys_err("Failed to analyze header(%u) host(%s)", bHeader, inet_ntoa(lpDesc->GetAddr().sin_addr));
  64. lpDesc->SetPhase(PHASE_CLOSE);
  65. #endif
  66. return true;
  67. }
  69. iPacketLen += iExtraPacketSize;
  70. lpDesc->Log("%s %d", c_pszName, iPacketLen);
  71. m_pPacketInfo->End();
  72. }
  74. c_pData += iPacketLen;
  75. m_iBufferLeft -= iPacketLen;
  76. r_iBytesProceed += iPacketLen;
  78. g_iLastPacket[1] = g_iLastPacket[0];
  79. g_iLastPacket[0] = bHeader;
  81. if (GetType() != lpDesc->GetInputProcessor()->GetType())
  82. return false;
  83. }
  85. return true;
  86. }
  96. client:
  99. Problem varsa:
  101. game.py aç ara ve sil
  103. if constInfo.SEQUENCE_PACKET_ENABLE:
  104. net.SetPacketSequenceMode()
  108. Constinfo aç ara ve sil
  110. SEQUENCE_PACKET_ENABLE = 1
  112. ----------------------------------------------------------------------------------------------
  116. Source Client:
  118. ara
  120. return SendSequence();
  122. değiştir
  124. // return disable;
  132. SERVERSIDE
  134. 0.1
  137. input_udp
  138. ara
  139. Set(1, sizeof(ServerStateChecker_RequestPacket), "ServerStateRequest", false);
  140. değiştir:
  141. Set(1, sizeof(ServerStateChecker_RequestPacket), "ServerStateRequest");
  144. 1) desc.cpp aç ve ara
  146. sil:
  147. #include "sequence.h"
  149. sil:
  150. m_iCurrentSequence = 0;
  152. hepsini sil
  153. m_seq_vector.clear();
  156. sil:
  157. BYTE DESC::GetSequence()
  158. {
  159. return gc_abSequence[m_iCurrentSequence];
  160. }
  162. void DESC::SetNextSequence()
  163. {
  164. if (++m_iCurrentSequence == SEQUENCE_MAX_NUM)
  165. m_iCurrentSequence = 0;
  166. }
  169. sil:
  170. void DESC::push_seq(BYTE hdr, BYTE seq)
  171. {
  172. if (m_seq_vector.size() >= 20)
  173. {
  174. m_seq_vector.erase(m_seq_vector.begin());
  175. }
  177. seq_t info = { hdr, seq };
  178. m_seq_vector.push_back(info);
  179. }
  188. 2) aç DESC.H
  190. sil:
  191. struct seq_t
  192. {
  193. BYTE hdr;
  194. BYTE seq;
  195. };
  196. typedef std::vector<seq_t> seq_vector_t;
  198. sil:
  199. BYTE GetSequence();
  200. void SetNextSequence();
  203. sil:
  204. int m_iCurrentSequence;
  206. sil:
  207. public:
  208. seq_vector_t m_seq_vector;
  209. void push_seq(BYTE hdr, BYTE seq);
  220. 3) aç INPUT.CPP
  222. ara:
  223. sys_log(0, "PONG! %u %u", m_pPacketInfo->IsSequence(bHeader), *(BYTE *)(c_pData + iPacketLen - sizeof(BYTE)));
  225. değiştir:
  226. sys_log(0, "PONG! %u", *(BYTE *)(c_pData + iPacketLen - sizeof(BYTE)));
  231. sil:
  232. if (m_pPacketInfo->IsSequence(bHeader))
  233. {
  234. BYTE bSeq = lpDesc->GetSequence();
  235. BYTE bSeqReceived = *(BYTE *)(c_pData + iPacketLen - sizeof(BYTE));
  237. if (bSeq != bSeqReceived)
  238. {
  239. sys_err("SEQUENCE %x mismatch 0x%x != 0x%x header %u", get_pointer(lpDesc), bSeq, bSeqReceived, bHeader);
  241. LPCHARACTER ch = lpDesc->GetCharacter();
  243. char buf[1024];
  244. int offset, len;
  246. offset = snprintf(buf, sizeof(buf), "SEQUENCE_LOG [%s]-------------\n", ch ? ch->GetName() : "UNKNOWN");
  248. if (offset < 0 || offset >= (int) sizeof(buf))
  249. offset = sizeof(buf) - 1;
  251. for (size_t i = 0; i < lpDesc->m_seq_vector.size(); ++i)
  252. {
  253. len = snprintf(buf + offset, sizeof(buf) - offset, "\t[%03d : 0x%x]\n",
  254. lpDesc->m_seq_vector[i].hdr,
  255. lpDesc->m_seq_vector[i].seq);
  257. if (len < 0 || len >= (int) sizeof(buf) - offset)
  258. offset += (sizeof(buf) - offset) - 1;
  259. else
  260. offset += len;
  261. }
  263. snprintf(buf + offset, sizeof(buf) - offset, "\t[%03d : 0x%x]\n", bHeader, bSeq);
  264. sys_err("%s", buf);
  266. lpDesc->SetPhase(PHASE_CLOSE);
  267. return true;
  268. }
  269. else
  270. {
  271. lpDesc->push_seq(bHeader, bSeq);
  272. lpDesc->SetNextSequence();
  273. //sys_err("SEQUENCE %x match %u next %u header %u", lpDesc, bSeq, lpDesc->GetSequence(), bHeader);
  274. }
  275. }
  280. sil:
  281. pkPacketInfo->SetSequence(HEADER_CG_PONG, false);
  300. 4)PACKET_INFO.CPP aç
  302. ara:
  303. void CPacketInfo::Set(int header, int iSize, const char * c_pszName, bool bSeq)
  305. değiştir:
  306. void CPacketInfo::Set(int header, int iSize, const char * c_pszName)
  309. sil:
  310. element->bSequencePacket = bSeq;
  312. if (element->bSequencePacket)
  313. element->iSize += sizeof(BYTE);
  316. sil:
  317. bool CPacketInfo::IsSequence(int header)
  318. {
  319. TPacketElement * pkElement = GetElement(header);
  320. return pkElement ? pkElement->bSequencePacket : false;
  321. }
  323. void CPacketInfo::SetSequence(int header, bool bSeq)
  324. {
  325. TPacketElement * pkElem = GetElement(header);
  327. if (pkElem)
  328. {
  329. if (bSeq)
  330. {
  331. if (!pkElem->bSequencePacket)
  332. pkElem->iSize++;
  333. }
  334. else
  335. {
  336. if (pkElem->bSequencePacket)
  337. pkElem->iSize--;
  338. }
  340. pkElem->bSequencePacket = bSeq;
  341. }
  342. }
  345. ara :
  346. void CPacketInfo::Log(const char * c_pszFileName)
  348. değiştir :
  350. void CPacketInfo::Log(const char * c_pszFileName)
  351. {
  352. #ifndef NO_PACKET_INFO_LOG
  353. FILE * fp;
  355. fp = fopen(c_pszFileName, "w");
  357. if (!fp)
  358. return;
  360. std::map<int, TPacketElement *>::iterator it = m_pPacketMap.begin();
  362. fprintf(fp, "Name Called Load Ratio\n");
  364. while (it != m_pPacketMap.end())
  365. {
  366. TPacketElement * p = it->second;
  367. ++it;
  369. fprintf(fp, "%-16s %-10d %-10u %.2f\n",
  370. p->stName.c_str(),
  371. p->iCalled,
  372. p->dwLoad,
  373. p->iCalled != 0 ? (float) p->dwLoad / p->iCalled : 0.0f);
  374. }
  376. fclose(fp);
  377. #endif
  378. }
  382. bul:
  384. , false");
  386. bu şekilde değiştir
  387. ");
  389. elle değiştirmek isterseniz ---> ", false" silin
  391. örnek:
  392. Set(HEADER_CG_TEXT, sizeof(TPacketCGText), "Text");
  411. 5) PACKET_INFO.H aç
  414. sil:
  415. bool bSequencePacket;
  418. ara:
  419. void Set(int header, int size, const char * c_pszName, bool bSeq = false);
  421. değiştir:
  422. void Set(int header, int size, const char * c_pszName);
  425. sil:
  426. bool IsSequence(int header);
  427. void SetSequence(int header, bool bSeq);
  436. 6) SEQUENCE.CPP aç
  438. sil
  440. const BYTE gc_abSequence[SEQUENCE_MAX_NUM] =
  441. {
  442. ..................BLA BLA
  443. ...............BLA BLA
  444. ............. BLA BLA
  445. .........BLA BLA BLA BLA
  446. };
  452. 7) aç SEQUENCE.H
  453. herşeyi sil
  462. CLIENTSIDE
  468. sil:
  469. m_iSequence = 0;
  473. sil tümünü:
  474. #define SEQUENCE_TABLE_SIZE 32768
  477. sil:
  478. void CNetworkStream::SetPacketSequenceMode(bool isOn)
  479. {
  480. m_bUseSequence = isOn;
  481. }
  485. ara:
  486. bool CNetworkStream::SendSequence()
  488. değiştir :
  489. bool CNetworkStream::SendSequence()
  490. {
  491. return true;
  492. }
  494. ara:
  495. static BYTE s_bSequenceTable[SEQUENCE_TABLE_SIZE] =
  497. sil:
  498. static BYTE s_bSequenceTable[SEQUENCE_TABLE_SIZE] =
  499. {
  500. ..................BLA BLA
  501. ...............BLA BLA
  502. ............. BLA BLA
  503. .........BLA BLA BLA BLA
  504. };
  508. sil:
  509. m_iSequence = 0;
  510. m_bUseSequence = false;
  511. m_kVec_bSequenceTable.resize(SEQUENCE_TABLE_SIZE);
  512. memcpy(&m_kVec_bSequenceTable[0], s_bSequenceTable, sizeof(BYTE) * SEQUENCE_TABLE_SIZE);
  516. NETSTREAM.H aç
  518. sil:
  519. void SetPacketSequenceMode(bool isOn);
  521. sil:
  522. DWORD m_iSequence;
  523. bool m_bUseSequence;
  524. std::vector<BYTE> m_kVec_bSequenceTable;
  528. PYTHONNETWORKSTREAMMODULE.CPP aö
  531. bul PyObject* netSetPacketSequenceMode(PyObject* poSelf, PyObject* poArgs)
  533. bunu sil
  534. CPythonNetworkStream& rns = CPythonNetworkStream::Instance();
  535. CAccountConnector & rkAccountConnector = CAccountConnector::Instance();
  536. rns.SetPacketSequenceMode(true);
  537. rkAccountConnector.SetPacketSequenceMode(true);
  554. ---------------------------------------------------------------------------------------------------------------
  555. 1.0 desc.cpp aç
  556. ara:
  557. void DESC::Packet(const void * c_pvData, int iSize)
  558. {
  559. assert(iSize > 0);
  561. değiştir:
  562. void DESC::Packet(const void * c_pvData, int iSize)
  563. {
  564. assert(NULL != c_pvData);
  565. assert(iSize > 0);
  566. ---------------------------------------------------------------------------------------------------------------
  574. ---------------------------------------------------------------------------------------------------------------
  575. 1.1) desc.cpp ara
  576. else if (!m_bEncrypted)
  578. değiştir:
  579. else if (!m_bEncrypted)
  580. {
  581. int iBytesProceed = 0;
  583. while (!m_pInputProcessor->Process(this, buffer_read_peek(m_lpInputBuffer), buffer_size(m_lpInputBuffer), iBytesProceed))
  584. {
  585. buffer_read_proceed(m_lpInputBuffer, iBytesProceed);
  586. iBytesProceed = 0;
  587. }
  589. buffer_read_proceed(m_lpInputBuffer, iBytesProceed);
  590. }
  591. else
  592. {
  593. int iSizeBuffer = buffer_size(m_lpInputBuffer);
  595. if (iSizeBuffer & 7)
  596. iSizeBuffer -= iSizeBuffer & 7;
  598. if (iSizeBuffer > 0)
  599. {
  600. TEMP_BUFFER tempbuf(8192 + 4);
  601. LPBUFFER lpBufferDecrypt = tempbuf.getptr();
  602. buffer_adjust_size(lpBufferDecrypt, iSizeBuffer);
  604. long iSizeAfter = TEA_Decrypt(reinterpret_cast<DWORD *>(buffer_write_peek(lpBufferDecrypt)),
  605. reinterpret_cast<const DWORD *>( buffer_read_peek(m_lpInputBuffer)),
  606. GetDecryptionKey(),
  607. iSizeBuffer);
  609. buffer_write_proceed(lpBufferDecrypt, iSizeAfter);
  611. int iBytesProceed = 0;
  613. while (!m_pInputProcessor->Process(this, buffer_read_peek(lpBufferDecrypt), buffer_size(lpBufferDecrypt), iBytesProceed))
  614. {
  615. if (iBytesProceed > iSizeBuffer)
  616. {
  617. buffer_read_proceed(m_lpInputBuffer, iSizeBuffer);
  618. iSizeBuffer = 0;
  619. iBytesProceed = 0;
  620. break;
  621. }
  623. buffer_read_proceed(m_lpInputBuffer, iBytesProceed);
  624. iSizeBuffer -= iBytesProceed;
  626. buffer_read_proceed(lpBufferDecrypt, iBytesProceed);
  627. iBytesProceed = 0;
  628. }
  630. buffer_read_proceed(m_lpInputBuffer, iBytesProceed);
  631. }
  632. }
  634. return (bytes_read);
  635. }
  636. ---------------------------------------------------------------------------------------------------------------
  644. ---------------------------------------------------------------------------------------------------------------
  645. 1.2) ara desc.cpp
  646. if (!m_bEncrypted)
  649. değiştir:
  651. if (!m_bEncrypted)
  652. {
  653. if (!packet_encode(m_lpOutputBuffer, c_pvData, iSize))
  654. {
  655. m_iPhase = PHASE_CLOSE;
  656. }
  657. }
  658. else
  659. {
  660. if (buffer_has_space(m_lpOutputBuffer) < iSize + 8)
  661. {
  662. buffer_adjust_size(m_lpOutputBuffer, iSize);
  663. if (buffer_has_space(m_lpOutputBuffer) < iSize + 8)
  664. {
  665. sys_err(
  666. "desc buffer mem_size overflow : ",
  667. " memsize(%u) ",
  668. " write_pos(%u)",
  669. " iSize(%d)",
  670. m_lpOutputBuffer->mem_size,
  671. m_lpOutputBuffer->write_point_pos,
  672. iSize);
  673. m_iPhase = PHASE_CLOSE;
  674. }
  675. }
  676. else
  677. {
  678. DWORD * pdwWritePoint = static_cast<DWORD *>(buffer_write_peek(m_lpOutputBuffer));
  680. if (packet_encode(m_lpOutputBuffer, c_pvData, iSize))
  681. {
  682. long iSize2 = TEA_Encrypt(pdwWritePoint, pdwWritePoint, GetEncryptionKey(), iSize);
  684. if (iSize2 > iSize)
  685. buffer_write_proceed(m_lpOutputBuffer, iSize2 - iSize);
  686. }
  687. }
  688. }
  690. SAFE_BUFFER_DELETE(m_lpBufferedOutputBuffer);
  691. }
  693. if (m_iPhase != PHASE_CLOSE)
  694. fdwatch_add_fd(m_lpFdw, m_sock, this, FDW_WRITE, true);
  695. }
  696. ---------------------------------------------------------------------------------------------------------------
  704. ---------------------------------------------------------------------------------------------------------------
  705. 1.4 protocol.h ara
  706. //buffer_adjust_size(pbuf, length);
  708. değiştir :
  709. buffer_adjust_size(pbuf, length);
  710. ---------------------------------------------------------------------------------------------------------------
  730. Anti flood sistemini aktif edelim
  732. 1) SERVICE.CPP aö
  733. ekle
  734. #define ENABLE_ANTI_PACKET_FLOOD
  737. 2) aç CHAR.CPP
  738. ara
  739. m_fAttMul = 1.0f;
  740. m_fDamMul = 1.0f;
  742. ekle
  743. #ifdef ENABLE_ANTI_PACKET_FLOOD
  744. m_dwPacketAntiFloodCount = 0;
  745. m_dwPacketAntiFloodPulse = 0;
  746. #endif
  748. 3) CHAR.H
  749. ara
  750. protected:
  751. CARDS_INFO character_cards;
  752. S_CARD randomized_cards[24];
  754. ekle
  755. #ifdef ENABLE_ANTI_PACKET_FLOOD
  756. private:
  757. int m_dwPacketAntiFloodPulse;
  758. DWORD m_dwPacketAntiFloodCount;
  759. public:
  760. int GetPacketAntiFloodPulse(){return m_dwPacketAntiFloodPulse;}
  761. DWORD GetPacketAntiFloodCount(){return m_dwPacketAntiFloodCount;}
  762. DWORD IncreasePacketAntiFloodCount(){return ++m_dwPacketAntiFloodCount;}
  763. void SetPacketAntiFloodPulse(int dwPulse){m_dwPacketAntiFloodPulse=dwPulse;}
  764. void SetPacketAntiFloodCount(DWORD dwCount){m_dwPacketAntiFloodCount=dwCount;}
  765. #endif
  768. 4) aç INPUT.CPP
  769. ara
  770. if (iExtraPacketSize < 0)
  771. {
  773. değiştir
  774. if (iExtraPacketSize < 0)
  775. {
  776. #ifdef ENABLE_ANTI_PACKET_FLOOD
  777. sys_err("Failed to analyze header(%u) host(%s)", bHeader, inet_ntoa(lpDesc->GetAddr().sin_addr));
  778. lpDesc->SetPhase(PHASE_CLOSE);
  779. #endif
  781. 5) INPUT_LOGIN.CPP de bul int CInputLogin::Analyze(LPDESC d, BYTE bHeader, const char * c_pData)
  784. tüm hepsini değiştir
  785. default:
  786. sys_err("login phase does not handle this packe2t! header %d", bHeader);
  787. #ifdef ENABLE_ANTI_PACKET_FLOOD
  788. return -1;
  789. #else
  790. return (0);
  791. #endif
  792. }
  794. return (iExtraLen);
  795. }
  798. 6) aç INPUT_MAIN.CPP
  799. ara
  800. if (!(ch = d->GetCharacter()))
  802. değiştir
  804. if (!(ch = d->GetCharacter()))
  805. {
  806. sys_err("no character on desc");
  807. d->SetPhase(PHASE_CLOSE);
  808. #ifdef ENABLE_ANTI_PACKET_FLOOD
  809. return -1;
  810. #else
  811. return (0);
  812. #endif
  813. }
  815. #ifdef ENABLE_ANTI_PACKET_FLOOD
  816. if (bHeader != HEADER_CG_ITEM_USE)
  817. {
  818. if (thecore_pulse() > ch->GetPacketAntiFloodPulse() + PASSES_PER_SEC(1))
  819. {
  820. ch->SetPacketAntiFloodCount(0);
  821. ch->SetPacketAntiFloodPulse(thecore_pulse());
  822. }
  824. if (ch->IncreasePacketAntiFloodCount() >= 250)
  825. {
  826. sys_err("<Flood packet> name(%s) header(%u) host(%s)", ch->GetName(), bHeader, inet_ntoa(d->GetAddr().sin_addr));
  827. ch->GetDesc()->DelayedDisconnect(0);
  828. return false;
  829. }
  830. }
  831. #endif
  834. ara
  835. if (!(ch = d->GetCharacter()))
  837. değiştir
  839. if (!(ch = d->GetCharacter()))
  840. {
  841. sys_err("no character on desc");
  842. #ifdef ENABLE_ANTI_PACKET_FLOOD
  843. return -1;
  844. #else
  845. return 0;
  846. #endif
  847. }
  851. int CInputDead::Analyze(LPDESC d, BYTE bHeader, const char * c_pData) da
  854. default: hepsini değiştir
  856. default: bununla
  857. #ifdef ENABLE_ANTI_PACKET_FLOOD
  858. return -1;
  859. #else
  860. return (0);
  861. #endif
  862. }
  864. return (iExtraLen);
  865. }
  871. CLIENT:
  872. 1) tüm sequence ile alakalı şeyleri silin

Sadece1.com