FileServerHandler Class Reference

Inheritance diagram for FileServerHandler:

Public Member Functions
void	read (Context *ctx, std::string filename) override
void	readException (Context *ctx, exception_wrapper ew) override
void	transportActive (Context *ctx) override
Public Member Functions inherited from wangle::HandlerAdapter< std::string >
void	read (Context *ctx, std::stringmsg) override
folly::Future< folly::Unit >	write (Context *ctx, std::stringmsg) override
Public Member Functions inherited from wangle::Handler< std::string, std::string, std::string, std::string >
	~Handler () override=default
virtual void	readEOF (Context *ctx)
virtual void	transportInactive (Context *ctx)
virtual folly::Future< folly::Unit >	writeException (Context *ctx, folly::exception_wrapper e)
virtual folly::Future< folly::Unit >	close (Context *ctx)
Public Member Functions inherited from wangle::HandlerBase< HandlerContext< std::string, std::string > >
virtual	~HandlerBase ()=default
virtual void	attachPipeline (HandlerContext< std::string, std::string > *)
virtual void	detachPipeline (HandlerContext< std::string, std::string > *)
HandlerContext< std::string, std::string > *	getContext ()

Additional Inherited Members
Public Types inherited from wangle::HandlerAdapter< std::string >
typedef Handler< std::string, std::string, std::string, std::string >::Context	Context
Public Types inherited from wangle::Handler< std::string, std::string, std::string, std::string >
typedef std::string	rin
typedef std::string	rout
typedef std::string	win
typedef std::string	wout
typedef HandlerContext< std::string, std::string >	Context
Static Public Attributes inherited from wangle::Handler< std::string, std::string, std::string, std::string >
static const HandlerDir	dir

Detailed Description

Definition at line 33 of file FileServer.cpp.

Member Function Documentation

void FileServerHandler::read ( Context *  ctx, std::string  filename  )

inlineoverridevirtual

Implements wangle::Handler< std::string, std::string, std::string, std::string >.

Definition at line 35 of file FileServer.cpp.

References folly::netops::close(), folly::exceptionStr(), wangle::HandlerContext< In, Out >::getPipelineShared(), wangle::HandlerContext< In, Out >::getTransport(), folly::gen::guard(), folly::sformat(), and fizz::detail::write().

                                                       {
    if (filename == "bye") {
      close(ctx);
    }

    int fd = open(filename.c_str(), O_RDONLY);
    if (fd == -1) {
      write(ctx, sformat("Error opening {}: {}\r\n",
                         filename,
                         strerror(errno)));
      return;
    }

    struct stat buf;
    if (fstat(fd, &buf) == -1) {
      write(ctx, sformat("Could not stat file {}: {}\r\n",
                         filename,
                         strerror(errno)));
      return;
    }

    FileRegion fileRegion(fd, 0, buf.st_size);
    auto guard = ctx->getPipelineShared();
    fileRegion.transferTo(ctx->getTransport())
      .onError([this, guard, ctx, filename](const std::exception& e){
        write(ctx, sformat("Error sending file {}: {}\r\n",
                           filename,
                           exceptionStr(e)));
      });
  }

void FileServerHandler::readException ( Context *  ctx, exception_wrapper  ew  )

inlineoverridevirtual

Reimplemented from wangle::Handler< std::string, std::string, std::string, std::string >.

Definition at line 66 of file FileServer.cpp.

References folly::netops::close(), folly::exceptionStr(), folly::sformat(), and fizz::detail::write().

                                                                  {
    write(ctx, sformat("Error: {}\r\n", exceptionStr(ew)))
        .thenValue([this, ctx](auto&&) { close(ctx); });
  }

void FileServerHandler::transportActive ( Context *  ctx )

inlineoverridevirtual

Reimplemented from wangle::Handler< std::string, std::string, std::string, std::string >.

Definition at line 71 of file FileServer.cpp.

References folly::SocketAddress::describe(), wangle::HandlerContext< In, Out >::getTransport(), and fizz::detail::write().

                                              {
    SocketAddress localAddress;
    ctx->getTransport()->getLocalAddress(&localAddress);
    write(ctx, "Welcome to " + localAddress.describe() + "!\r\n");
    write(ctx, "Type the name of a file and it will be streamed to you!\r\n");
    write(ctx, "Type 'bye' to exit.\r\n");
  }

---

The documentation for this class was generated from the following file:

• proxygen/wangle/wangle/example/file/FileServer.cpp