January 2007 - Freeswitch-trunk - FreeSWITCH Mailing Lists

[commit] r4025 - freeswitch/trunk/src/mod/event_handlers/mod_cdr
by Freeswitch SVN 22 Jan '07

22 Jan '07

Author: mishehu Date: Mon Jan 22 18:33:35 2007 New Revision: 4025 Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/csvcdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/curlcdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/xmlcdr.cpp Log: Merged changes from my branch r4024. Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile Mon Jan 22 18:33:35 2007 @@ -1,11 +1,11 @@ -CFLAGS += $(shell mysql_config --include) +#CFLAGS += $(shell mysql_config --include) #CFLAGS += -DSWITCH_QUEUE_ENHANCED -LDFLAGS += $(shell mysql_config --libs) +#LDFLAGS += $(shell mysql_config --libs) #LDFLAGS += -lcurl CPPCC = g++ -OBJS=cdrcontainer.o basecdr.o baseregistry.o mysqlcdr.o pddcdr.o csvcdr.o xmlcdr.o +OBJS=cdrcontainer.o basecdr.o baseregistry.o mysqlcdr.o pddcdr.o csvcdr.o xmlcdr.o sqlitecdr.o all: depends $(OBJS) $(MODNAME).$(DYNAMIC_LIB_EXTEN) Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.cpp Mon Jan 22 18:33:35 2007 @@ -324,7 +324,7 @@ temppair.second = tempvariable; chanvars_fixed.push_back(temppair); - } + } } // This one is for processing of supplemental chanvars Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/csvcdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/csvcdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/csvcdr.cpp Mon Jan 22 18:33:35 2007 @@ -74,8 +74,11 @@ switch_strftime(formattedcalltransferdate,&retsizectd,sizeof(formattedcalltransferdate),format,&tempcalltransfer); switch_strftime(formattedcallenddate,&retsizeced,sizeof(formattedcallenddate),format,&tempcallend); - process_channel_variables(chanvars_fixed_list,newchannel->channel); - process_channel_variables(chanvars_supp_list,chanvars_fixed_list,newchannel->channel,repeat_fixed_in_supp); + if(chanvars_fixed_list.size() > 0) + process_channel_variables(chanvars_fixed_list,newchannel->channel); + + if(chanvars_supp_list.size() > 0) + process_channel_variables(chanvars_supp_list,chanvars_fixed_list,newchannel->channel,repeat_fixed_in_supp); } } Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/curlcdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/curlcdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/curlcdr.cpp Mon Jan 22 18:33:35 2007 @@ -79,8 +79,11 @@ switch_strftime(formattedcalltransferdate,&retsizectd,sizeof(formattedcalltransferdate),format,&tempcalltransfer); switch_strftime(formattedcallenddate,&retsizeced,sizeof(formattedcallenddate),format,&tempcallend); - process_channel_variables(chanvars_fixed_list,newchannel->channel); - process_channel_variables(chanvars_supp_list,chanvars_fixed_list,newchannel->channel,0); + if(chanvars_fixed_list.size() > 0) + process_channel_variables(chanvars_fixed_list,newchannel->channel); + + if(chanvars_supp_list.size() > 0) + process_channel_variables(chanvars_supp_list,chanvars_fixed_list,newchannel->channel,0); } } Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.cpp Mon Jan 22 18:33:35 2007 @@ -79,8 +79,9 @@ outputfile_name.append("."); outputfile_name.append(myuuid); // The goal is to have a resulting filename of "/path/to/myuuid" outputfile_name.append(".pdd"); // .pdd - "perl data dumper" - bool repeat = 1; - process_channel_variables(chanvars_supp_list,chanvars_fixed_list,newchannel->channel,repeat); + bool repeat_fixed_in_supp = 1; + if(chanvars_supp_list.size() > 0) + process_channel_variables(chanvars_supp_list,chanvars_fixed_list,newchannel->channel,repeat_fixed_in_supp); } } Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/xmlcdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/xmlcdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/xmlcdr.cpp Mon Jan 22 18:33:35 2007 @@ -80,8 +80,10 @@ outputfile_name.append(myuuid); // The goal is to have a resulting filename of "/path/to/myuuid" outputfile_name.append(".xml"); // .xml - "XML Data Dumper" - bool repeat = 1; - process_channel_variables(chanvars_supp_list,chanvars_fixed_list,newchannel->channel,repeat); + bool repeat_fixed_in_supp = 1; + + if(chanvars_supp_list.size() > 0) + process_channel_variables(chanvars_supp_list,chanvars_fixed_list,newchannel->channel,repeat_fixed_in_supp); } }

1 0

[commit] r4023 - freeswitch/trunk/src/mod/event_handlers/mod_cdr
by Freeswitch SVN 22 Jan '07

22 Jan '07

Author: mishehu Date: Mon Jan 22 17:08:13 2007 New Revision: 4023 Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile Log: Commented out the CFLAGS in mod_cdr for using my apr_queue enhancements by default. Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile Mon Jan 22 17:08:13 2007 @@ -1,6 +1,6 @@ CFLAGS += $(shell mysql_config --include) -CFLAGS += -DSWITCH_QUEUE_ENHANCED +#CFLAGS += -DSWITCH_QUEUE_ENHANCED LDFLAGS += $(shell mysql_config --libs) #LDFLAGS += -lcurl

1 0

[commit] r4022 - freeswitch/trunk/src/mod/event_handlers/mod_cdr
by Freeswitch SVN 22 Jan '07

22 Jan '07

Author: mishehu Date: Mon Jan 22 17:03:56 2007 New Revision: 4022 Added: freeswitch/trunk/src/mod/event_handlers/mod_cdr/curlcdr.cpp - copied unchanged from r4020, /freeswitch/branches/mishehu/src/mod/event_handlers/mod_cdr/curlcdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/curlcdr.h - copied unchanged from r4020, /freeswitch/branches/mishehu/src/mod/event_handlers/mod_cdr/curlcdr.h freeswitch/trunk/src/mod/event_handlers/mod_cdr/sqlitecdr.cpp - copied unchanged from r4020, /freeswitch/branches/mishehu/src/mod/event_handlers/mod_cdr/sqlitecdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/sqlitecdr.h - copied unchanged from r4020, /freeswitch/branches/mishehu/src/mod/event_handlers/mod_cdr/sqlitecdr.h Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile freeswitch/trunk/src/mod/event_handlers/mod_cdr/README freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.h freeswitch/trunk/src/mod/event_handlers/mod_cdr/csvcdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/mysqlcdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/mysqlcdr.h freeswitch/trunk/src/mod/event_handlers/mod_cdr/odbccdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.cpp freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.h freeswitch/trunk/src/mod/event_handlers/mod_cdr/schema.sql freeswitch/trunk/src/mod/event_handlers/mod_cdr/xmlcdr.cpp Log: Merged changes in from my branch at r4020. Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/Makefile Mon Jan 22 17:03:56 2007 @@ -1,6 +1,8 @@ CFLAGS += $(shell mysql_config --include) +CFLAGS += -DSWITCH_QUEUE_ENHANCED LDFLAGS += $(shell mysql_config --libs) +#LDFLAGS += -lcurl CPPCC = g++ OBJS=cdrcontainer.o basecdr.o baseregistry.o mysqlcdr.o pddcdr.o csvcdr.o xmlcdr.o Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/README ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/README (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/README Mon Jan 22 17:03:56 2007 @@ -82,6 +82,14 @@ <param name="chanvars_supp" value=""/> value is a comma separated list of supplemental channel variables to log. Can be a wildcard (*) (optional) <param name="chanvars_supp_repeat_fixed" value=""/> value is 0 for no, 1 for yes, and determines whether or not to repeat any of the fixed channel variables as key / value pairs in the chanvars table. <param name="timezone" value=""/> value is utc for utc time, local for localtime. If not specified or incorrectly specified, localtime is assumed. + +Class: SqliteCDR, located in sqlitecdr.h and sqlitecdr.cpp + This class uses the Sqlite3 library as included with FreeSWITCH's core. Sqlite is not strict in its handling of column types, and in theory you can toss any sort of data at any sort of column. That being said, this logger was designed to at least attempt to match the column types to the type of data being sent to it. It will warn you if the schema does not match what chanvars_fixed types you specify, but it will not fail on them. However, due to the use of prepared statements, it is likely that you will have unexpected results if you mismatch your chanvars_fixed logging to db schema. The is the first SQL logger to automatically create the db schema and even update it on its own. +Configuration: Section <sqlitecdr> + <param name="path" value=""/> value is the path to the database to open or create (required) + <param name="chanvars_fixed" value=""/> Is a comma separated list of key=type pairs. Types are x for decimal, s for string (varchar), d for double, i for integer, t for tiny. If no type is provided, it defaults that column to string (varchar). It cannot accept wildcards (*). You must have a matching column of matching type in the main freeswitchcdr table. The logger will attempt to automatically update the schema, but it cannot if a column by that name already exists.(optional) + <param name="chanvars_supp" value=""/> value is a comma separated list of supplemental channel variables to log. Can be a wildcard (*) (optional) + <param name="chanvars_supp_repeat_fixed" value=""/> value is 0 for no, 1 for yes, and determines whether or not to repeat any of the fixed channel variables as key / value pairs in the chanvars table. FAQ: Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.cpp Mon Jan 22 17:03:56 2007 @@ -60,6 +60,7 @@ if(newchannel != 0) { errorstate = 0; + originated=1; // One-legged calls are always considered the originator memset(clid,0,80); memset(dialplan,0,80); memset(myuuid,0,37); @@ -132,7 +133,6 @@ // Or were we maybe we were the caller? if(newchannel->callerprofile->originatee_caller_profile) { - originated = 1; if (newchannel->callerprofile) { if(newchannel->callerprofile->caller_id_number != 0) strncpy(src,newchannel->callerprofile->caller_id_number,strlen(newchannel->callerprofile->caller_id_number)); @@ -377,6 +377,35 @@ } } +void BaseCDR::escape_string(std::string& src) +{ + std::string::size_type pos = 0; + + // find all occurences of ' and replace them with \' + while ( ( pos = src.find( "'", pos ) ) != std::string::npos ) + { + src.replace( pos, 1, "\\'" ); + pos += 2; + } +} + +std::string BaseCDR::escape_chararray(char* src) +{ + std::string src_string = src; + + std::string::size_type pos = 0; + + // find all occurences of ' and replace them with \' + while ( ( pos = src_string.find( "'", pos ) ) != std::string::npos ) + { + src_string.replace( pos, 1, "\\'" ); + pos += 2; + } + + return src_string; +} + + /* For Emacs: * Local Variables: * mode:c++ Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.h ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.h (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/basecdr.h Mon Jan 22 17:03:56 2007 @@ -84,6 +84,8 @@ void parse_channel_variables_xconfig(std::string& unparsed,std::list<std::string>& chanvarslist,std::vector<switch_mod_cdr_sql_types_t>& chanvars_fixed_types); // Typically used for SQL types void process_channel_variables(const std::list<std::string>& stringlist,const std::list<std::string>& fixedlist,switch_channel_t *channel,bool repeat = 1); //This is used for supplemental chanvars void process_channel_variables(const std::list<std::string>& stringlist,switch_channel_t *channel); // This is used for fixed chanvars + void escape_string(std::string& src); + std::string escape_chararray(char* src); switch_time_t callstartdate; switch_time_t callanswerdate; switch_time_t callenddate; Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/csvcdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/csvcdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/csvcdr.cpp Mon Jan 22 17:03:56 2007 @@ -179,7 +179,7 @@ if(outputfile.good()) { activated = 1; - switch_console_printf(SWITCH_CHANNEL_LOG,"CsvCDR activated, log rotation will occur at or after %d MB",(filesize_limit/1024/1024)); + switch_console_printf(SWITCH_CHANNEL_LOG,"CsvCDR activated, log rotation will occur at or after %d MB\n",(filesize_limit/1024/1024)); } } else @@ -228,7 +228,21 @@ switch_console_printf(SWITCH_CHANNEL_LOG,"Could not open the CSV file %s . CsvCDR logger will not be functional until this is resolved and a reload is issued. Failbit is set to %d.\n",filename.c_str(),outputfile.fail()); activated = 0; } + else + { + outputfile << "callstartdate,formattedcallstartdate,callanswerdate,formattedcallanswerdate,calltransferdate,formattedcalltransferdate,callendate,formattedcallenddate,hangupcause_text,hangupcause,clid,originated,dialplan,myuuid,destuuid,src,dst,srcchannel,dstchannel,ani,aniii,network_address,lastapp,lastdata,billusec,disposition,amaflags"; + if(chanvars_fixed_list.size()) + { + std::list<std::string>::iterator iItr, iEnd; + for(iItr = chanvars_fixed_list.begin(),iEnd = chanvars_fixed_list.end(); iItr != iEnd; iItr++) + outputfile << "," << *iItr; + } + if(logchanvars) + outputfile << ",chanvars_supp"; + + outputfile << std::endl; + } } bool CsvCDR::process_record() @@ -315,7 +329,7 @@ chanvars_fixed_list.clear(); chanvars_supp_list.clear(); connectionstate = 0; - switch_console_printf(SWITCH_CHANNEL_LOG,"Shutting down CsvCDR... Done!"); + switch_console_printf(SWITCH_CHANNEL_LOG,"Shutting down CsvCDR... Done!\n"); } AUTO_REGISTER_BASECDR(CsvCDR); Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/mysqlcdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/mysqlcdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/mysqlcdr.cpp Mon Jan 22 17:03:56 2007 @@ -62,6 +62,7 @@ dstchannel_length = (long unsigned int)strlen(dstchannel); lastapp_length = (long unsigned int)strlen(lastapp); lastdata_length = (long unsigned int)strlen(lastdata); + network_addr_length = (long unsigned int)strlen(network_addr); if(chanvars_fixed_list.size() > 0) process_channel_variables(chanvars_fixed_list,newchannel->channel); @@ -195,7 +196,7 @@ if(activated) { - tmp_sql_query = "INSERT INTO freeswitchcdr (callstartdate,callanswerdate,calltransferdate,callenddate,originated,clid,src,dst,ani,aniii,dialplan,myuuid,destuuid,srcchannel,dstchannel,lastapp,lastdata,billusec,disposition,hangupcause,amaflags"; + tmp_sql_query = "INSERT INTO freeswitchcdr (callstartdate,callanswerdate,calltransferdate,callenddate,originated,clid,src,dst,ani,aniii,dialplan,myuuid,destuuid,srcchannel,dstchannel,network_addr,lastapp,lastdata,billusec,disposition,hangupcause,amaflags"; int items_appended = 0; @@ -213,7 +214,7 @@ } } - tmp_sql_query.append(") VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?"); + tmp_sql_query.append(") VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?"); if(chanvars_fixed_list.size() > 0 ) { @@ -334,13 +335,13 @@ set_mysql_time(tm1,my_callstartdate); set_mysql_time(tm2,my_callanswerdate); set_mysql_time(tm3,my_calltransferdate); - set_mysql_time(tm4,my_calltransferdate); + set_mysql_time(tm4,my_callenddate); // Why is this out of order? I don't know, it doesn't make sense. add_parameter(my_callstartdate,MYSQL_TYPE_DATETIME); add_parameter(my_callanswerdate,MYSQL_TYPE_DATETIME); - add_parameter(my_callenddate,MYSQL_TYPE_DATETIME); add_parameter(my_calltransferdate,MYSQL_TYPE_DATETIME); + add_parameter(my_callenddate,MYSQL_TYPE_DATETIME); add_parameter(originated,MYSQL_TYPE_TINY); add_string_parameter(clid,clid_length,MYSQL_TYPE_VAR_STRING,0); @@ -353,6 +354,7 @@ add_string_parameter(destuuid,destuuid_length,MYSQL_TYPE_VAR_STRING,0); add_string_parameter(srcchannel,srcchannel_length,MYSQL_TYPE_VAR_STRING,0); add_string_parameter(dstchannel,dstchannel_length,MYSQL_TYPE_VAR_STRING,0); + add_string_parameter(network_addr,network_addr_length,MYSQL_TYPE_VAR_STRING,0); add_string_parameter(lastapp,lastapp_length,MYSQL_TYPE_VAR_STRING,0); add_string_parameter(lastdata,lastdata_length,MYSQL_TYPE_VAR_STRING,0); add_parameter(billusec,MYSQL_TYPE_LONGLONG,0); Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/mysqlcdr.h ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/mysqlcdr.h (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/mysqlcdr.h Mon Jan 22 17:03:56 2007 @@ -95,6 +95,7 @@ long unsigned int aniii_length; long unsigned int lastapp_length; long unsigned int lastdata_length; + long unsigned int network_addr_length; // Now a couple internal methods template <typename T> void add_parameter(T& param, enum_field_types type, bool *is_null=0); void add_string_parameter(char* param, long unsigned int& param_length, enum_field_types type, bool* is_null=0); Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/odbccdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/odbccdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/odbccdr.cpp Mon Jan 22 17:03:56 2007 @@ -222,7 +222,7 @@ { tmp_sql_query = "INSERT INTO "; tmp_sql_query.append(tablename); - tmp_sql_query.append(" (callstartdate,callanswerdate,calltransferdate,callenddate,originated,clid,src,dst,ani,aniii,dialplan,myuuid,destuuid,srcchannel,dstchannel,lastapp,lastdata,billusec,disposition,hangupcause,amaflags"); + tmp_sql_query.append(" (callstartdate,callanswerdate,calltransferdate,callenddate,originated,clid,src,dst,ani,aniii,dialplan,myuuid,destuuid,srcchannel,dstchannel,network_addr,lastapp,lastdata,billusec,disposition,hangupcause,amaflags"); int items_appended = 0; @@ -240,7 +240,7 @@ } } - tmp_sql_query.append(") VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?"); + tmp_sql_query.append(") VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?"); if(chanvars_fixed_list.size() > 0 ) { @@ -422,6 +422,7 @@ SQLBindParameter(ODBC_stmt, index++, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, sizeof(destuuid), 0, destuuid, 0, 0); SQLBindParameter(ODBC_stmt, index++, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_VARCHAR, sizeof(srcchannel), 0, srcchannel, 0, 0); SQLBindParameter(ODBC_stmt, index++, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_VARCHAR, sizeof(dstchannel), 0, dstchannel, 0, 0); + SQLBindParameter(ODBC_stmt, index++, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_VARCHAR, sizeof(network_addr), 0, network_addr, 0, 0); SQLBindParameter(ODBC_stmt, index++, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_VARCHAR, sizeof(lastapp), 0, lastapp, 0, 0); SQLBindParameter(ODBC_stmt, index++, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_VARCHAR, sizeof(lastdata), 0, lastdata, 0, 0); SQLBindParameter(ODBC_stmt, index++, SQL_PARAM_INPUT, SQL_C_UBIGINT, SQL_BIGINT, 0, 0, &billusec, 0, 0); Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.cpp Mon Jan 22 17:03:56 2007 @@ -172,41 +172,45 @@ { // Format the call record and proceed from here... outputfile << "$VAR1 = {" << std::endl; - outputfile << "\t\'callstartdate\' = \'" << callstartdate << "\'," << std::endl; - outputfile << "\t\'formattedcallstartdate\' = \'" << formattedcallstartdate << "\'," << std::endl; - outputfile << "\t\'callanswerdate\' = \'" << callanswerdate << "\'," << std::endl; - outputfile << "\t\'formattedcallanswerdate\' = \'" << formattedcallanswerdate << "\'," << std::endl; - outputfile << "\t\'calltransferdate\' = \'" << calltransferdate << "\'," << std::endl; - outputfile << "\t\'formattedcalltransferdate\' = \'" << formattedcalltransferdate << "\'," << std::endl; - outputfile << "\t\'callenddate\' = \'" << callenddate << "\'," << std::endl; - outputfile << "\t\'formatcallenddate\' = \'" << formattedcallenddate << "\'," << std::endl; - outputfile << "\t\'hangupcause\' = \'" << hangupcause_text << "\'," << std::endl; - outputfile << "\t\'hangupcausecode\' = \'" << hangupcause << "\'," << std::endl; - outputfile << "\t\'clid\' = \'" << clid << "\'," << std::endl; - outputfile << "\t\'originated\' = \'" << originated << "\'," << std::endl; - outputfile << "\t\'dialplan\' = \'" << dialplan << "\'," << std::endl; - outputfile << "\t\'myuuid\' = \'" << myuuid << "\'," << std::endl; - outputfile << "\t\'destuuid\' = \'" << destuuid << "\'," << std::endl; - outputfile << "\t\'src\' = \'" << src << "\'," << std::endl; - outputfile << "\t\'dst\' = \'" << dst << "\'," << std::endl; - outputfile << "\t\'srcchannel\' = \'" << srcchannel << "\'," << std::endl; - outputfile << "\t\'dstchannel\' = \'" << dstchannel << "\'," << std::endl; - outputfile << "\t\'ani\' = \'" << ani << "\'," << std::endl; - outputfile << "\t\'aniii\' = \'" << aniii << "\'," << std::endl; - outputfile << "\t\'network_addr\' = \'" << network_addr << "\'," << std::endl; - outputfile << "\t\'lastapp\' = \'" << lastapp << "\'," << std::endl; - outputfile << "\t\'lastdata\' = \'" << lastdata << "\'," << std::endl; - outputfile << "\t\'billusec\' = \'" << billusec << "\'," << std::endl; - outputfile << "\t\'disposition\' = \'" << disposition << "\'," << std::endl; - outputfile << "\t\'amaflags\' = \'" << amaflags << "\'," << std::endl; + outputfile << "\t\'callstartdate\' => \'" << callstartdate << "\'," << std::endl; + outputfile << "\t\'formattedcallstartdate\' => \'" << formattedcallstartdate << "\'," << std::endl; + outputfile << "\t\'callanswerdate\' => \'" << callanswerdate << "\'," << std::endl; + outputfile << "\t\'formattedcallanswerdate\' => \'" << formattedcallanswerdate << "\'," << std::endl; + outputfile << "\t\'calltransferdate\' => \'" << calltransferdate << "\'," << std::endl; + outputfile << "\t\'formattedcalltransferdate\' => \'" << formattedcalltransferdate << "\'," << std::endl; + outputfile << "\t\'callenddate\' => \'" << callenddate << "\'," << std::endl; + outputfile << "\t\'formattedcallenddate\' => \'" << formattedcallenddate << "\'," << std::endl; + outputfile << "\t\'hangupcause\' => \'" << hangupcause_text << "\'," << std::endl; + outputfile << "\t\'hangupcausecode\' => \'" << hangupcause << "\'," << std::endl; + outputfile << "\t\'clid\' => \'" << escape_chararray(clid) << "\'," << std::endl; + outputfile << "\t\'originated\' => \'" << originated << "\'," << std::endl; + outputfile << "\t\'dialplan\' => \'" << dialplan << "\'," << std::endl; + outputfile << "\t\'myuuid\' => \'" << myuuid << "\'," << std::endl; + outputfile << "\t\'destuuid\' => \'" << destuuid << "\'," << std::endl; + outputfile << "\t\'src\' => \'" << src << "\'," << std::endl; + outputfile << "\t\'dst\' => \'" << dst << "\'," << std::endl; + outputfile << "\t\'srcchannel\' => \'" << srcchannel << "\'," << std::endl; + outputfile << "\t\'dstchannel\' => \'" << dstchannel << "\'," << std::endl; + outputfile << "\t\'ani\' => \'" << ani << "\'," << std::endl; + outputfile << "\t\'aniii\' => \'" << aniii << "\'," << std::endl; + outputfile << "\t\'network_addr\' => \'" << network_addr << "\'," << std::endl; + outputfile << "\t\'lastapp\' => \'" << lastapp << "\'," << std::endl; + outputfile << "\t\'lastdata\' => \'" << lastdata << "\'," << std::endl; + outputfile << "\t\'billusec\' => \'" << billusec << "\'," << std::endl; + outputfile << "\t\'disposition\' => \'" << disposition << "\'," << std::endl; + outputfile << "\t\'amaflags\' => \'" << amaflags << "\'," << std::endl; // Now to process chanvars outputfile << "\t\'chanvars\' => {" << std::endl; if(chanvars_supp.size() > 0 ) { - std::map<std::string,std::string>::iterator iItr,iEnd; + std::map< std::string,std::string >::iterator iItr,iEnd; for(iItr = chanvars_supp.begin(), iEnd = chanvars_supp.end() ; iItr != iEnd; iItr++) - outputfile << "\t\t\'" << iItr->first << "\' = \'" << iItr->second << "\'," << std::endl; + { + escape_string(iItr->second); + outputfile << "\t\t\'" << iItr->first; + outputfile << "\' => \'" << iItr->second << "\'," << std::endl; + } } outputfile << "\t}," << std::endl << "};" << std::endl << std::endl; retval = 1; Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.h ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.h (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/pddcdr.h Mon Jan 22 17:03:56 2007 @@ -24,6 +24,7 @@ * Contributor(s): * * Yossi Neiman <freeswitch AT cartissolutions.com> + * Bret McDanel <trixter AT 0xdecafbad.com> * * Description: This C++ header file describes the PddCDR class which handles formatting a CDR out to * individual text files in a Perl Data Dumper format. @@ -54,7 +55,6 @@ virtual void tempdump_record(); virtual void reread_tempdumped_records(); virtual std::string get_display_name(); - private: static bool activated; // Is this module activated? static bool connectionstate; // What is the status of the connection? Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/schema.sql ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/schema.sql (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/schema.sql Mon Jan 22 17:03:56 2007 @@ -15,6 +15,7 @@ destuuid char(36) NOT NULL, srcchannel varchar(80) NOT NULL, dstchannel varchar(80) NOT NULL, /* Need to decide - this might be redundant as you can link the records via uuid */ + network_addr varchar(40) default "", lastapp varchar(80) default "", lastdata varchar(255) default "", billusec bigint default 0, Modified: freeswitch/trunk/src/mod/event_handlers/mod_cdr/xmlcdr.cpp ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_cdr/xmlcdr.cpp (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_cdr/xmlcdr.cpp Mon Jan 22 17:03:56 2007 @@ -171,7 +171,7 @@ switch_console_printf(SWITCH_CHANNEL_LOG, "XmlCDR::process_record(): Unable to open file %s to commit the call record to. Invalid path name, invalid permissions, or no space available?\n",outputfile_name.c_str()); else { - switch_console_printf(SWITCH_CHANNEL_LOG, "XmlCDR::process_record(): Preping the CDR to %s.\n",outputfile_name.c_str()); + //switch_console_printf(SWITCH_CHANNEL_LOG, "XmlCDR::process_record(): Preping the CDR to %s.\n",outputfile_name.c_str()); // Format the call record and proceed from here... outputfile << "<?xml version=\"1.0\"?>" << std::endl; outputfile << "<document type=\"freeswitch-cdr/xml\">" << std::endl; @@ -213,7 +213,7 @@ } outputfile << "\t</chanvars>" << std::endl << "</document>" << std::endl << std::endl; - switch_console_printf(SWITCH_CHANNEL_LOG, "XmlCDR::process_record(): Dumping the CDR to %s.\n",outputfile_name.c_str()); + //switch_console_printf(SWITCH_CHANNEL_LOG, "XmlCDR::process_record(): Dumping the CDR to %s.\n",outputfile_name.c_str()); retval = 1; }

