geode-unsafe/src/main/java/org/apache/geode/unsafe/internal/sun/misc/Signal.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
 * agreements. See the NOTICE file distributed with this work for additional information regarding
 * copyright ownership. The ASF licenses this file to You 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.
 */

package org.apache.geode.unsafe.internal.sun.misc;

import java.util.Objects;

public class Signal {

  final sun.misc.Signal signal;

  public Signal(String name) {
    signal = new sun.misc.Signal(name);
  }

  public int getNumber() {
    return unwrap(this).getNumber();
  }

  public String getName() {
    return unwrap(this).getName();
  }

  @Override
  public boolean equals(Object other) {
    if (this == other) {
      return true;
    }
    if (!(other instanceof Signal)) {
      return false;
    }
    return unwrap((Signal) other).equals(unwrap(this));
  }

  @Override
  public int hashCode() {
    return unwrap(this).hashCode();
  }

  @Override
  public String toString() {
    return unwrap(this).toString();
  }

  public static synchronized SignalHandler handle(final Signal signal,
      final SignalHandler signalHandler) throws IllegalArgumentException {
    Objects.requireNonNull(signal);
    Objects.requireNonNull(signalHandler);
    return wrap(sun.misc.Signal.handle(unwrap(signal), wrap(signalHandler)));
  }

  public static void raise(Signal signal) throws IllegalArgumentException {
    Objects.requireNonNull(signal);
    sun.misc.Signal.raise(unwrap(signal));
  }

  private static sun.misc.SignalHandler wrap(final SignalHandler signalHandler) {
    if (signalHandler instanceof SunSignalHandler) {
      return ((SunSignalHandler) signalHandler).signalHandler;
    }

    return new GeodeSignalHandler(signalHandler);
  }

  private static Signal wrap(final sun.misc.Signal signal) {
    return new Signal(signal.getName());
  }

  private static sun.misc.Signal unwrap(final Signal signal) {
    return signal.signal;
  }

  private static SignalHandler wrap(final sun.misc.SignalHandler signalHandler) {
    if (signalHandler == sun.misc.SignalHandler.SIG_DFL) {
      return SignalHandler.SIG_DFL;
    }

    if (signalHandler == sun.misc.SignalHandler.SIG_IGN) {
      return SignalHandler.SIG_IGN;
    }

    if (signalHandler instanceof GeodeSignalHandler) {
      return ((GeodeSignalHandler) signalHandler).signalHandler;
    }

    return new SunSignalHandler(signalHandler);
  }

  private static class GeodeSignalHandler implements sun.misc.SignalHandler {
    private final SignalHandler signalHandler;

    GeodeSignalHandler(final SignalHandler signalHandler) {
      this.signalHandler = signalHandler;
    }

    @Override
    public void handle(final sun.misc.Signal signal) {
      signalHandler.handle(wrap(signal));
    }
  }

  static class SunSignalHandler implements SignalHandler {
    final sun.misc.SignalHandler signalHandler;

    SunSignalHandler(final sun.misc.SignalHandler signalHandler) {
      this.signalHandler = signalHandler;
    }

    @Override
    public void handle(final Signal signal) {
      signalHandler.handle(unwrap(signal));
    }
  }
}