executor_pipe.c

Bu dosyanın dokümantasyonuna git.

/* ************************************************************************** */
/*                                                                            */
/*                                                        :::      ::::::::   */
/*   executor_pipe.c                                    :+:      :+:    :+:   */
/*                                                    +:+ +:+         +:+     */
/*   By: hgenc <hgenc@student.42kocaeli.com.tr>     +#+  +:+       +#+        */
/*                                                +#+#+#+#+#+   +#+           */
/*   Created: 2026/01/26 17:39:50 by hgenc             #+#    #+#             */
/*   Updated: 2026/02/16 17:00:00 by hgenc            ###   ########.fr       */
/*                                                                            */
/* ************************************************************************** */
 
#include "../../include/minishell.h"
#include <stdlib.h>
#include <sys/wait.h>
#include <unistd.h>
 
/**
 * @brief Pipe fd'lerini kapat
 */
void    close_pipe(int *pipefd)
{
    if (!pipefd)
        return ;
    close(pipefd[0]);
    close(pipefd[1]);
}
 
static int  fork_process(pid_t *pid, int *pipefd)
{
    *pid = fork();
    if (*pid < 0)
    {
        close_pipe(pipefd);
        shell_error(NULL, NULL, "fork failed");
        return (0);
    }
    return (1);
}
 
/**
 * @brief Pipe node'unu çalıştır
 * Her iki taraf da child process'te çalışır.
 */
int execute_pipe(t_shell *shell, t_ast *node)
{
    int     pipefd[2];
    pid_t   left_pid;
    pid_t   right_pid;
 
    if (pipe(pipefd) < 0)
    {
        shell_error(NULL, NULL, "pipe failed");
        return (1);
    }
    if (!fork_process(&left_pid, pipefd))
        return (1);
    if (left_pid == 0)
        pipe_left_child(shell, node, pipefd);
    if (!fork_process(&right_pid, pipefd))
    {
        waitpid(left_pid, NULL, 0);
        return (1);
    }
    if (right_pid == 0)
        pipe_right_child(shell, node, pipefd);
    close_pipe(pipefd);
    return (wait_pipe(left_pid, right_pid));
}