amqp_queue_declare_ok_t *qd_ret;
amqp_basic_consume_ok_t *cm_ret;
amqp_queue_declare_ok_t *qd_ret;
amqp_basic_consume_ok_t *cm_ret;
- qd_ret = amqp_queue_declare(conf->connection,
- /* channel = */ CAMQP_CHANNEL,
- /* queue = */
- (conf->queue != NULL)
- ? amqp_cstring_bytes(conf->queue)
- : AMQP_EMPTY_BYTES,
- /* passive = */ 0,
- /* durable = */ conf->queue_durable,
- /* exclusive = */ 0,
- /* auto_delete = */ conf->queue_auto_delete,
- /* arguments = */ AMQP_EMPTY_TABLE);
+ qd_ret =
+ amqp_queue_declare(conf->connection,
+ /* channel = */ CAMQP_CHANNEL,
+ /* queue = */
+ (conf->queue != NULL) ? amqp_cstring_bytes(conf->queue)
+ : AMQP_EMPTY_BYTES,
+ /* passive = */ 0,
+ /* durable = */ conf->queue_durable,
+ /* exclusive = */ 0,
+ /* auto_delete = */ conf->queue_auto_delete,
+ /* arguments = */ AMQP_EMPTY_TABLE);
if (qd_ret == NULL) {
ERROR("amqp plugin: amqp_queue_declare failed.");
camqp_close_connection(conf);
if (qd_ret == NULL) {
ERROR("amqp plugin: amqp_queue_declare failed.");
camqp_close_connection(conf);
/* queue = */ amqp_cstring_bytes(conf->queue),
/* exchange = */ amqp_cstring_bytes(conf->exchange),
/* routing_key = */
/* queue = */ amqp_cstring_bytes(conf->queue),
/* exchange = */ amqp_cstring_bytes(conf->exchange),
/* routing_key = */
- (conf->routing_key != NULL) ? amqp_cstring_bytes(conf->routing_key)
- : AMQP_EMPTY_BYTES,
+ (conf->routing_key != NULL) ? amqp_cstring_bytes(conf->routing_key)
+ : AMQP_EMPTY_BYTES,
/* arguments = */ AMQP_EMPTY_TABLE);
if ((qb_ret == NULL) && camqp_is_error(conf)) {
char errbuf[1024];
/* arguments = */ AMQP_EMPTY_TABLE);
if ((qb_ret == NULL) && camqp_is_error(conf)) {
char errbuf[1024];
* Kamil Wiatrowski <kamilx.wiatrowski@intel.com>
**/
* Kamil Wiatrowski <kamilx.wiatrowski@intel.com>
**/
#include "utils/common/common.h"
#include "utils/common/common.h"
#include "utils/config_cores/config_cores.h"
#include "utils/config_cores/config_cores.h"
* Michał Aleksiński <michalx.aleksinski@intel.com>
**/
* Michał Aleksiński <michalx.aleksinski@intel.com>
**/
#include "utils/common/common.h"
#include "utils/config_cores/config_cores.h"
#include "utils/proc_pids/proc_pids.h"
#include "utils/common/common.h"
#include "utils/config_cores/config_cores.h"
#include "utils/proc_pids/proc_pids.h"
#define RDT_PLUGIN "intel_rdt"
#define RDT_PLUGIN "intel_rdt"
* Ruben Kerkhof <ruben at rubenkerkhof.com>
**/
* Ruben Kerkhof <ruben at rubenkerkhof.com>
**/
#include "plugin.h"
#include "utils/common/common.h"
#include "utils_lua.h"
#include "plugin.h"
#include "utils/common/common.h"
#include "utils_lua.h"
/* Include the Lua API header files. */
#include <lauxlib.h>
/* Include the Lua API header files. */
#include <lauxlib.h>
/* do not automatically get the thread specific Perl interpreter */
#define PERL_NO_GET_CONTEXT
/* do not automatically get the thread specific Perl interpreter */
#define PERL_NO_GET_CONTEXT
#include <EXTERN.h>
#include <perl.h>
#include <EXTERN.h>
#include <perl.h>
#include "utils/avltree/avltree.h"
#include "utils/common/common.h"
#include "utils_cache.h"
#include "utils_llist.h"
#include "utils/avltree/avltree.h"
#include "utils/common/common.h"
#include "utils_cache.h"
#include "utils_llist.h"
#include <net-snmp/net-snmp-config.h>
#include <net-snmp/net-snmp-config.h>