2009-07-23 16 views
0

私はかなり新しいCソケットですが、単純なsendto()とrecvfrom()呼び出しを行うだけで、マルチキャストソケットを使ってネットワーク上で文字列を取得する必要があります。いくつかのガイド(Beej'sを含む)を見て読んだ後、私は、マルチキャストソケット(私が必要とするもの)を介して送信されたメッセージを聞くという仕事をしている以下のコードを見つけました。プログラムはメインではうまく動作しますが、プロジェクトのどこかのメソッド(つまりlistenForPacketsというメソッド)に入れて、runloopの別のスレッドで実行しようとすると問題が発生します。しかし、デバッグ後、問題はメインメソッドのargv [1]に割り当てられた変数 "mc_addr_str"になります。objective-C文字列エンコーディングの問題

#include <sys/types.h> // for type definitions 
#include <sys/socket.h> // for socket API calls 
#include <netinet/in.h> // for address structs 
#include <arpa/inet.h> // for sockaddr_in 
#include <stdio.h>  // for printf() and fprintf() 
#include <stdlib.h>  // for atoi() 
#include <string.h>  // for strlen() 
#include <unistd.h>  // for close() 

#define MAX_LEN 1024 // maximum receive string size 
#define MIN_PORT 1024 // minimum port allowed 
#define MAX_PORT 65535 // maximum port allowed 

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

    int sock;      // socket descriptor 
    int flag_on = 1;    // socket option flag 
    struct sockaddr_in mc_addr; // socket address structure 
    char recv_str[MAX_LEN+1];  // buffer to receive string 
    int recv_len;     // length of string received 
    struct ip_mreq mc_req;  // multicast request structure 
    char* mc_addr_str;   // multicast IP address 
    unsigned short mc_port;  // multicast port 
    struct sockaddr_in from_addr; // packet source 
    unsigned int from_len;  // source addr length 

    // validate number of arguments 
    if (argc != 3) { 
     fprintf(stderr, 
       "Usage: %s <Multicast IP> <Multicast Port>\n", 
       argv[0]); 
     exit(1); 
    } 

    mc_addr_str = argv[1];  // arg 1: multicast ip address 
    mc_port = atoi(argv[2]); // arg 2: multicast port number 

    // validate the port range 
    if ((mc_port < MIN_PORT) || (mc_port > MAX_PORT)) { 
     fprintf(stderr, "Invalid port number argument %d.\n", 
       mc_port); 
     fprintf(stderr, "Valid range is between %d and %d.\n", 
       MIN_PORT, MAX_PORT); 
     exit(1); 
    } 

    // create socket to join multicast group on 
    if ((sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) { 
     perror("socket() failed"); 
     exit(1); 
    } 

    // set reuse port to on to allow multiple binds per host 
    if ((setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &flag_on, sizeof(flag_on))) < 0) { 
     perror("setsockopt() failed"); 
     exit(1); 
    } 

    // construct a multicast address structure 
    memset(&mc_addr, 0, sizeof(mc_addr)); 
    mc_addr.sin_family  = AF_INET; 
    mc_addr.sin_addr.s_addr = htonl(INADDR_ANY); 
    mc_addr.sin_port  = htons(mc_port); 

    // bind multicast address to socket 
    if ((bind(sock, (struct sockaddr *) &mc_addr, sizeof(mc_addr))) < 0) { 
     perror("bind() failed"); 
     exit(1); 
    } 

    // construct an IGMP join request structure 
    mc_req.imr_multiaddr.s_addr = inet_addr(mc_addr_str); 
    mc_req.imr_interface.s_addr = htonl(INADDR_ANY); 

    // send an ADD MEMBERSHIP message via setsockopt 
    if ((setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, (void*) &mc_req, sizeof(mc_req))) < 0) { 
     perror("setsockopt() failed"); 
     exit(1); 
    } 

    for (;;) {   // loop forever 

     // clear the receive buffers & structs 
     memset(recv_str, 0, sizeof(recv_str)); 
     from_len = sizeof(from_addr); 
     memset(&from_addr, 0, from_len); 

     // block waiting to receive a packet 
     if ((recv_len = recvfrom(sock, recv_str, MAX_LEN, 0, (struct sockaddr*)&from_addr, &from_len)) < 0) { 
      perror("recvfrom() failed"); 
      exit(1); 
     } 

     // output received string 
     printf("Received %d bytes from %s: ", recv_len, inet_ntoa(from_addr.sin_addr)); 
     printf("%s", recv_str); 
    } 

    // send a DROP MEMBERSHIP message via setsockopt 
    if ((setsockopt(sock, IPPROTO_IP, IP_DROP_MEMBERSHIP, (void*) &mc_req, sizeof(mc_req))) < 0) { 
     perror("setsockopt() failed"); 
     exit(1); 
    } 

    close(sock); 
} 

