Backend *c = (Backend *) user->getData();

	boost::shared_ptr<MemoryReadBytestream> bytestream(new MemoryReadBytestream(payload.size()));

	bytestream->onDataNeeded.connect(boost::bind(&NetworkPluginServer::handleFTDataNeeded, this, c, bytestream_id + 1));

	LOG4CXX_INFO(logger, "jid=" << buddy->getJID());

	FileTransferManager::Transfer transfer = m_ftManager->sendFile(user, buddy, bytestream, fileInfo);

	if (!transfer.ft) {

		handleFTRejected(user, payload.buddyname(), payload.filename(), payload.size());

		return;

	}

	m_filetransfers[++bytestream_id] = transfer;

	transfer.ft->onStateChange.connect(boost::bind(&NetworkPluginServer::handleFTStateChanged, this, _1, payload.username(), payload.buddyname(), payload.filename(), payload.size(), bytestream_id));

	transfer.ft->start();

}

void NetworkPluginServer::handleFTFinishPayload(const std::string &data) {

	pbnetwork::File payload;

	if (payload.ParseFromString(data) == false) {

		// TODO: ERROR

		return;

	}

	if (payload.has_ftid()) {

		if (m_filetransfers.find(payload.ftid()) != m_filetransfers.end()) {

			FileTransferManager::Transfer &transfer = m_filetransfers[payload.ftid()];

			transfer.ft->cancel();

		}

		else {

			LOG4CXX_ERROR(logger, "FTFinishPayload for unknown ftid=" << payload.ftid());

		}

	}

}

void NetworkPluginServer::handleFTDataPayload(Backend *b, const std::string &data) {

	pbnetwork::FileTransferData payload;

	if (payload.ParseFromString(data) == false) {

		// TODO: ERROR

		return;

	}

// 	User *user = m_userManager->getUser(payload.username());

// 	if (!user)

// 		return;

	FileTransferManager::Transfer &transfer = m_filetransfers[payload.ftid()];

	MemoryReadBytestream *bytestream = (MemoryReadBytestream *) transfer.readByteStream.get();

	if (bytestream->appendData(payload.data()) > 5000000) {

		pbnetwork::FileTransferData f;

		f.set_ftid(payload.ftid());

		f.set_data("");

		std::string message;

		f.SerializeToString(&message);

		WRAP(message, pbnetwork::WrapperMessage_Type_TYPE_FT_PAUSE);

		send(b->connection, message);

	}

}

void NetworkPluginServer::handleFTDataNeeded(Backend *b, unsigned long ftid) {

	pbnetwork::FileTransferData f;

	f.set_ftid(ftid);

	f.set_data("");

	std::string message;

	f.SerializeToString(&message);

	WRAP(message, pbnetwork::WrapperMessage_Type_TYPE_FT_CONTINUE);

	send(b->connection, message);

}

void NetworkPluginServer::handlePongReceived(Backend *c) {

	// This could be first PONG from the backend

	if (c->pongReceived == -1) {

		// Backend is fully ready to handle requests

		c->willDie = false;

		if (m_clients.size() == 1) {

			// first backend connected, start the server, we're ready.

			m_component->start();

		}

		// some users are in queue waiting for this backend

		while(!m_waitingUsers.empty()) {

			// There's no new backend, so stop associating users and wait for new backend,

			// which has been already spawned in getFreeClient() call.

			if (getFreeClient() == NULL)

				break;