0

私の課題では、プロセスをフォークして、IPC を使用して Linux でヒューリスティック アルゴリズムを使用してプロセスを割り当てる分散オペレーティング システムをシミュレートする必要があります。

ここで、子をフォークnして、アルゴリズムをシミュレートします。問題は、それらすべての間のメッセージキュー接続にありますが、それは問題ではありません

2 つのメッセージ キューがUPありDOWN、どちらも動作していません。これらのキューのいずれかを介して何かを送信しようとするたびに、反対側でゴミとして受信されます。

したがって、この構造体とこれらのメソッドを使用して、メッセージ キューを処理します。

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/shm.h>
struct msgbuff
{
   long mtype;
   char mtext[70];
};

void Send(key_t msgqid,char* S,long pid)
{
  int send_val;
  struct msgbuff message;

  message.mtype = pid;      /* arbitrary value */
  strcpy(message.mtext,S);
  cout<<"Message is "<<message.mtext<<endl;
  //strcpy(message.mtext, str);
  cout<<getpid()<<" Entering Send process"<<endl;
  send_val = msgsnd (msgqid, &message, sizeof(message), IPC_NOWAIT);

  if(send_val == -1)
    perror("Error in send");

}

char* Recieve(key_t msgqid,bool nowait)
{
        int rec_val;
          struct msgbuff message;

          cout<<getpid()<<" Entering Receive process"<<endl;
          /* receive all types of messages */
          if(nowait)
  rec_val = msgrcv(msgqid, &message, sizeof(message), getpid(), IPC_NOWAIT);  
  else rec_val = msgrcv(msgqid, &message, sizeof(message), getpid(), !IPC_NOWAIT);  
  if(rec_val == -1){
//      perror("Error in receive");
    return "none";
}
  return message.mtext;
}

それから私はそのようにすべての子供にそれらを使用します

        DOWN = msgget(200, IPC_CREAT|0644);
        UP = msgget(201,IPC_CREAT|0644);

と

 while(1)
            {
                int countfail =0;
                char* ask =Recieve(DOWN,true); //nowait
                string asks(ask);
                cout<<getpid()<<" ask= "<<asks<<endl; //This here prints either garbage (symbols and other random characters) or "none"
                if(strcmp(ask,"none")!=0)
                {
                           ///////Logic for the algorithm
                    cout<<"*********"<<getpid()<<" In ASK "<<endl;
                    stringstream ss1;
                    ss1.str(ask);
                    int senderpid=0,processSize=0;
                    ss1>>processSize>>senderpid;
                    char* processRecMessage = new char[70];

                              ///setting up what will be sent to other process
                    if(count+ processSize <= load)
                    {
                        count+=processSize;
                        strcpy(processRecMessage,"Taken");

                    }
                    else
                    {
                        strcpy(processRecMessage,"Not Taken");
                    }

                           //Another Garbage here
                    Send(UP,processRecMessage,senderpid);



                }
                else{
                    int nextProcess = (rand()%3) +1;
                    if(count + nextProcess <=load)
                    {
                        count +=nextProcess;
                    }
                    else{

                        for(int k = 0;k<3;k++)
                        {
                            int selectedChild = rand()%n;
                            cout<<getpid()<<" Selected Child no "<<selectedChild+1<<" PID="<<children[selectedChild]<<endl;
                            char* x = new char[70];
                            stringstream ss;
                            ss<<nextProcess;
                            ss<<" "<<getpid();
                            strcpy(x,ss.str().c_str());// x= "nextProcess pid" 
                            cout<<x<<endl;
                 //// sending here also recieves garbage
                            Send (DOWN , x,children[selectedChild]);
                //// receiving  garbage
                            x= Recieve(UP,false);
                            cout<<getpid()<<" UP Value = "<<x<<endl;
                            if (strcmp(x,"Taken")==0){
                                cout<<"Process sent from "<<getpid()<<" to "<<children[selectedChild]<<endl;
                                break;
                            }
                            else
                            {
                                countfail++;
                                printf("TRAIL #%d failed\n",countfail);

                            }

                        }
                        if(countfail==3)
                        {
                            cout<<"Algorithm failed to allocate process.\n";
                            cout<<"Terminating Process "<<getpid()<<endl;
                            break;
                        }
                    }
                }
            }

誰かがこれで私を助けることができれば、私は感謝します

ps: プログラムの実行に失敗するたびにすべてのメッセージ キューを削除するので、メッセージ キューは新しく起動するたびに削除されますが、それでも使用されません。

edit : 完全なコードの追加

#include <iostream>
#include <fstream>
#include <string>
#include <algorithm>
#include <math.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <sys/shm.h>
#include <string.h>
#include <map>
#include <sstream>
#include <ctime>

using namespace std;


struct msgbuff
{
   long mtype;
   char mtext[70];
};


void Send(key_t msgqid,char* S,long pid)
{
  int send_val;
  struct msgbuff message;

  message.mtype = pid;      /* arbitrary value */
  strcpy(message.mtext,S);
  cout<<"Message is "<<message.mtext<<endl;
  //strcpy(message.mtext, str);
  cout<<getpid()<<" Entering Send process"<<endl;
  send_val = msgsnd (msgqid, &message, sizeof(message), IPC_NOWAIT);

  if(send_val == -1)
    perror("Errror in send");

}

