redis源码之main()函数剖析

今天看了redis的源码之中的main()函数,将大概的流程进行梳理。

在代码中进行了相应的注释,便于阅读者理解:

int main(int argc, char **argv) {struct timeval tv;int j;#ifdef REDIS_TESTif (argc == 3 && !strcasecmp(argv[1], "test")) {if (!strcasecmp(argv[2], "ziplist")) {return ziplistTest(argc, argv);} else if (!strcasecmp(argv[2], "quicklist")) {quicklistTest(argc, argv);} else if (!strcasecmp(argv[2], "intset")) {return intsetTest(argc, argv);} else if (!strcasecmp(argv[2], "zipmap")) {return zipmapTest(argc, argv);} else if (!strcasecmp(argv[2], "sha1test")) {return sha1Test(argc, argv);} else if (!strcasecmp(argv[2], "util")) {return utilTest(argc, argv);} else if (!strcasecmp(argv[2], "sds")) {return sdsTest(argc, argv);} else if (!strcasecmp(argv[2], "endianconv")) {return endianconvTest(argc, argv);} else if (!strcasecmp(argv[2], "crc64")) {return crc64Test(argc, argv);} else if (!strcasecmp(argv[2], "zmalloc")) {return zmalloc_test(argc, argv);}return -1; /* test not found */}
#endif/* We need to initialize our libraries, and the server configuration. */
#ifdef INIT_SETPROCTITLE_REPLACEMENTspt_init(argc, argv);
#endifsetlocale(LC_COLLATE,"");  //更改字符编码tzset(); /* Populates 'timezone' global. */// oom时的处理,主要是内存不足时,将需要的memory的值打印出来zmalloc_set_oom_handler(redisOutOfMemoryHandler);// 根据当前时间和pid获取随机值的srand(time(NULL)^getpid());gettimeofday(&tv,NULL);  // 1970年1月1日到现在的时间char hashseed[16];//获取哈希种子getRandomHexChars(hashseed,sizeof(hashseed));dictSetHashFunctionSeed((uint8_t*)hashseed);// 服务器的启动模式:单机模式、Cluster模式、sentinel模式server.sentinel_mode = checkForSentinelMode(argc,argv);// 服务器端的配置initServerConfig();ACLInit(); /* The ACL subsystem must be initialized ASAP because thebasic networking code and client creation depends on it. */moduleInitModulesSystem();/* Store the executable path and arguments in a safe place in order* to be able to restart the server later. */server.executable = getAbsolutePath(argv[0]);server.exec_argv = zmalloc(sizeof(char*)*(argc+1));server.exec_argv[argc] = NULL;for (j = 0; j < argc; j++) server.exec_argv[j] = zstrdup(argv[j]);/* We need to init sentinel right now as parsing the configuration file* in sentinel mode will have the effect of populating the sentinel* data structures with master nodes to monitor. */// sentinel模式下的配置if (server.sentinel_mode) {initSentinelConfig();initSentinel();}/* Check if we need to start in redis-check-rdb/aof mode. We just execute* the program main. However the program is part of the Redis executable* so that we can easily execute an RDB check on loading errors. */// 持久化的两种方式if (strstr(argv[0],"redis-check-rdb") != NULL)// 定期的将数据dump到磁盘中redis_check_rdb_main(argc,argv,NULL);else if (strstr(argv[0],"redis-check-aof") != NULL)// 通过aof记录事务执行的每个命令,便于数据的恢复redis_check_aof_main(argc,argv);// 帮助信息if (argc >= 2) {j = 1; /* First option to parse in argv[] */sds options = sdsempty();char *configfile = NULL;/* Handle special options --help and --version */if (strcmp(argv[1], "-v") == 0 ||strcmp(argv[1], "--version") == 0) version();if (strcmp(argv[1], "--help") == 0 ||strcmp(argv[1], "-h") == 0) usage();if (strcmp(argv[1], "--test-memory") == 0) {if (argc == 3) {memtest(atoi(argv[2]),50);exit(0);} else {fprintf(stderr,"Please specify the amount of memory to test in megabytes.\n");fprintf(stderr,"Example: ./redis-server --test-memory 4096\n\n");exit(1);}}/* First argument is the config file name? */if (argv[j][0] != '-' || argv[j][1] != '-') {configfile = argv[j];server.configfile = getAbsolutePath(configfile);/* Replace the config file in server.exec_argv with* its absolute path. */zfree(server.exec_argv[j]);server.exec_argv[j] = zstrdup(server.configfile);j++;}/* All the other options are parsed and conceptually appended to the* configuration file. For instance --port 6380 will generate the* string "port 6380\n" to be parsed after the actual file name* is parsed, if any. */while(j != argc) {if (argv[j][0] == '-' && argv[j][1] == '-') {/* Option name */if (!strcmp(argv[j], "--check-rdb")) {/* Argument has no options, need to skip for parsing. */j++;continue;}if (sdslen(options)) options = sdscat(options,"\n");options = sdscat(options,argv[j]+2);options = sdscat(options," ");} else {/* Option argument */options = sdscatrepr(options,argv[j],strlen(argv[j]));options = sdscat(options," ");}j++;}if (server.sentinel_mode && configfile && *configfile == '-') {serverLog(LL_WARNING,"Sentinel config from STDIN not allowed.");serverLog(LL_WARNING,"Sentinel needs config file on disk to save state.  Exiting...");exit(1);}// 释放内存 resetServerSaveParams();loadServerConfig(configfile,options);sdsfree(options);}serverLog(LL_WARNING, "oO0OoO0OoO0Oo Redis is starting oO0OoO0OoO0Oo");serverLog(LL_WARNING,"Redis version=%s, bits=%d, commit=%s, modified=%d, pid=%d, just started",REDIS_VERSION,(sizeof(long) == 8) ? 64 : 32,redisGitSHA1(),strtol(redisGitDirty(),NULL,10) > 0,(int)getpid());if (argc == 1) {serverLog(LL_WARNING, "Warning: no config file specified, using the default config. In order to specify a config file use %s /path/to/%s.conf", argv[0], server.sentinel_mode ? "sentinel" : "redis");} else {serverLog(LL_WARNING, "Configuration loaded");}server.supervised = redisIsSupervised(server.supervised_mode);int background = server.daemonize && !server.supervised;if (background) daemonize();//sever端的初始化initServer();if (background || server.pidfile) createPidFile();// 设置进程的titleredisSetProcTitle(argv[0]);redisAsciiArt();checkTcpBacklogSettings();// 非sentinel模式if (!server.sentinel_mode) {/* Things not needed when running in Sentinel mode. */serverLog(LL_WARNING,"Server initialized");#ifdef __linux__linuxMemoryWarnings();#endifmoduleLoadFromQueue();ACLLoadUsersAtStartup();// 从磁盘获取已经持久化的数据loadDataFromDisk();if (server.cluster_enabled) {if (verifyClusterConfigWithData() == C_ERR) {serverLog(LL_WARNING,"You can't have keys in a DB different than DB 0 when in ""Cluster mode. Exiting.");exit(1);}}if (server.ipfd_count > 0)serverLog(LL_NOTICE,"Ready to accept connections");if (server.sofd > 0)serverLog(LL_NOTICE,"The server is now ready to accept connections at %s", server.unixsocket);} else {// 检测sentinel的配置是否有效sentinelIsRunning();}/* Warning the user about suspicious maxmemory setting. */if (server.maxmemory > 0 && server.maxmemory < 1024*1024) {serverLog(LL_WARNING,"WARNING: You specified a maxmemory value that is less than 1MB (current value is %llu bytes). Are you sure this is what you really want?", server.maxmemory);}// 设置服务器sleep之前的函数调用aeSetBeforeSleepProc(server.el,beforeSleep);// 设置服务器sleep后的函数调用aeSetAfterSleepProc(server.el,afterSleep);// 主函数事件驱动aeMain(server.el);// 删除事件驱动aeDeleteEventLoop(server.el);return 0;
}

