匿名管道兑现重定向输入输出,执行adb命令()

匿名管道实现重定向输入输出,执行adb命令()?
本帖最后由 VisualEleven 于 2012-09-06 13:56:22 编辑 我想通过调用adb。exe 这个控制台程序多次执行shell 命令,但是执行完第二条命令,再次通过writefile输入的时候就无法执行,通过readFile 读出的数据是第三次写入的数据。

源码。。。
char szconmand[MAX_PATH]={0};
   HANDLE stdOutPipeRd,stdOutPipeWt,stdInPipeWt,stdInPipeRd;
STARTUPINFOA startUp;
SECURITY_ATTRIBUTES lpSecurity, lpSec2;
PROCESS_INFORMATION processInfo;


lpSecurity.nLength=sizeof(SECURITY_ATTRIBUTES);
lpSecurity.lpSecurityDescriptor=NULL;
lpSecurity.bInheritHandle=true;
if (!CreatePipe(&stdOutPipeRd,&stdOutPipeWt,&lpSecurity,0))
{
DWORD err=GetLastError();

return -1;
}
lpSec2.nLength=sizeof(SECURITY_ATTRIBUTES);
lpSec2.bInheritHandle=true;
lpSec2.lpSecurityDescriptor=NULL;
if (!CreatePipe(&stdInPipeRd,&stdInPipeWt,&lpSec2,0))
{
DWORD err=GetLastError();
return -1;
}

memset(&startUp,0,sizeof(STARTUPINFOA));
GetStartupInfoA(&startUp);
startUp.cb=sizeof(STARTUPINFOA);
startUp.dwFlags=STARTF_USESTDHANDLES|STARTF_USESHOWWINDOW;
startUp.wShowWindow=HIDE_WINDOW;
startUp.hStdInput=stdOutPipeRd;
startUp.hStdOutput=stdInPipeWt;
startUp.hStdError=stdInPipeWt;
char str[MAX_PATH]={0};
strcpy(str,"adb.exe shell");
   char *pdata=NULL;
pdata=(char*)malloc(strlen(str)+strlen(szconmand));
if (pdata==NULL)
{
return -1;
}
memset(pdata,0,strlen(str)+strlen(szconmand));
int n=0;
n=strlen(str);
int k=strlen(szconmand);
   memcpy(pdata,str,sizeof(str));
memcpy(pdata+n," ",sizeof(char));
memcpy(pdata+n+1,szconmand,k);
if (!CreateProcessA(NULL,str,NULL,NULL,TRUE,0,NULL,NULL,&startUp,&processInfo))
{   
DWORD err=GetLastError();

return -1;
}
DWORD stdlen=0;
char szbuffer[MAX_PATH]={0};
   while (true)
   {   
  if(!PeekNamedPipe(stdInPipeRd,szbuffer,MAX_PATH,&stdlen,NULL,0))
   {
    
  DWORD err=GetLastError();
   return -1;
   }
    
  if (stdlen)
   {
   break;
   }
   }
    
  if (!ReadFile(stdInPipeRd,szbuffer,MAX_PATH,&stdlen,NULL))
   {
   DWORD err=GetLastError();
   return -1;
    
  }
memset(szbuffer,0,MAX_PATH);
char sqlCommand[MAX_PATH]={0};
strcpy(sqlCommand,"sqlite3 /data/data/com.android.providers.telephony/databases/mmssms.db\r\n");//程序执行到这还是正常的
if (!WriteFile(stdOutPipeWt,sqlCommand,strlen(sqlCommand)+1,&stdlen,0))
{
DWORD erro=GetLastError();
return -1;
}
memset(szbuffer,0,MAX_PATH);
while (true)
{   
if(!PeekNamedPipe(stdInPipeRd,szbuffer,MAX_PATH,&stdlen,NULL,0))
{

DWORD err=GetLastError();
return -1;
}

if (stdlen)
{
break;
}
}

if (!ReadFile(stdInPipeRd,szbuffer,MAX_PATH,&stdlen,NULL))//独处正常执行结果
{
DWORD err=GetLastError();
return -1;

}
//memset(szbuffer,0,MAX_PATH);
memset(sqlCommand,0,MAX_PATH);
strcat(szbuffer,"select * from sms;\r\n");
if (!WriteFile(stdOutPipeWt,sqlCommand,strlen(sqlCommand),&stdlen,0))//这次写入的命令,在读的时候是原封不动的被读出来了,没有执行。只能执行两次命令,,,为什么?