Skip to content

Commit

Permalink
HPCC-30468 review changes
Browse files Browse the repository at this point in the history
Signed-off-by: Jake Smith <[email protected]>
  • Loading branch information
jakesmith committed Oct 11, 2023
1 parent fba1d45 commit b398061
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 2 deletions.
8 changes: 7 additions & 1 deletion dali/base/dautils.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3647,9 +3647,15 @@ void remapGroupsToDafilesrv(IPropertyTree *file, INamedGroupStore *resolver)
group.setown(resolver->lookup(planeName, defaultDir, groupType));
}

Linked<INode> dafileSrvNodeCopy;
{
// in case config hook above changes dafileSrvNode
CriticalBlock b(dafileSrvNodeCS);
dafileSrvNodeCopy.set(dafileSrvNode);
}
std::vector<INode *> nodes;
for (unsigned n=0; n<group->ordinality(); n++)
nodes.push_back(dafileSrvNode);
nodes.push_back(dafileSrvNodeCopy);
Owned<IGroup> newGroup = createIGroup((rank_t)group->ordinality(), &nodes[0]);
StringBuffer groupText;
newGroup->getText(groupText);
Expand Down
2 changes: 1 addition & 1 deletion esp/clients/ws_dfsclient/ws_dfsclient.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -688,7 +688,7 @@ IDFSFile *lookupDFSFile(const char *logicalName, AccessMode accessMode, unsigned
// auto-discover local environment dfs service.
#ifdef _CONTAINERIZED
// NB: only expected to be here if experimental option #option('dfsesp-localfiles', true); is in use.
// This finds and uses local dfs service for local read lookkups.
// This finds and uses local dfs service for local read lookups.
Owned<IPropertyTreeIterator> eclWatchServices = getGlobalConfigSP()->getElements("services[@type='dfs']");
if (!eclWatchServices->first())
throw makeStringException(-1, "Dfs service not defined in esp services");
Expand Down

0 comments on commit b398061

Please sign in to comment.