TelnetClient.cpp File Reference

#include <iostream>
#include <gflags/gflags.h>
#include <folly/init/Init.h>
#include <wangle/bootstrap/ClientBootstrap.h>
#include <wangle/channel/AsyncSocketHandler.h>
#include <wangle/channel/EventBaseHandler.h>
#include <wangle/codec/LineBasedFrameDecoder.h>
#include <wangle/codec/StringCodec.h>

Go to the source code of this file.

Classes
class	TelnetHandler
class	TelnetPipelineFactory

Typedefs
typedef Pipeline< folly::IOBufQueue &, std::string >	TelnetPipeline

Functions
	DEFINE_int32 (port, 23,"test telnet server port")
	DEFINE_string (host,"::1","test telnet server address")
int	main (int argc, char **argv)

Typedef Documentation

typedef Pipeline<folly::IOBufQueue&, std::string> TelnetPipeline

Definition at line 34 of file TelnetClient.cpp.

Function Documentation

DEFINE_int32	(	port	,
		23	,
		"test telnet server port"
	)

DEFINE_string	(	host	,
		"::1"	,
		"test telnet server address"
	)

int main	(	int	argc,
		char **	argv
	)

Definition at line 67 of file TelnetClient.cpp.

References wangle::ClientBootstrap< Pipeline >::connect(), folly::exceptionStr(), getline(), wangle::ClientBootstrap< Pipeline >::group(), folly::init(), wangle::BaseClientBootstrap< Pipeline >::pipelineFactory(), and string.

                                {
  folly::Init init(&argc, &argv);

  ClientBootstrap<TelnetPipeline> client;
  client.group(std::make_shared<folly::IOThreadPoolExecutor>(1));
  client.pipelineFactory(std::make_shared<TelnetPipelineFactory>());
  auto pipeline = client.connect(SocketAddress(FLAGS_host,FLAGS_port)).get();

  try {
    while (true) {
      std::string line;
      std::getline(std::cin, line);
      if (line == "") {
        break;
      }

      // Sync write will throw exception if server goes away
      pipeline->write(line + "\r\n").get();
      if (line == "bye") {
        pipeline->close();
        break;
      }
    }
  } catch(const std::exception& e) {
    std::cout << exceptionStr(e) << std::endl;
  }

  return 0;
}