c - 在我的 shell 中实现管道-6ren

c - 在我的 shell 中实现管道

转载作者：行者123 更新时间：2023-11-30 15:31:21

我读了很多类似的主题，并且已经搜索了很长时间，但我没有找到我的问题出在哪里，所以我向你寻求帮助:

我正在尝试实现一个迷你 shell，它工作得很好，但我在管道实现方面遇到一个问题:

管道完成工作之前会出现提示: /home/sim/t? ls | grep toto打印/home/sim/t? toto (在同一行)而不是

toto
/home/sim/t?

如果我添加一个 sleep(1) (查看代码的注释)它工作得很好，但我想找到如何等待好的过程，我尝试了很多东西，但它没有工作...

命令ls | wc在应该打印的时候也不打印任何内容。

这是我的代码(抱歉，长度太长，请随时要求澄清):

# include <assert.h> 
# include <stdio.h> 
# include <stdlib.h> 
# include <unistd.h> 
# include <sys/stat.h> 
# include <sys/types.h> 
# include <fcntl.h> 
# include <sys/wait.h>
# include <string.h>
enum { 
    MaxLigne = 1024,              
    MaxMot = MaxLigne / 2,       
    MaxDirs = 100,          
    MaxPathLength = 512,      
}; 
void decouper(char *, char *, char **, int); 
void affiche_prompt();
int in_array(char *, char **);
void executer_PATH(char **);
void usage(char *);

int 
main(int argc, char * argv[]){ 
    char ligne[MaxLigne]; 
    char * mot[MaxMot];
    char * mot2[MaxMot];
    int fd[2];
    int pipe_flag, i; 
    pid_t tmp, tmp_pipe;  

    for(affiche_prompt();fgets(ligne, sizeof ligne, stdin) != 0;affiche_prompt()) { 
        decouper(ligne, " \t\n", mot, MaxMot); 

        if (mot[0] == 0)  
            continue; 

        /* Is there a pipe? */
        pipe_flag = in_array("|", mot);
        if (pipe_flag > 0){
            if (pipe(fd) != 0)
               usage("Problème dans la création du pipe");

            if(mot[pipe_flag] == 0) {
                fprintf(stderr, 
                    "Vous devez entrer une commande après le pipe (|)\n");
            }
            //Copy second instruction in an array
            i = 0;
            while(pipe_flag <= MaxMot) {        
                mot2[i] = mot[pipe_flag];
                pipe_flag++;
                i++;
            }   
        }     

        tmp = fork();   

        if (tmp < 0){ 
            perror("fork"); 
            continue; 
        }  

        if (tmp != 0){  

            if (pipe_flag > 0){ //ther is a pipe            
                tmp_pipe = fork(); //for the shell not to be closed after a pipe

                if (tmp_pipe < 0){ 
                    perror("fork"); 
                    continue; 
                }  

                if (tmp_pipe != 0){ 
                    while(wait(0) != tmp_pipe); 
                    // here is the problem because a 
                    // sleep(1); 
                    // makes the shell waits as it should
                    continue;
                }  

                close(fd[0]); 
                dup2(fd[1], STDOUT_FILENO); 
                close(fd[1]); 
                executer_PATH(mot);   
            }    
            while(wait(0) != tmp) ; 
            continue;   
        } 

        if (pipe_flag == 0){ //There is no pipe                      
            executer_PATH(mot); 
        }
        //there is one pipe
        close(fd[1]);
        dup2(fd[0], STDIN_FILENO);
        close(fd[0]);
        executer_PATH(mot2);                  
    } 
    printf("Bye\n"); 
    return 0; 
}


/* decouper  --  decouper une chaine en mots */ 
void 
decouper(char * ligne, char * separ, char * mot[], int maxmot){ 
  int i; 

  mot[0] = strtok(ligne, separ); 
  for(i = 1; mot[i - 1] != 0; i++){ 
    if (i == maxmot){ 
      usage("Erreur dans la fonction decouper: trop de mots"); 
      mot[i - 1] = 0; 
      break; 
    } 
    mot[i] = strtok(NULL, separ); 
  } 
} 

/* affiche_prompt 
    affect à la variable globale PROMPT "?" + le répertoire courant*/
