fuse_server_client_thread.h

00001 
00002 /***************************************************************************
00003  *  fuse_server_client_thread.h - client thread for FuseServer
00004  *
00005  *  Created: Tue Nov 13 19:59:11 2007
00006  *  Copyright  2005-2007  Tim Niemueller [www.niemueller.de]
00007  *
00008  ****************************************************************************/
00009 
00010 /*  This program is free software; you can redistribute it and/or modify
00011  *  it under the terms of the GNU General Public License as published by
00012  *  the Free Software Foundation; either version 2 of the License, or
00013  *  (at your option) any later version. A runtime exception applies to
00014  *  this software (see LICENSE.GPL_WRE file mentioned below for details).
00015  *
00016  *  This program is distributed in the hope that it will be useful,
00017  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
00018  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00019  *  GNU Library General Public License for more details.
00020  *
00021  *  Read the full text in the LICENSE.GPL_WRE file in the doc directory.
00022  */
00023 
00024 #ifndef __FIREVISION_FVUTILS_NET_FUSE_SERVER_CLIENT_THREAD_H_
00025 #define __FIREVISION_FVUTILS_NET_FUSE_SERVER_CLIENT_THREAD_H_
00026 
00027 #include <core/threading/thread.h>
00028 
00029 #include <map>
00030 #include <string>
00031 
00032 namespace fawkes {
00033   class StreamSocket;
00034 }
00035 namespace firevision {
00036 #if 0 /* just to make Emacs auto-indent happy */
00037 }
00038 #endif
00039 
00040 class FuseServer;
00041 class FuseNetworkMessageQueue;
00042 class FuseNetworkMessage;
00043 class SharedMemoryImageBuffer;
00044 class SharedMemoryLookupTable;
00045 class JpegImageCompressor;
00046 
00047 class FuseServerClientThread : public fawkes::Thread
00048 {
00049  public:
00050   FuseServerClientThread(FuseServer *fuse_server,
00051                          fawkes::StreamSocket *s);
00052   virtual ~FuseServerClientThread();
00053 
00054   void recv();
00055   void send();
00056   virtual void loop();
00057   
00058   void process_greeting_message(FuseNetworkMessage *m);
00059   void process_getimage_message(FuseNetworkMessage *m);
00060   void process_getimageinfo_message(FuseNetworkMessage *m);
00061   void process_getimagelist_message(FuseNetworkMessage *m);
00062   void process_getlut_message(FuseNetworkMessage *m);
00063   void process_setlut_message(FuseNetworkMessage *m);
00064   void process_getlutlist_message(FuseNetworkMessage *m);
00065 
00066  private:
00067   void process_inbound();
00068   SharedMemoryImageBuffer *  get_shmimgbuf(const char *id);
00069 
00070   FuseServer   *__fuse_server;
00071   fawkes::StreamSocket *__socket;
00072 
00073   FuseNetworkMessageQueue *__outbound_queue;
00074   FuseNetworkMessageQueue *__inbound_queue;
00075 
00076   JpegImageCompressor *__jpeg_compressor;
00077 
00078   std::map< std::string, SharedMemoryImageBuffer * >  __buffers;
00079   std::map< std::string, SharedMemoryImageBuffer * >::iterator  __bit;
00080 
00081   std::map< std::string, SharedMemoryLookupTable * >  __luts;
00082   std::map< std::string, SharedMemoryLookupTable * >::iterator  __lit;
00083 
00084   bool __alive;
00085 };
00086 
00087 } // end namespace firevision
00088 
00089 #endif