[rygel] core: Rename HTTPGstSink.buffered to chunks_buffered
- From: Zeeshan Ali Khattak <zeeshanak src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [rygel] core: Rename HTTPGstSink.buffered to chunks_buffered
- Date: Fri, 1 Apr 2011 15:57:54 +0000 (UTC)
commit 5040cd0018e4fd34fc909dc5b7674a5f0e45a3d5
Author: Zeeshan Ali (Khattak) <zeeshanak gnome org>
Date: Fri Apr 1 16:49:44 2011 +0300
core: Rename HTTPGstSink.buffered to chunks_buffered
src/rygel/rygel-http-gst-sink.vala | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
---
diff --git a/src/rygel/rygel-http-gst-sink.vala b/src/rygel/rygel-http-gst-sink.vala
index ae742e9..d275aec 100644
--- a/src/rygel/rygel-http-gst-sink.vala
+++ b/src/rygel/rygel-http-gst-sink.vala
@@ -35,7 +35,7 @@ internal class Rygel.HTTPGstSink : BaseSink {
private unowned HTTPGstResponse response;
private int priority;
- private int64 buffered;
+ private int64 chunks_buffered;
private Mutex buffer_mutex;
private Cond buffer_condition;
@@ -50,7 +50,7 @@ internal class Rygel.HTTPGstSink : BaseSink {
}
public HTTPGstSink (HTTPGstResponse response) {
- this.buffered = 0;
+ this.chunks_buffered = 0;
this.buffer_mutex = new Mutex ();
this.buffer_condition = new Cond ();
@@ -76,7 +76,7 @@ internal class Rygel.HTTPGstSink : BaseSink {
public override FlowReturn render (Buffer buffer) {
this.buffer_mutex.lock ();
while (!this.cancellable.is_cancelled () &&
- this.buffered > MAX_BUFFERED_CHUNKS) {
+ this.chunks_buffered > MAX_BUFFERED_CHUNKS) {
// Client is either not reading (Paused) or not fast enough
this.buffer_condition.wait (this.buffer_mutex);
}
@@ -100,16 +100,16 @@ internal class Rygel.HTTPGstSink : BaseSink {
}
this.response.push_data (buffer.data);
- this.buffered++;
+ this.chunks_buffered++;
return false;
}
private void on_wrote_chunk (Soup.Message msg) {
this.buffer_mutex.lock ();
- this.buffered--;
+ this.chunks_buffered--;
- if (this.buffered < MIN_BUFFERED_CHUNKS) {
+ if (this.chunks_buffered < MIN_BUFFERED_CHUNKS) {
this.buffer_condition.broadcast ();
}
this.buffer_mutex.unlock ();
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]