acquire_internal.c

Go to the documentation of this file.

/*
 EasyDbus: DBUS Binding Library.
 Copyright (C) 2007  Daniele Rondina aka Ge@@eu, geaaru@gmail.com 

 This program 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.

 This program 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, write to the Free Software
 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

 Filename:  acquire_internal.c
 
 Description:  
 
 Version:  1.0
 Created:  09/17/07 17:04:41 CEST
 Revision:  none
 
 Author:   Daniele Rondina aka Ge@@ru , geaaru@gmail.com 
 License:  GPL 2.0
*/

#include <stdlib.h>
#include <string.h>
// easydbus includes
#include "easydbus-core.h"
#include "acquire_internal.h"
#include "debug.h"
#include "utils.h"

int
easydbus_get_address_serverSession (struct EasyDbus_conn *data,
                                    char *serviceName)
{
   DBusError err;
   struct EasyDbus_core *core = (struct EasyDbus_core *) data;
   int result = -1;
   char *new_service_name = NULL;

   dbus_error_init (&err);

   if (easydbus_connect_to_bus (core, &err, DBUS_BUS_SESSION))
      goto error_acquire;

// if (dbus_bus_register (core->conn, &err) == FALSE) {
//    EasyDbusDebug ("Error %s from dbus_bus_register: %s",
//          err.name,
//          err.message);
//    goto error_acquire;
// }

   result = easydbus_acquire_name (core, serviceName,
                                   data->flags | EASYDBUS_CONN_DO_NOT_QUEUE,
                                   &err);
   if (result == -1)
      goto error_acquire;
   if (result == EASYDBUS_CONN_NAME_SERVICE_EXISTS) {
      // probably this isn't needed because without this flags
      // return value is EASYDBUS_CONN_NAME_SERVICE_IN_QUEUE
      if (data->flags & EASYDBUS_CONN_NAME_SERVICE_RENAMED) {
         new_service_name = easydbus_found_new_name
            (core, serviceName, data->flags, &err);
         if (new_service_name == NULL)
            goto error_acquire;
         result = EASYDBUS_CONN_NAME_SERVICE_RENAMED;
      }
      else
         goto error_acquire;
   }

   data->registered_ondbus = 1;

   if (new_service_name != NULL)
      core->service_name = new_service_name;
   else if (easydbus_save_serviceName (core, serviceName)) {
      EasyDbusDebug ("Error on save service name");
      goto error_acquire;
   }

   if (data->flags & EASYDBUS_CONN_NAME_UNIQUE)
      if (easydbus_set_unique_nameID (core, core->service_name))
         goto error_acquire;

   dbus_error_free (&err);
   return result;

 error_acquire:
   if (data->registered_ondbus)
      dbus_bus_release_name (core->conn, 
                             core->service_name, &err);

   if (core->conn != NULL)
      dbus_connection_unref (core->conn);

   dbus_error_free (&err);

   return -1;
}

inline int
easydbus_set_unique_nameID (struct EasyDbus_core *core, 
                            char *nameId)
{
   EasyDbusDebug ("DBUS unique name = %s",
                  dbus_bus_get_unique_name (core->conn));

   if (!dbus_bus_set_unique_name (core->conn, nameId))
      return -1;

   EasyDbusDebug ("DBUS unique name = %s",
                  dbus_bus_get_unique_name (core->conn));

   return 0;
}

