Funkcje read, recv,… często zwracają mniej niż podana w argumentach wielkość bufora. Powód? Mniej danych przyszło lub skończyło się miejsce w buforze odbiorczym¹⁾. Może się tak stać nawet pomimo ustawienia flagi MSG_WAITALL w funkcji recv i podobnych (żądającej odebrania dokładnie tylu bajtów ile podano), np. w przypadku zakończenia połączenia.

Funkcje write, send,… mogą też w pewnych okolicznościach wysłać mniejszą ilość bajtów niż zażądano. Jest to spowodowane zapełnieniem systemowego buforu wysyłania (czyli jeśli dane są dostarczane do wysłania szybciej niż można je wysyłać). Normalnie funkcje zapisujące blokują się do momentu aż w buforze będzie dość miejsca. Jeśli jednak gniazdo pracuje w trybie nieblokującym (patrz niżej), to funkcje takie jak write, send, … zapiszą tylko część danych jeśli w buforze systemowym skończy się miejsce.

Dlatego zarówno przy odbieraniu jak i wysyłaniu trzeba sprawdzać zwracaną ilość przetworzonych danych.

Zasadniczo funkcje które wymagają wysłania lub odebrania danych z sieci mogą się zablokować, tj. po ich wywołaniu program zatrzymuje się do czasu zakończenia żądanej operacji (por. z definicją blocking z POSIX).
Przykłady funkcji które mogą się zablokować to:

• read / recv / recvfrom (czeka aż przyjdą dane)
• write / send (czeka aż zwolni się miejsce w buforze nadawczym)
• connect (czeka aż uda się nawiązać połączenie)
• accept (czeka aż przyjdzie nowe połączenie)
• gethostbyname / getaddrinfo (czeka na odpowiedź od serwera nazw, o ile zaszła konieczność odpytania).

Można zmienić domyśle blokujące zachowanie przestawiając gniazdo w tryb nieblokujący.
Jeśli wykonanie żądanej funkcji na gnieździe w trybie nieblokującym nie jest możliwe bez czekania, to wykonanie funkcji nie powodzi się (zwracany jest wynik -1) a zmienna errno jest ustawiana na EAGAIN lub EWOULDBLOCK²⁾.
Gniazdo przestawia się w tryb nieblokujący podobnie jak każdy inny deskryptor pliku:

fcntl(fd, F_SETFL, fcntl(fd, F_GETFL) | O_NONBLOCK)

recv(fileDescriptor, buff, buffSize, MSG_DONTWAIT);

Według standardu POSIX z 2024 roku tryb nieblokujący można ustawiać też sumując ostatni argument funkcji socket ze stałą SOCK_NONBLOCK [1], jak i ustawiając flagę SOCK_NONBLOCK w polu flag funkcji accept4 [2] (wersja funkcji accept z dodatkowym polem flag). Linux od dawna wspiera stałą SOCK_NONBLOCK.

Zadanie 1 Stwórz serwer TCP, który w pętli akceptuje nowe połączenia i je ignoruje (tzn. nie odbiera ani nie wysyła danych, nie zamyka połączeń).

Zadanie 2 Stwórz klienta TCP który:

• łączy się pod podany adres
• w pętli:
  • wysyła dane
  • wypisuje kolejny numer i ilość wysłanych danych

Możesz sprawdzić poleceniem netstat, np. netstat -tn, ile bajtów jest w buforze odbiorczym/nadawczym (kolumny Recv-Q i Send-Q).

Zadanie 3 Stwórz klienta TCP który:

• łączy się pod podany adres
• ustawia tryb nieblokujący
• w pętli:
  • wysyła dane
  • wypisuje kolejny numer i ilość wysłanych danych
  • jeśli wysłał mniej danych niż chciał, kończy się

Zadanie 4 Napisz serwer TCP który po odebraniu połączenia, do jego zamknięcia, wykonuje w pętli:

• odbiera do 10 bajtów
• wypisuje ile bajtów odebrał i co odebrał

Zadanie 5a Napisz klienta TCP który wysyła cały alfabet po jednej literze. Podłącz się (wielokrotnie) do serwera z zadania 4.
Zadanie 5b Napisz klienta TCP który wysyła wielokrotnie⁴⁾ po kilkanaście liter. Podłącz się (wielokrotnie) do serwera z zadania 4.

Zadanie 6 Powtórz zadanie 4 dla UDP.
Zadanie 7 Powtórz zadanie 5a i 5b dla UDP.

Zadanie 8 Napisz klienta TCP który w wielokrotnie:

ip link set lo mtu 1500
tc qdisc add dev lo root netem delay 2ms 3ms 90% distribution pareto

