240 log_dup_list = ucx_list_append(log_dup_list, dup); |
240 log_dup_list = ucx_list_append(log_dup_list, dup); |
241 ws_atomic_inc32(&log_dup_count); |
241 ws_atomic_inc32(&log_dup_count); |
242 pthread_mutex_unlock(&mutex); |
242 pthread_mutex_unlock(&mutex); |
243 } |
243 } |
244 |
244 |
245 void log_remove_logdup(LogDup *dup) { |
245 void log_remove_logdup(LogDup *ldup) { |
246 pthread_mutex_lock(&mutex); |
246 pthread_mutex_lock(&mutex); |
247 UcxList *elm = log_dup_list; |
247 UcxList *elm = log_dup_list; |
248 while(elm) { |
248 while(elm) { |
249 if(elm->data = dup) { |
249 if(elm->data == ldup) { |
250 log_dup_list = ucx_list_remove(log_dup_list, elm); |
250 log_dup_list = ucx_list_remove(log_dup_list, elm); |
251 ws_atomic_dec32(&log_dup_count); |
251 ws_atomic_dec32(&log_dup_count); |
252 break; |
252 break; |
253 } |
253 } |
254 elm = elm->next; |
254 elm = elm->next; |