ebouther / ada-async-protocol-based-on-udp Goto Github PK

ESC[31mException : BUFFER_HANDLING.COPY_PACKET_DATA_TO_DEST.BAD_INDEX
ESC[33mIndex [ 409606080] bigger that buffer size [ 409600000]ESC[0m

ACK [ 64 ]: Dropped : 32766 <- Lost
ACK [ 64 ]: Dropped : 32767 <- Lost
ACK [ 64 ]: Dropped : 0 <- Lost
ACK [ 64 ]: Dropped : 1 <- Lost
ACK [ 64 ]: Dropped : 87
ACK [ 64 ]: Dropped : 90
ACK [ 64 ]: Dropped : 91
ACK [ 64 ]: Dropped : 92
ACK [ 64 ]: Dropped : 8303
ACK [ 64 ]: Dropped : 28719
ACK [ 64 ]: Dropped : 28720
ACK [ 64 ]: Dropped : 28721
ACK [ 64 ]: Dropped : 28724
ACK [ 64 ]: Dropped : 28725
ACK [ 64 ]: Dropped : 28726
ACK [ 64 ]: Dropped : 28727
ACK [ 64 ]: Dropped : 28741
ACK [ 64 ]: Dropped : 11119
ACK [ 64 ]: Dropped : 29069

~ 4.96 Gb/s

Doesn't work if consumer confirmation packet is lost.

////////////\\\// DEBIT : 9.92272264346716E+09
-- Nb output : 62642
-- Nb_received : 8661839049
-- Last Packet Received : 12384
-- Dropped : 426903
-- Delta in bits : 9925400608
-- Ratio (dropped / total_sent) : 4.92830631575603E-05
-- Elapsed Time : 62646.888928000
-- Pps : 1.38264472461754E+05

-- Nb output : 92619
-- Nb_received : 12791790210
-- Last Packet Received : 7902
-- Dropped : 162731
-- Delta in bits : 9918581888
-- Ratio (dropped / total_sent) : 1.27213569929908E-05
-- Elapsed Time : 92715.836068000
-- Pps : 1.37967695190908E+05

mlock / mlockall requires priviledges (CAP_IPC_LOCK) to lock more than RLIMIT_MEMLOCK.

Current : 14
First : 14
Current : 15
First : 15
Current : 0
Current : 1
Current : 2
Current : 3

Current : 4
Current : 5
Current : 6
Current : 7

Current : 8
Current : 9
Current : 10
Current : 11
-- Nb output : 462
-- Nb_received : 63814123
-- Last Packet Received : 19451
-- Dropped : 2386
-- Delta in bits : 9834029760
-- Ratio (dropped / total_sent) : 3.73884444227433E-05
-- Elapsed Time : 462.326683000
-- Pps : 1.38028206777760E+05

Current : 12
Current : 13
Current : 14
[Switching to Thread 0x7ffff3228700 (LWP 33072)]

Catchpoint 1, PACKET_MGR.PMH_BUFFER_ADDR.NOT_RELEASED_FAST_ENOUGH (packet_mgr.adb:170) at <__gnat_debug_raise_exception> (e=0x74cb00 <not_released_fast_enough>, message=...) at s-excdeb.adb:43
43 s-excdeb.adb: No such file or directory.
(gdb) bt
#0 <__gnat_debug_raise_exception> (e=0x74cb00 <not_released_fast_enough>, message=...)

at s-excdeb.adb:43

#1 0x00000000004919b8 in ada.exceptions.complete_occurrence (x=x@entry=0x7fffcc000900)

at a-except.adb:925

#2 0x00000000004919c7 in ada.exceptions.complete_and_propagate_occurrence (

x=x@entry=0x7fffcc000900) at a-except.adb:936

#3 0x0000000000491a1a in <__gnat_raise_exception> (

e=e@entry=0x74cb00 <not_released_fast_enough>, message=...) at a-except.adb:978

#4 0x0000000000453526 in <packet_mgr__pmh_buffer_addr__L_7__B102b__new_buffer_addrA1> ()

at /home/boutherin/repository/RATP/src/packet_mgr.adb:170

#5 packet_mgr.pmh_buffer_addr (<_task>=)

at /home/boutherin/repository/RATP/src/packet_mgr.adb:165

#6 0x0000000000482e88 in system.tasking.stages.task_wrapper ()

Append_2 Elapsed : 0.000000378 Time : 0.953226854
Ack : FALSE Missed : 6 Elapsed : 0.000024646 Time : 0.953209737

Kernel gives process physical memory on socket receive which causes packets drops.

1. Set : 32766
2. Set : 32767
3. Set : 0
   Current : 5
4. Set : 1
   Good Loc index : 2
   Sequence_Size : 32768
   Last Pkt : 32767
   ** Manage Loss I: 32766
   **** Error !!
   ** LAST ADDR: 32766 32766
   -- Write in LAST to pos : 32766
   ** LAST ADDR: 32767 32766
   -- Write in LAST to pos : 32767
   ** NEW ADDR: 32768 32766
   -- Write in NEW to pos : 0
   ** NEW ADDR: 32769 32766
   -- Write in NEW to pos : 1
   Current : 6
5. Set : 16
6. Set : 17
   Good Loc index : 15476
   Sequence_Size : 32768
   Last Pkt : 32767
7. Set : 18
   ** Manage Loss I: 16
8. Set : 19
9. Set : 20
10. Set : 21
11. Set : 22

1. Set : 30116
   Ack : FALSE Missed : 1 Elapsed : 0.000022804
   ** Manage Loss I: 30116 Missed : 1
2. Set : 30118
3. Set : 30119
   Ack : FALSE Missed : 2 Elapsed : 0.000009844
   ** Manage Loss I: 30118 Missed : 2
4. Set : 30121
5. Set : 30122
   Ack : FALSE Missed : 2 Elapsed : 0.000009709
   ** Manage Loss I: 30121 Missed : 2
6. Set : 30124
7. Set : 30125

It only happens when too many packets are dropped.

Got to get filled buffers synchronously to have correct information about its size.
In the case of size exceeding receive buffer size.

Exception : CONSTRAINT_ERROR
buffer_handling.adb:485 access check failed

484                             (1 .. Stream_Element_Offset                          
485                                (Buffers.Get_Available_Bytes (Dest_Handle.all)));```

1.Tests

2.Algo

3.Udp / Tcp