Требуется мнение по коду

#include <sys/stat.h>
#include <sys/types.h>
#include <fstream>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <unistd.h>
#include <iostream>
#include <string.h>
#include <string>
#include <signal.h>
#include <sys/wait.h>
#include <ncursesw/ncurses.h>
#include <ncursesw/panel.h>
#include <fcntl.h>
 
#define FIFO_NAME "/tmp/.fifofile" 
 
using namespace std;
 
long long *get_mfile_size(const char *addr); //Получить размер файла
bool read_data(string message); //Читать из FIFO
void write_data(string message); //Писать в FIFO
void get_interface(); //Вывод человеко-ориенированного интерфейса данных
 
int main() {
    unlink(FIFO_NAME); //Удаляем на всякий случай FIFO файл
    pid_t pid[4]; //3 точки разделения
    if ((pid[0] = fork()) < 0) {//Порождаем первый процесс для exec
        perror("fork");
        exit(EXIT_FAILURE);
    }
    if (pid[0] == 0) {
        signal(SIGCHLD, SIG_IGN); //Пусть ядро само разбирается с зомби.
        execl("/bin/tar", " ", "-c", "-j", "-f", "/home/andrew/Загрузки/Kernel.tar.bz2", "/home/andrew/Загрузки/Kernel.mp4", NULL);
        exit(EXIT_FAILURE); //Если все хорошо, сюда реализация не заглянет
    } else { //Ветка родителей
        if ((pid[1] = fork()) < 0) {//Второй процесс для интерфейса
            perror("fork");
            exit(EXIT_FAILURE);
        }
        if (pid[1] == 0) {//Второй дочерний
            get_interface(); // Вызываем интерфейс и пусть он нас радует...
            exit(0);
        } else {//Parent
            if ((pid[2] = fork()) < 0) {//третий процесс для принудительной остановки интерфейса
                perror("fork");
                exit(EXIT_FAILURE);
            }
            if (pid[2] == 0) {
                char ch;
                do {
                    cin >> ch;
                } while (ch != 'q');
                write_data("off"); //пишем в FIFO магию
                sleep(2); //Время на отработку функцией чтения. Костыль в общем...
                exit(0);
            } else {//Родитель
                while (1) {
                    if (waitpid(pid[0], &pid[3], WNOHANG) < 0) break; //Если первый процесс закончился
                    if (read_data("off")) break;
                }
                if (!(read_data("off"))) write_data("off"); //Помирает своей смертью...
                sleep(2);
                unlink(FIFO_NAME);
                exit(0);
                return (EXIT_SUCCESS);
            }
        }
    }
}

long long *get_mfile_size(const char *addr) {//Рассчитываем размер файла
    long long _result;
    long long *result = &_result;
    ifstream file(addr, ios_base::in | ios_base::ate);
    if (file.is_open()) {
        _result = file.tellg();
        file.close();
    }
    return result;
}

bool read_data(string message) {//Читаем из FIFO
    bool result = false;
    string temp;
    ifstream in(FIFO_NAME, ios_base::in);
    if (in.is_open()) {
        int count = 0;
        char *buff = new char[255];
        memset(buff, '\n', 255);
        in.getline(buff, 255, '\n'); //Читаем строку
        count = in.gcount();
        for (int i = 0; i < (count - 1); i++) {
            temp.append(1, buff[i]);
        }
        if (message == temp) result = true;
        in.close();
        delete buff;
    }
    return result;
}

void write_data(string message) {//Пишем в FIFO
    ofstream out(FIFO_NAME, ios_base::out);
    mkfifo(FIFO_NAME, 0600);
    if (out.is_open()) {
        out << message << endl;
        out.close();
    }
}

