all: Full stops in comments!

node/src/main/kotlin/com/r3corda/node/api/APIServer.kt

@@ -32,7 +32,7 @@ interface APIServer {
     fun serverTime(): LocalDateTime
 
     /**
-     * Report whether this node is started up or not
+     * Report whether this node is started up or not.
      */
     @GET
     @Path("status")

node/src/main/kotlin/com/r3corda/node/api/Query.kt

@@ -1,7 +1,7 @@
 package com.r3corda.node.api
 
 /**
- * Extremely rudimentary query language which should most likely be replaced with a product
+ * Extremely rudimentary query language which should most likely be replaced with a product.
  */
 interface StatesQuery {
     companion object {

node/src/main/kotlin/com/r3corda/node/internal/AbstractNode.kt

@@ -71,7 +71,7 @@ abstract class AbstractNode(val dir: Path, val configuration: NodeConfiguration,
 
     // TODO: Persist this, as well as whether the node is registered.
     /**
-     * Sequence number of changes sent to the network map service, when registering/de-registering this node
+     * Sequence number of changes sent to the network map service, when registering/de-registering this node.
      */
     var networkMapSeq: Long = 1
 
@@ -202,7 +202,7 @@ abstract class AbstractNode(val dir: Path, val configuration: NodeConfiguration,
 
 
     /**
-     * Run any tasks that are needed to ensure the node is in a correct state before running start()
+     * Run any tasks that are needed to ensure the node is in a correct state before running start().
      */
     open fun setup(): AbstractNode {
         createNodeDir()

node/src/main/kotlin/com/r3corda/node/internal/Node.kt

@@ -42,15 +42,15 @@ class ConfigurationException(message: String) : Exception(message)
  * @param dir A [Path] to a location on disk where working files can be found or stored.
  * @param p2pAddr The host and port that this server will use. It can't find out its own external hostname, so you
  *                have to specify that yourself.
- * @param configuration This is typically loaded from a .properties file
+ * @param configuration This is typically loaded from a .properties file.
  * @param networkMapAddress An external network map service to use. Should only ever be null when creating the first
  * network map service, while bootstrapping a network.
  * @param advertisedServices The services this node advertises. This must be a subset of the services it runs,
  * but nodes are not required to advertise services they run (hence subset).
  * @param clientAPIs A list of JAX-RS annotated classes to register
  * which will be used to register any extra client web interfaces the node requires for demos to use.
- * Listed clientAPI classes are assumed to have to take a single APIServer constructor parameter
- * @param clock The clock used within the node and by all protocols etc
+ * Listed clientAPI classes are assumed to have to take a single APIServer constructor parameter.
+ * @param clock The clock used within the node and by all protocols etc.
  */
 class Node(dir: Path, val p2pAddr: HostAndPort, val webServerAddr: HostAndPort, configuration: NodeConfiguration,
            networkMapAddress: NodeInfo?, advertisedServices: Set<ServiceType>,

node/src/main/kotlin/com/r3corda/node/internal/testing/TestClock.kt

@@ -12,7 +12,7 @@ import javax.annotation.concurrent.ThreadSafe
 
 
 /**
- * A [Clock] that can have the time advanced for use in testing
+ * A [Clock] that can have the time advanced for use in testing.
  */
 @ThreadSafe
 class TestClock(private var delegateClock: Clock = Clock.systemUTC()) : MutableClock(), SerializeAsToken {

node/src/main/kotlin/com/r3corda/node/services/api/AbstractNodeService.kt

@@ -19,9 +19,9 @@ abstract class AbstractNodeService(val net: MessagingService, val networkMapCach
     /**
      * Register a handler for a message topic. In comparison to using net.addMessageHandler() this manages a lot of
      * common boilerplate code. Exceptions are caught and passed to the provided consumer.  If you just want a simple
-     * acknowledgement response with no content, use [com.r3corda.core.messaging.Ack]
+     * acknowledgement response with no content, use [com.r3corda.core.messaging.Ack].
      *
-     * @param topic the topic, without the default session ID postfix (".0)
+     * @param topic the topic, without the default session ID postfix (".0).
      * @param handler a function to handle the deserialised request and return an optional response (if return type not Unit)
      * @param exceptionConsumer a function to which any thrown exception is passed.
      */
@@ -47,10 +47,10 @@ abstract class AbstractNodeService(val net: MessagingService, val networkMapCach
     /**
      * Register a handler for a message topic. In comparison to using net.addMessageHandler() this manages a lot of
      * common boilerplate code. Exceptions are propagated to the messaging layer.  If you just want a simple
-     * acknowledgement response with no content, use [com.r3corda.core.messaging.Ack]
+     * acknowledgement response with no content, use [com.r3corda.core.messaging.Ack].
      *
-     * @param topic the topic, without the default session ID postfix (".0)
-     * @param handler a function to handle the deserialised request and return an optional response (if return type not Unit)
+     * @param topic the topic, without the default session ID postfix (".0).
+     * @param handler a function to handle the deserialised request and return an optional response (if return type not Unit).
      */
     protected inline fun <reified Q : ServiceRequestMessage, reified R : Any>
             addMessageHandler(topic: String,

node/src/main/kotlin/com/r3corda/node/services/api/ServiceHubInternal.kt

@@ -16,7 +16,7 @@ abstract class ServiceHubInternal : ServiceHub {
      * sends them to the wallet for further processing. This is intended for implementations to call from
      * [recordTransactions].
      *
-     * @param txs The transactions to record
+     * @param txs The transactions to record.
      */
     internal fun recordTransactionsInternal(writableStorageService: TxWritableStorageService, txs: Iterable<SignedTransaction>) {
         txs.forEach { writableStorageService.validatedTransactions.addTransaction(it) }
@@ -26,7 +26,7 @@ abstract class ServiceHubInternal : ServiceHub {
     /**
      * TODO: borrowing this method from service manager work in another branch.  It's required to avoid circular dependency
      *       between SMM and the scheduler.  That particular problem should also be resolved by the service manager work
-     *       itself, at which point this method would not be needed (by the scheduler)
+     *       itself, at which point this method would not be needed (by the scheduler).
      */
     abstract fun <T> startProtocol(loggerName: String, logic: ProtocolLogic<T>): ListenableFuture<T>
 
@@ -36,4 +36,4 @@ abstract class ServiceHubInternal : ServiceHub {
         val logic = protocolLogicRefFactory.toProtocolLogic(logicRef) as ProtocolLogic<T>
         return startProtocol(logicType.simpleName, logic)
     }
-}
+}

node/src/main/kotlin/com/r3corda/node/services/clientapi/NodeInterestRates.kt

@@ -97,7 +97,7 @@ object NodeInterestRates {
         }
 
         /**
-         * Register the protocol that is used with the Fixing integration tests
+         * Register the protocol that is used with the Fixing integration tests.
          */
         class FixingServicePlugin : CordaPluginRegistry {
             override val webApis: List<Class<*>> = emptyList()
@@ -252,7 +252,7 @@ object NodeInterestRates {
 
         /**
          * Returns the interest rate for a given [Tenor],
-         * or _null_ if the rate is not found and cannot be interpolated
+         * or _null_ if the rate is not found and cannot be interpolated.
          */
         fun getRate(tenor: Tenor): BigDecimal? {
             return rates.getOrElse(tenor) {
@@ -297,4 +297,4 @@ object NodeInterestRates {
         val name = words.dropLast(2).joinToString(" ")
         return FixOf(name, LocalDate.parse(date), Tenor(tenorString))
     }
-}
+}

node/src/main/kotlin/com/r3corda/node/services/keys/E2ETestKeyManagementService.kt

@@ -17,9 +17,9 @@ import javax.annotation.concurrent.ThreadSafe
  *   on a separate/firewalled service.
  * - Use the protocol framework so requests to fetch keys can be suspended whilst a human signs off on the request.
  * - Use deterministic key derivation.
- * - Possibly have some sort of TREZOR-like two-factor authentication ability
+ * - Possibly have some sort of TREZOR-like two-factor authentication ability.
  *
- * etc
+ * etc.
  */
 @ThreadSafe
 class E2ETestKeyManagementService(initialKeys: Set<KeyPair>) : SingletonSerializeAsToken(), KeyManagementService {
@@ -47,4 +47,4 @@ class E2ETestKeyManagementService(initialKeys: Set<KeyPair>) : SingletonSerializ
         }
         return keypair
     }
-}
+}

node/src/main/kotlin/com/r3corda/node/services/network/InMemoryMessagingNetwork.kt

@@ -85,9 +85,9 @@ class InMemoryMessagingNetwork(val sendManuallyPumped: Boolean) : SingletonSeria
     /**
      * Creates a node at the given address: useful if you want to recreate a node to simulate a restart.
      *
-     * @param manuallyPumped see [createNode]
+     * @param manuallyPumped see [createNode].
      * @param id the numeric ID to use, e.g. set to whatever ID the node used last time.
-     * @param description text string that identifies this node for message logging (if is enabled) or null to autogenerate
+     * @param description text string that identifies this node for message logging (if is enabled) or null to autogenerate.
      */
     fun createNodeWithID(manuallyPumped: Boolean, id: Int, description: String? = null): MessagingServiceBuilder<InMemoryMessaging> {
         return Builder(manuallyPumped, Handle(id, description ?: "In memory node $id"))

node/src/main/kotlin/com/r3corda/node/services/transactions/NotaryService.kt

@@ -12,12 +12,12 @@ import com.r3corda.protocols.NotaryProtocol
 
 /**
  * A Notary service acts as the final signer of a transaction ensuring two things:
- * - The (optional) timestamp of the transaction is valid
+ * - The (optional) timestamp of the transaction is valid.
  * - None of the referenced input states have previously been consumed by a transaction signed by this Notary
  *
  * A transaction has to be signed by a Notary to be considered valid (except for output-only transactions without a timestamp).
  *
- * This is the base implementation that can be customised with specific Notary transaction commit protocol
+ * This is the base implementation that can be customised with specific Notary transaction commit protocol.
  */
 abstract class NotaryService(val smm: StateMachineManager,
                              net: MessagingService,

node/src/main/kotlin/com/r3corda/node/servlets/Config.kt

@@ -8,10 +8,10 @@ import javax.ws.rs.ext.Provider
 
 /**
  * Primary purpose is to install Kotlin extensions for Jackson ObjectMapper so data classes work
- * and to organise serializers / deserializers for java.time.* classes as necessary
+ * and to organise serializers / deserializers for java.time.* classes as necessary.
  */
 @Provider
 class Config(val services: ServiceHub) : ContextResolver<ObjectMapper> {
     val defaultObjectMapper = JsonSupport.createDefaultMapper(services.identityService)
     override fun getContext(type: Class<*>) = defaultObjectMapper
-}
+}

node/src/main/kotlin/com/r3corda/node/servlets/ResponseFilter.kt

@@ -6,7 +6,7 @@ import javax.ws.rs.container.ContainerResponseFilter
 import javax.ws.rs.ext.Provider
 
 /**
- * This adds headers needed for cross site scripting on API clients
+ * This adds headers needed for cross site scripting on API clients.
  */
 @Provider
 class ResponseFilter : ContainerResponseFilter {
@@ -18,7 +18,7 @@ class ResponseFilter : ContainerResponseFilter {
          *
          * We don't want this scriptable from any web page anywhere, but for demo reasons
          * we're making this really easy to access pending a proper security approach including
-         * access control and authentication at a network and software level
+         * access control and authentication at a network and software level.
          *
          */
         headers.add("Access-Control-Allow-Origin", "*")

node/src/main/kotlin/com/r3corda/node/utilities/ClockUtils.kt

@@ -77,7 +77,7 @@ abstract class MutableClock : Clock() {
  * of it being mutated.  Just returns if [MutableClock] mutates, so needs to be
  * called in a loop.
  *
- * @throws InterruptedException if interrupted by something other than a [MutableClock]
+ * @throws InterruptedException if interrupted by something other than a [MutableClock].
  */
 @Suppress("UNUSED_VALUE") // This is here due to the compiler thinking version is not used
 @Suspendable
@@ -107,9 +107,9 @@ private fun Clock.doInterruptibly(runnable: SuspendableRunnable) {
 
 /**
  * Wait until the given [Future] is complete or the deadline is reached, with support for [MutableClock] implementations
- * used in demos or testing.  This will also substitute a Fiber compatible Future if required
+ * used in demos or testing.  This will also substitute a Fiber compatible Future if required.
  *
- * @return true if the [Future] is complete, false if the deadline was reached
+ * @return true if the [Future] is complete, false if the deadline was reached.
  */
 @Suspendable
 fun Clock.awaitWithDeadline(deadline: Instant, future: Future<*> = SettableFuture<Any>()): Boolean {

node/src/main/kotlin/com/r3corda/node/utilities/FiberBox.kt

@@ -12,7 +12,7 @@ import kotlin.concurrent.withLock
 
 
 /**
- * Modelled on [ThreadBox], but with support for waiting that is compatible with Quasar [Fiber]s and [MutableClock]s
+ * Modelled on [ThreadBox], but with support for waiting that is compatible with Quasar [Fiber]s and [MutableClock]s.
  *
  * 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.
@@ -74,4 +74,4 @@ class FiberBox<T>(private val content: T, private val lock: Lock = ReentrantLock
             lock.unlock()
         }
     }
-}
+}

node/src/main/kotlin/com/r3corda/node/utilities/JsonSupport.kt

@@ -109,7 +109,7 @@ object JsonSupport {
     }
 
     /**
-     * Implemented as a class so that we can instantiate for T
+     * Implemented as a class so that we can instantiate for T.
      */
     class SecureHashDeserializer<T : SecureHash> : JsonDeserializer<T>() {
         override fun deserialize(parser: JsonParser, context: DeserializationContext): T {