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 class FuseServer;
00033 class FuseNetworkMessageQueue;
00034 class FuseNetworkMessage;
00035 class SharedMemoryImageBuffer;
00036 class SharedMemoryLookupTable;
00037 class JpegImageCompressor;
00038
00039 namespace fawkes {
00040   class StreamSocket;
00041 }
00042
00043 class FuseServerClientThread : public fawkes::Thread
00044 {
00045  public:
00046   FuseServerClientThread(FuseServer *fuse_server,
00047                          fawkes::StreamSocket *s);
00048   virtual ~FuseServerClientThread();
00049
00050   void recv();
00051   void send();
00052   virtual void loop();
00053
00054   void process_greeting_message(FuseNetworkMessage *m);
00055   void process_getimage_message(FuseNetworkMessage *m);
00056   void process_getimageinfo_message(FuseNetworkMessage *m);
00057   void process_getimagelist_message(FuseNetworkMessage *m);
00058   void process_getlut_message(FuseNetworkMessage *m);
00059   void process_setlut_message(FuseNetworkMessage *m);
00060   void process_getlutlist_message(FuseNetworkMessage *m);
00061
00062  private:
00063   void process_inbound();
00064   SharedMemoryImageBuffer *  get_shmimgbuf(const char *id);
00065
00066   FuseServer   *__fuse_server;
00067   fawkes::StreamSocket *__socket;
00068
00069   FuseNetworkMessageQueue *__outbound_queue;
00070   FuseNetworkMessageQueue *__inbound_queue;
00071
00072   JpegImageCompressor *__jpeg_compressor;
00073
00074   std::map< std::string, SharedMemoryImageBuffer * >  __buffers;
00075   std::map< std::string, SharedMemoryImageBuffer * >::iterator  __bit;
00076
00077   std::map< std::string, SharedMemoryLookupTable * >  __luts;
00078   std::map< std::string, SharedMemoryLookupTable * >::iterator  __lit;
00079
00080   bool __alive;
00081 };
00082
00083
00084 #endif