BasicUDPSink.hh 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. /**********
  2. This library is free software; you can redistribute it and/or modify it under
  3. the terms of the GNU Lesser General Public License as published by the
  4. Free Software Foundation; either version 3 of the License, or (at your
  5. option) any later version. (See <http://www.gnu.org/copyleft/lesser.html>.)
  6. This library is distributed in the hope that it will be useful, but WITHOUT
  7. ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
  8. FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for
  9. more details.
  10. You should have received a copy of the GNU Lesser General Public License
  11. along with this library; if not, write to the Free Software Foundation, Inc.,
  12. 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  13. **********/
  14. // "liveMedia"
  15. // Copyright (c) 1996-2019 Live Networks, Inc. All rights reserved.
  16. // A simple UDP sink (i.e., without RTP or other headers added); one frame per packet
  17. // C++ header
  18. #ifndef _BASIC_UDP_SINK_HH
  19. #define _BASIC_UDP_SINK_HH
  20. #ifndef _MEDIA_SINK_HH
  21. #include "MediaSink.hh"
  22. #endif
  23. #ifndef _GROUPSOCK_HH
  24. #include <Groupsock.hh>
  25. #endif
  26. class BasicUDPSink: public MediaSink {
  27. public:
  28. static BasicUDPSink* createNew(UsageEnvironment& env, Groupsock* gs,
  29. unsigned maxPayloadSize = 1450);
  30. protected:
  31. BasicUDPSink(UsageEnvironment& env, Groupsock* gs, unsigned maxPayloadSize);
  32. // called only by createNew()
  33. virtual ~BasicUDPSink();
  34. private: // redefined virtual functions:
  35. virtual Boolean continuePlaying();
  36. private:
  37. void continuePlaying1();
  38. static void afterGettingFrame(void* clientData, unsigned frameSize,
  39. unsigned numTruncatedBytes,
  40. struct timeval presentationTime,
  41. unsigned durationInMicroseconds);
  42. void afterGettingFrame1(unsigned frameSize, unsigned numTruncatedBytes,
  43. unsigned durationInMicroseconds);
  44. static void sendNext(void* firstArg);
  45. private:
  46. Groupsock* fGS;
  47. unsigned fMaxPayloadSize;
  48. unsigned char* fOutputBuffer;
  49. struct timeval fNextSendTime;
  50. };
  51. #endif