RAMOutputStream.cs
上传用户:zhangkuixh
上传日期:2013-09-30
资源大小:5473k
文件大小:3k
源码类别:

搜索引擎

开发平台:

C#

  1. /*
  2.  * Copyright 2004 The Apache Software Foundation
  3.  * 
  4.  * Licensed under the Apache License, Version 2.0 (the "License");
  5.  * you may not use this file except in compliance with the License.
  6.  * You may obtain a copy of the License at
  7.  * 
  8.  * http://www.apache.org/licenses/LICENSE-2.0
  9.  * 
  10.  * Unless required by applicable law or agreed to in writing, software
  11.  * distributed under the License is distributed on an "AS IS" BASIS,
  12.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13.  * See the License for the specific language governing permissions and
  14.  * limitations under the License.
  15.  */
  16. using System;
  17. namespace Lucene.Net.Store
  18. {
  19. /// <summary> A memory-resident {@link IndexOutput} implementation.
  20. /// 
  21. /// </summary>
  22. /// <version>  $Id: RAMOutputStream.java 150537 2004-09-28 20:45:26Z cutting $
  23. /// </version>
  24. public class RAMOutputStream : BufferedIndexOutput
  25. {
  26. private RAMFile file;
  27. private int pointer = 0;
  28. /// <summary>Construct an empty output buffer. </summary>
  29. public RAMOutputStream() : this(new RAMFile())
  30. {
  31. }
  32. internal RAMOutputStream(RAMFile f)
  33. {
  34. file = f;
  35. }
  36. /// <summary>Copy the current contents of this buffer to the named output. </summary>
  37. public virtual void  WriteTo(IndexOutput out_Renamed)
  38. {
  39. Flush();
  40. long end = file.length;
  41. long pos = 0;
  42. int buffer = 0;
  43. while (pos < end)
  44. {
  45. int length = BUFFER_SIZE;
  46. long nextPos = pos + length;
  47. if (nextPos > end)
  48. {
  49. // at the last buffer
  50. length = (int) (end - pos);
  51. }
  52. out_Renamed.WriteBytes((byte[]) file.buffers[buffer++], length);
  53. pos = nextPos;
  54. }
  55. }
  56. /// <summary>Resets this to an empty buffer. </summary>
  57. public virtual void  Reset()
  58. {
  59. try
  60. {
  61. Seek(0);
  62. }
  63. catch (System.IO.IOException e)
  64. {
  65. // should never happen
  66. throw new System.SystemException(e.ToString());
  67. }
  68. file.length = 0;
  69. }
  70. public override void  FlushBuffer(byte[] src, int len)
  71. {
  72. int bufferNumber = pointer / BUFFER_SIZE;
  73. int bufferOffset = pointer % BUFFER_SIZE;
  74. int bytesInBuffer = BUFFER_SIZE - bufferOffset;
  75. int bytesToCopy = bytesInBuffer >= len?len:bytesInBuffer;
  76. if (bufferNumber == file.buffers.Count)
  77. file.buffers.Add(new byte[BUFFER_SIZE]);
  78. byte[] buffer = (byte[]) file.buffers[bufferNumber];
  79. Array.Copy(src, 0, buffer, bufferOffset, bytesToCopy);
  80. if (bytesToCopy < len)
  81. {
  82. // not all in one buffer
  83. int srcOffset = bytesToCopy;
  84. bytesToCopy = len - bytesToCopy; // remaining bytes
  85. bufferNumber++;
  86. if (bufferNumber == file.buffers.Count)
  87. file.buffers.Add(new byte[BUFFER_SIZE]);
  88. buffer = (byte[]) file.buffers[bufferNumber];
  89. Array.Copy(src, srcOffset, buffer, 0, bytesToCopy);
  90. }
  91. pointer += len;
  92. if (pointer > file.length)
  93. file.length = pointer;
  94. file.lastModified = System.DateTime.Now.Ticks;
  95. }
  96. public override void  Close()
  97. {
  98. base.Close();
  99. }
  100. public override void  Seek(long pos)
  101. {
  102. base.Seek(pos);
  103. pointer = (int) pos;
  104. }
  105. public override long Length()
  106. {
  107. return file.length;
  108. }
  109. }
  110. }