Method onWriteData

src/Server.cpp:158–197

}

void MNS::Server::onWriteData(uv_poll_t *handle, int status, int events) {
	MNS::SocketData *data = static_cast<MNS::SocketData *>(handle->data);

	if (status < 0) {
		if (errno != EAGAIN) {
			uv_poll_stop(handle);
			uv_close((uv_handle_t *) handle, MNS::Server::onClose);
			return;
		}
	}

	if (data) {
		MNS::Response *response = data->response;

		ssize_t numSent = send(data->fd, response->getBuffer(), response->getBufferLen(), 0);
		if (numSent == (int) response->getBufferLen()) {
			response->clear();

			if (data->request->isFinished()) {
				data->request->clear();
				if(!uv_is_closing((uv_handle_t*)handle))
					uv_poll_start(handle, UV_READABLE, onReadData);
			} else {
				// Request not finished, pipelining, continue serving data
				if(!uv_is_closing((uv_handle_t*)handle))
					uv_poll_start(handle, UV_WRITABLE, onReadDataPipelined);
				//onReadDataPipelined(handle, 0, 0);
			}
		} else if (numSent < 0) {
			int err = errno;

			if (err != EAGAIN) {
				uv_poll_stop(handle);
				uv_close((uv_handle_t *) handle, MNS::Server::onClose);
				return;
			}
		}

	}
}

MNS::Server::Server() {
	MNS::Server::response_msgs[200] = "200 OK\r\n";