From 8174eb73282e177112615c2dd332b69401959764 Mon Sep 17 00:00:00 2001
From: Gluzskiy Alexandr <sss123next@list.ru>
Date: Wed, 30 Mar 2011 08:51:28 +0300
Subject: one more threading variant (without mutexes)

---
 gpg_wrapper.cpp | 16 +++++++---------
 1 file changed, 7 insertions(+), 9 deletions(-)

(limited to 'gpg_wrapper.cpp')

diff --git a/gpg_wrapper.cpp b/gpg_wrapper.cpp
index 3091566..b85d24b 100644
--- a/gpg_wrapper.cpp
+++ b/gpg_wrapper.cpp
@@ -18,12 +18,12 @@
 
 //thx gpg module from Harald Treder, Zakhar V. Bardymov
 
-boost::mutex gpg_mutex;
+//boost::mutex gpg_mutex;
 
 
 pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD aexitcode, pxResult *result)
 {
-	gpg_mutex.lock();
+//	gpg_mutex.lock();
 	if(!gpg_configured)
 		return pxNotConfigured;
 	extern logtofile debuglog;
@@ -80,6 +80,7 @@ pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD
 			if(errno == ENOENT)
 			{
 				mir_free(bin_path);
+				debuglog<<time_str()<<": GPG executable not found\n";
 				*result = pxNotFound;
 				return pxNotFound;
 			}
@@ -99,7 +100,7 @@ pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD
 		delete [] home_dir;
 	}
 
-	debuglog<<time_str()<<": gpg in: "<<commandline;
+	debuglog<<time_str()<<": gpg in: "<<commandline<<"\n";
 
 
 	success = CreateProcess(NULL, (TCHAR*)commandline.c_str(), NULL, NULL, TRUE, CREATE_NEW_CONSOLE | CREATE_UNICODE_ENVIRONMENT, (void*)_T("LANGUAGE=en@quot\0LC_ALL=English\0"), NULL, &sinfo, &pri);
@@ -110,7 +111,8 @@ pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD
 		CloseHandle(writestdin);
 		CloseHandle(newstdout);
 		CloseHandle(readstdout);
-		gpg_mutex.unlock();
+		debuglog<<time_str()<<": Failed to create process\n";
+//		gpg_mutex.unlock();
 		*result = pxCreateProcessFailed;
 		return pxCreateProcessFailed;
 	}
@@ -147,7 +149,7 @@ pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD
 	CloseHandle(writestdin);
 
 	*result = pxSuccess;
-	gpg_mutex.unlock();
+//	gpg_mutex.unlock();
 	return pxSuccess;
 }
 
@@ -155,8 +157,4 @@ void pxEexcute_thread(void *param)
 {
 	gpg_execution_params *params = (gpg_execution_params*)param;
 	pxResult result = pxExecute(params->cmd, params->useless, params->out, params->code, params->result);
-	if(result == pxNotFound)
-	{
-		debuglog<<time_str()<<": Gpg binary not found";
-	}
 }
-- 
cgit v1.2.3


From 903cf85316f641a2d7fcc7fb87ed75889469d2dc Mon Sep 17 00:00:00 2001
From: Gluzskiy Alexandr <sss123next@list.ru>
Date: Wed, 30 Mar 2011 09:36:35 +0300
Subject: some agression )

---
 gpg_wrapper.cpp | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

(limited to 'gpg_wrapper.cpp')

diff --git a/gpg_wrapper.cpp b/gpg_wrapper.cpp
index b85d24b..3ed7f4a 100644
--- a/gpg_wrapper.cpp
+++ b/gpg_wrapper.cpp
@@ -21,7 +21,7 @@
 //boost::mutex gpg_mutex;
 
 
-pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD aexitcode, pxResult *result)
+pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD aexitcode, pxResult *result, HANDLE hProcess)
 {
 //	gpg_mutex.lock();
 	if(!gpg_configured)
@@ -102,7 +102,6 @@ pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD
 
 	debuglog<<time_str()<<": gpg in: "<<commandline<<"\n";
 
-
 	success = CreateProcess(NULL, (TCHAR*)commandline.c_str(), NULL, NULL, TRUE, CREATE_NEW_CONSOLE | CREATE_UNICODE_ENVIRONMENT, (void*)_T("LANGUAGE=en@quot\0LC_ALL=English\0"), NULL, &sinfo, &pri);
 
 	if (!success)
@@ -117,6 +116,8 @@ pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD
 		return pxCreateProcessFailed;
 	}
 
+	hProcess = pri.hProcess;
+
 	inputpos=ainput;
 
 	while (TRUE)
@@ -156,5 +157,5 @@ pxResult pxExecute(wstring *acommandline, char *ainput, string *aoutput, LPDWORD
 void pxEexcute_thread(void *param)
 {
 	gpg_execution_params *params = (gpg_execution_params*)param;
-	pxResult result = pxExecute(params->cmd, params->useless, params->out, params->code, params->result);
+	pxResult result = pxExecute(params->cmd, params->useless, params->out, params->code, params->result, params->hProcess);
 }
-- 
cgit v1.2.3