bundles/org.simantics.db.common/src/org/simantics/db/common/request/ResourceAsyncRead2.java

   1 /*******************************************************************************
   2  * Copyright (c) 2007, 2010 Association for Decentralized Information Management
   3  * in Industry THTH ry.
   4  * All rights reserved. This program and the accompanying materials
   5  * are made available under the terms of the Eclipse Public License v1.0
   6  * which accompanies this distribution, and is available at
   7  * http://www.eclipse.org/legal/epl-v10.html
   8  *
   9  * Contributors:
  10  *     VTT Technical Research Centre of Finland - initial API and implementation
  11  *******************************************************************************/
  12 package org.simantics.db.common.request;
  13
  14 import org.simantics.db.AsyncRequestProcessor;
  15 import org.simantics.db.RequestProcessor;
  16 import org.simantics.db.Resource;
  17 import org.simantics.db.exception.DatabaseException;
  18 import org.simantics.db.procedure.AsyncListener;
  19 import org.simantics.db.procedure.AsyncProcedure;
  20 import org.simantics.db.procedure.Listener;
  21 import org.simantics.db.procedure.Procedure;
  22 import org.simantics.db.procedure.SyncListener;
  23 import org.simantics.db.procedure.SyncProcedure;
  24 import org.simantics.db.request.AsyncRead;
  25 import org.simantics.db.request.ReadInterface;
  26
  27 public abstract class ResourceAsyncRead2<T> implements AsyncRead<T>, ReadInterface<T> {
  28
  29     final protected Resource resource;
  30     final protected Resource resource2;
  31
  32     @Override
  33     final public int hashCode() {
  34         final int h1 = resource != null ? resource.hashCode() : 0;
  35         final int h2 = resource2 != null ? resource2.hashCode() : 0;
  36         return h1 ^ h2;
  37     }
  38
  39     @Override
  40     public int threadHash() {
  41         return resource.hashCode() >>> 16;
  42     }
  43
  44     @Override
  45     final public boolean equals(Object object) {
  46         if (this == object)
  47             return true;
  48         else if (object == null)
  49             return false;
  50         else if (getClass() != object.getClass())
  51             return false;
  52         ResourceAsyncRead2<?> r = (ResourceAsyncRead2<?>) object;
  53         if(resource != null) {
  54             if(!resource.equals(r.resource)) return false;
  55         } else if(r.resource != null) return false;
  56         if(resource2 != null) {
  57             if(!resource2.equals(r.resource2)) return false;
  58         } else if(r.resource2 != null) return false;
  59         return true;
  60     }
  61
  62     @Override
  63     public int getFlags() {
  64         return 0;
  65     }
  66
  67     public ResourceAsyncRead2(Resource resource, Resource resource2) {
  68         this.resource = resource;
  69         this.resource2 = resource2;
  70     }
  71
  72     @Override
  73     public void request(AsyncRequestProcessor processor, AsyncProcedure<T> procedure) {
  74         processor.asyncRequest(this, procedure);
  75     }
  76
  77     @Override
  78     public void request(AsyncRequestProcessor processor, Procedure<T> procedure) {
  79         processor.asyncRequest(this, procedure);
  80     }
  81
  82     @Override
  83     public void request(AsyncRequestProcessor processor, SyncProcedure<T> procedure) {
  84         processor.asyncRequest(this, procedure);
  85     }
  86
  87     @Override
  88     public void request(AsyncRequestProcessor processor, AsyncListener<T> procedure) {
  89         processor.asyncRequest(this, procedure);
  90     }
  91
  92     @Override
  93     public void request(AsyncRequestProcessor processor, Listener<T> procedure) {
  94         processor.asyncRequest(this, procedure);
  95     }
  96
  97     @Override
  98     public void request(AsyncRequestProcessor processor, SyncListener<T> procedure) {
  99         processor.asyncRequest(this, procedure);
 100     }
 101
 102     @Override
 103     public T request(RequestProcessor processor) throws DatabaseException {
 104         return processor.syncRequest(this);
 105     }
 106
 107 }