Lines Matching refs:csep
566 …void buildSysCache(const execplan::CalpontSelectExecutionPlan& csep, boost::shared_ptr<execplan::C… in buildSysCache() argument
568 const execplan::CalpontSelectExecutionPlan::ColumnMap& colMap = csep.columnMap(); in buildSysCache()
591 … for (subIt = csep.derivedTableList().begin(); subIt != csep.derivedTableList().end(); ++ subIt) in buildSysCache()
602 execplan::CalpontSelectExecutionPlan csep; in operator ()() local
603 csep.sessionID(0); in operator ()()
643 if (gDebug > 1 || (gDebug && !csep.isInternal())) in operator ()()
644 … std::cout << "### Got a close(1) for session id " << csep.sessionID() << std::endl; in operator ()()
653 std::cout << "### Got a not-a-plan for session id " << csep.sessionID() in operator ()()
695 csep.unserialize(bs); in operator ()()
699 if ( !csep.isInternal() && in operator ()()
700 (csep.queryType() == "SELECT" || csep.queryType() == "INSERT_SELECT") ) in operator ()()
702 qts.query_uuid = csep.uuid(); in operator ()()
705 qts.query = csep.data(); in operator ()()
706 qts.session_id = csep.sessionID(); in operator ()()
707 qts.query_type = csep.queryType(); in operator ()()
710 qts.local_query = csep.localQuery(); in operator ()()
711 qts.schema_name = csep.schemaName(); in operator ()()
715 if (gDebug > 1 || (gDebug && !csep.isInternal())) in operator ()()
716 … std::cout << "### For session id " << csep.sessionID() << ", got a CSEP" << std::endl; in operator ()()
718 setRMParms(csep.rmParms()); in operator ()()
726 if (!csep.isInternal()) in operator ()()
729 execplan::CalpontSystemCatalog::makeCalpontSystemCatalog(csep.sessionID()); in operator ()()
730 buildSysCache(csep, csc); in operator ()()
738 incThreadCntPerSession( csep.sessionID() | 0x80000000 ); in operator ()()
744 std::string sqlText = csep.data(); in operator ()()
745 logging::LoggingID li(16, csep.sessionID(), csep.txnID()); in operator ()()
752 initStats( csep.sessionID(), sqlText ); in operator ()()
753 fStats.fQueryType = csep.queryType(); in operator ()()
757 if (csep.traceOn()) in operator ()()
760 args.add((int)csep.statementID()); in operator ()()
761 args.add((int)csep.verID().currentScn); in operator ()()
775 oss << sqlText << "; |" << csep.schemaName() << "|"; in operator ()()
787 jl = joblist::JobListFactory::makeJobList(&csep, fRm, true, true); in operator ()()
852 jl = joblist::JobListFactory::makeJobList(&csep, fRm, false, true); in operator ()()
883 if (gDebug > 1 || (gDebug && !csep.isInternal())) in operator ()()
884 … std::cout << "### Got a close(2) for session id " << csep.sessionID() << std::endl; in operator ()()
890 … std::cout << "### For session id " << csep.sessionID() << ", got too many bytes = " << in operator ()()
910 if (gDebug > 1 || (gDebug && !csep.isInternal())) in operator ()()
911 … std::cout << "### For session id " << csep.sessionID() << ", got a command = " << qb << std::endl; in operator ()()
934 if (gDebug > 1 || (gDebug && !csep.isInternal())) in operator ()()
935 … std::cout << "### For session id " << csep.sessionID() << ", returning end flag" << std::endl; in operator ()()
954 … !(csep.traceFlags() & execplan::CalpontSelectExecutionPlan::TRACE_TUPLE_OFF), in operator ()()
955 … (csep.traceFlags() & execplan::CalpontSelectExecutionPlan::TRACE_LOG), in operator ()()
962 … if ((csep.traceFlags() & execplan::CalpontSelectExecutionPlan::TRACE_LOG) != 0) in operator ()()
1036 … if (csep.traceFlags() & execplan::CalpontSelectExecutionPlan::TRACE_NO_ROWS3) in operator ()()
1067 decThreadCntPerSession( csep.sessionID() | 0x80000000 ); in operator ()()
1115 if (csep.traceOn()) in operator ()()
1116 jl->graph(csep.sessionID()); in operator ()()
1122 prefix << "ses:" << csep.sessionID() << " Query Totals"; in operator ()()
1129 … !(csep.traceFlags() & execplan::CalpontSelectExecutionPlan::TRACE_TUPLE_OFF), in operator ()()
1130 (csep.traceFlags() & execplan::CalpontSelectExecutionPlan::TRACE_LOG), in operator ()()
1137 args.add((int)csep.statementID()); in operator ()()
1152 deleteMaxMemPct( csep.sessionID() ); in operator ()()
1160 int stmtID = csep.statementID(); in operator ()()
1183 deleteMaxMemPct( csep.sessionID() ); in operator ()()
1187 if ((csep.traceFlags() & flagsWantOutput) && (csep.sessionID() < 0x80000000)) in operator ()()
1189 std::cout << "For session " << csep.sessionID() << ": " << in operator ()()
1196 if (csep.traceFlags() & in operator ()()
1205 else if (csep.traceFlags() & in operator ()()
1217 if ( !csep.isInternal() && in operator ()()
1218 (csep.queryType() == "SELECT" || csep.queryType() == "INSERT_SELECT") ) in operator ()()
1231 qts.session_id = csep.sessionID(); in operator ()()
1232 qts.query_type = csep.queryType(); in operator ()()
1233 qts.query = csep.data(); in operator ()()
1236 qts.local_query = csep.localQuery(); in operator ()()
1244 decThreadCntPerSession( csep.sessionID() | 0x80000000 ); in operator ()()
1248 decThreadCntPerSession( csep.sessionID() | 0x80000000 ); in operator ()()
1250 … std::cerr << "### ExeMgr ses:" << csep.sessionID() << " caught: " << ex.what() << std::endl; in operator ()()
1252 logging::LoggingID li(16, csep.sessionID(), csep.txnID()); in operator ()()
1259 decThreadCntPerSession( csep.sessionID() | 0x80000000 ); in operator ()()
1263 logging::LoggingID li(16, csep.sessionID(), csep.txnID()); in operator ()()