udp_echo_server.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"
#include "cyber/task/task.h"
#include "cyber/time/time.h"

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

浏览源代码.

函数
void	Echo (const std::shared_ptr< Session > &session)
int	main (int argc, char *argv[])

函数说明

Echo()

void Echo

(

const std::shared_ptr< Session > &

session

)

在文件 udp_echo_server.cc 第 35 行定义.

                                                 {
  struct sockaddr_in client_addr;
  std::vector<char> recv_buffer(2049);
  int nbytes = 0;
  socklen_t sock_len = static_cast<socklen_t>(sizeof(client_addr));
 
  while (true) {
    nbytes = static_cast<int>(
        session->RecvFrom(recv_buffer.data(), recv_buffer.size(), 0,
                          (struct sockaddr*)&client_addr, &sock_len));
    if (nbytes < 0) {
      std::cout << "recv from client failed." << std::endl;
      continue;
    }
    session->SendTo(recv_buffer.data(), nbytes, 0,
                    (const struct sockaddr*)&client_addr, sock_len);
  }
}

main()

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

在文件 udp_echo_server.cc 第 54 行定义.

                                 {
  if (argc != 2) {
    std::cout << "Usage: " << argv[0] << " <server port>" << std::endl;
    return -1;
  }
 
  apollo::cyber::Init(argv[0]);
 
  uint16_t server_port = static_cast<uint16_t>(atoi(argv[1]));
  apollo::cyber::scheduler::Instance()->CreateTask(
      [&server_port]() {
        struct sockaddr_in server_addr;
        server_addr.sin_family = AF_INET;
        server_addr.sin_addr.s_addr = htons(INADDR_ANY);
        server_addr.sin_port = htons(server_port);
 
        auto session = std::make_shared<Session>();
        session->Socket(AF_INET, SOCK_DGRAM, 0);
        if (session->Bind((struct sockaddr*)&server_addr, sizeof(server_addr)) <
            0) {
          std::cout << "bind to port[" << server_port << "] failed."
                    << std::endl;
          return;
        }
        Echo(session);
        session->Close();
      },
      "echo_server");
 
  apollo::cyber::WaitForShutdown();
  return 0;
}