ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-12 05:35:50 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

First phase of updates based on feedback

Browse Source
This commit is contained in:
rick.parker 2016-05-24 14:44:09 +01:00
parent 0b2c16be67
commit 4c75effe8c
2 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/src/main/kotlin/com/r3corda/node/utilities/ClockUtils.kt
View File

@ -26,7 +26,7 @@ import java.util.function.BiConsumer
*/ */
/** /**
* A marker interface and helper methods for a type of Clock that might have it's concept of "now" * An abstract class with helper methods for a type of Clock that might have it's concept of "now"
* adjusted externally. * adjusted externally.
* *
* e.g. for testing (so unit tests do not have to wait for timeouts in realtime) or for demos and simulations. * e.g. for testing (so unit tests do not have to wait for timeouts in realtime) or for demos and simulations.

12
node/src/main/kotlin/com/r3corda/node/utilities/FiberBox.kt
View File

@ -16,7 +16,7 @@ import kotlin.concurrent.withLock
* *
* It supports 3 main operations, all of which operate in a similar context to the [locked] method * It supports 3 main operations, all of which operate in a similar context to the [locked] method
* of [ThreadBox]. i.e. in the context of the content. * of [ThreadBox]. i.e. in the context of the content.
* * [read] operations which acquire the associated lock but do not notifty any waiters (see [readWithDeadline]) * * [read] operations which acquire the associated lock but do not notify any waiters (see [readWithDeadline])
* and is a direct equivalent of [ThreadBox.locked]. * and is a direct equivalent of [ThreadBox.locked].
* * [write] operations which are the same as [read] operations but additionally notify any waiters that the content may have changed. * * [write] operations which are the same as [read] operations but additionally notify any waiters that the content may have changed.
* * [readWithDeadline] operations acquire the lock and are evaluated repeatedly until they no longer throw any subclass * * [readWithDeadline] operations acquire the lock and are evaluated repeatedly until they no longer throw any subclass
@ -25,9 +25,15 @@ import kotlin.concurrent.withLock
* *
* The construct also supports [MutableClock]s so it can cope with artificial progress towards the deadline, for simulations * The construct also supports [MutableClock]s so it can cope with artificial progress towards the deadline, for simulations
* or testing. * or testing.
*
* Currently this is intended for use within a node as a simplified way for Oracles to implement subscriptions for changing
* data by running a protocol internally to implement the request handler (see [NodeInterestRates.Oracle]), which can then
* effectively relinquish control until the data becomes available. This isn't the most scalable design and is intended
* to be temporary. In addition, it's enitrely possible to envisage a time when we want public [ProtocolLogic]
* implementations to be able to wait for some condition to become true outside of message send/receive. At that point
* we may revisit this implementation and indeed the whole model for this, when we understand that requirement more fully.
*/ */
class FiberBox<T>(content: T, val lock: Lock = ReentrantLock()) { class FiberBox<T>(private val content: T, private val lock: Lock = ReentrantLock()) {
val content = content
private var mutated: SettableFuture<Boolean>? = null private var mutated: SettableFuture<Boolean>? = null
@Suspendable @Suspendable
fun <R> readWithDeadline(clock: Clock, deadline: Instant, body: T.() -> R): R { fun <R> readWithDeadline(clock: Clock, deadline: Instant, body: T.() -> R): R {