objects.storage.storageManager.storageManager Class Reference

The storageManager class is responsible for somehow storing a copy of all the captured TCP/IP data into the application's SQLite database. More...

Inherits objects::logic::common::observerInterface::observerInterface.

List of all members.

Public Member Functions
def	__init__
def	update
	implementation of observer method.
def	initializeStorage
	Initialized the internal storage file.
def	deleteStorage
	Deletes the internal storage file.
def	startupStorage
	Starts the storage threads.
def	shutdownStorage
	Stops the storage threads.
def	processPacket
	Processes a new packed.
Public Attributes
	storageImpl
	decoder
	saveStorage
	maxSize
	lck
	writer
	monitor
	packetList
	timeToCommit
	cnt

---

Detailed Description

The storageManager class is responsible for somehow storing a copy of all the captured TCP/IP data into the application's SQLite database.

This class also deals with other details, such as limiting the database file size to a user defined value, and perform periodic commits.

Definition at line 143 of file storageManager.py.

---

Member Function Documentation

def objects.storage.storageManager.storageManager.__init__	(		self,
			saveStorage,
			maxSize
	)

Definition at line 145 of file storageManager.py.

                                            :        
        self.storageImpl = sqlite3Impl(globalStrings.traceStoragePath)
        
        self.decoder = packetDecoder()
        self.decoder.setDefaultReader()
        
        self.saveStorage = saveStorage
        self.maxSize     = maxSize
        self.lck = RLock()
        
        
        self.writer = storageWriterThread(self)
        self.monitor = storageMonitorThread(self, self.writer)
        
        self.packetList = []
        
        self.timeToCommit = False
        
        self.cnt = 0

def objects.storage.storageManager.storageManager.deleteStorage

(

self

)

Deletes the internal storage file.

Definition at line 190 of file storageManager.py.

00190                            :
00191         self.storageImpl.deleteStorage()
00192     
00193     
00194     
    ## Starts the storage threads.

def objects.storage.storageManager.storageManager.initializeStorage

(

self

)

Initialized the internal storage file.

Definition at line 184 of file storageManager.py.

00184                                :
00185         self.storageImpl.createStorage()
00186         self.storageImpl.clear()
00187     
00188     
    ## Deletes the internal storage file.

def objects.storage.storageManager.storageManager.processPacket	(		self,
			header,
			data
	)

Processes a new packed.

Simply adds the (header, data) tuple to a list which is dequeued by the storageWriterThread class.

Parameters:

	header	Raw DataLink header
	data	Raw DataLink frame

Definition at line 213 of file storageManager.py.

00213                                          :
00214         
00215         if self.writer.getKillSignal() or self.monitor.getKillSignal():
00216             return
00217         
00218         try:
00219             self.packetList.append((header, data))
00220         finally:
00221             pass
00222     
00223     
00224     
    ## Helper function used to start worker threads.

def objects.storage.storageManager.storageManager.shutdownStorage

(

self

)

Stops the storage threads.

Definition at line 203 of file storageManager.py.

00203                              :
00204         if self.storageImpl.successful == True and self.saveStorage == True:
00205             self.__stopThreads()            
00206             
00207     
00208     
    ## Processes a new packed. Simply adds the (header, data) tuple to a

def objects.storage.storageManager.storageManager.startupStorage

(

self

)

Starts the storage threads.

Definition at line 196 of file storageManager.py.

00196                             :
00197         if self.storageImpl.successful == True and self.saveStorage == True:
00198             self.__startThreads()
00199     
00200     
00201     
    ## Stops the storage threads

def objects.storage.storageManager.storageManager.update	(		self,
			header,
			data
	)

implementation of observer method.

This class is an observer of the networkMonitor Class.

Parameters:

	header	Raw DataLink header
	data	Raw DataLink frame

Reimplemented from objects.logic.common.observerInterface.observerInterface.

Definition at line 170 of file storageManager.py.

                                  :        
        
        #self.cnt += 1
        #print "%d" % (self.cnt)
        
        try:
            self.processPacket(header, data)
        except exception, ex:
            logger.log(__name__ + ": Could add packet onto storage queue")
            logger.log(ex)
                   
                   
                   

---

Member Data Documentation

objects.storage.storageManager.storageManager.cnt

Definition at line 163 of file storageManager.py.

objects.storage.storageManager.storageManager.decoder

Definition at line 148 of file storageManager.py.

objects.storage.storageManager.storageManager.lck

Definition at line 153 of file storageManager.py.

objects.storage.storageManager.storageManager.maxSize

Definition at line 152 of file storageManager.py.

objects.storage.storageManager.storageManager.monitor

Definition at line 157 of file storageManager.py.

objects.storage.storageManager.storageManager.packetList

Definition at line 159 of file storageManager.py.

objects.storage.storageManager.storageManager.saveStorage

Definition at line 151 of file storageManager.py.

objects.storage.storageManager.storageManager.storageImpl

Definition at line 146 of file storageManager.py.

objects.storage.storageManager.storageManager.timeToCommit

Definition at line 161 of file storageManager.py.

objects.storage.storageManager.storageManager.writer

Definition at line 156 of file storageManager.py.

---

The documentation for this class was generated from the following file:

• C:/work/RevealedSystems/EyeSpy-RS/eyespy/src/objects/storage/storageManager.py