#include <iostream>
#include <vector>
#include <string>
#include <unistd.h>
#include "task.hpp"
#include <sys/stat.h>
#include <sys/wait.h>
#include <cstdio>

#define PROCESSNUM 10
std::vector<task_t> tasks;

int main()
{
	//加載任務(wù)
	LoadTask(&tasks);
	//定義一個(gè)vector管理所有的管道，channel是描述，channels是組織
    std::vector<channel> channels;
    //初始化
    InitProcessPool(&channels);
    //開(kāi)始進(jìn)行
    StartProcessPool(channels);
    //清理
    CleanProcessPool(channels);
    return 0;
}

#pragma once

#include <iostream>
#include <vector>
//定義一個(gè)函數(shù)指針task_t指向返回值為void，沒(méi)有參數(shù)的函數(shù)
typedef void (*task_t)();

void task1()
{
    std::cout << "this is task1 running" << std::endl;
}
void task2()
{
    std::cout << "this is task2 running" << std::endl;
}
void task3()
{
    std::cout << "this is task3 running" << std::endl;
}
void task4()
{
    std::cout << "this is task4 running" << std::endl;
}
//加載任務(wù)函數(shù)，將任務(wù)pushback到vector中
void LoadTask(std::vector<task_t> *tasks)
{
    tasks->push_back(task1);
    tasks->push_back(task2);
    tasks->push_back(task3);
    tasks->push_back(task4);
}

class channel
{
public:
    // 描述父進(jìn)程的fd，對(duì)應(yīng)子進(jìn)程的pid，子進(jìn)程的名字
    channel(int cmdfd, int slaverid, const std::string &processname)
    :_cmdfd(cmdfd),_slaverid(slaverid),_processname(processname)
    {}

    int _cmdfd;
    pid_t _slaverid;
    std::string _processname;
};

void slaver()
{
    while(true)
    {
        // 用于存儲(chǔ)從標(biāo)準(zhǔn)輸入讀取的命令碼
        int cmdcode = 0;
        // 從標(biāo)準(zhǔn)輸入（管道）讀取數(shù)據(jù)，嘗試讀取sizeof(int)字節(jié)的數(shù)據(jù)到cmdcode中
        // 如果父進(jìn)程不給子進(jìn)程發(fā)送數(shù)據(jù)子進(jìn)程就會(huì)進(jìn)入阻塞等待
        int n = read(0, &cmdcode, sizeof(int));    
        if(n == sizeof(int))
        {
            // read的返回值與sizeof(int)相等，就輸出子進(jìn)程pid和獲得命令碼
            // 如果命令碼有效就調(diào)用task任務(wù)，無(wú)效就退出
            std::cout <<"slaver say@ get a command: "<< getpid() << " : cmdcode: " 
            <<  cmdcode << std::endl;
            if(cmdcode >= 0 && cmdcode < tasks.size()) tasks[cmdcode]();
        }
        else break;
    }
}

void InitProcessPool(std::vector<channel>* channels)
{
    //用于存儲(chǔ)之前創(chuàng)建的管道的寫(xiě)端文件描述符
    //目的是讓后續(xù)創(chuàng)建的子進(jìn)程可以關(guān)閉這些舊的寫(xiě)端文件描述符，避免資源泄漏
    std::vector<int> oldfds;
    //循環(huán)創(chuàng)建子進(jìn)程
    for(int i = 0; i < PROCESSNUM; i++)
    {
        int pipefd[2] = {0};
        int n = pipe(pipefd);
        if(n < 0)
        {
            return;
        }

        pid_t id = fork();
        if(id < 0)
        {
            return;
        }
        if(id == 0)
        {
            //打印子進(jìn)程pid，打印并關(guān)閉上一個(gè)管道寫(xiě)端文件描述符
            std::cout << "child : " << getpid() << " close history fd: ";
            for(auto fd : oldfds)
            {
                std::cout << fd << " ";
                close(fd);
            }
            std::cout << std::endl;
            //關(guān)閉寫(xiě)端通道
            close(pipefd[1]);
            //將當(dāng)前管道的讀端文件描述符復(fù)制到標(biāo)準(zhǔn)輸入
            //這樣子進(jìn)程就可以通過(guò)標(biāo)準(zhǔn)輸入從管道讀取數(shù)據(jù)
            dup2(pipefd[0],0);
            // 讀取完關(guān)閉管道讀端
            close(pipefd[0]);
            // 子進(jìn)程主要業(yè)務(wù)
            slaver();
            //打印子進(jìn)程要退出了
            std::cout << "process : " << getpid() << " quit" << std::endl;
            exit(0);
        }
        //父進(jìn)程開(kāi)始
        //關(guān)閉讀端
        close(pipefd[0]);
        //將當(dāng)前channel信息添加到channels進(jìn)行組織
        std::string name = "process-" + std::to_string(i);
        channels->push_back(channel(pipefd[1],id,name));
        //添加這個(gè)寫(xiě)端的文件描述符，方便后面的進(jìn)程關(guān)閉它
        oldfds.push_back(pipefd[1]);
        sleep(1);
    }
}

//打印一個(gè)選擇任務(wù)的菜單
void Menu()
{
    std::cout << "################################################" << std::endl;
    std::cout << "# 1. 任務(wù)一             2. 任務(wù)二               #" << std::endl;
    std::cout << "# 3. 任務(wù)三             4. 任務(wù)四               #" << std::endl;
    std::cout << "#                   0. 退出                     #" << std::endl;
    std::cout << "#################################################" << std::endl;
}

void StartProcessPool(std::vector<channel>* channels)
{
    while(true)
    {	
        int select = 0;
        Menu();
        sleep(1);
        //輸入選項(xiàng)
        std::cout << "Please Enter>> ";
        std::cin >> select;

        if(select <= 0 || select >= 5) break;
		//將控制碼也就是選擇的數(shù)字select1234轉(zhuǎn)化為0123，因?yàn)関ector下標(biāo)從0開(kāi)始，所以要-1
        int cmdcode = select - 1;
		//通過(guò)管道寫(xiě)入信息，等待slaver()讀取
        write(channels[select]._cmdfd, &cmdcode, sizeof(cmdcode));
        sleep(1);
    }
}

void CleanProcessPool(std::vector<channel> &channels)
{
    //每個(gè)channel對(duì)象的左邊為父進(jìn)程的fd，右邊為子進(jìn)程fd，斷開(kāi)父進(jìn)程fd，然后進(jìn)程等待
    //父進(jìn)程斷開(kāi)后子進(jìn)程會(huì)在管道中讀到0，即文件結(jié)束，然后子進(jìn)程就會(huì)終止
    //然后被父進(jìn)程回收
    for(const auto &c : channels){
        close(c._cmdfd);
        waitpid(c._slaverid, nullptr, 0);
    }
}