| 101 | } |
| 102 | |
| 103 | static int connSocketConnect(connection *conn, const char *addr, int port, const char *src_addr, |
| 104 | ConnectionCallbackFunc connect_handler) { |
| 105 | int fd = anetTcpNonBlockBestEffortBindConnect(NULL,addr,port,src_addr); |
| 106 | if (fd == -1) { |
| 107 | conn->state = CONN_STATE_ERROR; |
| 108 | conn->last_errno = errno; |
| 109 | return C_ERR; |
| 110 | } |
| 111 | |
| 112 | conn->fd = fd; |
| 113 | conn->state = CONN_STATE_CONNECTING; |
| 114 | |
| 115 | conn->conn_handler = connect_handler; |
| 116 | aeCreateFileEvent(serverTL->el, conn->fd, AE_WRITABLE|AE_WRITE_THREADSAFE, |
| 117 | conn->type->ae_handler, conn); |
| 118 | |
| 119 | return C_OK; |
| 120 | } |
| 121 | |
| 122 | /* Returns true if a write handler is registered */ |
| 123 | int connHasWriteHandler(connection *conn) { |
nothing calls this directly
no test coverage detected