Method Update

cxx/ToLua.cpp:122–173

		}

		void ToLua::Update(Service* service)
		{
			ToLuaHandshakeDoneMap handshakeTmp;
			ToLuaSocketCloseMap socketCloseTmp;;
			std::unordered_set<long long> rpcTimeoutTmp;
			ToLuaBufferMap inputTmp;
			{
				std::lock_guard<std::mutex> lock(mutex);
				handshakeTmp.swap(ToLuaHandshakeDone);
				inputTmp.swap(ToLuaBuffer);
				socketCloseTmp.swap(ToLuaSocketClose);
				rpcTimeoutTmp.swap(ToLuaRpcTimeout);
			}
			for (auto& sid : rpcTimeoutTmp)
				CallRpcTimeout(sid);
			for (auto& e : socketCloseTmp)
				CallSocketClose(e.second, e.first);
			for (auto& e : handshakeTmp)
				CallHandshakeDone(e.second, e.first);

			for (auto& e : inputTmp)
			{
				std::shared_ptr<Socket> sender = service->GetSocket(e.first);
				if (NULL == sender.get())
					continue;
				Zeze::ByteBuffer bb((unsigned char*)e.second.data(), 0, (int)e.second.size());
				Protocol::DecodeProtocol(service, sender, bb, this);
				e.second.erase(0, bb.ReadIndex);
			}

			{
				std::lock_guard<std::mutex> lock(mutex);
				for (auto& e : inputTmp)
				{
					if (e.second.empty())
						continue; // 数据全部处理完成。

					ToLuaBufferMap::iterator bit = ToLuaBuffer.find(e.first);
					if (bit != ToLuaBuffer.end())
					{
						// 处理过程中有新数据到来，加到当前剩余数据后面，然后覆盖掉buffer。
						e.second.append(bit->second);
						ToLuaBuffer[e.first] = e.second;
					}
					else
					{
						// 没有新数据到来，有剩余，加回去。下一次update再处理。
						ToLuaBuffer[e.first] = e.second;
					}
				}
			}
		}

		void ToLua::RegisterGlobalAndCallback(ToLuaService* service)
		{