void get_interface() {
    system("clear");
    int y = 0;
    int x = 0;
    setlocale(LC_ALL, "");
    initscr();
    cbreak();
    raw();
    nonl();
    noecho();
    curs_set(0);
    start_color();
    use_default_colors();
    init_pair(1, COLOR_RED, COLOR_YELLOW);
    init_pair(2, COLOR_GREEN, COLOR_YELLOW);
    init_pair(3, COLOR_BLACK, COLOR_YELLOW);
    getmaxyx(stdscr, y, x);
    WINDOW *Wnd = newwin(6, 30, (y - (y / 2)) - 3, (x - (x / 2)) - 15); //Подложка
    PANEL *Pnl = new_panel(Wnd);
    wbkgd(Wnd, COLOR_PAIR(3));
    wborder(Wnd, ACS_VLINE, ACS_VLINE, ACS_HLINE, ACS_HLINE, ACS_ULCORNER,
            ACS_URCORNER, ACS_LLCORNER, ACS_LRCORNER);
    mvwprintw(Wnd, 1, 1, "%s", "Текущий размер файла (БАЙТ)");
    mvwprintw(Wnd, 3, 1, "%s", "Текущий размер архива (БАЙТ)");
    while (1) {
        if (read_data("off")) break;
        wattron(Wnd, COLOR_PAIR(1) | A_BOLD);
        mvwprintw(Wnd, 2, 1, "%lld", (*get_mfile_size("/home/andrew/Загрузки/Kernel.mp4")));
        wattroff(Wnd, COLOR_PAIR(1));
        wattron(Wnd, COLOR_PAIR(2) | A_BOLD);
        mvwprintw(Wnd, 4, 1, "%lld", (*get_mfile_size("/home/andrew/Загрузки/Kernel.tar.bz2")));
        wattroff(Wnd, COLOR_PAIR(2));
        update_panels();
        doupdate();
    }
    if (read_data("off"))mvwprintw(Wnd, 4, 1, "%s", "ЗАВЕРШЕНО       ");
    update_panels();
    doupdate();
    del_panel(Pnl);
    delwin(Wnd);
    endwin();
}

#include <ncursesw/ncurses.h>
#include <ncursesw/panel.h>
#include <mysql_connection.h>
#include <string.h>
#include <sstream>
#include <fstream>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <signal.h>
#include <sys/wait.h>
#include <fcntl.h>
#include <errno.h>
#include "sql_tablework.h"
#include "sql_connector.h"
#include "logtime.h"
 
#define FIFO_FILE1 "/tmp/.idfifo1"
#define FIFO_FILE2 "/tmp/.idfifo2"
#define FIFO_FILE3 "/tmp/.idfifo3"
#define BUFF_SIZE 64
 
using namespace std;
using namespace sql;
 
sql_tablework::sql_tablework(const char *conffile) {//конструктор класса 
    unlink(FIFO_FILE1);
    unlink(FIFO_FILE2);
    unlink(FIFO_FILE3);
    sql_connector *conn = new sql_connector(conffile);
    logtime *cDate = new logtime();
    this->sqlconffile = conffile;
    this->address = conn->getFolder().c_str();
    this->user = conn->getUser().c_str();
    this->password = conn->getPassword().c_str();
    this->con = conn->db_ident();
    this->dbasedump = conn->getDbdump();
    this->currtime = cDate->getFname(); //Фиксируем время
    delete conn;
    delete cDate;
}
 
string sql_tablework::int_to_string(int in) {//Преобразую целочисленный тип к string. Внутренняя реализация.
    stringstream output;
    output << in;
    if (in < 10 && in >= 0) {
        string out = "0" + output.str();
        return out;
    } else {
        return output.str();
    }
    return "0";
}
 
void sql_tablework::dbdump() {//Тут дамп нужной мне таблицы БД
    this->out_error = 0;
    ofstream logs("/var/log/sqservice/sqsrv.log", ios::app);
    if (logs.is_open()) {
        Statement *stmt = NULL;
        logtime *cDate = new logtime();
        sql_connector *conn = new sql_connector(this->sqlconffile);
        this->con = conn->db_ident();
         //Запрос отключен в тестовом режиме.
        //string query = "SELECT * INTO OUTFILE '" + this->dbasedump + this->currtime + ".csv' FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '"' LINES TERMINATED BY '\n' FROM sq_traffic";
        if (this->con->isValid()) {//Если соединение существует
            try {
                stmt = this->con->createStatement();
                stmt->execute(query);
            } catch (SQLException &e) {//Обрабатываем исключение
                this->out_error = 4;
                logs << cDate->getTime() + " #ОШБ(dbdump()): " << e.what() << endl;
                logs << cDate->getTime() + " (MySQL Код ошибки: " << e.getErrorCode();
                logs << ", SQLСтатус: " << e.getSQLState() << " )" << endl;
            }
            delete stmt;
        }
        logs << cDate->getTime() + " #ИНФ: Дамп таблицы завершен." << endl;
        delete cDate;
        delete conn;
        logs.close();
    } else this->out_error = 2;
}
 
