Changeset 438:e7814e24e57b in freeDiameter for extensions/app_diameap/diameap_mysql.c
- Timestamp:
- Jul 28, 2010, 3:59:39 PM (14 years ago)
- Branch:
- default
- Phase:
- public
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
extensions/app_diameap/diameap_mysql.c
r425 r438 38 38 #include "diameap_mysql.h" 39 39 40 static pthread_mutex_t db_cs_mutex = 41 PTHREAD_MUTEX_INITIALIZER; 42 40 43 int diameap_get_eap_user(struct eap_user * user, char * username) 41 44 { … … 44 47 { 45 48 TRACE_DEBUG(INFO, "%sNot connected to the MySQL Database server.",DIAMEAP_EXTENSION); 46 if (diameap_mysql_reconnect()) 47 { 48 return EINVAL; 49 } 49 50 return EINVAL; 51 50 52 } 51 53 mysql_thread_init(); … … 67 69 CHECK_POSIX(pthread_mutex_unlock( &db_cs_mutex )); 68 70 TRACE_DEBUG(INFO, "%sQuery execution fail. %s",DIAMEAP_EXTENSION, mysql_error(db_conn)); 69 db_conn = NULL;70 diameap_mysql_reconnect();71 71 mysql_thread_end(); 72 72 free(query); … … 83 83 84 84 user->id = atoi(row[0]); 85 user->userid = strdup(row[1]);85 memcpy(user->userid,row[1],strlen(row[1])); 86 86 user->useridLength = strlen(row[1]); 87 user->password = strdup(row[2]);87 memcpy(user->password, row[2],strlen(row[2])); 88 88 user->passwordLength = strlen(row[2]); 89 89 user->proposed_eap_method = atoi(row[3]); … … 115 115 { 116 116 TRACE_DEBUG(INFO, "%sNot connected to the MySQL Database server.",DIAMEAP_EXTENSION); 117 if (diameap_mysql_reconnect()) 118 { 119 return EINVAL; 120 } 117 118 return EINVAL; 119 121 120 } 122 121 … … 138 137 CHECK_POSIX(pthread_mutex_unlock( &db_cs_mutex )); 139 138 TRACE_DEBUG(INFO, "%sQuery execution fail. %s",DIAMEAP_EXTENSION, mysql_error(db_conn)); 140 db_conn = NULL;141 diameap_mysql_reconnect();142 139 mysql_thread_end(); 143 140 free(query); … … 178 175 { 179 176 TRACE_DEBUG(INFO, "%sNot connected to the MySQL Database server.",DIAMEAP_EXTENSION); 180 if (diameap_mysql_reconnect()) 181 { 182 return EINVAL; 183 } 177 178 return EINVAL; 179 184 180 } 185 181 … … 202 198 CHECK_POSIX(pthread_mutex_unlock( &db_cs_mutex )); 203 199 TRACE_DEBUG(INFO, "%sQuery execution fail. %s",DIAMEAP_EXTENSION, mysql_error(db_conn)); 204 db_conn = NULL;205 diameap_mysql_reconnect();206 200 mysql_thread_end(); 207 201 free(query); … … 233 227 } 234 228 235 void diameap_mysql_disconnect(){ 229 void diameap_mysql_disconnect() 230 { 236 231 mysql_close(db_conn); 237 232 }
Note: See TracChangeset
for help on using the changeset viewer.