X-Git-Url: https://git.sesse.net/?p=cubemap;a=blobdiff_plain;f=stream.cpp;h=d7a78a602098ab5d77dda08873af8c3d7b29e11b;hp=734110c9f47e79ee18586dff5afaabb0f1b311c3;hb=f0621e41fdb96ce1bd58e7561e0aa76345072ba3;hpb=3b73724f08274a2c5a435d6a834bc10fcf3db41b diff --git a/stream.cpp b/stream.cpp index 734110c..d7a78a6 100644 --- a/stream.cpp +++ b/stream.cpp @@ -26,15 +26,13 @@ Stream::Stream(const string &url, size_t backlog_size, size_t prebuffering_bytes src_encoding(src_encoding), data_fd(make_tempfile("")), backlog_size(backlog_size), - prebuffering_bytes(prebuffering_bytes), - bytes_received(0), - pacing_rate(~0U) + prebuffering_bytes(prebuffering_bytes) { if (data_fd == -1) { exit(1); } - pthread_mutex_init(&queued_data_mutex, NULL); + pthread_mutex_init(&queued_data_mutex, nullptr); } Stream::~Stream() @@ -52,8 +50,7 @@ Stream::Stream(const StreamProto &serialized, int data_fd) data_fd(data_fd), backlog_size(serialized.backlog_size()), prebuffering_bytes(serialized.prebuffering_bytes()), - bytes_received(serialized.bytes_received()), - pacing_rate(~0U) + bytes_received(serialized.bytes_received()) { if (data_fd == -1) { exit(1); @@ -69,7 +66,7 @@ Stream::Stream(const StreamProto &serialized, int data_fd) suitable_starting_points.push_back(point); } - pthread_mutex_init(&queued_data_mutex, NULL); + pthread_mutex_init(&queued_data_mutex, nullptr); } StreamProto Stream::serialize()