Skip to content

Commit

Permalink
Remove ParallelGzipOutputStream
Browse files Browse the repository at this point in the history
  • Loading branch information
Friendseeker committed Oct 5, 2024
1 parent da6f7a9 commit d595466
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 144 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,22 +22,16 @@ import xsbti.compile.{ AnalysisContents, AnalysisStore => XAnalysisStore }
import scala.util.control.Exception.allCatch
import xsbti.compile.analysis.ReadWriteMappers

import scala.concurrent.ExecutionContext

object ConsistentFileAnalysisStore {
def text(
file: File,
mappers: ReadWriteMappers,
sort: Boolean = true,
ec: ExecutionContext = ExecutionContext.global,
parallelism: Int = Runtime.getRuntime.availableProcessors()
): XAnalysisStore =
new AStore(
file,
new ConsistentAnalysisFormat(mappers, sort),
SerializerFactory.text,
ec,
parallelism
)

def binary(file: File): XAnalysisStore =
Expand All @@ -61,23 +55,17 @@ object ConsistentFileAnalysisStore {
file: File,
mappers: ReadWriteMappers,
sort: Boolean,
ec: ExecutionContext = ExecutionContext.global,
parallelism: Int = Runtime.getRuntime.availableProcessors()
): XAnalysisStore =
new AStore(
file,
new ConsistentAnalysisFormat(mappers, sort),
SerializerFactory.binary,
ec,
parallelism
)

private final class AStore[S <: Serializer, D <: Deserializer](
file: File,
format: ConsistentAnalysisFormat,
sf: SerializerFactory[S, D],
ec: ExecutionContext = ExecutionContext.global,
parallelism: Int = Runtime.getRuntime.availableProcessors()
) extends XAnalysisStore {

def set(analysisContents: AnalysisContents): Unit = {
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,6 @@ import sbt.internal.inc.VirtualFileUtil.toAbsolute
import sbt.internal.inc.caching.ClasspathCache
import sbt.internal.inc.javac.AnalyzingJavaCompiler
import sbt.internal.util.ConsoleAppender
import scala.concurrent.ExecutionContext

/** An instance of an analyzing compiler that can run both javac + scalac. */
final class MixedAnalyzingCompiler(
Expand Down Expand Up @@ -507,8 +506,6 @@ object MixedAnalyzingCompiler {
useConsistent = false,
mappers = ReadWriteMappers.getEmptyMappers(),
sort = true,
ec = ExecutionContext.global,
parallelism = Runtime.getRuntime.availableProcessors(),
)

def staticCachedStore(
Expand All @@ -517,8 +514,6 @@ object MixedAnalyzingCompiler {
useConsistent: Boolean,
mappers: ReadWriteMappers,
sort: Boolean,
ec: ExecutionContext,
parallelism: Int,
): AnalysisStore = {
val fileStore = (useTextAnalysis, useConsistent) match {
case (false, false) =>
Expand All @@ -528,8 +523,6 @@ object MixedAnalyzingCompiler {
file = analysisFile.toFile,
mappers = mappers,
sort = sort,
ec = ec,
parallelism = parallelism,
)
case (true, false) =>
FileAnalysisStore.text(analysisFile.toFile, mappers)
Expand All @@ -538,8 +531,6 @@ object MixedAnalyzingCompiler {
file = analysisFile.toFile,
mappers = mappers,
sort = sort,
ec = ec,
parallelism = parallelism,
)
}
val cachedStore = AnalysisStore.getCachedStore(fileStore)
Expand Down

0 comments on commit d595466

Please sign in to comment.