CFStream IOSソケット通信

Question

CFStreamバッファをクリアするには？ ソケットから読み込むたびに、古いリクエストのデータが残っています。これは、古いリクエストに対する完全な応答です。

私に何か不足していますか？

これは私が接続を初期化するために使用する機能です。

-(void)openSocketConnection:(UInt32)port: (NSString *)host 
{ 
    NSString *hoststring = [[NSString alloc] initWithString:host]; 
    CFStreamCreatePairWithSocketToHost(kCFAllocatorDefault,(__bridge CFStringRef)hoststring , 
port,&_nnet_readStream,&_nnet_writeStream); 

CFWriteStreamCanAcceptBytes(_nnet_writeStream); 

CFWriteStreamSetProperty(_nnet_writeStream, kCFStreamPropertyShouldCloseNativeSocket, kCFBooleanTrue); 

CFReadStreamSetProperty(_nnet_readStream, kCFStreamPropertyShouldCloseNativeSocket, kCFBooleanTrue); 

    if(!CFWriteStreamOpen(_nnet_writeStream)) { 
     NSLog(@"Error Opening Write Socket"); 
    } 
    if(!CFReadStreamOpen(_nnet_readStream)) { 
     NSLog(@"Error Opening Write Socket"); 
    } 

} 

これは私がソケットからデータを読み取るために使用する機能です。

BOOL done = NO; 
NSMutableString* result = [NSMutableString string]; 
while (!done) 
{ 
     if (CFReadStreamHasBytesAvailable(_nnet_readStream)) 
     { 
      UInt8 buf[1024]; 
      CFIndex bytesRead = CFReadStreamRead(_nnet_readStream, buf, 1024); 
      if (bytesRead < 0) 
      { 
       CFStreamError error = CFReadStreamGetError(_nnet_readStream); 
       NSLog(@"%@",error); 
      } else if (bytesRead == 0) 
      { 
       if (CFReadStreamGetStatus(_nnet_readStream) == kCFStreamStatusAtEnd) 
       { 
        done = YES; 
       } 
      } else 
      { 
       [result appendString:[[NSString alloc] initWithBytes:buf length:bytesRead encoding:NSUTF8StringEncoding]]; 
      } 
     } else 
     { 
      done = YES; 
     } 
} 

Answer 1

あなたがデータを取得するときにすることを前提としているように見えますもう片方のホストからは、常に一度に利用できるようになります。

私は基礎となるプロトコルが何であるか分かりませんが、一般的にリモートエンドが1600バイトを送信し、1500バイトを送信することは完全に可能ですが、数ミリ秒待たなければなりません秒）を次の100バイトに渡します。一方、CFReadStreamHasBytesAvailableはfalseを返すので、サーバーが送信したすべてのデータを読み取っていなくても、コードは完了フラグを設定します。