tcp_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"

tcp_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

)

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

                                                 {
  std::vector<char> recv_buffer(2049);
  int nbytes = 0;
  while ((nbytes = static_cast<int>(
              session->Recv(recv_buffer.data(), recv_buffer.size(), 0))) > 0) {
    session->Write(recv_buffer.data(), nbytes);
  }
 
  if (nbytes == 0) {
    std::cout << "client has been closed." << std::endl;
    session->Close();
  }
 
  if (nbytes < 0) {
    std::cout << "receive from client failed." << std::endl;
    session->Close();
  }
}

main()

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

在文件 tcp_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);
 
        Session session;
        session.Socket(AF_INET, SOCK_STREAM, 0);
        if (session.Bind((struct sockaddr*)&server_addr, sizeof(server_addr)) <
            0) {
          std::cout << "bind to port[" << server_port << "] failed."
                    << std::endl;
          return;
        }
        session.Listen(10);
        auto conn_session = session.Accept((struct sockaddr*)nullptr, nullptr);
        std::cout << "accepted" << std::endl;
        auto routine_name =
            "connected session" + std::to_string(Time::Now().ToNanosecond());
        apollo::cyber::scheduler::Instance()->CreateTask(
            std::bind(Echo, conn_session), routine_name);
      },
      "echo_server");
 
  apollo::cyber::WaitForShutdown();
  return 0;
}