Compare commits
1 Commits
1113a21b2d
...
multi-proc
| Author | SHA1 | Date | |
|---|---|---|---|
| 4c441cde92 |
@@ -22,6 +22,8 @@ public:
|
|||||||
setFlagOff();
|
setFlagOff();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
guarder(guarder &g) : shmid(g.shmid) {}
|
||||||
|
|
||||||
void setFlagOff()
|
void setFlagOff()
|
||||||
{
|
{
|
||||||
setFlag(false);
|
setFlag(false);
|
||||||
|
|||||||
@@ -10,6 +10,7 @@
|
|||||||
#include "locations.h"
|
#include "locations.h"
|
||||||
#include "usermanager.h"
|
#include "usermanager.h"
|
||||||
#include "guarder.h"
|
#include "guarder.h"
|
||||||
|
#include "processManager.h"
|
||||||
|
|
||||||
#define MAXNAMESIZE 255
|
#define MAXNAMESIZE 255
|
||||||
#define SCAN_DONE_SIG SIGRTMIN
|
#define SCAN_DONE_SIG SIGRTMIN
|
||||||
@@ -86,6 +87,7 @@ int main()
|
|||||||
|
|
||||||
int size;
|
int size;
|
||||||
char *buffer = nullptr;
|
char *buffer = nullptr;
|
||||||
|
processManager pm;
|
||||||
|
|
||||||
while (read(p1[0], &size, sizeof(int)))
|
while (read(p1[0], &size, sizeof(int)))
|
||||||
{
|
{
|
||||||
@@ -94,12 +96,11 @@ int main()
|
|||||||
|
|
||||||
read(p1[0], buffer, size * sizeof(char));
|
read(p1[0], buffer, size * sizeof(char));
|
||||||
std::string name(buffer);
|
std::string name(buffer);
|
||||||
|
std::string cmd = std::string(SCAN_CMD_USR) + name;
|
||||||
|
|
||||||
std::cout << "Scan received for: " << name << std::endl;
|
std::cout << "Scan received for: " << name << std::endl;
|
||||||
|
|
||||||
guard.setFlagOn();
|
pm.runTask(name, cmd);
|
||||||
system((std::string(SCAN_CMD_USR) + name).data());
|
|
||||||
guard.setFlagOff();
|
|
||||||
|
|
||||||
kill(parent, SCAN_DONE_SIG);
|
kill(parent, SCAN_DONE_SIG);
|
||||||
|
|
||||||
|
|||||||
41
src/processManager.h
Normal file
41
src/processManager.h
Normal file
@@ -0,0 +1,41 @@
|
|||||||
|
#ifndef _PROCCESSMANAGER_H
|
||||||
|
#define _PROCCESSMANAGER_H
|
||||||
|
|
||||||
|
#include <map>
|
||||||
|
#include <string>
|
||||||
|
#include <unistd.h>
|
||||||
|
#include <sys/types.h>
|
||||||
|
#include "guarder.h"
|
||||||
|
#include "usermanager.h"
|
||||||
|
|
||||||
|
class processManager
|
||||||
|
{
|
||||||
|
private:
|
||||||
|
std::map<std::string, guarder> running;
|
||||||
|
|
||||||
|
bool getIdTag(std::string &id)
|
||||||
|
{
|
||||||
|
return running[id].isFlagOn();
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public:
|
||||||
|
|
||||||
|
void runTask(std::string &id, std::string &cmdCommand)
|
||||||
|
{
|
||||||
|
if (!getIdTag(id))
|
||||||
|
{
|
||||||
|
running[id].setFlagOn();
|
||||||
|
pid_t child = fork();
|
||||||
|
|
||||||
|
if (child == 0) // child
|
||||||
|
{
|
||||||
|
system(cmdCommand.c_str());
|
||||||
|
running[id].setFlagOff();
|
||||||
|
exit(EXIT_SUCCESS);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
#endif // _PROCCESSMANAGER_H
|
||||||
Reference in New Issue
Block a user