Facilities/NHibernateIntegration/Castle.Facilities.NHibernateIntegration.Tests/Internals/SessionStoreTestCase.cs

   1 // Copyright 2004-2008 Castle Project - http://www.castleproject.org/
   2 //
   3 // Licensed under the Apache License, Version 2.0 (the "License");
   4 // you may not use this file except in compliance with the License.
   5 // You may obtain a copy of the License at
   6 //
   7 //     http://www.apache.org/licenses/LICENSE-2.0
   8 //
   9 // Unless required by applicable law or agreed to in writing, software
  10 // distributed under the License is distributed on an "AS IS" BASIS,
  11 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 // See the License for the specific language governing permissions and
  13 // limitations under the License.
  14
  15 namespace Castle.Facilities.NHibernateIntegration.Tests.Internals
  16 {
  17         using System;
  18         using System.Threading;
  19         using NUnit.Framework;
  20
  21         using NHibernate;
  22
  23         /// <summary>
  24         /// Tests the default implementation of ISessionStore
  25         /// </summary>
  26         [TestFixture]
  27         public class SessionStoreTestCase : AbstractNHibernateTestCase
  28         {
  29                 private AutoResetEvent arEvent = new AutoResetEvent(false);
  30
  31                 [Test]
  32                 [ExpectedException( typeof(ArgumentNullException) )]
  33                 public void NullAlias()
  34                 {
  35                         ISessionStore store = (ISessionStore) container[typeof(ISessionStore)];
  36
  37                         store.FindCompatibleSession(null);
  38                 }
  39
  40                 [Test]
  41                 public void FindCompatibleSession()
  42                 {
  43                         ISessionStore store = (ISessionStore) container[typeof(ISessionStore)];
  44                         ISessionFactory factory = (ISessionFactory) container[typeof(ISessionFactory)];
  45
  46                         ISession session = store.FindCompatibleSession( Constants.DefaultAlias );
  47
  48                         Assert.IsNull(session);
  49
  50                         session = factory.OpenSession();
  51
  52                         SessionDelegate sessDelegate = new SessionDelegate(true, session, store);
  53
  54                         store.Store( Constants.DefaultAlias, sessDelegate );
  55
  56                         Assert.IsNotNull(sessDelegate.SessionStoreCookie);
  57
  58                         ISession session2 = store.FindCompatibleSession( "something in the way she moves" );
  59
  60                         Assert.IsNull(session2);
  61
  62                         session2 = store.FindCompatibleSession( Constants.DefaultAlias );
  63
  64                         Assert.IsNotNull(session2);
  65                         Assert.AreSame(sessDelegate, session2);
  66
  67                         session.Dispose();
  68
  69                         store.Remove(sessDelegate);
  70
  71                         session = store.FindCompatibleSession( Constants.DefaultAlias );
  72
  73                         Assert.IsNull(session);
  74
  75                         Assert.IsTrue( store.IsCurrentActivityEmptyFor( Constants.DefaultAlias ) );
  76                 }
  77
  78                 [Test]
  79                 public void FindCompatibleSessionWithTwoThreads()
  80                 {
  81                         ISessionStore store = (ISessionStore) container[typeof(ISessionStore)];
  82                         ISessionFactory factory = (ISessionFactory) container[typeof(ISessionFactory)];
  83
  84                         ISession session = factory.OpenSession();
  85
  86                         SessionDelegate sessDelegate = new SessionDelegate(true, session, store);
  87
  88                         store.Store( Constants.DefaultAlias, sessDelegate );
  89
  90                         ISession session2 = store.FindCompatibleSession( Constants.DefaultAlias );
  91
  92                         Assert.IsNotNull(session2);
  93                         Assert.AreSame(sessDelegate, session2);
  94
  95                         Thread newThread = new Thread(new ThreadStart(FindCompatibleSessionOnOtherThread));
  96                         newThread.Start();
  97
  98                         arEvent.WaitOne();
  99
 100                         sessDelegate.Dispose();
 101
 102                         Assert.IsTrue( store.IsCurrentActivityEmptyFor( Constants.DefaultAlias ) );
 103                 }
 104
 105                 private void FindCompatibleSessionOnOtherThread()
 106                 {
 107                         ISessionStore store = (ISessionStore) container[typeof(ISessionStore)];
 108
 109                         ISession session = store.FindCompatibleSession( "something in the way she moves" );
 110
 111                         Assert.IsNull(session);
 112
 113                         ISession session2 = store.FindCompatibleSession( Constants.DefaultAlias );
 114
 115                         Assert.IsNull(session2);
 116
 117                         arEvent.Set();
 118                 }
 119         }
 120 }