* MDF [timer] remove qos timer.
@@ -574,7 +574,7 @@ nano_pipe_start(void *arg)
}
// By definition, we have not received a request yet on this pipe,
// so it cannot cause us to become writable.
- nni_timer_schedule(&p->pipe_qos_timer, nni_clock() + NNI_SECOND * NNI_NANO_QOS_TIMER);
+ //nni_timer_schedule(&p->pipe_qos_timer, nni_clock() + NNI_SECOND * NNI_NANO_QOS_TIMER);
nni_pipe_recv(p->pipe, &p->aio_recv);
return (0);
}
@@ -647,11 +647,7 @@ nano_pipe_send_cb(void *arg)
nni_pipe_send(p->pipe, &p->aio_send);
nni_mtx_unlock(&p->lk);
return;
- } else {
- p->busy = false;
}
-
- if(p->qos_retry > 0) {
//TODO check what if there are too much msgs with a busy pipe, could qos retry break ctx cb chain?
//TODO check timestamp of each msg, whether send it or not
if (nni_lmq_getq(&p->qlmq, &msg) == 0) {
@@ -669,10 +665,6 @@ nano_pipe_send_cb(void *arg)
debug_msg("nano_pipe_send_cb: end of qos logic ctx : %p", ctx);
return;
}
- // Nothing else to send.
- nni_mtx_unlock(&p->lk);
- return;
-}
static void
nano_cancel_recv(nni_aio *aio, void *arg, int rv)
