2009-07-25 14 views
1

基本的には、実行ループが1秒おきにアプリケーションに入りますが、同時に私は別のスレッドがlistenForPacketsメソッドをループしています。 broadcastMessageは、別のアクション方法が実行された場合にのみ開始されます。この質問の重要な部分は、リスナースレッドがメインスレッドから分離して実行されているときに、印刷コマンドを出力することがなく、私が定義したグローバル変数へのアクセスを許可していないように思われます。recvMessageインタフェースセクションと実装セクションobjective-C NSThreadはグローバル変数にアクセスできますか?

私のコードでは、メインループを実行するたびにGUIのUILabelを更新するように設定しています。アプリケーションが実行されているとき、私のラベルは空白のまま残り、変更されることはありません。私はGUIをダブルチェックし、すべてが正しくリンクされていて、私のラベルも正しくインスタンス化されています(私は、以下のコードでUILabelのインスタンスとして "label"という名前を使用します)。誰かが私のラベルが更新されている理由を知っていますか?物事のネットワーキングの面はうまくいきます。なぜなら、私はちょうどそのことを終え、すべてが「話しています」ということです。おそらく、これは私が知らない可変スコープの問題か、または別のスレッドがグローバル変数にアクセスすることを許されているかもしれません(例えば、以下で使用したもの(rcvMessage))?私はかなりマルチスレッドアプリケーションの新しいですが、実際にNSThread(コードの1行のみ)を使用して実装するのは難しいとは思いません。

グローバル変数

NSString *recvMessage; 

メイン実行ループ - ラベルにそれが実行ループ

​​

トーカ方法

