- case TASK_EVENT_CONNECTED:
- case TASK_EVENT_CONNECTED_TCP:
- case TASK_CONSUMER_REQ_DISCOVER:
- {
- NSConsumerDiscoveryTaskProcessing(task);
- break;
- }
- case TASK_CONSUMER_REQ_SUBSCRIBE:
- case TASK_SEND_SYNCINFO:
- {
- NSConsumerCommunicationTaskProcessing(task);
- break;
- }
- case TASK_CONSUMER_REQ_SUBSCRIBE_CANCEL:
- {
- NSProvider_internal * data = NSCopyProvider((NSProvider_internal *)task->taskData);
- NS_VERIFY_NOT_NULL_V(data);
- NSTask * conTask = NSMakeTask(TASK_CONSUMER_REQ_SUBSCRIBE_CANCEL, data);
- NS_VERIFY_NOT_NULL_V(conTask);
- NSConsumerCommunicationTaskProcessing(task);
- NSConsumerInternalTaskProcessing(conTask);
- break;
- }
- case TASK_RECV_SYNCINFO:
- case TASK_CONSUMER_RECV_MESSAGE:
- case TASK_CONSUMER_PROVIDER_DISCOVERED:
- case TASK_CONSUMER_RECV_SUBSCRIBE_CONFIRMED:
- case TASK_MAKE_SYNCINFO:
- {
- NSConsumerInternalTaskProcessing(task);
- break;
- }
- default:
- NS_LOG(ERROR, "Unknown type of task");
- break;
+ case TASK_EVENT_CONNECTED:
+ case TASK_EVENT_CONNECTED_TCP:
+ case TASK_CONSUMER_REQ_DISCOVER:
+ {
+ NSConsumerDiscoveryTaskProcessing(task);
+ break;
+ }
+ case TASK_CONSUMER_REQ_SUBSCRIBE:
+ case TASK_SEND_SYNCINFO:
+ {
+ NSConsumerCommunicationTaskProcessing(task);
+ break;
+ }
+ case TASK_CONSUMER_REQ_SUBSCRIBE_CANCEL:
+ {
+ NSProvider_internal * data = NSCopyProvider((NSProvider_internal *)task->taskData);
+ NS_VERIFY_NOT_NULL_V(data);
+ NSTask * conTask = NSMakeTask(TASK_CONSUMER_REQ_SUBSCRIBE_CANCEL, data);
+ NS_VERIFY_NOT_NULL_V(conTask);
+ NSConsumerCommunicationTaskProcessing(task);
+ NSConsumerInternalTaskProcessing(conTask);
+ break;
+ }
+ case TASK_RECV_SYNCINFO:
+ case TASK_CONSUMER_RECV_MESSAGE:
+ case TASK_CONSUMER_PROVIDER_DISCOVERED:
+ case TASK_CONSUMER_RECV_SUBSCRIBE_CONFIRMED:
+ case TASK_MAKE_SYNCINFO:
+ {
+ NSConsumerInternalTaskProcessing(task);
+ break;
+ }
+ default:
+ {
+ NS_LOG(ERROR, "Unknown type of task");
+ break;
+ }