socket服务 fork进程执行程序 报I/O error: 32

chllcy88

基本的代码如下,起一个服务,每次前台发送任务过来,后台服务子进程system调用,产生子进程处理前台任务.
但观察日志发现一直报
2012-05-04 11:34:21.433 237862:2 taskexec-[Debug] before fork

2012-05-04 11:34:21.436 237862:2 taskexec-[Debug] fork

2012-05-04 11:34:21.604 237862:2 taskexec-[Debug] after fork

2012-05-04 11:34:21.608 237862:2 taskexec-[Error] proxy Connection run error,I/O error: 32

然后前台程序发送消息后,没收到后台返回的任何信息,前台的基本代码如下:sbf返回为空

1.                         in = new BufferedReader(new InputStreamReader(socket
   
2.                                         .getInputStream()));
   
3. 
   
4.                         out = new PrintWriter(new BufferedWriter(
   
5.                                         new OutputStreamWriter(socket.getOutputStream())), true);
   
6. 
   
7.                         out.println(SimpleXMLWorkShop.doc2Str(doc, "GB2312"));
   
8.                         out.flush();
   
9. 
   
10.                         StringBuffer sbf = new StringBuffer();
    
11.                         String temp = null;
    
12.                         while ((temp = in.readLine()) != null) {
    
13.                                 sbf.append(temp);
    
14.                         }

复制代码

后台代码如下:

1. int TaskExecConnection::execLocalCmd(std::string & retInfo,const std::string & cmd)
   
2. {
   
3.         pid_t     pid;
   
4.         errno=0;
   
5.         int status;
   
6.     //printf("before fork\n");    /* we don't flush stdout */
   
7.     logger().debug(("before fork\n"));
   
8.     bool iferror = false;
   
9. 
   
10.     if ((pid = fork()) < 0)
    
11.     {
    
12.         printf("fork error");
    
13.     }
    
14.     else if (pid == 0)
    
15.     {      /* child */
    
16.             StreamSocket& ss = socket();
    
17.                 ss.shutdown();
    
18.                 errno = system(cmd.c_str());
    
19.                 if ( errno != 0 )
    
20.                 {
    
21.                         iferror = true;
    
22.                         retInfo = "-1,exec cmd error";       
    
23.                         exit(-1);
    
24.                 }
    
25.                 exit(0);
    
26.     }
    
27.     else
    
28.     {
    
29.             logger().debug(("fork parent\n"));
    
30.                 waitpid(pid,&status,0);
    
31.     }
    
32.     logger().debug(("after fork\n"));
    
33.     if( iferror == true )
    
34.     {
    
35.             return -1;
    
36.     }       
    
37.     else
    
38.     {
    
39.             retInfo = "0,exec ok";
    
40.             return 0;
    
41.     }
    
42. 
    
43. }

复制代码