protected override IBin Decorate(BinConfiguration config, IBin bin)
			{
				MsgExceptionHandlingTestCase.CloseAwareBin decorated = new MsgExceptionHandlingTestCase.CloseAwareBin
					(this, bin);
				lock (_openBins)
				{
					_openBins[decorated] = decorated;
				}
				return decorated;
			}

 public LogReplayer(String logFilePath, IBin bin, ISet commands)
 {
     _logFilePath = logFilePath;
     _bin = bin;
     _commands = commands;
     _counts = new Hashtable();
     foreach (object com in commands)
     {
         _counts[com] = (Int64)0;
     }
 }

		/// <exception cref="Db4objects.Db4o.Ext.Db4oIOException"></exception>
		public CachingBin(IBin bin, ICache4 cache, int pageCount, int pageSize) : base(bin
			)
		{
			_onDiscardPage = new _IProcedure4_22(this);
			_producerFromDisk = new _IFunction4_138(this);
			_producerFromPool = new _IFunction4_147(this);
			_pageSize = pageSize;
			_pagePool = new SimpleObjectPool(NewPagePool(pageCount));
			_cache = cache;
			_fileLength = _bin.Length();
		}

	protected override IBin Decorate(BinConfiguration config, IBin bin) 
	{
        try 
		{
			var file = new FileStream(_fileName, FileMode.Create);

			var @out = new StreamWriter(file);
			return new LoggingBin(bin, @out, _config);
		} 
        catch(FileNotFoundException e) 
		{
			throw new Db4oIOException(e);
		}
	}

		protected override IBin Decorate(BinConfiguration config, IBin bin)
		{
			ResetShutdownState();
			return new ExceptionSimulatingStorage.ExceptionSimulatingBin(bin, _exceptionFactory
				, _triggerCondition);
		}

			public virtual void DelegateTo(IBin bin)
			{
				_bin = bin;
			}

		private static void SyncAndClose(IBin bin)
		{
			if (bin != null)
			{
				try
				{
					bin.Sync();
				}
				finally
				{
					bin.Close();
				}
			}
		}

 protected override IBin Decorate(BinConfiguration config, IBin bin)
 {
     return new MonitoredBin(bin);
 }

		private void AssertReadOnly(IBin adapter)
		{
			Assert.Expect(typeof(Db4oIOException), new _ICodeBlock_21(adapter));
		}

		public ThreadedSyncBin(IBin bin) : base(bin)
		{
			_thread = new Thread(new _IRunnable_23(this), "ThreadedSyncBin");
			_thread.Start();
		}

			/// <exception cref="Db4objects.Db4o.Ext.Db4oIOException"></exception>
			public NonFlushingCachingBin(IBin bin, ICache4 cache, int pageCount, int pageSize
				) : base(bin, cache, pageCount, pageSize)
			{
			}

 protected override IBin Decorate(BinConfiguration config, IBin bin)
 {
     var decorated = new CloseAwareBin
         (this, bin);
     lock (_openBins)
     {
         _openBins[decorated] = decorated;
     }
     return decorated;
 }

 public CloseAwareBin(CloseAwareStorage storage, IBin
     bin) : base(bin)
 {
     _storage = storage;
 }

		protected virtual IBin Decorate(BinConfiguration config, IBin bin)
		{
			return bin;
		}

		public BlockAwareBin(IBin bin) : base(bin)
		{
		}

		public virtual void Replay(IBin bin)
		{
			bin.Read(_pos, PrepareBuffer(), _length);
		}

			public _ICodeBlock_21(IBin adapter)
			{
				this.adapter = adapter;
			}

 protected override IBin Decorate(BinConfiguration config, IBin bin)
 {
     return new LoggingBin(base.Decorate(config, bin));
 }

 public MonitoredBin(IBin bin) : base(bin)
 {
     _bytesWrittenCounter = Db4oPerformanceCounters.CounterFor(PerformanceCounterSpec.BytesWrittenPerSec, false);
     _bytesReadCounter = Db4oPerformanceCounters.CounterFor(PerformanceCounterSpec.BytesReadPerSec, false);
 }

		protected override IBin Decorate(BinConfiguration config, IBin storage)
		{
			return new NonFlushingStorage.NonFlushingBin(storage);
		}