mirrors/byedpi
1
0
Fork 0
mirror of https://github.com/hufrea/byedpi.git synced 2024-11-22 06:55:22 +03:00
Code Issues Projects Releases Packages Wiki Activity

Reapply "Use original tcp_info struct"

Browse source 
This reverts commit e96aeff679.
This commit is contained in:
ruti 2024-08-19 15:56:18 +03:00
parent ff65b9f780
commit 6d21aae7b5
2 changed files with 8 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
desync.c
View file

@ -11,13 +11,12 @@
#include <sys/mman.h>
#include <arpa/inet.h>
#include <fcntl.h>
#ifndef __linux__
#include <netinet/tcp.h>
#else
#include <sys/sendfile.h>
#include <linux/tcp.h>
#include <sys/syscall.h>
#define memfd_create(name, flags) syscall(__NR_memfd_create, name, flags)
@ -84,24 +83,25 @@ static inline void delay(long ms)
void wait_send(int sfd)
{
for (int i = 0; params.wait_send && i < 500; i++) {
struct tcpi tcpi = {};
struct tcp_info tcpi = {};
socklen_t ts = sizeof(tcpi);
if (getsockopt(sfd, IPPROTO_TCP,
TCP_INFO, (char *)&tcpi, &ts) < 0) {
uniperror("getsockopt TCP_INFO");
perror("getsockopt TCP_INFO");
break;
}
if (tcpi.state != 1) {
LOG(LOG_E, "state: %d\n", tcpi.state);
if (tcpi.tcpi_state != 1) {
LOG(LOG_E, "state: %d\n", tcpi.tcpi_state);
return;
}
if (ts < sizeof(tcpi)) {
size_t s = (char *)&tcpi.tcpi_notsent_bytes - (char *)&tcpi.tcpi_state;
if (ts < s) {
LOG(LOG_E, "tcpi_notsent_bytes not provided\n");
params.wait_send = 0;
break;
}
if (tcpi.notsent_bytes == 0) {
if (tcpi.tcpi_notsent_bytes == 0) {
return;
}
LOG(LOG_S, "not sent after %d ms\n", i);

9
desync.h
View file

@ -18,13 +18,4 @@ int get_family(struct sockaddr *dst);
int setttl(int fd, int ttl, int family);
struct tcpi {
uint8_t state;
uint8_t r[3];
uint32_t rr[5];
uint32_t unacked;
uint32_t rrr[29];
uint32_t notsent_bytes;
};
#endif