src/thread_ipc_send.cpp

   1 ///////////////////////////////////////////////////////////////////////////////
   2 // Simple x264 Launcher
   3 // Copyright (C) 2004-2016 LoRd_MuldeR <MuldeR2@GMX.de>
   4 //
   5 // This program is free software; you can redistribute it and/or modify
   6 // it under the terms of the GNU General Public License as published by
   7 // the Free Software Foundation; either version 2 of the License, or
   8 // (at your option) any later version, but always including the *additional*
   9 // restrictions defined in the "License.txt" file.
  10 //
  11 // This program is distributed in the hope that it will be useful,
  12 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  13 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14 // GNU General Public License for more details.
  15 //
  16 // You should have received a copy of the GNU General Public License along
  17 // with this program; if not, write to the Free Software Foundation, Inc.,
  18 // 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  19 //
  20 // http://www.gnu.org/licenses/gpl-2.0.txt
  21 ///////////////////////////////////////////////////////////////////////////////
  22
  23 #include "thread_ipc_send.h"
  24
  25 //Internal
  26 #include "Global.h"
  27 #include "cli.h"
  28 #include "ipc.h"
  29
  30 //MUtils
  31 #include <MUtils/Global.h>
  32 #include <MUtils/IPCChannel.h>
  33 #include <MUtils/OSSupport.h>
  34
  35 //Qt
  36 #include <QStringList>
  37 #include <QApplication>
  38 #include <QFileInfo>
  39 #include <QDir>
  40
  41 //CRT
  42 #include <limits.h>
  43
  44 ////////////////////////////////////////////////////////////
  45 // Constructor
  46 ////////////////////////////////////////////////////////////
  47
  48 IPCThread_Send::IPCThread_Send(MUtils::IPCChannel *const ipcChannel)
  49 :
  50         m_ipcChannel(ipcChannel)
  51 {
  52 }
  53
  54 IPCThread_Send::~IPCThread_Send(void)
  55 {
  56 }
  57
  58 void IPCThread_Send::run()
  59 {
  60         setTerminationEnabled(true);
  61         bool bSentFiles = false;
  62         const MUtils::OS::ArgumentMap &args = MUtils::OS::arguments();
  63
  64         quint32 flags = 0;
  65         bool commandSent = false;
  66
  67         //Handle flags
  68         if(args.contains(CLI_PARAM_FORCE_START))
  69         {
  70                 flags = ((flags | IPC_FLAG_FORCE_START) & (~IPC_FLAG_FORCE_ENQUEUE));
  71         }
  72         if(args.contains(CLI_PARAM_FORCE_ENQUEUE))
  73         {
  74                 flags = ((flags | IPC_FLAG_FORCE_ENQUEUE) & (~IPC_FLAG_FORCE_START));
  75         }
  76
  77         //Process all command-line arguments
  78         if(args.contains(CLI_PARAM_ADD_FILE))
  79         {
  80                 foreach(const QString &fileName, args.values(CLI_PARAM_ADD_FILE))
  81                 {
  82                         if(!m_ipcChannel->send(IPC_OPCODE_ADD_FILE, flags, QStringList() << fileName))
  83                         {
  84                                 qWarning("Failed to send IPC message!");
  85                         }
  86                         commandSent = true;
  87                 }
  88         }
  89         if(args.contains(CLI_PARAM_ADD_JOB))
  90         {
  91                 foreach(const QString &options, args.values(CLI_PARAM_ADD_JOB))
  92                 {
  93                         const QStringList optionValues = options.split('|', QString::SkipEmptyParts);
  94                         if(optionValues.count() == 3)
  95                         {
  96                                 if(!m_ipcChannel->send(IPC_OPCODE_ADD_JOB, flags, optionValues))
  97                                 {
  98                                         qWarning("Failed to send IPC message!");
  99                                 }
 100                         }
 101                         else
 102                         {
 103                                 qWarning("Invalid number of arguments for parameter \"--%s\" detected!", CLI_PARAM_ADD_JOB);
 104                         }
 105                         commandSent = true;
 106                 }
 107         }
 108
 109         //If no argument has been sent yet, send a ping!
 110         if(!commandSent)
 111         {
 112                 if(!m_ipcChannel->send(IPC_OPCODE_PING, 0, QStringList()))
 113                 {
 114                         qWarning("Failed to send IPC message!");
 115                 }
 116         }
 117 }
 118
 119 ////////////////////////////////////////////////////////////
 120 // EVENTS
 121 ////////////////////////////////////////////////////////////
 122
 123 /*NONE*/