Chinaunix首页 | 论坛 | 博客
  • 博客访问: 183115
  • 博文数量: 67
  • 博客积分: 0
  • 博客等级: 民兵
  • 技术积分: 622
  • 用 户 组: 普通用户
  • 注册时间: 2014-11-19 19:12
文章分类

全部博文(67)

分类: C/C++

2014-11-19 19:51:12

switch_core_init_and_modload()

函数原型如下:

SWITCH_DECLARE(switch_status_t)

switch_core_init_and_modload(switch_core_flag_tflags, switch_bool_t console, const char **err)

其中,windows下展开为 #define SWITCH_DECLARE(type) __declspec(dllexport) type __stdcall

linux展开#define SWITCH_DECLARE(type) type

windows下该宏主要用于将函数声明为dll的导出符号,这样,在其他模块中,便可以使用该函数了。其他系统平台上,例如在linux下,共享库的符号是全局的,不需要声明为导出符号。一般来说,freeswitch其他的动态加载模块所定义的函数不需要用该宏声明,在windows平台下,各个模块之间是隔离的,而核心模块中定义的函数大部分使用了该宏声明,因为其他模块需要大量使用核心模块中的核心函数,这里所指的核心模块是FreeSwitchCoreLib共享对象。

于是可以知道,switch_core_init_and_modload()函数可以在其他依赖于核心模块的动态加载模块中使用,这里主函数所在的模块是FreeSwitchConsole,依赖于核心模块,于是,便可以使用该函数来完成模块加载。

 

switch_core_init()

用来初始化一些全局化的信息,包括一个全局的switch_runtime结构,各种全局的哈希表,互斥变量。

①  全局的switch_runtime结构runtime部分字段的初始化——

     if(runtime.runlevel > 0) {

         returnSWITCH_STATUS_SUCCESS;

     }

     runtime.runlevel++;//从这里可见,runlevel大于0是一个服务器已启动的标志

     .........

接下来又重新初始化了一遍apr库,why?

     if(apr_initialize() != SWITCH_STATUS_SUCCESS) {

         *err = "FATALERROR! Could not initialize APR\n";

         returnSWITCH_STATUS_MEMERR;

     }

}//从这里可以看见,全局的runtime是有一个内存池来管理它所需要的其他资源的。

②  安装时的目录信息的相关设置

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.base_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//主目录,即工程所在目录,一般为./bin,./表示安装路径

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.mod_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//模块所在目录,一般为安装目录./mod,./表示安装路径

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.conf_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//配置文件所在目录,一般为./conf

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.log_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//日志所在的目录。一般为./log

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.run_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//进程文件所在目录,一般为./run,进程文件为freeswitch.pid

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.db_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//数据库文件所在目录,一般为./db

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.script_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//脚本文件所在目录,一般为./script,存放系统需要执行的脚本文件,

//比较常用的由javascript脚本和lua脚本。

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.htdocs_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.grammar_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.recordings_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//录音文件所在目录

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.sounds_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//声音文件所在目录。

switch_dir_make_recursive(SWITCH_GLOBAL_dirs.temp_dir,SWITCH_DEFAULT_DIR_PERMS, runtime.memory_pool);//临时目录。

③     全局的互斥变量和哈希表初始化

④     系统相关的很重要的初始化

1.       switch_core_set_globals()

由于在主函数中已经设置好了各个安装目录,所以此次调用将不做任何实际意义的工作。

2.       switch_core_session_init(runtime.memory_pool)

3.       load_mime_types()

4.       gethostname(hostname, sizeof(hostname))获取主机名

5.       switch_find_local_ip(guess_ip,sizeof(guess_ip), &mask, AF_INET)获取主机的ip地址。这里主要是获取ipv4的地址。

6.        switch_console_init(runtime.memory_pool)初始化控制台。

7.       switch_event_init(runtime.memory_pool)初始化freeswitch整个系统的事件机制,这个初始化很重要,在函数内部除了初始化一些互斥量,哈希队列,还创建了三个用于事件循环的队列,然后启动三个线程,分别代表了三个队列的时间循环处理线程。而所有的资源,都有runtime.memory_pool进行管理,event事件的循环处理见后续分析。

8.       switch_xml_init(runtime.memory_pool,err)进行xml配置文件相关的初始化。

9.       switch_log_init(runtime.memory_pool,runtime.colorize_console)日志系统的初始化。

10.    switch_load_core_config("switch.conf")读取全局的配置文件,然后根据该配置文件中的指令,依次读取后续的子目录下面的各个配置文件,详见后续分析。

11.    switch_core_state_machine_init(runtime.memory_pool)state_machine是整个FS系统的核心部位了,即通话状态机,根据各个channel的状态执行相应的状态处理函数,见后续分析。此处的函数为空函数。

12.    switch_core_sqldb_start()sql数据库的相关初始化。

13.    switch_rtp_init(runtime.memory_pool)rtp协议的初始化。函数内调用srtp_init()初始化rtp协议栈,freeswitch所用的rtp库是libsrtp。

14.    switch_scheduler_add_task(switch_epoch_time_now(NULL),heartbeat_callback, "heartbeat", "core", 0, NULL, SSHF_NONE |SSHF_NO_DEL)

在freeswitch中有一个task调度机制,这里讲heartbeat加入到task队列中。事件由

switch_scheduler_task_container_t结构描述,在switch_scheduler.c中,通过全局的

