Redis源码分析（十七）---multi事务操作

/* ================================ MULTI/EXEC ============================== */
void initClientMultiState(redisClient *c) /* 初始化客户端操作 */
void freeClientMultiState(redisClient *c) /* 释放客户端所有与multi/exec相关的资源 */
void queueMultiCommand(redisClient *c) /* 客户端的multi命令队列添加一条新的命令 */
void discardTransaction(redisClient *c) /* 撤销事务操作 */
void flagTransaction(redisClient *c) /* 标记一个事物为DIRTY_EXEC状态，最后这个事物会执行失败，，此方法调用于插入命令的时候 */
void multiCommand(redisClient *c) /* 加入multi命令 */
void discardCommand(redisClient *c) /* 撤销命令 */
void execCommandPropagateMulti(redisClient *c) /* 发送multi命令给所有的从客户端和aof文件 */
void execCommand(redisClient *c) /* 客户单执行Command命令 */
void watchForKey(redisClient *c, robj *key) /* 为客户端添加key监听 */
void unwatchAllKeys(redisClient *c) /* 客户端移除所有的key */
void touchWatchedKey(redisDb *db, robj *key) /* touch key的意思，表示key正在被监听，下一条执行操作将会失败 */
void touchWatchedKeysOnFlush(int dbid) /* 根据key所在的的db，把此db下的watched-key统统touch一遍 */
void watchCommand(redisClient *c) /* watch key 的命令方法，通过client中的参数传值 */
void unwatchCommand(redisClient *c) /* 取消监听key的命令方法 */

/* 撤销事务 */
void discardTransaction(redisClient *c) {
    freeClientMultiState(c);
    initClientMultiState(c);
    c->flags &= ~(REDIS_MULTI|REDIS_DIRTY_CAS|REDIS_DIRTY_EXEC);
    //客户端取消监听所有的key
    unwatchAllKeys(c);
}

/* 在事务处理中，存在2种mapping映射，key-->client lists ,表示所有列表中的Client都在监听这个key
	，当这个key的value发生改变了，可以标记这些Client为DIRTY状态，需要更新了，同时在Client内部也会维护
	一个key of list,表示一个客户端所监视的所有key，当Client发生free操作等，就要把key里面维护的Client列表
	做更新*/

/* touch key的意思，表示key正在被监听，下一条执行操作将会失败 */

/* "Touch" a key, so that if this key is being WATCHed by some client the
 * next EXEC will fail. */
/* touch key的意思，表示key正在被监听，下一条执行操作将会失败 */
void touchWatchedKey(redisDb *db, robj *key) {
    list *clients;
    listIter li;
    listNode *ln;

    if (dictSize(db->watched_keys) == 0) return;
    clients = dictFetchValue(db->watched_keys, key);
    if (!clients) return;

    /* Mark all the clients watching this key as REDIS_DIRTY_CAS */
    /* Check if we are already watching for this key */
    listRewind(clients,&li);
    while((ln = listNext(&li))) {
        redisClient *c = listNodeValue(ln);
		
		//遍历该key拥有的Client，把flag标记为DIRTY_CAS状态
        c->flags |= REDIS_DIRTY_CAS;
    }
}

/* 定义了watchedKey结构体 */
typedef struct watchedKey {
    robj *key;
    redisDb *db;
} watchedKey;