void 
affiche_prompt(){
    char buffer[MaxPathLength];
    if (getcwd (buffer, MaxPathLength) == NULL) 
        usage("impossible de connaître le répertoire courant");
    printf("%s", strcat(buffer, "? ")); 
}

/* in_array --
    renvoie 0 si le mot n'est pas trouvé, la case suivante sinon */
int
in_array(char * mot_cherche, char ** mot)
{
    int i;
    for(i = 1; i <= MaxMot; i++){ 
        if (mot[i] == 0) 
            break; 

        if (strcmp(mot[i], mot_cherche) == 0){  
            mot[i] = 0; 
            return i+1;
        } 
    }   
    return 0; 
}

/* executer_PATH -- essaye de lancer la commande donnée en argument avec les 
chemins enregistrés dans PATH */ 
void 
executer_PATH(char ** commande){ 
    int i; 
    char * dirs[MaxDirs]; 
    char pathname[MaxPathLength]; 

    /* Decouper PATH en repertoires */ 
    decouper(strdup(getenv("PATH")), ":", dirs, MaxDirs); 

    for(i = 0; dirs[i] != 0; i++){           
        snprintf(pathname, sizeof pathname, "%s/%s", dirs[i], commande[0]); 
        execv(pathname, commande); 
    } 
    /* Aucun exec n’a fonctionné */       
    fprintf(stderr, "%s: not found\n", commande[0]); 
    exit(1); 
} 

/* usage -- afficher un message d'erreur et sortir */
void 
usage(char * message)
{
    fprintf(stderr, "%s\n", message);
    exit(1);
}

欢迎对我的代码提出任何评论，提前谢谢!

最佳答案

你的主要问题是executer_PATH()可以在程序执行失败时返回，但 5 次调用中只有 3 次后面有错误处理代码。最好让函数报告错误并退出。进行更改后，shell 就会正常执行。

修改executer_PATH()至:

void
executer_PATH(char **commande)
{
    int i;
    char *dirs[MaxDirs];
    char pathname[MaxPathLength];

    decouper(strdup(getenv("PATH")), ":", dirs, MaxDirs);

    for (i = 0; dirs[i] != 0; i++)
    {
        snprintf(pathname, sizeof pathname, "%s/%s", dirs[i], commande[0]);
        execv(pathname, commande);
    }
    fprintf(stderr, "Failed to find a command for %s\n", commande[0]);
    exit(1);
}

导致输出如下:

/Users/jleffler/soq? ls | wkj
Failed to find a command for wkj
/Users/jleffler/soq? wkj | cat
Failed to find a command for wkj
/Users/jleffler/soq? wkj | lkq
Failed to find a command for lkq
Failed to find a command for wkj
/Users/jleffler/soq? Bye

在调用executer_PATH()之后，我确实删除了现在多余的错误检查代码。，但是显示的代码更改足以使事情正常运行。问题是executer_PATH()如果没有错误代码，则子进程仍在运行(等待输入？)，而父进程仍在等待子进程退出，但事实并非如此。

<小时/>

修改后的代码经过轻微修改后的变体如下所示:

声明affiche_prompt();具有完整的原型(prototype)(没有参数，它只是说“该函数存在，但你对参数列表一无所知”)。
定义main()没有参数，因为它们没有被使用。
打印 executer_PATH() 中有关 PID 和命令的诊断信息.
捕获并打印有关 PID 的诊断信息以及等待循环中的退出状态。
修改内部逻辑fork()处理代码有 if (pid < 0)和else if (pid != 0)和一个else 。我更喜欢这个，或者switch (pid) { case -1: ...; case 0: ...; default: ...; } ，到您所在的组织。我经常创建一个函数来作为 if 的每个部分中的操作。陈述。我没有修复外部代码。

结果输出如下:

$ ./pipe43
/home/jleffler/soq? ls | sleep 4
Child 19300: sleep
Child 19301: ls
End-1: PID 19301 exit status 0x0000
End-2: PID 19300 exit status 0x0000
/home/jleffler/soq? sleep 4 | ls
Child 19318: ls
Child 19319: sleep
bash-assoc-arrays.sh  kwargs.py  pipe43    posixver.h  spc.py  tmn.c
data              makefile   pipe43.c  select.c    tmn
Got-1: PID 19318 exit status 0x0000
End-1: PID 19319 exit status 0x0000
End-2: PID -1 exit status 0x0000
/home/jleffler/soq? Bye
$

