AppendEntries定义了follower节点收到appendentries以后的处理逻辑 * * 其实一共四种情况，就是follower日志多于leader，follower日志少于leader，follower日志等于leader（最新index处Term是否相同） */

*3.--------------测试并发Delete操作--------------*/

(chubbyGoMap.ConcurrentMap)

(chubbyGoMap.Sync.map)

(ConcurrentMap)

(Sync.map)

*2.--------------测试Get操作--------------*/ 读取一个存在的key (BaseMap)

(chubbyGoMap.ConcurrentMap)

(chubbyGoMap.Sync.map)

(ConcurrentMap)

(Sync.map)

*3.--------------测试并发Get,put操作--------------*/ (BaseMap)

(chubbyGoMap.ConcurrentMap)

(chubbyGoMap.Sync.map)

(ConcurrentMap)

(Sync.map)

*1.--------------测试Put操作--------------*/ 在此测试中冲突键较多,对并发的map并不有利 (BaseMap)

(chubbyGoMap.ConcurrentMap)

(chubbyGoMap.Sync.map)

(ConcurrentMap)

(Sync.map)

* * @brief: CAS操作只有在key对应的value值为数字时才有效 */

* * @brief: 提供一个更为灵活的CAS操作，具体的定义见compareSwap.go文件首部 */

* * @brief: 返回一个Config结构体，用于开始一个服务 * @param: nservers这个集群需要的机器数，包括本身，而且每个服务器初始化的时候必须配置正确 */

* * @param: 文件描述符传来的InstanceSeq，要删除的文件的名字 * @return: 成功删除返回true，否则返回false * @notes: 需要检测name是否存在; */

* * @brief: FastGet不提供任何一致性保证，适用于读极多写极少的情况，此时讲并发map的策略改为syncmap更优，性能可以提升百分之二十到三十 */

显然对于同一个客户端不允许并发执行多个操作,会发生死锁,这是我定义的使用规范

Retrieves an element from map under given key.

* * @brief: 根据本机网卡MAC地址和随机数拼出一个16位的机器标识 * @notes: sony的雪花算法库默认的生成机器标示函数是使用内网IP算的,因为客户端在调用这个函数,现在基本都使用NET技术,很可能出现重复,所以需要修改生成机器标识函数. * 目前打算前6位为分别为mac

* * @brief: 通过雪花算法生成一个全局唯一的ID * @notes: 在协议层使用0作为初始值，显然使用flake生成的uuid不可能为零,因为时间戳已经设置好了 */ ps:测试代码出现问题的原因很简单,就是时间戳可能是一样的,这其实没什么好办法,测试代码手工配置最方便。

-------------------------- DEBUG用的两个函数,发现雪花算法巨大的问题,同一进程内生成的一样,导致测试出现问题

Looks up an item under specified key

* * @brief: Debug用,输出间隔符号 */

Checks if map is empty.

Returns all items as map[string]interface{}

Returns an iterator which could be used in a for range loop. Deprecated: using IterBuffered() will get a better performence

Callback based iterator, cheapest way to read all elements in a map. 传入一个回调函数，目前map中的每个值都会调用这个回调

Return all keys as []string 这个貌似不对 可能channel会阻塞，因为count结束以后可能会传入值，导致这里channel阻塞

config file locker

在创建的时候已经知道了如何与服务端交互

* * @brief: 用于创建一个raft实体 */

Reviles ConcurrentMap "private" variables to json marshal. 可以用这个持久化

* * @param: 文件描述符传来的InstanceSeq;要打开的文件名 * @return: 返回当前文件的instanceSeq * @notes: 对于一个文件来说客户端open操作可以检查某个文件是否存在,如果存在会返回一个句柄,反之返回false; 对于一个目录来说open

其中重复代码很多不修改的原因很多地方类型都不一样,减少代码行数就需要反射,会降低可读性与性能;

* * @brief: 负责按照策略进行持久化,其实这个守护协程值执行everysec策略 */

Removes an element from the map and returns it

--------------------------

* * @brief: Debug用,显示当前目录树的全部文件名 */

* * @param: 文件描述符传来的InstanceSeq;要释放的文件(锁)的名字 * @return: 成功删除返回true，否则返回false * @notes: 需要检测name是否存在 */

RequestVote定义了Follower收到投票以后的处理逻辑 * * 我们在这个函数中需要实现将请求者的日志和被请求者的日志作对比 如果当前节点的Term比候选者节点的Term大，拒绝投票 * 1.如果当前节点的Term比候选者节点的Term大，拒绝投票 * 2.如果当前节点的Term比

Save both Raft state and K/V snapshot as a single atomic action, to help avoid them getting out of sync.

Sets the given value under the specified key if no value was associated with it.

*func (kv *RaftKV) Kill() { close(kv.shutdownCh) kv.rf.Kill() }*/

Insert or Update - updates existing element or inserts a new one using UpsertCb

config file locker

* * @brief: 判断文件名是否出现错误 */

* * 测试分为两个部分,第一部分对于写锁测试,第二部分对于读锁测试 */

测试分为两个板块，基础锁定操作与延迟锁定

import _ "net/http/pprof"

测试CAS操作的基础功能，分别为正常CAS，指定边界和跨度的递增和递减。

* 测试ChubbyGo的功能是否ok. */