|
|
@@ -187,6 +187,7 @@ void* log_producer_read_persistent_thread(void* param)
|
|
|
|
|
|
|
|
|
send_param = create_log_producer_send_param(config, producer_manager, lz4_buf, builder);
|
|
|
+ /*
|
|
|
int i = 0;
|
|
|
for (i = 0; i < send_param->log_buf->n_logs; i++)
|
|
|
{
|
|
|
@@ -195,7 +196,7 @@ void* log_producer_read_persistent_thread(void* param)
|
|
|
memcpy(uuid, send_param->log_buf->uuid[i], MAX_UUID_LEN);
|
|
|
send_log_data("http://127.0.0.1:9000/read_uuid", uuid);
|
|
|
}
|
|
|
-
|
|
|
+ */
|
|
|
|
|
|
producer_manager->send_param_queue[producer_manager->send_param_queue_write++ % producer_manager->send_param_queue_size] = send_param;//放入发送队列
|
|
|
CS_LEAVE(producer_manager->lock);
|