Scale Stack 0.3 Developer Documentation

scalestack/network/ip/tcp/connection.cc

Go to the documentation of this file.

/*
 * Scale Stack
 *
 * Copyright 2010 Eric Day
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "config.h"

#include <cerrno>
#include <cstring>
#include <sys/types.h> /* Must be before socket headers for Free BSD. */
#include <netdb.h>
#include <netinet/in.h>
#include <netinet/tcp.h>
#include <sys/socket.h>
#include <unistd.h>

#include <scalestack/kernel/module.h>
#include <scalestack/network/ip/tcp/connection.h>
#include <scalestack/network/ip/tcp/connection_service.h>

using namespace std;

namespace scalestack
{
namespace network
{
namespace ip
{
namespace tcp
{

/*
 * Public methods.
 */

connection::connection(event::handler_service& handler_service,
                       stream_service& stream_service,
                       int file_descriptor):
  network::stream_provider(handler_service, stream_service, file_descriptor)
{
}

connection::connection(event::handler_service& handler_service,
                       stream_service& stream_service,
                       const struct addrinfo* addresses):
  network::stream_provider(handler_service, stream_service, addresses)
{
}

connection::~connection()
{
  if (_addresses != NULL)
    freeaddrinfo(const_cast<struct addrinfo*>(_addresses));
}

void connection::set_file_descriptor(int file_descriptor)
{
  if (file_descriptor != -1)
  {
    int return_code = 1;
    return_code = setsockopt(file_descriptor, IPPROTO_TCP, TCP_NODELAY,
                             &return_code, static_cast<socklen_t>(sizeof(int)));
    if (return_code == -1 && errno != EOPNOTSUPP)
    {
      _module.log_error(_("Could not set TCP_NODELAY: %s"), strerror(errno));
      shutdown();
      return;
    }
  }

  network::stream_provider::set_file_descriptor(file_descriptor);
}

} /* namespace tcp */
} /* namespace ip */
} /* namespace network */
} /* namespace scalestack */

---