今、別のSOメンバーからの助けを経て、私はまた、私のプログラムの他の場所でそれを使用しています(NSStringのように私にIPアドレスを返しますメソッドを持っているので、私はそれがNSStringのを返して維持する必要があります)。私は私がこれまで持っているどのようなシンプルで小さな変換

mc_addr_str = (someConversion)getIPAddress; 

を単に行うことができると思った

-(NSString *)getIPAddress { 
    NSString *address = @"error"; 
    struct ifaddrs *interfaces; // = NULL; 
    struct ifaddrs *temp_addr; // = NULL; 
    int success = 0; 

    // retrieve the current interfaces - returns 0 on success 
    success = getifaddrs(&interfaces); 
    if (success == 0) 
    { 
     // Loop through linked list of interfaces 
     temp_addr = interfaces; 
     while(temp_addr != NULL) 
     { 
      if(temp_addr->ifa_addr->sa_family == AF_INET) 
      { 
       // Check if interface is en0 which is the wifi connection on the iPhone 
       if([[NSString stringWithUTF8String:temp_addr->ifa_name] isEqualToString:@"en0"]) 
       { 
        // Get NSString from C String 
        address = [NSString stringWithUTF8String:inet_ntoa(((struct sockaddr_in *)temp_addr->ifa_addr)->sin_addr)]; 
       } 
      } 
      temp_addr = temp_addr->ifa_next; 
     } 
    } 

    // Free memory 
    freeifaddrs(interfaces); 
    return address; 
} 

は次のとおりです。

NSString *ipAddress = [[NSString alloc] initWithString:self.getIPAddress]; 

mc_addr_str = [ipAddress cStringUsingEncoding:[NSString defaultCStringEncoding]]; 

私はこれを行うと、プログラムはのsetsockoptにしますエラーコード-1で失敗します(これは、プログラムに何らかの悪い事態が発生したことを知らせる一般的なエラーコードだと思いますが、中止する必要があります)。また、前のステートメントでmc_addr_strを割り当てると、私は得る

warning: assignment discards qualifiers from pointer target type 

私の問題がどこから発生しているのか分かりません。 mc_addr_strへの代入中にキャストエラーが発生するか、間違ったエンコーディングを使用しましたか?すべての入力をいただければ幸いです!

+0

** NSString **は*不変*文字列です。コンパイラは、変換の結果を** char ***に代入していて、その** char ***が指す文字列を有効に変更できるため、不平を言っています。警告を消すには、mc_addr_strを** const char ***と宣言する必要があります。 – Inshallah

+0

また、試してみてください:mc_add_str = [ipAddress UTF8String] – Inshallah

+0

私はまだsetsockoptメソッド呼び出しでエラーが発生しています...私はエラーが正確に何かを見つけることができますか? –

答えて

1

getIPAddresss()から取得するアドレスは、マルチキャストグループではなく、インターフェイスのアドレスです。あなたの例ではアドレスがどのように使われているのですか?問題を見つけることができますか?

// construct an IGMP join request structure 
mc_req.imr_multiaddr.s_addr = inet_addr(mc_addr_str); 
mc_req.imr_interface.s_addr = htonl(INADDR_ANY) 

あなたは、インターフェイスアドレスを保持しているmc_addr_strのアドレス、マルチキャストアドレスを設定します。それは正しいとは思わない? ;)

は、ここにあなたが何をすべきかです:224.0.0.0〜239.255.255.255から

// construct an IGMP join request structure 
mc_req.imr_multiaddr.s_addr = inet_addr("225.0.0.37"); 
mc_req.imr_interface.s_addr = inet_addr(mc_addr_str); 

アドレス範囲は、マルチキャストアドレス用に予約されています。 224.0.0.0〜224.0.0.255はマルチキャストルーティング情報のために予約されているため使用しないでください。他のアドレスを使用すると、setsockopt()はあなたの例のように失敗します。

1

cStringUsingEncodingconst char *を返し、mc_add_strはchar *です。コンパイラが警告を発行している理由です。

+0

あなたは何を言っているのか分かりませんが、私は混乱しています。これは私が欲しいものではありませんか? [ipAddress UTF8String]を指すようにchar型のポインタを宣言します。これはchar *を返すでしょう...したがって、私のcharポインタはcharデータ型を指しています??? –

+0

@Josh Bradley:** const char ***! ** const **を忘れないでください。それはあなたにエラーを与えるものです。上記の私のコメントを参照してください、それはより詳細に説明します。 – Inshallah

+0

ああ、それを持っています。申し訳ありませんが、私はそれを見ませんでした。これにより、警告エラーが修正されました。これでメンバーシップを追加しているときにsetsockoptがなぜ失敗しているのか分かります。 –

関連する問題