static struct {

switch_scheduler_task_container_t*task_list;

switch_mutex_t*task_mutex;

uint32_t task_id;

int task_thread_running;

switch_memory_pool_t *memory_pool;

} globals;

 

Globals变量对task队列进行管理。Task的调度的线程也是在switch_core_init()中启动的,具体的启动函数时switch_scheduler_task_thread_start().该函数内部生成的线程主函数为switch_scheduler_task_thread():函数里有主循环;

        while (globals.task_thread_running == 1) {

         if(task_thread_loop(0)) {

              break;

         }

         switch_yield(500000);

}通过层层剥离,会进入task_thread_loop中一次执行挂接在switch_scheduler.c中得全局globals的task队列。

 

switch_loadable_module_init()

根据目录信息加载各个动态模块。

函数内根据平台做了相关处理,在win32平台下,还需要通过函数switch_loadable_module_path_init()获取环境变量的相关信息。另外需要注意的是,该函数内部重新重新生成了一个memory_pool不再是上面描述的runtime的memory_pool了。代码如下:

switch_core_new_memory_pool(&loadable_modules.pool);

其中loadable_modules是一个文件作用域范围的全局量,

static structswitch_loadable_module_container loadable_modules;类型为

switch_loadable_module_container,定义如下:

//************* switch_loadable_module_container的定义*****************************//

structswitch_loadable_module_container {

switch_hash_t *module_hash;//存放各个模块结构的哈希表指针

switch_hash_t *endpoint_hash;// 存放各个endpoint_interface的哈希表指针

switch_hash_t *codec_hash; // 存放各个codec_interface的哈希表指针

switch_hash_t *dialplan_hash; // 存放各个diaplan_interface的哈希表指针

switch_hash_t *timer_hash;// // 存放各个计时器的哈希表指针

switch_hash_t *application_hash;//存放各个application_interface的哈希表指针

switch_hash_t *api_hash; // 存放各个api_interface的哈希表指针

switch_hash_t *file_hash;

switch_hash_t *speech_hash;

switch_hash_t *asr_hash;

switch_hash_t *directory_hash;

switch_hash_t *chat_hash;

switch_hash_t *say_hash;

switch_hash_t *management_hash;

switch_mutex_t *mutex;//全局互斥量

switch_memory_pool_t *pool;//用于模块相关的apr内存池

};

该结构包含了若该的哈希表指针,分别指向存放各个接口结构的哈希表。

//***********************************************************************************//

接下来函数初始化了用于存放各个接口的哈希表,以及全局互斥量。

该函数是通过switch_loadable_module_load_module_ex((char *) SWITCH_GLOBAL_dirs.mod_dir, (char *) val, SWITCH_FALSE, global, &err)函数加载模块的。可见这里使用到了模块的目录信息SWITCH_GLOBAL_dirs.mod_dir。

 

switch_loadable_module_load_module_ex()

函数原型为:

static switch_status_t switch_loadable_module_load_module_ex(char *dir, char*fname, switch_bool_t runtime, switch_bool_t global, constchar **err)

这里讲该函数顶定义成了一个static类型,只能在本文件中被调用。dir是上面个传下来的目录信息,fname是读取配置文件得到的需要加载的动态对象名(例如mod_conference.dll,mod_sofia.dll或mod_conference.so,mod_sofia.so等)

 

在该函数中,通过以下两个函数完成动态对象的加载:

1.  switch_loadable_module_load_file(path,file, global, &new_module),这里我是用了调用时的实参,globals并非上面提出的全局管理结构,而是一个SWITCH_STATUS的枚举对象。Path是加上了路径的完整文件名,而file仍然是配置文件中取得的名称。New_module是一个秒速模块的结构对象,具体的类型为

a)   struct switch_loadable_module {

b)        char *key;

c)        char*filename;

d)        int perm;

e)        switch_loadable_module_interface_t*module_interface;

f)        switch_dso_lib_t lib;

g)        switch_module_load_t switch_module_load;

h)        switch_module_runtime_tswitch_module_runtime;

i)        switch_module_shutdown_tswitch_module_shutdown;

j)        switch_memory_pool_t *pool;

k)        switch_status_t status;

l)        switch_thread_t *thread;

m)        switch_bool_t shutting_down;

n)        calltime_t *time_record;

o)   };

在switch_loadable_module_load_module_ex函数的开始出定义 

switch_loadable_module_t*new_module = NULL;

在switch_loadable_module_load_file函数中,会为每一个模块生成一个资源池

switch_core_new_memory_pool(&pool);

2.  switch_loadable_module_process(file,new_module)函数主要是将new_module以及module中定义的各个接口结构加入全局哈希表,在插入哈希表的过程中,由loadable_modules.mutex进行临界保护,举例如下:

①   switch_core_hash_insert(loadable_modules.module_hash, key,new_module);//将new_module

//插入loadable_modules.module_hash指向的哈希表。

②   if (new_module->module_interface->endpoint_interface){

constswitch_endpoint_interface_t *ptr;

          for (ptr =new_module->module_interface->endpoint_interface; ptr; ptr =ptr->next) {

switch_core_hash_insert(loadable_modules.endpoint_hash,ptr->interface_name, (const void *) ptr);

}//end if

//若new_module的module_interface中包含endpoint_interface,则将该endpoint_interface插入全局的endpoint_interface哈希表。

至此,模块加载也结束了。各个模块加载后各自进入自己的主线程中循环处理。

阅读(2022) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~