RtspFile.cxx
上传用户:sy_wanhua
上传日期:2013-07-25
资源大小:3048k
文件大小:7k
源码类别:

流媒体/Mpeg4/MP4

开发平台:

C/C++

  1. /* ====================================================================
  2.  * The Vovida Software License, Version 1.0 
  3.  * 
  4.  * Copyright (c) 2000 Vovida Networks, Inc.  All rights reserved.
  5.  * 
  6.  * Redistribution and use in source and binary forms, with or without
  7.  * modification, are permitted provided that the following conditions
  8.  * are met:
  9.  * 
  10.  * 1. Redistributions of source code must retain the above copyright
  11.  *    notice, this list of conditions and the following disclaimer.
  12.  * 
  13.  * 2. Redistributions in binary form must reproduce the above copyright
  14.  *    notice, this list of conditions and the following disclaimer in
  15.  *    the documentation and/or other materials provided with the
  16.  *    distribution.
  17.  * 
  18.  * 3. The names "VOCAL", "Vovida Open Communication Application Library",
  19.  *    and "Vovida Open Communication Application Library (VOCAL)" must
  20.  *    not be used to endorse or promote products derived from this
  21.  *    software without prior written permission. For written
  22.  *    permission, please contact vocal@vovida.org.
  23.  *
  24.  * 4. Products derived from this software may not be called "VOCAL", nor
  25.  *    may "VOCAL" appear in their name, without prior written
  26.  *    permission of Vovida Networks, Inc.
  27.  * 
  28.  * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
  29.  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
  30.  * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, TITLE AND
  31.  * NON-INFRINGEMENT ARE DISCLAIMED.  IN NO EVENT SHALL VOVIDA
  32.  * NETWORKS, INC. OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT DAMAGES
  33.  * IN EXCESS OF 281421,000, NOR FOR ANY INDIRECT, INCIDENTAL, SPECIAL,
  34.  * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
  35.  * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
  36.  * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY
  37.  * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  38.  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
  39.  * USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
  40.  * DAMAGE.
  41.  * 
  42.  * ====================================================================
  43.  * 
  44.  * This software consists of voluntary contributions made by Vovida
  45.  * Networks, Inc. and many individuals on behalf of Vovida Networks,
  46.  * Inc.  For more information on Vovida Networks, Inc., please see
  47.  * <http://www.vovida.org/>.
  48.  *
  49.  */
  50. static const char* const RtspFile_cxx_version =
  51.     "$Id: RtspFile.cxx,v 1.15 2001/06/05 01:19:44 kle Exp $";
  52. #include "RtspFile.hxx"
  53. #include <sys/stat.h>
  54. #include <unistd.h>
  55. bool
  56. RtspFile::writeSdpFile( RtspSdp& rtspSdp )
  57. {
  58.     string sdpFilename = RtspConfiguration::instance().audioDirectory;
  59.     if( !sdpFilename.empty() )
  60.     {
  61.         sdpFilename += "/";
  62.     }
  63.     sdpFilename += myShortFilename;
  64.     sdpFilename += ".sdp";
  65.     cpLog( LOG_DEBUG, "Writing sdp to descriptor file: %s", sdpFilename.c_str() );
  66.     /*
  67.     FILE* fSdpDescFile = fopen( sdpFilename.c_str(), "rb" );
  68.     if( fSdpDescFile )
  69.     {
  70.         cpLog( LOG_ERR, "Sdp file already exists" );
  71.         cpLog( LOG_ERR, "Hacked to overwrite existing sdp file" );
  72.         //return false;
  73.     }
  74.     fclose( fSdpDescFile );
  75.     fSdpDescFile = fopen( sdpFilename.c_str(), "wb" );
  76.     */
  77.     FILE* fSdpDescFile = fopen( sdpFilename.c_str(), "wb+" );
  78.     if( !fSdpDescFile )
  79.     {
  80.         cpLog( LOG_ERR, "Fail to open sdp file" );
  81.         return false;
  82.     }
  83.     Data newSdpData = rtspSdp.encode();
  84.     int writeRes = fwrite( newSdpData.getData(), newSdpData.length(),
  85.                            1, fSdpDescFile );
  86.     fclose( fSdpDescFile );
  87.     if( writeRes <= 0 )
  88.     {
  89.         cpLog( LOG_DEBUG, "Fail to write sdp data to file" );
  90.         return false;
  91.     }
  92.     return true;
  93. }
  94. bool
  95. RtspFile::readSdpFile( RtspSdp& rtspSdp )
  96. {
  97.     string sdpFilename = RtspConfiguration::instance().audioDirectory;
  98.     if( !sdpFilename.empty() )
  99.     {
  100.         sdpFilename += "/";
  101.     }
  102.     sdpFilename += myShortFilename;
  103.     sdpFilename += ".sdp";
  104.     FILE* fSdpDescFile = fopen( sdpFilename.c_str(), "rb" );
  105.     if( !fSdpDescFile )
  106.     {
  107.         // failure is ok, RtspFileHandler will try reading
  108.         // audio header for sdp information
  109.         return false;
  110.     }
  111.     cpLog( LOG_DEBUG, "Generating sdp from descriptor file: %s",
  112.            sdpFilename.c_str() );
  113.     // read information from sdp file
  114.     struct stat ifstat;
  115.     if( stat( sdpFilename.c_str(), &ifstat ) )
  116.     {
  117.         cpLog( LOG_ERR, "Error in stat()" );
  118.         return false;
  119.     }
  120.     int iSdpFileSize = ifstat.st_size;
  121.     char* tmpBuff = new char[iSdpFileSize+1];
  122.     fread( (void*)tmpBuff, iSdpFileSize, 1, fSdpDescFile );
  123.     fclose( fSdpDescFile );
  124.     tmpBuff[iSdpFileSize] = '';
  125.     cpLog(LOG_DEBUG, "Sdp file length is: %d", iSdpFileSize);
  126.     cpLog(LOG_DEBUG, "Sdp file has data: %s", tmpBuff);
  127.     Data dataTmp(tmpBuff, iSdpFileSize);
  128.     delete [] tmpBuff;
  129.     // build sdp object
  130.     rtspSdp.decode( dataTmp );
  131.     if( !rtspSdp.isValid() )
  132.     {
  133.         cpLog( LOG_ERR, "Sdp data from file is invalid" );
  134.         return false;
  135.     }
  136.     return true;
  137. }
  138. bool
  139. RtspFile::appendSdpFile( const char* data, const int len )
  140. {
  141. #ifndef SDP_FILE
  142.     return true;
  143. #endif
  144.     string sdpFilename = RtspConfiguration::instance().audioDirectory;
  145.     if( !sdpFilename.empty() )
  146.     {
  147.         sdpFilename += "/";
  148.     }
  149.     sdpFilename += myShortFilename;
  150.     sdpFilename += ".sdp";
  151.     cpLog( LOG_DEBUG, "Appending data to descriptor file: %s", sdpFilename.c_str() );
  152.     FILE* fSdpDescFile = fopen( sdpFilename.c_str(), "ab" );
  153.     if( !fSdpDescFile )
  154.     {
  155.         cpLog( LOG_DEBUG, "Error opening descriptor file with append mode" );
  156.         return false;
  157.     }
  158.     fwrite( data, len, 1, fSdpDescFile );
  159.     fclose( fSdpDescFile );
  160.     return true;
  161. }
  162. bool
  163. RtspFile::deleteLineSdpFile( const char* data )
  164. {
  165. #ifndef SDP_FILE
  166.     return true;
  167. #endif
  168.     //TODO read entire sdp file.  If any line begin
  169.     //     with data, then delete that line.
  170.     //     return true if a line was deleted
  171.     return false;
  172. }
  173. void
  174. RtspFile::updateSdpFileRange()
  175. {
  176. #ifndef SDP_FILE
  177.     return;
  178. #endif
  179.     if( myFileMode == RTSP_FILE_MODE_REC )
  180.     {
  181.         // reload updated header
  182.         int ftIndex;
  183.         int lengthInMs;
  184.         loadHeader( &ftIndex, &lengthInMs );
  185.         // write to sdp file
  186.         char rangeBuffer[20];
  187.         sprintf( rangeBuffer, "a=range:npt=0.0-%.3frn",
  188.                  lengthInMs / 1000.0 );
  189.         deleteLineSdpFile( "a=range:" );
  190.         appendSdpFile( rangeBuffer, strlen( rangeBuffer) );
  191.     }
  192. }
  193. /* Local Variables: */
  194. /* c-file-style: "stroustrup" */
  195. /* indent-tabs-mode: nil */
  196. /* c-file-offsets: ((access-label . -) (inclass . ++)) */
  197. /* c-basic-offset: 4 */
  198. /* End: */