norm

srcs/execution/exec_pline.c

@@ -0,0 +1,94 @@
+/* ************************************************************************** */
+/*                                                                            */
+/*                                                        :::      ::::::::   */
+/*   exec_pline.c                                       :+:      :+:    :+:   */
+/*                                                    +:+ +:+         +:+     */
+/*   By: lderidde <lderidde@student.s19.be>        +#+  +:+       +#+         */
+/*                                                +#+#+#+#+#+   +#+           */
+/*   Created: 2025/02/12 09:50:12 by lderidde          #+#    #+#             */
+/*   Updated: 2025/02/12 09:50:12 by lderidde         ###   ########.fr       */
+/*                                                                            */
+/* ************************************************************************** */
+
+#include "../../includes/exec/exec.h"
+
+void	exec_pcmd(t_ast_n *pcmd)
+{
+	int	ret;
+
+	if (!pcmd->cmd)
+		exit(0);
+	if (is_builtin(pcmd->cmd))
+	{
+		ret = exec_builtin(pcmd);
+		free_child(pcmd->msh);
+		exit(ret);
+	}
+	else
+		exec(pcmd);
+}
+
+void	exec_pchild(int *pipes, int index, t_ast_n *pcmd, int cmds)
+{
+	int	ret;
+
+	ret = 0;
+	if (index < cmds - 1)
+		dup2(pipes[1], STDOUT_FILENO);
+	close(pipes[0]);
+	close(pipes[1]);
+	handle_redir(pcmd);
+	if (pcmd->state == _CMD)
+		exec_pcmd(pcmd);
+	else if (pcmd->state == _SUBSH)
+	{
+		ret = execute_shcommand(pcmd->left);
+		free_child(pcmd->msh);
+		exit(ret);
+	}
+}
+
+int	end_pline(pid_t last_pid, t_ast_n **pline)
+{
+	int	status;
+	int	i;
+
+	i = -1;
+	waitpid(last_pid, &status, 0);
+	while (++i < count_cmds(pline) - 1)
+		wait(NULL);
+	reset_redir(pline[0]->parent);
+	if (WIFEXITED(status))
+		return (WEXITSTATUS(status));
+	else
+		return (1);
+}
+
+int	exec_pline(t_ast_n **pline)
+{
+	int		i;
+	pid_t	pid;
+	pid_t	last_pid;
+
+	i = -1;
+	while (pline[++i])
+	{
+		if (i == 0)
+			handle_redir(pline[0]->parent);
+		pipe(pline[i]->fds);
+		pid = fork();
+		if (pid == 0)
+			exec_pchild(pline[i]->fds, i, pline[i], count_cmds(pline));
+		else if (pid > 0)
+		{
+			dup2(pline[i]->fds[0], STDIN_FILENO);
+			close(pline[i]->fds[0]);
+			close(pline[i]->fds[1]);
+			if (i == count_cmds(pline) - 1)
+				last_pid = pid;
+		}
+		else if (pid < 0)
+			return (err_fork_pline(pline[i]->fds));
+	}
+	return (end_pline(last_pid, pline));
+}