root/experimental/components/image_display/trunk/image_display/WorkModule.py @ 4030

#!/usr/bin/env python

'''
/****************************************************************************

Copyright 2007 Virginia Polytechnic Institute and State University

This file is part of the OSSIE image_display.

OSSIE image_display is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.

OSSIE image_display is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with OSSIE image_display; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

****************************************************************************/

'''

import wx
import threading


class WorkClass:
    """This class provides a place for the main processing of the 
    component to reside."""

    def __init__(self, image_display_ref, buffer_size):

        # debug statement:
        print "work class __init__ called in image_display"

        self.image_display_ref = image_display_ref
        self.buffer_size = buffer_size
        
        self.data_queue = []
        self.data_queue_lock = threading.Lock()
        self.data_signal = threading.Event()

        self.is_running = True

        self.process_thread = threading.Thread(target=self.Process)
        self.process_thread.start()
  
                
    def __del__(self):
        # Destructor
        pass
        
    def AddData(self, bytesIn):
        self.data_queue_lock.acquire()
        self.data_queue.insert(0, bytesIn)
        self.data_queue_lock.release()
        self.data_signal.set()

    def Release(self):
        self.is_running = False
        self.data_signal.set()
                
    def Process(self):
        print "Process in work module of image display has been called"
        while self.is_running:
            self.data_signal.wait()  #wait for data_signal to be .set() in AddData

            print len(self.data_queue)

            while len(self.data_queue) > 0:
                self.data_queue_lock.acquire()
                new_data = self.data_queue.pop()
                self.data_queue_lock.release()
                                
                # get data out of tuple
                bytesIn = new_data
                                
                # debuggin loop - outputs the data that I'm getting
                for x in range(len(bytesIn)):
                    print bytesIn[x]     # print the first byte         
                                        
                # put display code here
                # convert bytesIn into a python image

                # refresh the image 
                print "this is where I should be refreshing the image"

                image = wx.Image("/sdr/buddha.jpg", wx.BITMAP_TYPE_JPEG)  # load a jpeg from file.  maybe start out with None
                self.image_display_ref.prnt_orb.prnt_frame.refresh(image)  
 
                # # not sure if I need this code:
                # # reset the signal event variable
                # self.data_signal.clear()