Commit e2ff3787 authored by Giacomo Strangolino's avatar Giacomo Strangolino
Browse files

removed old prints

parent 571fc1a3
......@@ -248,9 +248,9 @@ CaCuTangoReadImpl::~CaCuTangoReadImpl() {
int CaCuTangoReadImpl::process(const CaNetMsg &netmsg) {
assert(pthread_self() == d->my_thread);
std::string channel, src = findSource(netmsg), me;
std::string channel, src = findSource(netmsg);
CaJsonSrcBundleExtract bux;
std::list<CuData> dl, sync_l, async_l;
std::list<CuData> dl;
int reco = 0;
bool proc = (src == "src-bundle");
if(proc) {
......@@ -262,8 +262,7 @@ int CaCuTangoReadImpl::process(const CaNetMsg &netmsg) {
}
for(const CuData& da : dl) { // every element in the bundle received from netmsg.fd awaits a reply
if(netmsg.fd >= 0) { // except netmsgs for stray activity recover
me = da.s("method");
d->sylinks.add(da, me, channel, netmsg.fd); // me determines the type of sync reply in CaSyLinks
d->sylinks.add(da, da.s("method"), channel, netmsg.fd); // me determines the type of sync reply in CaSyLinks
}
else {
reco++;
......@@ -285,8 +284,6 @@ void CaCuTangoReadImpl::m_process_single(const CuData& da, const std::string& ch
const std::string& method = da["method"].s();
const std::string& channel = da.containsKey("channel") ? da["channel"].s() : chan;
std::string sync_meth = sync_method(method, da);
cuprintf("CaCuTangoReadImpl.m_process_single src %s method %s chan %s class %s data %s\n",
src.c_str(), method.c_str(), channel.c_str(), sync_meth.c_str(), datos(da));
CuData o(da);
if(method == "read") read(src, o);
else if(method == "s") m_apply_subscribe_options(src, sync_meth, o);
......@@ -537,10 +534,7 @@ void CaCuTangoReadImpl::subscribe_run() {
}
if(d->chsub_interrupt)
cuprintf("[0x%lx] CaCuTangoReadImpl::subscribe_run: \e[1;35m\n#############################################################\n"
"must interrupt subscription cuz busy after subscribing %lu over queue of %ld items\n"
"#############################################################\e[0m\n", pthread_self(),
subscr, d->chsub_link_queue.size());
cuprintf("[0x%lx] CaCuTangoReadImpl::subscribe_run: \e[1;35minterrupted subs cuz busy after subs %lu in queue of %ld items\e[0m\n", pthread_self(), subscr, d->chsub_link_queue.size());
}
}
......@@ -560,7 +554,6 @@ void CaCuTangoReadImpl::onXmitted(const std::string& chan, int what) {
}
}
if(links.size() > 0) {
cuprintf("[0x%lx] \e[1;34;4mCaCuTangoReadImpl::onXmitted scheduling subscribe!!!!\n", pthread_self());
if(!d->chsub_tmr) d->chsub_tmr = d->tmr_srvc.registerListener(this, d->chsub_delay_ms);
else d->tmr_srvc.restart(d->chsub_tmr, d->chsub_delay_ms);
}
......@@ -571,9 +564,6 @@ void CaCuTangoReadImpl::onXmitted(const std::string& chan, int what) {
}
void CaCuTangoReadImpl::onTimeout(CuTimer *l) {
cuprintf("[0x%lx] \e[1;34;2m"
"CaCuTangoReadImpl::onTimeout notifying #######################################################################################\e[0m\n"
"\n", pthread_self());
std::unique_lock lk(d->chsub_wait_mutex);
d->chsub_condvar.notify_one();
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment