abclinuxu.cz AbcLinuxu.cz itbiz.cz ITBiz.cz HDmag.cz HDmag.cz abcprace.cz AbcPráce.cz
AbcLinuxu hledá autory!
Inzerujte na AbcPráce.cz od 950 Kč
Rozšířené hledání
×

    dnes 12:33 | Komunita

    Alex Ellis upozornil 15. března, že firma Docker se chystala zrušit bezplatný hosting open-source projektů na Docker Hubu. Po vlně odporu se představitelé firmy omluvili a posléze byl původní záměr odvolán.

    Fluttershy, yay! | Komentářů: 0
    dnes 07:00 | IT novinky

    Ve věku 94 let zemřel Gordon Moore, mj. spoluzakladatel společnosti Intel a autor Moorova zákona.

    Ladislav Hagara | Komentářů: 0
    včera 17:11 | Nová verze

    Mercurial (Wikipedie), software pro SCM (Source Code Management), byl vydán ve verzi 6.4. Přehled novinek v poznámkách k vydání. Ve dnech 5. až 7. dubna proběhne konference Mercurial Paris.

    Ladislav Hagara | Komentářů: 0
    včera 11:55 | IT novinky

    Byly rozdány Ceny Velkého bratra (Big Brother Awards) za rok 2022 pro největší slídily pořádané nevládní organizací Iuridicum Remedium. Dlouhodobý slídil: Microsoft. Firemní slídil: Seznam. Úřední slídil: Nejvyšší správní soud. Výrok Velkého bratra: Marian Jurečka. Pozitivní cena: NoLog.

    Ladislav Hagara | Komentářů: 10
    včera 11:11 | Zajímavý projekt

    Byla představena online vzdělávací platforma Ada Computer Science pro učitele, studenty a kohokoli, kdo se zajímá o informatiku. Stojí za ní Raspberry Pi Foundation a Univerzita v Cambridgi.

    Ladislav Hagara | Komentářů: 0
    včera 09:11 | Bezpečnostní upozornění

    GitHub má nový RSA SSH klíč. Předchozí soukromý klíč byl krátce vystaven na GitHubu.

    Ladislav Hagara | Komentářů: 0
    včera 08:55 | IT novinky

    Společnost Framework Computer představila (YouTube) nové modulární notebooky: Laptop 13 s Intel Core nebo AMD Ryzen a Laptop 16 (YouTube).

    Ladislav Hagara | Komentářů: 0
    23.3. 19:33 | Nová verze

    Bylo vydáno Ubuntu 20.04.6 LTS, tj. šesté opravné vydání Ubuntu 20.04 LTS s kódovým názvem Focal Fossa. Přehled novinek v poznámkách k vydání a v přehledu změn.

    Ladislav Hagara | Komentářů: 2
    23.3. 14:44 | IT novinky

    Připojit neznámý USB flash disk do počítače může být nebezpečné. Dokonce může jít i o život. Někdo rozeslal ekvádorským novinářům USB flash disky, které po připojení do počítače explodují [BBC, Twitter].

    Ladislav Hagara | Komentářů: 2
    23.3. 13:33 | Nová verze

    Byla vydána nová verze 7.4 open source virtualizační platformy Proxmox VE (Proxmox Virtual Environment, Wikipedie) založené na Debianu. Přehled novinek v poznámkách k vydání a v informačním videu.

    Ladislav Hagara | Komentářů: 0
    Používáte WSL (Windows Subsystem for Linux)?
     (74%)
     (12%)
     (4%)
     (10%)
    Celkem 318 hlasů
     Komentářů: 4, poslední včera 06:42
    Rozcestník


    Dotaz: Systemovy daemon pomoci select()

    tomes.io avatar 24.1.2014 17:41 tomes.io | skóre: 12 | blog: tomesh
    Systemovy daemon pomoci select()
    Přečteno: 231×
    Ahoj,

    mam za ukol napsat daemona v C jako takovou nahradu za syslog.

    Daemon přijímá data z pojmenované roury, zapisovat do tohoto souboru smí kdokoliv. Prvním parametrem daemona je název souboru, do kterého bude zapisovat události ve tvaru
    time caller: message
    A dale vytvorit knihovnu s funkcí pro zápis do této roury. dalším parametrem daemona je interval, ve kterém daemon zapisuje vlastní statistiku (počet obdržených zpráv) do syslogu.

    Daemon jsem napsal pomoci fce select(), ale nemuzu odstranit chybu, ktera spociva v ukonceni programu pote, co si precte prvni zpravu z roury a korektne ji zapise do zadaneho logu.

    V nasledujicim prubehu WHILE funkce select vrati hodnotu vetsi nez nula, jakoby dosla dalsi zprava, ale funkce read vrati nulu. Zajimalo by me, kde je chyba. Je to nekde v souboru s rourou, nebo v samotnem spatnem pouziti select ?

    Kod daemona:
    /*
     
    #define DEFAULT_INTERVAL 2
    #define SIZE 256
    
    char* get_current_time() {
    
        
            time_t current_time;
            char* c_time_string;
            int j;
            current_time = time(NULL); /* Obtain current time as seconds elapsed since the Epoch. */
     
            if (current_time == ((time_t)-1)) {
                
                    (void) fprintf(stderr, "Failure to compute the current time.");
                    exit(EXIT_FAILURE);
            }
                           
            c_time_string = ctime(¤t_time);  /* Convert to local time format. */
                                                   
            for ( j = 0; c_time_string[j] != '\n'; j++)  /*Get rid EOL*/
                                    ;                          
            c_time_string[j] = '\0';
     
            if (c_time_string == NULL) {
                
                    (void) fprintf(stderr, "Failure to convert the current time.");
                    exit(EXIT_FAILURE);
            }
            
            return c_time_string;   
    }
    
    void print_help() {
    
            printf("Programme must be run with with 2 arguments:\n"
                "argv[1] is a name of the file which the daemon wil be writting in\n"
                "argv[2] is an interval the daemon will be sending logs into syslog\n");
    }
    
    int main(int argc, char *argv[]) {
    
            if (argc != 3) {
        
                    print_help();
                    exit(1);
            }
            
            int c;
            while((c = getopt(argc, argv, "h")) != -1) {
    
                    switch (c) {
    
                    case 'h':
                            print_help();
                            break;
                            
                    case '?':
                            printf("try -h for help");
                            break;
                    default:
                        break;
                    }
    
            }
        
    
            FILE *fw;
            int fp;
            char buf[SIZE];
        char *linesep;
            int line, i, count; 
            buf[0] = '\0'; // in case there is nothing to read
            buf[SIZE] = '\0'; // guarentee a end-of-line
            fd_set readfds;
            struct timeval timeout;
            int r;
            int interval = atoi(argv[2]);
        openlog ("exampleprog", LOG_CONS | LOG_PID | LOG_NDELAY, LOG_LOCAL1);
            
        fprintf(stderr, "Daemonizing...\n");    
        //daemon(0,0);
    
        unlink("/tmp/pb173_syslog");
            mkfifo("/tmp/pb173_syslog", S_IWUSR | S_IRUSR | S_IRGRP | S_IROTH);
        
            fp = open("/tmp/pb173_syslog", O_RDONLY | O_NONBLOCK);
    
            if(fp == -1) {
            syslog (LOG_CRIT, "Could not open the pipe: %s\n", strerror(errno));
                    exit(1);
            }
    
        fw = fopen(argv[1], "a+");
    
            if(fw == NULL) {
            openlog ("exampleprog", LOG_CONS | LOG_PID | LOG_NDELAY, LOG_LOCAL1);
            syslog (LOG_CRIT, "Error openning logfile : %s\n", strerror(errno));
                    exit(1);
            }
    
            
            timeout.tv_sec = interval; 
            timeout.tv_usec = 0;
            count = 0;
           
        line = 0; 
        r = 0;
            while(1) {        
            FD_ZERO(&readfds);
            FD_SET(fp,&readfds);
                    r = select(fp+1, &readfds, NULL, NULL, &timeout);
            if (r == -1) {
                openlog ("daemon", LOG_CONS | LOG_PID | LOG_NDELAY, LOG_LOCAL1);
                syslog (LOG_CRIT, "Error openning logfile : %s\n", strerror(errno));
                close(fp);
                fclose(fw);
                exit(1);
            }
                if (r == 0) {
                timeout.tv_sec = interval;
                timeout.tv_usec = 0;
                setlogmask (LOG_UPTO (LOG_NOTICE));    
                            openlog ("daemon", LOG_CONS | LOG_PID | LOG_NDELAY, LOG_LOCAL1);
                            syslog (LOG_NOTICE, "Number of received messages: %d\n", count ); 
                            closelog ();        
            } else {
                line += (r = read(fp, buf+line, SIZE-line-1));
                if (r == 0) {
                    close(fp);
                    fclose(fw);
    
                    exit(EXIT_SUCCESS);
                }
                buf[line] = '\0';
    
                if (line && (linesep = strstr(buf, "\n"))) { 
                    *linesep = '\0';
                    char *caller;
                    int callerLength;
                    char *message;
                    caller = strtok(buf, "^");
                    callerLength = strlen(caller);
                    message = caller + callerLength + 1;
                    fprintf(fw, "%s %s: %s\n", get_current_time(), caller, message);
                    fflush(fw);
                    memmove(buf, linesep + 1, (line = strlen(linesep + 1)) + 1);                
                    count++;
                        }
                    }       
            }
            
            close(fp);
            fclose(fw);
    
            exit(EXIT_SUCCESS);
    }
    
    
    A kod funkce, ktera zapisuje do roury:
    
    int sl_log(const char *caller, const char* message) {
        
        int fp;
        fp = open("/tmp/pb173_syslog", O_WRONLY);
        char *msg;
    
        if (fp == -1) {
            perror("Could not open the pipe\n");
            exit(1);
        }
        
        asprintf(&msg, "%s^%s\n", caller, message);
        write(fp, msg, strlen(msg));
        free(msg);
        close(fp);
        return 0;
    } 
    

    Řešení dotazu:


    Odpovědi

    Josef Kufner avatar 25.1.2014 00:22 Josef Kufner | skóre: 70
    Rozbalit Rozbalit vše Re: Systemovy daemon pomoci select()
    Popisované chování odpovídá tomu, že rouru nezavíráš. Jakmile ti odesílatel zapíše do roury data a zavře ji, tak ji musí zavřít i příjemce. Pokud chce čekat na další data, musí ji znovu otevřít. Takže jakmile ti read vrátí nulu (konec souboru), tak rouru zavři a znovu otevři. Konec souboru je také důvod, proč select oznamuje aktivitu na filedeskriptoru.

    V praktické aplikaci pak raději použij unixový socket. Ten je narozdíl od rour na tento use-case stavěný.
    Hello world ! Segmentation fault (core dumped)
    tomes.io avatar 25.1.2014 17:59 tomes.io | skóre: 12 | blog: tomesh
    Rozbalit Rozbalit vše Re: Systemovy daemon pomoci select()
    Diky za vysvetleni, ted uz to pracuje jak ma.

    Založit nové vláknoNahoru

    Tiskni Sdílej: Linkuj Jaggni to Vybrali.sme.sk Google Del.icio.us Facebook

    ISSN 1214-1267   www.czech-server.cz
    © 1999-2015 Nitemedia s. r. o. Všechna práva vyhrazena.