Trianta/proxy-network
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Push to master for current working build #2

Merged
Trianta merged 8 commits from dev into master 2023-10-03 22:05:27 -05:00
Conversation 0 Commits 8 Files Changed 5 +5 -4
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit f8f03bb5ee - Show all commits

9
src/proxy.cpp
View File

@ -18,8 +18,6 @@ int main(void)
Client browser; Client browser;
Client webserver; Client webserver;
proxy.Open();
// Main loop to listen, accept, and then spin-off a thread to handle the GET // Main loop to listen, accept, and then spin-off a thread to handle the GET
while (1) while (1)
{ {
@ -33,8 +31,11 @@ int main(void)
std::cerr << "ERROR - Unable to connect to webserver" << std::endl; std::cerr << "ERROR - Unable to connect to webserver" << std::endl;
continue; continue;
} }
auto newThreadRequest = std::async(std::launch::async, HandleClient, browser.socketFD, webserver.socketFD); auto newThreadRequest1 = std::async(std::launch::async, PipeSockets, browser.socketFD, webserver.socketFD);
pending_futures.push_back(std::move(newThreadRequest)); auto newThreadRequest2 = std::async(std::launch::async, ProxySockets, webserver.socketFD, browser.socketFD);
pending_futures.push_back(std::move(newThreadRequest1));
pending_futures.push_back(std::move(newThreadRequest2));
std::cout << "Returned from creating threads, continuing..." << std::endl;
} }
proxy.Close(); proxy.Close();
return 0; return 0;