1 0

[commit] r4021 - in freeswitch/trunk/src: . include
by Freeswitch SVN 22 Jan '07

22 Jan '07

Author: anthm Date: Mon Jan 22 16:59:07 2007 New Revision: 4021 Modified: freeswitch/trunk/src/include/switch_core.h freeswitch/trunk/src/switch_core.c Log: tweak core for build err and add core_get_var Modified: freeswitch/trunk/src/include/switch_core.h ============================================================================== --- freeswitch/trunk/src/include/switch_core.h (original) +++ freeswitch/trunk/src/include/switch_core.h Mon Jan 22 16:59:07 2007 @@ -473,6 +473,13 @@ SWITCH_DECLARE(char *) switch_core_get_variable(char *varname); /*! + \brief Add a global variable to the core + \param varname the name of the variable + \param value the value of the variable +*/ +SWITCH_DECLARE(void) switch_core_set_variable(char *varname, char *value); + +/*! \brief Hangup All Sessions \param cause the hangup cause to apply to the hungup channels */ Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Mon Jan 22 16:59:07 2007 @@ -610,6 +610,11 @@ return (char *) switch_core_hash_find(runtime.global_vars, varname); } +SWITCH_DECLARE(void) switch_core_set_variable(char *varname, char *value) +{ + switch_core_hash_insert(runtime.global_vars, switch_core_strdup(runtime.memory_pool, varname), switch_core_strdup(runtime.memory_pool, value)); +} + #ifdef SWITCH_DEBUG_RWLOCKS SWITCH_DECLARE(switch_core_session_t *) switch_core_session_perform_locate(char *uuid_str, @@ -2881,7 +2886,7 @@ #endif -static int handle_fatality(int sig) +static void handle_fatality(int sig) { switch_thread_id_t thread_id; jmp_buf *env; @@ -2909,10 +2914,10 @@ jmp_buf env; int sig; - signal(SIGSEGV, (void *) handle_fatality); - signal(SIGFPE, (void *) handle_fatality); + signal(SIGSEGV, handle_fatality); + signal(SIGFPE, handle_fatality); #ifndef WIN32 - signal(SIGBUS, (void *) handle_fatality); + signal(SIGBUS, handle_fatality); #endif if ((sig = setjmp(env)) != 0) {