到目前为止，一切都很好。然后我尝试了:

$ ./pipe43
/home/jleffler/soq? ls | cat
Child 19807: ls
Child 19806: cat
End-1: PID 19807 exit status 0x0000
bash-assoc-arrays.sh
data
kwargs.py
makefile
pipe43
pipe43.c
posixver.h
select.c
spc.py
tmn
tmn.c

直到我打断它，它才终止。这表明您没有关闭父进程中的管道 - 正在等待的 shell。我添加了几行:

close(fd[0]);
close(fd[1]);

在每个 wait() 之前循环 - 现在显示在下面的代码中 - 尽管第二对是多余的，除非您删除内部 wait()循环。

额外关闭到位后，输出将变为:

$ ./pipe43
/home/jleffler/soq? ls | cat
Child 20111: cat
Child 20112: ls
bash-assoc-arrays.sh
data
kwargs.py
makefile
pipe43
pipe43.c
posixver.h
select.c
spc.py
tmn
tmn.c
End-1: PID 20112 exit status 0x0000
End-2: PID 20111 exit status 0x0000
/home/jleffler/soq? Bye
$

修改后的代码:

#include <assert.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <fcntl.h>
#include <sys/wait.h>
#include <string.h>

enum {
    MaxLigne = 1024,
    MaxMot = MaxLigne / 2,
    MaxDirs = 100,
    MaxPathLength = 512,
};
void decouper(char *, char *, char **, int);
void affiche_prompt(void);
int in_array(char *, char **);
void executer_PATH(char **);
void usage(char *);

int
main(void)
{
    char ligne[MaxLigne];
    char * mot[MaxMot];
    char * mot2[MaxMot];
    int fd[2];
    int pipe_flag, i;
    pid_t tmp;

    for(affiche_prompt();fgets(ligne, sizeof ligne, stdin) != 0;affiche_prompt()) {
        decouper(ligne, " \t\n", mot, MaxMot);

        if (mot[0] == 0)
            continue;

        /* Is there a pipe? */
        pipe_flag = in_array("|", mot);
        if (pipe_flag > 0){
            if (pipe(fd) != 0)
               usage("Problème dans la création du pipe");

            if(mot[pipe_flag] == 0) {
                fprintf(stderr,
                    "Vous devez entrer une commande après le pipe (|)\n");
            }
            //Copy second instruction in an array
            i = 0;
            while(pipe_flag <= MaxMot) {
                mot2[i] = mot[pipe_flag];
                pipe_flag++;
                i++;
            }
        }

        tmp = fork();

        if (tmp < 0){
            perror("fork");
            continue;
        }

        if (tmp != 0)
        {
            if (pipe_flag > 0){ //ther is a pipe
                pid_t pid2 = fork(); //for the shell not to be closed after a pipe

                if (pid2 < 0){
                    perror("fork");
                }
                else if (pid2 != 0){
                  close(fd[0]);
                  close(fd[1]);
                  int corpse;
                  int status;
                  while ((corpse = wait(&status)) != pid2 && corpse != -1)
                    fprintf(stderr, "Got-1: PID %d exit status 0x%.4X\n", corpse, status);
                  fprintf(stderr, "End-1: PID %d exit status 0x%.4X\n", corpse, status);
                }
                else
                {
                  close(fd[0]);
                  dup2(fd[1], STDOUT_FILENO);
                  close(fd[1]);
                  executer_PATH(mot);
                }
            }
            {
              int corpse;
              int status;
              /* These closes are redundant until you remove the inner wait code */
              close(fd[0]);
              close(fd[1]);
              while ((corpse = wait(&status)) != tmp && corpse != -1)
                fprintf(stderr, "Got-2: PID %d exit status 0x%.4X\n", corpse, status);
              fprintf(stderr, "End-2: PID %d exit status 0x%.4X\n", corpse, status);
            }
            continue;
        }

        if (pipe_flag == 0){ //There is no pipe
            executer_PATH(mot);
        }
        //there is one pipe
        close(fd[1]);
        dup2(fd[0], STDIN_FILENO);
        close(fd[0]);
        executer_PATH(mot2);
    }
    printf("Bye\n");
    return 0;
}


