summaryrefslogtreecommitdiffstatshomepage
path: root/tests/multi_net/udp_recv_peek.py
blob: 47897ce553954b16253e5356b4d2f270080cea4f (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
# Test UDP recv and recvfrom with MSG_PEEK
import random
import socket
import time


# Server
def instance0():
    PORT = random.randrange(10000, 50000)
    multitest.globals(IP=multitest.get_network_ip(), PORT=PORT)
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    s.bind(socket.getaddrinfo("0.0.0.0", PORT)[0][-1])
    multitest.next()
    peek_bytes, peek_addr = s.recvfrom(8, socket.MSG_PEEK)
    print(peek_bytes)
    real_bytes, real_addr = s.recvfrom(8)
    print(real_bytes)
    print(peek_addr == real_addr)  # source addr should be the same for each
    res = s.sendto(b"1234567890", peek_addr)
    print(res)
    print(s.recv(5, socket.MSG_PEEK))
    print(s.recv(5, socket.MSG_PEEK))
    s.close()


# Client
def instance1():
    multitest.next()
    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    s.connect(socket.getaddrinfo(IP, PORT)[0][-1])
    s.send(b"abcdefgh")
    s.send(b"klmnopqr")
    print(s.recv(5, socket.MSG_PEEK))
    print(s.recv(10))
    s.close()