createClient上次执行了一半,此次一口气说完剩下的。 node
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ 函数
c->fd = fd;
//记录句柄号
//自定义检查点: 1 2 3
c->name = NULL;
//自定义检查点: 1 2 3
c->bufpos = 0;
//自定义检查点: 1 2 3
c->querybuf = sdsempty();
//自定义检查点: 1 2 3
c->querybuf_peak = 0;
//自定义检查点: 1 2 3
c->reqtype = 0;
//自定义检查点: 1 2 3
c->argc = 0;
//自定义检查点: 1 2 3
c->argv = NULL;
//自定义检查点: 1 2 3
c->cmd = c->lastcmd = NULL;
//自定义检查点: 1 2 3
c->multibulklen = 0;
//自定义检查点: 1 2 3
c->bulklen = -1;
//自定义检查点: 1 2 3
c->sentlen = 0;
//自定义检查点: 1 2 3
c->flags = 0;
//自定义检查点: 1 2 3
c->ctime = c->lastinteraction = server.unixtime;
//自定义检查点: 1 2 3
c->authenticated = 0;
//自定义检查点: 1 2 3
c->replstate = REDIS_REPL_NONE;
//自定义检查点: 1 2 3 unix
c->reploff = 0;
//自定义检查点: 1 2 3
c->repl_ack_off = 0;
//自定义检查点: 1 2 3
c->repl_ack_time = 0;
//自定义检查点: 1 2 3
c->slave_listening_port = 0;
//自定义检查点: 1 2 3
c->reply = listCreate();
//自定义检查点: 1 2 3
c->reply_bytes = 0;
//自定义检查点: 1 2 3
c->obuf_soft_limit_reached_time = 0;
//自定义检查点: 1 2 3
listSetFreeMethod(c->reply,decrRefCountVoid);
//自定义检查点: 1 2 3
listSetDupMethod(c->reply,dupClientReplyValue);
//自定义检查点: 1 2 3
c->bpop.keys = dictCreate(&setDictType,NULL);
//自定义检查点: 1 2 3
c->bpop.timeout = 0;
//自定义检查点: 1 2 3
c->bpop.target = NULL;
//自定义检查点: 1 2 3
c->io_keys = listCreate();
//自定义检查点: 1 2 3
c->watched_keys = listCreate();
//自定义检查点: 1 2 3
listSetFreeMethod(c->io_keys,decrRefCountVoid);
//自定义检查点: 1 2 3
c->pubsub_channels = dictCreate(&setDictType,NULL);
//自定义检查点: 1 2 3
c->pubsub_patterns = listCreate();
//自定义检查点: 1 2 3
listSetFreeMethod(c->pubsub_patterns,decrRefCountVoid);
//自定义检查点: 1 2 3
listSetMatchMethod(c->pubsub_patterns,listMatchObjects);
//自定义检查点: 1 2 3 server
这些都没什么好说的。 get
后面的代码是: cmd
listAddNodeTail,咱们来研究代码,发现是构造一个listnode类型节点 qt
这个node.value为C it
而后将这个node增长到server.clients中去 io
~~~~~~~~~~~~~~ ast
最后看一个函数initClientMultiState很简单。
至此,createClient函数结束,回到acceptCommonHandler。
这个函数剩下的代码比较简单,就不说了。
这样,函数acceptCommonHandler就结束了。
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
回到acceptTcpHandler函数,这个函数也执行完了。
因而就回到了aeProcessEvents
预知后事如何,且听下回分解!