TSVConnFdCreate

Create a TSVConn from a socket.

Synopsis

  1. #include <ts/ts.h>

TSVConn TSVConnFdCreate(int fd)

Description

TSVConnFdCreate() accepts a network socket fd and returns a new TSVConn constructed from the socket. The socket descriptor must be an already connected socket. It will be placed into non-blocking mode.

Return Values

On success, the returned TSVConn object owns the socket and the caller must not close it. If TSVConnFdCreate() fails, NULL is returned, the socket is unchanged and the caller must close it.

Examples

The example below is excerpted from example/plugins/c-api/intercept/intercept.cc in the Traffic Server source distribution. It demonstrates how to use TSVConnFdCreate() to construct a TSVConn from a connected socket.

  1.     // the TSHttpTxn pointer.
  2.     VDEBUG("allocated server intercept state istate=%p for txn=%p", istate, cdata.txn);
  4.     // Set up a connection to our real origin, which will be
  5.     // 127.0.0.1:$PORT.
  6.     memset(&addr, 0, sizeof(addr));
  7.     addr.sin.sin_family      = AF_INET;
  8.     addr.sin.sin_addr.s_addr = htonl(INADDR_LOOPBACK); // XXX config option
  9.     addr.sin.sin_port        = htons(PORT);            // XXX config option
  11.     // Normally, we would use TSNetConnect to connect to a secondary service, but to demonstrate
  12.     // the use of TSVConnFdCreate, we do a blocking connect inline. This it not recommended for
  13.     // production plugins, since it might block an event thread for an arbitrary time.
  14.     fd = ::socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
  15.     TSReleaseAssert(fd != -1);
  17.     if (::connect(fd, &addr.sa, sizeof(addr.sin)) == -1) {
  18.       // We failed to connect to the intercepted origin. Abort the
  19.       // server intercept since we cannot handle it.
  20.       VDEBUG("connect failed with %s (%d)", strerror(errno), errno);
  21.       TSVConnAbort(arg.vc, TS_VC_CLOSE_ABORT);
  23.       delete istate;
  24.       TSContDestroy(contp);
  26.       ::close(fd);
  27.       return TS_EVENT_NONE;
  28.     }
  30.     if ((istate->server.vc = TSVConnFdCreate(fd)) == nullptr) {
  31.       VDEBUG("TSVconnFdCreate() failed");
  32.       TSVConnAbort(arg.vc, TS_VC_CLOSE_ABORT);
  34.       delete istate;
  35.       TSContDestroy(contp);
  37.       ::close(fd);
  38.       return TS_EVENT_NONE;
  39.     }
  41.     VDEBUG("binding client vc=%p to %s:%u", istate->client.vc, inet_ntop(AF_INET, &addr.sin.sin_addr, buf, sizeof(buf)),
  42.            (unsigned)ntohs(addr.sin.sin_port));
  44.     istate->txn       = cdata.txn;
  45.     istate->client.vc = arg.vc;
  47.     // Reset the continuation data to be our intercept state
  48.     // block. We will need this so that we can access both of the
  49.     // VCs at the same time. We need to do this before calling

See Also

TSAPI(3ts)