ip link set lo mtu 65535
tc qdisc del dev lo root

Zadanie 9 Jak w strumieniu danych – czyli w połączeniu TCP – przesyłać dane tak by serwer wiedział kiedy cała wiadomość dotrze?

Zadanie 10 Jak w protokole UDP zapewnić, że cała wiadomość została odebrana?

Zadanie 11 Wykonaj z roota poniższe polecenie, które spowoduje pomieszanie kolejności pakietów wysłanych przez interfejs lo.
Następnie uruchom ponownie programy z zadań 4÷7.

tc qdisc add dev lo root netem delay 5ms 5ms distribution normal loss 10%

Aby przywrócić domyślne zachowanie po wykonaniu ćwiczeń, możesz wpisać:

tc qdisc del root dev lo

Zadanie 12 Przygotuj program, który wyśle 1000 pakietów UDP zawierających kolejne liczby.

Zadanie 13 Wykonaj z roota poniższe polecenie, które spowoduje ograniczenie prędkości wysyłania pakietów i przetestuj program z poprzedniego zadania:

tc qdisc add dev lo root tbf rate 10kbps burst 1.5kb limit 10kb

Dla TCP możesz zobaczyć gromadzone przez system operacyjny informacje używane do dobrania prędkości do możliwości łącza używając polecenia ss z przełącznikiem i, np:      ss -atip

Zadanie 14 Jak w protokole UDP radzić sobie z kolejnością pakietów? Jak radzić sobie ze zgubieniem pakietów?

Funkcja setsockopt pozwala dostosować zachowanie gniazd do potrzeb programisty. Bliźniacze getsockopt pozwala na odczyt opcji gniazd.
Podobnie jak np. ioctl, funkcja setsockopt pozwala zmieniać zachowanie na wielu poziomach (np. gniazda / protokołu warstwy sieci / protokołu warstwy transportu). Drugi argument to właśnie wybór poziomu, trzeci - wybór opcji, czwarty to wskaźnik na wartość opcji, ostatni określa rozmiar przekazywanej opcji.
Parametry (opcje) które można ustawić są opisane w rozdziale 7 podręcznika systemowego. Przykłady opcji:

• Ogólne opcje (man 7 socket, poziom SOL_SOCKET):
  • SO_BROADCAST – wymagane do UDP broadcastu
  • SO_KEEPALIVE – włącza mechanizm TCP keepalive http://tldp.org/HOWTO/TCP-Keepalive-HOWTO/overview.html
  • SO_LINGER – pozwala przed zamknięciem gniazda wysłać zakolejkowane dane
  • SO_RCVBUF i SO_SNDBUF – ustawienie rozmiaru systemowych buforów odbiorczych / nadawczych
  • SO_REUSEADDR – pozwala ignorować połączenia w stanie TIME_WAIT przy ustalaniu lokalnego adresu gniazda (wywoływaniu bind) https://tools.ietf.org/html/rfc793#page-22
• Opcje protokołu IP (man 7 ip, poziom IPPROTO_IP):
  • IP_ADD_MEMBERSHIP oraz IP_DROP_MEMBERSHIP – pozwala dodać siebie do grupy multicastowej
• Opcje protokołu TCP (man 7 tcp, poziom IPPROTO_TCP):
  • TCP_NODELAY – wyłącza algorytm Nagle'a (wyłącza buforowanie wyjścia jeśli danych jest mało a poprzednie nie zostały potwierdzone)

Przykłady zmiany opcji gniazd

// typowe zastosowanie – reuseaddr
const int one = 1;
setsockopt(sockFd, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one));
// przykład z innego poziomu - zmiana opcji TCP
setsockopt(sockFd, IPPROTO_TCP, TCP_NODELAY, &one, sizeof(one));
// opcja której argumentem jest rozmiar
size_t bufsize = 4*1024*1024;
setsockopt(sockFd, SOL_SOCKET, SO_RCVBUF, &bufsize, sizeof(bufsize));
// opcja której argumentem jest struktura
struct sctp_event_subscribe events{.sctp_data_io_event=1, .sctp_association_event=1};
setsockopt(sockFe, IPPROTO_SCTP, SCTP_EVENTS, &events, sizeof(events));
// przykład odczytania opcji
uint32_t mtu;
socklen_t optSize = sizeof(mtu);
getsockopt(sockFd, IPPROTO_IP, IP_MTU, &mtu, &optSize);

Funkcja fcntl (man fcntl open) pozwala na ustawienie (F_SETFL) opcji O_NONBLOCK potrzebnej do nieblokującej obsługi gniazd.