1 files changed, 207 insertions, 0 deletions
diff --git a/plugins/MirFox/src/MirFoxCommons/MirFoxCommons_sharedMemory.h b/plugins/MirFox/src/MirFoxCommons/MirFoxCommons_sharedMemory.h
new file mode 100644
index 0000000000..8ccc1494cf
--- /dev/null
+++ b/plugins/MirFox/src/MirFoxCommons/MirFoxCommons_sharedMemory.h
@@ -0,0 +1,207 @@
+#ifndef _WSX22_IPC_SHAREDMEMORY
+#define _WSX22_IPC_SHAREDMEMORY
+
+
+#include "MirFoxCommons_logger.h"
+
+
+//shared memory related definitions
+#define CSMTHREAD_TICK_TIME		100		// 100ms - check exit every this time
+#define CSMTHREAD_FIRSTRUN_TIME	100		// CSMTHREAD_FIRSTRUN_TIME * CSMTHREAD_TICK_TIME = 10s  - time to first run of checking csm state in csm thread (after thread start)
+#define CSMTHREAD_NEXTRUN_TIME	100		// CSMTHREAD_NEXTRUN_TIME * CSMTHREAD_TICK_TIME = 10s  - time to next run of checking csm state in csm thread
+
+#define SMUCONST_CSM_RECORD_VISABLETO_SIZEC_DEF 128
+#define SMUCONST_CSM_RECORD_DNAME_SIZEC_DEF 78
+#define SMUCONST_MSM_RECORD_DNAME_SIZEC_DEF 78
+
+
+
+class ClientInstanceClass
+{
+public:
+	std::wstring displayName;	//display name
+	uint16_t recordId;			//id
+};
+
+class ContactClass
+{
+public:
+	std::wstring displayName;	//display name
+	uint64_t handle;			//miranda HANDLE to contact (casted pointer)
+};
+
+class AccountClass
+{
+public:
+	std::wstring displayName;	//display name
+	uint64_t handle;			//miranda HANDLE to account (casted pointer)
+};
+
+
+
+struct OpenOrCreateSMReturnStruct {
+	int errorCode;
+	uint16_t processCsmId;
+};
+
+
+
+/**
+ * SharedMemory Utils
+ *
+ * Singleton pattern based on
+ * http://www.codeproject.com/KB/threads/SingletonThreadSafety.aspx
+ */
+class SharedMemoryUtils
+{
+
+public:
+
+	
+	//constructor
+	SharedMemoryUtils();
+	//destructor
+	~SharedMemoryUtils();
+
+
+	/**
+	 * open existing or create new central shared memory
+	 *
+	 * type - char - 'M' - Miranda, 'F' - Firefox
+	 *
+	 * return OpenOrCreateSMReturnStruct
+	 * .errorCode
+	 *  0 - ok, and .processCsmId = id of process record in csm
+	 * -2 - no more available (Empty) records in central shared memory
+	 * -3 - existing csm version is too high (from checkCsmVersion)
+	 * -4 - existing csm version is too low (from checkCsmVersion)
+	 */
+	OpenOrCreateSMReturnStruct openOrCreateSM(char type, std::wstring& displayName, std::wstring& visableTo, bool doCommitSM);
+
+
+	int addOptionToSM(int optionID, std::wstring& optionValue);
+
+	int addTranslationToSM(int translationId, std::wstring& translationValue );
+
+	int addAccountToSM(uint64_t mirandaAccountId, std::wstring& displayName);
+
+	// group type:  R - root, N - normal
+	int addGroupToSM(uint64_t mirandaGroupHandle, uint64_t parentGroupHandle, char groupType, std::wstring& displayName);
+
+	int addContactToSM(uint64_t mirandaContactHandle, uint64_t mirandaAccountHandle, uint64_t mirandaGroupHandle, std::wstring& displayName);
+
+	//call after openOrCreateSM and after creating sm thread
+	int commitSM();
+
+	//delete returned sm object after use
+	boost::interprocess::windows_shared_memory* getSmById(const char* smName, std::size_t smSize);
+
+	//returns:
+	// 0 - ok
+	// 1 - record error (state != 'W' (working) or wrong displayName)
+	// -3 - existing csm version is too high (from checkCsmVersion)
+	// -4 - existing csm version is too low (from checkCsmVersion)
+	int checkCSM(boost::interprocess::windows_shared_memory* checkedCsm, uint16_t processCsmId, std::wstring& displayNameProfile);
+
+	void updateCsmTimestamp(boost::interprocess::windows_shared_memory& updateCsm, uint16_t processCsmId);
+
+	//for every other CSM records with 'W' status, check if record is outdated, if yes then delete this record
+	void checkAnotherCsm(boost::interprocess::windows_shared_memory& checkedCsm, uint16_t processCsmId);
+
+	//unload and free shared memory records and structures
+	void unloadSharedMemory(uint16_t processCsmId);
+
+	//execute before start creating MSMs
+	void resetMsmParameters();
+
+
+	////FUNCTIONS FOR FIREFOX
+
+	//return true if any client (miranda instance) is available in csm for current firefox profile
+	bool isAnyMirandaCsmRecordAvailable(std::wstring& forThisProfileName);
+
+	//return number of records in clientInstanceNamesList, empty list as parameter
+	int getClientInstances(boost::ptr_list<ClientInstanceClass> * clientInstancesListPtr, std::wstring& forThisProfileName);
+
+	//return number of records in contactsListPtr, empty list as parameter
+	int getContacts(boost::ptr_list<ContactClass> * contactsListPtr, unsigned short clientRecordNo);
+
+	//return number of records in accountsListPtr, empty list as parameter
+	int getAccounts(boost::ptr_list<AccountClass> * accountsListPtr, unsigned short clientRecordNo);
+
+	////FUNCTIONS FOR FIREFOX - end
+
+
+
+
+	const char* getCsmName();
+	std::string getMsmName(uint16_t id, int currentNumber);
+	std::size_t getCsmTotalSize();
+	std::size_t getMsmTotalSize();
+
+
+
+	//static method that returns only instance of SharedMemoryUtils
+	static SharedMemoryUtils * getInstance()
+	{
+		//initialized always from one thread at a time
+		if (m_pOnlyOneInstance == NULL) {
+			if (m_pOnlyOneInstance == NULL) {
+				m_pOnlyOneInstance = new SharedMemoryUtils();
+			}
+		}
+		return m_pOnlyOneInstance;
+	}
+
+
+private:
+
+	//holds one and only object of MySingleton
+	static SharedMemoryUtils* m_pOnlyOneInstance;
+	
+	MFLogger* logger;
+
+
+	//global variables
+	boost::interprocess::windows_shared_memory* csm;
+	boost::ptr_list<boost::interprocess::windows_shared_memory> msmList;
+	
+
+
+	bool isCsmInited(boost::interprocess::windows_shared_memory& csm);
+	void initCsm(boost::interprocess::windows_shared_memory& csm);
+
+	//return:
+	//	0 - versions match,
+	// -3 - existing csm version is too high
+	// -4 - existing csm version is too low
+	int checkCsmVersion(boost::interprocess::windows_shared_memory& csm);
+
+	uint16_t allocateRecordInCsm(boost::interprocess::windows_shared_memory& csm, char type, std::wstring& displayName, std::wstring& visableTo, bool doCommitSM);
+
+	time_t mfGetCurrentTimestamp();
+
+	int addRecordToMsm(char type, uint64_t agcHandle, uint64_t accountHandle, uint64_t groupHandle, char status, std::wstring& value);
+
+	int checkCsmRecord(boost::interprocess::windows_shared_memory& checkedCsm, uint16_t processCsmId, std::wstring& displayNameProfile);
+	
+	void freeCsmRecord(boost::interprocess::windows_shared_memory& csm, uint16_t recordNo);
+
+	bool isTokenOnList(std::wstring& token, std::wstring& tokensList);
+
+	//free own record in csm
+	void unloadFromCSM(uint16_t processCsmId);
+
+	//free msm instances
+	void unloadMSMs();
+
+	uint16_t processCsmId;
+	int freeMsmRecordsCount;
+	int nextMsmNumber;  //from 1
+	
+	
+};
+
+
+#endif //#ifndef _WSX22_IPC_SHAREDMEMORY
+