Print this page
XXXX introduce drv_sectohz

*** 770,780 **** sp->session_state); while (!((sp->session_state == RDS_SESSION_STATE_CLOSED) || (sp->session_state == RDS_SESSION_STATE_FAILED) || (sp->session_state == RDS_SESSION_STATE_FINI))) { rw_exit(&sp->session_lock); ! delay(drv_usectohz(1000000)); rw_enter(&sp->session_lock, RW_READER); RDS_DPRINTF2("rds_destroy_session", "SP(%p) State: %d WAITING " "ON SESSION", sp, sp->session_state); } rw_exit(&sp->session_lock); --- 770,780 ---- sp->session_state); while (!((sp->session_state == RDS_SESSION_STATE_CLOSED) || (sp->session_state == RDS_SESSION_STATE_FAILED) || (sp->session_state == RDS_SESSION_STATE_FINI))) { rw_exit(&sp->session_lock); ! delay(drv_sectohz(1)); rw_enter(&sp->session_lock, RW_READER); RDS_DPRINTF2("rds_destroy_session", "SP(%p) State: %d WAITING " "ON SESSION", sp, sp->session_state); } rw_exit(&sp->session_lock);
*** 861,871 **** if (sp_state == RDS_SESSION_STATE_ERROR) { rds_session_close(sp, IBT_BLOCKING, 1); } /* wait 1 sec before re-connecting */ ! delay(drv_usectohz(1000000)); do { ibt_ip_path_attr_t ipattr; ibt_ip_addr_t dstip; --- 861,871 ---- if (sp_state == RDS_SESSION_STATE_ERROR) { rds_session_close(sp, IBT_BLOCKING, 1); } /* wait 1 sec before re-connecting */ ! delay(drv_sectohz(1)); do { ibt_ip_path_attr_t ipattr; ibt_ip_addr_t dstip;
*** 905,915 **** } RDS_DPRINTF2(LABEL, "ibt_get_ip_paths failed, ret: %d ", ret); /* wait 1 sec before re-trying */ ! delay(drv_usectohz(1000000)); cnt++; } while (cnt < 5); if (ret != IBT_SUCCESS) { rw_enter(&sp->session_lock, RW_WRITER); --- 905,915 ---- } RDS_DPRINTF2(LABEL, "ibt_get_ip_paths failed, ret: %d ", ret); /* wait 1 sec before re-trying */ ! delay(drv_sectohz(1)); cnt++; } while (cnt < 5); if (ret != IBT_SUCCESS) { rw_enter(&sp->session_lock, RW_WRITER);
*** 1113,1123 **** /* wait until all the buffers are freed by the sockets */ while (RDS_GET_RXPKTS_PEND() != 0) { /* wait one second and try again */ RDS_DPRINTF2("rds_close_sessions", "waiting on " "pending packets", RDS_GET_RXPKTS_PEND()); ! delay(drv_usectohz(1000000)); } RDS_DPRINTF2("rds_close_sessions", "No more RX packets pending"); /* close all the sessions */ rw_enter(&rdsib_statep->rds_sessionlock, RW_WRITER); --- 1113,1123 ---- /* wait until all the buffers are freed by the sockets */ while (RDS_GET_RXPKTS_PEND() != 0) { /* wait one second and try again */ RDS_DPRINTF2("rds_close_sessions", "waiting on " "pending packets", RDS_GET_RXPKTS_PEND()); ! delay(drv_sectohz(1)); } RDS_DPRINTF2("rds_close_sessions", "No more RX packets pending"); /* close all the sessions */ rw_enter(&rdsib_statep->rds_sessionlock, RW_WRITER);