pa/eqemu-server
2
0
Fork 0
mirror of https://github.com/EQEmu/Server.git synced 2025-12-13 14:41:28 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update daybreak_connection.cpp

Browse Source
This commit is contained in:
Akkadius 2025-01-27 15:41:05 -06:00
parent fab02799a7
commit 6b548576da
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
common/net/daybreak_connection.cpp
View File

@ -64,7 +64,7 @@ void EQ::Net::DaybreakConnectionManager::Attach(uv_loop_t *loop)
rc = uv_udp_recv_start(&m_socket, rc = uv_udp_recv_start(&m_socket,
[](uv_handle_t* handle, size_t suggested_size, uv_buf_t* buf) { [](uv_handle_t* handle, size_t suggested_size, uv_buf_t* buf) {
int current_buffer_index = buffer_index.fetch_add(1) % NUM_STATIC_BUFFERS; int current_buffer_index = buffer_index.fetch_add(1) % NUM_STATIC_BUFFERS;
std::cout << "recv current_buffer_index: " << current_buffer_index << " current_thread_id: " << std::this_thread::get_id() << std::endl; // std::cout << "recv current_buffer_index: " << current_buffer_index << " current_thread_id: " << std::this_thread::get_id() << std::endl;
char* buffer = static_buffers[current_buffer_index]; char* buffer = static_buffers[current_buffer_index];
// clear the buffer // clear the buffer
memset(buffer, 0, 512); memset(buffer, 0, 512);
@ -78,7 +78,7 @@ void EQ::Net::DaybreakConnectionManager::Attach(uv_loop_t *loop)
return; return;
} }
std::cout << "recv nread: " << nread << " current_thread_id: " << std::this_thread::get_id() << std::endl; // std::cout << "recv nread: " << nread << " current_thread_id: " << std::this_thread::get_id() << std::endl;
char endpoint[16]; char endpoint[16];
uv_ip4_name((const sockaddr_in*)addr, endpoint, 16); uv_ip4_name((const sockaddr_in*)addr, endpoint, 16);
@ -538,7 +538,7 @@ void EQ::Net::DaybreakConnection::AddToQueue(int stream, uint16_t seq, const Pac
auto iter = s->packet_queue.find(seq); auto iter = s->packet_queue.find(seq);
if (s->packet_queue.bucket_count() < seq) { if (s->packet_queue.bucket_count() < seq) {
std::cout << "Resizing packet queue to " << seq << std::endl; // std::cout << "Resizing packet queue to " << seq << std::endl;
s->packet_queue.reserve(seq); s->packet_queue.reserve(seq);
} }
@ -1333,7 +1333,7 @@ void EQ::Net::DaybreakConnection::InternalSend(Packet &p)
// Select the next static buffer in a round-robin manner // Select the next static buffer in a round-robin manner
int current_buffer_index = buffer_index.fetch_add(1) % NUM_STATIC_BUFFERS; int current_buffer_index = buffer_index.fetch_add(1) % NUM_STATIC_BUFFERS;
std::cout << "current_buffer_index: " << current_buffer_index << " current_thread_id: " << std::this_thread::get_id() << std::endl; // std::cout << "current_buffer_index: " << current_buffer_index << " current_thread_id: " << std::this_thread::get_id() << std::endl;
char* buffer = static_buffers[current_buffer_index]; char* buffer = static_buffers[current_buffer_index];
// clear the buffer // clear the buffer
memset(buffer, 0, 512); memset(buffer, 0, 512);