Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features.

BUG:215923


git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdebase@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da

1 files changed, 225 insertions, 0 deletions

diff --git a/kcontrol/samba/ksmbstatus.cpp b/kcontrol/samba/ksmbstatus.cpp
new file mode 100644
index 000000000..4866a3a1e
--- /dev/null
+++ b/kcontrol/samba/ksmbstatus.cpp
@@ -0,0 +1,225 @@
+/*
+ * ksmbstatus.cpp
+ *
+ *  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.
+ *
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ */
+
+#include <signal.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <time.h>
+
+#include <qlayout.h>
+
+#include <klocale.h>
+#include <kdialog.h>
+
+#include "ksmbstatus.h"
+#include "ksmbstatus.moc"
+
+
+#define Before(ttf,in) in.left(in.find(ttf))
+#define After(ttf,in)  (in.contains(ttf)?QString(in.mid(in.find(ttf)+QString(ttf).length())):QString(""))
+
+NetMon::NetMon( QWidget * parent, KConfig *config, const char * name )
+   : QWidget(parent, name)
+   ,configFile(config)
+   ,showmountProc(0)
+   ,strShare("")
+   ,strUser("")
+   ,strGroup("")
+   ,strMachine("")
+   ,strSince("")
+   ,strPid("")
+   ,iUser(0)
+   ,iGroup(0)
+   ,iMachine(0)
+   ,iPid(0)
+{
+    QBoxLayout *topLayout = new QVBoxLayout(this, KDialog::marginHint(),
+        KDialog::spacingHint());
+    topLayout->setAutoAdd(true);
+
+    list=new QListView(this,"Hello");
+    version=new QLabel(this);
+
+    list->setAllColumnsShowFocus(true);
+    list->setMinimumSize(425,200);
+    list->setShowSortIndicator(true);
+
+    list->addColumn(i18n("Type"));
+    list->addColumn(i18n("Service"));
+    list->addColumn(i18n("Accessed From"));
+    list->addColumn(i18n("UID"));
+    list->addColumn(i18n("GID"));
+    list->addColumn(i18n("PID"));
+    list->addColumn(i18n("Open Files"));
+
+    timer = new QTimer(this);
+    timer->start(15000);
+    QObject::connect(timer, SIGNAL(timeout()), this, SLOT(update()));
+    update();
+}
+
+void NetMon::processNFSLine(char *bufline, int)
+{
+   QCString line(bufline);
+   if (line.contains(":/"))
+      new QListViewItem(list,"NFS",After(":",line),Before(":/",line));
+}
+
+void NetMon::processSambaLine(char *bufline, int)
+{
+   QCString line(bufline);
+   rownumber++;
+   if (rownumber == 2)
+      version->setText(bufline); // second line = samba version
+   if ((readingpart==header) && line.contains("Service"))
+   {
+      iUser=line.find("uid");
+      iGroup=line.find("gid");
+      iPid=line.find("pid");
+      iMachine=line.find("machine");
+   }
+   else if ((readingpart==header) && (line.contains("---")))
+   {
+      readingpart=connexions;
+   }
+   else if ((readingpart==connexions) && (int(line.length())>=iMachine))
+   {
+      strShare=line.mid(0,iUser);
+      strUser=line.mid(iUser,iGroup-iUser);
+      strGroup=line.mid(iGroup,iPid-iGroup);
+      strPid=line.mid(iPid,iMachine-iPid);
+
+      line=line.mid(iMachine,line.length());
+      strMachine=line;
+      new QListViewItem(list,"SMB",strShare,strMachine, strUser,strGroup,strPid/*,strSince*/);
+   }
+   else if (readingpart==connexions)
+      readingpart=locked_files;
+   else if ((readingpart==locked_files) && (line.find("No ")==0))
+      readingpart=finished;
+   else if (readingpart==locked_files)
+   {
+      if ((strncmp(bufline,"Pi", 2) !=0) // "Pid DenyMode ..."
+          && (strncmp(bufline,"--", 2) !=0)) // "------------"
+      {
+         char *tok=strtok(bufline," ");
+         if (tok) {
+             int pid=atoi(tok);
+             (lo)[pid]++;
+         }
+      }
+   }
+}
+
+// called when we get some data from smbstatus
+// can be called for any size of buffer (one line, several lines,
+// half of one ...)
+void NetMon::slotReceivedData(KProcess *, char *buffer, int )
+{
+   //kdDebug()<<"received stuff"<<endl;
+   char s[250],*start,*end;
+   size_t len;
+   start = buffer;
+   while ((end = strchr(start,'\n'))) // look for '\n'
+   {
+      len = end-start;
+      if (len>=sizeof(s))
+	      len=sizeof(s)-1;
+      strncpy(s,start,len);
+      s[len] = '\0';
+      //kdDebug() << "recived: "<<s << endl;
+      if (readingpart==nfs)
+         processNFSLine(s,len);
+      else
+         processSambaLine(s,len); // process each line
+      start=end+1;
+   }
+   if (readingpart==nfs)
+   {
+      list->viewport()->update();
+      list->update();
+   }
+   // here we could save the remaining part of line, if ever buffer
+   // doesn't end with a '\n' ... but will this happen ?
+}
+
+void NetMon::update()
+{
+   KProcess * process = new KProcess();
+
+   memset(&lo, 0, sizeof(lo));
+   list->clear();
+   /* Re-read the Contents ... */
+
+   QString path(::getenv("PATH"));
+   path += "/bin:/sbin:/usr/bin:/usr/sbin";
+
+   rownumber=0;
+   readingpart=header;
+   nrpid=0;
+   process->setEnvironment("PATH", path);
+   connect(process,
+           SIGNAL(receivedStdout(KProcess *, char *, int)),
+           SLOT(slotReceivedData(KProcess *, char *, int)));
+   *process << "smbstatus";
+   if (!process->start(KProcess::Block,KProcess::Stdout))
+      version->setText(i18n("Error: Unable to run smbstatus"));
+   else if (rownumber==0) // empty result
+      version->setText(i18n("Error: Unable to open configuration file \"smb.conf\""));
+   else
+   {
+      // ok -> count the number of locked files for each pid
+      for (QListViewItem *row=list->firstChild();row!=0;row=row->itemBelow())
+      {
+//         cerr<<"NetMon::update: this should be the pid: "<<row->text(5)<<endl;
+         int pid=row->text(5).toInt();
+         row->setText(6,QString("%1").arg((lo)[pid]));
+      }
+   }
+   delete process;
+   process=0;
+
+   readingpart=nfs;
+   delete showmountProc;
+   showmountProc=new KProcess();
+   showmountProc->setEnvironment("PATH", path);
+   *showmountProc<<"showmount"<<"-a"<<"localhost";
+   connect(showmountProc,SIGNAL(receivedStdout(KProcess *, char *, int)),SLOT(slotReceivedData(KProcess *, char *, int)));
+   //without this timer showmount hangs up to 5 minutes
+   //if the portmapper daemon isn't running
+   QTimer::singleShot(5000,this,SLOT(killShowmount()));
+   //kdDebug()<<"starting kill timer with 5 seconds"<<endl;
+   connect(showmountProc,SIGNAL(processExited(KProcess*)),this,SLOT(killShowmount()));
+   if (!showmountProc->start(KProcess::NotifyOnExit,KProcess::Stdout)) // run showmount
+   {
+      delete showmountProc;
+      showmountProc=0;
+   }
+
+   version->adjustSize();
+   list->show();
+}
+
+void NetMon::killShowmount()
+{
+   //kdDebug()<<"killShowmount()"<<endl;
+    delete showmountProc;
+    showmountProc=0;
+}
+