阅读了main()函数中的源码之后发现redis居然有OOM机制,内存分配不出来时,将申请的内存打印出来等等。由于本人能力有限只能理解到这里。后续继续分析redis源码。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/463456.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

SQL Server 文件规划 -位置规划

数据库设计中&#xff0c;文件规划是相当重要的一个环节。 这部分内容包括文件数目的规划&#xff0c;大小的规划&#xff0c;位置的规划。 本篇介绍的是文件位置的规划&#xff0c;如下图所示 1. 数据文件 有可能的情况下&#xff0c;应该区分经常更新的表与不经常更新的表。分…

const关键字

const关键字const是constant的简写&#xff0c;只要一个变量前面用const来修饰&#xff0c;就意味着该变量里的数据可以被访问&#xff0c;不能被修改。也就是说const意味着“只读”readonly规则&#xff1a;const离谁近&#xff0c;谁就不能被修改&#xff1b;const修饰一个变…

深入理解计算机系统 第十二章 并发编程

如果逻辑控制流在时间上重叠&#xff0c;那么它们就是并发的&#xff08;concurrent&#xff09; 这种常见的现象称为并发&#xff08;concurrency&#xff09;&#xff0c;出现在计算机系统的许多不同层面上。 并发不仅仅局限于内核&#xff0c;它也可以在应用程序中扮演重要角…

