~codership/galera/2.x

« back to all changes in this revision

Viewing changes to gcs/src/gcs.c

  • Committer: Alexey Yurchenko
  • Date: 2014-01-29 14:43:26 UTC
  • mto: This revision was merged to the branch mainline in revision 167.
  • Revision ID: alexey.yurchenko@codership.com-20140129144326-aa70nhzofl0smkm8
Fixes:
* provider pause() is fixed to avoid potential deadlock with replicating threads.
* lp:1099478 - handle own address in the address list properly (do not throw exception)
* lp:1259952 - fixed allocation of multiple of pages when posix_fallocate() is unavailable
* lp:1261996 - fixed compilation on Solaris 11
* lp:1232747 - fixed group remerge after partitioning event

Synced with SVN r3450

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
1
/*
2
2
 * Copyright (C) 2008-2013 Codership Oy <info@codership.com>
3
3
 *
4
 
 * $Id: gcs.c 3217 2013-08-23 12:09:40Z alex $
 
4
 * $Id: gcs.c 3446 2014-01-13 01:33:30Z teemu $
5
5
 */
6
6
 
7
7
/*
1156
1156
        if (gu_likely (rcvd.act.type != GCS_ACT_TORDERED ||
1157
1157
                       (rcvd.id > 0 && (conn->global_seqno = rcvd.id)))) {
1158
1158
            /* successful delivery - increment local order */
1159
 
            this_act_id = conn->local_act_id++;
 
1159
            this_act_id = gu_sync_fetch_and_add(&conn->local_act_id, 1);
1160
1160
        }
1161
1161
 
1162
1162
        if (NULL != rcvd.repl_buf                                       &&
1810
1810
    return _join (conn, seqno);
1811
1811
}
1812
1812
 
 
1813
gcs_seqno_t gcs_local_sequence(gcs_conn_t* conn)
 
1814
{
 
1815
    return gu_sync_fetch_and_add(&conn->local_act_id, 1);
 
1816
}
 
1817
 
1813
1818
void
1814
1819
gcs_get_stats (gcs_conn_t* conn, struct gcs_stats* stats)
1815
1820
{