|
@@ -169,14 +169,12 @@ void vmnet_push_data(rx_command command) {
|
|
int approve_size = MIN(size, MAX_BUFFER_SIZE - vmnet_queue_waiting_buffer->length);
|
|
int approve_size = MIN(size, MAX_BUFFER_SIZE - vmnet_queue_waiting_buffer->length);
|
|
if (approve_size > 0) {
|
|
if (approve_size > 0) {
|
|
memcpy(&vmnet_queue_waiting_buffer->buffer[vmnet_queue_waiting_buffer->length], &command.sstdin[0], approve_size);
|
|
memcpy(&vmnet_queue_waiting_buffer->buffer[vmnet_queue_waiting_buffer->length], &command.sstdin[0], approve_size);
|
|
- log_message("append (%d, %d)", vmnet_queue_waiting_buffer->length, approve_size);
|
|
|
|
vmnet_queue_waiting_buffer->length += approve_size;
|
|
vmnet_queue_waiting_buffer->length += approve_size;
|
|
}
|
|
}
|
|
|
|
|
|
if (!has_next) {
|
|
if (!has_next) {
|
|
if (vmnet_queue_front == NULL) {
|
|
if (vmnet_queue_front == NULL) {
|
|
vmnet_queue_front = vmnet_queue_waiting_buffer;
|
|
vmnet_queue_front = vmnet_queue_waiting_buffer;
|
|
- log_message("setup to queue: %d", vmnet_queue_waiting_buffer->length);
|
|
|
|
}
|
|
}
|
|
else {
|
|
else {
|
|
vmnet_queue_elem *elem, *elem_prev;
|
|
vmnet_queue_elem *elem, *elem_prev;
|
|
@@ -184,7 +182,6 @@ void vmnet_push_data(rx_command command) {
|
|
elem_prev = elem;
|
|
elem_prev = elem;
|
|
}
|
|
}
|
|
elem_prev->next = vmnet_queue_waiting_buffer;
|
|
elem_prev->next = vmnet_queue_waiting_buffer;
|
|
- log_message("add to queue: %d", vmnet_queue_waiting_buffer->length);
|
|
|
|
}
|
|
}
|
|
vmnet_queue_waiting_buffer->next = NULL;
|
|
vmnet_queue_waiting_buffer->next = NULL;
|
|
vmnet_queue_waiting_buffer = NULL;
|
|
vmnet_queue_waiting_buffer = NULL;
|