Redis源码分析之小型测试框架testhelp.h和redis-check-aof.c日志检测

使用的是redis 3.2版本 test中的文件主要分为以下几个&#xff1a; 1.memtest.c 内存检测 2.redis_benchmark.c 用于redis性能测试的实现&#xff0c;后续会当做单独的一个章节进行分析 3.redis_check_aof.c 用于更新日志检查的实现。 4.redis_check_dump.c 用于本地数据库检查…

VSTS学习和迁移(1) 安装部署

要将开发环境从SVN到VFS中&#xff0c;下个月开始迁移。 先从WebCast中下载文件&#xff0c;看了安装部署部分。以下为部分截图&#xff1a; 一&#xff1a;课程内容 Team Foundation 的逻辑结构与物理结构 Team Foundation 系统要求 Team Foundation 安装实战 Team Founda…

【HNOI2013】数列

题面 题解 设\(\{a_n\}\)为差分数组&#xff0c;可以得到柿子&#xff1a;\[ \begin{aligned} ans & \sum_{a_1 1} ^ m \sum_{a_2 1} ^ m \cdots \sum_{a_{k-1} 1} ^ m (n - \sum_{i 1} ^ {k - 1} a_i) \\ & nm^{k - 1} - \sum_{a_1 1} ^ m \sum_{a_2 1} ^ m \cd…

程序员的艺术:排序算法舞蹈

1、冒泡排序&#xff1a; 2、希尔排序&#xff1a; 3、选择排序&#xff1a; 4&#xff1a;插入排序&#xff1a; 5、快速排序&#xff1a; 6、归并排序&#xff1a; 转载于:https://www.cnblogs.com/jxgxy/archive/2012/08/20/2648210.html

Redis源码分析之内存检测memtest

redis的内存检测会和机器的CPU位数有关&#xff0c;32位或64位会影响后面的一些宏定义参数。首先给出memtest中的API&#xff1a; void memtest_progress_start(char *title, int pass) /* 内存检测加载开始&#xff0c;输出开始的一些图线显示 */ void memtest_progress_end(…

Java Collections Framework - Java集合框架List,Map,Set等全面介绍之概要篇

deng 转载于:https://www.cnblogs.com/jacktu/archive/2009/05/15/1457316.html

C语言 数据结构 树和二叉树

树 1、树&#xff1a;是n节点的有限集。树是n(n>0)个节点的有限集。 n0时成为空树。 在任意一颗非空树中&#xff1a;&#xff08;1&#xff09;有且仅有一个称为根的节点&#xff1b;&#xff08;2&#xff09;当n>0时&#xff0c;其余节点可分为m(m>0)个互不相交的…

