luke
/
sbt
mirror of https://github.com/sbt/sbt.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove return statement in CommandExchange.scala

This commit is contained in:
xuwei-k 2026-03-20 12:30:54 +09:00 committed by kenji yoshida
parent 324f863d60
commit 5a74ba3992
1 changed files with 27 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
main/src/main/scala/sbt/internal/CommandExchange.scala
View File

@ -517,38 +517,37 @@ private[sbt] final class CommandExchange {
val thread = new Thread("sbt-notify-other-servers") {
setDaemon(true)
@SuppressWarnings(Array("scalafix:DisableSyntax"))
override def run(): Unit = {
val procDir = SysProp.globalLocalCache / "proc"
if (!procDir.exists) return
val myPid = ProcessHandle.current().pid()
val files = procDir.listFiles
if (files == null) return
for (f <- files if f.getName.endsWith(".json")) {
val pidStr = f.getName.stripSuffix(".json")
val pid =
try pidStr.toLong
catch { case _: NumberFormatException => -1L }
if (pid != myPid) {
try {
val (socket, _) = sbt.protocol.ClientSocket.socket(f)
if (procDir.exists) {
val myPid = ProcessHandle.current().pid()
val files = Option(procDir.listFiles).toSeq.flatten
for (f <- files if f.getName.endsWith(".json")) {
val pidStr = f.getName.stripSuffix(".json")
val pid =
try pidStr.toLong
catch { case _: NumberFormatException => -1L }
if (pid != myPid) {
try {
val notification = sbt.internal.protocol.JsonRpcNotificationMessage(
"2.0",
sbt.protocol.Serialization.dropIfIdle,
None
)
val bytes = sbt.protocol.Serialization.serializeNotificationMessage(notification)
socket.getOutputStream.write(bytes)
socket.getOutputStream.flush()
} finally {
socket.close()
val (socket, _) = sbt.protocol.ClientSocket.socket(f)
try {
val notification = sbt.internal.protocol.JsonRpcNotificationMessage(
"2.0",
sbt.protocol.Serialization.dropIfIdle,
None
)
val bytes = sbt.protocol.Serialization.serializeNotificationMessage(notification)
socket.getOutputStream.write(bytes)
socket.getOutputStream.flush()
} finally {
socket.close()
}
} catch {
case scala.util.control.NonFatal(_) =>
// Server unreachable - clean up stale proc file
try IO.delete(f)
catch { case scala.util.control.NonFatal(_) => }
}
} catch {
case scala.util.control.NonFatal(_) =>
// Server unreachable - clean up stale proc file
try IO.delete(f)
catch { case scala.util.control.NonFatal(_) => }
}
}
}