Skip to content

Commit

Permalink
Cosmetic: Remove trailing whitespace
Browse files Browse the repository at this point in the history
No change to code or comments.
  • Loading branch information
don-clugston-sociomantic authored and gavin-norman-sociomantic committed Aug 8, 2019
1 parent 42df086 commit d02f152
Show file tree
Hide file tree
Showing 16 changed files with 36 additions and 36 deletions.
6 changes: 3 additions & 3 deletions src/dhtproto/node/request/Exists.d
Expand Up @@ -52,7 +52,7 @@ public abstract scope class Exists : SingleKey
}

/***************************************************************************
Params:
channel_name = channel name for request that was read and validated
earlier
Expand All @@ -70,11 +70,11 @@ public abstract scope class Exists : SingleKey
/***************************************************************************
Force "accept-all" behaviour for `isAllowed`
Hash range check isn't done for read requests (including 'Exists').
It's a practical concern to keep the dht running as best as possible,
while a redistribution is in progress.
The situation is as follows:
1. all writing clients are shut down. Readers stay active.
2. a redistribution is triggered
Expand Down
6 changes: 3 additions & 3 deletions src/dhtproto/node/request/Get.d
Expand Up @@ -54,11 +54,11 @@ public abstract scope class Get : SingleKey
/***************************************************************************
Force "accept-all" behaviour for `isAllowed`
Hash range check isn't done for read (Get) requests. It's a practical
concern to keep the dht running as best as possible, while a
redistribution is in progress.
The situation is as follows:
1. all writing clients are shut down. Readers stay active.
2. a redistribution is triggered
Expand All @@ -77,7 +77,7 @@ public abstract scope class Get : SingleKey
}

/***************************************************************************
Sends queried record to client
Params:
Expand Down
6 changes: 3 additions & 3 deletions src/dhtproto/node/request/GetAllFilter.d
Expand Up @@ -23,7 +23,7 @@ import ocean.transition;
import dhtproto.node.request.model.CompressedBatch;

/*******************************************************************************
Request protocol
*******************************************************************************/
Expand Down Expand Up @@ -52,7 +52,7 @@ public abstract scope class GetAllFilter : CompressedBatch!(mstring, mstring)
}

/***************************************************************************
Read filter data from the client
***************************************************************************/
Expand All @@ -65,7 +65,7 @@ public abstract scope class GetAllFilter : CompressedBatch!(mstring, mstring)
}

/***************************************************************************
Allows request to process read filter string into more efficient form
and save it before starting actual record iteration.
Expand Down
2 changes: 1 addition & 1 deletion src/dhtproto/node/request/GetNumConnections.d
Expand Up @@ -50,7 +50,7 @@ public abstract scope class GetNumConnections : DhtCommand
}

/***************************************************************************
Payload struct that holds the data requested
***************************************************************************/
Expand Down
4 changes: 2 additions & 2 deletions src/dhtproto/node/request/Listen.d
Expand Up @@ -59,7 +59,7 @@ public abstract scope class Listen : SingleChannel
Keeps sending new records in dht channel to client until channel
gets removed or client closes connection
Params:
channel_name = channel name for request that was read and validated
earlier
Expand Down Expand Up @@ -108,7 +108,7 @@ public abstract scope class Listen : SingleChannel

if (disconnect_detector.disconnected)
return;

this.writer.fiber.register(this.writer);

Hash.HexDigest key;
Expand Down
4 changes: 2 additions & 2 deletions src/dhtproto/node/request/Put.d
Expand Up @@ -106,7 +106,7 @@ public abstract scope class Put : SingleKey
}

/***************************************************************************
Stores incoming record
Params:
Expand All @@ -132,7 +132,7 @@ public abstract scope class Put : SingleKey
this.writer.write(DhtConst.Status.E.EmptyValue);
return;
}

if (!this.isSizeAllowed(value.length))
{
this.writer.write(DhtConst.Status.E.OutOfMemory);
Expand Down
6 changes: 3 additions & 3 deletions src/dhtproto/node/request/PutBatch.d
Expand Up @@ -62,7 +62,7 @@ public abstract scope class PutBatch : SingleChannel
}

/***************************************************************************
Read batch of records to put into the channel
***************************************************************************/
Expand All @@ -73,7 +73,7 @@ public abstract scope class PutBatch : SingleChannel
}

/***************************************************************************
Params:
channel_name = channel name for request that was read and validated
earlier
Expand All @@ -98,7 +98,7 @@ public abstract scope class PutBatch : SingleChannel
this.writer.write(DhtConst.Status.E.WrongNode);
return;
}

if (!this.isSizeAllowed(value.length))
{
this.writer.write(DhtConst.Status.E.OutOfMemory);
Expand Down
4 changes: 2 additions & 2 deletions src/dhtproto/node/request/Redistribute.d
Expand Up @@ -70,7 +70,7 @@ public abstract scope class Redistribute : DhtCommand
private hash_t min, max;

/***************************************************************************
Pointer to external data buffer used to store incoming redistribution
data
Expand Down Expand Up @@ -151,7 +151,7 @@ public abstract scope class Redistribute : DhtCommand
}

/***************************************************************************
Validates hash ranges and forward to derivative methods to do actual
redistribution which is 100% implementation-defined
Expand Down
2 changes: 1 addition & 1 deletion src/dhtproto/node/request/Remove.d
Expand Up @@ -52,7 +52,7 @@ public abstract scope class Remove : SingleKey
}

/***************************************************************************
Params:
channel_name = channel name for request that was read and validated
earlier
Expand Down
8 changes: 4 additions & 4 deletions src/dhtproto/node/request/model/CompressedBatch.d
Expand Up @@ -106,7 +106,7 @@ public abstract scope class CompressedBatch(T...) : SingleChannel
Params:
channel_name = channel name for request that was read and validated
earlier
***************************************************************************/