1 0

[commit] r4019 - freeswitch/trunk/src/mod/xml_int/mod_xml_rpc
by Freeswitch SVN 22 Jan '07

22 Jan '07

Author: mikej Date: Mon Jan 22 13:18:48 2007 New Revision: 4019 Modified: freeswitch/trunk/src/mod/xml_int/mod_xml_rpc/mod_xml_rpc.c Log: add "freeswitch_api" in addition to "freeswitch.api" as xmlrpc method so it can work with java. Modified: freeswitch/trunk/src/mod/xml_int/mod_xml_rpc/mod_xml_rpc.c ============================================================================== --- freeswitch/trunk/src/mod/xml_int/mod_xml_rpc/mod_xml_rpc.c (original) +++ freeswitch/trunk/src/mod/xml_int/mod_xml_rpc/mod_xml_rpc.c Mon Jan 22 13:18:48 2007 @@ -235,6 +235,7 @@ registryP = xmlrpc_registry_new(&env); xmlrpc_registry_add_method(&env, registryP, NULL, "freeswitch.api", &freeswitch_api, NULL); + xmlrpc_registry_add_method(&env, registryP, NULL,"freeswitch_api", &freeswitch_api, NULL); MIMETypeInit(); MIMETypeAdd("text/html", "html");

1 0

