PSForever/PSF-LoginServer
1
0
Fork 0
mirror of https://github.com/psforever/PSF-LoginServer.git synced 2026-01-19 18:44:45 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #656 from jgillich/fix-ec

Browse source 
Fix queueProcessor running on system thread
This commit is contained in:
Fate-JH 2020-12-27 09:55:31 -05:00 committed by GitHub
parent 06b63d8d23 0c7ac8f0a9
commit 18fa6aac98
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/main/scala/net/psforever/actors/net/MiddlewareActor.scala
View file

@ -2,7 +2,6 @@ package net.psforever.actors.net
import java.net.InetSocketAddress import java.net.InetSocketAddress
import java.security.{SecureRandom, Security} import java.security.{SecureRandom, Security}
import akka.actor.Cancellable import akka.actor.Cancellable
import akka.actor.typed.{ActorRef, ActorTags, Behavior, PostStop, Signal} import akka.actor.typed.{ActorRef, ActorTags, Behavior, PostStop, Signal}
import akka.actor.typed.scaladsl.{ActorContext, Behaviors} import akka.actor.typed.scaladsl.{ActorContext, Behaviors}
@ -34,6 +33,7 @@ import net.psforever.packet.game.{ChangeFireModeMessage, CharacterInfoMessage, K
import scodec.Attempt.{Failure, Successful} import scodec.Attempt.{Failure, Successful}
import scodec.bits.{BitVector, ByteVector, HexStringSyntax} import scodec.bits.{BitVector, ByteVector, HexStringSyntax}
import scodec.interop.akka.EnrichedByteVector import scodec.interop.akka.EnrichedByteVector
import javax.crypto.spec.SecretKeySpec import javax.crypto.spec.SecretKeySpec
import net.psforever.packet.PacketCoding.CryptoCoding import net.psforever.packet.PacketCoding.CryptoCoding
import net.psforever.util.{DiffieHellman, Md5Mac} import net.psforever.util.{DiffieHellman, Md5Mac}
@ -42,7 +42,7 @@ import scodec.Attempt
import scala.collection.mutable import scala.collection.mutable
import scala.collection.mutable.ListBuffer import scala.collection.mutable.ListBuffer
import scala.concurrent.ExecutionContextExecutor import scala.concurrent.{ExecutionContext, ExecutionContextExecutor}
import scala.concurrent.duration._ import scala.concurrent.duration._
/** MiddlewareActor sits between the raw UDP socket and the "main" actors (either login or session) and handles /** MiddlewareActor sits between the raw UDP socket and the "main" actors (either login or session) and handles
@ -90,6 +90,7 @@ class MiddlewareActor(
import MiddlewareActor._ import MiddlewareActor._
implicit val ec: ExecutionContextExecutor = context.executionContext implicit val ec: ExecutionContextExecutor = context.executionContext
implicit val executor: ExecutionContext = context.executionContext
private[this] val log = org.log4s.getLogger private[this] val log = org.log4s.getLogger