63 lines
1.2 KiB
C++
63 lines
1.2 KiB
C++
#include "App.h"
|
|
|
|
/* This is not an example; it is a smoke test used in CI testing */
|
|
|
|
struct Stream {
|
|
int offset;
|
|
bool aborted;
|
|
};
|
|
|
|
std::string constantChunk;
|
|
|
|
void streamData(auto *res, auto stream, int chunk) {
|
|
|
|
if (stream->aborted) {
|
|
return;
|
|
}
|
|
|
|
if (chunk < 1600) {
|
|
res->cork([res, stream, chunk]() {
|
|
auto ok = res->write(constantChunk);
|
|
if (ok) {
|
|
streamData(res, stream, chunk + 1);
|
|
return;
|
|
}
|
|
|
|
uWS::Loop::get()->defer([res, stream, chunk]() {
|
|
streamData(res, stream, chunk + 1);
|
|
});
|
|
});
|
|
} else {
|
|
res->cork([res]() {
|
|
res->end();
|
|
});
|
|
}
|
|
}
|
|
|
|
int main() {
|
|
|
|
for (int i = 0; i < 65536; i++) {
|
|
constantChunk.append("a", 1);
|
|
}
|
|
|
|
uWS::SSLApp({
|
|
.key_file_name = "misc/key.pem",
|
|
.cert_file_name = "misc/cert.pem",
|
|
.passphrase = "1234"
|
|
}).get("/*", [](auto *res, auto */*req*/) {
|
|
|
|
auto stream = std::make_shared<Stream>(0, false);
|
|
streamData(res, stream, 0);
|
|
|
|
res->onAborted([stream]() {
|
|
stream->aborted = true;
|
|
});
|
|
}).listen(3000, [](auto *listen_socket) {
|
|
if (listen_socket) {
|
|
std::cout << "Listening on port " << 3000 << std::endl;
|
|
}
|
|
}).run();
|
|
|
|
std::cout << "Failed to listen on port 3000" << std::endl;
|
|
}
|