1. /*
2. *  fork_test.c
3. *  version 1
4. *  Created on: 2010-5-29
5. *      Author: wangth
6. */
7. #include <unistd.h>
8. #include <stdio.h>
9. int main ()
10. {
11. pid_t fpid; //fpid表示fork函数返回的值
12. int count=0;
13. fpid=fork();
14. if (fpid < 0)
15. printf("error in fork!");
16. else if (fpid == 0) {
17. printf("i am the child process, my process id is %d/n",getpid());
18. printf("我是爹的儿子/n");//对某些人来说中文看着更直白。
19. count++;
20. }
21. else {
22. printf("i am the parent process, my process id is %d/n",getpid());
23. printf("我是孩子他爹/n");
24. count++;
25. }
26. printf("统计结果是: %d/n",count);
27. return 0;
28. }

#include <signal.h>

#include <sys/mman.h>

#include <sys/types.h>

#include <unistd.h>

#include <cstdio>

#include <cstring>

#include <cstdlib>

#include <iostream>

#include <sys/wait.h>

#include <queue>

using namespace std;

#define BUFFER_SIZE 50

#define MAXLINE 80

char buffer[BUFFER_SIZE];

struct mes{//用于保存命令的参数,参数个数,是否并发执行,执行后是否错误

    char** args;//参数,arg[0]为命令本身

    int len;//参数个数

    bool bg;//是否并发

    int erno;//执行后是否错误

    mes():args(NULL),len(0),bg(false){}

    mes(char **_args,int _len,bool _bg):\

    args(_args),len(_len),bg(_bg){}

    void show(){//打印命令

        if(erno==-1)cout<<"ERROR:";

        for(int i=0;i<len;i++)cout<<args[i]<<" ";

        if(bg)cout<<"&"<<endl;

        else cout<<endl;

    }

    ~mes(){

        for(int i=0;i<len&&args[i];i++){

            delete[] args[i];

            args[i]=NULL;

        }

        delete[] args;

        args=NULL;

    }

};

queue <mes*> rec,quetmp;//rec用于存储最近10条命令,quetmp只是在遍历rec时暂时存储rec中的变量

static int quelen=0;//rec内变量个数

static int reclen=0;//已执行命令总条数

static int srclen=0;//已经读取字符串长度

bool read2(char * des,char *src,bool init){//从字符串src中读取非空字符串des,失败返回false, 从同一个src字符串读取应该一次性读完, init为true时代表重新读取新的src字符串

    if(init)srclen=0;

    bool fl=false;

    for(;src[srclen];srclen++){

        if(src[srclen]!=' '&&src[srclen]!='\t'&&src[srclen]!='\n'){

            fl=true;

            for(int i=0;src[srclen];srclen++,i++){

                if(src[srclen]==' '||src[srclen]=='\t'||src[srclen]=='\n')break;

                des[i]=src[srclen];

                des[i+1]=0;

            }

            break;

        }

    }

    return fl;

}

void setup(char inputBuffer[],char*args[],bool background){//执行命令inputBuffer –args[1] –arg[2]…,background为true代表并发

    int len=0;

    for(len=0;len<MAXLINE/2+1&&args[len]!=NULL;len++){}//重新新建args数组,以保证数据形式满足execvp

    char **_args=new char*[len+1];

    for(int i=0;i<len;i++){

        _args[i]=new char[strlen(args[i])+1];

        strcpy(_args[i],args[i]);

    }

    _args[len]=NULL;

    mes* pmes=new mes(_args,len,background);

    int * p_errno=(int*)mmap(NULL,sizeof(int)*2,PROT_READ|PROT_WRITE,\

        MAP_SHARED|MAP_ANONYMOUS,-1,0);//共享内存以便传递子进程的执行结果

    int pid=fork();

    if(pid==0){

        int erno=execvp(inputBuffer,_args);

        *p_errno=erno;

        _exit(0);//子进程及时退出

    }

    else{

        if(!background){

            waitpid(pid,NULL,0);

        }

    }

    pmes->erno=*p_errno;

    if(quelen<10){

        rec.push(pmes);quelen++;

    }

    else {

        delete rec.front();

        rec.pop();

        rec.push(pmes);

    }

    reclen++;

}

void handle_SIGINT(int sig){//历史缓存工具

    int ci=reclen-quelen,ind=0;

    mes* ls[10];

    cout<<endl;

    while(!rec.empty()){

        cout<<++ci<<": ";

        rec.front()->show();

        quetmp.push(rec.front());

        ls[ind++]=rec.front();

        rec.pop();

    }
　　while(!quetmp.empty()){
　　　　rec.push(quetmp.front());quetmp.pop();
　　}

    cout<<"Exit record input \"q\", repeat command,\

input \"r\" or \"r x\"(x is the prefix of command)"<<endl;

    char buff[MAXLINE],buff2[MAXLINE];

    int exeNum=ind-1;

    while(true){

        fgets(buff,MAXLINE,stdin);

        read2(buff2,buff,true);

        if(strcmp(buff2,"q")==0)break;

        if(strcmp(buff2,"r")!=0){

            cout<<"No such command"<<endl;

            continue;

        }

        if(read2(buff2,buff,false)){

            for(;exeNum>=0;exeNum--){

                bool fl=true;

                for(int i=0;buff2[i]!=0;i++){

                    if(buff2[i]!=ls[exeNum]->args[0][i]){

                        fl=false;

                        break;

                    }

                }

                if(fl)break;

            }

            if(exeNum<0)cout<<"No such prefix"<<endl;

        }

        if(exeNum>=0){

            ls[exeNum]->show();

            if(ls[exeNum]->erno==-1){

                cout<<"It is an error command!"<<endl;

            }

            else {

                setup(ls[exeNum]->args[0],ls[exeNum]->args,ls[exeNum]->bg);

            }

        }

    }

    cout<<"record has quitted"<<endl;

}

void handle_SIGTSTP(int sig){//Ctrl+d退出

    write(STDOUT_FILENO,buffer,strlen(buffer));

    exit(0);

}

int main(int argc,char * arg[]){

    char inputBuffer[MAXLINE],buff[MAXLINE];

    bool background;

    char * args[MAXLINE/2+1];

    memset(args,0,sizeof(args));

    signal(SIGINT,handle_SIGINT);

    signal(SIGTSTP,handle_SIGTSTP);

    while(true){

        background=false;

        cout<<"COMMAND->";

        fgets(inputBuffer,MAXLINE,stdin);//读取拆分命令

        int len=0;

        while(read2(buff,inputBuffer,len==0)){

            if(args[len])delete[] args[len];

            args[len++]=new char[strlen(buff)];

            strcpy(args[len-1],buff);

        }

        if(args[len])delete[] args[len];

        if(len>0&&args[len-1][0]=='&'){

            delete[] args[len-1];

            args[len-1]=NULL;

            len--;

            background=true;

        }

        setup(args[0],args,background);

        for(int i=0;i<len;i++){

            delete args[i];

            args[i]=NULL;

        }

    }

    return 0;

}