index_ipc.c

Go to the documentation of this file.

/*
 * File Name: index_ipc.c
 */

/*
 * This file is part of ctb.
 *
 * ctb is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 2 of the License, or
 * (at your option) any later version.
 *
 * ctb is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

/**
 * Copyright (C) 2009 iRex Technologies B.V.
 * All rights reserved.
 */

//----------------------------------------------------------------------------
// Include Files
//----------------------------------------------------------------------------

#include "config.h"

// system include files, between < >
#include <stdlib.h>
#include <unistd.h>

// ereader include files, between < >
#include <liberipc/eripc.h>
#include <liberipc/eripc_support.h>
#include <liberutils/er_error.h>

// local include files, between " "
#include "ctb_log.h"
#include "index_ipc.h"
#include "index.h"

//----------------------------------------------------------------------------
// Type Declarations
//----------------------------------------------------------------------------

//----------------------------------------------------------------------------
// Constants
//----------------------------------------------------------------------------

// IPC content browser
#define DBUS_APPL_NAME                  "index"
#define DBUS_SERVICE                     "com.irexnet." DBUS_APPL_NAME
#define DBUS_PATH                       "/com/irexnet/" DBUS_APPL_NAME
#define DBUS_INTERFACE                   "com.irexnet." DBUS_APPL_NAME
#define DBUS_SERVICE_UDS                "com.irexnet.uds"

#define DBUS_STORE_METADATA_TIMEOUT 25000

//----------------------------------------------------------------------------
// Static Variables
//----------------------------------------------------------------------------

static eripc_client_context_t *eripcClient = NULL;

//============================================================================
// Local Function Definitions
//============================================================================

static void on_storemetadata_ready( eripc_context_t          *context,
                                    const eripc_event_info_t *info,
                                    void                     *user_data ); 

// Exported DBUS API list
static eripc_callback_function_t service_functions[] = {
    { on_storemetadata_ready, "storeMetadataReady", NULL, 0},
    { NULL, NULL, NULL ,0 }  // end of list
};


//============================================================================
// Functions Implementation
//============================================================================


//----------------------------------------------------------------------------
// Generic
//----------------------------------------------------------------------------

// initialise
void ipc_set_services ()
{
    eripcClient = eripc_client_context_new(
                    DBUS_APPL_NAME, 
                    "1.0",
                    DBUS_SERVICE, 
                    DBUS_PATH,
                    DBUS_INTERFACE,
                    service_functions);
}


// un-initialise
void ipc_unset_services (void)
{
    eripc_client_context_free(eripcClient, service_functions);
}

//----------------------------------------------------------------------------
// Indexer
//----------------------------------------------------------------------------

gboolean ipc_send_store_metadata(const char *dir, const char *document)
{
    LOGPRINTF("entry");
    
    char* fullpath = (char *)calloc(strlen(dir) + strlen(document) + 2, sizeof(char));
    strcat(fullpath, dir);
    strcat(fullpath, "/");
    strcat(fullpath, document);    
    
    eripc_error_t retval;

    g_return_val_if_fail(document != NULL, FALSE);
    
    int status = (int)eripc_set_timeout(eripcClient->context,  DBUS_STORE_METADATA_TIMEOUT);
    if (status != 0)
    {
        ERRORPRINTF("Could not set timeout, status = [%d]", status);
    }

    retval = eripc_send_string_and_wait(eripcClient->context,
                               NULL,
                               ERIPC_BUS_SESSION,
                               DBUS_SERVICE_UDS,
                               "storeMetadata",
                               fullpath);
                               
    // Fullpath can be freed here because send_string_and_wait only returns
    // after executing (and it makes a copy of it anyway) [MDB]
    free(fullpath);
    
    if (retval != ERIPC_ERROR_SUCCESS) 
    {
        ERRORPRINTF("Error launching eripc handler: %s", eripc_error_string(retval));
        return FALSE;
    }

    return TRUE;
}


//============================================================================
// Local Function Implementation
//============================================================================

//----------------------------------------------------------------------------
// Signal/message handlers
//----------------------------------------------------------------------------

static void on_storemetadata_ready ( eripc_context_t          *context,
                                     const eripc_event_info_t *info,
                                     void                     *user_data )
{
    LOGPRINTF("entry");
      
    store_metadata_ready();    
}