beagled/Lucene.Net/Search/RemoteSearchable.cs

   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
  17 using System;
  18 using Document = Lucene.Net.Documents.Document;
  19 using Term = Lucene.Net.Index.Term;
  20
  21 namespace Lucene.Net.Search
  22 {
  23
  24         /// <summary> A remote searchable implementation.
  25         ///
  26         /// </summary>
  27         /// <version>  $Id: RemoteSearchable.cs,v 1.4 2006/10/02 17:09:06 joeshaw Exp $
  28         /// </version>
  29         [Serializable]
  30         public class RemoteSearchable : System.MarshalByRefObject, Lucene.Net.Search.Searchable
  31         {
  32
  33                 private Lucene.Net.Search.Searchable local;
  34
  35                 /// <summary>Constructs and exports a remote searcher. </summary>
  36                 public RemoteSearchable(Lucene.Net.Search.Searchable local) : base()
  37                 {
  38                         this.local = local;
  39                 }
  40
  41                 // this implementation should be removed when the deprecated
  42                 // Searchable#search(Query,Filter,HitCollector) is removed
  43                 public virtual void  Search(Query query, Filter filter, HitCollector results)
  44                 {
  45                         local.Search(query, filter, results);
  46                 }
  47
  48                 public virtual void  Search(Weight weight, Filter filter, HitCollector results)
  49                 {
  50                         local.Search(weight, filter, results);
  51                 }
  52
  53                 public virtual void  Close()
  54                 {
  55                         local.Close();
  56                 }
  57
  58                 public virtual int DocFreq(Term term)
  59                 {
  60                         return local.DocFreq(term);
  61                 }
  62
  63
  64                 public virtual int[] DocFreqs(Term[] terms)
  65                 {
  66                         return local.DocFreqs(terms);
  67                 }
  68
  69                 public virtual int MaxDoc()
  70                 {
  71                         return local.MaxDoc();
  72                 }
  73
  74                 // this implementation should be removed when the deprecated
  75                 // Searchable#search(Query,Filter,int) is removed
  76                 public virtual TopDocs Search(Query query, Filter filter, int n)
  77                 {
  78                         return local.Search(query, filter, n);
  79                 }
  80
  81                 public virtual TopDocs Search(Weight weight, Filter filter, int n)
  82                 {
  83                         return local.Search(weight, filter, n);
  84                 }
  85
  86                 // this implementation should be removed when the deprecated
  87                 // Searchable#search(Query,Filter,int,Sort) is removed
  88                 public virtual TopFieldDocs Search(Query query, Filter filter, int n, Sort sort)
  89                 {
  90                         return local.Search(query, filter, n, sort);
  91                 }
  92
  93                 public virtual TopFieldDocs Search(Weight weight, Filter filter, int n, Sort sort)
  94                 {
  95                         return local.Search(weight, filter, n, sort);
  96                 }
  97
  98                 public virtual Document Doc(int i)
  99                 {
 100                         return local.Doc(i);
 101                 }
 102
 103                 public virtual Query Rewrite(Query original)
 104                 {
 105                         return local.Rewrite(original);
 106                 }
 107
 108                 // this implementation should be removed when the deprecated
 109                 // Searchable#explain(Query,int) is removed
 110                 public virtual Explanation Explain(Query query, int doc)
 111                 {
 112                         return local.Explain(query, doc);
 113                 }
 114
 115                 public virtual Explanation Explain(Weight weight, int doc)
 116                 {
 117                         return local.Explain(weight, doc);
 118                 }
 119
 120         public override System.Object InitializeLifetimeService()
 121         {
 122             long initialLeaseTime, sponsorshipTimeout, renewOnCallTime;
 123
 124             initialLeaseTime = SupportClass.AppSettings.Get("Lucene.Net.Remoting.Lifetime.initialLeaseTime", -1);
 125             sponsorshipTimeout = SupportClass.AppSettings.Get("Lucene.Net.Remoting.Lifetime.sponsorshipTimeout", -1);
 126             renewOnCallTime = SupportClass.AppSettings.Get("Lucene.Net.Remoting.Lifetime.renewOnCallTime", -1);
 127
 128             if ((initialLeaseTime == -1) || (sponsorshipTimeout == -1) || (renewOnCallTime == -1))
 129             {
 130                 return null;
 131             }
 132             else
 133             {
 134                 System.Runtime.Remoting.Lifetime.ILease lease =
 135                     (System.Runtime.Remoting.Lifetime.ILease) base.InitializeLifetimeService();
 136                 if (lease.CurrentState == System.Runtime.Remoting.Lifetime.LeaseState.Initial)
 137                 {
 138                     lease.InitialLeaseTime = System.TimeSpan.FromMinutes(initialLeaseTime);
 139                     lease.SponsorshipTimeout = System.TimeSpan.FromMinutes(sponsorshipTimeout);
 140                     lease.RenewOnCallTime = System.TimeSpan.FromSeconds(renewOnCallTime);
 141                 }
 142                 return lease;
 143             }
 144         }
 145
 146                 /// <summary>Exports a searcher for the index in args[0] named
 147                 /// "//localhost/Searchable".
 148                 /// </summary>
 149                 [STAThread]
 150                 public static void  Main(System.String[] args)
 151                 {
 152                         System.Runtime.Remoting.RemotingConfiguration.Configure("Lucene.Net.Search.RemoteSearchable.config");
 153                         System.Runtime.Remoting.Channels.ChannelServices.RegisterChannel(new System.Runtime.Remoting.Channels.Http.HttpChannel(1099));
 154                         System.String indexName = null;
 155
 156                         if (args != null && args.Length == 1)
 157                                 indexName = args[0];
 158
 159                         if (indexName == null)
 160                         {
 161                                 System.Console.Out.WriteLine("Usage: Lucene.Net.search.RemoteSearchable <index>");
 162                                 return ;
 163                         }
 164
 165                         // create and install a security manager
 166                         if (true)  // if (System_Renamed.getSecurityManager() == null) // {{Aroush-1.4.3}} Do we need this line?!
 167                         {
 168                                 // System_Renamed.setSecurityManager(new RMISecurityManager());     // {{Aroush-1.4.3}} Do we need this line?!
 169                         }
 170
 171                         Lucene.Net.Search.Searchable local = new IndexSearcher(indexName);
 172                         RemoteSearchable impl = new RemoteSearchable(local);
 173
 174                         // bind the implementation to "Searchable"
 175                         System.Runtime.Remoting.RemotingServices.Marshal(impl, "tcp://localhost:1099/Searchable");
 176                         System.Console.ReadLine();
 177                 }
 178         }
 179 }