[commit] r4018 - freeswitch/trunk/libs/js/src
by Freeswitch SVN 22 Jan '07

22 Jan '07

Author: mikej Date: Mon Jan 22 12:59:27 2007 New Revision: 4018 Modified: freeswitch/trunk/libs/js/src/jsfile.c Log: add file object from spidermonkey. Modified: freeswitch/trunk/libs/js/src/jsfile.c ============================================================================== --- freeswitch/trunk/libs/js/src/jsfile.c (original) +++ freeswitch/trunk/libs/js/src/jsfile.c Mon Jan 22 12:59:27 2007 @@ -41,9 +41,7 @@ /* * JS File object */ -#if defined(JS_HAS_FILE_OBJECT) && (JS_HAS_FILE_OBJECT - 0) /* OSSP BUGFIX */ - -#ifdef OSSP +#ifdef OSSP_HACK #include "../config.h" #endif @@ -52,7 +50,7 @@ /* ----------------- Platform-specific includes and defines ----------------- */ #if defined(XP_WIN) || defined(XP_OS2) # include <direct.h> -#ifdef OSSP +#ifdef OSSP_HACK # include <dirent.h> # include <fcntl.h> # include <time.h> @@ -65,7 +63,7 @@ # define CURRENT_DIR "c:\\" # define POPEN _popen # define PCLOSE _pclose -#ifdef OSSP +#ifdef OSSP_HACK # undef mkdir # define mkdir(file, mode) _mkdir(file) #endif @@ -74,7 +72,7 @@ # include <stdio.h> # include <stdlib.h> # include <unistd.h> -#ifdef OSSP +#ifdef OSSP_HACK # include <sys/types.h> # include <sys/stat.h> # include <dirent.h> @@ -104,13 +102,13 @@ #include "jsscript.h" #include "jsstr.h" #include "jsutil.h" /* Added by JSIFY */ -#ifdef OSSP /* CLEANUP */ +#ifdef OSSP_HACK /* CLEANUP */ #include "jsfile.h" #endif #include <string.h> /* NSPR dependencies */ -#ifdef OSSP +#ifdef OSSP_HACK #define PR_RDONLY 0x01 #define PR_WRONLY 0x02 #define PR_RDWR 0x04 @@ -174,7 +172,7 @@ #undef MSG_DEF }; -#ifdef OSSP +#ifdef OSSP_HACK static #endif const JSErrorFormatString * @@ -270,7 +268,7 @@ JSBool hasAutoflush; /* should we force a flush for each line break? */ JSBool isNative; /* if the file is using OS-specific file FILE type */ /* We can actually put the following two in a union since they should never be used at the same time */ -#ifdef OSSP +#ifdef OSSP_HACK FILE *handle; /* the handle for the file, if open. */ #else PRFileDesc *handle; /* the handle for the file, if open. */ @@ -823,7 +821,7 @@ /* Buffered version of PR_Read. Used by js_FileRead */ static int32 -#ifdef OSSP +#ifdef OSSP_HACK js_BufferedRead(JSFile * f, unsigned char *buf, int32 len) #else js_BufferedRead(JSFile * f, char *buf, int32 len) @@ -842,7 +840,7 @@ } if (len>0) { -#ifdef OSSP +#ifdef OSSP_HACK count += (!f->isNative) ? fread(buf, 1, len, f->handle) : fread(buf, 1, len, f->nativehandle); @@ -921,7 +919,7 @@ break; case UCS2: -#ifdef OSSP +#ifdef OSSP_HACK count = js_BufferedRead(file, (unsigned char*)buf, len*2) >> 1; #else count = js_BufferedRead(file, (char*)buf, len*2) >> 1; @@ -954,7 +952,7 @@ switch (mode) { case ASCII: -#ifdef OSSP +#ifdef OSSP_HACK count = fseek(file->handle, len, SEEK_CUR); #else count = PR_Seek(file->handle, len, PR_SEEK_CUR); @@ -994,7 +992,7 @@ break; case UCS2: -#ifdef OSSP +#ifdef OSSP_HACK count = fseek(file->handle, len*2, SEEK_CUR)/2; #else count = PR_Seek(file->handle, len*2, PR_SEEK_CUR)/2; @@ -1030,7 +1028,7 @@ for (i = 0; i<len; i++) aux[i] = buf[i] % 256; -#ifdef OSSP +#ifdef OSSP_HACK count = (!file->isNative) ? fwrite(aux, 1, len, file->handle) : fwrite(aux, 1, len, file->nativehandle); @@ -1060,7 +1058,7 @@ } i+=j; } -#ifdef OSSP +#ifdef OSSP_HACK j = (!file->isNative) ? fwrite(utfbuf, 1, i, file->handle) : fwrite(utfbuf, 1, i, file->nativehandle); @@ -1078,7 +1076,7 @@ break; case UCS2: -#ifdef OSSP +#ifdef OSSP_HACK count = (!file->isNative) ? fwrite(buf, 1, len*2, file->handle) >> 1 : fwrite(buf, 1, len*2, file->nativehandle) >> 1; @@ -1114,7 +1112,7 @@ return JS_FALSE; } -#ifdef OSSP +#ifdef OSSP_HACK return access(file->path, F_OK) == 0; #else return PR_Access(file->path, PR_ACCESS_EXISTS) == PR_SUCCESS; @@ -1127,7 +1125,7 @@ if (!file->isNative) { if (file->isOpen && !(file->mode & PR_RDONLY)) return JS_FALSE; -#ifdef OSSP +#ifdef OSSP_HACK return access(file->path, R_OK) == 0; #else return PR_Access(file->path, PR_ACCESS_READ_OK) == PR_SUCCESS; @@ -1148,7 +1146,7 @@ if (!file->isNative) { if (file->isOpen && !(file->mode & PR_WRONLY)) return JS_FALSE; -#ifdef OSSP +#ifdef OSSP_HACK return access(file->path, W_OK) == 0; #else return PR_Access(file->path, PR_ACCESS_WRITE_OK) == PR_SUCCESS; @@ -1168,7 +1166,7 @@ js_isFile(JSContext *cx, JSFile *file) { if (!file->isNative) { -#ifdef OSSP +#ifdef OSSP_HACK struct stat info; if (file->isOpen @@ -1203,7 +1201,7 @@ js_isDirectory(JSContext *cx, JSFile *file) { if(!file->isNative){ -#ifdef OSSP +#ifdef OSSP_HACK struct stat info; #else PRFileInfo info; @@ -1213,7 +1211,7 @@ if (!js_exists(cx, file)) return JS_FALSE; -#ifdef OSSP +#ifdef OSSP_HACK if (file->isOpen ? fstat(fileno(file->handle), &info) != 0 : stat(file->path, &info) != 0) { @@ -1243,7 +1241,7 @@ static jsval js_size(JSContext *cx, JSFile *file) { -#ifdef OSSP +#ifdef OSSP_HACK struct stat info; #else PRFileInfo info; @@ -1251,7 +1249,7 @@ JSFILE_CHECK_NATIVE("size"); -#ifdef OSSP +#ifdef OSSP_HACK if (file->isOpen ? fstat(fileno(file->handle), &info) != 0 : stat(file->path, &info) != 0) { @@ -1495,7 +1493,7 @@ } } else { /* TODO: what about the permissions?? Java ignores the problem... */ -#ifdef OSSP +#ifdef OSSP_HACK { int my_fd; int my_fd_mode = 0; @@ -1562,7 +1560,7 @@ JS_ReportWarning(cx, "Unable to close a native file, proceeding", file->path); goto out; }else{ -#ifdef OSSP +#ifdef OSSP_HACK if (file->handle && fclose(file->handle) != 0) { #else if(file->handle && PR_Close(file->handle)){ @@ -1599,7 +1597,7 @@ JSFILE_CHECK_NATIVE("remove"); JSFILE_CHECK_CLOSED("remove"); -#ifdef OSSP +#ifdef OSSP_HACK if (remove(file->path) == 0) { #else if ((js_isDirectory(cx, file) ? @@ -1624,7 +1622,7 @@ { JSFile *file = JS_GetInstancePrivate(cx, obj, &file_class, NULL); char *dest = NULL; -#ifdef OSSP +#ifdef OSSP_HACK FILE *handle = NULL; #else PRFileDesc *handle = NULL; @@ -1655,7 +1653,7 @@ goto out; } -#ifdef OSSP +#ifdef OSSP_HACK { int my_fd; if ((my_fd = open(file->path, O_WRONLY|O_CREAT|O_TRUNC, 0644)) != -1) @@ -1677,7 +1675,7 @@ buffer = JS_malloc(cx, size); -#ifdef OSSP +#ifdef OSSP_HACK count = INT_TO_JSVAL((int)fread(buffer, 1, (size_t)size, file->handle)); #else count = INT_TO_JSVAL(PR_Read(file->handle, buffer, size)); @@ -1691,7 +1689,7 @@ goto out; } -#ifdef OSSP +#ifdef OSSP_HACK count = INT_TO_JSVAL((int)fwrite(buffer, 1, (size_t)JSVAL_TO_INT(size), handle)); #else count = INT_TO_JSVAL(PR_Write(handle, buffer, JSVAL_TO_INT(size))); @@ -1711,7 +1709,7 @@ if(!file_close(cx, obj, 0, NULL, rval)) goto out; } -#ifdef OSSP +#ifdef OSSP_HACK if (fclose(handle) != 0) { #else if(PR_Close(handle)!=PR_SUCCESS){ @@ -1725,7 +1723,7 @@ return JS_TRUE; out: if(file->isOpen && !fileInitiallyOpen){ -#ifdef OSSP +#ifdef OSSP_HACK if (fclose(file->handle) != 0) { #else if(PR_Close(file->handle)!=PR_SUCCESS){ @@ -1734,7 +1732,7 @@ } } -#ifdef OSSP +#ifdef OSSP_HACK if (handle && fclose(handle) != 0) { #else if(handle && PR_Close(handle)!=PR_SUCCESS){ @@ -1759,7 +1757,7 @@ dest = RESOLVE_PATH(cx, JS_GetStringBytes(JS_ValueToString(cx, argv[0]))); -#ifdef OSSP +#ifdef OSSP_HACK if (rename(file->path, dest) == 0){ #else if (PR_Rename(file->path, dest)==PR_SUCCESS){ @@ -1788,7 +1786,7 @@ JSFILE_CHECK_NATIVE("flush"); JSFILE_CHECK_OPEN("flush"); -#ifdef OSSP +#ifdef OSSP_HACK if (fflush(file->handle) == 0){ #else if (PR_Sync(file->handle)==PR_SUCCESS){ @@ -2096,7 +2094,7 @@ static JSBool file_list(JSContext *cx, JSObject *obj, uintN argc, jsval *argv, jsval *rval) { -#ifdef OSSP +#ifdef OSSP_HACK DIR *dir; struct dirent *entry; #else @@ -2136,7 +2134,7 @@ goto out; } -#ifdef OSSP +#ifdef OSSP_HACK dir = opendir(file->path); #else dir = PR_OpenDir(file->path); @@ -2151,12 +2149,12 @@ array = JS_NewArrayObject(cx, 0, NULL); len = 0; -#ifdef OSSP +#ifdef OSSP_HACK while ((entry = readdir(dir))!=NULL) { #else while ((entry = PR_ReadDir(dir, PR_SKIP_BOTH))!=NULL) { #endif -#ifdef OSSP +#ifdef OSSP_HACK if ( strcmp(entry->d_name, ".") == 0 || strcmp(entry->d_name, "..") == 0) continue; @@ -2165,7 +2163,7 @@ if (re!=NULL) { size_t index = 0; -#ifdef OSSP +#ifdef OSSP_HACK str = JS_NewStringCopyZ(cx, entry->d_name); #else str = JS_NewStringCopyZ(cx, entry->name); @@ -2180,7 +2178,7 @@ } }else if (func!=NULL) { -#ifdef OSSP +#ifdef OSSP_HACK str = JS_NewStringCopyZ(cx, entry->d_name); #else str = JS_NewStringCopyZ(cx, entry->name); @@ -2195,7 +2193,7 @@ } } -#ifdef OSSP +#ifdef OSSP_HACK filePath = js_combinePath(cx, file->path, (char*)entry->d_name); #else filePath = js_combinePath(cx, file->path, (char*)entry->name); @@ -2209,7 +2207,7 @@ } v = OBJECT_TO_JSVAL(eachFile); JS_SetElement(cx, array, len, &v); -#ifdef OSSP +#ifdef OSSP_HACK JS_SetProperty(cx, array, entry->d_name, &v); #else JS_SetProperty(cx, array, entry->name, &v); @@ -2217,7 +2215,7 @@ len++; } -#ifdef OSSP +#ifdef OSSP_HACK if (closedir(dir) != 0) { #else if(PR_CloseDir(dir)!=PR_SUCCESS){ @@ -2259,7 +2257,7 @@ char *fullName; fullName = js_combinePath(cx, file->path, dirName); -#ifdef OSSP +#ifdef OSSP_HACK if (mkdir(fullName, 0755) == 0) { #else if (PR_MkDir(fullName, 0755)==PR_SUCCESS){ @@ -2283,7 +2281,7 @@ file_toString(JSContext *cx, JSObject *obj, uintN argc, jsval *argv, jsval*rval) { JSFile *file = JS_GetInstancePrivate(cx, obj, &file_class, NULL); -#ifdef OSSP +#ifdef OSSP_HACK JSString *str; if ((str = JS_NewStringCopyZ(cx, file->path)) == NULL) @@ -2301,8 +2299,8 @@ JSFile *file = JS_GetInstancePrivate(cx, obj, &file_class, NULL); char url[MAX_PATH_LENGTH]; jschar *urlChars; -#ifdef OSSP size_t len; +#ifdef OSSP_HACK JSString *str; #endif @@ -2311,7 +2309,7 @@ sprintf(url, "file://%s", file->path); /* TODO: js_escape in jsstr.h may go away at some point */ -#ifdef OSSP /* BUGFIX */ +#ifdef OSSP_HACK /* BUGFIX */ len = strlen(url); if ((urlChars = js_InflateString(cx, url, &len)) == NULL) return JS_FALSE; @@ -2321,7 +2319,8 @@ } *rval = STRING_TO_JSVAL(str); #else - urlChars = js_InflateString(cx, url, strlen(url)); + len = strlen(url); + urlChars = js_InflateString(cx, url, &len); if (urlChars == NULL) return JS_FALSE; *rval = STRING_TO_JSVAL(js_NewString(cx, urlChars, strlen(url), 0)); #endif @@ -2399,7 +2398,7 @@ } /* Internal function, used for cases which NSPR file support doesn't cover */ -#ifdef OSSP /* CLEANUP */ +#ifdef OSSP_HACK /* CLEANUP */ static #endif JSObject* @@ -2514,7 +2513,7 @@ FILE_APPEND = -19, FILE_REPLACE = -20, FILE_AUTOFLUSH = -21, -#ifdef OSSP /* BUGFIX */ +#ifdef OSSP_HACK /* BUGFIX */ FILE_ISNATIVE = -22 #else FILE_ISNATIVE = -22, @@ -2554,13 +2553,13 @@ char *bytes; JSString *str; jsint tiny; -#ifdef OSSP +#ifdef OSSP_HACK struct stat info; #else PRFileInfo info; #endif JSBool flag; -#ifdef OSSP +#ifdef OSSP_HACK struct tm *tm; time_t t; #else @@ -2703,7 +2702,7 @@ case FILE_CREATED: SECURITY_CHECK(cx, NULL, "creationTime", file); JSFILE_CHECK_NATIVE("creationTime"); -#ifdef OSSP +#ifdef OSSP_HACK if (file->isOpen ? fstat(fileno(file->handle), &info) != 0 : stat(file->path, &info) != 0) { @@ -2749,7 +2748,7 @@ case FILE_MODIFIED: SECURITY_CHECK(cx, NULL, "lastModified", file); JSFILE_CHECK_NATIVE("lastModified"); -#ifdef OSSP +#ifdef OSSP_HACK if (file->isOpen ? fstat(fileno(file->handle), &info) != 0 : stat(file->path, &info) != 0) { @@ -2793,7 +2792,7 @@ JSFILE_CHECK_NATIVE("length"); if (js_isDirectory(cx, file)) { /* XXX debug me */ -#ifdef OSSP +#ifdef OSSP_HACK DIR *dir; struct dirent *entry; #else @@ -2802,7 +2801,7 @@ #endif jsint count = 0; -#ifdef OSSP +#ifdef OSSP_HACK if(!(dir = opendir(file->path))){ #else if(!(dir = PR_OpenDir(file->path))){ @@ -2812,7 +2811,7 @@ goto out; } -#ifdef OSSP +#ifdef OSSP_HACK while ((entry = readdir(dir))) { if ( strcmp(entry->d_name, ".") == 0 || strcmp(entry->d_name, "..") == 0) @@ -2824,7 +2823,7 @@ count++; } -#ifdef OSSP +#ifdef OSSP_HACK if(closedir(dir) != 0){ #else if(!PR_CloseDir(dir)){ @@ -2859,7 +2858,7 @@ } if (file->isOpen && js_isFile(cx, file)) { -#ifdef OSSP +#ifdef OSSP_HACK int pos = fseek(file->handle, 0, SEEK_CUR); #else int pos = PR_Seek(file->handle, 0, PR_SEEK_CUR); @@ -2882,7 +2881,7 @@ /* this is some other property -- try to use the dir["file"] syntax */ if (js_isDirectory(cx, file)) { -#ifdef OSSP +#ifdef OSSP_HACK DIR *dir = NULL; struct dirent *entry = NULL; #else @@ -2898,7 +2897,7 @@ prop_name = JS_GetStringBytes(str); /* no native files past this point */ -#ifdef OSSP +#ifdef OSSP_HACK dir = opendir(file->path); #else dir = PR_OpenDir(file->path); @@ -2909,7 +2908,7 @@ return JS_FALSE; } -#ifdef OSSP +#ifdef OSSP_HACK while ((entry = readdir(dir)) != NULL) { if ( strcmp(entry->d_name, ".") == 0 || strcmp(entry->d_name, "..") == 0) @@ -2922,7 +2921,7 @@ bytes = js_combinePath(cx, file->path, prop_name); *vp = OBJECT_TO_JSVAL(js_NewFileObject(cx, bytes)); JS_free(cx, bytes); -#ifdef OSSP /* BUGFIX */ +#ifdef OSSP_HACK /* BUGFIX */ closedir(dir); #else PR_CloseDir(dir); @@ -2930,7 +2929,7 @@ return JS_TRUE; } } -#ifdef OSSP /* BUGFIX */ +#ifdef OSSP_HACK /* BUGFIX */ closedir(dir); #else PR_CloseDir(dir); @@ -2977,7 +2976,7 @@ goto out; } -#ifdef OSSP +#ifdef OSSP_HACK pos = fseek(file->handle, offset, SEEK_SET); #else pos = PR_Seek(file->handle, offset, PR_SEEK_SET); @@ -3108,4 +3107,3 @@ JSPROP_ENUMERATE | JSPROP_READONLY ); return file; } -#endif /* JS_HAS_FILE_OBJECT */

