raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Replace FileInputStream and FileOutputStream, #22733

Browse source 
(because they use finalize that is not gc friendly)
This commit is contained in:
Patrik Nordwall 2017-04-19 19:05:19 +02:00 • committed by Johan Andrén
parent 64c576da0f
commit de27c18469
5 changed files with 11 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-actor/src/main/scala/akka/io/TcpConnection.scala
View file

@ -19,6 +19,7 @@ import akka.io.Inet.SocketOption
import akka.io.Tcp._
import akka.io.SelectionHandler._
import akka.dispatch.{ UnboundedMessageQueueSemantics, RequiresMessageQueue }
import java.nio.file.Paths
/**
* Base class for TcpIncomingConnection and TcpOutgoingConnection.
@ -426,7 +427,7 @@ private[io] abstract class TcpConnection(val tcp: TcpExt, val channel: SocketCha
def PendingWriteFile(commander: ActorRef, filePath: String, offset: Long, count: Long, ack: Event,
tail: WriteCommand): PendingWriteFile =
new PendingWriteFile(commander, new FileInputStream(filePath).getChannel, offset, count, ack, tail)
new PendingWriteFile(commander, FileChannel.open(Paths.get(filePath)), offset, count, ack, tail)
class PendingWriteFile(
val commander: ActorRef,