diff options
author | Othmar Gsenger <otti@anytun.org> | 2008-10-19 20:06:14 +0000 |
---|---|---|
committer | Othmar Gsenger <otti@anytun.org> | 2008-10-19 20:06:14 +0000 |
commit | 7ec2d1c53b753238509bf7a89587509305b9216d (patch) | |
tree | 2e81d3fbd6b2a515f71449a2a16b2c69ecf4ddad /src/Sockets/tests/retry.cpp | |
parent | switched from PracticalSocket to libasio (diff) |
move to asio socket libary for sync
bugs / todos:
* new connections don't sync
* anyrtpproxy broken
* anytun-controlld doesn't send data
Diffstat (limited to 'src/Sockets/tests/retry.cpp')
-rw-r--r-- | src/Sockets/tests/retry.cpp | 67 |
1 files changed, 0 insertions, 67 deletions
diff --git a/src/Sockets/tests/retry.cpp b/src/Sockets/tests/retry.cpp deleted file mode 100644 index 36954a6..0000000 --- a/src/Sockets/tests/retry.cpp +++ /dev/null @@ -1,67 +0,0 @@ -#include <TcpSocket.h> -#include <SocketHandler.h> -#include <ListenSocket.h> - - - bool quit = false; - -/* - virtual bool OnConnectRetry(); -- void SetRetryClientConnect(bool x = true); -- bool RetryClientConnect(); - void SetConnectionRetry(int n); - int GetConnectionRetry(); - void IncreaseConnectionRetries(); - int GetConnectionRetries(); - void ResetConnectionRetries(); -*/ -class RetrySocket : public TcpSocket -{ -public: - RetrySocket(ISocketHandler& h) : TcpSocket(h) { - SetConnectTimeout(2); - SetConnectionRetry(-1); - } - - bool OnConnectRetry() { - printf("Connection attempt#%d\n", GetConnectionRetries()); - if (GetConnectionRetries() == 3) - { - ListenSocket<RetrySocket> *l = new ListenSocket<RetrySocket>(Handler()); - if (l -> Bind(12345)) - { - printf("Bind port 12345 failed\n"); - } - l -> SetDeleteByHandler(); - Handler().Add(l); - } - return true; - } - - void OnConnect() { - printf("Connected\n"); - printf("GetRemoteAddress(): %s\n", GetRemoteAddress().c_str()); - printf("Remote address: %s\n", GetRemoteSocketAddress() -> Convert(false).c_str()); - printf("Remote address: %s\n", GetRemoteSocketAddress() -> Convert(true).c_str()); - SetCloseAndDelete(); - } - - void OnDelete() { - quit = true; - } -}; - - -int main(int argc, char *argv[]) -{ - SocketHandler h; - RetrySocket sock(h); - sock.Open("localhost", 12345); - h.Add(&sock); - while (!quit) - { - h.Select(0, 200000); - } -} - - |