Oracle开启关闭归档日志

开启归档日志 shutdown immediate; --关闭数据库 startup mount; --打开数据库 alter database archivelog; --开启归档日志 alter database open; --开启数据库 archive log list; --查看归档日志是否开启 关闭归档日志 shutdown immediate; --关闭数据库 startup mount; …

Redis源码分析之anet网络通信的封装

anet是redis对tcp/ip网络中socket api接口的一个全面的封装&#xff0c;针对server/client端。封装的api的接口如下&#xff0c;注释了主要的接口&#xff1a; // tcp连接 int anetTcpConnect(char *err, char *addr, int port); // 非阻塞连接 int anetTcpNonBlockConnect(ch…

使用AJAX Toolkit创建新闻列表

我们很多站点上面都需要显示新闻列表&#xff0c;由标题和正文组成的。一般客户都希望实现这样的效果&#xff1a; 开始的时候只是显示标题&#xff0c;当点击标题的时候&#xff0c;再展开正文。再点击&#xff0c;又可缩回去。 这是典型的AJAX效果&#xff0c;或者说以前你也…

C语言 嵌入式 面试小知识点(一)

sizeof是C/C中的一个操作符&#xff08;operator&#xff09;&#xff0c;简单的说其作用就是返回一个对象或者类型所占的内存字节数。 与strlen的区别&#xff1a; 一、sizeof 是运算符&#xff0c;确切的说是一个编译时运算符&#xff0c;参数可以是数组、指针、类型、对象…

将数据渲染到页面的几种方式

将数据渲染到页面的几种方式&#xff1a; 1.字符串拼接&#xff1b; 2.dom回流 3.文档碎片&#xff08;文档碎片节点&#xff1a;documentFragment&#xff09; 4.模板 &#xff08;下章会详细介绍模板&#xff09;转载于:https://www.cnblogs.com/shangjun6/p/1039740…

论证是一门学问

本文的标题借用了安东尼.韦斯顿&#xff08;Anthony Weston&#xff09;的《论证是一门学问》一书的标题&#xff0c;向安东尼老爷子致敬的同时&#xff0c;也希望更多人能够真正了解“什么是论证”。 争论与论证从来都不是新鲜事物&#xff0c;作为软件行业的科技工作者&…

[翻译]SQL Server 工作集消息

Q&#xff1a;我发现有指向工作集&#xff08;SQL Server保留内存区域&#xff09;被分页出来相关的消息&#xff1a; 重要部分的 SQL 服务器进程内存已被分页。这可能导致性能下降。持续时间: 0 秒。 工作集 (KB)&#xff1a; 2484&#xff0c;已提交 (KB)&#xff1a; 48036&…

Redis源码分析之工具类util

在redis源码中的辅助工具类中&#xff0c;主要包括大小端转换、SHA算法以及util.h中对应的算法。 大小端转换&#xff1a; LittleEndian&#xff1a;低位字节数据存放于低地址&#xff0c;高位字节数据存放于高地址。 BigEndian&#xff1a;低位字节数据存放于高地址&#x…

Linux下如何安装软件

一、解析Linux应用软件安装包通常Linux应用软件的安装包有三种&#xff1a;1&#xff09; tar包&#xff0c;如software-1.2.3-1.tar.gz。它是使用UNIX系统的打包工具tar打包的。2&#xff09; rpm包&#xff0c;如software-1.2.3-1.i386.rpm。它是RedHat Linux提供的一种包封装…

Python深浅拷贝辨析

1 import copy2 3 list1 [11, 22, [33, 44]]4 list2 list15 list3 list1[:]6 list4 copy.copy(list1)7 list5 copy.deepcopy(list1)8 9 list1[0] 0 # 对列表的首层做增删改查操作 10 print("list1:",id(list1),list1) # list1: 1455502266696 [0, 22, […