diff options
Diffstat (limited to 'lanbrowsing/kio_lan/kio_lan.cpp')
| -rw-r--r-- | lanbrowsing/kio_lan/kio_lan.cpp | 794 |
1 files changed, 0 insertions, 794 deletions
diff --git a/lanbrowsing/kio_lan/kio_lan.cpp b/lanbrowsing/kio_lan/kio_lan.cpp deleted file mode 100644 index e573f7ea..00000000 --- a/lanbrowsing/kio_lan/kio_lan.cpp +++ /dev/null @@ -1,794 +0,0 @@ -/* This file is part of the KDE project - Copyright (C) 2000,2001 Alexander Neundorf <[email protected]> - - This library is free software; you can redistribute it and/or - modify it under the terms of the GNU Library General Public - License as published by the Free Software Foundation; either - version 2 of the License, or (at your option) any later version. - - This library 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 - Library General Public License for more details. - - You should have received a copy of the GNU Library General Public License - along with this library; see the file COPYING.LIB. If not, write to - the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, - Boston, MA 02110-1301, USA. -*/ - -#ifdef HAVE_CONFIG_H -#include <config.h> -#endif - -#include <kdebug.h> -#include <klocale.h> -#include <kinstance.h> -#include <tdeconfig.h> -#include <kglobal.h> -#include <kprocess.h> - -#include <tqfile.h> - -#include <iostream> -#include <string.h> -#include <sys/un.h> -#include <sys/stat.h> -#include <sys/time.h> -#include <sys/types.h> -#include <sys/socket.h> -#include <netinet/in.h> -#include <unistd.h> -#include <netdb.h> -#include <stdlib.h> -#include <fcntl.h> -#include <errno.h> -#include <time.h> -#include <pwd.h> - -#include "tdeio_lan.h" - -#ifndef AF_LOCAL -#define AF_LOCAL AF_UNIX -#endif - -#define PORTSETTINGS_CHECK 0 -#define PORTSETTINGS_PROVIDE 1 -#define PORTSETTINGS_DISABLE 2 - -using namespace TDEIO; - -#ifndef SHUT_RDWR -#define SHUT_RDWR 2 -#endif - -extern "C" { KDE_EXPORT int kdemain(int argc, char **argv); } - -int kdemain( int argc, char **argv ) -{ - TDEInstance instance( "tdeio_lan" ); - - if (argc != 4) - { - fprintf(stderr, "Usage: tdeio_lan protocol domain-socket1 domain-socket2\n"); - exit(-1); - } - int isLanIoslave=(strcmp("lan",argv[1])==0); - - // Trigger creation to make sure we pick up KIOSK settings correctly. - (void)TDEGlobal::dirs(); - (void)TDEGlobal::locale(); - (void)TDEGlobal::config(); - - kdDebug(7101) << "LAN: kdemain: starting" << endl; - - LANProtocol slave(isLanIoslave, argv[2], argv[3]); - slave.dispatchLoop(); - return 0; -} - -LANProtocol::LANProtocol(int isLanIoslave, const TQCString &pool, const TQCString &app ) -:TCPSlaveBase(7741,isLanIoslave?"lan":"rlan", pool, app) -,m_currentHost("") -,m_port(7741) -,m_maxAge(15*60) -,m_isLanIoslave(isLanIoslave?true:false) -{ - TDEConfig *config=TDEGlobal::config(); - - m_protocolInfo[KIOLAN_FTP].enabled=config->readNumEntry("Support_FTP",PORTSETTINGS_CHECK); - m_protocolInfo[KIOLAN_HTTP].enabled=config->readNumEntry("Support_HTTP",PORTSETTINGS_CHECK); - m_protocolInfo[KIOLAN_NFS].enabled=config->readNumEntry("Support_NFS",PORTSETTINGS_CHECK); - m_protocolInfo[KIOLAN_SMB].enabled=config->readNumEntry("Support_SMB",PORTSETTINGS_CHECK); - m_protocolInfo[KIOLAN_FISH].enabled=config->readNumEntry("Support_FISH",PORTSETTINGS_CHECK); - - m_defaultLisaHost=config->readEntry("DefaultLisaHost", "localhost"); - m_shortHostnames=config->readBoolEntry("ShowShortHostnames",false); - m_maxAge=config->readNumEntry("MaxAge",15)*60; - if (m_maxAge<0) m_maxAge=0; - - strcpy(m_protocolInfo[KIOLAN_NFS].name,"NFS"); - strcpy(m_protocolInfo[KIOLAN_FTP].name,"FTP"); - strcpy(m_protocolInfo[KIOLAN_SMB].name,"SMB"); - strcpy(m_protocolInfo[KIOLAN_HTTP].name,"HTTP"); - strcpy(m_protocolInfo[KIOLAN_FISH].name,"FISH"); - - // Now we check for port 445 for SMB/CIFS also. But we call both entries - // SMB. Clients will see only one SMB folder, though, whichever - // port (or both) is detected. The smb ioslave should be able - // to figure out which port to actually use. - - m_protocolInfo[KIOLAN_NFS].ports.push_back(2049); - m_protocolInfo[KIOLAN_FTP].ports.push_back(21); - m_protocolInfo[KIOLAN_SMB].ports.push_back(445); - m_protocolInfo[KIOLAN_SMB].ports.push_back(139); - m_protocolInfo[KIOLAN_HTTP].ports.push_back(80); - m_protocolInfo[KIOLAN_FISH].ports.push_back(22); - - m_hostInfoCache.setAutoDelete(true); -} - -LANProtocol::~LANProtocol() -{ - m_hostInfoCache.clear(); -} - -int LANProtocol::readDataFromServer() -{ - if (m_isLanIoslave) - return lanReadDataFromServer(); - else - return rlanReadDataFromServer(); - return 0; -} - -int LANProtocol::lanReadDataFromServer() -{ - kdDebug(7101)<<"LANProtocol::lanReadDataFromServer() host: "<<m_currentHost<<" port: "<<m_port<<endl; - if (!connectToHost(m_currentHost.latin1(), m_port, false)) - { - error(ERR_SLAVE_DEFINED, i18n("<qt>The Lisa daemon does not appear to be running.<p>" - "In order to use the LAN Browser the Lisa daemon must be " - "installed and activated by the system administrator.")); - return 0; - } - kdDebug(7101)<<"LANProtocol::lanReadDataFromServer() connected"<<endl; - - int receivedBytes(0); - char* receiveBuffer(0); - char tmpBuf[64*1024]; - int bytesRead(0); - do - { - fd_set tmpFDs; - FD_ZERO(&tmpFDs); - FD_SET(m_iSock,&tmpFDs); - timeval tv; - tv.tv_sec = 1; - tv.tv_usec = 0; - select(m_iSock+1,&tmpFDs,0,0,&tv); - if (FD_ISSET(m_iSock,&tmpFDs)) - { - bytesRead=read(tmpBuf,64*1024); - kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: read "<<bytesRead<<" bytes"<<endl; - - if (bytesRead>0) - { - char *newBuf=new char[receivedBytes+bytesRead]; - if (receiveBuffer!=0) memcpy(newBuf,receiveBuffer,receivedBytes); - memcpy(newBuf+receivedBytes,tmpBuf,bytesRead); - receivedBytes+=bytesRead; - if (receiveBuffer!=0) delete [] receiveBuffer; - receiveBuffer=newBuf; - } - } - } while (bytesRead>0); - closeDescriptor(); - if ((bytesRead<0) || (receivedBytes<4)) - { - delete [] receiveBuffer; - error(ERR_INTERNAL_SERVER,i18n("Received unexpected data from %1").arg(m_currentHost)); - return 0; - } - - UDSEntry entry; - - char *currentBuf=receiveBuffer; - int bytesLeft=receivedBytes; - //this should be large enough for a name - char tmpName[4*1024]; - //this should be large enough for the hostname - char tmpHostname[4*1024]; - while (bytesLeft>0) - { - int tmpIP=2; - tmpName[0]='\0'; - if ((memchr(currentBuf,0,bytesLeft)==0) || (memchr(currentBuf,int('\n'),bytesLeft)==0)) - { - delete [] receiveBuffer; - error(ERR_INTERNAL_SERVER,i18n("Received unexpected data from %1").arg(m_currentHost)); - return 0; - } - kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: processing "<<currentBuf; - //since we check for 0 and \n with memchr() we can be sure - //at this point that tmpBuf is correctly terminated - int length=strlen(currentBuf)+1; - if (length<(4*1024)) - sscanf(currentBuf,"%u %s\n",&tmpIP,tmpName); - else - { - kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: buffer overflow attempt detected, aborting"<<endl; - break; - } - - bytesLeft-=length; - currentBuf+=length; - if ((bytesLeft==0) && ((tmpIP==0) ||(tmpIP==1)) && (strstr(tmpName,"succeeded")!=0)) - { - kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: succeeded"<<endl; - } - else if (tmpIP!=2) - { - kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: listing host: "<<tmpName<<" with ip: "<<tmpIP<<endl; - UDSAtom atom; - - atom.m_uds = TDEIO::UDS_NAME; - if (m_shortHostnames) - { - if (inet_addr(tmpName)!=-1) - atom.m_str=tmpName; - else - { - sscanf(tmpName,"%[^.]",tmpHostname); - kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: Hostname of " << tmpName << " is " << tmpHostname << "\n"; - atom.m_str = tmpHostname; - } - } - else - atom.m_str = tmpName; - - entry.append( atom ); - atom.m_uds = TDEIO::UDS_SIZE; - atom.m_long = 1024; - entry.append(atom); - atom.m_uds = TDEIO::UDS_ACCESS; - atom.m_long = S_IRUSR | S_IRGRP | S_IROTH ; - //atom.m_long = S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH; - entry.append(atom); - atom.m_uds = TDEIO::UDS_FILE_TYPE; - atom.m_long = S_IFDIR; // it is always a directory - entry.append( atom ); - listEntry(entry,false); - } - } - - listEntry( entry, true ); // ready - delete [] receiveBuffer; - return 1; -} - -int LANProtocol::rlanReadDataFromServer() -{ - kdDebug(7101)<<"RLANProtocol::readDataFromServer"<<endl; - - int sockFD=socket(AF_LOCAL, SOCK_STREAM, 0); - sockaddr_un addr; - memset((char*)&addr,0,sizeof(addr)); - addr.sun_family=AF_LOCAL; - TQCString socketname="/tmp/resLisa-"; - - struct passwd *user = getpwuid( getuid() ); - if ( user ) - socketname+=user->pw_name; - else - //should never happen - socketname+="???"; - - strlcpy(addr.sun_path,socketname,sizeof(addr.sun_path)); - int result=::connect(sockFD,(sockaddr*)&addr, sizeof(addr)); - - kdDebug(7101)<<"readDataFromServer(): result: "<<result<<" name: "<<addr.sun_path<<" socket: "<<sockFD<<endl; - - if (result!=0) - { - ::close(sockFD); - TDEProcess proc; - proc<<"reslisa"; - - bool ok=proc.start(TDEProcess::DontCare); - if (!ok) - { - error( ERR_CANNOT_LAUNCH_PROCESS, "reslisa" ); - return 0; - } - //wait a moment - //reslisa starts tde-config, then does up to 64 - //name lookups and then starts to ping - //results won't be available before this is done - kdDebug(7101)<<"sleeping..."<<endl; - ::sleep(1); - kdDebug(7101)<<"sleeping again..."<<endl; - ::sleep(5); - kdDebug(7101)<<"woke up "<<endl; - sockFD=socket(AF_LOCAL, SOCK_STREAM, 0); - - memset((char*)&addr,0,sizeof(addr)); - addr.sun_family=AF_LOCAL; - strlcpy(addr.sun_path,socketname,sizeof(addr.sun_path)); - - kdDebug(7101)<<"connecting..."<<endl; - result=::connect(sockFD,(sockaddr*)&addr, sizeof(addr)); - kdDebug(7101)<<"readDataFromServer() after starting reslisa: result: "<<result<<" name: "<<addr.sun_path<<" socket: "<<sockFD<<endl; - if (result!=0) - { - error( ERR_CANNOT_OPEN_FOR_READING, socketname ); - return 0; - } - kdDebug(7101)<<"succeeded :-)"<<endl; - } - - int receivedBytes(0); - char* receiveBuffer(0); - char tmpBuf[64*1024]; - int bytesRead(0); - do - { - fd_set tmpFDs; - FD_ZERO(&tmpFDs); - FD_SET(sockFD,&tmpFDs); - timeval tv; - tv.tv_sec = 1; - tv.tv_usec = 0; - select(sockFD+1,&tmpFDs,0,0,&tv); - if (FD_ISSET(sockFD,&tmpFDs)) - { - bytesRead=::read(sockFD,tmpBuf,64*1024); - kdDebug(7101)<<"RLANProtocol::readDataFromServer: read "<<bytesRead<<" bytes"<<endl; - - if (bytesRead>0) - { - char *newBuf=new char[receivedBytes+bytesRead]; - if (receiveBuffer!=0) memcpy(newBuf,receiveBuffer,receivedBytes); - memcpy(newBuf+receivedBytes,tmpBuf,bytesRead); - receivedBytes+=bytesRead; - if (receiveBuffer!=0) delete [] receiveBuffer; - receiveBuffer=newBuf; - } - } - } while (bytesRead>0); - ::close(sockFD); - - - if ((bytesRead<0) || (receivedBytes<4)) - { - delete [] receiveBuffer; - error(ERR_CANNOT_OPEN_FOR_READING,socketname); - return 0; - } - - UDSEntry entry; - - char *currentBuf=receiveBuffer; - int bytesLeft=receivedBytes; - //this should be large enough for a name - char tmpName[4*1024]; - //this should be large enough for the hostname - char tmpHostname[4*1024]; - while (bytesLeft>0) - { - int tmpIP=2; - tmpName[0]='\0'; - if ((memchr(currentBuf,0,bytesLeft)==0) || (memchr(currentBuf,int('\n'),bytesLeft)==0)) - { - delete [] receiveBuffer; - error(ERR_INTERNAL_SERVER,i18n("Received unexpected data from %1").arg(socketname.data())); - return 0; - } - kdDebug(7101)<<"RLANProtocol::readDataFromServer: processing "<<currentBuf; - //since we check for 0 and \n with memchr() we can be sure - //at this point that tmpBuf is correctly terminated - int length=strlen(currentBuf)+1; - if (length<(4*1024)) - sscanf(currentBuf,"%u %s\n",&tmpIP,tmpName); - else - { - kdDebug(7101)<<"RLANProtocol::readDataFromServer: buffer overflow attempt detected, aborting"<<endl; - break; - } - - bytesLeft-=length; - currentBuf+=length; - if ((bytesLeft==0) && ((tmpIP==0) ||(tmpIP==1)) && (strstr(tmpName,"succeeded")!=0)) - { - kdDebug(7101)<<"RLANProtocol::readDataFromServer: succeeded"<<endl; - } - else if (tmpIP!=2) - { - kdDebug(7101)<<"RLANProtocol::readDataFromServer: listing host: "<<tmpName<<" with ip: "<<tmpIP<<endl; - UDSAtom atom; - - atom.m_uds = TDEIO::UDS_NAME; - if (m_shortHostnames) - { - if (inet_addr(tmpName)!=-1) - atom.m_str=tmpName; - else - { - sscanf(tmpName,"%[^.]",tmpHostname); - kdDebug(7101)<<"LANProtocol::lanReadDataFromServer: Hostname of " << tmpName << " is " << tmpHostname << "\n"; - atom.m_str = tmpHostname; - } - } - else - atom.m_str = tmpName; - entry.append( atom ); - atom.m_uds = TDEIO::UDS_SIZE; - atom.m_long = 1024; - entry.append(atom); - atom.m_uds = TDEIO::UDS_ACCESS; - atom.m_long = S_IRUSR | S_IRGRP | S_IROTH ; - //atom.m_long = S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH; - entry.append(atom); - atom.m_uds = TDEIO::UDS_FILE_TYPE; - atom.m_long = S_IFDIR; // it is always a directory - entry.append( atom ); - listEntry(entry,false); - } - } - - listEntry( entry, true ); // ready - delete [] receiveBuffer; - return 1; -} - -int LANProtocol::checkHost(const TQString& host) -{ - kdDebug(7101)<<"LAN::checkHost() "<<host<<endl; - - TQString hostUpper=host.upper(); - HostInfo* hostInfo=m_hostInfoCache[hostUpper]; - if (hostInfo!=0) - { - kdDebug(7101)<<"LAN::checkHost() getting from cache"<<endl; - //this entry is too old, we delete it ! - if ((time(0)-hostInfo->created)>m_maxAge) - { - kdDebug(7101)<<"LAN::checkHost() cache content too old, deleting it"<<endl; - m_hostInfoCache.remove(hostUpper); - hostInfo=0; - } - } - if (hostInfo==0) - { - hostInfo=new HostInfo; - in_addr ip; - - struct hostent *hp=gethostbyname(host.latin1()); - if (hp==0) - { - error( ERR_UNKNOWN_HOST, host.latin1() ); - delete hostInfo; - return 0; - } - memcpy(&ip, hp->h_addr, sizeof(ip)); - - for (int i=0; i<KIOLAN_MAX; i++) - { - int result(0); - if (m_protocolInfo[i].enabled==PORTSETTINGS_DISABLE) - result=0; - else if (m_protocolInfo[i].enabled==PORTSETTINGS_PROVIDE) - result=1; - else if (m_protocolInfo[i].enabled==PORTSETTINGS_CHECK) - result=checkPort(m_protocolInfo[i].ports,ip); - - //host not reachable - if (result==-1) - { - delete hostInfo; - hostInfo=0; - error( ERR_UNKNOWN_HOST, host.latin1() ); - return 0; - } - hostInfo->services[i]=result; - } - hostInfo->created=time(0); - m_hostInfoCache.insert(hostUpper,hostInfo); - } - //here hostInfo is always != 0 - if (hostInfo==0) - { - error( ERR_INTERNAL, "hostInfo==0" ); - return 0; - } - - UDSEntry entry; - for (int i=0; i<KIOLAN_MAX; i++) - { - if (hostInfo->services[i]==1) - { - kdDebug(7101)<<"LAN::checkHost(): Host ["<<hostUpper<<"] Service ["<<m_protocolInfo[i].name<<"]"<<endl; - UDSAtom atom; - // name - atom.m_uds = TDEIO::UDS_NAME; - atom.m_str = m_protocolInfo[i].name; - entry.append( atom ); - // size - atom.m_uds = TDEIO::UDS_SIZE; - atom.m_long = 1024; - entry.append(atom); - // access permissions - atom.m_uds = TDEIO::UDS_ACCESS; - atom.m_long = S_IRUSR | S_IRGRP | S_IROTH ; - //atom.m_long = S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH; - entry.append(atom); - // file type - atom.m_uds = TDEIO::UDS_FILE_TYPE; - if (strcmp(m_protocolInfo[i].name,"HTTP")==0) - { - // normal file -- if we called stat(2) on this, - // this flag would be set in the st_mode field of struct stat - atom.m_long=S_IFREG; - entry.append(atom); - - // also define the mime-type for this file - atom.m_uds = TDEIO::UDS_MIME_TYPE; - atom.m_str="text/html"; - entry.append( atom ); - } - else - { - // directory -- if we called stat(2) on this, then this - // flag would be set in the st_mode field of the struct stat - atom.m_long = S_IFDIR; // it is always a directory - entry.append(atom); - - // also set the mime-type - atom.m_uds = TDEIO::UDS_MIME_TYPE; - atom.m_str="inode/directory"; - entry.append( atom ); - } - listEntry(entry,false); - } - } - listEntry( entry, true ); // ready - return 1; -} - -// Check if a service is running on a host with IP address 'ip' -// by checking all the ports in '_ports', using a non-blocking connect. -// Right now -- assume if *any* of these ports are active, -// the service is active. -int LANProtocol::checkPort( TQValueVector<int>& _ports, in_addr ip ) -{ - int _port=0; - struct sockaddr_in to_scan; - - to_scan.sin_family = AF_INET; - to_scan.sin_addr = ip; - - for (TQValueVector<int>::iterator i= _ports.begin(); i != _ports.end(); i++) - { - _port=(*i); - kdDebug(7101)<<"LANProtocol::checkPort: "<<_port<<endl; - to_scan.sin_port = htons(_port); - // open a TCP socket - int mysocket = ::socket (AF_INET, SOCK_STREAM, IPPROTO_TCP); - if (mysocket< 0 ) - { - std::cerr << "LanProt::checkPort: Error while opening Socket" << std::endl; - ::close( mysocket ); - return 0; - } - //make the socket non blocking - long int options = O_NONBLOCK | ::fcntl(mysocket, F_GETFL); - if (::fcntl( mysocket, F_SETFL, options )!=0) - { - std::cerr << "LanProt::checkPort: Error making it nonblocking"<< std::endl; - ::close( mysocket ); - return 0; - } - int result=connect( mysocket, (struct sockaddr *) &to_scan, sizeof( to_scan )); - //it succeeded immediately - if (result==0) - { - std::cerr<<"LANProtocol::checkPort("<<_port<<") connect succeeded immediately"<<std::endl; - ::shutdown( mysocket, SHUT_RDWR ); - return 1; - } - //it failed - if ((result<0) && (errno!=EINPROGRESS)) - { - // errno was not EINPROGRESS, so there is some serious problem - ::shutdown( mysocket, SHUT_RDWR ); - // maybe some other port will work - continue; - } - // last errno was EINPROGRESS, so we should select() on socket - // and wait for the final verdict - timeval tv; - tv.tv_sec=5; - tv.tv_usec=0; - fd_set rSet, wSet; - FD_ZERO(&rSet); - FD_SET(mysocket,&rSet); - wSet=rSet; - //timeout or error - result=select(mysocket+1,&rSet,&wSet,0,&tv); - ::shutdown( mysocket, SHUT_RDWR ); - if (result==1) - return 1; - } - // gosh, no port worked - return 0; - -} - -void LANProtocol::setHost( const TQString& host, int port, const TQString& , const TQString& ) -{ - if (m_isLanIoslave) - { - m_currentHost=host; - if (port==0) - m_port=7741; - else - m_port=port; - kdDebug(7101)<<"LANProtocol::setHost: "<<m_currentHost<<endl; - } - else - { - if (!host.isEmpty()) - error(ERR_MALFORMED_URL,i18n("No hosts allowed in rlan:/ URL")); - } -} - -void LANProtocol::mimetype( const KURL& url) -{ - kdDebug(7101)<<"LANProtocol::mimetype -"<<url.prettyURL()<<"-"<<endl; - TQString path( TQFile::encodeName(url.path())); - TQStringList pathList=TQStringList::split( "/",path); - if ((pathList.count()==2) && (pathList[1].upper()=="HTTP")) - { - //kdDebug(7101)<<"LANProtocol::mimeType text/html"<<endl; - mimeType("text/html"); - } - else - { - mimeType("inode/directory"); - //kdDebug(7101)<<"LANProtocol::mimeType inode/directory"<<endl; - } - finished(); -} - -void LANProtocol::listDir( const KURL& _url) -{ - KURL url(_url); - TQString path( TQFile::encodeName(url.path())); - if (path.isEmpty()) - { - url.setPath("/"); - redirection(url); - finished(); - return; - } - if ((m_currentHost.isEmpty()) && (m_isLanIoslave)) - { - url.setHost(m_defaultLisaHost); - redirection(url); - finished(); - return; - } - kdDebug(7101)<<"LANProtocol::listDir: host: "<<m_currentHost<<" port: "<<m_port<<" path: "<<path<<endl; - TQStringList pathList=TQStringList::split("/", path); - kdDebug(7101)<<"parts are: "<<endl; - for (TQStringList::Iterator it=pathList.begin(); it !=pathList.end(); it++) - kdDebug(7101)<<"-"<<(*it)<<"-"<<endl; - if (pathList.count()>2) - { - kdDebug(7101)<<"LANProtocol::listDir: too deep path: "<<pathList.count()<<endl; - error(ERR_DOES_NOT_EXIST,_url.prettyURL()); - return; - } - int succeeded(0); - if (path=="/") - { - //get the stuff from the netland server - succeeded=readDataFromServer(); - } - else if (pathList.count()==1) - { - //check the ports and stuff - succeeded=checkHost(pathList[0]); - } - else - { - kdDebug(7101)<<"LANProtocol::listDir: trying to redirect"<<endl; - int isSupportedProtocol(0); - for (int i=0; i<KIOLAN_MAX; i++) - { - if (pathList[1].upper()==m_protocolInfo[i].name) - { - isSupportedProtocol=m_protocolInfo[i].enabled; - break; - } - } - if (isSupportedProtocol==PORTSETTINGS_DISABLE) - { - kdDebug(7101)<<"LANProtocol::listDir: protocol not enabled "<<endl; - error(ERR_DOES_NOT_EXIST,_url.prettyURL()); - return; - } - //redirect it - KURL newUrl(pathList[1]+"://"+pathList[0]); - redirection(newUrl); - succeeded=1; - } - if (succeeded) finished(); -} - -void LANProtocol::stat( const KURL & url) -{ - kdDebug(7101)<<"LANProtocol::stat: "<<endl; - UDSEntry entry; - UDSAtom atom; - - atom.m_uds = TDEIO::UDS_NAME; - atom.m_str = url.path(); - entry.append( atom ); - atom.m_uds = TDEIO::UDS_SIZE; - atom.m_long = 1024; - entry.append(atom); - - atom.m_uds = TDEIO::UDS_ACCESS; - atom.m_long = S_IRUSR | S_IRGRP | S_IROTH ; - //atom.m_long = S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH; - entry.append(atom); - - - TQString path( TQFile::encodeName(url.path())); - TQStringList pathList=TQStringList::split( "/",path); - if ((pathList.count()==2) && (pathList[1].upper()=="HTTP")) - { - atom.m_uds = TDEIO::UDS_FILE_TYPE; - atom.m_long=S_IFREG; - entry.append(atom); - atom.m_uds = TDEIO::UDS_MIME_TYPE; - atom.m_str="text/html"; - //kdDebug(7101)<<"LANProtocol::stat: http is reg file"<<endl; - entry.append( atom ); - } - else - { - atom.m_uds = TDEIO::UDS_FILE_TYPE; - atom.m_long = S_IFDIR; // it is always a directory - entry.append(atom); - atom.m_uds = TDEIO::UDS_MIME_TYPE; - atom.m_str="inode/directory"; - //kdDebug(7101)<<"LANProtocol::stat: is dir"<<endl; - entry.append( atom ); - } - - statEntry( entry ); - finished(); -} - -void LANProtocol::get(const KURL& url ) -{ - TQString path(TQFile::encodeName(url.path())); - - kdDebug(7101)<<"LANProtocol::get: "<<path<<endl; - TQStringList pathList=TQStringList::split("/", path); - kdDebug(7101)<<"parts are: "<<endl; - for (TQStringList::Iterator it=pathList.begin(); it !=pathList.end(); it++) - kdDebug(7101)<<"-"<<(*it)<<"-"<<endl; - if ((pathList.count()!=2) || (pathList[1].upper()!="HTTP")) - { - kdDebug(7101)<<"LANProtocol::get: invalid url: "<<pathList.count()<<endl; - error(ERR_DOES_NOT_EXIST,url.prettyURL()); - return; - } - KURL newUrl("http://"+pathList[0]); - redirection(newUrl); - finished(); - return; -} |