char* Recieve(key_t msgqid,bool nowait)
{
        int rec_val;
          struct msgbuff message;

          cout<<getpid()<<" Entering Receive process"<<endl;
          /* receive all types of messages */
          if(nowait)
  rec_val = msgrcv(msgqid, &message, sizeof(message), getpid(), IPC_NOWAIT);  
  else rec_val = msgrcv(msgqid, &message, sizeof(message), getpid(), !IPC_NOWAIT);  
  if(rec_val == -1){
//      perror("Error in receive");
    return "none";
}
  return message.mtext;
}

int main()
{
    int n ;
    pid_t pid;
    key_t DOWN,UP;
    DOWN = msgget(200, IPC_CREAT|0644);//Creates new identifier
    UP = msgget(201,IPC_CREAT|0644);

        int shmid;
        shmid = shmget(50, 393216, IPC_CREAT|0644);
void *shmaddr;

  shmaddr = shmat(shmid, (void *)0, 0);
    printf("DOWN = %d\n", DOWN);
    printf("UP = %d\n", UP);
    cout<<"Please enter the number of machines "<<endl;
    cin>>n;
    int* children = new int[n];
    string pids;
    stringstream ss4;
    ss4<<n;
    string number = ss4.str();
    pids+=number;
    pids+=" ";
    for (int i=0;i<n;i++)
    {
         pid = fork();
         children[i]=pid;
         stringstream ss3;
         ss3<<pid;
         string pidstr=ss3.str();
         pids+=pidstr;
         pids+=" ";
        if (pid==0)
            break;
    }
    if (pid==-1) 
    cout<<"Error in fork" <<endl;

    else if (pid==0) // child 
    {
        sleep(1);
        DOWN = msgget(200, IPC_CREAT|0644);
        UP = msgget(201,IPC_CREAT|0644);
        //cout<<"Entering child process"<<endl;

        shmid = shmget(50, 393216, IPC_CREAT|0644);
        shmaddr = shmat(shmid, (void *)0, 0);
        char* pidsrec = new char[100];
        strcpy(pidsrec,(char*) shmaddr);
        stringstream sss;
        string spid(pidsrec);
        sss.str(spid);
        sss>>n;
        children = new int[n];
        for(int i =0;i<n;i++)
        {
            sss>>children[i];
            //cout<<getpid()<<"Child #"<<i<<" = "<<children[i]<<endl;
        }

        srand(getpid());
        int load = (rand()%10) +1;  // load of operating on this system from 1-10
        int count=0;
        while(1)
        {
            int countfail =0;
            char* ask =Recieve(DOWN,true); //nowait
            string asks(ask);
            cout<<getpid()<<" ask= "<<asks<<endl;
            if(strcmp(ask,"none")!=0)
            {
                cout<<"*********"<<getpid()<<" In ASK "<<endl;
                stringstream ss1;
                ss1.str(ask);
                int senderpid=0,processSize=0;
                ss1>>processSize>>senderpid;
                char* processRecMessage = new char[70];
                if(count+ processSize <= load)
                {
                    count+=processSize;
                    strcpy(processRecMessage,"Taken");

                }
                else
                {
                    strcpy(processRecMessage,"Not Taken");
                }
                Send(UP,processRecMessage,senderpid);



            }
            else{
                int nextProcess = (rand()%3) +1;
                if(count + nextProcess <=load)
                {
                    count +=nextProcess;
                }
                else{

                    for(int k = 0;k<3;k++)
                    {
                        int selectedChild = rand()%n;
                        cout<<getpid()<<" Selected Child no "<<selectedChild+1<<" PID="<<children[selectedChild]<<endl;
                        char* x = new char[70];
                        stringstream ss;
                        ss<<nextProcess;
                        ss<<" "<<getpid();
                        strcpy(x,ss.str().c_str());// x= "nextProcess pid" 
                        cout<<x<<endl;
                        Send (DOWN , x,children[selectedChild]);

                        x= Recieve(UP,false);
                        cout<<getpid()<<" UP Value = "<<x<<endl;
                        if (strcmp(x,"Taken")==0){
                            cout<<"Process sent from "<<getpid()<<" to "<<children[selectedChild]<<endl;
                            break;
                        }
                        else
                        {
                            countfail++;
                            printf("TRAIL #%d failed\n",countfail);

                        }

                    }
                    if(countfail==3)
                    {
                        cout<<"Algorithm failed to allocate process.\n";
                        cout<<"Terminating Process "<<getpid()<<endl;
                        break;
                    }
                }
            }
        }

    }
    else //parent
    {

    strcpy((char*) shmaddr,pids.c_str());
    }
    cout<<getpid()<<" GOODBYE"<<endl;
    return 0;
}

任意の数のプロセスで試してみると、メッセージキューの受信側で常にガベージが受信されます

4

1 に答える 1

1

あなたのReceive機能では、あなたがするとき

return message.mtext;

スタック上でローカルに割り当てられたデータへのポインターを返しています。スタックのこの領域は、関数が戻った後は有効ではないため、ポインターを逆参照すると、未定義の動作が発生します。また、別の関数を呼び出した後にこのポインタを使用すると、スタックのその領域はおそらく別の関数によって上書きされます。

C++ を使用しているので、なぜ返さないのstd::stringですか? この問題を解決します。

于 2013-04-23T08:18:12.100 に答える