• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            Prayer

            在一般中尋求卓越
            posts - 1256, comments - 190, trackbacks - 0, articles - 0
              C++博客 :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理
            其他的不管,只是關注一下alarm的用法,設定了msgrcv超時。


            環境是redhat9
            當把發送緩沖中寫入大于8位數據時 可以成功發送但只能收到8位信息

            代碼如下
            //定義
            struct msgbuf  //消息結構
            {
                    long mtype;
                    char mtext[100];
            }msgbuf;
                                                                                            


            //創建消息隊列
            void  creatque()
            {
                                                                                                                                                           
                    static int msg_que_id=-1;
                    struct sigaction action;
                    /*檢查是否存在的要創建的消息隊列,如果存在到 就刪除它*/
                    msg_que_id=msgget(BOOKING_KEY,0);
                    if(msg_que_id!=-1){
                            if(msgctl(msg_que_id,IPC_RMID,0)==-1){
                                    perror("remove old message");
                                    exit(1);
                            }
                    }
                    /*創建消息隊列*/
                    msg_que_id=msgget(BOOKING_KEY,IPC_CREAT|0666);
                    if(msg_que_id==-1){
                            perror("creat new message list");
                            exit(1);
                    }
                    /*忽略其它一些參數*/
                    action.sa_handler=SIG_IGN;
                    action.sa_flags=0;
                    sigemptyset(&action.sa_mask);
                    sigaction(SIGINT,&action,NULL);
                    sigaction(SIGQUIT,&action,NULL);
                    sigaction(SIGHUP,&action,NULL);
            }

            //發消息
            void control(char *c)
            {
                    int send_len;
                    int msg_que_id=-1;
                    struct msgbuf send_msg;
                    memset(send_msg.mtext,'\0',sizeof(send_msg.mtext));
                    send_len=sizeof(long)+sizeof(int);
                    msg_que_id=msgget(BOOKING_KEY,0);
                    if(msg_que_id==-1){
                            perror("get message list id");
                            exit(1);
                    }
                                                                                            
                                                                                            
                    if(!strncasecmp(c,"lk",2)){/*連接狀態信號*/
                            send_msg.mtype=httpd_stoped;
                            sprintf(send_msg.mtext,"linking");
                            if(msgsnd(msg_que_id,&send_msg,send_len,0)&lt;0){
                                    perror("send message");
                                    exit(1);
                            }
                    }
            }

            //接收消息
            void *other_key(void *data)
            {
                    int msg_que_id=-1;
                    int rece_len,send_len;
                    struct msgbuf rece_msg;
                    memset(rece_msg.mtext,'\0',sizeof(rece_msg.mtext));
                    send_len=sizeof(long)+sizeof(int);
                    msg_que_id=msgget(BOOKING_KEY,0);
                    if(msg_que_id==-1){
                            perror("get message list id");
                            exit(1);
                    }
                    while(1){
                            /*定時器定時LKTIMEOUTs來接收30s一次的連接狀態信號,*/
                            /*如果時間到而沒有接收到信號則判斷接收方關閉了監視端,服務器將中斷此次連接*/
                                                                                                                                                   
                            alarm(35);
                            rece_len=msgrcv(msg_que_id,&rece_msg,sizeof(msgbuf)-sizeof(long),(int)httpd_stoped,0);
                            if(rece_len&lt;0){
                                    perror("receive message");
                                    exit(1);
                            }
                            if(!strcmp(rece_msg.mtext,"linking")){
                                  alarm(0);
                            }
                            else if(!strcmp(rece_msg.mtext,"q")){
                                     if(msgsnd(msg_que_id,&rece_msg,send_len,0)&lt;0){/*把取出的結束信息再寫回去(因為一條信息只能被取一次)*/
                                             perror("send message");               /*而取出一次只能結束一個進程*/
                                             exit(1);
                                     }
                                     exit(1);
                            }
                                                                                                                                                   
                                                                                                                                                   
            }
            }

            Feedback

            # re: 我創建的消息隊列為什么最大只能接收到8位信息--只關注alarm的用法  回復  更多評論   

            2009-04-30 16:14 by 半島刀客
            在msgsnd的長度參數,最好不要用sizeof()...,請直接用定長試試
            久久精品日日躁夜夜躁欧美| 亚州日韩精品专区久久久| 久久夜色精品国产噜噜麻豆| 国产午夜免费高清久久影院| 国产亚洲欧美成人久久片 | 日韩亚洲欧美久久久www综合网 | 久久97久久97精品免视看| 色诱久久av| 久久伊人精品青青草原高清| 久久久久久久综合狠狠综合| 精品一区二区久久| 久久人人爽人人爽人人爽| 色综合久久中文综合网| 无码日韩人妻精品久久蜜桃| 久久国产成人| 久久久久久免费一区二区三区 | 99久久精品无码一区二区毛片| 久久精品国产清自在天天线 | 亚洲综合婷婷久久| 日韩久久久久久中文人妻| 欧美久久天天综合香蕉伊| 久久久久夜夜夜精品国产| 人妻无码αv中文字幕久久 | 久久99亚洲网美利坚合众国| 亚洲国产成人乱码精品女人久久久不卡| 精品久久久久久无码中文字幕一区| 亚洲欧美国产精品专区久久| 国产精品综合久久第一页| 久久国产乱子精品免费女| 精品久久久久久无码中文字幕一区| 亚洲中文字幕久久精品无码喷水 | 国产精品九九久久精品女同亚洲欧美日韩综合区 | 久久久久久精品免费看SSS| 久久乐国产精品亚洲综合| 亚洲午夜久久影院| 91秦先生久久久久久久| 久久久久国产精品| 久久精品成人| 日产久久强奸免费的看| 少妇久久久久久被弄到高潮 | 欧美一区二区三区久久综|