Chinaunix首页 | 论坛 | 博客

hjun119620的CU博客

首页　| 　博文目录　| 　关于我

hjun119620

  • 博客访问： 96861
  • 博文数量： 31
  • 博客积分： 0
  • 博客等级： 民兵
  • 技术积分： 380
  • 用 户 组： 普通用户
  • 注册时间： 2014-02-24 22:04
文章分类

全部博文（31）

文章存档

2014年（31）

我的朋友
最近访客
推荐博文
相关博文
Fdfs_trackerd.c文件分析

分类： C/C++

2014-07-21 13:20:42


Fdfs_trackerd.c文件中tracker的运行函数架构
main
|-----log_init，getExeAbsoluteFilename
|-----tracker_load_from_conf_file
|-----tracker_load_status_from_file
|-----base64_init_ex
|-----tracker_mem_init
|-----socketServer
|-----tcpsetserveropt
|-----daemon_init
|-----tracker_service_init
|-----sigUsrHandler，sigHupHandler，sigQuitHandler，sigDumpHandler
|-----tracker_httpd_start
|-----tracker_http_check_start
|-----set_run_by
|-----sched_start
|-----tracker_accept_loop
|-----tracker_terminate_threads,tracker_http_check_stop
|-----tracker_mem_destroy,tracker_service_destroy,log_destroy


通过tracker目录下的Fdfs_trackerd.c文件，可以分析出tracker的执行流程

