summaryrefslogtreecommitdiffstats
path: root/kstars/kstars/stardatasink.cpp
blob: e0f9f09fdcedee5157c77ad1d96a206fa1d319ca (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
/***************************************************************************
                          stardatasink.cpp  -  description
                             -------------------
    begin                : Son Feb 10 2002
    copyright            : (C) 2002 by Thomas Kabelmann
    email                : tk78@gmx.de
 ***************************************************************************/

/***************************************************************************
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 ***************************************************************************/

#include "stardatasink.h"

#include "dms.h"
#include "kstarsdata.h"

StarDataSink::StarDataSink(KStarsData *tqparent, const char *name) : TQObject(tqparent, name) {
	ksData = tqparent;
	receivedBlocks = 0;
	nameListCount = ksData->ObjNames.count();
}

StarDataSink::~StarDataSink(){
}

int StarDataSink::readyToReceive(){
	// return a value != NULL, to show that the object is ready for receiveing data.
	return 1;
}

void StarDataSink::eof() {
	// update skymap at the end of reloading
	emit updateSkymap();
	// clear cached finddialog if new objects were appended to the list
	if (nameListCount != ksData->ObjNames.count()) emit clearCache();
	// end of data transmission
	emit done();
}

void StarDataSink::receive( const uchar *data, int entries ) {
	receivedBlocks++;
	// Pointer was send as const uchar* so it must be converted explicitly to TQString*
	TQString *line = (TQString *) data;
	int counter = -1;
	while (++counter < entries) {  // run counter from 0 to entries -1
		ksData->processStar(line, true);
		line++;
	}

	// update the skymap every tenth block
	if (receivedBlocks % 10 == 0) emit updateSkymap();
}

#include "stardatasink.moc"