Skip to content

Commit

Permalink
doc string
Browse files Browse the repository at this point in the history
  • Loading branch information
Binyang2014 committed Jul 27, 2023
1 parent 59e15c8 commit b9ec5a6
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 1 deletion.
3 changes: 3 additions & 0 deletions include/mscclpp/proxy_channel.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,9 @@ class ProxyService : public BaseProxyService {
/// @return The ID of the semaphore.
SemaphoreId addSemaphore(std::shared_ptr<Connection> connection);

/// Add a pitch pair to the proxy service.
/// @param id The ID of the semaphore.
/// @param pitch The pitch pair.
void addPitch(SemaphoreId id, std::pair<uint64_t, uint64_t> pitch);

/// Register a memory region with the proxy service.
Expand Down
2 changes: 1 addition & 1 deletion src/proxy_channel.cc
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ ProxyHandlerResult ProxyService::handleTrigger(ProxyTrigger triggerRaw) {
RegisteredMemory& dst = memories_[trigger->fields.dstMemoryId];
RegisteredMemory& src = memories_[trigger->fields.srcMemoryId];
if (trigger->fields2D.multiDimensionFlag) {
std::pair<uint64_t, uint64_t>& pitch = pitches_[trigger->fields.chanId];
std::pair<uint64_t, uint64_t>& pitch = pitches_.at(trigger->fields.chanId);
semaphore->connection()->write2D(dst, trigger->fields.dstOffset, pitch.first, src, trigger->fields.srcOffset,
pitch.second, trigger->fields2D.width, trigger->fields2D.height);
} else {
Expand Down

0 comments on commit b9ec5a6

Please sign in to comment.