Add echo example with raw QUIC transport

Author: starwarfan

example/Makefile

@@ -0,0 +1,11 @@
+CXX ?= "g++"
+
+all: echo_client echo_server
+echo_client: QuicEchoClient.cc
+	$(CXX) -std=c++11 -I../src/wrapper -c -o QuicEchoClient.o QuicEchoClient.cc && \
+	$(CXX) -o echo_client QuicEchoClient.o -L/home/user/work/quic/qlib -ltestquic
+echo_server: QuicEchoServer.cc
+	$(CXX) -std=c++11 -I../src/wrapper -c -o QuicEchoServer.o QuicEchoServer.cc && \
+	$(CXX) -o echo_server QuicEchoServer.o -L/home/user/work/quic/qlib -ltestquic
+clean:
+	rm *.o echo_*

example/QuicEchoClient.cc

@@ -0,0 +1,50 @@
+#include <iostream>
+#include <string>
+#include <memory>
+#include <functional>
+#include <chrono>
+#include <thread>
+
+#include "quic_raw_lib.h"
+
+using namespace net;
+
+std::string message;
+
+class ClientListener : public RQuicListener {
+ public:
+  ClientListener(RQuicClientInterface* client) : client_(client) {}
+  void onReady() override {
+    std::cout << "Client Started." << std::endl;
+    if (client_) {
+      client_->send(message.c_str(), message.length());
+    }
+  }
+  void onData(uint32_t session_id, uint32_t stream_id,
+      char* data, uint32_t len) override {
+    std::cout << "Stream: " << stream_id << " received: "
+        << std::string(data, len) << std::endl;
+    if (client_) {
+      client_->stop();
+    }
+  }
+ private:
+  RQuicClientInterface* client_;
+};
+
+int main(int argc, char* argv[]) {
+  if (argc < 4) {
+    std::cout << "Usage: QuicEchoClient [ServerIP] [ServerPort] [message]" << std::endl;
+    return 0;
+  }
+  int port = atoi(argv[2]);
+  message = std::string(argv[3]);
+
+  std::shared_ptr<RQuicClientInterface> client(RQuicFactory::createQuicClient());
+  ClientListener listener(client.get());
+  client->setListener(&listener);
+
+  client->start(argv[1], port);
+  client->waitForClose();
+  return 0;
+}

example/QuicEchoServer.cc

@@ -0,0 +1,55 @@
+#include <iostream>
+#include <string>
+#include <memory>
+#include <functional>
+#include <chrono>
+#include <thread>
+
+#include "quic_raw_lib.h"
+
+using namespace net;
+
+int port = 6121;
+std::string unused_cert = "leaf_cert.pem";
+std::string unused_key = "leaf_cert.pkcs8";
+
+class ServerListener : public RQuicListener {
+ public:
+  ServerListener(RQuicServerInterface* server) : server_(server) {}
+  void onReady() override {
+    std::cout << "Server Started." << std::endl;
+    if (server_) {
+      std::cout << "Listening Port: " << server_->getServerPort() << std::endl;
+    }
+  }
+  void onData(uint32_t session_id, uint32_t stream_id,
+      char* data, uint32_t len) override {
+    std::cout << "Session: " << session_id << " stream: " << stream_id
+        << " received: " << std::string(data, len) << std::endl;
+    if (server_) {
+      server_->send(session_id, stream_id, data, len);
+    }
+  }
+ private:
+  RQuicServerInterface* server_;
+};
+
+int main(int argc, char* argv[]) {
+  if (argc > 1) {
+    port = atoi(argv[1]);
+  }
+  if (argc > 3) {
+    unused_cert = std::string(argv[2]);
+    unused_key = std::string(argv[3]);
+  }
+
+  std::shared_ptr<RQuicServerInterface> server(RQuicFactory::createQuicServer(
+      unused_cert.c_str(), unused_key.c_str()));
+
+  ServerListener listener(server.get());
+  server->setListener(&listener);
+
+  server->listen(port);
+  server->waitForClose();
+  return 0;
+}

example/leaf_cert.pem

