freetdm: ftmod_wanpipe - implement tx and rx flush command

diff --git a/libs/freetdm/src/ftmod/ftmod_wanpipe/ftmod_wanpipe.c b/libs/freetdm/src/ftmod/ftmod_wanpipe/ftmod_wanpipe.c
index c8b8868acd3fdbbdef53daff9f525a64f9f17f3f..0bafa40bdd71fc823b180ce6403b14bfbedea37a 100644 (file)
--- a/libs/freetdm/src/ftmod/ftmod_wanpipe/ftmod_wanpipe.c
+++ b/libs/freetdm/src/ftmod/ftmod_wanpipe/ftmod_wanpipe.c
@@ -756,6 +756,16 @@ static FIO_COMMAND_FUNCTION(wanpipe_command)
                        err = sangoma_flush_bufs(ftdmchan->sockfd, &tdm_api);
                }
                break;
+       case FTDM_COMMAND_FLUSH_RX_BUFFERS:
+               {
+                       err = sangoma_flush_rx_bufs(ftdmchan->sockfd, &tdm_api);
+               }
+       case FTDM_COMMAND_FLUSH_TX_BUFFERS:
+               break;
+               {
+                       err = sangoma_flush_tx_bufs(ftdmchan->sockfd, &tdm_api);
+               }
+               break;
        case FTDM_COMMAND_FLUSH_IOSTATS:
                {
                        err = sangoma_flush_stats(ftdmchan->sockfd, &tdm_api);
@@ -775,12 +785,13 @@ static FIO_COMMAND_FUNCTION(wanpipe_command)
                }
                break;
        default:
+               err = FTDM_NOTIMPL;
                break;
        };
 
        if (err) {
                snprintf(ftdmchan->last_error, sizeof(ftdmchan->last_error), "%s", strerror(errno));
-               return FTDM_FAIL;
+               return err;
        }