← Back to branch summary

~raghavendra-prabhu/percona-xtradb-cluster/release-5.5.30-galera-2.x

« back to all changes in this revision

Viewing changes to galera/src/replicator_smm.hpp

  • Committer: Ignacio Nin
  • Date: 2012-10-31 22:57:41 UTC
  • mfrom: (95.2.11 2.x)
  • Revision ID: ignacio.nin@percona.com-20121031225741-kzcz6072mwzfpaiw
Merge from upstream

Show diffs side-by-side

added added

removed removed

Lines of Context:
galera/src/replicator_smm.hpp
103
103
            throw (gu::Exception);
104
104
        void process_sync(wsrep_seqno_t seqno_l)
105
105
            throw (gu::Exception);
106
 
        const struct wsrep_stats_var* stats() const;
 
106
 
 
107
        const struct wsrep_stats_var* stats_get()  const;
 
108
        static void                   stats_free(struct wsrep_stats_var*);
107
109
 
108
110
        // helper function
109
111
        void           set_param (const std::string& key,
134
136
        {
135
137
            static const std::string commit_order;
136
138
            static const std::string causal_read_timeout;
 
139
            static const std::string base_host;
 
140
            static const std::string base_port;
137
141
        };
138
142
 
139
143
        typedef std::pair<std::string, std::string> Default;
157
161
        wsrep_status_t cert_for_aborted(TrxHandle* trx);
158
162
 
159
163
        void update_state_uuid (const wsrep_uuid_t& u);
 
164
        void update_incoming_list (const wsrep_view_info_t& v);
160
165
 
161
166
        /* aborts/exits the program in a clean way */
162
167
        void abort() throw();
263
268
                switch (mode_)
264
269
                {
265
270
                case BYPASS:
266
 
                    gu_throw_fatal 
 
271
                    gu_throw_fatal
267
272
                        << "commit order condition called in bypass mode";
268
273
                    throw;
269
274
                case OOOC:
383
388
         * |------------------------------------------------------
384
389
         * | protocol_version_ | trx_proto_ver_ | str_proto_ver_ |
385
390
         * |------------------------------------------------------
386
 
         * |                 0 |              0 |              0 |
387
391
         * |                 1 |              1 |              0 |
388
392
         * |                 2 |              1 |              1 |
389
393
         * |                 3 |              2 |              1 |
437
441
        // action sources
438
442
        ActionSource*   as_;
439
443
        GcsActionSource gcs_as_;
440
 
        ist::Receiver ist_receiver_;
 
444
        ist::Receiver   ist_receiver_;
441
445
        ist::AsyncSenderMap ist_senders_;
442
446
        // trx processing
443
447
        Wsdb            wsdb_;
444
448
        Certification   cert_;
445
449
 
446
450
        // concurrency control
447
 
        Monitor<LocalOrder> local_monitor_;
448
 
        Monitor<ApplyOrder> apply_monitor_;
 
451
        Monitor<LocalOrder>  local_monitor_;
 
452
        Monitor<ApplyOrder>  apply_monitor_;
449
453
        Monitor<CommitOrder> commit_monitor_;
450
454
        gu::datetime::Period causal_read_timeout_;
451
455
 
460
464
        gu::Atomic<long long> local_replays_;
461
465
        gu::Atomic<long long> causal_reads_;
462
466
 
 
467
        // non-atomic stats
 
468
        std::string           incoming_list_;
 
469
        mutable gu::Mutex     incoming_mutex_;
 
470
 
463
471
        mutable std::vector<struct wsrep_stats_var> wsrep_stats_;
464
472
    };
465
473