Merge branch 'project0.92'

back_recharge
zhangshanxue 2019-08-27 15:05:27 +08:00
commit 3bb041a711
2 changed files with 4 additions and 1 deletions

View File

@ -149,7 +149,6 @@ public class HandlerLogicThread extends Thread{
MissionEventDistributor.requestStart();
baseHandler.execute(session, packetNetData);
MissionEventDistributor.requestEnd(session,true);
current().commit();
MongoUtil.getInstence().lastUpdate();
if(msgId != MessageTypeProto.MessageType.GET_CHAT_MESSAGE_REQUEST_VALUE){
long useTime = System.currentTimeMillis() - curTimeMillis;

View File

@ -97,6 +97,10 @@ public class MessageUtil {
}
public static void sendMessage(ISession session, int result, int msgId, GeneratedMessage generatedMessage, boolean flush) {
if( null!=HandlerLogicThread.current()){
HandlerLogicThread.current().commit();
}
byte[] byteBuf = wrappedBuffer(session.getUid(), session.getToken(), session.getIndex(), result, msgId, generatedMessage);
if (flush) {
session.writeAndFlush(byteBuf);