kernel/middleware/portqueueingcreate.c - master - dzavalishin/pok

kernel/middleware/portqueueingcreate.c
66 строк2 KB
Samuel Tardieu
Update year in copyright headers
20 мар 2021, 11:30
20 мар 2021, 11:3071185e2
/*
 *                               POK header
 *
 * The following file is a part of the POK project. Any modification should
 * be made according to the POK licence. You CANNOT use this file or a part
 * of a file for your own project.
 *
 * For more information on the POK licence, please see our LICENCE FILE
 *
 * Please follow the coding guidelines described in doc/CODING_GUIDELINES
 *
 *                                      Copyright (c) 2007-2021 POK team
 */

#ifdef POK_NEEDS_PORTS_QUEUEING

#include <core/lockobj.h>
#include <errno.h>
#include <middleware/port.h>
#include <middleware/queue.h>
#include <types.h>

extern pok_port_t pok_ports[POK_CONFIG_NB_PORTS];

pok_ret_t
pok_port_queueing_create(char *name, const pok_port_size_t size,
                         const pok_port_direction_t direction,
                         const pok_port_queueing_discipline_t discipline,
                         pok_port_id_t *id) {
  pok_ret_t ret;
  pok_lockobj_attr_t lockattr;
  if (discipline != POK_QUEUEING_DISCIPLINE_FIFO) {
    return POK_ERRNO_DISCIPLINE;
  }

  ret = pok_port_create(name, size, direction, POK_PORT_KIND_QUEUEING, id);

  /*
   * FIXME: should be done using another way by reinitializing
   * ports when a partition is restarted. At this time, when
   * a partition is restarted, the ports are not reinitialized
   * so that when the partition restart, it tries to reopen
   * ports already created. We pass over actually and keep
   * the port in the previous step, but we should reinitialize
   * the port while reinitializing the partition AND also
   * does not report an OK return code (see below) when trying to re
   * create a port that was already created.
   */
  if (ret == POK_ERRNO_EXISTS) {
    return POK_ERRNO_OK;
  }

  if (ret != POK_ERRNO_OK) {
    return ret;
  }

  pok_ports[*id].discipline = discipline;

  lockattr.kind = POK_LOCKOBJ_KIND_EVENT;
  lockattr.locking_policy = POK_LOCKOBJ_POLICY_STANDARD;
  ret = pok_lockobj_create(&pok_ports[*id].lock, &lockattr);

  return (ret);
}

#endif