Function install_plugin_int

db/plugin_handler.c:51–155

static comdb2_queue_consumer_t *queue_consumer_handlers[CONSUMER_TYPE_LAST];

static int install_plugin_int(comdb2_plugin_t *new_plugin)
{
    int i;
    assert(new_plugin);

    for (i = 0; gbl_plugins[i]; ++i) {
        /* Do not allow similar plugins with same version. */
        if ((strcmp(gbl_plugins[i]->name, new_plugin->name) == 0) &&
            gbl_plugins[i]->version == new_plugin->version) {
            logmsg(LOGMSG_ERROR, "Plugin %s:%d already installed "
                                 "overriding..\n",
                   new_plugin->name, new_plugin->version);
            return 1;
        }
    }

    if (i >= MAXPLUGINS) {
        logmsg(LOGMSG_ERROR, "Maximum number of plugins already installed. "
                             "Ignoring further requests to install "
                             "plugin(s).\n");
        return 1;
    }

    /* TODO: Check plugin version */
    if (new_plugin->type >= COMDB2_PLUGIN_LAST) {
        logmsg(LOGMSG_ERROR, "Invalid plugin type for %s.\n", new_plugin->name);
        return 1;
    }

    /*
      Initialize the plugin and add it to the global list of installed plugins.
    */
    if (new_plugin->init_cb && new_plugin->init_cb(NULL)) {
        logmsg(LOGMSG_ERROR, "Plugin initialization failed (%s).",
               new_plugin->name);
        return 1;
    }

    switch (new_plugin->type) {
    case COMDB2_PLUGIN_APPSOCK: {
        comdb2_appsock_t *appsock;
        appsock = (comdb2_appsock_t *)new_plugin->data;

        /*
          Check whether a similar appsock handler has already been
          added to the hash.
        */
        if (hash_find_readonly(gbl_appsock_hash, &appsock->name)) {
            logmsg(LOGMSG_FATAL, "duplicate appsock handler found\n");
            return 1;
        }
        hash_add(gbl_appsock_hash, appsock);
        break;
    }
    case COMDB2_PLUGIN_OPCODE: {
        comdb2_opcode_t *opcode;
        opcode = (comdb2_opcode_t *)new_plugin->data;