addressing review

Signed-off-by: dorjesinpo <129227380+dorjesinpo@users.noreply.github.com>
bloomberg · Sep 18, 2024 · 244398f · 244398f
1 parent 8a4e3ad
commit 244398f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/groups/mqb/mqbblp/mqbblp_cluster.h b/src/groups/mqb/mqbblp/mqbblp_cluster.h
@@ -546,7 +546,7 @@ class Cluster : public mqbi::Cluster,
  mqbi::DomainFactory* domainFactory,
  mqbi::Dispatcher* dispatcher,
  mqbnet::TransportManager* transportManager,
- const mqbi::ClusterResources&  resources,
+ const mqbi::ClusterResources& resources,
  bslma::Allocator* allocator,
  const mqbnet::Session::AdminCommandEnqueueCb& adminCb);
 

diff --git a/src/groups/mqb/mqbblp/mqbblp_pushstream.cpp b/src/groups/mqb/mqbblp/mqbblp_pushstream.cpp
@@ -44,6 +44,8 @@ PushStream::PushStream(
  noOpDeleter,
  allocator)
 {
+ allocator = bslma::Default::allocator(allocator);
+
  if (!d_pushElementsPool_sp) {
  d_pushElementsPool_sp.load(
  new (*allocator) bdlma::ConcurrentPool(sizeof(Element), allocator),
@@ -129,8 +131,6 @@ void PushStreamIterator::removeCurrentElement()
  // doKeepGuid because of the d_iterator
 
  if (d_iterator->second.numElements() == 0) {
- // d_currentElement->eraseFromStream(d_owner_p->d_stream);
-
  BSLS_ASSERT_SAFE(d_currentElement == 0);
  }
 }