bool CInputProcessor::Process(LPDESC lpDesc, const void * c_pvOrig, int iBytes, int & r_iBytesProceed)
{
	const char * c_pData = (const char *) c_pvOrig;

	BYTE	bLastHeader = 0;
	int		iLastPacketLen = 0;
	int		iPacketLen;

	if (!m_pPacketInfo)
	{
		sys_err("No packet info has been binded to");
		return true;
	}

	for (m_iBufferLeft = iBytes; m_iBufferLeft > 0;)
	{
		BYTE bHeader = (BYTE) *(c_pData);
		const char * c_pszName;

		if (bHeader == 0) // ¾Ïȣȭ 󸮰¡ ÀÖÀ¸¹Ç·Î 0¹ø Çì´õ´Â ½ºÅµÇÑ´Ù.
			iPacketLen = 1;

		else if (!m_pPacketInfo->Get(bHeader, &iPacketLen, &c_pszName))
		{
			sys_err("UNKNOWN HEADER: %d, LAST HEADER: %d(%d), REMAIN BYTES: %d, fd: %d",
					bHeader, bLastHeader, iLastPacketLen, m_iBufferLeft, lpDesc->GetSocket());
			//printdata((BYTE *) c_pvOrig, m_iBufferLeft);
			lpDesc->SetPhase(PHASE_CLOSE);
			return true;
		}

		if (m_iBufferLeft < iPacketLen)
			return true;

		if (bHeader)
		{
			if (test_server && bHeader != HEADER_CG_MOVE)
				sys_log(0, "Packet Analyze [Header %d][bufferLeft %d] ", bHeader, m_iBufferLeft);

			m_pPacketInfo->Start();

			int iExtraPacketSize = Analyze(lpDesc, bHeader, c_pData);

			if (iExtraPacketSize < 0)
				return true;

			iPacketLen += iExtraPacketSize;
			lpDesc->Log("%s %d", c_pszName, iPacketLen);
			m_pPacketInfo->End();
		}

		// TRAFFIC_PROFILER
		if (g_bTrafficProfileOn)
			TrafficProfiler::instance().Report(TrafficProfiler::IODIR_INPUT, bHeader, iPacketLen);
		// END_OF_TRAFFIC_PROFILER

		if (bHeader == HEADER_CG_PONG)
			sys_log(0, "PONG! %u %u", m_pPacketInfo->IsSequence(bHeader), *(BYTE *) (c_pData + iPacketLen - sizeof(BYTE)));

    #ifdef SEQUENCE_PACKET_ENABLE
    		if (m_pPacketInfo->IsSequence(bHeader))
    		{
    
    			sys_err("false && m_pPacketInfo->IsSequence(bHeader)");
    			BYTE bSeq = lpDesc->GetSequence();
    			BYTE bSeqReceived = *(BYTE *) (c_pData + iPacketLen - sizeof(BYTE));
    
    			if (bSeq != bSeqReceived)
    			{
    				sys_err("SEQUENCE %x mismatch 0x%x != 0x%x header %u", get_pointer(lpDesc), bSeq, bSeqReceived,     bHeader);
    
    				LPCHARACTER	ch = lpDesc->GetCharacter();
    
    				char buf[1024];
    				int	offset, len;
    
    				offset = snprintf(buf, sizeof(buf), "SEQUENCE_LOG [%s]-------------\n", ch ? ch->GetName() : "UNKNOWN"    );
    
    				if (offset < 0 || offset >= (int) sizeof(buf))
    					offset = sizeof(buf) - 1;
    
    				for (size_t i = 0; i < lpDesc->m_seq_vector.size(); ++i)
    				{
    					len = snprintf(buf + offset, sizeof(buf) - offset, "\t[%03d : 0x%x]\n",
    							lpDesc->m_seq_vector[i].hdr,
    							lpDesc->m_seq_vector[i].seq);
    
    					if (len < 0 || len >= (int) sizeof(buf) - offset)
    						offset += (sizeof(buf) - offset) - 1;
    					else
    						offset += len;
    				}
    
    				snprintf(buf + offset, sizeof(buf) - offset, "\t[%03d : 0x%x]\n", bHeader, bSeq);
    				sys_err("%s", buf);
    
    				lpDesc->SetPhase(PHASE_CLOSE);
    				return true;
    			}
    			else
    			{
    				lpDesc->push_seq(bHeader, bSeq);
    				lpDesc->SetNextSequence();
    				//sys_err("SEQUENCE %x match %u next %u header %u", lpDesc, bSeq, lpDesc->GetSequence(), bHeader);
    			}
    		}
    #endif

		c_pData	+= iPacketLen;
		m_iBufferLeft -= iPacketLen;
		r_iBytesProceed += iPacketLen;

		iLastPacketLen = iPacketLen;
		bLastHeader	= bHeader;

		if (GetType() != lpDesc->GetInputProcessor()->GetType())
			return false;
	}

	return true;
}