Method run

lib_acl_cpp/samples/socket/s3/main.cpp:14–43

protected:
	void* run(void)
	{
		char* buf = (char*) malloc(dlen_);
		memset(buf, 'X', dlen_);
		int flags = MSG_NOSIGNAL;
		if (zerocp_) {
			flags |= MSG_ZEROCOPY;
			conn_->set_zerocopy(true);
		}

		for (int i = 0; i < max_; i++)
		{
			if (conn_->send(buf, dlen_, flags) == -1)
			{
				printf("send error %s\r\n", acl::last_serror());
				break;
			}
			if (zerocp_ && !conn_->wait_iocp(5000)) {
				printf("wait result error %s\r\n", acl::last_serror());
				break;
			}
		}

		printf("Send over!\r\n");
		free(buf);
		delete conn_;
		delete this;

		return NULL;
	}

private:
	acl::socket_stream* conn_;