X-Git-Url: https://git.cweiske.de/enigma2.git/blobdiff_plain/a1664e81dd83e11828909d10b629ed04ea7d3467..7aa8a533ef0657eaa8e786384b3a3821a04c179f:/lib/base/console.cpp

diff --git a/lib/base/console.cpp b/lib/base/console.cpp
index b3fbbf73..f6e8763f 100644
--- a/lib/base/console.cpp
+++ b/lib/base/console.cpp
@@ -49,7 +49,7 @@ int bidirpipe(int pfd[], char *cmd , char *argv[])
 }
 
 eConsoleAppContainer::eConsoleAppContainer()
-:pid(-1), killstate(0)
+:pid(-1), killstate(0), in(0), out(0), err(0)
 {
 	for (int i=0; i < 3; ++i)
 		fd[i]=-1;
@@ -124,7 +124,9 @@ int eConsoleAppContainer::execute( const std::string &cmd )
 
 //	eDebug("%d args", cnt-2);
 	char **argv = new char*[cnt];  // min two args... path and terminating 0
-	argv[0] = new char[ plen ];
+//	eDebug("%d args", cnt);
+	argv[0] = new char[ plen+1 ];
+//	eDebug("new argv[0] %d bytes (%s)", plen+1, path.c_str());
 	strcpy( argv[0], path.c_str() );
 	argv[cnt-1] = 0;               // set terminating null
 
@@ -154,6 +156,7 @@ int eConsoleAppContainer::execute( const std::string &cmd )
 					tmp.erase(tmp.length()-1, 1);
 					bracketClosed=false;
 				}
+//				eDebug("new argv[%d] %d bytes (%s)", cnt, tmp.length()+1, tmp.c_str());
 				argv[cnt] = new char[ tmp.length()+1 ];
 //				eDebug("idx=%d, arg = %s", idx, tmp.c_str() );
 				strcpy( argv[cnt++], tmp.c_str() );
@@ -171,7 +174,8 @@ int eConsoleAppContainer::execute( const std::string &cmd )
 			cmds.erase(cmds.length()-1, 1);
 		}
 		// store the last arg
-		argv[cnt] = new char[ cmds.length() ];
+//		eDebug("new argv[%d] %d bytes (%s)", cnt, cmds.length()+1, cmds.c_str());
+		argv[cnt] = new char[ cmds.length()+1 ];
 		strcpy( argv[cnt], cmds.c_str() );
 	}
 	else
@@ -196,7 +200,7 @@ int eConsoleAppContainer::execute( const std::string &cmd )
 	if ( pid == -1 )
 		return -3;
 
-	eDebug("pipe in = %d, out = %d, err = %d", fd[0], fd[1], fd[2]);
+//	eDebug("pipe in = %d, out = %d, err = %d", fd[0], fd[1], fd[2]);
 
 	in = new eSocketNotifier(eApp, fd[0], POLLIN|POLLPRI|POLLHUP );
 	out = new eSocketNotifier(eApp, fd[1], POLLOUT, false);  
@@ -214,7 +218,7 @@ eConsoleAppContainer::~eConsoleAppContainer()
 
 void eConsoleAppContainer::kill()
 {
-	if ( killstate != -1 )
+	if ( killstate != -1 && pid != -1 )
 	{
 		eDebug("user kill(SIGKILL) console App");
 		killstate=-1;
@@ -235,7 +239,7 @@ void eConsoleAppContainer::kill()
 
 void eConsoleAppContainer::sendCtrlC()
 {
-	if ( killstate != -1 )
+	if ( killstate != -1 && pid != -1 )
 	{
 		eDebug("user send SIGINT(Ctrl-C) to console App");
 		::kill(pid, SIGINT);
@@ -244,15 +248,27 @@ void eConsoleAppContainer::sendCtrlC()
 
 void eConsoleAppContainer::closePipes()
 {
-	in->stop();
-	out->stop();
-	err->stop();
-	::close(fd[0]);
-	fd[0]=-1;
-	::close(fd[1]);
-	fd[1]=-1;
-	::close(fd[2]);
-	fd[2]=-1;
+	if (in)
+		in->stop();
+	if (out)
+		out->stop();
+	if (err)
+		err->stop();
+	if (fd[0] != -1)
+	{
+		::close(fd[0]);
+		fd[0]=-1;
+	}
+	if (fd[1] != -1)
+	{
+		::close(fd[1]);
+		fd[1]=-1;
+	}
+	if (fd[2] != -1)
+	{
+		::close(fd[2]);
+		fd[2]=-1;
+	}
 	eDebug("pipes closed");
 	while( outbuf.size() ) // cleanup out buffer
 	{
@@ -260,6 +276,7 @@ void eConsoleAppContainer::closePipes()
 		outbuf.pop();
 		delete [] d.data;
 	}
+	pid = -1;
 }
 
 void eConsoleAppContainer::readyRead(int what)
@@ -337,3 +354,4 @@ void eConsoleAppContainer::readyWrite(int what)
 	if ( !outbuf.size() )
 		out->stop();
 }
+	
\ No newline at end of file