Dash Core Source Documentation (0.16.0.1)
Find detailed information regarding the Dash Core source code.
Public Types | |
typedef Aggregator< T > | AggregatorType |
typedef std::vector< T > | VectorType |
typedef std::shared_ptr< VectorType > | VectorPtrType |
typedef std::vector< VectorPtrType > | VectorVectorType |
typedef std::function< void(const VectorPtrType &agg)> | DoneCallback |
Public Member Functions | |
VectorAggregator (const VectorVectorType &_vecs, size_t _start, size_t _count, bool _parallel, ctpl::thread_pool &_workerPool, DoneCallback _doneCallback) | |
void | Start () |
void | CheckDone (const T &agg, size_t idx) |
Public Attributes | |
DoneCallback | doneCallback |
const VectorVectorType & | vecs |
size_t | start |
size_t | count |
bool | parallel |
ctpl::thread_pool & | workerPool |
std::atomic< size_t > | doneCount |
VectorPtrType | result |
size_t | vecSize |
Detailed Description
template<typename T>
struct VectorAggregator< T >
Definition at line 333 of file bls_worker.cpp.
Member Typedef Documentation
◆ AggregatorType
typedef Aggregator<T> VectorAggregator< T >::AggregatorType |
Definition at line 334 of file bls_worker.cpp.
◆ DoneCallback
typedef std::function<void(const VectorPtrType& agg)> VectorAggregator< T >::DoneCallback |
Definition at line 338 of file bls_worker.cpp.
◆ VectorPtrType
typedef std::shared_ptr<VectorType> VectorAggregator< T >::VectorPtrType |
Definition at line 336 of file bls_worker.cpp.
◆ VectorType
typedef std::vector<T> VectorAggregator< T >::VectorType |
Definition at line 335 of file bls_worker.cpp.
◆ VectorVectorType
typedef std::vector<VectorPtrType> VectorAggregator< T >::VectorVectorType |
Definition at line 337 of file bls_worker.cpp.
Constructor & Destructor Documentation
◆ VectorAggregator()
|
inline |
Definition at line 352 of file bls_worker.cpp.
References VectorAggregator< T >::doneCount, VectorAggregator< T >::result, VectorAggregator< T >::vecs, and VectorAggregator< T >::vecSize.
Member Function Documentation
◆ CheckDone()
|
inline |
Definition at line 387 of file bls_worker.cpp.
References VectorAggregator< T >::doneCallback, VectorAggregator< T >::doneCount, VectorAggregator< T >::result, and VectorAggregator< T >::vecSize.
Referenced by VectorAggregator< T >::Start().
◆ Start()
|
inline |
Definition at line 369 of file bls_worker.cpp.
References VectorAggregator< T >::CheckDone(), VectorAggregator< T >::count, VectorAggregator< T >::parallel, VectorAggregator< T >::start, VectorAggregator< T >::vecs, VectorAggregator< T >::vecSize, and VectorAggregator< T >::workerPool.
Referenced by ContributionVerifier::AsyncAggregate(), and CBLSWorker::AsyncBuildQuorumVerificationVector().
Member Data Documentation
◆ count
size_t VectorAggregator< T >::count |
Definition at line 343 of file bls_worker.cpp.
Referenced by VectorAggregator< T >::Start().
◆ doneCallback
DoneCallback VectorAggregator< T >::doneCallback |
Definition at line 339 of file bls_worker.cpp.
Referenced by VectorAggregator< T >::CheckDone().
◆ doneCount
std::atomic<size_t> VectorAggregator< T >::doneCount |
Definition at line 347 of file bls_worker.cpp.
Referenced by VectorAggregator< T >::CheckDone(), and VectorAggregator< T >::VectorAggregator().
◆ parallel
bool VectorAggregator< T >::parallel |
Definition at line 344 of file bls_worker.cpp.
Referenced by VectorAggregator< T >::Start().
◆ result
VectorPtrType VectorAggregator< T >::result |
Definition at line 349 of file bls_worker.cpp.
Referenced by VectorAggregator< T >::CheckDone(), and VectorAggregator< T >::VectorAggregator().
◆ start
size_t VectorAggregator< T >::start |
Definition at line 342 of file bls_worker.cpp.
Referenced by VectorAggregator< T >::Start().
◆ vecs
const VectorVectorType& VectorAggregator< T >::vecs |
Definition at line 341 of file bls_worker.cpp.
Referenced by VectorAggregator< T >::Start(), and VectorAggregator< T >::VectorAggregator().
◆ vecSize
size_t VectorAggregator< T >::vecSize |
Definition at line 350 of file bls_worker.cpp.
Referenced by VectorAggregator< T >::CheckDone(), VectorAggregator< T >::Start(), and VectorAggregator< T >::VectorAggregator().
◆ workerPool
ctpl::thread_pool& VectorAggregator< T >::workerPool |
Definition at line 345 of file bls_worker.cpp.
Referenced by VectorAggregator< T >::Start().
The documentation for this struct was generated from the following file:
- src/bls/bls_worker.cpp