fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-23 02:50:50 +00:00
Code Issues Projects Releases Wiki Activity

Cluster: refactoring of clusterNode*Bit to use helper bitmap functions.

Browse Source
This commit is contained in:
antirez 2013-02-28 15:23:09 +01:00
parent d21d6b666f
commit 5f8fd27ace
1 changed files with 27 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/cluster.c
View File

@ -1328,31 +1328,47 @@ void clusterCron(void) {
* Slots management * Slots management
* -------------------------------------------------------------------------- */ * -------------------------------------------------------------------------- */
/* Test bit 'pos' in a generic bitmap. Return 1 if the bit is zet,
* otherwise 0. */
int bitmapTestBit(unsigned char *bitmap, int pos) {
off_t byte = pos/8;
int bit = pos&7;
return (bitmap[byte] & (1<<bit)) != 0;
}
/* Set the bit at position 'pos' in a bitmap. */
void bitmapSetBit(unsigned char *bitmap, int pos) {
off_t byte = pos/8;
int bit = pos&7;
bitmap[byte] |= 1<<bit;
}
/* Clear the bit at position 'pos' in a bitmap. */
void bitmapClearBit(unsigned char *bitmap, int pos) {
off_t byte = pos/8;
int bit = pos&7;
bitmap[byte] &= ~(1<<bit);
}
/* Set the slot bit and return the old value. */ /* Set the slot bit and return the old value. */
int clusterNodeSetSlotBit(clusterNode *n, int slot) { int clusterNodeSetSlotBit(clusterNode *n, int slot) {
off_t byte = slot/8; int old = bitmapTestBit(n->slots,slot);
int bit = slot&7; bitmapSetBit(n->slots,slot);
int old = (n->slots[byte] & (1<<bit)) != 0;
n->slots[byte] |= 1<<bit;
if (!old) n->numslots++; if (!old) n->numslots++;
return old; return old;
} }
/* Clear the slot bit and return the old value. */ /* Clear the slot bit and return the old value. */
int clusterNodeClearSlotBit(clusterNode *n, int slot) { int clusterNodeClearSlotBit(clusterNode *n, int slot) {
off_t byte = slot/8; int old = bitmapTestBit(n->slots,slot);
int bit = slot&7; bitmapClearBit(n->slots,slot);
int old = (n->slots[byte] & (1<<bit)) != 0;
n->slots[byte] &= ~(1<<bit);
if (old) n->numslots--; if (old) n->numslots--;
return old; return old;
} }
/* Return the slot bit from the cluster node structure. */ /* Return the slot bit from the cluster node structure. */
int clusterNodeGetSlotBit(clusterNode *n, int slot) { int clusterNodeGetSlotBit(clusterNode *n, int slot) {
off_t byte = slot/8; return bitmapTestBit(n->slots,slot);
int bit = slot&7;
return (n->slots[byte] & (1<<bit)) != 0;
} }
/* Add the specified slot to the list of slots that node 'n' will /* Add the specified slot to the list of slots that node 'n' will