udp_echo_client.cc 文件参考

#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <cstdlib>
#include <iostream>
#include <string>
#include <vector>
#include "cyber/cyber.h"
#include "cyber/init.h"
#include "cyber/io/session.h"
#include "cyber/scheduler/scheduler_factory.h"

udp_echo_client.cc 的引用(Include)关系图:

浏览源代码.

函数
int	main (int argc, char *argv[])

函数说明

main()

int main	(	int	argc,
		char *	argv[]
	)

在文件 udp_echo_client.cc 第 32 行定义.

                                 {
  if (argc != 2) {
    std::cout << "Usage: " << argv[0] << " <server port>" << std::endl;
    return -1;
  }
 
  apollo::cyber::Init(argv[0]);
 
  int server_port = atoi(argv[1]);
  apollo::cyber::scheduler::Instance()->CreateTask(
      [&server_port]() {
        struct sockaddr_in server_addr;
        server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
        server_addr.sin_family = AF_INET;
        server_addr.sin_port = htons((uint16_t)server_port);
 
        std::string user_input;
        std::vector<char> server_reply(2049);
        ssize_t nbytes = 0;
        uint32_t count = 0;
 
        Session session;
        session.Socket(AF_INET, SOCK_DGRAM, 0);
        if (session.Connect((struct sockaddr*)&server_addr,
                            sizeof(server_addr)) < 0) {
          std::cout << "connect to server failed, " << strerror(errno)
                    << std::endl;
          return;
        }
 
        while (true) {
          count = 0;
          std::cout << "please enter a message (enter Ctrl+C to exit):"
                    << std::endl;
          std::getline(std::cin, user_input);
          if (!apollo::cyber::OK()) {
            break;
          }
          if (user_input.empty()) {
            continue;
          }
 
          if (session.Send(user_input.c_str(), user_input.length(), 0) < 0) {
            std::cout << "send message failed." << std::endl;
            return;
          }
 
          while ((nbytes = session.Recv(server_reply.data(),
                                        server_reply.size(), 0)) > 0) {
            for (auto itr = server_reply.begin();
                 itr < server_reply.begin() + nbytes; ++itr) {
              std::cout << *itr;
            }
            count += (uint32_t)nbytes;
            if (count >= user_input.length()) {
              break;
            }
          }
 
          if (nbytes == 0) {
            std::cout << "server has been closed." << std::endl;
            session.Close();
            return;
          }
 
          if (nbytes < 0) {
            std::cout << "receive message from server failed." << std::endl;
            session.Close();
            return;
          }
 
          std::cout << std::endl;
        }
      },
      "echo_client");
 
  apollo::cyber::WaitForShutdown();
  return 0;
}