-(void)broadcastMessage { // (NSString*)msg { 
    msg = @"From_Master"; 

    NSLog(@"broadcastMessage - Stage 1"); 
    mc_ttl = 15; // number of node hops the message is allowed to travel across the network 
    // define the port we will be using 
    mc_port = MYPORT; 

    // create a socket for sending to the multicast address 
    if ((sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) { 
     NSLog(@"ERROR: broadcastMessage - socket() failed"); 
     return; 
    } 

    memset(&mc_addr, 0, sizeof(mc_addr)); 
    mc_addr.sin_family  = AF_INET; 
    mc_addr.sin_addr.s_addr = inet_addr(GROUP_ADDRESS); 
    mc_addr.sin_port  = htons(MYPORT); 

    NSLog(@"broadcastMessage - Stage 2"); 

// set the TTL (time to live/hop count) for the send 
    if ((setsockopt(sock, IPPROTO_IP, IP_MULTICAST_TTL, &mc_ttl, sizeof(mc_ttl))) < 0) { 
     NSLog(@"ERROR: broadcastMessage - setsockopt() failed"); 
     return; 
    } 

    NSLog(@"broadcastMessage - Stage 3"); 

    // clear send buffer 
    memset(send_str, 0, sizeof(send_str)); 

    // convert the message to a C string to send 
    [msg getCString:send_str maxLength:MAX_LEN encoding:NSASCIIStringEncoding]; 

    //while (fgets(send_str, MAX_LEN, stdin)) { 
    NSLog(@"broadcastMessage - Stage 4"); 
    NSLog(@"Message ="); 
    printf(send_str); 

    // send string to multicast address 
    if ((sendto(sock, send_str, sizeof(send_str), 0, (struct sockaddr *)&mc_addr, sizeof(mc_addr))) < 0) { 
     NSLog(@"ERROR: broadcastMessage - sendto() sent incorrect number of bytes"); 
     //return; 
    } 
    NSLog(@"Sent Message -"); 
    printf(send_str); 
    NSLog(@"broadcastMessage - Stage 5"); 

    // clear send buffer 
    memset(send_str, 0, sizeof(send_str)); 
    NSLog(@"broadcastMessage - Stage 6 - Complete"); 
    close(sock); 
} 

リスナー・メソッド

を通過するたびに更新セクション
-(void)listenForPackets { 
    listeningFlag_on = 1; // allows reuse of the same socket 

    NSLog(@"listenForPackets - Stage 1"); 
    if ((listeningSock = socket(AF_INET, SOCK_DGRAM,IPPROTO_UDP)) < 0) { 
     NSLog(@"ERROR: listenForPackets - socket() failed"); 
     return; 
      // make the method return an int instead of void and use this statement to check for errors 
    } 

    NSLog(@"listenForPackets - Stage 2"); 

    // set reuse port to on to allow multiple binds per host 
    if ((setsockopt(listeningSock, SOL_SOCKET, SO_REUSEADDR, &listeningFlag_on, sizeof(listeningFlag_on))) < 0) { 
     NSLog(@"ERROR: listenForPackets - setsockopt() Reuse failed"); 
     return; 
      // make the method return an int instead of void and use this statement to check for errors 
    } 

    // construct a multicast address structure after erasing anything in the listeningmc_addr structure 
    memset(&listeningmc_addr, 0, sizeof(listeningmc_addr)); 
    listeningmc_addr.sin_family  = AF_INET; 
    listeningmc_addr.sin_addr.s_addr = htonl(INADDR_ANY); // different from sender 
    listeningmc_addr.sin_port  = htons(MYPORT); 

    // bind multicast address to socket 
    if ((bind(listeningSock, (struct sockaddr *)&listeningmc_addr, sizeof(listeningmc_addr))) < 0) { 
     NSLog(@"ERROR: listenForPackets - bind() failed"); 
     perror("Bind() -"); 
     return;       // make the method return an int instead of void and use this statement to check for errors 
    } 

    //********************************************************************************* 

    NSString *ipAddress = [[NSString alloc] initWithString:self.getIPAddress]; 
    const char *tmp = [ipAddress UTF8String]; 
    listeningMc_addr_str = tmp; 

    printf("%s\n", listeningMc_addr_str); 

    listeningMc_req.imr_multiaddr.s_addr = inet_addr(GROUP_ADDRESS); 
    listeningMc_req.imr_interface.s_addr = htonl(INADDR_ANY); 
    // send an ADD MEMBERSHIP message via setsockopt 
    if ((setsockopt(listeningSock, IPPROTO_IP, IP_ADD_MEMBERSHIP, &listeningMc_req, sizeof(listeningMc_req))) < 0) { 
     NSLog(@"ERROR: listenForPackets - setsockopt() failed"); 
     int err = errno; 
     NSLog(@"errno - %i", err); 
     NSLog(@"Error = %s", strerror(err)); 
     perror("ERROR"); 
     return;       // make the method return an int instead of void and use this statement to check for errors 
    } 

    NSLog(@"listenForPackets - Stage 3"); 
    for (;;) {   // loop forever 

     // clear the receive buffers & structs 
     memset(listeningRecv_str, 0, sizeof(listeningRecv_str)); 
     listeningFrom_len = sizeof(listeningFrom_addr); 
     memset(&listeningFrom_addr, 0, listeningFrom_len); 

     NSLog(@"Test #1 Complete"); 
     //msgStatus.text = @"Waiting..."; 

     // block waiting to receive a packet 
     listeningFrom_len = sizeof(listeningmc_addr); 
     if ((listeningRecv_len = recvfrom(listeningSock, listeningRecv_str, MAX_LEN, 0, (struct sockaddr*)&listeningmc_addr, &listeningFrom_len)) < 0) { 
      NSLog(@"ERROR: listenForPackets - recvfrom() failed"); 
      return;      // make the method return an int instead of void and use this statement to check for errors 
     } 
     NSLog(@"Test #2 Complete - Received a Message ="); 
     NSLog(@"listenForPackets - Stage 4"); 

     // listeningRecv_str 
    **tmpString = [[NSString alloc] initWithCString:listeningRecv_str encoding:NSASCIIStringEncoding]; 
      NSLog(@"Message Received ="); 
      NSLog(tmpString); 
      recvMessage = tmpString;** 
     //} 
     // received string 
     printf("Received %d bytes from %s: ", listeningRecv_len, inet_ntoa(listeningFrom_addr.sin_addr)); 
     printf("%s", listeningRecv_str); 
     //} 
    } 
    // send a DROP MEMBERSHIP message via setsockopt 
    if ((setsockopt(listeningSock, IPPROTO_IP, IP_DROP_MEMBERSHIP, (void*) &listeningMc_req, sizeof(listeningMc_req))) < 0) { 
     NSLog(@"ERROR: listenForPackets - setsockopt() drop membership failed"); 
     //return 1;       // make the method return an int instead of void and use this statement to check for errors 
    } 
    close(listeningSock); 
    NSLog(@"listenForPackets - Stage 5 - Complete"); 
} 
+0

この質問は、無関係なソケットコードをすべて取り除き、あなたの質問に関連する部分を投稿しただけで、人々が答えやすくなります。 – smorgan

答えて

4

はい、すべてのスレッドはグローバル変数にアクセスできます。変数を更新するたびに作成するNSStringをリークし、アクセス制御なしで2つのスレッドから同じメモリにアクセスしていますが、変数を防ぐことはできません更新されることから

ログメッセージが表示されない場合は、コードが実行されないという問題があります。そのため、変数は変更されません。この新しいスレッドを開始するはずのコードを見てください。

+0

ありがとうございました。可変アクセス制御とメモリリークを防止する方法について私が読むことができる記事や文書がありますか?私が見つけることができるNSThreadのドキュメントにはそれほど多くはありません。 –

+0

あなたのリークについてスレッド関連のものはありません。そのためには、http://developer.apple.com/documentation/Cocoa/Conceptual/MemoryMgmt/MemoryMgmt.htmlなど、Cocoaのメモリ管理の基本的なガイドが必要です。 – smorgan

0

また、UIコンポーネントを更新する場合、ラベルテキストやその他のGUI要素の値設定を行うには、performSelectorOnMainThreadメソッドを使用する必要があります。値はバックグラウンドスレッドから更新されません。

関連する問題