blob: c75f43e3f0ff721f56ab378fbf540258e12d787b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
#include <vector>
#include <string>
#include <filesystem>
#include <iostream>
#include <utility>
#include <list>
#include <chrono>
#include <thread>
#include <memory>
#include "libcppbuild.h"
#include "task_cc.h"
#include "task_ld.h"
#include "settings.h"
#include <unistd.h>
using namespace std::chrono_literals;
int main(int argc, const char* argv[])
{
Settings settings;
// TODO: Set from commandline
settings.builddir = "build/foo";
settings.parallel_processes =
std::max(1u, std::thread::hardware_concurrency() * 2 - 1);
std::filesystem::path builddir(settings.builddir);
std::filesystem::create_directories(builddir);
auto config = configs();
std::vector<std::string> objects;
std::vector<std::unique_ptr<Task>> tasks;
for(const auto& file : config.sources)
{
tasks.emplace_back(std::make_unique<TaskCC>(config, settings, file));
objects.push_back(tasks.back()->target());
}
TaskLD task_ld(config, settings, config.target, objects);
if(argc == 2 && std::string(argv[1]) == "clean")
{
std::cout << "Cleaning\n";
//std::filesystem::remove_all(builddir);
for(auto& task : tasks)
{
if(task->clean() != 0)
{
return 1;
}
}
if(task_ld.clean() != 0)
{
return 1;
}
return 0;
}
std::cout << "Building\n";
std::list<std::future<int>> processes;
// Start all tasks
auto task = tasks.begin();
while(task != tasks.end())
{
while(processes.size() < settings.parallel_processes &&
task != tasks.end())
{
if(!(*task)->dirty())
{
++task;
continue;
}
processes.emplace_back(
std::async(std::launch::async,
[&t = *task]()
{
return t->run();
}));
++task;
std::this_thread::sleep_for(2ms);
}
for(auto process = processes.begin();
process != processes.end();
++process)
{
if(process->valid())
{
if(process->get() != 0)
{
return 1;
}
processes.erase(process);
break;
}
}
std::this_thread::sleep_for(2ms);
}
for(auto process = processes.begin();
process != processes.end();
++process)
{
process->wait();
auto ret = process->get();
if(ret != 0)
{
return 1;
}
}
std::cout << "Linking\n";
if(task_ld.dirty())
{
return task_ld.run();
}
return 0;
}
|
