Skip to content

Commit 0197cd0

Browse files
devdev
authored andcommitted
Removed restrict in case of thread issues
1 parent bdcf83a commit 0197cd0

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/process_packets.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ static inline bool check_packet_already_completed(const uint16_t packet_id, stru
112112
return false;
113113
}
114114

115-
static inline struct SwiftNetPendingMessage* const get_pending_message(const struct SwiftNetPacketInfo* const restrict packet_info, struct SwiftNetVector* const pending_messages_vector, const enum ConnectionType connection_type, const struct in_addr sender_address, const uint16_t packet_id) {
115+
static inline struct SwiftNetPendingMessage* const get_pending_message(struct SwiftNetVector* const pending_messages_vector, const enum ConnectionType connection_type, const struct in_addr sender_address, const uint16_t packet_id) {
116116
vector_lock(pending_messages_vector);
117117

118118
for(uint32_t i = 0; i < pending_messages_vector->size; i++) {
@@ -231,7 +231,7 @@ static inline void chunk_received(uint8_t* const chunks_received, const uint32_t
231231
chunks_received[byte] |= 1 << bit;
232232
}
233233

234-
static inline struct SwiftNetPendingMessage* const create_new_pending_message(struct SwiftNetVector* const pending_messages, struct SwiftNetMemoryAllocator* const pending_messages_memory_allocator, const struct SwiftNetPacketInfo* const restrict packet_info, const enum ConnectionType connection_type, const struct in_addr sender_address, const uint16_t packet_id) {
234+
static inline struct SwiftNetPendingMessage* const create_new_pending_message(struct SwiftNetVector* const pending_messages, struct SwiftNetMemoryAllocator* const pending_messages_memory_allocator, const struct SwiftNetPacketInfo* const packet_info, const enum ConnectionType connection_type, const struct in_addr sender_address, const uint16_t packet_id) {
235235
struct SwiftNetPendingMessage* const new_pending_message = allocator_allocate(pending_messages_memory_allocator);
236236

237237
uint8_t* const allocated_memory = malloc(packet_info->packet_length);
@@ -435,7 +435,7 @@ static inline void swiftnet_process_packets(
435435
{
436436
const uint32_t mtu = MIN(packet_info.maximum_transmission_unit, maximum_transmission_unit);
437437

438-
struct SwiftNetPendingMessage* const pending_message = get_pending_message(&packet_info, pending_messages, connection_type, ip_header.ip_src, ip_header.ip_id);
438+
struct SwiftNetPendingMessage* const pending_message = get_pending_message(pending_messages, connection_type, ip_header.ip_src, ip_header.ip_id);
439439
if(pending_message == NULL) {
440440
const bool packet_already_completed = check_packet_already_completed(ip_header.ip_id, packets_completed_history);
441441
if(likely(packet_already_completed == true)) {
@@ -559,7 +559,7 @@ static inline void swiftnet_process_packets(
559559
const uint32_t mtu = MIN(packet_info.maximum_transmission_unit, maximum_transmission_unit);
560560
const uint32_t chunk_data_size = mtu - PACKET_HEADER_SIZE;
561561

562-
struct SwiftNetPendingMessage* const pending_message = get_pending_message(&packet_info, pending_messages, connection_type, node->sender_address, ip_header.ip_id);
562+
struct SwiftNetPendingMessage* const pending_message = get_pending_message(pending_messages, connection_type, node->sender_address, ip_header.ip_id);
563563

564564
if(pending_message == NULL) {
565565
if(packet_info.packet_length > chunk_data_size) {

0 commit comments

Comments
 (0)