X-Git-Url: http://git.ithinksw.org/ITFoundation.git/blobdiff_plain/14a301f7aa7b244c4831006cfc4cfa42185517a4..af1fcfcf8c78f03127d3929b49330cc191259487:/ITInetSocket.m diff --git a/ITInetSocket.m b/ITInetSocket.m index af5d8a2..b7441cb 100755 --- a/ITInetSocket.m +++ b/ITInetSocket.m @@ -30,7 +30,7 @@ ITServiceBrowserDelegate *bd = [[ITServiceBrowserDelegate alloc] initWithDelegate:d]; [browse setDelegate:bd]; - [browse searchForServicesOfType:[NSString stringWithFormat:@"._%@._tcp",type] inDomain:nil]; + [browse searchForServicesOfType:[NSString stringWithFormat:@"_%@._tcp.",type] inDomain:@""]; } -(id)initWithFD:(int)fd delegate:(id )d @@ -47,7 +47,9 @@ sarr = nil; bufs = 512; actionflag = dieflag = 0; + nc = 0; } + [self spinoffReadLoop]; return self; } @@ -65,6 +67,7 @@ sarr = nil; bufs = 512; actionflag = dieflag = 0; + nc = 1; } return self; } @@ -103,17 +106,26 @@ { NSEnumerator *e = [arr objectEnumerator]; NSData *d; - struct addrinfo *a; + struct addrinfo *a,*oa; ai = malloc(sizeof(struct addrinfo)); - a = ai; + ai_cur = ai; + oa = a = ai; + bzero(a,sizeof(struct addrinfo)); while (d = [e nextObject]) { struct sockaddr *s = (struct sockaddr*)[d bytes]; + bzero(a,sizeof(struct addrinfo)); a->ai_family = s->sa_family; a->ai_addr = s; a->ai_next = malloc(sizeof(struct addrinfo)); + oa = a; a = a->ai_next; } + free(a); + oa->ai_next = NULL; + NSLog(@"Sockaddr connecting...."); + [self dumpv6Addrinfo:ai]; + [self realDoConnection]; } } @@ -152,10 +164,10 @@ -(void)newDataAdded:(ITByteStream*)sender { - NSLog(@"writePipe got something"); - actionflag = 1; - NSLog(@"thread saw actionFlag"); } + +-(ITByteStream*)readPipe {return readPipe;} +-(ITByteStream*)writePipe {return writePipe;} @end @implementation ITInetSocket(Debugging) @@ -193,7 +205,7 @@ struct addrinfo hints; int err; const char *portNam = [namedPort cString], *hostCStr = [host cString]; - + state = ITInetSocketConnecting; hints.ai_flags = 0; hints.ai_family = PF_UNSPEC; hints.ai_socktype = SOCK_STREAM; @@ -213,7 +225,7 @@ -(void)realDoConnection { - sockfd = socket(ai_cur->ai_addr->sa_family,SOCK_STREAM,IPPROTO_TCP); + sockfd = socket(ai_cur->ai_family,SOCK_STREAM,IPPROTO_TCP); [self spinoffReadLoop]; } @@ -232,25 +244,28 @@ NSConnection *dcon = [[NSConnection alloc] initWithReceivePort:[data objectAtIndex:0] sendPort:[data objectAtIndex:1]]; NSProxy *dp = [[dcon rootProxy] retain]; char *buf = malloc(bufs); - unsigned long readLen = 0; + unsigned long readLen = 0,wpl = 0; signed int err; - [readPipe setDelegate:dp]; + [readPipe setDelegate:(id )dp]; + if (nc){ NSLog(@"Connecting"); err = connect(sockfd,ai_cur->ai_addr,ai_cur->ai_addrlen); if (err == -1) { perror("CAwh"); + *((char*)NULL) = 12; [(id)dp errorOccured:ITInetCouldNotConnect during:ITInetSocketConnecting onSocket:self]; goto dieaction; } + } NSLog(@"Sending finishedConnecting"); [(id)dp finishedConnecting:self]; lstart: - - while (!actionflag && !dieflag) + state = ITInetSocketListening; + while (!actionflag && !dieflag && !(wpl = CFDataGetLength((CFDataRef)writePipe->data))) { - NSData *d; readLen = recv(sockfd,buf,bufs,0); + state = ITInetSocketReading; if (readLen == -1) {[(id)dp errorOccured:ITInetConnectionDropped during:ITInetSocketReading onSocket:self];goto dieaction;} if (readLen) { NSLog(@"recv'd"); @@ -260,12 +275,13 @@ lstart: ap = [[NSAutoreleasePool alloc] init]; } } - + state = ITInetSocketListening; actionflag = 0; if (dieflag) { dieaction: + state = ITInetSocketDisconnected; perror("Awh"); free(buf); shutdown(sockfd,2); @@ -277,9 +293,13 @@ dieaction: } { - NSLog(@"Emptying writePipe"); - NSData *d = [writePipe readAllData]; - write(sockfd,[d bytes],[d length]); + const char *d = CFDataGetBytePtr((CFDataRef)writePipe->data); + state = ITInetSocketWriting; + NSLog(@"Writing"); + [writePipe lockStream]; + wpl = send(sockfd,d,wpl,0); + [writePipe shortenData:wpl]; + [writePipe unlockStream]; [ap release]; ap = [[NSAutoreleasePool alloc] init]; goto lstart;