@@ -0,0 +1,83 @@
+Certificate:
+    Data:
+        Version: 3 (0x2)
+        Serial Number: 1 (0x1)
+    Signature Algorithm: sha256WithRSAEncryption
+        Issuer: CN=QUIC Server Root CA
+        Validity
+            Not Before: Apr 10 02:21:26 2019 GMT
+            Not After : Apr 13 02:21:26 2019 GMT
+        Subject: C=US, ST=California, L=Mountain View, O=QUIC Server, CN=127.0.0.1
+        Subject Public Key Info:
+            Public Key Algorithm: rsaEncryption
+                Public-Key: (2048 bit)
+                Modulus:
+                    00:b8:dc:04:43:13:b6:f8:2a:43:e1:25:e2:ae:fd:
+                    65:b8:8d:0a:5b:ae:f2:81:77:f1:b0:5d:b0:b6:35:
+                    c7:f8:f6:7a:41:ee:f4:2c:5b:ff:32:fd:25:e2:6b:
+                    ff:d8:20:32:62:f4:21:2c:05:62:2c:b7:96:d5:31:
+                    0a:01:6e:75:e0:15:c6:24:d9:d1:6d:48:64:4c:e5:
+                    1e:5e:0b:b2:38:5d:0b:6e:4c:b3:52:00:fc:bf:63:
+                    e3:65:fa:ee:56:8d:bf:e6:7b:72:06:08:f6:0a:7d:
+                    69:c6:36:02:cb:ea:61:5d:4d:c6:c9:82:d7:18:e2:
+                    78:d5:70:81:0b:bf:b5:e6:54:b0:83:0a:7d:f2:d6:
+                    ed:0e:9b:03:e9:ec:9a:43:c0:f5:f9:64:92:a2:e5:
+                    ee:5f:8c:b5:8e:aa:c3:a8:0f:84:b5:b0:c2:fc:5d:
+                    e2:93:72:a6:c3:4f:d0:1d:27:57:31:ce:30:7c:85:
+                    76:61:3a:6a:b7:57:9c:99:dd:5d:96:82:40:9e:d7:
+                    e7:bb:9b:79:db:7a:f9:fa:6c:a4:fa:f2:0f:24:61:
+                    1f:e3:6d:2c:61:1a:8b:d1:c1:a0:6e:c8:6c:c0:46:
+                    40:d0:9c:c2:45:f6:38:fd:c0:17:90:de:b7:c6:0d:
+                    7a:14:bc:c4:68:1d:2c:74:7a:b6:54:c8:02:d8:40:
+                    d8:b9
+                Exponent: 65537 (0x10001)
+        X509v3 extensions:
+            X509v3 Basic Constraints: critical
+                CA:FALSE
+            X509v3 Subject Key Identifier: 
+                59:9C:02:B1:85:0E:4B:D1:29:50:60:62:8F:8E:DB:A8:65:84:3D:45
+            X509v3 Authority Key Identifier: 
+                keyid:14:3B:F7:F9:BF:31:FC:99:72:F8:61:B9:F9:DD:F1:F4:67:E2:42:38
+
+            X509v3 Extended Key Usage: 
+                TLS Web Server Authentication, TLS Web Client Authentication
+            X509v3 Subject Alternative Name: 
+                DNS:www.example.org, DNS:mail.example.org, DNS:mail.example.com, IP Address:127.0.0.1
+    Signature Algorithm: sha256WithRSAEncryption
+         2c:92:af:5e:38:10:26:61:f3:77:7c:27:2b:6e:7c:ee:4a:f5:
+         f3:20:96:e0:52:03:20:fe:af:89:47:dc:cf:1d:74:eb:20:19:
+         93:9d:4d:b5:61:fb:08:9c:1f:ee:3b:b2:af:43:d6:9e:27:41:
+         19:54:82:c2:d4:09:71:d8:5a:e6:c4:50:bf:fc:00:37:c6:f4:
+         b3:9f:18:1f:28:ac:3b:5f:69:14:93:f4:8a:61:01:b4:f8:fa:
+         5e:8c:10:8d:9e:60:ce:80:52:d6:c8:54:a5:44:01:66:0c:89:
+         ef:9a:34:20:2a:19:30:11:57:b5:94:2b:cb:bd:82:cc:58:21:
+         c7:dc:ee:1c:31:ba:8f:18:0d:1c:ea:81:85:d9:c0:22:f9:4f:
+         7f:a1:00:e1:f2:6c:9f:fb:6b:3b:f8:e8:4b:b6:59:d0:04:eb:
+         15:db:d2:7c:8a:15:44:62:12:cb:50:df:f0:f2:a9:5c:58:e8:
+         ea:e9:8f:10:34:68:a4:a1:e5:a3:5d:53:57:1a:a2:e6:70:4e:
+         37:6f:1e:61:c5:b7:2c:b6:c6:72:09:a3:21:e5:3b:97:38:ad:
+         61:4a:2b:4c:c9:9b:d6:6a:76:70:4f:0b:d3:30:73:4b:af:a0:
+         47:a9:8d:27:25:8a:e5:0d:46:0a:56:0e:2b:a1:74:37:8d:24:
+         d1:e6:09:fa
+-----BEGIN CERTIFICATE-----
+MIIDtDCCApygAwIBAgIBATANBgkqhkiG9w0BAQsFADAeMRwwGgYDVQQDDBNRVUlD
+IFNlcnZlciBSb290IENBMB4XDTE5MDQxMDAyMjEyNloXDTE5MDQxMzAyMjEyNlow
+ZDELMAkGA1UEBhMCVVMxEzARBgNVBAgMCkNhbGlmb3JuaWExFjAUBgNVBAcMDU1v
+dW50YWluIFZpZXcxFDASBgNVBAoMC1FVSUMgU2VydmVyMRIwEAYDVQQDDAkxMjcu
+MC4wLjEwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQC43ARDE7b4KkPh
+JeKu/WW4jQpbrvKBd/GwXbC2Ncf49npB7vQsW/8y/SXia//YIDJi9CEsBWIst5bV
+MQoBbnXgFcYk2dFtSGRM5R5eC7I4XQtuTLNSAPy/Y+Nl+u5Wjb/me3IGCPYKfWnG
+NgLL6mFdTcbJgtcY4njVcIELv7XmVLCDCn3y1u0OmwPp7JpDwPX5ZJKi5e5fjLWO
+qsOoD4S1sML8XeKTcqbDT9AdJ1cxzjB8hXZhOmq3V5yZ3V2WgkCe1+e7m3nbevn6
+bKT68g8kYR/jbSxhGovRwaBuyGzARkDQnMJF9jj9wBeQ3rfGDXoUvMRoHSx0erZU
+yALYQNi5AgMBAAGjgbYwgbMwDAYDVR0TAQH/BAIwADAdBgNVHQ4EFgQUWZwCsYUO
+S9EpUGBij47bqGWEPUUwHwYDVR0jBBgwFoAUFDv3+b8x/Jly+GG5+d3x9GfiQjgw
+HQYDVR0lBBYwFAYIKwYBBQUHAwEGCCsGAQUFBwMCMEQGA1UdEQQ9MDuCD3d3dy5l
+eGFtcGxlLm9yZ4IQbWFpbC5leGFtcGxlLm9yZ4IQbWFpbC5leGFtcGxlLmNvbYcE
+fwAAATANBgkqhkiG9w0BAQsFAAOCAQEALJKvXjgQJmHzd3wnK2587kr18yCW4FID
+IP6viUfczx106yAZk51NtWH7CJwf7juyr0PWnidBGVSCwtQJcdha5sRQv/wAN8b0
+s58YHyisO19pFJP0imEBtPj6XowQjZ5gzoBS1shUpUQBZgyJ75o0ICoZMBFXtZQr
+y72CzFghx9zuHDG6jxgNHOqBhdnAIvlPf6EA4fJsn/trO/joS7ZZ0ATrFdvSfIoV
+RGISy1Df8PKpXFjo6umPEDRopKHlo11TVxqi5nBON28eYcW3LLbGcgmjIeU7lzit
+YUorTMmb1mp2cE8L0zBzS6+gR6mNJyWK5Q1GClYOK6F0N40k0eYJ+g==
+-----END CERTIFICATE-----