const char *sql_tablework::get_mfile_size(const char* addr) {//Получаю текущий размер файла в нужном мне формате
    int tmp = 0;
    string out = "0б";
    long long _result = 0;
    ifstream file(addr, ios_base::in | ios_base::ate);
    if (file.is_open()) {
        file.seekg(0,file.end);
        _result = file.tellg();
        file.seekg(0,file.beg);
        if (_result > 1024 && _result < 1024000) {
            tmp = _result / 1024;
            out = this->int_to_string(tmp) + "кб ";
        } else if (_result > 1024000 && _result < 1024000000) {
            tmp = _result / 1024000;
            out = this->int_to_string(tmp) + "Мб ";
        } else if (_result > 1024000000) {
            tmp = _result / 1024000000;
            out = this->int_to_string(tmp) + "Гб ";
        } else {
            out = "0б";
        }
        file.close();
    }
    return out.c_str();
}
 
string sql_tablework::read_data(const char* f_name) {//Читаем из канала
    string result = "";
    int i = 0;
    int fd;
    char buff[BUFF_SIZE];
    memset(buff, '\0', (BUFF_SIZE - 1));
    if ((fd = open(f_name, O_RDONLY)) >= 0) {
        if (read(fd, &buff, BUFF_SIZE) >= 0) {
            while (buff[i] != '\0') {
                result.append(1, buff[i]);
                i++;
            }
        } else {
            ofstream logs("/var/log/sqservice/sqsrv.log", ios::app); //Хранение логов
            if (logs.is_open()) {
                logtime *cDate = new logtime();
                logs << cDate->getTime() + " #ОШБ(read_data()): Ошибка чтения канала:" << f_name << " " << " Ошибка(read()): " << errno << endl;
                logs.close();
                delete cDate;
            }
        }
        close(fd);
    } else {
        ofstream logs("/var/log/sqservice/sqsrv.log", ios::app); //Хранение логов
        if (logs.is_open()) {
            logtime *cDate = new logtime();
            logs << cDate->getTime() + " #ОШБ(read_data()): Невозможно открыть канал " + *f_name + " для чтения" << " Ошибка(open()): " << errno << endl;
            logs.close();
            delete cDate;
        }
    }
    return result;
}
 
void sql_tablework::write_data(const char* f_name, const char* message) {//Пишем в канал
    int fd;
    if ((fd = open(f_name, O_WRONLY)) >= 0) {
        if (write(fd, message, BUFF_SIZE) > 0) {
            fsync(fd); //На всякий случай.Write не гарантирует запись.
        } else {
            if (errno != EPIPE) {
                ofstream logs("/var/log/sqservice/sqsrv.log", ios::app); //Хранение логов
                if (logs.is_open()) {
                    logtime *cDate = new logtime();
                    logs << cDate->getTime() + " #ОШБ(write_data()): Ошибка записи в канал:" << f_name << " Ошибка(write()): " << errno << endl;
                    logs.close();
                    delete cDate;
                }
            }
        }
        close(fd);
    } else {
        ofstream logs("/var/log/sqservice/sqsrv.log", ios::app); //Хранение логов
        if (logs.is_open()) {
            logtime *cDate = new logtime();
            logs << cDate->getTime() + " #ОШБ(write_data()): Невозможно открыть канал: " + *f_name + " для записи" << " Ошибка(write()): " << errno << endl;
            logs.close();
            delete cDate;
        }
    }
}
 
