binding/mdsal-binding-dom-codec/src/main/java/org/opendaylight/mdsal/binding/dom/codec/impl/BitsCodec.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.mdsal.binding.dom.codec.impl;
   9
  10 import static com.google.common.base.Preconditions.checkArgument;
  11 import static java.util.Objects.requireNonNull;
  12
  13 import com.google.common.cache.Cache;
  14 import com.google.common.cache.CacheBuilder;
  15 import com.google.common.collect.ImmutableMap;
  16 import com.google.common.collect.ImmutableSet;
  17 import java.lang.invoke.MethodHandle;
  18 import java.lang.invoke.MethodHandles;
  19 import java.lang.invoke.MethodType;
  20 import java.lang.reflect.Constructor;
  21 import java.lang.reflect.InvocationTargetException;
  22 import java.lang.reflect.Method;
  23 import java.util.ArrayList;
  24 import java.util.Collection;
  25 import java.util.LinkedHashMap;
  26 import java.util.Map;
  27 import java.util.Map.Entry;
  28 import java.util.Set;
  29 import java.util.TreeSet;
  30 import java.util.concurrent.ExecutionException;
  31 import org.eclipse.jdt.annotation.NonNull;
  32 import org.opendaylight.mdsal.binding.spec.naming.BindingMapping;
  33 import org.opendaylight.yangtools.yang.model.api.type.BitsTypeDefinition;
  34 import org.opendaylight.yangtools.yang.model.api.type.BitsTypeDefinition.Bit;
  35
  36 // FIXME: 'SchemaUnawareCodec' is not correct: we use BitsTypeDefinition in construction
  37 final class BitsCodec extends ValueTypeCodec implements SchemaUnawareCodec {
  38     /*
  39      * Use identity comparison for keys and allow classes to be GCd themselves.
  40      *
  41      * Since codecs can (and typically do) hold a direct or indirect strong reference to the class, they need to be also
  42      * accessed via reference. Using a weak reference could be problematic, because the codec would quite often be only
  43      * weakly reachable. We therefore use a soft reference, whose implementation guidance is suitable to our use case:
  44      *
  45      *     "Virtual machine implementations are, however, encouraged to bias against clearing recently-created or
  46      *      recently-used soft references."
  47      */
  48     private static final Cache<Class<?>, @NonNull BitsCodec> CACHE = CacheBuilder.newBuilder().weakKeys().softValues()
  49         .build();
  50     private static final MethodType CONSTRUCTOR_INVOKE_TYPE = MethodType.methodType(Object.class, Boolean[].class);
  51
  52     // Ordered by position
  53     private final ImmutableMap<String, Method> getters;
  54     // Ordered by lexical name
  55     private final ImmutableSet<String> ctorArgs;
  56     private final MethodHandle ctor;
  57
  58     private BitsCodec(final MethodHandle ctor, final Set<String> ctorArgs, final Map<String, Method> getters) {
  59         this.ctor = requireNonNull(ctor);
  60         this.ctorArgs = ImmutableSet.copyOf(ctorArgs);
  61         this.getters = ImmutableMap.copyOf(getters);
  62     }
  63
  64     static @NonNull BitsCodec of(final Class<?> returnType, final BitsTypeDefinition rootType)
  65             throws ExecutionException {
  66         return CACHE.get(returnType, () -> {
  67             final Map<String, Method> getters = new LinkedHashMap<>();
  68             final Set<String> ctorArgs = new TreeSet<>();
  69
  70             for (Bit bit : rootType.getBits()) {
  71                 final Method valueGetter = returnType.getMethod(BindingMapping.GETTER_PREFIX
  72                     + BindingMapping.getClassName(bit.getName()));
  73                 ctorArgs.add(bit.getName());
  74                 getters.put(bit.getName(), valueGetter);
  75             }
  76             Constructor<?> constructor = null;
  77             for (Constructor<?> cst : returnType.getConstructors()) {
  78                 if (!cst.getParameterTypes()[0].equals(returnType)) {
  79                     constructor = cst;
  80                 }
  81             }
  82
  83             final MethodHandle ctor = MethodHandles.publicLookup().unreflectConstructor(constructor)
  84                     .asSpreader(Boolean[].class, ctorArgs.size()).asType(CONSTRUCTOR_INVOKE_TYPE);
  85             return new BitsCodec(ctor, ctorArgs, getters);
  86         });
  87     }
  88
  89     @Override
  90     @SuppressWarnings("checkstyle:illegalCatch")
  91     public Object deserialize(final Object input) {
  92         checkArgument(input instanceof Set);
  93         @SuppressWarnings("unchecked")
  94         final Set<String> casted = (Set<String>) input;
  95
  96         /*
  97          * We can do this walk based on field set sorted by name, since constructor arguments in Java Binding are
  98          * sorted by name.
  99          *
 100          * This means we will construct correct array for construction of bits object.
 101          */
 102         final Boolean[] args = new Boolean[ctorArgs.size()];
 103         int currentArg = 0;
 104         for (String value : ctorArgs) {
 105             args[currentArg++] = casted.contains(value);
 106         }
 107
 108         try {
 109             return ctor.invokeExact(args);
 110         } catch (Throwable e) {
 111             throw new IllegalStateException("Failed to instantiate object for " + input, e);
 112         }
 113     }
 114
 115     @Override
 116     public Set<String> serialize(final Object input) {
 117         final Collection<String> result = new ArrayList<>(getters.size());
 118         for (Entry<String, Method> valueGet : getters.entrySet()) {
 119             final Boolean value;
 120             try {
 121                 value = (Boolean) valueGet.getValue().invoke(input);
 122             } catch (IllegalAccessException | InvocationTargetException e) {
 123                 throw new IllegalArgumentException("Failed to get bit " + valueGet.getKey(), e);
 124             }
 125
 126             if (value) {
 127                 result.add(valueGet.getKey());
 128             }
 129         }
 130         return result.size() == getters.size() ? getters.keySet() : ImmutableSet.copyOf(result);
 131     }
 132 }