fix indicaiton

back_recharge
wangyuan 2019-08-27 12:04:05 +08:00
parent a173bcc00d
commit 5c96eb3756
2 changed files with 4 additions and 1 deletions

View File

@ -145,7 +145,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);