summaryrefslogtreecommitdiff
authorllornkcor <llornkcor>2002-11-05 01:10:38 (UTC)
committer llornkcor <llornkcor>2002-11-05 01:10:38 (UTC)
commit9ac6d0a443c417158e3f2acf2de0629c51b6511c (patch) (side-by-side diff)
treee9791e964d950a49c43b05459e0710b5aa8d5dae
parent4efdcbfa9ae55ba42b10b5003c9e524b2e1f0eef (diff)
downloadopie-9ac6d0a443c417158e3f2acf2de0629c51b6511c.zip
opie-9ac6d0a443c417158e3f2acf2de0629c51b6511c.tar.gz
opie-9ac6d0a443c417158e3f2acf2de0629c51b6511c.tar.bz2
pthread stuff.
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--noncore/todayplugins/stockticker/stocktickerlib/stocktickerlib.pro2
-rw-r--r--noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.cpp195
-rw-r--r--noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.h16
3 files changed, 142 insertions, 71 deletions
diff --git a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerlib.pro b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerlib.pro
index 4b7b177..13c846b 100644
--- a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerlib.pro
+++ b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerlib.pro
@@ -19,9 +19,9 @@ INCLUDEPATH += $(OPIEDIR)/include \
../ ../library
DEPENDPATH += $(OPIEDIR)/include \
../ ../library
-LIBS+= -lqpe -lopie
+LIBS+= -lqpe -lopie -lpthread
TMAKE_CFLAGS += -D__UNIX__
DESTDIR = $(OPIEDIR)/plugins/today
TARGET = todaystocktickerplugin
diff --git a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.cpp b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.cpp
index 8830472..572a720 100644
--- a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.cpp
+++ b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.cpp
@@ -13,8 +13,9 @@
* (at your option) any later version. *
* *
***************************************************************************/
+#include <qsocket.h>
#include <qvaluelist.h>
#include <qtl.h>
#include <qstring.h>
#include <qstringlist.h>
@@ -22,61 +23,34 @@
#include <qlayout.h>
#include <qlineedit.h>
#include <qregexp.h>
#include <qtimer.h>
+#include <qmessagebox.h>
#include <qpe/config.h>
#include <qpe/timestring.h>
#include <qpe/qcopenvelope_qws.h>
+#include <qpe/network.h>
#include <opie/oticker.h>
-//#include "ticker.h"
extern "C" {
#include "libstocks/stocks.h"
}
-#include "stocktickerpluginwidget.h"
-
-StockTickerPluginWidget::StockTickerPluginWidget( QWidget *parent, const char* name)
- : QWidget(parent, name ) {
- init();
- startTimer(1000);
-}
-
-StockTickerPluginWidget::~StockTickerPluginWidget() {
-}
+#include <pthread.h>
-void StockTickerPluginWidget::init() {
-
- QHBoxLayout* layout = new QHBoxLayout( this );
-
- stocktickerTicker = new OTicker(this);
- stocktickerTicker->setMinimumHeight(15);
- connect( stocktickerTicker, SIGNAL( mousePressed()), this, SLOT( doStocks() ));
-
- layout->addWidget( stocktickerTicker);
-
-}
-
-void StockTickerPluginWidget::doStocks() {
- Config cfg( "stockticker");
- cfg.setGroup( "Symbols" );
- QString symbollist;
- symbollist = cfg.readEntry("Symbols", "");
- symbollist.replace(QRegExp(" "),"+");//seperated by +
-// qDebug(symbollist);
+#include "stocktickerpluginwidget.h"
- getStocks( symbollist.latin1());
-
- stocktickerTicker->setText( output );
-}
+QString output;
+OTicker *stocktickerTicker;
-void StockTickerPluginWidget::getStocks( const char *blah) {
+void getStocks( const QString *blah) {
+// stocktickerTicker->setText( "Downloading stock data.");
stock *stocks_quotes=NULL;
stock *stocks_tmp;
-
+ qDebug("%s", blah->latin1());
QString tempString;
output = "";
libstocks_return_code error;
@@ -100,10 +74,31 @@ void StockTickerPluginWidget::getStocks( const char *blah) {
domaxPriceCheck=cfg.readBoolEntry("maxPriceCheck",1);
dovariationCheck=cfg.readBoolEntry("variationCheck",1);
dovolumeCheck=cfg.readBoolEntry("volumeCheck",1);
- DefProxy();
- char *stock_liste = (char *)blah;
+// DefProxy();
+ {
+ char *proxy;
+ libstocks_return_code error;
+
+ /* Proxy support */
+ /* Checks for "http_proxy" environment variable */
+ proxy = getenv("http_proxy");
+ if(proxy) {
+ /* printf("proxy set\n"); */
+ error = set_proxy(proxy);
+ if (error) {
+ printf("Proxy error (%d)\n", error);
+ QString tempString;
+ tempString.sprintf("Proxy error (%d)\n", error);
+ output = tempString;
+ return;
+// exit(1);
+ }
+ }
+ }
+ char *stock_liste = (char *)blah->latin1();
+// char *stock_liste = (char *)blah;
/* Get the stocks and process errors */
error = get_stocks( stock_liste, &stocks_quotes);
if (error) {
@@ -216,39 +211,119 @@ void StockTickerPluginWidget::getStocks( const char *blah) {
}
/* frees stocks */
free_stocks(stocks_quotes);
+ stocktickerTicker->setText( output );
}
-void StockTickerPluginWidget::DefProxy(void) {
- char *proxy;
- libstocks_return_code error;
+StockTickerPluginWidget::StockTickerPluginWidget( QWidget *parent, const char* name)
+ : QWidget(parent, name ) {
+ init();
+ startTimer(1000);
+// checkConnection();
+}
- /* Proxy support */
- /* Checks for "http_proxy" environment variable */
- proxy = getenv("http_proxy");
- if(proxy) {
- /* printf("proxy set\n"); */
- error = set_proxy(proxy);
- if (error) {
-// printf("Proxy error (%d)\n", error);
- QString tempString;
- tempString.sprintf("Proxy error (%d)\n", error);
- output = tempString;
- return;
-// exit(1);
- }
+StockTickerPluginWidget::~StockTickerPluginWidget() {
+}
+
+void StockTickerPluginWidget::init() {
+
+ QHBoxLayout* layout = new QHBoxLayout( this );
+ stocktickerTicker = new OTicker(this);
+ stocktickerTicker->setMinimumHeight(15);
+ connect( stocktickerTicker, SIGNAL( mousePressed()), this, SLOT( checkConnection() ));
+ layout->addWidget( stocktickerTicker);
+ wasError = true;
+}
+
+void StockTickerPluginWidget::doStocks() {
+ Config cfg( "stockticker");
+ cfg.setGroup( "Symbols" );
+ QString symbollist;
+ symbollist = cfg.readEntry("Symbols", "");
+ symbollist.replace(QRegExp(" "),"+");//seperated by +
+
+// qDebug(symbollist);
+ if (!symbollist.isEmpty()) {
+ pthread_t thread1;
+ pthread_create(&thread1,NULL, (void * (*)(void *))getStocks, &symbollist);
}
+// pthread_join(thread1,NULL);
+// getStocks( symbollist.latin1() );
+}
+
+void StockTickerPluginWidget::DefProxy(void) {
+// char *proxy;
+// libstocks_return_code error;
+
+// /* Proxy support */
+// /* Checks for "http_proxy" environment variable */
+// proxy = getenv("http_proxy");
+// if(proxy) {
+// /* printf("proxy set\n"); */
+// error = set_proxy(proxy);
+// if (error) {
+// // printf("Proxy error (%d)\n", error);
+// QString tempString;
+// tempString.sprintf("Proxy error (%d)\n", error);
+// output = tempString;
+// return;
+// // exit(1);
+// }
+// }
+}
+
+void StockTickerPluginWidget::timerEvent( QTimerEvent *e ) {
+ killTimer(e->timerId());
+ checkConnection();
+}
+
+void StockTickerPluginWidget::checkConnection() {
+// qDebug("checking connection");
+// Sock = new QSocket( this );
+
+// if( wasError)
+// stocktickerTicker->setText("Checking connection");
+
+// if(Sock->state() == QSocket::Idle) {
+// Sock->connectToHost("finance.yahoo.com", 80);
+// connect( Sock, SIGNAL( error(int) ), SLOT(socketError(int)) );
+// connect( Sock, SIGNAL( hostFound() ), SLOT(isConnected()) );
+// } else {
+// qDebug("State is not Idle");
+ isConnected();
+// }
}
-void StockTickerPluginWidget::timerEvent( QTimerEvent *e ) {
- killTimer(e->timerId());
+void StockTickerPluginWidget::isConnected() {
+// qDebug("We connect, so ok to grab stocks");
doStocks();
+
Config cfg( "stockticker");
- cfg.setGroup("Timer");
- timerDelay= cfg.readNumEntry("Delay",0);
+ cfg.setGroup("Timer");
+ timerDelay= cfg.readNumEntry("Delay",0);
if(timerDelay > 0)
startTimer(timerDelay*60000);
qDebug("timer set for %d",(timerDelay*60000)/60000);
-
+ wasError = false;
+
+// Sock->close();
+}
+
+void StockTickerPluginWidget::socketError(int errcode) {
+ switch(errcode) {
+ case QSocket::ErrConnectionRefused:
+ output = tr("Connection refused.");
+ break;
+ case QSocket::ErrHostNotFound:
+ output = tr("Could not find server.");
+ break;
+ case QSocket::ErrSocketRead :
+ output = tr("Socket read error.");
+ break;
+ };
+ stocktickerTicker->setText( output );
+ wasError = true;
+// Sock->close();
+
}
diff --git a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.h b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.h
index 26472fa..c8de806 100644
--- a/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.h
+++ b/noncore/todayplugins/stockticker/stocktickerlib/stocktickerpluginwidget.h
@@ -17,8 +17,9 @@
#ifndef STOCKTICKERL_PLUGIN_WIDGET_H
#define STOCKTICKERL_PLUGIN_WIDGET_H
+#include <qsocket.h>
#include <qstring.h>
#include <qwidget.h>
#include <qlineedit.h>
@@ -32,14 +33,8 @@
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
-//#include "ticker.h"
-
-/* extern "C" { */
-/* #include "stocks.h" */
-/* } */
-
class QTimer;
class StockTickerPluginWidget : public QWidget {
@@ -47,18 +42,19 @@ class StockTickerPluginWidget : public QWidget {
public:
StockTickerPluginWidget( QWidget *parent, const char *name );
~StockTickerPluginWidget();
- QString output;
protected slots:
void doStocks();
-
+ void isConnected();
+ void socketError(int);
+ void checkConnection();
private:
- OTicker *stocktickerTicker;
+ bool wasError;
+ QSocket *Sock;
void timerEvent( QTimerEvent * );
void init();
- void getStocks( const char *stock_liste);
void DefProxy(void);
int timerDelay;
};