void sql_tablework::arch_table() {//Основной функционал
    this->out_error = 0;
    ofstream logs("/var/log/sqservice/sqsrv.log", ios::app); //Хранение логов
    if (logs.is_open()) {
        int status;
        pid_t forkid[3];
        logtime *cDate = new logtime();
        if (((mkfifo(FIFO_FILE1, 0777)) != 0) || ((mkfifo(FIFO_FILE2, 0777)) != 0) || ((mkfifo(FIFO_FILE3, 0777)) != 0)) {
            logs << cDate->getTime() + " #ОШБ(arch_table()): Ошибка создания каналов межпроцессной связи" << endl;
            exit(EXIT_FAILURE);
        }
        if ((forkid[0] = fork()) < 0) {
            logs << cDate->getTime() + " #ОШБ(arch_table()): Ошибка создания процесса архивации" << endl;
            exit(EXIT_FAILURE);
        }
        if (forkid[0] == 0) {//Первый процесс архивация
            this->dbdump();
            string inFile = this->dbasedump + this->currtime + ".csv";
            string outFile = this->dbasedump + this->currtime + ".csv.bz2";
            logs << cDate->getTime() + " #ИНФ: Запущен процесс архивации" << endl;
            execl("/usr/local/bin/sql_arch.sh", " ", outFile.c_str(), inFile.c_str(), NULL);
            //execl("/bin/tar", " ", "-c", "-j", "-f", "/home/andrew/Загрузки/tst.iso.tar.bz2", "/home/andrew/Загрузки/tst.iso", NULL);
            exit(EXIT_FAILURE); //Если все хорошо, сюда реализация не заглянет
        } else if (forkid[0] > 0) {//Второй процесс
            if ((forkid[1] = fork()) < 0) {
                logs << cDate->getTime() + " #ОШБ(arch_table()): Ошибка создания процесса ручной отмены операции" << endl;
                exit(EXIT_FAILURE);
            }
            if (forkid[1] == 0) {
                char ch;
                nodelay(stdscr, TRUE); //Переводим getch в неблокирующий режим
                while (1) {
                    write_data(FIFO_FILE2, "rdy");
                    ch = getch();
                    if ((ch == 'q') || (ch == 'Q')) break;
                }
                sleep(1);//Надо дать возможность считать данные иначе блокировка записи не позволит исполниться коду дальше
                write_data(FIFO_FILE2, "off");//Корректно завершаем работу модуля
                nodelay(stdscr, FALSE);
                exit(0);
            } else if (forkid[1] > 0) {
                if ((forkid[2] = fork()) < 0) {
                    logs << cDate->getTime() + " #ОШБ(arch_table()): Ошибка создания процесса интерфейса" << endl;
                    exit(EXIT_FAILURE);
                }
                if (forkid[2] == 0) {//Третий процесс визуализация
                    string inFile = this->dbasedump + this->currtime + ".csv";
                    string outFile = this->dbasedump + this->currtime + ".csv.bz2";
                    string title = ("Псевдографическая утилита для конфигурирования прокси-сервера SQUID");
                    string bkgName = "Архивирование таблицы БД";
                    string f_message = "Текущий размер файла: " + this->currtime + ".csv";
                    string s_message = "Текущий размер файла: " + this->currtime + ".csv.bz2";
                    int y = 0;
                    int x = 0;
                    noecho();
                    curs_set(0);
                    init_pair(1, COLOR_BLUE, COLOR_YELLOW);
                    init_pair(2, COLOR_GREEN, COLOR_YELLOW);
                    init_pair(3, COLOR_BLACK, COLOR_YELLOW);
                    init_pair(4, COLOR_WHITE, COLOR_BLUE);
                    init_pair(5, COLOR_GREEN, COLOR_BLACK);
                    getmaxyx(stdscr, y, x);
                    int height = y - 3; //Насколько окно меньше терминала
                    int width = x - 6;
                    int ycurr = (LINES - height) / 2; //Теперь это насколько  делим дабы поставить окно посередине
                    int xcurr = (COLS - width) / 2;
                    int c = (width / 2) - (bkgName.length() / 3); //Центр экрана для заглолвка    
                    attron(COLOR_PAIR(5));
                    mvwprintw(stdscr, 0, xcurr, "%s", title.c_str());
                    attroff(COLOR_PAIR(5));
                    WINDOW *Frnt = newwin(height, width, ycurr + 1, xcurr); //Подложка
                    WINDOW *Wnd = newwin(6, 46, (y - (y / 2)) - 3, (x - (x / 2)) - 23); //Рабочее окно
                    WINDOW *Shad = newwin(6, 46, (y - (y / 2)) - 2, (x - (x / 2)) - 22); //Рабочее окно
                    PANEL *PnlW = new_panel(Wnd);
                    PANEL *PnlF = new_panel(Frnt);
                    PANEL *PnlS = new_panel(Shad);
                    wbkgd(Frnt, COLOR_PAIR(4));
                    wbkgd(Shad, COLOR_BLACK);
                    wbkgd(Wnd, COLOR_PAIR(3));
                    wborder(Frnt, ACS_VLINE, ACS_VLINE, ACS_HLINE, ACS_HLINE, ACS_ULCORNER,
                            ACS_URCORNER, ACS_LLCORNER, ACS_LRCORNER);
                    attron(COLOR_PAIR(5));
                    mvwprintw(Frnt, 0, c, "%s", bkgName.c_str());
                    attroff(COLOR_PAIR(5));
                    wborder(Wnd, ACS_VLINE, ACS_VLINE, ACS_HLINE, ACS_HLINE, ACS_ULCORNER,
                            ACS_URCORNER, ACS_LLCORNER, ACS_LRCORNER);
                    mvwprintw(Frnt, height - 2, 3, "ОТМЕНА/НАЗАД В МЕНЮ(q или Q)");
                    mvwprintw(Wnd, 1, 1, "%s", f_message.c_str());
                    mvwprintw(Wnd, 3, 1, "%s", s_message.c_str());
                    top_panel(PnlW);
                    while (1) {
                        if (read_data(FIFO_FILE1) == "off") break;
                        mvwprintw(Wnd, 0, 1, "%s", read_data(FIFO_FILE3).c_str());
                        wattron(Wnd, COLOR_PAIR(1) | A_BOLD);
                        mvwprintw(Wnd, 2, 1, "%s", get_mfile_size(inFile.c_str()));
                        wattroff(Wnd, COLOR_PAIR(1));
                        wattron(Wnd, COLOR_PAIR(2) | A_BOLD);
                        mvwprintw(Wnd, 4, 1, "%s", get_mfile_size(outFile.c_str()));
                        wattroff(Wnd, COLOR_PAIR(2));
                        update_panels();
                        doupdate();
                    }
                    mvwprintw(Wnd, 2, 1, "%s", "ВОЗВРАТ В МЕНЮ     ");
                    update_panels();
                    doupdate();
                    del_panel(PnlW);
                    del_panel(PnlF);
                    del_panel(PnlS);
                    delwin(Frnt);
                    delwin(Shad);
                    delwin(Wnd);
                    exit(0);
                } else if (forkid[2] > 0) { //Родитель третьего процесса
                    while (read_data(FIFO_FILE2) != "off") {
                        write_data(FIFO_FILE1, "rdy"); //Постоянно шлем сигнал готовности иначе циклы будут заблокированы
                        if (waitpid(forkid[0], &status, WNOHANG) == -1) {//Неблокирующий режим контроля детей.
                            write_data(FIFO_FILE3, "Завершено ");
                        } else {
                            write_data(FIFO_FILE3, "Обработка");
                        }
                    }
                    write_data(FIFO_FILE1, "off");
                    kill(forkid[0], SIGKILL); //Прибиваем на всякий случай
                    kill(forkid[1], SIGKILL);
                    nodelay(stdscr, FALSE);
                    sleep(1);
                    waitpid(forkid[2], &status, WNOHANG);
                }
                waitpid(forkid[1], &status, WNOHANG);
            }
            waitpid(forkid[0], &status, WNOHANG);
        }
        unlink(FIFO_FILE1);//программа завершается разлинковываем каналы
        unlink(FIFO_FILE2);
        unlink(FIFO_FILE3);
        delete cDate;
        logs.close();
    } else this->out_error = 2; //  Проблемы открытия лог файла  
}
 
sql_tablework::~sql_tablework() {
}

char buff[BUFF_SIZE] = {0};

string sql_tablework::get_mfile_size(const char* addr) {
    int tmp = 0;
    string out = "0б";
    long long _result = 0;
    ifstream file(addr, ios_base::in | ios_base::ate);
    if (file.is_open()) {
        file.seekg(0,file.end);
        _result = file.tellg();
        file.seekg(0,file.beg);
        if (_result > 1024 && _result < 1024000) {
            tmp = _result / 1024;
            out = this->int_to_string(tmp) + "кб ";
        } else if (_result > 1024000 && _result < 1024000000) {
            tmp = _result / 1024000;
            out = this->int_to_string(tmp) + "Мб ";
        } else if (_result > 1024000000) {
            tmp = _result / 1024000000;
            out = this->int_to_string(tmp) + "Гб ";
        } else {
            out = "0б";
        }
        file.close();
    }
    return out;
}

char buff[BUFF_SIZE]={'\0'};