1

Linux のソケット用の C++ ラッパーを作成しています。http サーバーに読み取り/書き込みを接続できます。私のポーリング機能は読み取りには完全に機能しますが、何らかの理由で書き込みには機能しません。gdb を使用してみfd.reventsましたが、fd.events のときに poll が 0 に設定されているようですPOLLOUT

投票コード:

/**
 *@brief assigns request.reply based on fd.revents
 */
static void translate_request(mizaru::PollRequest &request, pollfd &fd)
{

    assert( (fd.revents & POLLHUP) == 0);
    assert( (fd.revents & POLLERR) == 0);
    assert( (fd.revents & POLLNVAL) == 0);


    switch(fd.revents)
  {
      case (POLLIN | POLLOUT) :
        request.reply = mizaru::POLL_REPLY_RW;
        break;
      case POLLIN :
        request.reply = mizaru::POLL_REPLY_READ;
        break;
      case POLLOUT :
        request.reply = mizaru::POLL_REPLY_WRITE;
      default :
        request.reply = 0;
  }

}

/**
 * @fills in fd.events based on request.request
 * and fd.fd based on request.sock
 */
static void prep_request(mizaru::PollRequest &request, pollfd &fd)
{

    fd.fd = request.sock.get_handle();
    switch(request.request)
  {

    case mizaru::PollType::POLL_READ :
      fd.events = POLLIN;
      break;
    case mizaru::PollType::POLL_WRITE :
      fd.events = POLLOUT;
      break;
    default :
      fd.events = POLLIN | POLLOUT;

  }


}

void mizaru::trans::poll(mizaru::PollRequest &request,const std::chrono::milliseconds& wait_time) noexcept
{

  pollfd fd;
  prep_request(request, fd);
  poll(&fd, 1, wait_time.count());
  translate_request(request, fd);
}

mizaru::PollRequest構造体:

struct PollRequest
{
  PollRequest(PollType request, const SyncSocket &sock) : sock(sock), request(request), reply(POLL_REPLY_FAIL) {}
  const SyncSocket & sock;
  PollType request;
  uint8_t reply;
};

SyncSocket.get_handle()socket(int,int,int)inによって返された fd を返すだけですsys/socket.h

テスト機能:

bool test_poll()
{
    mizaru::IPv4 ip ( "54.225.138.124" );
    mizaru::SyncSocketTCP sock ( ip, 80 ,true);
    mizaru::PollRequest  request{mizaru::PollType::POLL_READ, sock};
    std::chrono::milliseconds time(1000);

    mizaru::poll(request, time);

    if(request.reply == mizaru::POLL_REPLY_READ)
    {
      std::cout << "fail test_poll first read" <<std::endl;
       return false;
    } 

    request.request = mizaru::PollType::POLL_WRITE;
    mizaru::poll(request, time);

    if(request.reply != mizaru::POLL_REPLY_WRITE)
    {
      std::cout << "fail test_poll first write" << std::endl;
      return false;
    }

 std::string toWrite ( "GET / http/1.1\nHost: httpbin.org\n\n" );
 mizaru::byte_buffer write_buff;

for ( char c : toWrite )
    {
      write_buff.push_back ( c );
    }

  unsigned int r_value = sock.write ( write_buff );

   if (r_value != toWrite.size()) 
   {
      std::cout << "fail test_poll r_value" << std::endl;
      return false;
   }



    request.request = mizaru::PollType::POLL_READ;

    mizaru::poll(request, time);

    if(request.reply != mizaru::POLL_REPLY_READ)
    {
       std::cout << "fail test_poll second read" << std::endl;
        return false;
    }

    request.request = mizaru::PollType::POLL_WRITE;

    mizaru::poll(request, time);

    if(request.reply != mizaru::POLL_REPLY_WRITE)
    {
      std::cout << "fail test_poll second write " << std::endl;
        return false;
    }

    return true;
}

PollType列挙型:

enum PollType {POLL_READ, POLL_WRITE, POLL_RW};

POLL_REPLY_*定数:

constexpr uint8_t POLL_REPLY_READ = 0x01;
constexpr uint8_t POLL_REPLY_WRITE = 0x02;
constexpr uint8_t POLL_REPLY_RW = POLL_REPLY_READ | POLL_REPLY_WRITE;
constexpr uint8_t POLL_REPLY_FAIL = 0;

申し訳ありませんが、サンプル コードは直接コンパイルできません。短くしようとしましたが、適切な HTTP 200 OK 応答が得られるので、接続と読み取り/書き込みが適切に処理されていると見なすことができます。書き込みのポーリング時にテストが失敗する

4

1 に答える 1