SocketLib2/testdgram.cpp at master · ferenci84/SocketLib2 · GitHub

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
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

#include "socketlib2.h"
#include <thread>
#include <iostream>

using namespace std;


int main() {

    string addr = "127.0.0.1";
    unsigned short port = 5321;

    auto process = [port] {
        int err;
        SOCKETLIB_HANDLE sock = open_socket_dgam_for_receive(err);
        if (sock == 0) {
            cout << "Error: " << err << endl;
        }

        string addr = "0.0.0.0";
        //string addr = "127.0.0.1";
        const char* caddr = addr.c_str();

        if (!::bind(sock,(unsigned char*)caddr,port,err)) {
            cout << "Client Bind Error: " << err << endl;
        }

        this_thread::sleep_for(chrono::milliseconds(500));
        char buf[512];
        string recvfrom_addr = "0.0.0.0";
        //string recvfrom_addr = "127.0.0.1";
        caddr = recvfrom_addr.c_str();
        int bytes = receive_dgram_sync(sock,(unsigned char*)caddr,port,(unsigned char*)buf,512,err);
        if (bytes == -1) {
            cout << sock << " Error receiving: " << err << endl;
        } else {
            cout << sock << " received bytes: " << bytes << endl;
            cout << sock << " msg:" << buf << endl;
        }
    };

    auto th1 = new thread(process);
    this_thread::sleep_for(chrono::milliseconds(10));
    auto th2 = new thread(process);

    this_thread::sleep_for(chrono::milliseconds(300));

    int err;
    SOCKETLIB_HANDLE sock = open_socket_dgam_for_send(err);
    if (sock == 0) {
        cout << "Error: " << err << endl;
    }
    const char* caddr = addr.c_str();

    this_thread::sleep_for(chrono::milliseconds(1000));

    string msg = "THISISASMALLMESSAGE";
    const char* cmsg = msg.c_str();
    //string broadcast_addr = "255.255.255.255";
    //string broadcast_addr = "127.255.255.255";
    string broadcast_addr = "10.0.2.255";
    int bytes = send_dgram(sock,(unsigned char*)broadcast_addr.c_str(),port,(unsigned char*)cmsg,err);
    //int bytes = send_dgram(sock,(unsigned char*)caddr,port,(unsigned char*)cmsg,err);
    if (bytes == -1) {
        cout << "Error: " << err << endl;
    } else {
        cout << "sent bytes " << bytes << " of " << msg.size()+1 << endl;
    }

    th1->join();
    th2->join();
    delete th1;
    delete th2;

    return 0;
}