TSVConnFdCreate

    TSVConn (int fd)

    On success, the returned 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.

    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
    13.     fd = ::socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
    14.     TSReleaseAssert(fd != -1);
    16.     if (::connect(fd, &addr.sa, sizeof(addr.sin)) == -1) {
    17.       // We failed to connect to the intercepted origin. Abort the
    18.       // server intercept since we cannot handle it.
    19.       VDEBUG("connect failed with %s (%d)", strerror(errno), errno);
    20.       TSVConnAbort(arg.vc, TS_VC_CLOSE_ABORT);
    22.       delete istate;
    23.       TSContDestroy(contp);
    25.       ::close(fd);
    26.       return TS_EVENT_NONE;
    27.     }
    29.     if ((istate->server.vc = TSVConnFdCreate(fd)) == nullptr) {
    30.       TSVConnAbort(arg.vc, TS_VC_CLOSE_ABORT);
    32.       delete istate;
    33.       TSContDestroy(contp);
    35.       ::close(fd);
    36.       return TS_EVENT_NONE;
    37.     }
    39.     VDEBUG("binding client vc=%p to %s:%u", istate->client.vc, inet_ntop(AF_INET, &addr.sin.sin_addr, buf, sizeof(buf)),
    40.            (unsigned)ntohs(addr.sin.sin_port));
    42.     istate->txn       = cdata.txn;
    43.     istate->client.vc = arg.vc;
    45.     // Reset the continuation data to be our intercept state
    46.     // block. We will need this so that we can access both of the

    TSAPI(3ts)