/* decouper  --  decouper une chaine en mots */
void
decouper(char * ligne, char * separ, char * mot[], int maxmot){
  int i;

  mot[0] = strtok(ligne, separ);
  for(i = 1; mot[i - 1] != 0; i++){
    if (i == maxmot){
      usage("Erreur dans la fonction decouper: trop de mots");
      mot[i - 1] = 0;
      break;
    }
    mot[i] = strtok(NULL, separ);
  }
}

/* affiche_prompt
    affect à la variable globale PROMPT "?" + le répertoire courant*/
void
affiche_prompt(void){
    char buffer[MaxPathLength];
    if (getcwd (buffer, MaxPathLength) == NULL)
        usage("impossible de connaître le répertoire courant");
    printf("%s", strcat(buffer, "? "));
}

/* in_array --
    renvoie 0 si le mot n'est pas trouvé, la case suivante sinon */
int
in_array(char * mot_cherche, char ** mot)
{
    int i;
    for(i = 1; i <= MaxMot; i++){
        if (mot[i] == 0)
            break;

        if (strcmp(mot[i], mot_cherche) == 0){
            mot[i] = 0;
            return i+1;
        }
    }
    return 0;
}

/* executer_PATH -- essaye de lancer la commande donnée en argument avec les
chemins enregistrés dans PATH */
void
executer_PATH(char ** commande){
    int i;
    char * dirs[MaxDirs];
    char pathname[MaxPathLength];
    fprintf(stderr, "Child %d: %s\n", (int)getpid(), commande[0]);

    /* Decouper PATH en repertoires */
    decouper(strdup(getenv("PATH")), ":", dirs, MaxDirs);

    for(i = 0; dirs[i] != 0; i++){
        snprintf(pathname, sizeof pathname, "%s/%s", dirs[i], commande[0]);
        execv(pathname, commande);
    }
    /* Aucun exec n’a fonctionné */
    fprintf(stderr, "%s: not found\n", commande[0]);
    exit(1);
}

/* usage -- afficher un message d'erreur et sortir */
void
usage(char * message)
{
    fprintf(stderr, "%s\n", message);
    exit(1);
}

关于c - 在我的 shell 中实现管道，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/24877423/

文章推荐： c - GtkButton 发出 GDK_KEY_PRESS

文章推荐： c# - 对 Microsoft.SharePoint.dll 的引用

文章推荐： c# - 如何使用 C# 和 OpenXml 访问 Word 文档中大纲的编号？

