/*
Bacula® - The Network Backup Solution
- Copyright (C) 2007-2009 Free Software Foundation Europe e.V.
+ Copyright (C) 2007-2010 Free Software Foundation Europe e.V.
The main author of Bacula is Kern Sibbald, with contributions from
many others, a complete list can be found in the file AUTHORS.
Switzerland, email:ftf@fsfeurope.org.
*/
/*
- * Version $Id$
- *
* Console Class
*
* Kern Sibbald, January MMVII
#include "select.h"
#include "run/run.h"
-Console::Console(QStackedWidget *parent)
+Console::Console(QTabWidget *parent)
{
QFont font;
+ m_name = tr("Console");
m_messages_pending = false;
m_parent = parent;
m_closeable = false;
m_console = this;
m_warningPrevent = false;
m_dircommCounter = 0;
+
+ /*
+ * Create a connection to the Director and put it in a hash table
+ */
m_dircommHash.insert(m_dircommCounter, new DirComm(this, m_dircommCounter));
setupUi(this);
void Console::poll_messages()
{
int conn;
- if (!availableDirComm(conn))
+ if (!availableDirComm(conn)) {
return;
+ }
DirComm *dircomm = m_dircommHash.value(conn);
if (mainWin->m_checkMessages && dircomm->m_at_main_prompt && hasFocus() && !mainWin->getWaitState()){
* A function created to separate out the population of the lists
* from the Console::connect_dir function
*/
-void Console::populateLists(bool forcenew)
+void Console::populateLists(bool /*forcenew*/)
{
int conn;
- if (forcenew) {
- if (!newDirComm(conn)) {
- Pmsg1(000, "newDirComm Seems to Failed to create a connection for populateLists %s\n", m_dir->name());
- return;
- }
- } else {
- if (!availableDirComm(conn)) {
- Pmsg1(000, "availableDirComm Seems to Failed to find a connection for populateListsi %s\n", m_dir->name());
- return;
- }
+ if (!availableDirComm(conn) && !newDirComm(conn)) {
+ Emsg1(M_ABORT, 0, "Failed to connect to %s for populateLists.\n", m_dir->name());
+ return;
}
populateLists(conn);
}
storage_list.clear();
type_list.clear();
level_list.clear();
+ volstatus_list.clear();
+ mediatype_list.clear();
dir_cmd(conn, ".jobs", job_list);
dir_cmd(conn, ".clients", client_list);
dir_cmd(conn, ".filesets", fileset_list);
dir_cmd(conn, ".storage", storage_list);
dir_cmd(conn, ".types", type_list);
dir_cmd(conn, ".levels", level_list);
+ dir_cmd(conn, ".volstatus", volstatus_list);
+ dir_cmd(conn, ".mediatypes", mediatype_list);
+ dir_cmd(conn, ".locations", location_list);
if (mainWin->m_connDebug) {
QString dbgmsg = QString("jobs=%1 clients=%2 filesets=%3 msgs=%4 pools=%5 storage=%6 types=%7 levels=%8 conn=%9 %10\n")
dir_cmd(conn, cmd, results);
return true;
} else {
- Pmsg1(000, "dir_cmd Seems to Failed to find a connection %s\n", m_dir->name());
+ Pmsg1(000, "dir_cmd failed to connect to %s\n", m_dir->name());
return false;
}
}
bool Console::sql_cmd(QString &query, QStringList &results)
{
int conn;
- if (!availableDirComm(conn))
+ if (!availableDirComm(conn)) {
return false;
+ }
return sql_cmd(conn, query.toUtf8().data(), results, true);
}
bool Console::sql_cmd(const char *query, QStringList &results)
{
int conn;
- if (!availableDirComm(conn))
+ if (!availableDirComm(conn)) {
return false;
+ }
return sql_cmd(conn, query, results, true);
}
int Console::write_dir(const char *msg)
{
int conn;
- if (availableDirComm(conn))
+ if (availableDirComm(conn)) {
write_dir(conn, msg);
+ }
return conn;
}
int Console::write_dir(const char *msg, bool dowait)
{
int conn;
- if (availableDirComm(conn))
+ if (availableDirComm(conn)) {
write_dir(conn, msg, dowait);
+ }
return conn;
}
if (mainWin->m_commDebug) Pmsg2(000, "endDiscardToPrompt=%d %s\n", stat, m_dir->name());
}
+QString Console::returnFromPrompt(int conn)
+{
+ DirComm *dircomm = m_dircommHash.value(conn);
+ QString text("");
+
+ int stat = 0;
+ text = "";
+ if (mainWin->m_commDebug) Pmsg1(000, "returnFromPrompt %s\n", m_dir->name());
+ while (!dircomm->m_at_prompt) {
+ if ((stat=dircomm->read()) > 0) {
+ text += dircomm->msg();
+ }
+ }
+ if (mainWin->m_commDebug) Pmsg2(000, "endreturnFromPrompt=%d %s\n", stat, m_dir->name());
+ return text;
+}
+
/*
* When the notifier is enabled, read_dir() will automatically be
* called by the Qt event loop when ever there is any output
int Console::notifyOff()
{
int conn = 0;
- if (availableDirComm(conn))
+ if (availableDirComm(conn)) {
notify(conn, false);
+ }
return conn;
}
* This may be rendered not needed if the multiple connections feature gets working */
bool Console::hasFocus()
{
- if (mainWin->stackedWidget->currentIndex() == mainWin->stackedWidget->indexOf(this))
+ if (mainWin->tabWidget->currentIndex() == mainWin->tabWidget->indexOf(this))
return true;
else
return false;
*/
bool Console::availableDirComm(int &conn)
{
- QHash<int, DirComm*>::const_iterator iter = m_dircommHash.constBegin();
- while (iter != m_dircommHash.constEnd()) {
- DirComm *dircomm = iter.value();
- if (dircomm->m_at_prompt && dircomm->m_at_main_prompt && dircomm->is_notify_enabled()) {
- conn = dircomm->m_conn;
- return true;
- }
- ++iter;
- }
- if (newDirComm(conn))
+ if (currentDirComm(conn)) {
return true;
- else
- return false;
+ }
+ return newDirComm(conn);
}
*/
bool Console::currentDirComm(int &conn)
{
+ int i = 1;
QHash<int, DirComm*>::const_iterator iter = m_dircommHash.constBegin();
while (iter != m_dircommHash.constEnd()) {
DirComm *dircomm = iter.value();
- if (dircomm->m_at_prompt && !dircomm->m_at_main_prompt && dircomm->is_notify_enabled()) {
+ if (dircomm->m_at_prompt && dircomm->m_at_main_prompt && dircomm->is_notify_enabled()) {
conn = dircomm->m_conn;
return true;
}
+ if (mainWin->m_connDebug) {
+ Pmsg4(000, "currentDirComm=%d at_prompt=%d at_main=%d && notify=%d\n",
+ i, dircomm->m_at_prompt, dircomm->m_at_main_prompt, dircomm->is_notify_enabled());
+ i++;
+ }
++iter;
}
return false;
*/
bool Console::newDirComm(int &conn)
{
- m_dircommCounter += 1;
- conn = m_dircommCounter;
- if (mainWin->m_connDebug)
- Pmsg2(000, "DirComm %i About to Create and Connect %s\n", m_dircommCounter, m_dir->name());
+ m_dircommCounter++;
+ if (mainWin->m_connDebug) {
+ Pmsg2(000, "newDirComm=%i to: %s\n", m_dircommCounter, m_dir->name());
+ }
DirComm *dircomm = new DirComm(this, m_dircommCounter);
m_dircommHash.insert(m_dircommCounter, dircomm);
bool success = dircomm->connect_dir();
if (mainWin->m_connDebug) {
- if (success)
- Pmsg2(000, "DirComm %i Connected %s\n", conn, m_dir->name());
- else
- Pmsg2(000, "DirComm %i NOT Connected %s\n", conn, m_dir->name());
+ if (success) {
+ Pmsg2(000, "newDirComm=%i Connected %s\n", m_dircommCounter, m_dir->name());
+ } else {
+ Emsg2(M_ERROR, 0, "DirComm=%i. Unable to connect to %s\n",
+ m_dircommCounter, m_dir->name());
+ }
}
+ if (!success) {
+ m_dircommHash.remove(m_dircommCounter);
+ delete dircomm;
+ m_dircommCounter--;
+ }
+ conn = m_dircommCounter;
return success;
}