/* Initialize module */
void __attribute__ ((constructor)) _init(void)
{
	int opt = 1;
	struct sockaddr_in sin;

	orig_sendto = preload("sendto");
	orig_recvfrom = preload("recvfrom");
	orig_setsockopt = preload("setsockopt");
	orig_bind = preload("bind");

	ctrl_socket = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP);
	if (ctrl_socket < 0) {
		printf ("Ajil lib failed to create control socket\n");
		exit (-1);
	}
	orig_setsockopt (ctrl_socket, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));

	memset (&sin, 0, sizeof(struct sockaddr_in));
	sin.sin_family = AF_INET;
	sin.sin_addr.s_addr = inet_addr(DADDRESS);
	sin.sin_port = htons(DPORT);

	if (connect (ctrl_socket, (struct sockaddr *) &sin, sizeof(struct sockaddr_in)) < 0) {
		printf ("Could not connect to Ajil daemon\n");
		exit (-1);
	} else {
		printf ("Connected to Ajil daemon\n");
		usleep (500);
		if (recv (ctrl_socket, (void *) &data_port, sizeof(uint16_t), 0) < 0) {
			printf ("Error receiving port number from daemon\n");
			exit (-1);
		}
	}
}

SlippyMapCache::SlippyMapCache()
: QObject(0), DownloadReply(0), DownloadBusy(false), theMap(0)
{
    baseUrl.setUrl("http://tile.openstreetmap.org");
    Download.setProxy(M_PREFS->getProxy(baseUrl));

    connect(&Download,SIGNAL(finished(QNetworkReply*)),this,SLOT(on_requestFinished(QNetworkReply*)));

    preload(Coord(0,0,0),":/Tiles/000.png");
    preload(Coord(0,0,1),":/Tiles/100.png");
    preload(Coord(0,1,1),":/Tiles/101.png");
    preload(Coord(1,0,1),":/Tiles/110.png");
    preload(Coord(1,1,1),":/Tiles/111.png");
}

SlippyMapCache::SlippyMapCache()
: QObject(0), DownloadId(0), DownloadBusy(false), theMap(0)
{
    Download.setProxy(M_PREFS->getProxy(QUrl(QString("http://tile.openstreetmap.org"))));
    Download.setHost("tile.openstreetmap.org");

    DownloadBuffer.setBuffer(&DownloadData);
    DownloadBuffer.open(QIODevice::WriteOnly);
    connect(&Download,SIGNAL(requestFinished(int,bool)),this,SLOT(on_requestFinished(int, bool)));

    preload(Coord(0,0,0),":/Tiles/000.png");
    preload(Coord(0,0,1),":/Tiles/100.png");
    preload(Coord(0,1,1),":/Tiles/101.png");
    preload(Coord(1,0,1),":/Tiles/110.png");
    preload(Coord(1,1,1),":/Tiles/111.png");
}

__int64 binstream::read_int64( )
{
	if (pos>inbuffer-8) preload();
	__int64 i64=*((__int64*)&buffer[pos]);
	pos+=8;
	return i64;
}

int binstream::read_int( )
{
	if (pos>inbuffer-4) preload();
	int i= *((int*)&buffer[pos]);
	pos+=4;
	return i;
}

double binstream::read_double( )
{
	if (pos>inbuffer-8) preload();
	double d=*((double*)&buffer[pos]);
	pos+=8;
	return d;
}

int binstream::readblock(void* dataPtr, int len)
{
	if (pos>inbuffer-len) preload();
	memcpy(dataPtr, &buffer[pos], len);
	pos+=len;
	return len;
}

bool binstream::read_bool( )
{
	if (pos>inbuffer-1) preload();
	bool b= *((bool*)&buffer[pos]);
	++pos;
	return b;
}

void 
MMRDecoder::VLSource::shift(const int n)
{ 
  codeword<<=n;
  lowbits+=n;
  if (lowbits>=16)
    preload();
}