inline int 
easydbus_get_address_onsession (struct EasyDbus_conn *data, 
                                char *serviceName)
{
   struct EasyDbus_core *core = (struct EasyDbus_core *) data;
   DBusError err;
   int result = -1;
   char *new_service_name = NULL;

   dbus_error_init (&err);

   /* connect to system bus */
   if (easydbus_connect_to_bus (core, &err, DBUS_BUS_SESSION))
      goto error_acquire;

   result = easydbus_acquire_name (core, serviceName, 
                                   data->flags, &err);
   if (result == -1)
      goto error_acquire;

   if (result == EASYDBUS_CONN_NAME_SERVICE_EXISTS &&
       // probably this isn't needed because without this flags
       // return value is EASYDBUS_CONN_NAME_SERVICE_IN_QUEUE
       (data->flags & EASYDBUS_CONN_DO_NOT_QUEUE)) {
      if (data->flags & EASYDBUS_CONN_NAME_SERVICE_RENAMED) {
         new_service_name = easydbus_found_new_name
            (core, serviceName, data->flags, &err);
         if (new_service_name == NULL)
            goto error_acquire;
         result = EASYDBUS_CONN_NAME_SERVICE_RENAMED;
      }
      else
         goto error_acquire;
   }

   data->registered_ondbus = 1;

   if (new_service_name != NULL)
      core->service_name = new_service_name;
   else if (easydbus_save_serviceName (core, serviceName)) {
      EasyDbusDebug ("Error on save service name");
      goto error_acquire;
   }
   
   if (data->flags & EASYDBUS_CONN_NAME_UNIQUE)
      if (easydbus_set_unique_nameID (core, core->service_name))
         goto error_acquire;

   EasyDbusDebug ("Acquire operation terminated");

   dbus_error_free (&err);
   return result;

 error_acquire:
   if (data->registered_ondbus)
      dbus_bus_release_name (core->conn, 
                             core->service_name, &err);

   if (core->conn != NULL)
      dbus_connection_unref (core->conn);

   dbus_error_free (&err);

   return result;
}

int 
easydbus_connect_to_bus (struct EasyDbus_core *core,
                         DBusError * err, 
                         DBusBusType type_bus) 
{
   /* connect to system bus */
   core->conn = dbus_bus_get (type_bus, err);
   if (!core->conn) {
      EasyDbusDebug ("Error %s from dbus_bus_get: %s",
                     err->name, err->message);
      return -1;
   }

   EasyDbusDebug ("Connected and registered to bus daemon");
   /* do not allw libdbus to exit on connection failure ( This
    * may around random exit () on SIGPIPE errors) */
   dbus_connection_set_exit_on_disconnect (core->conn, FALSE);
   return 0;
}

inline int 
easydbus_get_address_onsystem (struct EasyDbus_conn *data, 
                               char *serviceName)
{
   struct EasyDbus_core *core = (struct EasyDbus_core *) data;
   DBusError err;
   int result = -1;
   char *new_service_name = NULL;

   dbus_error_init (&err);

   if (easydbus_connect_to_bus (core, &err, DBUS_BUS_SYSTEM))
      goto error_acquire;

   result = easydbus_acquire_name (core, serviceName, data->flags, 
                                   &err);
   if (result == -1)
      goto error_acquire;
   if (result == EASYDBUS_CONN_NAME_SERVICE_EXISTS &&
       // probably this isn't needed because without this flags
       // return value is EASYDBUS_CONN_NAME_SERVICE_IN_QUEUE
       (data->flags & EASYDBUS_CONN_DO_NOT_QUEUE)) {
      if (data->flags & EASYDBUS_CONN_NAME_SERVICE_RENAMED) {
         new_service_name = easydbus_found_new_name
            (core, serviceName, data->flags, &err);
         if (new_service_name == NULL)
            goto error_acquire;
         result = EASYDBUS_CONN_NAME_SERVICE_RENAMED;
      }
      else
         goto error_acquire;
   }

   data->registered_ondbus = 1;

   if (new_service_name != NULL)
      core->service_name = new_service_name;
   else if (easydbus_save_serviceName (core, serviceName)) {
      EasyDbusDebug ("Error on save service name");
      goto error_acquire;
   }

   if (data->flags & EASYDBUS_CONN_NAME_UNIQUE)
      if (easydbus_set_unique_nameID (core, core->service_name))
         goto error_acquire;

   dbus_error_free (&err);
   return result;

 error_acquire:
   if (data->registered_ondbus)
      dbus_bus_release_name (core->conn, 
                             core->service_name, &err);

   if (core->conn != NULL)
      dbus_connection_unref (core->conn);

   dbus_error_free (&err);

   return -1;
}


void
close_dbus_connection (EasyDbus_conn *data)
{
   struct EasyDbus_core *core = (struct EasyDbus_core *) data;

   dbus_connection_close (core->conn);
}

// vim: ts=3 shiftwidth=3 expandtab

---