Skip to content

Commit

Permalink
Bugfixes
Browse files Browse the repository at this point in the history
  • Loading branch information
davschneller committed May 21, 2024
1 parent dd69ff0 commit cd5ba73
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 5 deletions.
2 changes: 1 addition & 1 deletion async/as/MPIAsync.h
Original file line number Diff line number Diff line change
Expand Up @@ -195,7 +195,7 @@ class MPIAsync : public MPIBase<Executor, InitParameter, Parameter> {
(Base<Executor, InitParameter, Parameter>::bufferSize(id)));

if (Base<Executor, InitParameter, Parameter>::origin(id)) {
async::ExecInfo::bufferOrigin(id)->copyFrom(
async::ExecInfo::bufferOrigin(id).copyFrom(
Base<Executor, InitParameter, Parameter>::_buffer(id) +
MPIBase<Executor, InitParameter, Parameter>::bufferPos(id),
Base<Executor, InitParameter, Parameter>::origin(id) +
Expand Down
2 changes: 2 additions & 0 deletions async/as/MPIBase.h
Original file line number Diff line number Diff line change
Expand Up @@ -248,6 +248,8 @@ class MPIBase : public ThreadBase<Executor, InitParameter, Parameter>, private S
return std::max(sizeof(InitParameter), sizeof(Parameter));
}

bool useAsyncCopy() const override {}

bool useAsyncCopy(unsigned int id) const override {
assert(id < m_executorBuffer.size());

Expand Down
6 changes: 3 additions & 3 deletions async/as/Sync.h
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ class Sync : public Base<Executor, InitParameter, Parameter> {

const void* buffer(unsigned int id) const override {
if (Base<Executor, InitParameter, Parameter>::origin(id) &&
async::ExecInfo::bufferOrigin(id)->transparentHost()) {
async::ExecInfo::bufferOrigin(id).transparentHost()) {
return Base<Executor, InitParameter, Parameter>::origin(id);
}

Expand All @@ -77,8 +77,8 @@ class Sync : public Base<Executor, InitParameter, Parameter> {

void sendBuffer(unsigned int id, size_t size) override {
if (Base<Executor, InitParameter, Parameter>::origin(id) &&
!async::ExecInfo::bufferOrigin(id)->transparentHost()) {
async::ExecInfo::bufferOrigin(id)->copyFrom(
!async::ExecInfo::bufferOrigin(id).transparentHost()) {
async::ExecInfo::bufferOrigin(id).copyFrom(
Base<Executor, InitParameter, Parameter>::_buffer(id),
Base<Executor, InitParameter, Parameter>::origin(id),
async::ExecInfo::bufferSize(id));
Expand Down
2 changes: 1 addition & 1 deletion async/as/Thread.h
Original file line number Diff line number Diff line change
Expand Up @@ -163,7 +163,7 @@ class Thread : public ThreadBase<Executor, InitParameter, Parameter> {
assert(m_buffer[id].position + size <=
(Base<Executor, InitParameter, Parameter>::bufferSize(id)));

async::ExecInfo::bufferOrigin(id)->copyFrom(
async::ExecInfo::bufferOrigin(id).copyFrom(
Base<Executor, InitParameter, Parameter>::_buffer(id) + m_buffer[id].position,
Base<Executor, InitParameter, Parameter>::origin(id) + m_buffer[id].position,
size);
Expand Down

0 comments on commit cd5ba73

Please sign in to comment.