X-Git-Url: http://git.eversberg.eu/gitweb.cgi?p=lcr.git;a=blobdiff_plain;f=mISDN.cpp;h=a7facb68947e0c5a307f01fc2557181a9e4d573d;hp=179646b8002151d9e9611839c41536a753d40f7e;hb=034d3a91404addedc1c7a3494862c79532b0b878;hpb=42b2772d78f3c1ecd4a4e9e5f2e49db9b420554f diff --git a/mISDN.cpp b/mISDN.cpp index 179646b..a7facb6 100644 --- a/mISDN.cpp +++ b/mISDN.cpp @@ -965,7 +965,7 @@ void PmISDN::load_tx(void) p_m_load = 0; /* to send data, tone must be on */ - if ((p_tone_name[0] || p_m_crypt_msg_loops || p_m_inband_send_on) /* what tones? */ + if ((p_tone_name[0] || p_dov_tx || p_m_crypt_msg_loops || p_m_inband_send_on) /* what tones? */ && (p_m_load < p_m_preload) /* not too much load? */ && (p_state==PORT_STATE_CONNECT || p_m_mISDNport->tones || p_m_inband_send_on)) { /* connected or inband-tones? */ int tosend = p_m_preload - p_m_load, length; @@ -1005,6 +1005,11 @@ void PmISDN::load_tx(void) tosend -= length; } + /* copy dov */ + if (p_dov_tx) { + tosend -= dov_tx(p, tosend); + } + /* copy tones */ if (p_tone_name[0] && tosend) { tosend -= read_audio(p, tosend); @@ -1142,6 +1147,10 @@ void PmISDN::bchannel_receive(struct mISDNhead *hh, unsigned char *data, int len return; } + /* dov is processed */ + if (p_dov_rx) + dov_rx(data, len); + /* inband is processed */ if (p_m_inband_receive_on) inband_receive(data, len); @@ -1435,17 +1444,44 @@ void PmISDN::message_crypt(unsigned int epoint_id, int message_id, union paramet } +/* MESSAGE_VOOTP */ +void PmISDN::message_vootp(unsigned int epoint_id, int message_id, union parameter *param) +{ + struct lcr_msg *message; + + message = message_create(p_serial, ACTIVE_EPOINT(p_epointlist), PORT_TO_EPOINT, MESSAGE_UPDATEBRIDGE); + message_put(message); + +#if 0 +does not make sense, since remote port may dejitter + if (param->vootp.enable) { + PDEBUG(DEBUG_ISDN, "PmISDN(%s) received vootp enable order, so we disable de-jitter.\n", p_name); + p_m_disable_dejitter = 1; + } +#endif + update_rxoff(); +} + /* * endpoint sends messages to the port */ int PmISDN::message_epoint(unsigned int epoint_id, int message_id, union parameter *param) { + /* messages also handled by base class */ + switch(message_id) { + case MESSAGE_VOOTP: /* crypt control command */ + PDEBUG(DEBUG_ISDN, "PmISDN(%s) received VoOTP encryption\n", p_name); + message_vootp(epoint_id, message_id, param); + break; + } + if (Port::message_epoint(epoint_id, message_id, param)) { if (message_id == MESSAGE_BRIDGE) update_rxoff(); return 1; } + /* messages not handled by base class */ switch(message_id) { case MESSAGE_mISDNSIGNAL: /* user command */ PDEBUG(DEBUG_ISDN, "PmISDN(%s) received special ISDN SIGNAL %d.\n", p_name, param->mISDNsignal.message); @@ -1473,7 +1509,7 @@ void PmISDN::update_rxoff(void) int tx_dejitter = 0; /* call bridges in user space OR crypto OR recording */ - if (p_bridge || p_m_crypt_msg_loops || p_m_crypt_listen || p_record || p_tap || p_m_inband_receive_on) { + if (p_bridge || p_m_crypt_msg_loops || p_m_crypt_listen || p_record || p_tap || p_m_inband_receive_on || p_dov_rx) { /* rx IS required */ if (p_m_rxoff) { /* turn on RX */ @@ -2275,6 +2311,9 @@ int PmISDN::bridge_rx(unsigned char *data, int length) struct mISDNhead *hh = (struct mISDNhead *)buf; int ret; + if ((ret = Port::bridge_rx(data, length))) + return ret; + if (p_m_b_index < 0) return -EIO; if (p_m_mISDNport->b_state[p_m_b_index] != B_STATE_ACTIVE) @@ -2283,7 +2322,7 @@ int PmISDN::bridge_rx(unsigned char *data, int length) /* check if high priority tones exist * ignore data in this case */ - if (p_tone_name[0] || p_m_crypt_msg_loops || p_m_inband_send_on) + if (p_tone_name[0] || p_dov_tx || p_m_crypt_msg_loops || p_m_inband_send_on) return -EBUSY; /* preload procedure