/*
 * Copyright [2021] JD.com, Inc.
 *
 * 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.
 */

#ifndef DA_SIGNAL_H_
#define DA_SIGNAL_H_

#include "compiler.h"
#include "da_queue.h"
#include <signal.h>
#include <string.h>

#define MAX_SIGNAL 256

/* those are highly dynamic and stored in pools */
struct sig_handler {
  TAILQ_ENTRY(sig_handler) sig_tqe;
  void *handler; /* function to call or task to wake up */
  int arg;       /*arg needed when process function or signals*/
};

TAILQ_HEAD(sig_tqh, sig_handler);

/* one per signal */
struct signal_descriptor {
  int count;              /* number of times raised */
  struct sig_tqh sig_tqh; /* sig_handler */
};

extern volatile int signal_queue_len;
extern struct signal_descriptor signal_state[];
extern struct pool_head *pool2_sig_handlers;

void signal_handler(int sig);
void __signal_process_queue();
int signal_init();
void deinit_signals();
struct sig_handler *
signal_register_fct(int sig, void (*fct)(struct sig_handler *), int arg);
void signal_unregister_handler(int sig, struct sig_handler *handler);
void signal_unregister_target(int sig, void *target);

static inline void signal_process_queue() {
  if (unlikely(signal_queue_len > 0))
    __signal_process_queue();
}

#endif /* DA_SIGNAL_H_ */