window

1 write to window

System.ServiceModel (1)

System\ServiceModel\Channels\TransmissionStrategy.cs (1)

105this.window = new SlidingWindow(maxWindowSize);

42 references to window

System.ServiceModel (42)

System\ServiceModel\Channels\TransmissionStrategy.cs (42)

126return (this.window.Count > 0 || this.waitQueue.Count > 0); 204window.Close(); 231sequenceNumber = this.windowStart + this.window.Count; 234if (this.requestAcks && (this.window.Count == this.windowSize - 1 || this.quotaRemaining == 1)) // can't add any more 240if (this.window.Count == 0) 245this.window.Add(message, Now, state); 251attemptInfo = new MessageAttemptInfo(this.window.GetMessage(index), sequenceNumber, 0, state); 273return (this.window.Count < this.windowSize && // Does the message fit in the transmission window? 294window.Close(); 307int count = Math.Min(this.windowSize, this.quotaRemaining) - this.window.Count; 354if (this.window.Count == 0) 357this.window.RecordRetry(0, Now); 365attemptInfo = new MessageAttemptInfo(this.window.GetMessage(0), this.windowStart, this.window.GetRetryCount(0), this.window.GetState(0)); 372if (!this.closed && (this.window.Count > 0)) 402window.Close(); 437if (this.window.GetTransferred(index)) 440return new MessageAttemptInfo(this.window.GetMessage(index), next, this.window.GetRetryCount(index), this.window.GetState(index)); 463this.last = this.windowStart + this.window.Count - 1; 558if ((this.windowStart == 1) && (this.window.Count == 0)) 587Int64 lastMessageSent = this.windowStart + this.window.Count - 1; 589int transferredInWindow = this.window.TransferredCount; 617int endIndex = (int)((range.Upper > lastMessageSent) ? (this.window.Count - 1) : (range.Upper - this.windowStart)); 619newAck = this.window.GetTransferredInRangeCount(beginIndex, endIndex) < (endIndex - beginIndex + 1); 625int endIndex = (int)((range.Upper > lastMessageSent) ? (this.window.Count - 1) : (range.Upper - this.windowStart)); 627transferredInWindow -= this.window.GetTransferredInRangeCount(beginIndex, endIndex); 697this.quotaRemaining = quotaRemaining - Math.Min(this.windowSize, this.window.Count); 715for (int i = 1; i < this.window.Count; i++) 717if (this.window.GetTransferred(i)) 732UpdateStats(now, this.window.GetLastAttemptTime(i)); 736int inFlightAfterAck = Math.Min(this.windowSize, this.window.Count) - (int)slide; 740this.window.Remove((int)slide); 772int sendEndIndex = Math.Min(this.windowSize, this.window.Count); 778for (int i = sendBeginIndex; i < this.windowSize && i < this.window.Count; i++) 782if (!this.window.GetTransferred(i) && !this.retransmissionWindow.Contains(sequenceNumber)) 784this.window.RecordRetry(i, Now); 790if (window.Count > 0) 801this.window.SetTransferred((int)(i - this.windowStart)); 831if (this.windowStart + this.window.Count + this.waitQueue.Count == Int64.MaxValue)