Method threadEntry

src/decrypt/dvbapi/Client.cpp:368–519

	}

	void Client::threadEntry() {
		SI_LOG_INFO("Setting up DVBAPI client");

		struct pollfd pfd[1];

		// set time to try to connect
		std::time_t retryTime = std::time(nullptr) + 2;

		for (;; ) {
			// try to connect to server
			if (!_connected) {
				pfd[0].events  = POLLIN | POLLHUP | POLLRDNORM | POLLERR;
				pfd[0].revents = 0;
				pfd[0].fd      = -1;
				if (_enabled) {
					const std::time_t currTime = std::time(nullptr);
					if (retryTime < currTime) {
						if (initClientSocket(_client, _serverIPAddr, _serverPort)) {
							sendClientInfo();
							pfd[0].fd = _client.getFD();
						} else {
							_client.closeFD();
							retryTime = currTime + 5;
						}
					}
				}
			}
			// call poll with a timeout of 500 ms
			const int pollRet = poll(pfd, 1, 500);
			if (pollRet > 0) {
				if (pfd[0].revents != 0) {
					char tmpData[2048];
					auto i = 0;
					const ssize_t size = _client.recvDatafrom(tmpData, sizeof(tmpData) - 1, MSG_DONTWAIT);
					const unsigned char *buf = reinterpret_cast<unsigned char *>(&tmpData);
					if (size > 0) {
						while (i < size) {
							// get command
							const uint32_t cmd = (buf[i + 0] << 24) | (buf[i + 1] << 16) | (buf[i + 2] << 8) | buf[i + 3];
							SI_LOG_DEBUG("Stream: %d, Receive data total size %u - cmd: 0x%X", buf[i + 4] - _adapterOffset, size, cmd);

							switch (cmd) {
								case DVBAPI_SERVER_INFO: {
										_serverName.assign(reinterpret_cast<const char *>(&buf[i + 7]), buf[i + 6]);
										SI_LOG_INFO("Connected to %s", _serverName.c_str());
										_connected = true;

										// Goto next cmd
										i += 7 + _serverName.size();
										break;
									}
								case DVBAPI_DMX_SET_FILTER: {
										const int adapter =  buf[i + 4] - _adapterOffset;
										const int demux   =  buf[i + 5];
										const int filter  =  buf[i + 6];
										const int pid     = (buf[i + 7] << 8) | buf[i + 8];
										const unsigned char *filterData = &buf[i + 9];
										const unsigned char *filterMask = &buf[i + 25];