assert(stream_index >= 0 && stream_index < ssize_t(streams.size()));
streams[stream_index]->set_header(http_header, stream_header);
}
+
+void Server::set_unavailable(int stream_index)
+{
+ lock_guard<mutex> lock(mu);
+ assert(stream_index >= 0 && stream_index < ssize_t(streams.size()));
+ streams[stream_index]->set_unavailable();
+}
void Server::set_pacing_rate(int stream_index, uint32_t pacing_rate)
{
}
if (client->stream_pos_end == Client::STREAM_POS_NO_END) {
- if (stream->http_header.empty()) {
+ if (stream->unavailable) {
return 503; // Service unavailable.
}