点击(此处)折叠或打开

  1. int main(int argc, char *argv[])
  2. {
  3.     char *conf_filename;   //配置文件名称
  4.     int result;
  5.     int sock;   //sock id
  6.     pthread_t schedule_tid;
  7.     struct sigaction act;  //信号
  8.     ScheduleEntry scheduleEntries[SCHEDULE_ENTRIES_COUNT];
  9.     ScheduleArray scheduleArray;

  11.     if (argc < 2)
  12.     {
  13.         printf("Usage: %s \n", argv[0]);
  14.         return 1;
  15.     }

  17.     g_up_time = time(NULL);
  18.     log_init();

  20. #if defined(DEBUG_FLAG) && defined(OS_LINUX)
  21.     if (getExeAbsoluteFilename(argv[0], g_exe_name, \    //获取配置文件的绝对路径名
  22.         sizeof(g_exe_name)) == NULL)
  23.     {
  24.         log_destroy();
  25.         return errno != 0 ? errno : ENOENT;
  26.     }
  27. #endif

  29.     conf_filename = argv[1];    //tracker的配置文件
  30.     memset(bind_addr, 0, sizeof(bind_addr));
  31.     if ((result=tracker_load_from_conf_file(conf_filename, \   //解析配置文件，初始化全局参数
  32.             bind_addr, sizeof(bind_addr))) != 0)
  33.     {
  34.         log_destroy();
  35.         return result;
  36.     }

  38.     if ((result=tracker_load_status_from_file(&g_tracker_last_status)) != 0)    //从状态文件中读取状态信息
  39.     {
  40.         log_destroy();
  41.         return result;
  42.     }

  44.     base64_init_ex(&g_base64_context, 0, '-', '_', '.');    //
  45.     if ((result=set_rand_seed()) != 0)
  46.     {
  47.         logCrit("file: "__FILE__", line: %d, " \
  48.             "set_rand_seed fail, program exit!", __LINE__);
  49.         return result;
  50.     }

  52.     if ((result=tracker_mem_init()) != 0)    //所有的空间分配操作，数据读取操作，锁的初始化操作
  53.     {
  54.         log_destroy();
  55.         return result;
  56.     }
  57.     
  58.     sock = socketServer(bind_addr, g_server_port, &result);    //创建socket，绑定，监听
  59.     if (sock < 0)
  60.     {
  61.         log_destroy();
  62.         return result;
  63.     }
  64.     
  65.     if ((result=tcpsetserveropt(sock, g_fdfs_network_timeout)) != 0)  //设定socket的选项
  66.     {
  67.         log_destroy();
  68.         return result;
  69.     }

  71.     daemon_init(true);    //使该进程成功一个守护进程
  72.     umask(0);    //重设文件掩码
  73.     
  74.     if (dup2(g_log_context.log_fd, STDOUT_FILENO) < 0 || \
  75.         dup2(g_log_context.log_fd, STDERR_FILENO) < 0)
  76.     {
  77.         logCrit("file: "__FILE__", line: %d, " \
  78.             "call dup2 fail, errno: %d, error info: %s, " \
  79.             "program exit!", __LINE__, errno, STRERROR(errno));
  80.         g_continue_flag = false;
  81.         return errno;
  82.     }

  84.     if ((result=tracker_service_init()) != 0)   //初始化tracker service
  85.     {
  86.         log_destroy();
  87.         return result;
  88.     }
  89.     
  90.     memset(&act, 0, sizeof(act));   //初始化信号内存
  91.     sigemptyset(&act.sa_mask);

  93.     act.sa_handler = sigUsrHandler;   //设置信号SIGUSR1与SIGUSR2的处理程序
  94.     if(sigaction(SIGUSR1, &act, NULL) < 0 || \
  95.         sigaction(SIGUSR2, &act, NULL) < 0)
  96.     {
  97.         logCrit("file: "__FILE__", line: %d, " \
  98.             "call sigaction fail, errno: %d, error info: %s", \
  99.             __LINE__, errno, STRERROR(errno));
  100.         return errno;
  101.     }

  103.     act.sa_handler = sigHupHandler;  //设置信号SIGHUP的处理程序
  104.     if(sigaction(SIGHUP, &act, NULL) < 0)
  105.     {
  106.         logCrit("file: "__FILE__", line: %d, " \
  107.             "call sigaction fail, errno: %d, error info: %s", \
  108.             __LINE__, errno, STRERROR(errno));
  109.         return errno;
  110.     }
  111.     
  112.     act.sa_handler = SIG_IGN;     //设置信号SIGPIPE的处理程序
  113.     if(sigaction(SIGPIPE, &act, NULL) < 0)
  114.     {
  115.         logCrit("file: "__FILE__", line: %d, " \
  116.             "call sigaction fail, errno: %d, error info: %s", \
  117.             __LINE__, errno, STRERROR(errno));
  118.         return errno;
  119.     }

  121.     act.sa_handler = sigQuitHandler;    //设置信号SIGINT的处理程序
  122.     if(sigaction(SIGINT, &act, NULL) < 0 || \
  123.         sigaction(SIGTERM, &act, NULL) < 0 || \
  124.         sigaction(SIGQUIT, &act, NULL) < 0)
  125.     {
  126.         logCrit("file: "__FILE__", line: %d, " \
  127.             "call sigaction fail, errno: %d, error info: %s", \
  128.             __LINE__, errno, STRERROR(errno));
  129.         return errno;
  130.     }

  132. #if defined(DEBUG_FLAG)
  133. /*
  134. #if defined(OS_LINUX)
  135.     memset(&act, 0, sizeof(act));
  136.     sigemptyset(&act.sa_mask);
  137.         act.sa_sigaction = sigSegvHandler;
  138.         act.sa_flags = SA_SIGINFO;
  139.         if (sigaction(SIGSEGV, &act, NULL) < 0 || \   //设置信号SIGSEGV与SIGABRT的处理程序
  140.             sigaction(SIGABRT, &act, NULL) < 0)
  141.     {
  142.         logCrit("file: "__FILE__", line: %d, " \
  143.             "call sigaction fail, errno: %d, error info: %s", \
  144.             __LINE__, errno, STRERROR(errno));
  145.         return errno;
  146.     }
  147. #endif
  148. */

  150.     memset(&act, 0, sizeof(act));
  151.     sigemptyset(&act.sa_mask);
  152.     act.sa_handler = sigDumpHandler;
  153.     if(sigaction(SIGUSR1, &act, NULL) < 0 || \
  154.         sigaction(SIGUSR2, &act, NULL) < 0)
  155.     {
  156.         logCrit("file: "__FILE__", line: %d, " \
  157.             "call sigaction fail, errno: %d, error info: %s", \
  158.             __LINE__, errno, STRERROR(errno));
  159.         return errno;
  160.     }
  161. #endif

  163. #ifdef WITH_HTTPD   //http设置
  164.     if (!g_http_params.disabled)  
  165.     {
  166.         if ((result=tracker_httpd_start(bind_addr)) != 0)
  167.         {
  168.             logCrit("file: "__FILE__", line: %d, " \
  169.                 "tracker_httpd_start fail, program exit!", \
  170.                 __LINE__);
  171.             return result;
  172.         }

  174.     }

  176.     if ((result=tracker_http_check_start()) != 0)
  177.     {
  178.         logCrit("file: "__FILE__", line: %d, " \
  179.             "tracker_http_check_start fail, " \
  180.             "program exit!", __LINE__);
  181.         return result;
  182.     }
  183. #endif

  185.     if ((result=set_run_by(g_run_by_group, g_run_by_user)) != 0)   //设置用户启动组与启动用户
  186.     {
  187.         log_destroy();
  188.         return result;
  189.     }

  191.     scheduleArray.entries = scheduleEntries;   //初始化调度数组
  192.     scheduleArray.count = SCHEDULE_ENTRIES_COUNT;

  194.     memset(scheduleEntries, 0, sizeof(scheduleEntries));
  195.     scheduleEntries[0].id = 1;
  196.     scheduleEntries[0].time_base.hour = TIME_NONE;
  197.     scheduleEntries[0].time_base.minute = TIME_NONE;
  198.     scheduleEntries[0].interval = g_sync_log_buff_interval;
  199.     scheduleEntries[0].task_func = log_sync_func;  //处理函数
  200.     scheduleEntries[0].func_args = &g_log_context;  //参数

  202.     scheduleEntries[1].id = 2;
  203.     scheduleEntries[1].time_base.hour = TIME_NONE;
  204.     scheduleEntries[1].time_base.minute = TIME_NONE;
  205.     scheduleEntries[1].interval = g_check_active_interval;
  206.     scheduleEntries[1].task_func = tracker_mem_check_alive;
  207.     scheduleEntries[1].func_args = NULL;

  209.     scheduleEntries[2].id = 3;
  210.     scheduleEntries[2].time_base.hour = 0;
  211.     scheduleEntries[2].time_base.minute = 0;
  212.     scheduleEntries[2].interval = TRACKER_SYNC_STATUS_FILE_INTERVAL;
  213.     scheduleEntries[2].task_func = tracker_write_status_to_file;
  214.     scheduleEntries[2].func_args = NULL;
  215.     if ((result=sched_start(&scheduleArray, &schedule_tid, \  //调度开始
  216.         g_thread_stack_size, &g_continue_flag)) != 0) 
  217.     {
  218.         log_destroy();
  219.         return result;
  220.     }

  222.     log_set_cache(true);

  224.     bTerminateFlag = false;
  225.     bAcceptEndFlag = false;

  227.     tracker_accept_loop(sock);   //开始接受连接请求
  228.     bAcceptEndFlag = true;
  229.     if (g_schedule_flag)
  230.     {
  231.         pthread_kill(schedule_tid, SIGINT);//发送SIGINT信号
  232.     }
  233.     tracker_terminate_threads();

  235. #ifdef WITH_HTTPD
  236.     if (g_http_check_flag)
  237.     {
  238.         tracker_http_check_stop();
  239.     }

  241.     while (g_http_check_flag)
  242.     {
  243.         usleep(50000);
  244.     }
  245. #endif

  247.     while ((g_tracker_thread_count != 0) || g_schedule_flag)
  248.     {

  250. /*
  251. #if defined(DEBUG_FLAG) && defined(OS_LINUX)
  252.         if (bSegmentFault)
  253.         {
  254.             sleep(5);
  255.             break;
  256.         }
  257. #endif
  258. */

  260.         usleep(50000);
  261.     }
  262.     
  263.     tracker_mem_destroy();  //清理内存
  264.     tracker_service_destroy();    //清理服务
  265.     
  266.     logInfo("exit nomally.\n");
  267.     log_destroy();  //清理日志
  268.     
  269.     return 0;
  270. }


函数执行步骤如下：
（1） 日志系统初始化，调用函数log_init，并获取配置文件的绝对文件名称，调用函数getExeAbsoluteFilename
（2） 从配置文件中读取配置数据，并初始化全局变量，调用函数tracker_load_from_conf_file
（3） 从状态配置文件中读取状态数据，并初始化全局变量，调用函数tracker_load_status_from_file
（4） 调用base64_init_ex函数，初始化g_base64_context变量
（5） 初始化所需要的内存与锁，调用函数tracker_mem_init
（6） 创建socket，调用函数socketServer
（7） 设置socket，调用函数tcpsetserveropt
（8） 使进程变成守护进程，调用函数daemon_init
（9） 初始化tracker service，调用函数tracker_service_init
（10）设定信号处理函数
（11）启动http服务，调用函数tracker_httpd_start
（12）tracker_http_check_start
（13）设置运行用户与用户组，调用函数set_run_by
（14）调度进程启动，调用函数sched_start
（15）主循环启动，调用函数tracker_accept_loop
（16）清理

阅读(1383) | 评论(0) | 转发(0) |
0

上一篇：IO事件的执行流程

下一篇：第二步：tracker读取配置文件(part 4)--getFileContent函数分析

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6