1 0

[commit] r4017 - freeswitch/trunk/src
by Freeswitch SVN 22 Jan '07

22 Jan '07

Author: mikej Date: Mon Jan 22 12:45:09 2007 New Revision: 4017 Modified: freeswitch/trunk/src/switch.c Log: tweak to work around shutdown segfault in windows in background mode. This forces it to not do apr_terminate, which shouldn't be necessary anyways as the entire process in ending. Modified: freeswitch/trunk/src/switch.c ============================================================================== --- freeswitch/trunk/src/switch.c (original) +++ freeswitch/trunk/src/switch.c Mon Jan 22 12:45:09 2007 @@ -197,9 +197,11 @@ const char *err = NULL; // error value for return from freeswitch initialization #ifndef WIN32 int nf = 0; // TRUE if we are running in nofork mode + int vg = 1; // Allways TRUE on windows to not do apr_terminate +#else + int vg = 0; // TRUE if we are running in vg mode #endif int nc = 0; // TRUE if we are running in noconsole mode - int vg = 0; // TRUE if we are running in vg mode FILE *f; // file handle to the pid file pid_t pid = 0; // int x; //

1 0

[commit] r4016 - freeswitch/trunk/src
by Freeswitch SVN 22 Jan '07

22 Jan '07

Author: mikej Date: Mon Jan 22 12:16:25 2007 New Revision: 4016 Modified: freeswitch/trunk/src/switch_core.c Log: rearrange a bit Modified: freeswitch/trunk/src/switch_core.c ============================================================================== --- freeswitch/trunk/src/switch_core.c (original) +++ freeswitch/trunk/src/switch_core.c Mon Jan 22 12:16:25 2007 @@ -4237,13 +4237,6 @@ switch_yield(1000000); - if (runtime.memory_pool) { - apr_pool_destroy(runtime.memory_pool); - if (!vg) { - apr_terminate(); - } - } - #ifdef WIN32 free(SWITCH_GLOBAL_dirs.base_dir); free(SWITCH_GLOBAL_dirs.mod_dir); @@ -4256,6 +4249,13 @@ free(SWITCH_GLOBAL_dirs.temp_dir); #endif + if (runtime.memory_pool) { + apr_pool_destroy(runtime.memory_pool); + if (!vg) { + apr_terminate(); + } + } + return SWITCH_STATUS_SUCCESS; }

