/[LeafOK_CVS]/lbbs/src/user_list.c
ViewVC logotype

Diff of /lbbs/src/user_list.c

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

Revision 1.19 by sysadm, Thu Oct 23 05:54:16 2025 UTC Revision 1.30 by sysadm, Thu Nov 6 10:58:03 2025 UTC
# Line 1  Line 1 
1  /***************************************************************************  /* SPDX-License-Identifier: GPL-3.0-or-later */
2                                                   user_list.c  -  description  /*
3                                                           -------------------   * user_list
4          Copyright            : (C) 2004-2025 by Leaflet   *   - data model and basic operations of (online) user list
5          Email                : leaflet@leafok.com   *
6   ***************************************************************************/   * Copyright (C) 2004-2025  Leaflet <leaflet@leafok.com>
7     */
 /***************************************************************************  
  *                                                                         *  
  *   This program is free software; you can redistribute it and/or modify  *  
  *   it under the terms of the GNU General Public License as published by  *  
  *   the Free Software Foundation; either version 3 of the License, or     *  
  *   (at your option) any later version.                                   *  
  *                                                                         *  
  ***************************************************************************/  
8    
9  #include "common.h"  #include "common.h"
10  #include "database.h"  #include "database.h"
# Line 41  union semun Line 33  union semun
33  };  };
34  #endif // #ifdef _SEM_SEMUN_UNDEFINED  #endif // #ifdef _SEM_SEMUN_UNDEFINED
35    
36  #define USER_LIST_TRY_LOCK_WAIT_TIME 1 // second  enum _user_list_constant_t
37  #define USER_LIST_TRY_LOCK_TIMES 10  {
38            USER_LIST_TRY_LOCK_WAIT_TIME = 1, // second
39            USER_LIST_TRY_LOCK_TIMES = 10,
40    };
41    
42  struct user_list_pool_t  struct user_list_pool_t
43  {  {
# Line 55  struct user_list_pool_t Line 50  struct user_list_pool_t
50          USER_ONLINE_LIST *p_online_current;          USER_ONLINE_LIST *p_online_current;
51          USER_ONLINE_LIST *p_online_new;          USER_ONLINE_LIST *p_online_new;
52          USER_STAT_MAP user_stat_map;          USER_STAT_MAP user_stat_map;
53            int user_login_count;
54  };  };
55  typedef struct user_list_pool_t USER_LIST_POOL;  typedef struct user_list_pool_t USER_LIST_POOL;
56    
# Line 93  static int user_list_rd_lock(int semid); Line 89  static int user_list_rd_lock(int semid);
89  static int user_list_rw_lock(int semid);  static int user_list_rw_lock(int semid);
90    
91  static int user_list_load(MYSQL *db, USER_LIST *p_list);  static int user_list_load(MYSQL *db, USER_LIST *p_list);
92  static int user_online_list_load(MYSQL *db, USER_ONLINE_LIST *p_list);  static int user_online_list_load(MYSQL *db, USER_ONLINE_LIST *p_online_list);
93    static int user_login_count_load(MYSQL *db);
94    
95  static int user_info_index_uid_comp(const void *ptr1, const void *ptr2)  static int user_info_index_uid_comp(const void *ptr1, const void *ptr2)
96  {  {
# Line 148  int user_list_load(MYSQL *db, USER_LIST Line 145  int user_list_load(MYSQL *db, USER_LIST
145    
146          snprintf(sql, sizeof(sql),          snprintf(sql, sizeof(sql),
147                           "SELECT user_list.UID AS UID, username, nickname, gender, gender_pub, life, exp, visit_count, "                           "SELECT user_list.UID AS UID, username, nickname, gender, gender_pub, life, exp, visit_count, "
148                           "UNIX_TIMESTAMP(signup_dt), UNIX_TIMESTAMP(last_login_dt), UNIX_TIMESTAMP(birthday), `introduction` "                           "UNIX_TIMESTAMP(signup_dt), UNIX_TIMESTAMP(last_login_dt), UNIX_TIMESTAMP(last_logout_dt), "
149                             "UNIX_TIMESTAMP(birthday), `introduction` "
150                           "FROM user_list INNER JOIN user_pubinfo ON user_list.UID = user_pubinfo.UID "                           "FROM user_list INNER JOIN user_pubinfo ON user_list.UID = user_pubinfo.UID "
151                           "INNER JOIN user_reginfo ON user_list.UID = user_reginfo.UID "                           "INNER JOIN user_reginfo ON user_list.UID = user_reginfo.UID "
152                           "WHERE enable ORDER BY username");                           "WHERE enable ORDER BY username");
# Line 185  int user_list_load(MYSQL *db, USER_LIST Line 183  int user_list_load(MYSQL *db, USER_LIST
183                  p_list->users[i].visit_count = (row[7] == NULL ? 0 : atoi(row[7]));                  p_list->users[i].visit_count = (row[7] == NULL ? 0 : atoi(row[7]));
184                  p_list->users[i].signup_dt = (row[8] == NULL ? 0 : atol(row[8]));                  p_list->users[i].signup_dt = (row[8] == NULL ? 0 : atol(row[8]));
185                  p_list->users[i].last_login_dt = (row[9] == NULL ? 0 : atol(row[9]));                  p_list->users[i].last_login_dt = (row[9] == NULL ? 0 : atol(row[9]));
186                  p_list->users[i].birthday = (row[10] == NULL ? 0 : atol(row[10]));                  p_list->users[i].last_logout_dt = (row[10] == NULL ? 0 : atol(row[10]));
187                  intro_len = strlen((row[11] == NULL ? "" : row[11]));                  p_list->users[i].birthday = (row[10] == NULL ? 0 : atol(row[11]));
188                    intro_len = strlen((row[12] == NULL ? "" : row[12]));
189                  if (intro_len >= sizeof(p_list->user_intro_buf) - 1 - intro_buf_offset)                  if (intro_len >= sizeof(p_list->user_intro_buf) - 1 - intro_buf_offset)
190                  {                  {
191                          log_error("OOM for user introduction: len=%d, i=%d\n", intro_len, i);                          log_error("OOM for user introduction: len=%d, i=%d\n", intro_len, i);
192                          break;                          break;
193                  }                  }
194                  memcpy(p_list->user_intro_buf + intro_buf_offset,                  memcpy(p_list->user_intro_buf + intro_buf_offset,
195                             (row[11] == NULL ? "" : row[11]),                             (row[12] == NULL ? "" : row[12]),
196                             intro_len + 1);                             intro_len + 1);
197                  p_list->users[i].intro = p_list->user_intro_buf + intro_buf_offset;                  p_list->users[i].intro = p_list->user_intro_buf + intro_buf_offset;
198                  intro_buf_offset += (intro_len + 1);                  intro_buf_offset += (intro_len + 1);
# Line 236  cleanup: Line 235  cleanup:
235          return ret;          return ret;
236  }  }
237    
238  int user_online_list_load(MYSQL *db, USER_ONLINE_LIST *p_list)  int user_online_list_load(MYSQL *db, USER_ONLINE_LIST *p_online_list)
239  {  {
240          MYSQL_RES *rs = NULL;          MYSQL_RES *rs = NULL;
241          MYSQL_ROW row;          MYSQL_ROW row;
# Line 244  int user_online_list_load(MYSQL *db, USE Line 243  int user_online_list_load(MYSQL *db, USE
243          int ret = 0;          int ret = 0;
244          int i;          int i;
245          int j;          int j;
246            int user_cnt;
247            int guest_cnt;
248    
249          if (db == NULL || p_list == NULL)          if (db == NULL || p_online_list == NULL)
250          {          {
251                  log_error("NULL pointer error\n");                  log_error("NULL pointer error\n");
252                  return -1;                  return -1;
# Line 254  int user_online_list_load(MYSQL *db, USE Line 255  int user_online_list_load(MYSQL *db, USE
255          snprintf(sql, sizeof(sql),          snprintf(sql, sizeof(sql),
256                           "SELECT SID, UID, ip, current_action, UNIX_TIMESTAMP(login_tm), "                           "SELECT SID, UID, ip, current_action, UNIX_TIMESTAMP(login_tm), "
257                           "UNIX_TIMESTAMP(last_tm) FROM user_online "                           "UNIX_TIMESTAMP(last_tm) FROM user_online "
258                           "WHERE last_tm >= SUBDATE(NOW(), INTERVAL %d SECOND) AND UID <> 0 "                           "WHERE last_tm >= SUBDATE(NOW(), INTERVAL %d SECOND) "
259                           "ORDER BY last_tm DESC",                           "ORDER BY last_tm DESC",
260                           BBS_user_off_line);                           BBS_user_off_line);
261    
# Line 273  int user_online_list_load(MYSQL *db, USE Line 274  int user_online_list_load(MYSQL *db, USE
274          }          }
275    
276          i = 0;          i = 0;
277            user_cnt = 0;
278            guest_cnt = 0;
279          while ((row = mysql_fetch_row(rs)))          while ((row = mysql_fetch_row(rs)))
280          {          {
281                  p_list->users[i].id = i;                  if (atoi(row[1]) == 0) // guest
282                  strncpy(p_list->users[i].session_id, row[0], sizeof(p_list->users[i].session_id) - 1);                  {
283                  p_list->users[i].session_id[sizeof(p_list->users[i].session_id) - 1] = '\0';                          guest_cnt++;
284                            continue;
285                    }
286                    else
287                    {
288                            user_cnt++;
289                    }
290    
291                    p_online_list->users[i].id = i;
292                    strncpy(p_online_list->users[i].session_id, row[0], sizeof(p_online_list->users[i].session_id) - 1);
293                    p_online_list->users[i].session_id[sizeof(p_online_list->users[i].session_id) - 1] = '\0';
294    
295                  if ((ret = query_user_info_by_uid(atoi(row[1]), &(p_list->users[i].user_info))) <= 0)                  if ((ret = query_user_info_by_uid(atoi(row[1]), &(p_online_list->users[i].user_info), NULL, 0)) <= 0)
296                  {                  {
297                          log_error("query_user_info_by_uid(%d) error\n", atoi(row[1]));                          log_error("query_user_info_by_uid(%d) error\n", atoi(row[1]));
298                          continue;                          continue;
299                  }                  }
300    
301                  strncpy(p_list->users[i].ip, row[2], sizeof(p_list->users[i].ip) - 1);                  strncpy(p_online_list->users[i].ip, row[2], sizeof(p_online_list->users[i].ip) - 1);
302                  p_list->users[i].ip[sizeof(p_list->users[i].ip) - 1] = '\0';                  p_online_list->users[i].ip[sizeof(p_online_list->users[i].ip) - 1] = '\0';
303    
304                  strncpy(p_list->users[i].current_action, row[3], sizeof(p_list->users[i].current_action) - 1);                  strncpy(p_online_list->users[i].current_action, row[3], sizeof(p_online_list->users[i].current_action) - 1);
305                  p_list->users[i].current_action[sizeof(p_list->users[i].current_action) - 1] = '\0';                  p_online_list->users[i].current_action[sizeof(p_online_list->users[i].current_action) - 1] = '\0';
306                  p_list->users[i].current_action_title = NULL;                  p_online_list->users[i].current_action_title = NULL;
307                  if (p_list->users[i].current_action[0] == '\0')                  if (p_online_list->users[i].current_action[0] == '\0')
308                  {                  {
309                          p_list->users[i].current_action_title = "";                          p_online_list->users[i].current_action_title = "";
310                  }                  }
311                  else if (trie_dict_get(p_trie_action_dict, p_list->users[i].current_action, (int64_t *)(&(p_list->users[i].current_action_title))) < 0)                  else if (trie_dict_get(p_trie_action_dict, p_online_list->users[i].current_action, (int64_t *)(&(p_online_list->users[i].current_action_title))) < 0)
312                  {                  {
313                          log_error("trie_dict_get(p_trie_action_dict, %s) error on session_id=%s\n",                          log_error("trie_dict_get(p_trie_action_dict, %s) error on session_id=%s\n",
314                                            p_list->users[i].current_action, p_list->users[i].session_id);                                            p_online_list->users[i].current_action, p_online_list->users[i].session_id);
315                          continue;                          continue;
316                  }                  }
317    
318                  p_list->users[i].login_tm = (row[4] == NULL ? 0 : atol(row[4]));                  p_online_list->users[i].login_tm = (row[4] == NULL ? 0 : atol(row[4]));
319                  p_list->users[i].last_tm = (row[5] == NULL ? 0 : atol(row[5]));                  p_online_list->users[i].last_tm = (row[5] == NULL ? 0 : atol(row[5]));
320    
321                  i++;                  i++;
322                  if (i >= BBS_max_user_online_count)                  if (i >= BBS_max_user_online_count)
# Line 315  int user_online_list_load(MYSQL *db, USE Line 328  int user_online_list_load(MYSQL *db, USE
328          mysql_free_result(rs);          mysql_free_result(rs);
329          rs = NULL;          rs = NULL;
330    
331          if (i > 0)          if (user_cnt > 0)
332          {          {
333                  // Rebuild index                  // Rebuild index
334                  for (j = 0; j < i; j++)                  for (j = 0; j < user_cnt; j++)
335                  {                  {
336                          p_list->index_uid[j].uid = p_list->users[j].user_info.uid;                          p_online_list->index_uid[j].uid = p_online_list->users[j].user_info.uid;
337                          p_list->index_uid[j].id = j;                          p_online_list->index_uid[j].id = j;
338                  }                  }
339    
340                  qsort(p_list->index_uid, (size_t)i, sizeof(USER_INFO_INDEX_UID), user_info_index_uid_comp);                  qsort(p_online_list->index_uid, (size_t)user_cnt, sizeof(USER_INFO_INDEX_UID), user_info_index_uid_comp);
   
 #ifdef _DEBUG  
                 log_error("Rebuild index of %d online users\n", i);  
 #endif  
341          }          }
342    
343          p_list->user_count = i;          p_online_list->user_count = user_cnt;
344            p_online_list->guest_count = guest_cnt;
 #ifdef _DEBUG  
         log_error("Loaded %d online users\n", p_list->user_count);  
 #endif  
345    
346  cleanup:  cleanup:
347          mysql_free_result(rs);          mysql_free_result(rs);
# Line 343  cleanup: Line 349  cleanup:
349          return ret;          return ret;
350  }  }
351    
352  int user_list_pool_init(void)  int user_login_count_load(MYSQL *db)
353    {
354            MYSQL_RES *rs = NULL;
355            MYSQL_ROW row;
356            char sql[SQL_BUFFER_LEN];
357    
358            if (db == NULL)
359            {
360                    log_error("NULL pointer error\n");
361                    return -1;
362            }
363    
364            snprintf(sql, sizeof(sql),
365                             "SELECT ID FROM user_login_log ORDER BY ID DESC LIMIT 1");
366            if (mysql_query(db, sql) != 0)
367            {
368                    log_error("Query user_login_log error: %s\n", mysql_error(db));
369                    return -2;
370            }
371            if ((rs = mysql_store_result(db)) == NULL)
372            {
373                    log_error("Get user_login_log data failed\n");
374                    return -2;
375            }
376            if ((row = mysql_fetch_row(rs)))
377            {
378                    p_user_list_pool->user_login_count = atoi(row[0]);
379            }
380            mysql_free_result(rs);
381    
382            return 0;
383    }
384    
385    int user_list_pool_init(const char *filename)
386  {  {
387          int shmid;          int shmid;
388          int semid;          int semid;
# Line 377  int user_list_pool_init(void) Line 416  int user_list_pool_init(void)
416    
417          // Allocate shared memory          // Allocate shared memory
418          proj_id = (int)(time(NULL) % getpid());          proj_id = (int)(time(NULL) % getpid());
419          key = ftok(VAR_USER_LIST_SHM, proj_id);          key = ftok(filename, proj_id);
420          if (key == -1)          if (key == -1)
421          {          {
422                  log_error("ftok(%s %d) error (%d)\n", VAR_USER_LIST_SHM, proj_id, errno);                  log_error("ftok(%s %d) error (%d)\n", filename, proj_id, errno);
423                  return -2;                  return -2;
424          }          }
425    
# Line 459  void user_list_pool_cleanup(void) Line 498  void user_list_pool_cleanup(void)
498                  log_error("shmdt(shmid = %d) error (%d)\n", shmid, errno);                  log_error("shmdt(shmid = %d) error (%d)\n", shmid, errno);
499          }          }
500    
501          if (shmctl(shmid, IPC_RMID, NULL) == -1)          if (shmid != 0 && shmctl(shmid, IPC_RMID, NULL) == -1)
502          {          {
503                  log_error("shmctl(shmid = %d, IPC_RMID) error (%d)\n", shmid, errno);                  log_error("shmctl(shmid = %d, IPC_RMID) error (%d)\n", shmid, errno);
504          }          }
# Line 541  int user_list_pool_reload(int online_use Line 580  int user_list_pool_reload(int online_use
580                          ret = -2;                          ret = -2;
581                          goto cleanup;                          goto cleanup;
582                  }                  }
583    
584                    if (user_login_count_load(db) < 0)
585                    {
586                            log_error("user_login_count_load() error\n");
587                            ret = -2;
588                            goto cleanup;
589                    }
590          }          }
591          else          else
592          {          {
# Line 854  cleanup: Line 900  cleanup:
900          return ret;          return ret;
901  }  }
902    
903    int get_user_list_count(int *p_user_cnt)
904    {
905            if (p_user_cnt == NULL)
906            {
907                    log_error("NULL pointer error\n");
908                    return -1;
909            }
910    
911            // acquire lock of user list
912            if (user_list_rd_lock(p_user_list_pool->semid) < 0)
913            {
914                    log_error("user_list_rd_lock() error\n");
915                    return -2;
916            }
917    
918            *p_user_cnt = p_user_list_pool->p_current->user_count;
919    
920            // release lock of user list
921            if (user_list_rd_unlock(p_user_list_pool->semid) < 0)
922            {
923                    log_error("user_list_rd_unlock() error\n");
924                    return -2;
925            }
926    
927            return 0;
928    }
929    
930    int get_user_online_list_count(int *p_user_cnt, int *p_guest_cnt)
931    {
932            if (p_user_cnt == NULL || p_guest_cnt == NULL)
933            {
934                    log_error("NULL pointer error\n");
935                    return -1;
936            }
937    
938            // acquire lock of user list
939            if (user_list_rd_lock(p_user_list_pool->semid) < 0)
940            {
941                    log_error("user_list_rd_lock() error\n");
942                    return -2;
943            }
944    
945            *p_user_cnt = p_user_list_pool->p_online_current->user_count;
946            *p_guest_cnt = p_user_list_pool->p_online_current->guest_count;
947    
948            // release lock of user list
949            if (user_list_rd_unlock(p_user_list_pool->semid) < 0)
950            {
951                    log_error("user_list_rd_unlock() error\n");
952                    return -2;
953            }
954    
955            return 0;
956    }
957    
958    int get_user_login_count(int *p_login_cnt)
959    {
960            if (p_login_cnt == NULL)
961            {
962                    log_error("NULL pointer error\n");
963                    return -1;
964            }
965    
966            *p_login_cnt = p_user_list_pool->user_login_count;
967    
968            return 0;
969    }
970    
971  int query_user_info(int32_t id, USER_INFO *p_user)  int query_user_info(int32_t id, USER_INFO *p_user)
972  {  {
973          int ret = 0;          int ret = 0;
# Line 887  int query_user_info(int32_t id, USER_INF Line 1001  int query_user_info(int32_t id, USER_INF
1001          return ret;          return ret;
1002  }  }
1003    
1004  int query_user_info_by_uid(int32_t uid, USER_INFO *p_user)  int query_user_info_by_uid(int32_t uid, USER_INFO *p_user, char *p_intro_buf, size_t intro_buf_len)
1005  {  {
1006          int left;          int left;
1007          int right;          int right;
# Line 916  int query_user_info_by_uid(int32_t uid, Line 1030  int query_user_info_by_uid(int32_t uid,
1030                  mid = (left + right) / 2;                  mid = (left + right) / 2;
1031                  if (uid < p_user_list_pool->p_current->index_uid[mid].uid)                  if (uid < p_user_list_pool->p_current->index_uid[mid].uid)
1032                  {                  {
1033                          right = mid;                          right = mid - 1;
1034                  }                  }
1035                  else if (uid > p_user_list_pool->p_current->index_uid[mid].uid)                  else if (uid > p_user_list_pool->p_current->index_uid[mid].uid)
1036                  {                  {
# Line 934  int query_user_info_by_uid(int32_t uid, Line 1048  int query_user_info_by_uid(int32_t uid,
1048                  id = p_user_list_pool->p_current->index_uid[left].id;                  id = p_user_list_pool->p_current->index_uid[left].id;
1049                  *p_user = p_user_list_pool->p_current->users[id];                  *p_user = p_user_list_pool->p_current->users[id];
1050                  ret = 1;                  ret = 1;
1051    
1052                    if (p_intro_buf != NULL)
1053                    {
1054                            strncpy(p_intro_buf, p_user_list_pool->p_current->users[id].intro, intro_buf_len - 1);
1055                            p_intro_buf[intro_buf_len - 1] = '\0';
1056                            p_user->intro = p_intro_buf;
1057                    }
1058          }          }
1059    
1060          // release lock of user list          // release lock of user list
# Line 946  int query_user_info_by_uid(int32_t uid, Line 1067  int query_user_info_by_uid(int32_t uid,
1067          return ret;          return ret;
1068  }  }
1069    
1070    int query_user_info_by_username(const char *username_prefix, int max_user_cnt,
1071                                                                    int32_t uid_list[], char username_list[][BBS_username_max_len + 1])
1072    {
1073            int left;
1074            int right;
1075            int mid;
1076            int left_save;
1077            int ret = 0;
1078            size_t prefix_len;
1079            int comp;
1080            int i;
1081    
1082            if (username_prefix == NULL || uid_list == NULL || username_list == NULL)
1083            {
1084                    log_error("NULL pointer error\n");
1085                    return -1;
1086            }
1087    
1088            prefix_len = strlen(username_prefix);
1089    
1090            // acquire lock of user list
1091            if (user_list_rd_lock(p_user_list_pool->semid) < 0)
1092            {
1093                    log_error("user_list_rd_lock() error\n");
1094                    return -2;
1095            }
1096    
1097            left = 0;
1098            right = p_user_list_pool->p_current->user_count - 1;
1099    
1100            while (left < right)
1101            {
1102                    mid = (left + right) / 2;
1103                    comp = strncasecmp(username_prefix, p_user_list_pool->p_current->users[mid].username, prefix_len);
1104                    if (comp < 0)
1105                    {
1106                            right = mid - 1;
1107                    }
1108                    else if (comp > 0)
1109                    {
1110                            left = mid + 1;
1111                    }
1112                    else // if (comp == 0)
1113                    {
1114                            left = mid;
1115                            break;
1116                    }
1117            }
1118    
1119            if (strncasecmp(username_prefix, p_user_list_pool->p_current->users[left].username, prefix_len) == 0) // Found
1120            {
1121    #ifdef _DEBUG
1122                    log_error("Debug: match found, pos=%d\n", left);
1123    #endif
1124    
1125                    left_save = left;
1126                    right = left;
1127                    left = 0;
1128    
1129                    while (left < right)
1130                    {
1131                            mid = (left + right) / 2;
1132                            comp = strncasecmp(username_prefix, p_user_list_pool->p_current->users[mid].username, prefix_len);
1133                            if (comp > 0)
1134                            {
1135                                    left = mid + 1;
1136                            }
1137                            else if (comp == 0)
1138                            {
1139                                    right = mid;
1140                            }
1141                            else // if (comp < 0)
1142                            {
1143                                    log_error("Bug: left=%d right=%d mid=%d");
1144                                    ret = -2;
1145                                    goto cleanup;
1146                            }
1147                    }
1148    
1149    #ifdef _DEBUG
1150                    log_error("Debug: first match found, pos=%d\n", right);
1151    #endif
1152    
1153                    left = left_save;
1154                    left_save = right;
1155                    right = p_user_list_pool->p_current->user_count - 1;
1156    
1157                    while (left < right)
1158                    {
1159                            mid = (left + right) / 2 + (left + right) % 2;
1160                            comp = strncasecmp(username_prefix, p_user_list_pool->p_current->users[mid].username, prefix_len);
1161                            if (comp < 0)
1162                            {
1163                                    right = mid - 1;
1164                            }
1165                            else if (comp == 0)
1166                            {
1167                                    left = mid;
1168                            }
1169                            else // if (comp > 0)
1170                            {
1171                                    log_error("Bug: left=%d right=%d mid=%d");
1172                                    ret = -2;
1173                                    goto cleanup;
1174                            }
1175                    }
1176    
1177    #ifdef _DEBUG
1178                    log_error("Debug: last match found, pos=%d\n", left);
1179    #endif
1180    
1181                    right = left;
1182                    left = left_save;
1183    
1184                    for (i = 0; i < max_user_cnt && left + i <= right; i++)
1185                    {
1186                            uid_list[i] = p_user_list_pool->p_current->users[left + i].uid;
1187                            strncpy(username_list[i], p_user_list_pool->p_current->users[left + i].username, sizeof(username_list[i]) - 1);
1188                            username_list[i][sizeof(username_list[i]) - 1] = '\0';
1189                    }
1190                    ret = i;
1191            }
1192    
1193    cleanup:
1194            // release lock of user list
1195            if (user_list_rd_unlock(p_user_list_pool->semid) < 0)
1196            {
1197                    log_error("user_list_rd_unlock() error\n");
1198                    ret = -1;
1199            }
1200    
1201            return ret;
1202    }
1203    
1204  int query_user_online_info(int32_t id, USER_ONLINE_INFO *p_user)  int query_user_online_info(int32_t id, USER_ONLINE_INFO *p_user)
1205  {  {
1206          int ret = 0;          int ret = 0;
# Line 987  int query_user_online_info_by_uid(int32_ Line 1242  int query_user_online_info_by_uid(int32_
1242          int32_t id;          int32_t id;
1243          int ret = 0;          int ret = 0;
1244          int i;          int i;
1245            int user_cnt;
1246    
1247          if (p_users == NULL || p_user_cnt == NULL)          if (p_users == NULL || p_user_cnt == NULL)
1248          {          {
# Line 994  int query_user_online_info_by_uid(int32_ Line 1250  int query_user_online_info_by_uid(int32_
1250                  return -1;                  return -1;
1251          }          }
1252    
1253            user_cnt = *p_user_cnt;
1254            *p_user_cnt = 0;
1255    
1256          // acquire lock of user list          // acquire lock of user list
1257          if (user_list_rd_lock(p_user_list_pool->semid) < 0)          if (user_list_rd_lock(p_user_list_pool->semid) < 0)
1258          {          {
# Line 1009  int query_user_online_info_by_uid(int32_ Line 1268  int query_user_online_info_by_uid(int32_
1268                  mid = (left + right) / 2;                  mid = (left + right) / 2;
1269                  if (uid < p_user_list_pool->p_online_current->index_uid[mid].uid)                  if (uid < p_user_list_pool->p_online_current->index_uid[mid].uid)
1270                  {                  {
1271                          right = mid;                          right = mid - 1;
1272                  }                  }
1273                  else if (uid > p_user_list_pool->p_online_current->index_uid[mid].uid)                  else if (uid > p_user_list_pool->p_online_current->index_uid[mid].uid)
1274                  {                  {
# Line 1041  int query_user_online_info_by_uid(int32_ Line 1300  int query_user_online_info_by_uid(int32_
1300                  }                  }
1301    
1302                  for (i = 0;                  for (i = 0;
1303                           left < p_user_list_pool->p_online_current->user_count && i < *p_user_cnt &&                           left < p_user_list_pool->p_online_current->user_count && i < user_cnt &&
1304                           uid == p_user_list_pool->p_online_current->index_uid[left].uid;                           uid == p_user_list_pool->p_online_current->index_uid[left].uid;
1305                           left++, i++)                           left++, i++)
1306                  {                  {
# Line 1095  int get_user_id_list(int32_t *p_uid_list Line 1354  int get_user_id_list(int32_t *p_uid_list
1354                  mid = (left + right) / 2;                  mid = (left + right) / 2;
1355                  if (start_uid < p_user_list_pool->p_current->index_uid[mid].uid)                  if (start_uid < p_user_list_pool->p_current->index_uid[mid].uid)
1356                  {                  {
1357                          right = mid;                          right = mid - 1;
1358                  }                  }
1359                  else if (start_uid > p_user_list_pool->p_current->index_uid[mid].uid)                  else if (start_uid > p_user_list_pool->p_current->index_uid[mid].uid)
1360                  {                  {

Legend:
Removed lines/characters  
Changed lines/characters
  Added lines/characters
webmaster@leafok.com
 ViewVC Help
Powered by ViewVC 1.3.0-beta1