2

私のサーバーは複数の client をサポートする必要があります。今のところ、 client を操作していると仮定しましょう2

サーバーは次のとおりです。

#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/stat.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <fcntl.h>
#include <sys/types.h>
#include <unistd.h>
#include <sys/fcntl.h>
#include <sys/stat.h>

#define FIFONAME "fifo_clientTOserver"
#define SHM_SIZE 1024  /* make it a 1K shared memory segment */
#define ROWS 10
#define COLS 10



void error(char* str)
{
    perror(str);
    exit(1);
}



int main(int argc, char *argv[])
{

    unlink(FIFONAME);               // remove any previous fifo pipes

    // create a FIFO named pipe - only if it's not already exists
    if(mkfifo(FIFONAME , 0666) < 0)
        error("mkfifo");

    /**
     * process 1
     */


    // open the fifo for reading

    int server_to_client = open(FIFONAME, O_RDONLY);
    int reading;

    while (1)
    {
        if (read(server_to_client, &reading ,sizeof(int)) < 0)
            perror("read");
        else
            break;
    }

    printf("Reading from the fifo : %d\n" , reading);
    if (close(server_to_client) < 0)
        error("close");

    // casting into pid_t
    pid_t pid = (pid_t)reading;

    // signal to the process that he's the first
    kill(pid, SIGUSR2);



    /**
     *  process 2
     */

    printf("Now waiting for process 2...\n");

    // doing it again - this time for the second process

    // remove any previous fifo pipes
    unlink(FIFONAME);

    // create a FIFO named pipe - only if it's not already exists
    if(mkfifo(FIFONAME , 0666) < 0)
        error("mkfifo");

    printf("Server tester1\n");

    server_to_client = open(FIFONAME, O_RDONLY);

    // grab the PID of process 2
    while (1)
    {
        if (read(server_to_client, &reading ,sizeof(int)) > 0)
            break;  // got the data
    }

    printf("Server tester2\n");

    printf("Reading from the fifo : %d\n" , reading);
    if (close(server_to_client) < 0)
        error("close");

    // casting into pid_t
    pid = (pid_t)reading;

    // signal to the process that he's the first
    kill(pid, SIGUSR2);




    return 0;

    }

問題は、両方のクライアントが PID を渡す必要があることです (これは父と息子の関係ではありません!!! これらは 2 つの別個のプロセスです)、サーバーSIGUSR2は最初のプロセスに、彼が最初に選択されたプロセスであることを通知します。その場合、そのプロセスは type の文字で機能しXます。

一方、2 番目のプロセスの場合は、タイプの文字を操作しYます。

クライアントは次のとおりです。

int static flagger = 0;
char process_char = 'a';

/**
 *  handler for SIGUSR2
 */
void my_handler(int signum)
{

    printf("foo bar\n");

    if (signum == SIGUSR2)
    {
        printf("Received SIGUSR2!\n");
        flagger++;
    }

    printf("flagger is :%d\n" , flagger);

    if (flagger == 1)
    {
        // then process works with "X"
            process_char = 'x';
            printf("I'm process 1, working with X char\n");
            // exit(1);
    }

    else if (flagger == 2)
    {
        process_char = 'Y';
        printf("I'm process 2 , working with Y char\n");
        // exit(1);
    }

}




void error(char* str)
{
    perror(str);
    exit(1);
}




int main(int argc, char *argv[])
{

    pid_t pid;

    /* get the process id */
    if ((pid = getpid()) < 0)
    {
        perror("unable to get pid");
    }
    else
    {
        printf("The process id is %d\n", pid);
    }

    int pidInt = (int)pid;      // convert the pid to int

    // write pid into the fifo

    int fd = open("fifo_clientTOserver",O_WRONLY);  // open the fifo for writing
    if(fd < 0)
    {
         perror("open");
         exit(1);
    }

    signal(SIGUSR2, my_handler);

    printf("Tester1\n");


    // writing the PID of the client into the pipe
    write(fd, &pidInt ,sizeof(int));

    close(fd);      // closing the pipe

    printf("Tester2\n");

    while(1)
    {
        printf("Waiting for the signal...\n");
        sleep(1);
    }


        // more code 

    }

信号 (1 番目または 2 番目)flaggerを区別するためにクライアント ( ) で static int 変数を使用しようとしましたが、各クライアントにとって staticは で始まり に達する新しい変数であるため、役に立ちません。SIGUSR2flagger01

プロセスが最初に受け取った時間と別のプロセスが受け取っSIGUSR2た2回目を区別するにはどうすればよいですか?SIGUSR2

4

1 に答える 1

4

データを渡す必要がある場合、シグナルは適切なメカニズムではありません。名前付きパイプなど、別の IPC メソッドの使用を検討してください。

于 2013-05-12T07:18:18.853 に答える