开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 多媒体 > mpeg/mp3 > 查看源码
protocol_thread.h
资源名称：videoserver-0.6.2.tar.gz　[点击查看]
上传用户：psq1974
上传日期：2007-01-06
资源大小：1195k
文件大小：4k
源码类别：

mpeg/mp3

开发平台：

C/C++

protocol_thread.h：源码内容
  1. /* Copyright (C) 1998, 1999 State University of New York at Stony Brook
  2.    Author: Andrew V. Shuvalov ( andrew@ecsl.cs.sunysb.edu )
  3.    Software license is located in file "COPYING"
  4. */
  6. #ifndef protocol_thread_h
  7. #define protocol_thread_h
  9. #include "protocol_stream.h"
  10. #include "../../pusher/src/sockaddr.h"
  11. #include "../../pusher/src/timeval.h"
  12. #include "mutex.h"
  14. class protocol_cmd 
  15. {
  16. public:
  17.   typedef enum { } commandT;
  18. private:
  19.   commandT command;
  20. public:
  21.   protocol_cmd( commandT cmd );
  22. };
  24. struct text_data;
  26. class protocol_thread
  27. {
  28.   /** connection status is determined by checking this to be NULL */
  29.   protocol_stream *protocolStream;
  30.   Sockaddr dbServerAddr;
  32.   Timeval whenTryToRetryConnection;
  33.   /** received from handshake */
  34.   int acquisition_server_id;
  35.   bool shutdown_now;
  36.   /** commands from other threads are queued in this queue. */
  37.   std::queue< protocol_cmd * > commands;
  39.   /** abstract log destination */
  40.   ostream *log_output;
  41.   /** mutex to lock log out stream */
  42.   mutex lock_log;
  44.   /** queue of push servers where we successfully connected - to report to
  45.       the db server */
  46.   std::queue < int > connected_push_servers;
  47.   /** lock connected_push_servers
  48.    */
  49.   mutex lock_various_cmdstacks;
  51.   /** queue of text data to be sent to the database server */
  52.   std::queue< text_data * > new_text;
  53.   /** access to the queue is shared */
  54.   mutex lock_new_text;
  55.   
  56.   /** logging level */
  57.   int verbose_level;
  59.   static const int retryConnectionInterval;
  60.   static const int setupConnectionTimeout;
  62.   static const char register_acquisition_server[];
  63.   static const char cmd_request_broadcast_parameters[];
  64.   static const char cmd_push_server_ok[];
  65.   static const char cmd_add_caption_noid[];
  67. public:
  68.   /** only set-up initial values */
  69.   protocol_thread( int argc, char **argv );
  71.   /** static thread - entry function. When it ends - thread ends 
  72.       gets the address and port of database video server from command line,
  73.       -a address_ip_or_text -p portnum
  74.       try to connect. If connection fails - set up timeout and reconnect
  75.       again 
  76.    */
  77.   static void protocol_thread_entry_func( void *instance );
  78.   /** close sockets, etc. */
  79.   void cleanup();
  80.   /** this may be called several times after timeout */
  81.   void open_connection();
  82.   /** deallocate data associated with connection - but not to shutdown! 
  83.       only to reconnect later. Call cleanup if want to shutdown after call */
  84.   void cleanup_connection();
  86.   /** handshake with server */
  87.   void handshake();
  88.   void request_broadcast_parameters();
  89.   /** never exit, work until some exception */
  90.   void loop();
  91.   /** we have something on input... */
  92.   void process_unknown_input();
  94. private:
  95.   /** sleep for spec num of seconds */
  96.   void sleep( int seconds );
  97.   /** look in command queue for commands from others threads
  98.    */
  99.   void lookup_cmd_stack();
  100.   /** acquisition server do not knows whether this channel is recorded now 
  101.       or not. It just send the text - database server will drop it if 
  102.       it don't need it */
  103.   void check_new_text();
  105. public:
  106.   // ------- outside ------------
  108.   /** call from outside thread
  109.    */
  110.   void shutdown_requested();
  111.   /** report to db server that push server id is operating fine
  112.    */
  113.   void report_push_serv_ok( int push_id );
  114.   /** pass new text data to protocol thread. This call should never be 
  115.       blocked by any I/O - only place pointer into queue. The queue is
  116.       protected by mutex and mutex should never lock the queue while any
  117.       I/O on the way */
  118.   void new_text_data( text_data *data );
  120.   /** take log from old input stream messages */
  121.   void dump_log();
  122.   /** log this message */
  123.   void log( int level, const char *s, ... );
  124. };
  126. extern protocol_thread *protocolThread;
  128. #endif  //  protocol_thread_h