Note that PHAB_ID=# and RB_ID=# correspond to associated messages in commits.
- util-app: Better handling of exceptions when awaiting on the c.t.app.App to close at the end of the main function. We Await.ready on this as the last step of App#nonExitingMain which can potentially throw a TimeoutException which was previously unhandled. We have updated the logic to ensure that TimeoutException`s are handled accordingly. ``PHAB_ID=D356846`
- util: Upgrade to Scala Collections Compat 2.1.2.
PHAB_ID=D364013
- util-core: BoundedStack is unused and really old code. Delete it.
PHAB_ID=D357338 - util-logging: com.twitter.logging.ScribeHandler and com.twitter.logging.ScribeHandlers have
been removed. Users are encouraged to use slf4j for logging. However, if a util-logging integrated
ScribeHandler is still required, users can either build their own Finagle-based scribe client as
in ScribeRawZipkinTracer in finagle-zipkin-scribe, or copy the old ScribeHandler
implementation directly into their code.
PHAB_ID=D357008
- util: Enables cross-build for 2.13.0.
PHAB_ID=D333021
- util-stats: In c.t.finagle.stats.AbstractStatsReceiver, the counter, stat and
addGauge become final, override counterImpl, statImpl and addGaugeImpl instead.
PHAB_ID=D333021 - util-core:
- c.t.concurrent.Offer.choose,
c.t.concurrent.AsyncStream.apply,
c.t.util.Await.all,
c.t.util.Closable.sequence become available to java for passing varargs.
PHAB_ID=D333021
- util-stats:
- c.t.finagle.stats.StatsReceiver.provideGauge and addGauge become available to java for
passing varags.
PHAB_ID=D333021
- util-core: (not breaking) c.t.util.Future.join and c.t.util.Future.collect now take
Iterable[Future[A]] other than Seq.
PHAB_ID=D333021 - util-core: Revert the change above, in c.t.util.Future, collect, collectToTry and join
take scala.collection.Seq[Future[A]].
PHAB_ID=D355403 - util-core: com.twitter.util.Event#build now builds a Seq of events. Event#buildAny builds
against any collection of events.
PHAB_ID=D333021
- util-logging: The namespace forwarders for Level and Policy in com.twitter.logging.config
have been removed. Code should be updated to use com.twitter.logging.Level and
com.twitter.logging.Policy where necessary. Users are encouraged to use 'util-slf4j-api' though
where possible.
PHAB_ID=D344439 - util-logging: The deprecated com.twitter.logging.config.LoggerConfig and associated
classes have been removed. These have been deprecated since 2012. Code should be updated
to use com.twitter.logging.LoggerFactory where necessary. Users are encouraged to use
'util-slf4j-api' though where possible.
PHAB_ID=D345381
- util: Upgrade to Jackson 2.9.9.
PHAB_ID=D345969 - util-app: It is now illegal to define GlobalFlags enclosed in package objects.
PHAB_ID=D353045
- util-core: Removed deprecated c.t.concurrent.Scheduler methods usrTime,
cpuTime, and wallTime. These were deprecated in 2015 and have no
replacement.
PHAB_ID=D330386 - util-core: Removed deprecated com.twitter.logging.config classes SyslogFormatterConfig,
ThrottledHandlerConfig, SyslogHandlerConfig. These were deprecated in 2012 and have
no replacement. Users are encouraged to use 'util-slf4j-api' where possible.
PHAB_ID=D339563
- util-core: Remove experimental toggle com.twitter.util.BypassScheduler used
for speeding up ConstFuture.map (transformTry). Now, we always run map
operations immediately instead of via the Scheduler, where they may be queued
and potentially reordered.
PHAB_ID=D338487
- util-core: Fixed the behavior in c.t.io.Reader where reading from Reader#empty fails to return
a ReaderDiscardedException after it's discarded.
PHAB_ID=D325465
- util-core: Use Local at callback creation for Future's interrupt handler rather than
raiser's locals so that it is consistent with other callbacks. This functionality is
currently disabled and can be enabled by a toggle (com.twitter.util.UseLocalInInterruptible)
by setting it to 1.0 if you would like to try it out.
PHAB_ID=D324315
No Changes
- util-app: Track the registration of duplicated Flag names. Currently, we print a warning to
stderr but do not track the duplicated Flag names. Tracking them allows us to inspect and
warn over the entire set.
PHAB_ID=D314410
- util-app: Improve usage of Flag.let by providing a Flag.letParse method
PHAB_ID=D288549
- util-core: Discard parent reader from Reader.flatten when child reader encounters an exception.
PHAB_ID=D281830 - util-core: Added c.t.conversions.StringOps#toSnakeCase,toCamelCase,toPascalCase implementations.
PHAB_ID=D280886
- util-core: updated Reader#fromFuture to resolve its onClose when reading of end-of-stream.
PHAB_ID=D269413 - util-core: Added Reader.flatten to flatten a Reader[Reader[_]] to Reader[_],
and Reader.fromSeq to create a new Reader from a Seq.
PHAB_ID=D255424 - util-core: Added Duration.fromMinutes to return a Duration from a given number of minutes.
PHAB_ID=D259795 - util-core: If given a Timer upon construction, c.t.io.Pipe will respect the close
deadline and wait the given amount of time for any pending writes to be read.
PHAB_ID=D229728 - util-core: Optimized ConstFuture.proxyTo which brings the performance of
flatMap and transform of a ConstFuture in line with map.
PHAB_ID=D271358 - util-core: Experimental toggle (com.twitter.util.BypassScheduler) for speeding up
ConstFuture.map (transformTry). The mechanism, when turned on, runs map operations
immediately (why not when we have a concrete value), instead of via the Scheduler, where it may
be queued and potentially reordered, e.g.:
f.flatMap { _ => println(1); g.map { _ => println(2) }; println(3) } will print 1 2 3,
where it would have printed 1 3 2.
PHAB_ID=D271962 - util-security: Pkcs8KeyManagerFactory now supports a certificates file which contains multiple
certificates that are part of the same certificate chain.
PHAB_ID=D263190
- util-core: Fixed the behavior in c.t.io.Reader where Reader#flatMap fails to propagate
parent reader's onClose.
PHAB_ID=D269413
- util-core: Closing a c.t.io.Pipe will notify onClose when the deadline has passed whereas
before the pipe would wait indefinitely for a read before transitioning to the Closed state.
PHAB_ID=D229728
- util-core: Remove c.t.u.CountDownLatch which is an extremely thin shim around
j.u.c.CountDownLatch that provides pretty limited value. To migrate to j.u.c.CountDownLatch,
instead of c.t.u.CountDownLatch#await(Duration), please use
j.u.c.CountDownLatch#await(int, TimeUnit), and instead of
c.t.u.CountDownLatch#within(Duration), please throw an exception yourself after awaiting.
PHAB_ID=D269404 - util-core: Deprecated conversions in c.t.conversions have new implementations
that follow a naming scheme of SomethingOps.
PHAB_ID=D272206- percent is now PercentOps
- storage is now StorageUnitOps
- string is now StringOps
- thread is now ThreadOps
- time is now DurationOps
- u64 is now U64Ops
- util-collection: Delete util-collection. We deleted GenerationalQueue, MapToSetAdapter, and
ImmutableLRU, because we found that they were of little utility. We deleted LruMap because it
was a very thin shim around a j.u.LinkedHashMap, where you override removeEldestEntry. If you
need SynchronizedLruMap, you can wrap your LinkedHashMap with
j.u.Collection.synchronizedMap. We moved RecordSchema into finagle-base-http because it was
basically only used for HTTP messages, so its new package name is c.t.f.http.collection.
PHAB_ID=D270548 - util-core: Rename BlacklistStatsReceiver to DenylistStatsReceiver.
PHAB_ID=D270526 - util-core: Buf.Composite is now private. Program against more generic, Buf interface instead.
PHAB_ID=D270916
- util-core: Added Reader.map/flatMap to transform Reader[A] to Reader[B]. Added fromFuture()
and value() in the Reader object to construct a new Reader.
PHAB_ID=D252165
- util-core: The implicit conversions classes in c.t.conversions.SomethingOps have been
renamed to have unique names. This allows them to be used together with wildcard imports.
See Github issue (twitter#239).
PHAB_ID=D252462 - util-core: Both c.t.io.Writer.FailingWriter and c.t.io.Writer.fail were removed. Build your
own instance should you need to.
PHAB_ID=D256615
- util-core: Provide a way to listen for stream termination to c.t.util.Reader, Reader#onClose
which is satisfied when the stream is discarded or read until the end.
PHAB_ID=D236311 - util-core: Conversions in c.t.conversions have new implementations
that follow a naming scheme of SomethingOps. Where possible the implementations
are AnyVal based avoiding allocations for the common usage pattern.
PHAB_ID=D249403- percent is now PercentOps
- storage is now StorageUnitOps
- string is now StringOps
- thread is now ThreadOps
- time is now DurationOps
- u64 is now U64Ops
- util-core: Fixed a bug where tail would sometimes return Some empty AsyncStream instead of None.
PHAB_ID=D241513
- util-core: Conversions in c.t.conversions have been deprecated in favor of SomethingOps
versions. Where possible the implementations are AnyVal based and use implicit classes
instead of implicit conversions.
PHAB_ID=D249403- percent is now PercentOps
- storage is now StorageUnitOps
- string is now StringOps
- thread is now ThreadOps
- time is now DurationOps
- u64 is now U64Ops
- util-core: Experimental c.t.io.exp.MinThroughput utilities were removed.
PHAB_ID=D240944 - util-core: Deleted c.t.io.Reader.Null, which was incompatible with Reader#onClose semantics.
c.t.io.Reader#empty[Nothing] is a drop-in replacement.
PHAB_ID=D236311 - util-core: Removed c.t.util.U64 bits. Use c.t.converters.u64._ instead.
PHAB_ID=D244723
- util-core: c.t.u.Future.raiseWithin methods now take the timeout exception as a call-by-name
parameter instead of a strict exception. While Scala programs should compile as usual, Java
users will need to use a scala.Function0 as the second parameter. The helper
c.t.u.Function.func0 can be helpful.
PHAB_ID=D229559 - util-core: Rename c.t.io.Reader.ReaderDiscarded to c.t.io.ReaderDiscardedException.
PHAB_ID=D231969
- util-core: Made Stopwatch.timeNanos monotone.
PHAB_ID=D236629
- util-core: c.t.io.Reader.Writable and c.t.Reader.writable() are removed. Use c.t.io.Pipe
instead.
PHAB_ID=D226603 - util-core: c.t.util.TempFolder has been moved to c.t.io.TempFolder.
PHAB_ID=D226940 - util-core: Removed the forwarding types c.t.util.TimeConversions and
c.t.util.StorageUnitConversions. Use c.t.conversions.time and
c.t.conversions.storage directly.
PHAB_ID=D227363 - util-core: c.t.concurrent.AsyncStream.fromReader has been moved to
c.t.io.Reader.toAsyncStream.
PHAB_ID=D228277 - util-core: c.t.io.Reader.read() no longer takes n, the maximum number of bytes to read off a
stream.
PHAB_ID=D228385
- util-core: c.t.io.Reader.fromBuf (BufReader), c.t.io.Reader.fromFile,
c.t.io.Reader.fromInputStream (InputStreamReader) now take an additional parameter,
chunkSize, the upper bound of the number of bytes that a given reader emits at each read.
PHAB_ID=D203154
- util-core: c.t.u.Duration.inTimeUnit can now return
j.u.c.TimeUnit.MINUTES.
PHAB_ID=D225115
- util-core: c.t.io.Writer now extends c.t.util.Closable. c.t.io.Writer.ClosableWriter
is no longer exist.
PHAB_ID=D218453 - util-core: Add onClose into c.t.io.Writer, it exposes a Future that is satisfied when
the stream is closed.
PHAB_ID=D226319
- util-slf4j-api: Moved slf4j-simple dependency to be a 'test' dependency, instead of a
compile dependency, which was inaccurate.
PHAB_ID=D220718
- util-core: Added a contramap function into c.t.io.Writer, Writer is now a contravariant
functor. Added the AbstractWriter for Java compatibility
PHAB_ID=D225686
- util-logging: New way to construct ScribeHandler for java interoperability.
PHAB_ID=D208928 - util-core: Added Reader#fromAsyncStream for consuming an AsyncStream as a Reader.
PHAB_ID=D202334 - util-core: Introducing Reader.chunked that chunks the output of a given reader.
PHAB_ID=D206676 - util-core: Added Reader#framed for consuming data framed by a user supplied function.
PHAB_ID=D212396 - util-security: Add NullSslSession related objects for use with non-existent SSLSession`s. ``PHAB_ID=D201421`
- util-tunable: Introducing Tunable.asVar that allows observing changes to tunables.
PHAB_ID=D211622
util-core: c.t.io.Reader and c.t.io.Writer are now abstracted over the type they produce/consume (Reader[A] and Writer[A]) and are no longer fixed to Buf.
PHAB_ID=D195638util-core: InMemoryStatsReceiver now eagerly creates the mappings for Counters and Stats instead of waiting for the first call to Counter.incr and Stat.add.
PHAB_ID=D205760util-core: c.t.io.Reader.Writable is now c.t.io.Pipe. Both Writable type and its factory method are deprecated; use new Pipe[A] instead.
PHAB_ID=D199536util-slf4j-api: Ensure that marker information is used when determining if log level is enabled for methods which support markers.
PHAB_ID=D202387util-slfj4-api: Finalize the underlying logger def in the Logging trait as it is not expected that this be overridable. If users wish to change how the underlying logger is constructed they should simply use the Logger and its methods directly rather than configuring the the underlying logger of the Logging trait.
Add better Java compatibility for constructing a Logger.
PHAB_ID=D204330
- util-core: Fixed an issue with Future.joinWith where it waits for
completion of both futures even if one has failed. This also affects
the join method, which is implemented in terms of joinWith.
PHAB_ID=D191342
- util-core: Local.Context used to be a type alias for Array[Option[_]], now it is
a new key-value liked structure.
PHAB_ID=D182478
- util-app: Allow users a way to override the argument parsing behavior in
c.t.app.App#nonExitingMain which was inlined. Users can override parseArgs
to define custom behavior.
PHAB_ID=D181660 - util-core: Removed c.t.u.NonFatal, use scala.util.control.NonFatal
instead.
PHAB_ID=D181918 - util-class-preloader: This library has been removed since it deprecated. We
no longer recommend that people do this.
PHAB_ID=D174250
- util-app: Fix issue where in some environments, URLClassLoader#getURLs can
return null, failing LoadService from initializing properly
(see: google/guava#2239). The URLClassLoader javadoc
is not clear if a null can be returned when calling URLClassLoader#getURLs and for
at least one application server, the default returned is null, thus we should be more
resilient against this possibility. Fixes Finagle #695.
PHAB_ID=D181152
- util-reflect: This library has been deprecated since it is legacy code and shouldn't
be used for new services. We no longer think this facility is the right way to do it
and encourage you to provide your own forwarders.
PHAB_ID=D174250
- util-app: added #suppressGracefulShutdownErrors method to optionally suppress exceptions
during graceful shutdown from bubbling up.
PHAB_ID=D176970
- util-core: c.t.concurrent.AsyncSemaphore no longer completes promises while holding
its intrinsic lock.
PHAB_ID=D167434 - util-logging: Fix incorrect loggerName in c.t.logging.ScribeHandler which
prevented the short-circuiting of publishing messages emitted from the ScribeHandler.
PHAB_ID=D161552 - util-hashing: Add murmur3, a fast, non-cryptographic hashing function that
is missing from hashing.
PHAB_ID=D164915
- util-app: Add the ability to bind specific implementations for LoadService.apply
via App.loadServiceBindings.
PHAB_ID=D146554 - util-core: Introduce the ClosableOnce trait which extends the guarantees of
Closable to include idempotency of the close method.
PHAB_ID=D152000
util-app: Add visibility for NonFatal exceptions during exiting of c.t.app.App. Added visibility into any NonFatal exceptions which occur during the closing of resources during App#close.
PHAB_ID=D146029util-core: Ensure the Awaitable.CloseAwaitably0.closeAwaitably Future returns. Because the closed AtomicBoolean is flipped, we want to make sure that executing the passed in f function satisfies the onClose Promise even the cases of thrown exceptions.
PHAB_ID=D146565util-stats: Alphabetically sort stats printed to the given PrintStream in the c.t.finagle.stats.InMemoryStatsReceiver#print(PrintStream) function.
To include stats headers which provide better visual separation for the different types of stats being printedm, set includeHeaders to true. E.g.,
` InMemoryStatsReceiver#print(PrintStream, includeHeaders = true) `PHAB_ID=D144091
- util-app: Ensure that any flag parsing error reason is written to System.err
before attempting to print flag usage. In the event that collecting flags for
the printing the usage message fails, users will still receive a useful message
as to why flag parsing failed.
PHAB_ID=D137629 - util-core: Promises/Futures now use LIFO execution order for their callbacks
(was depth-based algorithm before).
PHAB_ID=D135407 - util-core: Wrap the function passed to Closable.make in a try/catch and return
a Future.exception over any NonFatal exception.
PHAB_ID=D142086
- util-core: RichU64* APIs are deprecated. Use Java 8 Unsigned Long API instead:
PHAB_ID=D137893- new RichU64String("123").toU64Long -> Long.parseUnsignedInt
- new RichU64Long(123L).toU64HexString -> Long.toHexString (no leading zeros)
- util-core: Added implicit conversion for percentage specified as "x.percent"
to a fractional Double in c.t.conversions.percent.
PHAB_ID=D128792 - util-tunable: Add deserializer for c.t.u.StorageUnit to JsonTunableMapper
PHAB_ID=D132368
- util-app: When c.t.a.App.exitOnError is called, it now gives close
an opportunity to clean up resources before exiting with an error.
PHAB_ID=D129437
- util-security: Added c.t.util.security.X509CrlFile for reading
Certificate Revocation List PEM formatted X509CRL files.
PHAB_ID=D127700
- util-collection: c.t.util.SetMaker has been removed.
Direct usage of Guava is recommended if needed.
PHAB_ID=D116852
- Guava has been removed as dependency from all modules except the
'util-cache-guava' module.
PHAB_ID=D117039
- util-security: Added c.t.util.security.PrivateKeyFile for reading PKCS#8
PEM formatted PrivateKey files.
PHAB_ID=D105266
- util-core: c.t.io.BufByteWriter.fixed(size).owned() will only represent bytes
explicitly written instead of the full size of the backing array, size.
PHAB_ID=D112938
- util-cache: The Guava dependency and its associated implementations have been
moved to a new module, 'util-cache-guava'.
PHAB_ID=D117039 - util-cache: c.t.cache.EvictingCache.lazily now takes a FutureCache
instead of an implementation specific cache.
PHAB_ID=D117039
- From now on, release versions will be based on release date in the format of
YY.MM.x where x is a patch number.
PHAB_ID=D101244
- util-intellij: Create util-intellij project and publish IntelliJ capture
points plugin for debugging asynchronous stack traces of code using Twitter
Futures in Scala 2.11.11.
PHAB_ID=D96782
- util-app: c.t.app.Flag.let and letClear are now generic in their return type.
PHAB_ID=D93951
- util-core: Fix Buf.ByteArray.Shared.apply(bytes,begin,end) constructor function.
PHAB_ID=D100648
- util-core: c.t.io.Buf.ByteArray.[Owned.Shared](Array[Byte], begin, end) now
validates its input arguments.
PHAB_ID=D100648 - util-jvm: The jvm/mem/postGC/{poolName}/max metric has been removed
because it is the same as the jvm/mem/current/{poolName}/max metric.
PHAB_ID=D95291 - util-security: Assert validity of X.509 certificates when read from a file.
Attempting to read a c.t.util.security.X509CeritificateFile will now assert
that the certificate is valid, i.e., if the current date and time are within
the validity period given in the certificate.
PHAB_ID=D88745
- util-events: Module has been removed.
PHAB_ID=D82346 - util-lint: Add GlobalRules#withRules for testing. Allow for the ability to
specify a global rules set for use in testing.
PHAB_ID=D83506
- util-core: Added c.t.util.SlowProbeProxyTimer for monitoring the duration
of execution for timer tasks.
PHAB_ID=D70279 - util-core: Introduced RootMonitor#set to set custom Monitor to RootMonitor.
PHAB_ID=D70876 - util-jvm: JvmStats has been moved here from TwitterServer allowing broader
access to many metrics including GC, allocations, memory, and more.
PHAB_ID=D80883 - util-stats: Introducing Verbosity Levels for StatsReceivers (see docs on StatsReceiver
for more info).
PHAB_ID=D70112 - util-tunable: c.t.u.tunable.Tunable, c.t.u.tunable.TunableMap,
c.t.u.tunable.JsonTunableMapper, and c.t.u.tunable.ServiceLoadedTunableMap are now public.
This allows users to create and use Tunables, a mechanism for accessing dynamically
configured values. See https://twitter.github.io/finagle/guide/Configuration.html#tunables
for details on how these can be used in Finagle.
PHAB_ID=D80751.
- util-core: Fix some consistency issues with c.t.util.ByteReaderImpl. Advance its
cursor by the number of bytes consumed via readBytes(Int), not the number specified
as a method argument. readString will now throw an UnderflowException if the number
of bytes specified exceeds the remaining buffer length instead of silently making due
with the rest of the buffer's contents.
PHAB_ID=D78301
- util-core: c.t.util.Closable.sequence now continues processing
the Closables should any of their closes result in a failed Future
and will return the first failure. Synchronous exceptions are now
handled by lifting them into failed Futures.
PHAB_ID=D62418 - util-events: com.twitter.util.events.sinkEnabled now defaults to false
in preparation for removal in an upcoming release.
PHAB_ID=D64437
- util-core: ByteWriter has been transformed into a true trait which can now
be implemented outside of the com.twitter.io package.
PHAB_ID=D59996 - util-core: The method ByteWriter.owned() has been moved to a sub trait,
BufByteWriter, to separate the notion of the target buffer representation from the
writer methods in order to make it easier to target different buffer representations.
PHAB_ID=D61215 - util-stats:
PHAB_ID=D59762
- ProxyStatsReceiver.self is now protected (was public before).
- StatsReceiver.repr is now def (was val before).
- util-stats: Counter#add now takes a Long instead of an Integer as an argument.
PHAB_ID=D69064 - util-stats: StatsReceiver#counter, StatsReceiver#stat, and StatsReceiver.addGauge
now may optionally take c.t.f.stats.Verbosity as a first argument.
PHAB_ID=D70112
- util-events: This module is deprecated and will be removed in an upcoming
release.
PHAB_ID=D64437 - util-stats:
PHAB_ID=D62611- StatsReceiver.counter0 is deprecated in favour of vararg StatsReceiver.counter
- StatsReceiver.stat0 is deprecated in favour of vararg StatsReceiver.stat
- util-app: Optional resource shutdown sequencing for registered closables
via c.t.app.App#closeOnExitLast. See longer note there for usage.
RB_ID=916120 - util-core: Added writeBytes(Buf) to the ByteWriter abstract class to allow
for efficient writing of the c.t.io.Buf type.
RB_ID=917094 - util-core: Added writeString(CharSequence, Charset) and readString(Int, Charset)`
to ByteWriter and ByteReader respectively to facilitate for more efficient String
encoding and decoding.
PHAB_ID=D63987 - util-core: Added ByteReader.readUnsignedLongBE and ByteReader.readUnsignedLongLE.
RB_ID=917289
util-collection: Removed deprecated c.t.u.JMapWrapper. Use scala.collection.JavaConverters instead.
RB_ID=915544util-core: ByteReader extends the AutoClosable interface to provide a notion of resource management. Users should ensure that instances of the ByteReader interface are closed after they are no longer needed.
RB_ID=916086- util-core: Removed deprecated methods from c.t.u.Future:
- rawException; use exception instead
- cancel; use raise instead
Removed deprecated c.t.u.Futures.select; use Future.select instead. Remove deprecated flatten method on c.t.u.Future; use Futures.flatten instead.
RB_ID=915500util-core: Removed deprecated c.t.u.LongOverflowException. Use java.lang.ArithmeticException instead. Removed deprecated c.t.u.LongOverflowArith and all methods on it: - add; use Java 8's Math.addExact instead - sub; use Java 8's Math.subtractExact instead - mul; use Java 8's Math.multiplyExact instead
RB_ID=915545util-core: Removed deprecated c.t.concurrent.exp.AsyncStream. Use c.t.concurrent.AsyncStream instead.
RB_ID=916422util-eval: Removed from the project.
RB_ID=915430https://finagle.github.io/blog/2017/04/06/announce-removals/
- util-core: All Timers now handle negative or undefined times/durations in uniform way:
treat them as zeros (i.e., Time.epoch, Duration.Zero).
RB_ID=916008
- util-core: Closable.all(..) will now catch synchronous exceptions thrown
by any Closable.close(..) invocations, and wrap them in a failed Future.
RB_ID=914859 - util-stats: InMemoryStatsReceiver's gauges member is now safe for
concurrent iteration but now holds strong references to gauge instances.
RB_ID=911951
- util-core: c.t.f.u.BufReader and c.t.f.u.BufWriter have been
moved from finagle-core to util-core and renamed to
c.t.io.ByteReader and c.t.io.ByteWriter respectively. They
are now also exposed publicly.
RB_ID=911639
- util: util-zk-commons was removed, since it was only a connector between
util and commons, which was not widely used.
RB_ID=910721 - util-core: AsyncQueue's size method is now final while offer and fail
are no longer final.
RB_ID=914191
- util-core: Promoted the positional Buf.Indexed API to be a first-class
part of c.t.io.Buf. If you have a custom implementation of Buf it
will require some effort to become compatible.
RB_ID=907231
- util-app: Set failFastUntilParsed on created flag added to c.t.app.Flags
via c.t.app.Flags#add.
RB_ID=908804 - util-core: Remove deprecated c.t.io.ConcatBuf which is replaced by
c.t.io.Buf.apply(Iterable[Buf]).
RB_ID=907180 - util-core: Remove deprecated c.t.util.RingBuffer. Use Guava's
EvictingQueue.
RB_ID=907516 - util-core: Remove deprecated c.t.concurrent.ConcurrentPool. Prefer
Finagle's c.t.f.pool.BufferingPool.
RB_ID=907516 - util-core: Remove deprecated c.t.concurrent.ConcurrentMultiMap. Prefer
Guava's Multimap.
RB_ID=907516
- util: Bump guava to 19.0.
RB_ID=907807
- util-app: App now exposes closeOnExit publicly.
RB_ID=906890 - util-core: Add method to Buf to efficiently write to a nio ByteBuffer.
RB_ID=910152 - util-core: Add Java-friendly API to Scala.java for converting from
a Java 8 Optional to a Scala Option.
RB_ID=906512 - util-core: Introduced a positional Buf API, Buf.Indexed, and retrofitted
all existing implementations in util and finagle to adopt it. It is now used
throughout for a reductions in allocation and latency. In two services at
Twitter we saw a 1-2% reduction in allocations. We plan to open the API to
the public and make it a part of Buf once we are confident in the APIs.
RB_ID=904559RB_ID=905253RB_ID=906201 - util-slf4j-api: Introduce slf4j-api support into util. This includes a
small scala wrapper over the org.slf4j.Logger and a scala-friendly
Logging trait. Changes also include the util-slf4j-jul-bridge module which
is a library that provides a utility to "smartly" install the
Slf4jBridgeHandler.
RB_ID=900815
- util-core: Improved performance and allocation rates of some "random access"
Buf operations.
RB_ID=905253 - util-core: Standardized argument checking in implementations of
c.t.io.Buf.write and c.t.io.Buf.slice.
RB_ID=899935
- util-core: Deprecated c.t.io.ConcatBuf which is replaced by
c.t.io.Buf.apply(Iterable[Buf]).
RB_ID=899623
- util-core: Fix issue with c.t.concurrent.AsyncStream.mapConcurrent which
will cause the stream head to be held for life of operation.
RB_ID=896168
- util-core: Deprecated charset constants in c.t.io.Charsets have been
removed. Use java.nio.charset.StandardCharsets instead.
RB_ID=893542 - util-core: com.twitter.util.NonFatal is deprecated, use
scala.util.control.NonFatal instead.
RB_ID=892475 - util-core: FactoryPool/SimplePool now inherits scala.collection.mutable.Queue[A]
not deprecated scala.collection.mutable.QueueProxy[A]
RB_ID=896485 - util-core: Buf has been promoted from a trait to an abstract class to facilitate
memoization of the Buf hash code. This also removes the need for the Java friendly
abstract class: AbstractBuf.
RB_ID=897476
No Changes
- util-app: Java developers can now declare instances of GlobalFlag
from Java. See c.t.app.JavaGlobalFlag for details.
RB_ID=874073 - util-thrift: We now depend on a fork of libthrift hosted in the Central Repository.
The new package lives in the 'com.twitter' organization. This removes the necessity of
depending on maven.twttr.com. This also means that eviction will not be automatic and
using a newer libthrift library requires manual eviction if artifacts are being pulled
in transitively.
RB_ID=885879 - util-logging: Allow users to override c.t.util.logging.Logger installation,
making it easier to work with SLF4J bridges.
RB_ID=870684 - util: No longer need to add an additional resolver that points to maven.twttr.com.
RB_ID=878967
- util-core: c.t.io.InputStreamReader and Readers created by
c.t.io.Reader.fromFile and fromStream now close the underlying
InputStream on reading of EOF and on calls to Reader.discard.
RB_ID=873319
- util-core: c.t.app.GlobalFlag is now abstract to reflect how the class
is intended to be used.
RB_ID=875409
- util-app: Introduce c.t.app.Flag.letClear allowing flags to be unset.
RB_ID=868177
- util-core: c.t.util.FuturePool now optionally exposes metrics on
their internal state such as active tasks, and completed tasks.
RB_ID=850652 - util-core: Add a system property
com.twitter.concurrent.schedulerSampleBlockingFraction that can be
set to a value between 0.0 and 1.0 (inclusive). When the Scheduler
runs blocking code, it will log the stacktrace for that fraction of
the calls.
RB_ID=861892 - util-core: Add Java-friendly API for StorageUnit. See StorageUnit.fromX
and StorageUnit.{times, plus, minus, divide} methods.
RB_ID=864546
- util-eval: The compiler reporter is now reset between code check invocations.
This means that when there is a failure that it is no longer required to reset
the entire state to recover and that already compiled and loaded classes can still
be used.
RB_ID=859878
- util-codec: StringEncoder no longer depends on apache commons-codec, and
decode will now throw an exception when it fails to decode a byte, instead
of failing silently.
RB_ID=833478 - util-collection: LruMap is now backed by jdk LinkedHashMap instead of apache
collections LRUMap.
RB_ID=833515 - util-core: com.twitter.util.NonFatal is now implemented by Scala's
scala.util.control.NonFatal. This changes behavior such that
java.lang.StackOverflowError is considered fatal and
java.lang.NoSuchMethodException is considered non-fatal.
RB_ID=835671
- util-app: com.twitter.finagle.util.LoadService has been moved to
c.t.app.LoadService and can now be used without needing a finagle-core
dependency.
RB_ID=829897 - util-cache: Adds support for Caffeine-style caches.
RB_ID=833848 - util-core: Add c.t.concurrent.Scheduler.blockingTimeNanos which tracks time spent doing
blocking operations.
RB_ID=828289 - util-core: Reduced allocations by 40% and latency by 18% of satisfying Promises.
RB_ID=832816 - util-core: c.t.util.NoStacktrace is removed. Use scala.util.control.NoStackTrace instead.
RB_ID=833188 - util-core: Add Future.joinWith that also accepts a function (A, B) => C for mapping
a joined result.
RB_ID=838169 - util-core: Add Future.by(Time), complementary to the existing Future.within(Duration)
RB_ID=838169 - util-core: Add c.t.util.ProxyTimer which allows for creating proxy based
Timers outside of the com.twitter.util package.
RB_ID=846194 - util-core: Add AsyncStream.merge merge potentially inifite streams
RB_ID=846681 - util-security: Added new project.
RB_ID=843070
- Builds are now only for Java 8 and Scala 2.11. See the
blog post
for details.
RB_ID=828898 - util-core: c.t.u.Bijection is removed. use c.t.bijection.Bijection
(https://github.com/twitter/bijection) instead.
RB_ID=834383 - util-core: Deprecated method Future.get() has been removed because it made it
too easy to hide blocking code. Replaced usage with the more explicit
com.twitter.util.Await.result(Future).
RB_ID=833579 - util-core: Deprecated method Future.get(Duration): Try has been removed because it
made it too easy to hide blocking code. Replaced usage with the more explicit
com.twitter.util.Await.result(Future.liftToTry).
RB_ID=836066 - util-core: Deprecated methods Future.isReturn and Future.isThrow have been
removed because they made it too easy to hide blocking code. Replaced usage with
the more explicit Await.result(Future.liftToTry).isReturn and
Await.result(Future.liftToTry).isThrow.
RB_ID=837329 - util-lint: Added methods com.twitter.util.lint.Rules.removeById(String) and
com.twitter.util.lint.RulesImpl.removeById(String) so that it is now possible
to remove a com.twitter.util.lint.Rule from the com.twitter.util.lint.GlobalRules
set.
RB_ID=840753
- util-core: AsyncMeter had a bug where if the burst size was smaller than
the number of disbursed tokens, it would discard all of the tokens over
the disbursal limit. Changed to instead process tokens in the wait queue
with leftover tokens. This improves behavior where the actual period is
smaller than can actually be simulated with the given timer.
RB_ID=836742 - util-core: Once didn't actually provide the guarantee it tried to, because
of an issue with the scala compiler,
https://issues.scala-lang.org/browse/SI-9814. It should now actually be
synchronized.
RB_ID=842245 - util-zk: Fixed race when an existing permit is released between the time
the list was gotten and the data was checked.
RB_ID=835856 - util-core: Memoize apply now throws IllegalStateException if a thread re-enters with identical input parameters instead of deadlocking.
- util-core: Add Throwables.unchecked to help Java users deal with checked
exceptions.
RB_ID=811441 - util-stats: Can now get from a com.twitter.finagle.stats.StatsReceiver` to all "leaf"
StatsReceivers that don't delegate to another StatsReceiver with
com.twitter.finagle.stats.DelegatingStatsReceiver.all.
RB_ID=819519
- util-core: Removed deprecated methods from Buf.scala
RB_ID=809948- Removed c.t.io.Buf.ByteArray.apply, replace usage with Buf.ByteArray.Owned.apply. - Removed c.t.io.Buf.ByteArray.unapply, replace usage with Buf.ByteArray.Owned.unapply. - Removed c.t.io.Buf.ByteBuffer.apply, replace usage with Buf.ByteBuffer.Owned.apply. - Removed c.t.io.Buf.toByteBuffer, replace usage with Buf.ByteBuffer.Owned.extract. - util-core: Removed deprecated Future.apply methods
RB_ID=811617 - util-stats: Removed com.twitter.finagle.stats.BroadcastStatsReceiver marker trait in favor of
com.twiter.finagle.stats.DelegatingStatsReceiver marker trait, which lets us specify that we
only delegate to a single com.twitter.finagle.stats.StatsReceiver.
RB_ID=819519 - util-zk-common: Removed com.twitter.zk.ServerSet. Use implementations of ServerSets in the
finagle-serversets project.
RB_ID=821355
- util-core: Fix memory leak in Var.apply(T, Event[T]) and Var.patch.
RB_ID=809100
- util-core: AsyncSemaphore supports closing and draining of waiters via fail.
RB_ID=807590 - util-core: Add convenience methods force, size, sum, and withEffect to AsyncStream.
RB_ID=808411
- util-core: Fix nested functions AsyncStream.++ to avoid stack overflow.
RB_ID=804408
- util-core: Future.rawException is deprecated in favor of Future.exception.
RB_ID=798223
- util-core: Add Future.traverseSequentially. Take a sequence and sequentially apply a function
A => Future[B] to each item.
RB_ID=785091
NOT RELEASED
- util-core: Introduce an AsyncMeter for asynchronously rate limiting to a fixed rate over time.
It can be used for smoothing out bursty traffic, or for slowing down access to a
resource.
RB_ID=756333 - util-core: Introduce a TokenBucket for helping to control the relative rates of two processes,
or for smoothing out the rate of a single process.
RB_ID=756333
- util-core: Timer now has final implementations for schedule which delegate
to new protected scheduleOnce and schedulePeriodically methods. This is
done to ensure that Locals are captured when the task is scheduled and
then used when the task is run. Existing Timer implementations should rename
their existing schedule methods to work with the new interface.
RB_ID=755387 - util-core: Remove deprecated FuturePool.defaultPool, callers should
use FuturePool.unboundedPool instead.
RB_ID=757499 - util-stats: Remove deprecated methods on com.twitter.finagle.stats.StatsReceiver.
RB_ID=757414 - util-core: AsyncStream graduates out of com.twitter.concurrent.exp into
com.twitter.concurrent. Backwards compatibility aliases remain for Scala
users, but Java users will need to update their imports.
RB_ID=758061 - util-codec: Add a new encoder com.twitter.util.Base64UrlSafeStringEncoder
which extends from com.twitter.util.Base64StringEncoder. Both the url-safe
and non-url-safe encoders can decode all strings generated by either.
RB_ID=765189 - util-core: Remove unnecessary invalidate method from util-cache's
com.twitter.cache.guava.LoadingFutureCache, and change the remove semantic
to match the com.twitter.cache.FutureCache contract.
RB_ID=766988 - util-core: Remove protected Timer.monitor (overrides a monitor to use by a
timer implementation) because any possible implementation rather than Monitor.get
promotes memory leaks when timer is used to schedule recursive tasks (tasks that
reschedules themselves).
RB_ID=771736
- util-core: Introduce an optional max capacity to AsyncQueue.
Modified AsyncQueue.offer to return a boolean indicating whether or not the
item was accepted. Added AsyncQueue.drain(): Try[Queue].
RB_ID=745567
- util-core: Remove deprecated methods from com.twitter.util.Time and
com.twitter.util.Duration.
RB_ID=751771 - util-core: Provide methods on Stopwatch so that users can take advantage of
Time manipulation tools in latency-sensitive code when measuring elapsed
time.
RB_ID=75268
- util-core: The Scheduler clock stats were decommissioned as they only make sense
relative to wallTime and the tracking error we have experienced wallTime and
*Time make it impossible to use them reliably. It is not worth the performance
and code complexity to support them.
RB_ID=750239 - util-core: JavaTimer and ScheduledThreadPoolTimer now capture the Local
state when scheduled and is used along with that Monitor when the TimerTask
is run.
RB_ID=755387 - util-logging: QueueingHandler does not create a separate thread per instance.
RB_ID=745567
util-core: Remove deprecated methods from com.twitter.util.Var.
To migrate observe and foreach, given aVar.observe { t => somethingWith(t) } you would write aVar.changes.register(Witness({ t => somethingWith(t) })).
To migrate observeUntil, given aVar.observeUntil(_ == something), you would write aVar.changes.filter(_ == something).toFuture().
To migrate observeTo, given aVar.observeTo(anAtomicReference), you would write aVar.changes.register(Witness(anAtomicReference)).
RB_ID=744282
- util-core: TimeFormat optionally takes a TimeZone in the constructor. If not provided, it uses UTC.
- util-core: Activity, BoundedStack, RingBuffer and Var migrated
off of deprecated ClassManifest to ClassTag.
RB_ID=720455 - util-core: Added Spool#zip
- util-core: Removed deprecated methods Future.void and Future$.void().
Use Future.voided and Future$.Void instead.
RB_ID=720427
- util-core: Promise.forwardInterruptsTo(other) is a no-op if the
- other future is fulfilled.
RB_ID=714420
- util-events: Recording of events is disabled by default and can be updated
- at runtime via TwitterServer's /admin/events page or
/admin/events/{recordOn,recordOff}.
RB_ID=715712
- util-events: Enable event sink by default.
- util-core: Introduce AsyncStream, an experimental replacement for Spool.
- util-core: Future.willEqual() now returns Future[Boolean] instead of
- Promise[Boolean].
- util-core: rename VarSource to ActivitySource. remove
- com.twitter.io.exp.VarSource.Result, return Activity[T] instead of Var[VarSource.Result[T]]. Remove FailoverVarSource in favor of ActivitySource.orElse.
- util-core: TimeFormat now throws IllegalArgumentException if the pattern
- uses the week year ('Y') without the week number ('w')
- util-core: Spool.++ used to force its argument, but now it is evaluated
- only if this Spool is empty. To revert to existing behavior, simply force the argument before passing it to ++.
- util-core: Reader.writable() returns a new type, Reader.Writable, which
- combines Reader, Writer and Closable.
- util-core: Reader.concat and Reader.copyMany now take an AsyncStream
- argument instead of Spool.
- util-core: Futures still rethrow on fatals, but now also Monitor.handle on
- them.
- util-core: Future.onFailure now only applies a PartialFunction if
- PartialFunction.isDefinedAt returns true.
- util-core: AsyncSemaphore now requires that initialPermits be positive.
- util-core: The Reader and Writer from Reader.Writable.close() are now
- synchronized on close.
- util-core: Add method .flushBatch() to batched future returned by Future.batched()
- that immediately initiates processing of all remaining queued requests
- util-core: Add Future.collect() method that collects over Map's values
- util-stats: Create a new module, util-stats to move finagle-core
- StatsReceivers to. They retain the com.twitter.finagle namespace to ease the transition.
Deprecation:
- util-stats: Deprecate com.twitter.finagle.stats.StatsReceiver#time{,TimeFuture}.
- Instead, please use the com.twitter.finagle.stats.Stat helpers from scala, and the com.twitter.finagle.stats.JStats helpers from java.
- util-cache: Remove unused com.twitter.cache.Mod trait and object
- util-core: Rename Buf._.Unsafe to Buf._.Owned and Buf._.Copied to Buf._.Shared
- util-core: Remove the com.twitter.util.repository package
- util-core: Change return type of Future.batched() to com.twitter.util.Batcher
- util-app: Flaggable is now an abstract class for Java compatibility
- util-core: Make Futures an API entry point for Java users
- (even for methods that take Scala collections)
- util-core: Add compilation tests to track Java compatibility of new API
- util-core: Removed Sieve example.
- util-core: Introduce new constructors and extractors for Buf types to
- support more efficient, correct uses. Buf types now come with Copied and Direct management interfaces -- Direct tries to provide direct access to the Buf's backing byte array, while Copied ensures that the caller cannot accidentally mutate a Buf's data. Additionally, helpers to support Buf-type coersion have been added.
- util-app: add an option so that we can let apps fail fast if reading
- argument before args are parsed.
- util: add missing @RunWith annotation
- util-core: Java tests for Duration, Time and Timer
- util-core: Reader.writable.fail: make reentrant
- util-core: Slurry of PartialFunction micro-optimizations
- util and finagle: fix compiler warnings
Deprecation:
- util-core: Add deprecation of RingBuffer to changelog
- util-core: Removed IVar and IVarField
- util-core: Clarify Scaladoc of Promise.attached
- util-core: Add self-type to Promise.Detachable and augment Promise Scaladocs
- util-io: Better names for Buf.slice() paramters.
- util-app: Add App registration
- util-cache Add asynchronous cache with TTL
- util-core: Add Activity.future
- util-logging: factor out testing code into new package util-test
- util-core: prefer Await.result(future.liftToTry) to deprecated methods
- c.t.util.Time: Scope Locals with Local.let instead of save`+`restore
util-logging: * Logging's default handler is now async by default via com.twitter.logging.QueueingHandler. * Two Flags allowing for customization:
- com.twitter.logging.log.async: Default true, turns this functionality on/off.
- com.twitter.logging.log.async.maxsize: Default 4096, max size of the async buffer.
util.RingBuffer: fix buffer size on drops
util-io: Fix Buf.ByteBuffer.slice
util-core: Future.sleep: short-circuit when duration <= 0
util-core: IVar and IVarField were removed. Use com.twitter.util.Promise instead because it provides a superset of IVar behavior.
- util-core: introduce Memoize.snappable
- util-app: add Flaggable.ofSet
- util-app: introduce Flag.let
- util-core: Perf improvement to ConcatBuf#slice
- util-core: Avoid accumulation of listeners in Future.select
- util-core: Event.filter only 1 call to filter predicate
- util-jvm: Fix logging in Jvm.foreachGc
- util-core: document StorageUnit can overflow
- util-core: check Future.proxyTo and Promise.become preconditions
- util-core: remove Leaky and FutureBenchmark
- util, ostrich, finagle, twitter-server: Remove all trailing spaces
- Test classes from util-logging were factored into its own package, util-test.
- util-core: Deprecate RingBuffer in favor of Guava's com.google.common.collect.EvictingQueue.
- util-cache: Adds a Guava-backed asynchronous cache
- util-core: Fixed FuturePool for NLRCK
- util-core: Improve java friendliness of futures
- util-core: Make register/close on Event() work atomically
- util-core: Reimplement Buf.Utf8 encoder/extractor using io.Charsets
- util-core: storage parse() should be able to handle Long
- util-logging: make Logger immutable & break cyclic dependency on Level
- util: Upgrade to scala_2.10
- util: Enables cross-publishing for 2.11
- util-app: Log severely if a flag is read at the wrong time
- util-core: Changes transform to fail Futures if you return inside the passed closure
- util-core: Copy bytes from Reader to Writer and OutputStream
- util-core: Fix RichU64String to throw for negative input Problem
- util-core: Optimizations in Buf
- util-core: Remove some unnecessary implicit conversions
- util-doc: Fix updatedocs.bash to update new util docs
- util: smattering of minor cleanups in util and finagle
- util-core: Reader and getContent symmetry
- util-core: Remove confusing NOOP 0.until(5) in Future.collect().
- util-app: Fix a bug in global flag parsing
- util-core: Fixes a broken sbt test
- util-core: Log exceptions caught by ChannelStatsHandler
- util-core: Satisfy promise on fatal exception in FuturePool task
- util-core: small perf improvements to Future.collect, Throw, Flag
- util-logging: java-friendly LoggerFactory API
- util: Update README to reflect correct storage units.
- util: Convert all tests in util to scalatest
- util-app: Simplifies the logic to get the appname
- util-io: Buf, Reader: remove Buf.Eof; end-of-stream is None
- util-io: Create Buf.ByteBuffer to wrap java.nio.ByteBuffer
- util-app: Don't kill the JVM on flag-parsing failure
- util-app: Improve the Scaladocs for com.twitter.app.Flag and friends
- util-core: Add U(32|64)(BE|LE) to Buf
- util-core: Add com.twitter.util.NilStopwatch
- util-core: Add src/main/java dependency on src/main/scala
- util-core: Catch InterruptedException in Closable collector thread
- util-core: Fix MockTimer#schedule(Duration)(=> Unit)'s cancel
- util-core: Fix update-after-interrupt race condition in AsyncSemaphore
- util-core: Signal the deprecation of com.twitter.util.Bijection.
- util-logging: Add additional handlers to Logging trait
- util: Upgrade dependency versions
- util-core: Scheduler productivity = cpuTime/wallTime
- util-core: Add a take method to Spool
- util-core: Introduce ConcatBuf
- util-core: add Spool.collectFuture
- util-app: Add flag for configuring acceptance of undefined flags
- util-app: Minor c.t.app.ClassPath/c.t.f.util.LoadService cleanup
- util-core: Adds Time.sleep for testing sleeping code
- util-app: enforce close grace period
- util-core: special case buf.slice(0, buf.length)
- util-core: add LIFO option to LocalScheduler
- util-core: improves usability of Var and VarSource from java
- util-core: Make spool lazier
- util-core: Fixes detachable semantics with ConstFuture
- util-core: make LocalScheduler non-private for custom schedulers
- util-benchmark: Fix caliper failures due to new guava
- util-core: Add Local.let
- util-core: Add com.twitter.io.Charsets and replace the use of org.jboss.netty.util.CharsetUtil
- util-core: Bump objectsize dependency to 0.0.10
- util-core: Comprehensive Scaladocs for Scheduler-related classes and traits
- util-core: Create a static Exception for use in Future.raiseWithin
- util-core: Future.select: fix inaccurate comments
- util-core: Make Function classes covariant
- util-core: Parse names into trees; introduce separate evaluation.
- util-core: Short-circuit within and raiseWithin if Future is already satisfied
- util-core: Add StorageUnit.hashCode
- util-core: Event.mergeMap: fix Closable
- util: Update 3rdparty library versions
- util: Upgrade to guava 16
- util: Update zk libraries
- util-app: add usage string, printed before flags
- util-app: Handle comma-separated values in Flaggable.ofMap
- util-app: Implement application-level shutdown handling in App.
- util-app: Remove hardcoded ports in FlagTest
- util-app: sort global flags in usage
- util-core/Offer: Don't do indexed lookups in prepare()
- util-core: Add support for interrupting Future.sleep
- util-core: Check whether JVM supports thread measurement before measuring
- util-core: Create daemon threads in all stock com.twitter.util.FuturePools
- util-core: Event: mergeMap, not flatMap
- util-core: Performance optimizations for Future.collect
- util-core: TimeLike inSeconds should not truncate
- util-core: Var.collect, Fix deadlock caused by oversynchronizing
- util-core: Var: prevent stale updates
- util: ForkJoin scheduler: first draft
- Upgrade everyone to the new c.t.common.server-set
- LocalScheduler: improve concurrency by sampling less
- Option to enable thread pool scheduler in finagle, and fix the shutting down RejectedExecutionException's.
- re-write Future.unit in terms of Future.Unit
- Revert "Option to enable thread pool scheduler in finagle, and fix the shutting down RejectedExecutionException's." (It's breaking the build on JDK6 machines)
- twitter-server: Report on deadlock conditions in admin/contentions
- Update 3rdpaty zookeeper client
- Update version of com.twitter.common*
- util-core: Add a Scaladoc for com.twitter.util.RandomSocket
- util-core: State[+A] => State[A]
- util-logging: Increase richness of file-logging flags
- util-zk: scalatest as test dep
- util-{app,jvm}: various small improvements from gcflow
- util: Drop util-eval dep from util-zk-common, which pulls in scala-compiler unnecessarily
- Var: fix an iatrogenic concurrency bug
- util-collection: Depend on jsr305.
- util-core: Add Promise.attached and Detachable.
- util-core: Add Future.batched.
- util-common: Fix a race condition in ExecutorServiceFuturePool.
- util-core: Add BridgedThreadPoolScheduler.
- util-core: Add Events, discrete-time values.
- util-core: Add Future.delayed, Timer.Nil.
- util-core: Add Var.join.
- util-core: Add utilities for composing Future side effects.
- util-core: Allocation improvements to Future.isDefined, Promise.isDefined, Promise.interrupts.
- util-core: Fix forcing issues with Spool.*::.
- util-core: Future.followedBy->Future.before
- util-core: s/setValue(())/setDone()/g
- util-logging: Allocation improvements to Formatter.formatMessageLines.
- util-logging: Get correct method and class name in c.t.u.LogRecord
- util-zk-common: Fix finagle-serversets dependencies discrepancy.
- util-core: Add functionality to AsyncSemaphore for executing functions as permits become available.
- util-core: Fine-grained locking to prevent deadlocks in Var.
- util-core: Introduce com.twitter.io.BufInputStream - wraps a Buf and exposes a java.io.InputStream interface.
- util-core: Introduce com.twitter.util.Memoize - thread-safe memoization of a function.
- util-core: 2.10 pattern matching strictness
- util-core: Gives Var single-owner semantics
- util-core: Seq[Future[A]] => Future[Seq[Try[A]]]
- util-core: Adds a comment explicitly describing synchronous callback on observe for Var
- util-core: async semaphore cancellation
- util: sbt version in build.properties
- util-core: Break apart interruptible FuturePool for java backcompat
- util-app: Fix null error for Flaggable[InetSocketAddress].
- util-app: Flag, easier usage of default.
- util-core: adds closable.close(Duration)
- util-core: Adds com.twitter.io.exp.VarSource
- util-core: adds comment re using FuturePool from java.
- util-core: buffers requests until Var[Addr] is in a ready state
- util-core: Fix Promise update race when interrupting FuturePool threads.
- util-core: improve allocation/perf in Offer.choose and Future.select
- util-core: Var: remove Var.apply; introduce Var.sample
- util-zk-common: update pom com.twitter.common.zookeeper dependencies
- util: scaladoc warning cleanup.
- util-core: Introduce Try.collect(), analagous to Future.collect
- util-core: Add some empirically useful add-ons to Var
- util-logging: Use ConsoleHandler when outputFlag is /dev/null
- util-core: Fix broken string-deserialization in Buf.Utf8.unapply
- util-core: Improve gc profile around Var
- util-app: Properly propagate underlying exceptions.
- util-core: Add a Var.value function. (835a043)
- util-core: Augment Var and Local in support of Finagle's request context feature. (b2d689a)
- util-core: Avoid instantiating TimeoutException until it is needed (CSL-592)
- util-core: Make Future.never a val instead of a def
- util-core: Move Var to core util, add Var.unapply
- util-core: Testing function Time.withTimeAt now uses Locals.
- util-core: Throw AlreadyNackd on nack-ack.
- util-core: raiseWithin, alternative to within, that raise interrupt.
- util-jvm: Add a GlobalFlag for a machine's number of logical cores. (dc20fbf1)
- util-logging: Add a NullLogger object.
- util-logging: makes Logging more flexible for easy extension of twitter-server
- util-zk: Add ShardCoordinator and ZkAsyncSemaphore classes. (c57b2a9)
- util-hashing: removed dependency on util-core
- util-core: Introduce swappable schedulers, ThreadPool scheduler.
- util-core: Scheduler - "productivity" stats, dispatches.
- util-core: Add Future.when
- util-core: introduced Var - composable variables
- util-core: adding short note on Future 'within'
- util-core: Add Return constants
- util-core: Make ConstFuture.transform consistent with Promise.transform
- util-core: Make it possible to explicitly set a locale on TimeFormat
- util-logging: Refactored formatter to decrease coupling
- util-core: Add NoSuchMethodException as fatal exception in NonFatal
- util-app: Add some logging helpers to Flags
- util-core: Introduce Buf, Reader, and Writer: Zerocopy, buffered I/O
- util-core: Add Future.True and Future.False constants
- util-app: Treat '--' as end of flags indicator
- util-app: Add support for long flags
- util-app: flags use by-name default values
- util-app: Make the global flag test idempotent
- util-collection: guard against missing element exception in BGQ
- util: Deal with UnknownHostException thrown by InetAddress.getLocalHost
- util: update version in README
- util: Update owners files
- util-jvm: CpuProfile: sleep the right amount of time for the recording thread
- util-jvm: always try to construct hotspot instance Detection by VM name is unreliable.
- util: util/* compiling, testing and benchmarking with pants.
- util-eval: Gizzard: Some followup deps alignment to fix deployment classpath issues
- util-core: add Time.fromMicroseconds to util.Time
- util-core: NullMonitor takes itself out when composed
- util-core: deprecate Config
- util-hashing: add entryForHash api to Distributor
- util-app: Flag: clarify usage and hide all Flag constructors.
- util-core: Added reduceLeft and foldLeft to the Spool class
- util: Update sbt project for (util, ostrich, finagle)
- util-core: Convenience method to await all
- util-core: RootMonitor never propagates non fatal exception
- util-collection: When growing chain only grow the chain. This addresses a NoSuchElementException.
- util-eval: fix for when class files are on the classpath directly
- util: Generate build.properties from sbt
- util-core:Time, Duration: implement Java serialization
- util-thrift: Bump Jackson to 1.9.11
- util-core: Add withFilter to Future and Try
- util: Remove zookeeper dependency ivyXML and replace with ExclusionRules
- util-core: create less garbage in AsyncSemaphore.acquire()
- util-core: deprecate com.twitter.util.concurrent.Concurrent{Pool, MultiMap}
- util-core: restore prior Future.get behavior
- util-core: Spool error propagation
- util-core: Use futures for schema detection to avoid blocking finagle threads
- util-refect: test: use sys.error
- util-zk: ZNode("/path").parentPath should be "/", not an empty string
- util-core: flag a bug with U64 truncation
- util-core: Future.get: include fatal exceptions
- util-core: deprecate Future#apply, get.
- util-core: special-case Duration.Zero to avoid allocation
- util-zk: Improvements to util-zk NativeConnector
- util: Update sbt project definition
- util: launching test in all scala version of the project
- util-core: Add Future.Nil, it can be used anytime you need a Future[Seq[_]] with an empty sequence.
- util-core: fix VM test error by ensuring reset
- util-core: Move Disposable/Managed to util
- util-logging: scribe binary thrift for tbird add/remove/scrub ops:
- util: upgrade com.twitter.common.objectsize to 0.0.7
- util-core: Remove StreamHelper
- Flag: create Map flag type
- Flag: introduce global flags
- HttpMux: provide visibility into available handlers
- Flag: add Time type
- Spool: encode exceptions
- Closable: use Time.Bottom for close()
- Future.within: bypass timer entirely if we're passed Duration.Top
- Awaitable: introduce Await
- util-jvm: GC predictor
- io.Files: don't overallocate buffers
- Future: use .nonEmpty instead of != Nil
- preliminary 2.10 port/build
- Add Closable trait
- Add contention snapshot
- util-core: concurrent.SpoolSource utility for creating Spools
- util-core: Spool.flatMap, Spool.++
- util-app: add shutdown hooks
- util-logging: Make the logging work properly for Scala and mixed Scala/Java
- Broker: more efficient dequeueing of offers
- Duration: parse all output of Duration.toString
- ScheduledThreadPoolTimer: aggressively remove runnables to avoid space leak
- util-core documentation: fix some parentheses, backticks
- util-hashing: add Hashable type class
- Promise: remove future tracing, add explicit transforming state to avoid extraneous allocation
- update zk client
- com.twitter.app: composable apps & flags
- Use java.util.ArrayDeque in place of mutable.Queue due to https://issues.scala-lang.org/browse/SI-6690
- Removed future cancellation, which is now replaced with one-shot
interrupts. These also carry a
causewhich will be used profitably in finagle. - A new, leaner Promise implemetnation
- New implementations for Time and Duration with true sentinels
- Promise, Try combinators no longer attempt to catch fatal exceptions
- fix compiler warnings
- Future.join: support up to 22-tupled futures
- com.twitter.concurrent.Serialized: explicit docs
- util-logging: concurrent enqueue support for ScribeHandler, add stats
- AsyncSemaphore: Use volatile vars for the active number and the waiters
- util-logging: fix ThrottledHandler to not leak memory
- util-logging: for file handlers, default to append=true since that was the default with FileHandlerConfig and is safer behavior
- upgrading slf4j dependent projects (1.6.1).
- sbt: robust MD5 checking.
- Fix Spool.foreachElem crashing on resoved spool with error
- FuturePool.defaultPool: use cached threadpool by default.
- util-logging: Correctly handle files with a shared prefix.
- Improve ZNode.name and ZNode.parentPath to not use Regexes
- Fix ScheduledThreadPoolTimer.schedule(...).cancel()
- Upgrade guava dependency to v13
- Add a ZkClient Connector that dispatches requests across several zookeeper connections
- Support prefix-less sequential nodes in util-zk
- util-logging: Add Logger.withLoggers.
- Clean up equals and hashCode for Time and Duration
- Disable log handler purging
- Added ThriftCodec
- Add a Time.hashCode method
- GC monitor: be more quiet about missed GCs
- patch public release of OSS libraries; catch up sbt
- Fix temporary file name generation
- util-jvm: start timer thread in 'daemon' mode
- JVM CPU profiler
- util-jvm: fix for JDK 7
- fix documentation
- util-jvm: gc monitoring
- Kill com.twitter.concurrent.Channel
- Upgrade scala to 2.9.2
- Java compatibility: void -> voided
- added AsyncQueue
- config:validate optional subconfigs
- util-zk: allow multiple session event listeners, fix AsyncCallbackPromise exception handling, misc fixes
- offer: deprecate apply()
- propagate cancellation exception when Timer.doAt future is cancelled
- KetamaDistributor optionally preserves a floating point truncation
- Timer uses daemon thread by default
- Future.monitor: release reference to promise when it's satisfied
- Future: misc Java compatibility fixes
- Eval.scala: Allow @deprecated
- util-logging: Add LoggerFactory
- Util: Add util-class-preloader (classfile preloading), util-jvm (access to performance counters)
- Future: divorce from TryLike hierarchy
- LogRecord: use MessageFormat
- Time: Treat MaxValue specially in TimeMod.{add,sub}
- AsyncSemaphore: allow parameterizing maximum queue size
- Logging: scribe handlers may now be named "scribe"
- Logging: Always make sure Level is initialized before being able to refer to Logger.
- Offer/Broker: simpler, more flexible implementation
- Config: Config.optional results in lazy evaluation
- NetUtil: optimize ipv4 address parsing
- upgrade to Guava r11
- NetUtil: Add inetAddressToInt, isInetAddressInBlock, isInetAddressInBlocks
- Future tracer: fix bug where double proxied exceptions fail
- add "ExceptionalFunction0" for easier use from Java
- Locals: many optimizations to reduce allocations caused by saving and restoring contexts
- util-zk-common: Asynchronous wrappers for common ServerSets.
- IVar.unget: only remove closures by object equality
- Offer.choose: use nanoseconds for random seed
- Future.const - builds a constant Future from an existing Try
- ThreadPoolFactories are named by default
- Offer: ensure ObjectOrder is independent of Object#hashCode
- new package: util-zk: asynchronous bindings to ZooKeeper
- Future: temporarily disabling default usage of the AsmTracer
- Future: all helper methods now have Java-friendly equivalents that take Lists.
- Config: recompile configs based on hash instead of timestamp, add memoization
- Timer: make JavaTimer more resilient, log errors
- FuturePool: Fixed race condition in FuturePool where work that was cancelled would not clean up after itself
- Function: Add ExceptionalFunction type to allow Java to throw checked exceptions.
- Futures: trace dispatch "stack", supplying it as a stack trace for exceptions, implement "transform", "transformedBy" to allow for a more imperative control flow when used from Java.
- Monitors: composable widgets for handling exceptions
- Files.delete has to follow symlinks because jdk6 support for symlinks is weaksauce
- properly handle cancellation in FuturePool
- Locals: ensure
Localis fully initialized before registering
- add some docs to Offer, Time
- util.io.Files: file utilities, documentation for TempFile
- Offer/Broker: explicit return types for Java compat.
- Json thrift deserializer
- Finagle: count pending timeouts
- Fix eval precompile bug
- util.Config.Specified now delays evaluation of specified value, to ensure evaluation happens in correct dependency order, rather than in class-hierarchy order. This change is mostly source compatible, unless you have directly used the Specified class.
- ivar/future: provide "TCE", per-thread scheduling, and promise squashing
- logger: restore original logging level after modifying them
- u64: fix
- filehandler: thread-visibility
- eval: fix mtime invalidation
- base64 encoder: make it threadsafe
- Back out TCE for ivar/futures. This introduced a space leak and will be fixed momentarily.
- FuturePool: Catch any exception thrown by executor.submit() and return as a Future.exception
- ivar/future: provide "TCE", per-thread scheduling, and promise squashing
- util-core: add bijection
- util: Time.now is now measured at nanosecond granularity instead of millisecond.
- futurepool: don't attempt to perform work for Futures that are cancelled
- offer: use Int.compare instead of subtraction to avoid integer overflow in ObjectOrder
- offer: accept an empty offer list. this is just Offer.never
- Eval: persistent compilation targets
- offer/broker: fixes, simplifications - gets rid of thunked values on sends. removing the infrastructure required to support this led to significant simplification. lock the correct objects for broker events. don't try to resolve identical objects in lock order.
- offer: java support
- hashing: actually return 64bit values from the 64bit hash functions; tests
- Introduce new util-codec module to contain various codecs. Primarily so that it can depend on apache commons-codec 1.5 for base64 improvements over the sun one.
- Added TestLogging specs helper to util-logging.
- Spools: like scala streams, but with deferred tails.
- add GZip string encoder
- Maintain a map of already visited objects incase someone creates a circular of config objects.
- Make Duration hashable.
- Promise.on{Success, Failure}: returned chained future.