カテゴリー: C++

void backHitCB(Fl_Widget*, void*){
    // 初期化
    jsonInput -> value("");

    Fl_Text_Buffer* bufferReset = new Fl_Text_Buffer();
    bufferReset -> text("");
    output->buffer(bufferReset);
    jsonDisplay->buffer(bufferReset);
    codeDisplay->buffer(bufferReset);
    noticeDisplay->buffer(bufferReset);

    window -> redraw();

    currentHit--;

    if (currentHit < 0){
        currentHit = pathsNum - 1;
        pathsNumStr = to_string(pathsNum) + " / " + to_string(pathsNum);
    } else {
        pathsNumStr = to_string(currentHit + 1) + " / " + to_string(pathsNum);
    }

    hitShow -> value(pathsNumStr.c_str());

    jsonInput -> value(paths[currentHit].c_str());
    loadBtn -> do_callback();
}

void searchCB(Fl_Widget*, void*){
    // 初期化
    hitShow -> value();
    window -> redraw();

    const char* grepStr = grepInput -> value();
    cout << "grepStr: " << grepStr << endl;

    stringstream iss(grepStr);
    vector<string> words;
    string word;
    while (getline(iss, word, ' ')) {
        words.push_back(word);
    }
    for (const auto& w : words) {
        cout << "word: " << w << endl;
    }

    string dirPath = "/ChatGPT";
    vector<string> paths = grepFiles(words, dirPath);
    for (const auto& p : paths) {
        cout << "path: " << p << endl;
    }

    int pathsNum = paths.size();
    cout << "HITファイル数: " << pathsNum << endl;

    string pathsNumStr;
    if (pathsNum < 10){
        pathsNumStr = to_string(pathsNum) + " / " + to_string(pathsNum);
    } else {
        pathsNumStr = to_string(pathsNum);
    }

    hitShow -> value(pathsNumStr.c_str());
}

vector<string> grepFiles(const vector<string>& words, const string& path) {
    vector<string> result;
    DIR* dir = opendir(path.c_str());

    if (!dir) {
        cerr << "Error: opendir() failed." << endl;
        return result;
    }

    struct dirent* entry;
    while ((entry = readdir(dir)) != nullptr) {
        if (entry->d_type == DT_REG) { // regular file
            string filePath = path + "/" + entry->d_name;
            string command = "grep -l ";

            int count = 0;
            for (const auto& word : words) {
                if (count == 0){
                    command += word + " \"" + filePath + "\"";
                } else {
                    command += "| grep " + word;
                }
                count++;
            }

            // cout << "command:\n" << command << endl;
            
            FILE* pipe = popen(command.c_str(), "r");
            if (!pipe) {
                cerr << "Error: popen() failed." << endl;
                continue;
            }
            char buffer[256];
            if (fgets(buffer, sizeof(buffer), pipe) != nullptr) {
                result.emplace_back(filePath);
            }
            pclose(pipe);
        }
    }
    closedir(dir);
    return result;
}

void processA() {
    std::cout << "ProcessA: PID = " << getpid() << std::endl;
    sendCB_A();
}

void processB() {
    std::cout << "ProcessB: PID = " << getpid() << std::endl;
    timerCallback(nullptr);
}

void sendCB(Fl_Widget*, void*) {
    sendBool = true;

    pid_t pidA, pidB;

    pidA = fork();
    if (pidA == 0) { // 子プロセスA
        processA();
        return;
    }
    else if (pidA > 0) { // 親プロセス
        std::cout << "Parent process: PID = " << getpid() << std::endl;

        pidB = fork();
        if (pidB == 0) { // 子プロセスB
            processB();
            return;
        }
        else if (pidB > 0) { // 親プロセス
            waitpid(pidA, NULL, 0);
            waitpid(pidB, NULL, 0);
        }
        else { // forkに失敗した場合
            std::cerr << "fork() failed." << std::endl;
            return;
        }
    }
    else { // forkに失敗した場合
        std::cerr << "fork() failed." << std::endl;
        return;
    }
}

Parent process: PID = 62590
ProcessA: PID = 62601
question1回目
ChatGPTとは
requestData: {"model":"gpt-3.5-turbo", "messages":[{"role":"system","content":""},{"role":"user","content":"ChatGPTとは"}], "temperature":0.0}
ProcessB: PID = 62602
The process has forked and you cannot use this CoreFoundation functionality safely. You MUST exec().
Break on __THE_PROCESS_HAS_FORKED_AND_YOU_CANNOT_USE_THIS_COREFOUNDATION_FUNCTIONALITY___YOU_MUST_EXEC__() to debug.
The process has forked and you cannot use this CoreFoundation functionality safely. You MUST exec().
Break on __THE_PROCESS_HAS_FORKED_AND_YOU_CANNOT_USE_THIS_COREFOUNDATION_FUNCTIONALITY___YOU_MUST_EXEC__() to debug.
The process has forked and you cannot use this CoreFoundation functionality safely. You MUST exec().

void sendCB(Fl_Widget*, void*) {
    sendBool = true;

    std::thread sendMain([](){
        sendCB_A();
    });

    std::thread stopwatch([](){
        timerCallback(nullptr);
    });

    sendMain.join();
    stopwatch.join();

}

#include "taskflow/taskflow.hpp"

void sendCB_A(){
    (送受信に関するコード)
}

void sendCB_B(){
    // ストップウォッチ開始
    resetBtn -> do_callback();
    startBtn -> do_callback();

    sendBool = true; // timerCallback関数を停止させるため
}

void sendCB_C(){
    // ストップウォッチ停止
    stopBtn -> do_callback();
}

void sendCB_D(){
    timerCallback(nullptr);
}


void sendCB(Fl_Widget*, void*) {
    tf::Executor executor;
    tf::Taskflow taskflow;

    auto [A, B, C, D] = taskflow.emplace(
        [] () { sendCB_A(); },
        [] () { sendCB_B(); },
        [] () { sendCB_C(); },
        [] () { sendCB_D(); }
    );

    A.succeed(B); // ストップウォッチ開始後、送受信開始
    D.succeed(B); // ストップウォッチ開始後、timerCallback関数開始
    C.succeed(A); // 送受信終了後、ストップウォッチ停止
 
    executor.run(taskflow).wait();
}

int main(int argc, char **argv) {

   	＜中略＞

   	window->end();  
   	window->show(argc, argv);

    Fl::add_timeout(0.01, timerCallback);

   	return Fl::run();
}

void timerCallback(void*) {
    // 経過時間を取得して、Fl_Outputに表示する
    double elapsedTime = stopwatch.elapsedTime();
    stringstream ss;
    // ss << std::fixed << elapsedTime;
    ss << std::fixed << std::setprecision(1) << elapsedTime;
    // cout << "経過時間: " << ss.str() << endl;
    timeShow->value(ss.str().c_str());

    window -> redraw();

    // タイマーを再起動する
    Fl::repeat_timeout(0.01, timerCallback);
}

void sendCB2(Fl_Widget*, void*) {
    // ストップウォッチ開始
    resetBtn -> do_callback();
    startBtn -> do_callback();
}