| 37 | } |
| 38 | |
| 39 | void RunLocalDgramTest(const char* localServerSockName, const char* localClientSockName) { |
| 40 | char buf[256]; |
| 41 | TSockAddrLocalDgram servAddr(localServerSockName); |
| 42 | TSockAddrLocalDgram cliAddr(localClientSockName); |
| 43 | TSockAddrLocalDgram servFromAddr; |
| 44 | TSockAddrLocalDgram cliFromAddr; |
| 45 | TLocalDgramSocket cliSock; |
| 46 | TLocalDgramSocket servSock; |
| 47 | cliSock.CheckSock(); |
| 48 | servSock.CheckSock(); |
| 49 | |
| 50 | TBaseSocket::Check(cliSock.Bind(&cliAddr), "bind client"); |
| 51 | TBaseSocket::Check(servSock.Bind(&servAddr), "bind server"); |
| 52 | |
| 53 | // client |
| 54 | const char reqStr[] = "Hello, world!!!"; |
| 55 | TBaseSocket::Check(cliSock.SendTo(reqStr, sizeof(reqStr), &servAddr), "send from client"); |
| 56 | |
| 57 | // server |
| 58 | TBaseSocket::Check(servSock.RecvFrom(buf, 256, &servFromAddr), "receive from client"); |
| 59 | UNIT_ASSERT(strcmp(reqStr, buf) == 0); |
| 60 | const char repStr[] = "The World's greatings to you"; |
| 61 | TBaseSocket::Check(servSock.SendTo(repStr, sizeof(repStr), &servFromAddr), "send to client"); |
| 62 | |
| 63 | // client |
| 64 | TBaseSocket::Check(cliSock.RecvFrom(buf, 256, &cliFromAddr), "receive from server"); |
| 65 | UNIT_ASSERT(strcmp(repStr, buf) == 0); |
| 66 | } |
| 67 | |
| 68 | Y_UNIT_TEST(LocalDgramTest) { |
| 69 | const char* localServerSockName = "./serv_sock"; |