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í
×
eParkomat, startup z ČR, postoupil mezi finalisty evropského akcelerátoru ChallengeUp!
Robot na pivo mu otevřel dveře k opravdovému byznysu
Internet věcí: Propojený svět? Už se to blíží...
včera 16:24 | Nová verze

Byla vydána Mageia 5.1. Jedná se o první opravné vydání verze 5, jež vyšla v červnu loňského roku (zprávička). Uživatelům verze 5 nepřináší opravné vydání nic nového, samozřejmě pokud pravidelně aktualizují. Vydání obsahuje všechny aktualizace za posledního téměř půldruhého roku. Mageia 5.1 obsahuje LibreOffice 4.4.7, Linux 4.4.32, KDE4 4.14.5 nebo GNOME 3.14.3.

Ladislav Hagara | Komentářů: 0
včera 13:42 | Pozvánky

V Praze probíhá konference Internet a Technologie 16.2, volné pokračování jarní konference sdružení CZ.NIC. Konferenci lze sledovat online na YouTube. K dispozici je také archiv předchozích konferencí.

Ladislav Hagara | Komentářů: 0
2.12. 22:44 | Komunita

Joinup informuje, že Mnichov používá open source groupware Kolab. V srpnu byl dokončen dvouletý přechod na toto řešení. V provozu je asi 60 000 poštovních schránek. Nejenom Kolabu se věnoval Georg Greve ve své přednášce Open Source: the future for the European institutions (SlideShare) na konferenci DIGITEC 2016, jež proběhla v úterý 29. listopadu v Bruselu. Videozáznam přednášek z hlavního sálu je ke zhlédnutí na Livestreamu.

Ladislav Hagara | Komentářů: 18
2.12. 15:30 | Zajímavý projekt

Společnost Jolla oznámila v příspěvku Case study: Sailfish Watch na svém blogu, že naportovala Sailfish OS na chytré hodinky. Využila a inspirovala se otevřeným operačním systémem pro chytré hodinky AsteroidOS. Použita je knihovna libhybris. Ukázka ovládání hodinek na YouTube.

Ladislav Hagara | Komentářů: 8
2.12. 14:15 | Nová verze

Byla vydána verze 7.1.0 skriptovacího jazyka PHP používaného zejména k vývoji dynamických webových stránek. Jedná se o první stabilní verzi nejnovější větvě 7.1. Přehled novinek v dokumentaci. Podrobnosti v ChangeLogu. K dispozici je také příručka pro přechod z PHP 7.0.x na PHP 7.1.x.

Ladislav Hagara | Komentářů: 2
2.12. 12:55 | Nová verze

Google Chrome 55 byl prohlášen za stabilní. Nejnovější stabilní verze 55.0.2883.75 tohoto webového prohlížeče přináší řadu oprav a vylepšení (YouTube). Opraveno bylo také 36 bezpečnostních chyb. Mariusz Mlynski si například vydělal 22 500 dolarů za 3 nahlášené chyby (Universal XSS in Blink).

Ladislav Hagara | Komentářů: 4
2.12. 11:55 | Pozvánky

Máte rádi svobodný software a hardware nebo se o nich chcete něco dozvědět? Přijďte na 135. sraz spolku OpenAlt, který se bude konat ve čtvrtek 8. prosince od 18:00 v Radegastovně Perón (Stroupežnického 20, Praha 5). Sraz bude tentokrát tématický. Bude retro! K vidění budou přístroje jako Psion 5mx nebo Palm Z22. Ze svobodného hardwaru pak Openmoko nebo čtečka WikiReader. Přijďte se i vy pochlubit svými legendami, nebo alespoň na pivo. Moderní hardware má vstup samozřejmě také povolen.

xkucf03 | Komentářů: 0
2.12. 00:10 | Nová verze

Byla vydána verze 3.2 svobodného systému pro detekci a prevenci průniků a monitorování bezpečnosti počítačových sítí Suricata. Z novinek lze zmínit například podporu protokolů DNP3 a CIP/ENIP, vylepšenou podporu TLS a samozřejmě také aktualizovanou dokumentaci.

Ladislav Hagara | Komentářů: 0
1.12. 21:00 | Nová verze

Byla vydána beta verze Linux Mintu 18.1 s kódovým jménem Serena. Na blogu Linux Mintu jsou hned dvě oznámení. První o vydání Linux Mintu s prostředím MATE a druhé o vydání Linux Mintu s prostředím Cinnamon. Stejným způsobem jsou rozděleny také poznámky k vydání (MATE, Cinnamon) a přehled novinek s náhledy (MATE, Cinnamon). Linux Mint 18.1 bude podporován až do roku 2021.

Ladislav Hagara | Komentářů: 0
1.12. 16:42 | Nová verze

Byl vydán Devuan Jessie 1.0 Beta 2. Jedná se o druhou beta verzi forku Debianu bez systemd představeného v listopadu 2014 (zprávička). První beta verze byla vydána v dubnu letošního roku (zprávička). Jedna z posledních přednášek věnovaných Devuanu proběhla v listopadu na konferenci FSCONS 2016 (YouTube, pdf).

Ladislav Hagara | Komentářů: 0
Kolik máte dat ve svém domovském adresáři na svém primárním osobním počítači?
 (32%)
 (24%)
 (29%)
 (7%)
 (5%)
 (3%)
Celkem 767 hlasů
 Komentářů: 50, poslední 29.11. 15:50
Rozcestník
Reklama

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: 203×
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: 66
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.