Line data    Source code

       1             : /*
       2             :  * Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
       3             :  * Copyright Contributors to the OpenSDN project
       4             :  */
       5             : 
       6             : #include "contrail-collector/redis_connection.h"
       7             : 
       8         176 : RedisAsyncConnection * rac_alloc(EventManager *evm, const std::string & redis_ip,
       9             :             unsigned short redis_port,
      10             :             RedisAsyncConnection::ClientConnectCbFn client_connect_cb,
      11             :             RedisAsyncConnection::ClientDisconnectCbFn client_disconnect_cb,
      12             :             bool redis_ssl_enable, const std::string & redis_keyfile,
      13             :             const std::string & redis_certfile, const std::string & redis_ca_cert) {
      14             :     RedisAsyncConnection * rac =
      15             :             new RedisAsyncConnection( evm, redis_ip, redis_port,
      16             :                             client_connect_cb, client_disconnect_cb,
      17         176 :                             redis_ssl_enable, redis_keyfile, redis_certfile, redis_ca_cert);
      18         176 :     rac->RAC_Connect();
      19         176 :     return rac;
      20             : }
      21          44 : RedisAsyncConnection * rac_alloc_nocheck(EventManager *evm, const std::string & redis_ip,
      22             :             unsigned short redis_port,
      23             :             RedisAsyncConnection::ClientConnectCbFn client_connect_cb,
      24             :             RedisAsyncConnection::ClientDisconnectCbFn client_disconnect_cb,
      25             :             bool redis_ssl_enable, const std::string & redis_keyfile,
      26             :             const std::string & redis_certfile, const std::string & redis_ca_cert) {
      27             :     RedisAsyncConnection * rac =
      28             :             new RedisAsyncConnection( evm, redis_ip, redis_port,
      29             :                             client_connect_cb, client_disconnect_cb,
      30          44 :                             redis_ssl_enable, redis_keyfile, redis_certfile, redis_ca_cert);
      31          44 :     rac->RAC_Connect();
      32          44 :     return rac;
      33             : }