Changeset 307

Show
Ignore:
Timestamp:
02/25/08 22:50:31 (9 months ago)
Author:
rm
Message:

SpreadConnection? -> Spread

Location:
trunk/thrucommon
Files:
2 modified
2 moved

Legend:

Unmodified
Added
Removed

  • trunk/thrucommon/src/Makefile.am

    r306 r307  
    1717                             ThruFileTransport.h        \ 
    1818                             RecoveryManager.h          \ 
    19                              SpreadConnection.h         \ 
     19                             Spread.h                   \ 
    2020                             bloom_filter.hpp           \ 
    2121                             utils.h 
    … …  
    3030                           CircuitBreaker.cpp                   \ 
    3131                           ConfigFile.cpp                       \ 
    32                            ThruFileTransport.cpp                \ 
    3332                           RecoveryManager.cpp                  \ 
    34                            SpreadConnection.cpp 
     33                           Spread.cpp                           \ 
     34                           ThruFileTransport.cpp 
    3535 
    3636libthrucommon_la_CPPFLAGS = -Wall -Igen-cpp $(MEMCACHED_CFLAGS) $(SPEAD_CFLAGS) $(SSL_CFLAGS) $(THRIFT_CFLAGS) $(UUID_CFLAGS) 

  • trunk/thrucommon/src/Spread.cpp

    r306 r307  
    11 
    2 #include "SpreadConnection.h" 
     2#include "Spread.h" 
    33 
    44using namespace log4cxx; 
    … …  
    77string SP_error_to_string (int error); 
    88 
    9 LoggerPtr SpreadConnection::logger (Logger::getLogger ("SpreadConnection")); 
     9LoggerPtr Spread::logger (Logger::getLogger ("Spread")); 
    1010 
    1111/* TODO: 
    … …  
    1414 */ 
    1515 
    16 SpreadConnection::SpreadConnection (const string & name, 
     16Spread::Spread (const string & name, 
    1717                                    const string & private_name) 
    1818{ 
    1919    char buf[1024]; 
    20     sprintf (buf, "SpreadConnection: name=%s, private_name=%s", 
     20    sprintf (buf, "Spread: name=%s, private_name=%s", 
    2121             name.c_str (), private_name.c_str ()); 
    2222    LOG4CXX_INFO (logger, buf); 
    … …  
    3939    // save our private group name 
    4040    this->private_group = private_group; 
    41     LOG4CXX_INFO (logger, "SpreadConnection: private_group=" + 
     41    LOG4CXX_INFO (logger, "Spread: private_group=" + 
    4242                  this->private_group); 
    4343} 
    4444 
    45 SpreadConnection::~SpreadConnection () 
    46 { 
    47     LOG4CXX_INFO (logger, "~SpreadConnection"); 
     45Spread::~Spread () 
     46{ 
     47    LOG4CXX_INFO (logger, "~Spread"); 
    4848    map<string, vector<string> >::iterator i; 
    4949    for (i = this->groups.begin (); 
    … …  
    5656} 
    5757 
    58 void SpreadConnection::join (const std::string & group) 
     58void Spread::join (const std::string & group) 
    5959{ 
    6060    LOG4CXX_DEBUG (logger, "join: group=" + group); 
    … …  
    8282} 
    8383 
    84 void SpreadConnection::leave (const std::string & group) 
     84void Spread::leave (const std::string & group) 
    8585{ 
    8686    LOG4CXX_DEBUG (logger, "leave: group=" + group); 
    … …  
    9595} 
    9696 
    97 void SpreadConnection::subscribe (const string & sender, const string & group, 
     97void Spread::subscribe (const string & sender, const string & group, 
    9898                                  const int message_type, 
    9999                                  SubscriberCallbackInfo * callback) 
    … …  
    112112} 
    113113 
    114 void SpreadConnection::send (const service service_type, const string & group, 
     114void Spread::send (const service service_type, const string & group, 
    115115                             const int message_type, const char * message,  
    116116                             const int message_len) 
    … …  
    128128 
    129129// message will be copied in to a local buffer 
    130 void SpreadConnection::queue (const service service_type, const string & group, 
     130void Spread::queue (const service service_type, const string & group, 
    131131                              const int message_type, const char * message,  
    132132                              const int message_len) 
    … …  
    149149} 
    150150 
    151 void SpreadConnection::run (int count) 
     151void Spread::run (int count) 
    152152{ 
    153153    if (logger->isDebugEnabled ()) 
    … …  
    231231} 
    232232 
    233 void SpreadConnection::make_callbacks 
     233void Spread::make_callbacks 
    234234(vector<SubscriberCallbackInfo *> & callbacks, const string & sender, 
    235235 const vector<string> & groups, const int message_type, const char * message,  
    … …  
    269269} 
    270270 
    271 void SpreadConnection::dispatch (const string & sender,  
     271void Spread::dispatch (const string & sender,  
    272272                                 const vector<string> & groups, 
    273273                                 const int message_type, const char * message,  
    … …  
    404404} 
    405405 
    406 void SpreadConnection::drain_pending () 
     406void Spread::drain_pending () 
    407407{ 
    408408    if (logger->isDebugEnabled ()) 

  • trunk/thrucommon/src/Spread.h

    r305 r307  
    2828 
    2929// only so we can pass this in to callbacks 
    30 class SpreadConnection; 
     30class Spread; 
    3131/* callbacks return true to stay installed, false to be removed */ 
    32 typedef bool (*subscriber_callback) (SpreadConnection * spread_connection, 
     32typedef bool (*subscriber_callback) (Spread * spread_connection, 
    3333                                     const std::string & sender, 
    3434                                     const std::vector<std::string> & groups, 
    … …  
    5353}; 
    5454 
    55 class SpreadConnection 
     55class Spread 
    5656{ 
    5757    public: 
    58         SpreadConnection (const std::string & name, 
     58        Spread (const std::string & name, 
    5959                          const std::string & private_name); 
    60         ~SpreadConnection (); 
     60        ~Spread (); 
    6161 
    6262        void subscribe (const std::string & sender, const std::string & group, 

  • trunk/thrucommon/tests/SpreadTest.cpp

    r305 r307  
    99#if HAVE_CPPUNIT 
    1010 
    11 #include "SpreadConnection.h" 
     11#include "Spread.h" 
    1212 
    1313#include <cppunit/CompilerOutputter.h> 
    … …  
    3333        { 
    3434            string spread_name = "4803@localhost"; 
    35             SpreadConnection * conn =  
    36                 new SpreadConnection (spread_name, "cppunit"); 
    37             CPPUNIT_ASSERT (conn);  
     35            Spread * conn = new Spread (spread_name, "cppunit"); 
     36            CPPUNIT_ASSERT (conn); 
    3837 
    3938            string group = "testing"; 
    … …  
    106105 
    107106            // other sender... 
    108             SpreadConnection * other_conn =  
    109                 new SpreadConnection (spread_name, "other_cppunit"); 
     107            Spread * other_conn = new Spread (spread_name, "other_cppunit"); 
    110108            other_conn->send (SAFE_MESS, group, 42, msg, msg_len); 
    111109            conn->run (1); 
    … …  
    122120        }; 
    123121 
    124         static bool all_callback (SpreadConnection * /* spread_connection */, 
     122        static bool all_callback (Spread * /* spread_connection */, 
    125123                                  const string & /* sender */, 
    126124                                  const vector<string> & /* groups */, 
    … …  
    134132        } 
    135133 
    136         static bool sender_callback (SpreadConnection * /* spread_connection */, 
     134        static bool sender_callback (Spread * /* spread_connection */, 
    137135                                     const string & /* sender */, 
    138136                                     const vector<string> & /* groups */, 
    … …  
    146144        } 
    147145 
    148         static bool group_callback (SpreadConnection * /* spread_connection */, 
     146        static bool group_callback (Spread * /* spread_connection */, 
    149147                                    const string & /* sender */, 
    150148                                    const vector<string> & /* groups */, 
    … …  
    158156        } 
    159157 
    160         static bool type_callback (SpreadConnection * /* spread_connection */, 
     158        static bool type_callback (Spread * /* spread_connection */, 
    161159                                   const string & /* sender */, 
    162160                                   const vector<string> & /* groups */, 
    … …  
    170168        } 
    171169 
    172         static bool once_callback (SpreadConnection * /* spread_connection */, 
     170        static bool once_callback (Spread * /* spread_connection */, 
    173171                                   const string & /* sender */, 
    174172                                   const vector<string> & /* groups */,