1 0

[commit] r4015 - freeswitch/trunk/libs/iax/src
by Freeswitch SVN 22 Jan '07

22 Jan '07

Author: mikej Date: Mon Jan 22 11:54:30 2007 New Revision: 4015 Modified: freeswitch/trunk/libs/iax/src/iax.c Log: use closesocket on sockets.. not close Modified: freeswitch/trunk/libs/iax/src/iax.c ============================================================================== --- freeswitch/trunk/libs/iax/src/iax.c (original) +++ freeswitch/trunk/libs/iax/src/iax.c Mon Jan 22 11:54:30 2007 @@ -949,7 +949,7 @@ #ifdef WIN32 flags = 1; if (ioctlsocket(netfd,FIONBIO,(unsigned long *) &flags)) { - _close(netfd); + closesocket(netfd); netfd = -1; DEBU(G "Unable to set non-blocking mode."); IAXERROR "Unable to set non-blocking mode.");

1 0

[commit] r4014 - freeswitch/trunk/src/mod/event_handlers/mod_event_socket
by Freeswitch SVN 21 Jan '07

21 Jan '07

Author: anthm Date: Sun Jan 21 14:36:55 2007 New Revision: 4014 Modified: freeswitch/trunk/src/mod/event_handlers/mod_event_socket/mod_event_socket.c Log: let bgapi choose your own id Modified: freeswitch/trunk/src/mod/event_handlers/mod_event_socket/mod_event_socket.c ============================================================================== --- freeswitch/trunk/src/mod/event_handlers/mod_event_socket/mod_event_socket.c (original) +++ freeswitch/trunk/src/mod/event_handlers/mod_event_socket/mod_event_socket.c Sun Jan 21 14:36:55 2007 @@ -760,6 +760,7 @@ struct api_command_struct *acs; char *api_cmd = cmd + 6; char *arg = NULL; + char *uuid_str = NULL; strip_cr(api_cmd); if ((arg = strchr(api_cmd, ' '))) { @@ -784,8 +785,12 @@ switch_threadattr_detach_set(thd_attr, 1); switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE); switch_thread_create(&thread, thd_attr, api_exec, acs, listener->pool); - switch_uuid_get(&uuid); - switch_uuid_format(acs->uuid_str, &uuid); + if ((uuid_str = switch_event_get_header(event, "job-uuid"))) { + switch_copy_string(acs->uuid_str, uuid_str, sizeof(acs->uuid_str)); + } else { + switch_uuid_get(&uuid); + switch_uuid_format(acs->uuid_str, &uuid); + } snprintf(reply, reply_len, "+OK Job-UUID: %s", acs->uuid_str); } else { snprintf(reply, reply_len, "-ERR memory error!");

1 0