RemoteSearchable.cs :  » Search-Engines » dotLucene » Lucene » Net » Search » C# / CSharp Open Source

/*
 * Copyright 2004 The Apache Software Foundation
 * 
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * 
 * http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

using System;
using DocumentLucene.Net.Documents.Document;
using TermLucene.Net.Index.Term;

namespace Lucene.Net.Search{
  
  /// <summary> A remote searchable implementation.
  /// 
  /// </summary>
  /// <version>  $Id: RemoteSearchable.java 351472 2005-12-01 21:15:53Z bmesser $
  /// </version>
  [Serializable]
  public class RemoteSearchable : System.MarshalByRefObject, Lucene.Net.Search.Searchable
  {
    
    private Lucene.Net.Search.Searchable local;
    
    /// <summary>Constructs and exports a remote searcher. </summary>
    public RemoteSearchable(Lucene.Net.Search.Searchable local) : base()
    {
      this.local = local;
    }
    
    // this implementation should be removed when the deprecated
    // Searchable#search(Query,Filter,HitCollector) is removed
    public virtual void  Search(Query query, Filter filter, HitCollector results)
    {
      local.Search(query, filter, results);
    }
    
    public virtual void  Search(Weight weight, Filter filter, HitCollector results)
    {
      local.Search(weight, filter, results);
    }
    
    public virtual void  Close()
    {
      local.Close();
    }
    
    public virtual int DocFreq(Term term)
    {
      return local.DocFreq(term);
    }
    
    
    public virtual int[] DocFreqs(Term[] terms)
    {
      return local.DocFreqs(terms);
    }
    
    public virtual int MaxDoc()
    {
      return local.MaxDoc();
    }
    
    // this implementation should be removed when the deprecated
    // Searchable#search(Query,Filter,int) is removed
    public virtual TopDocs Search(Query query, Filter filter, int n)
    {
      return local.Search(query, filter, n);
    }
    
    public virtual TopDocs Search(Weight weight, Filter filter, int n)
    {
      return local.Search(weight, filter, n);
    }
    
    // this implementation should be removed when the deprecated
    // Searchable#search(Query,Filter,int,Sort) is removed
    public virtual TopFieldDocs Search(Query query, Filter filter, int n, Sort sort)
    {
      return local.Search(query, filter, n, sort);
    }
    
    public virtual TopFieldDocs Search(Weight weight, Filter filter, int n, Sort sort)
    {
      return local.Search(weight, filter, n, sort);
    }
    
    public virtual Document Doc(int i)
    {
      return local.Doc(i);
    }
    
    public virtual Query Rewrite(Query original)
    {
      return local.Rewrite(original);
    }
    
    // this implementation should be removed when the deprecated
    // Searchable#explain(Query,int) is removed
    public virtual Explanation Explain(Query query, int doc)
    {
      return local.Explain(query, doc);
    }
    
    public virtual Explanation Explain(Weight weight, int doc)
    {
      return local.Explain(weight, doc);
    }
    
        public override System.Object InitializeLifetimeService()
        {
            long initialLeaseTime, sponsorshipTimeout, renewOnCallTime;

            initialLeaseTime = SupportClass.AppSettings.Get("Lucene.Net.Remoting.Lifetime.initialLeaseTime", -1);
            sponsorshipTimeout = SupportClass.AppSettings.Get("Lucene.Net.Remoting.Lifetime.sponsorshipTimeout", -1);
            renewOnCallTime = SupportClass.AppSettings.Get("Lucene.Net.Remoting.Lifetime.renewOnCallTime", -1);

            if ((initialLeaseTime == -1) || (sponsorshipTimeout == -1) || (renewOnCallTime == -1))
            {
                return null;
            }
            else
            {
                System.Runtime.Remoting.Lifetime.ILease lease = 
                    (System.Runtime.Remoting.Lifetime.ILease) base.InitializeLifetimeService();
                if (lease.CurrentState == System.Runtime.Remoting.Lifetime.LeaseState.Initial)
                {
                    lease.InitialLeaseTime = System.TimeSpan.FromMinutes(initialLeaseTime);
                    lease.SponsorshipTimeout = System.TimeSpan.FromMinutes(sponsorshipTimeout);
                    lease.RenewOnCallTime = System.TimeSpan.FromSeconds(renewOnCallTime);
                }
                return lease;
            }
        }

    /// <summary>Exports a searcher for the index in args[0] named
    /// "//localhost/Searchable". 
    /// </summary>
    [STAThread]
    public static void  Main(System.String[] args)
    {
      System.Runtime.Remoting.RemotingConfiguration.Configure("Lucene.Net.Search.RemoteSearchable.config");
      System.Runtime.Remoting.Channels.ChannelServices.RegisterChannel(new System.Runtime.Remoting.Channels.Http.HttpChannel(1099));
      System.String indexName = null;
      
      if (args != null && args.Length == 1)
        indexName = args[0];
      
      if (indexName == null)
      {
        System.Console.Out.WriteLine("Usage: Lucene.Net.search.RemoteSearchable <index>");
        return ;
      }
      
      // create and install a security manager
      if (true)  // if (System_Renamed.getSecurityManager() == null) // {{Aroush-1.4.3}} Do we need this line?!
      {
        // System_Renamed.setSecurityManager(new RMISecurityManager());     // {{Aroush-1.4.3}} Do we need this line?!
      }
      
      Lucene.Net.Search.Searchable local = new IndexSearcher(indexName);
      RemoteSearchable impl = new RemoteSearchable(local);
      
      // bind the implementation to "Searchable"
      System.Runtime.Remoting.RemotingServices.Marshal(impl, "tcp://localhost:1099/Searchable");
      System.Console.ReadLine();
    }
  }
}