javascript - 我需要将文本放在一个中，它位于一个 Div 中，该 Div 位于另一个 Div 中，该 Div 位于另一个 Div 中
我需要将文本放在中在一个 Div 中，在另一个 Div 中，在另一个 Div 中。所以这是它的样子: #document Change PIN
html - 两个背景图像。一个在 HTML 中，一个在 BODY 中。在 Firefox 中，主体图像未呈现
奇怪的事情发生了。我有一个基本的 html 代码。 html，头部， body 。(因为我收到了一些反对票，这里是完整的代码) 这是我的CSS: html { backgroun
ios - 将图像从 asset.xcassets 加载到 imageArray 中，并将其动态加载到 UIImageView 中，该 UIImageView 存在于 UICollectionView 中 - swift
我正在尝试将 Assets 中的一组图像加载到 UICollectionview 中存在的 ImageView 中，但每当我运行应用程序时它都会显示错误。而且也没有显示图像。我在ViewDidLoa
linux - 在 BASH 中，我需要根据 perl 脚本的输出更改一些环境变量。在 tcsh 中，我可以使用别名 eval 组合。不能在 bash 中
我需要根据带参数的 perl 脚本的输出更改一些环境变量。在 tcsh 中，我可以使用别名命令来评估 perl 脚本的输出。 tcsh: alias setsdk 'eval `/localhome/
asp.net - Windows 身份验证适用于 IIS，但不适用于 Kestrel/Microsoft.AspNetCore.Authentication.Negotiate(不在 Chrome 中，有时在 Edge 中，始终在 IE 中)？
我使用 Windows 身份验证创建了一个新的 Blazor(服务器端)应用程序，并使用 IIS Express 运行它。它将显示一条消息“Hello Domain\User!”来自右上方的以下 Ra
java - java 中 Kotlin 中的等价物是什么？
这是我的方法 void login(Event event);我想知道 Kotlin 中应该如何最佳答案在 Kotlin 中通配符运算符是 * 。它指示编译器它是未知的，但一旦知道，就不会有其他类
express - 在 Jade 中，为什么有时我可以按原样使用变量而有时必须将它们包含在#{......} 中？
看下面的代码 for story in book if story.title.length < 140 - var story
c - C 中 strstr() 中 for 循环的错误使用
我正在尝试用 C 语言学习字符串处理。我写了一个程序，它存储了一些音乐轨道，并帮助用户检查他/她想到的歌曲是否存在于存储的轨道中。这是通过要求用户输入一串字符来完成的。然后程序使用 strstr()
c - * 在 sscanf 中，* 在 [] 中
我正在学习 sscanf 并遇到如下格式字符串: sscanf("%[^:]:%[^*=]%*[*=]%n",a,b,&c); 我理解 %[^:] 部分意味着扫描直到遇到 ':' 并将其分配给 a。:
python - 在 Python (2.7.3) 中，如果 str(x) 中的任何字符在 str(y) 中(或 str(y) 在 str(x) 中)，我如何编写一个函数来回答？
def char_check(x,y): if (str(x) in y or x.find(y) > -1) or (str(y) in x or y.find(x) > -1):
ansible - 在 Ansible 中，如何将一行移动到一个 block 中？
我有一种情况，我想将文本文件中的现有行包含到一个新 block 中。 line 1 line 2 line in block line 3 line 4 应该变成 line 1 line 2 line
Django 调试工具栏显示在根 URL 中，但不显示在应用程序 URL 中
我有一个新项目，我正在尝试设置 Django 调试工具栏。首先，我尝试了快速设置，它只涉及将 'debug_toolbar' 添加到我的已安装应用程序列表中。有了这个，当我转到我的根 URL 时，调试
r - 在 R 中，Matlab 中 @ 函数句柄的等价物是什么？
在 Matlab 中，如果我有一个函数 f，例如签名是 f(a,b,c)，我可以创建一个只有一个变量 b 的函数，它将使用固定的 a=a1 和 c=c1 调用 f: g = @(b) f(a1, b,
swiftui - SwiftUI 中 ScrollView 中 VStack 元素中的神秘间距或填充
我不明白为什么 ForEach 中的元素之间有多余的垂直间距在 VStack 里面在 ScrollView 里面使用 GeometryReader 时渲染自定义水平分隔线。 Scrol
cookies - 什么应该存储在 session 中，什么应该存储在 cookie 中？
我想知道，是否有关于何时使用 session 和 cookie 的指南或最佳实践？什么应该和什么不应该存储在其中？谢谢! 最佳答案这些文档很好地了解了 session cookie 的安全问题以及
python - Python 中 matplotlib 中 3d 直方图的奇怪行为
我在 scipy/numpy 中有一个 Nx3 矩阵，我想用它制作一个 3 维条形图，其中 X 轴和 Y 轴由矩阵的第一列和第二列的值、高度确定每个条形的是矩阵中的第三列，条形的数量由 N 确定。
c - c 中 sem_init(...) 中 value 参数的不同用法
假设我用两种不同的方式初始化信号量 sem_init(&randomsem,0,1) sem_init(&randomsem,0,0) 现在， sem_wait(&randomsem) 在这两种情况下
c - 实际值存储在 pstr 中，但是该值如何存储在数组 "WORD"中
我怀疑该值如何存储在“WORD”中，因为 PStr 包含实际输出。？既然Pstr中存储的是小写到大写的字母，那么在printf中如何将其给出为“WORD”。有人可以吗？解释一下？ #include
javascript - 数组索引选择像在 numpy 中，但在 javascript 中
我有一个 3x3 数组: var my_array = [[0,1,2], [3,4,5], [6,7,8]]; 并想获得它的第一个 2
javascript - 在 Javascript 中，如何检测浏览器窗口何时在 View 中？
我意识到您可以使用如下方式轻松检查焦点: var hasFocus = true; $(window).blur(function(){ hasFocus = false; }); $(win

行者123

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

c - 在我的 shell 中实现管道