Method DecodeAndDispatch

cxx/ToLua.cpp:229–315

		}

		bool ToLua::DecodeAndDispatch(Service* service, long long sessionId, int moduleId, int protocolId, Zeze::ByteBuffer& _os_)
		{
			if (Lua.GetGlobal("ZezeDispatchProtocol") != LuaHelper::LuaType::Function) // push func onto stack
			{
				Lua.Pop(1);
				return false;
			}
			// 现在不支持 Rpc.但是代码没有检查。
			// 生成的时候报错。
			Lua.CreateTable(0, 16);

			Lua.PushString("Service");
			Lua.PushObject(service);
			Lua.SetTable(-3);

			Lua.PushString("SessionId");
			Lua.PushInteger(sessionId);
			Lua.SetTable(-3);

			Lua.PushString("ModuleId");
			Lua.PushInteger(moduleId);
			Lua.SetTable(-3);

			Lua.PushString("ProtcolId");
			Lua.PushInteger(protocolId);
			Lua.SetTable(-3);

			long long typeId = (long long)moduleId << 32 | (unsigned int)protocolId;
			Lua.PushString("TypeId");
			Lua.PushInteger(typeId);
			Lua.SetTable(-3);

			ProtocolMetasMap::iterator pit = ProtocolMetas.find(typeId);
			if (pit == ProtocolMetas.end())
				throw std::exception("protocol not found in meta for typeid=" + typeId);

			if (pit->second.IsRpc)
			{
				bool IsRequest = _os_.ReadBool();
				long long sid = _os_.ReadLong();
				long long resultCode = _os_.ReadLong();
				long long argumentBeanTypeId;
				const char* argument;
				if (IsRequest)
				{
					argumentBeanTypeId = pit->second.ArgumentBeanTypeId;
					argument = "Argument";
				}
				else
				{
					argumentBeanTypeId = pit->second.ResultBeanTypeId;
					argument = "Result";
				}
				Lua.PushString("IsRpc");
				Lua.PushBoolean(true);
				Lua.SetTable(-3);
				Lua.PushString("IsRequest");
				Lua.PushBoolean(IsRequest);