final override protected void handleChannelRequest ( cstring channel_name )
Expand Down Expand Up @@ -152,7 +152,7 @@ public abstract scope class CompressedBatch(T...) : SingleChannel
assert(false, "Invalid AddResult in switch");
}
}

// handle last pending batch at the end of iteration (does nothing if no records are pending)
writeBatch();

Expand All @@ -161,7 +161,7 @@ public abstract scope class CompressedBatch(T...) : SingleChannel
}

/***************************************************************************
Returns current record to be sent to the client. May handle fiber
context switches and event loop internally if necessary. Always returns
same record until this.fetchNext gets called.
Expand All @@ -181,7 +181,7 @@ public abstract scope class CompressedBatch(T...) : SingleChannel
/******************************************************************************
Params:
args = variadic list of array arguments
args = variadic list of array arguments
Returns:
length of largest array among arguments
Expand Down
4 changes: 2 additions & 2 deletions src/dhtproto/node/request/model/DhtCommand.d
Expand Up @@ -24,7 +24,7 @@ import ocean.core.Verify;
import swarm.node.protocol.Command;

/*******************************************************************************
DHT command base class
*******************************************************************************/
Expand All @@ -37,7 +37,7 @@ public abstract scope class DhtCommand : Command
import dhtproto.client.legacy.DhtConst;

/***************************************************************************
Holds set of method to access temporary resources used by dhtnode
protocol classes. Those all are placed into single class to simplify
maintenance and eventually may be replaced with more automatic approach.
Expand Down
8 changes: 4 additions & 4 deletions src/dhtproto/node/request/model/SingleChannel.d
Expand Up @@ -79,7 +79,7 @@ public abstract scope class SingleChannel : DhtCommand
}

/***************************************************************************
If protocol for derivate request needs any parameters other than
channel name and request code, this method must be overridden to read
and store those.
Expand All @@ -90,7 +90,7 @@ public abstract scope class SingleChannel : DhtCommand

/***************************************************************************
Validate the channel name that comes from `readRequestData`.
Validate the channel name that comes from `readRequestData`.
Also ensures that channel can be worked with (via method overridden
in request-specific classes) and makes appropriate status response.
Expand Down Expand Up @@ -120,7 +120,7 @@ public abstract scope class SingleChannel : DhtCommand
/***************************************************************************
Ensures that requested channel exists or can be created and in general
can be read from or written to.
can be read from or written to.
By default this is no-op method that always succeeds.
Expand All @@ -142,7 +142,7 @@ public abstract scope class SingleChannel : DhtCommand
Params:
channel_name = channel name for request that was read and validated
earlier
***************************************************************************/

abstract protected void handleChannelRequest ( cstring channel_name );
Expand Down
4 changes: 2 additions & 2 deletions src/fakedht/request/GetAllFilter.d
Expand Up @@ -53,7 +53,7 @@ public scope class GetAllFilter : Protocol.GetAllFilter
mixin RequestConstruction!();

/***************************************************************************
Predicate that accepts records that match filter defined by this.match
Params:
Expand All @@ -80,7 +80,7 @@ public scope class GetAllFilter : Protocol.GetAllFilter
mixin ChannelIteration!(IterationKind.KeyValue, filterPredicate);

/***************************************************************************
Initialized regex match based on provided filter string
Params:
Expand Down
2 changes: 1 addition & 1 deletion src/fakedht/request/GetSize.d
Expand Up @@ -39,7 +39,7 @@ public scope class GetSize : Protocol.GetSize
***************************************************************************/

mixin RequestConstruction!();

/***************************************************************************
Must return aggregated size of all channels.
Expand Down
4 changes: 2 additions & 2 deletions src/fakedht/request/Listen.d
Expand Up @@ -59,7 +59,7 @@ public scope class Listen : Protocol.Listen, DhtListener

/***************************************************************************
Indicates that channel has been deleted and request needs to be
Indicates that channel has been deleted and request needs to be
terminated
***************************************************************************/
Expand Down Expand Up @@ -213,7 +213,7 @@ public scope class Listen : Protocol.Listen, DhtListener
this.channel_deleted = true;
break;
default:
break;
break;
}

this.event.trigger();
Expand Down
2 changes: 1 addition & 1 deletion src/fakedht/request/Put.d
Expand Up @@ -58,7 +58,7 @@ public scope class Put : Protocol.Put
{
return true;
}

/***************************************************************************
Verifies that this node is allowed to store records of given size
Expand Down

0 comments on commit d02f152

Please sign in to comment.