@@ -484,6 +484,7 @@ int ServicePrimProc::Child()
484484 BRPBlocks = BRPBlocksPct / 8192 ;
485485 else
486486 BRPBlocks = ((BRPBlocksPct / 100.0 ) * (double )cg.getTotalMemory ()) / 8192 ;
487+ std::cout << " [init] after line 486: BRPBlocks=" << BRPBlocks << std::endl;
487488#if 0
488489 temp = toInt(cf->getConfig(dbbc, "NumThreads"));
489490
@@ -550,7 +551,9 @@ int ServicePrimProc::Child()
550551 aggPct = temp;
551552
552553 // ...Start the thread to monitor our memory usage
554+ std::cout << " [init] before MonitorProcMem ctor/spawn (line ~553)" << std::endl;
553555 new boost::thread (utils::MonitorProcMem (maxPct, aggPct, 28 ));
556+ std::cout << " [init] after MonitorProcMem spawn" << std::endl;
554557
555558 // config file priority is 40..1 (highest..lowest)
556559 string sPriority = cf->getConfig (primitiveServers, " Priority" );
@@ -572,7 +575,9 @@ int ServicePrimProc::Child()
572575 setpriority (PRIO_PROCESS , 0 , priority);
573576 // ..Instantiate UmSocketSelector singleton. Disable rotating destination
574577 // ..selection if no UM IP addresses are in the Calpo67108864LLnt.xml file.
578+ std::cout << " [init] before UmSocketSelector::instance() (line ~575)" << std::endl;
575579 UmSocketSelector* pUmSocketSelector = UmSocketSelector::instance ();
580+ std::cout << " [init] after UmSocketSelector::instance()" << std::endl;
576581
577582 if (rotatingDestination)
578583 {
@@ -590,7 +595,9 @@ int ServicePrimProc::Child()
590595 {
591596 // count the actual #cores
592597
598+ std::cout << " [init] before cg.getNumCores() (line ~593)" << std::endl;
593599 numCores = cg.getNumCores ();
600+ std::cout << " [init] after cg.getNumCores(): " << numCores << std::endl;
594601
595602 if (numCores == 0 )
596603 numCores = 8 ;
@@ -648,21 +655,26 @@ int ServicePrimProc::Child()
648655 if ((strVal == " n" ) || (strVal == " N" ))
649656 directIOFlag = 0 ;
650657
658+ std::cout << " [init] before IDBPolicy::configIDBPolicy() (line ~651)" << std::endl;
651659 IDBPolicy::configIDBPolicy ();
660+ std::cout << " [init] after IDBPolicy::configIDBPolicy()" << std::endl;
652661
653662 // no versionbuffer if using HDFS for performance reason
654663 if (IDBPolicy::useHdfs ())
655664 noVB = 1 ;
665+ std::cout << " [init] before Starting PrimitiveServer cout (line ~657)" << std::endl;
656666
657667 cout << " Starting PrimitiveServer: st = " << serverThreads << " , sq = " << serverQueueSize
658668 << " , pw = " << processorWeight << " , pq = " << processorQueueSize << " , nb = " << BRPBlocks
659669 << " , nt = " << BRPThreads << " , nc = " << cacheCount << " , ra = " << blocksReadAhead
660670 << " , db = " << deleteBlocks << " , mb = " << maxBlocksPerRead << " , rd = " << rotatingDestination
661671 << " , tr = " << PTTrace << " , ss = " << PMSmallSide << " , bp = " << BPPCount << endl;
662672
673+ std::cout << " [init] before PrimitiveServer ctor (line ~663)" << std::endl;
663674 PrimitiveServer server (serverThreads, serverQueueSize, processorWeight, processorQueueSize,
664675 rotatingDestination, BRPBlocks, BRPThreads, cacheCount, maxBlocksPerRead,
665676 blocksReadAhead, deleteBlocks, PTTrace, prefetchThreshold, PMSmallSide);
677+ std::cout << " [init] after PrimitiveServer ctor" << std::endl;
666678
667679#ifdef QSIZE_DEBUG
668680 thread* qszMonThd;
@@ -696,6 +708,7 @@ int ServicePrimProc::Child()
696708
697709 primServerThreadPool = server.getProcessorThreadPool ();
698710
711+ std::cout << " [init] before server.start() (line ~699)" << std::endl;
699712 server.start (this , startupRaceLock);
700713
701714 cerr << " server.start() exited!" << endl;
0 commit comments