Я добавляю сообщения, которые хочу отправить на сервер, в очередь:
typedef struct StreamOutputQueue{
char message[513];
struct StreamOutputQueue * next;
} StreamOutputQueue;
Когда я получаю событие NSStreamEventHasSpaceAvailable, я отправляю первое сообщение в очереди, затем удаляю его, чтобы следующее сообщение было готово. Если очередь пуста, я устанавливаю флаг, чтобы можно было сразу отправить следующее сообщение, не добавляя его в очередь, поскольку поток должен быть готов, а очередь пуста.
Это код после получения события:
case NSStreamEventHasSpaceAvailable:
NSLog(@"Space Available!");
if (login_start) { //Login
range = [nick_field.text rangeOfString: @" "]; //Find space in nickname text
if (range.location != NSNotFound) { //Found so include only the text up to the space.
used_nick = [nick_field.text substringToIndex: range.location];
}else{ //Else include it all
used_nick = nick_field.text;
}
[irc_output_stream write:(const uint8_t *)[[NSString stringWithFormat:@"USER %@ * * :%@ \r\nNICK %@\r\n", used_nick, nick_field.text,used_nick,nil] UTF8String] maxLength:1024]; //Send USER and NICK IRC commands
login_start = NO; //Login done.
}else if (output_queue){ //Queue exists
printf("OUTPUT QUEUE HAS DATA - %s\n",output_queue->message);
[irc_output_stream write: (const uint8_t *)output_queue->message maxLength:512]; //Send message to server.
StreamOutputQueue * next = output_queue->next;
free(output_queue);
output_queue = next; //Queue pointer points to next node.
space_available = NO;
}else{
space_available = YES; //Nothing sent, space available for immediate data delivery to server.
}
break;
Логин работает нормально. После завершения входа в систему программа начинает использовать очередь для отправки сообщений, когда это необходимо.
Вот код, который добавляет данные в конец очереди:
- (void) appendToOutputQueue: (char *) message{
if (space_available) { //Space available with no queue so send the next one now.
printf("SPACE AVAILABLE NO QUEUE - %s",message);
[irc_output_stream write: (const uint8_t *)message maxLength:512];
space_available = NO; //Wait until space is available again
return; //Do not continue to add to queue
}
//Add to queue
StreamOutputQueue * new;
new = malloc(sizeof(*new)); //Allocate new node
new->next = NULL; //Next must be null to signify end
strcpy(new->message,message); //Copy message data
if (output_queue) { //If the queue exists add the node to the end
output_queue_end->next = new;
}else{ //Else make the queue start at this node
output_queue = new;
}
output_queue_end = new; //The end node is now this one
}
Проблема в том, что сервер не распознает данные, отправленные через очередь. Данные печатаются правильно при вызовах printf. Логин работает абсолютно нормально. Кажется, что каждый раз происходит сбой, если данные отправляются вне метода события, и происходит сбой в течение некоторого времени, когда он находится в методе события, когда сервер будет действовать так, как если бы он получил поврежденные данные.
Как это должно быть сделано?
Спасибо.