char binstream::getchar()
{
	if (pos>inbuffer || inbuffer==0) preload();
	char c=buffer[pos];
	pos++;
	if (unicode) pos++;
	return c;
}

Options_Window::Options_Window() : 
Window(SCREEN_WIDTH, SCREEN_HEIGHT, "Options"),
tabs(*this),
content_area(*this)
{
  preload(10,10);

}

void HTMLResourcePreloader::takeAndPreload(PreloadRequestStream& r)
{
    PreloadRequestStream requests;
    requests.swap(r);

    for (PreloadRequestStream::iterator it = requests.begin(); it != requests.end(); ++it)
        preload(it->release());
}

void PEAC:: openanswerfile()
{
    name= QFileDialog::getOpenFileName (this,"Browse Files","~/Desktop",("PEAC File (*.peac)"));
    preload();

   // ui->textEdit_2->append(list[0]);
    checkNA();
}

int binstream::read_bigendianint()
{
	if (pos>inbuffer-4) preload();
	int i= (unsigned char)buffer[pos++];
	i = (i<<8) + (unsigned char)buffer[pos++];
	i = (i<<8) + (unsigned char)buffer[pos++];
	i = (i<<8) + (unsigned char)buffer[pos++];
	return i;
}

void ResourcePreloader::takeAndPreload(PreloadRequestStream& r)
{
    PreloadRequestStream requests;
    NetworkHintsInterfaceImpl networkHintsInterface;
    requests.swap(r);

    for (PreloadRequestStream::iterator it = requests.begin(); it != requests.end(); ++it)
        preload(it->release(), networkHintsInterface);
}

static void
ReadDependentCB(const char *aDependentLib, bool do_preload)
{
    if (do_preload)
        preload(aDependentLib);
    (void) NSAddImage(aDependentLib,
                      NSADDIMAGE_OPTION_RETURN_ON_ERROR |
                      NSADDIMAGE_OPTION_MATCH_FILENAME_BY_INSTALLNAME);
}

bool binstream::open(const wchar_t* filename)
{
// http://msdn.microsoft.com/en-us/library/windows/desktop/aa365747(v=vs.85).aspx
	if (opened)
	{
		flush();
		CloseHandle(f);
	}

	inbuffer=0;
	pos=0;
	fileStream = true;

	if (buffersize<2)
		throw "Buffer should be at least 2 characters long.";
	if (writable)
	{
		f = CreateFileW( filename, 
			GENERIC_WRITE,
			0, // No sharing
			NULL,
			CREATE_ALWAYS, // 
			FILE_ATTRIBUTE_NORMAL,
			NULL);
	} else
	{
		f = CreateFileW( filename, 
			GENERIC_READ,
			0, // No sharing
			NULL,
			OPEN_EXISTING, // 
			FILE_ATTRIBUTE_NORMAL,
			NULL);
		if (GetLastError()==ERROR_FILE_NOT_FOUND )
		{
		failbit=true;
			throw "File not found.";
		}
	}
	if (!f)
	{			
		failbit=true;
		return false;
	}

	if (!buffer)
		buffer = new char[buffersize]; 
	preload();

	testforUnicode();

	opened=true;
	return true;
} // binstream::open(wchar_t* filename)

wchar_t* binstream::read_wchar( )
{
	wchar_t* wc; //shared ptr would be better
	int len=read_int();
	if (pos>inbuffer-len*2) preload();
	wc=new wchar_t[len+1];
	memcpy(wc,&buffer[pos], len*2);
	pos+=len*2;
	wc[len]=0;
	return wc;
}

bool binstream::eof()
{
	if (pos<inbuffer)
		return false;
	
	if (!fileStream) return true; // end of the memory stream
	
	// read on more data if it is a file stream
	preload();
	return inbuffer==0;
}

char* binstream::read_char( )
{
	char* c; //shared ptr would be better
	int len=read_int();
	if (pos>inbuffer-len) preload();
	c=new char[len+1];
	memcpy(c,&buffer[pos], len);
	pos+=len;
	c[len]=0;
	return c;
}