| 467 | } |
| 468 | |
| 469 | int ParallelChannel::AddChannel(ChannelBase* sub_channel, |
| 470 | ChannelOwnership ownership, |
| 471 | CallMapper* call_mapper, |
| 472 | ResponseMerger* merger) { |
| 473 | if (NULL == sub_channel) { |
| 474 | LOG(ERROR) << "Param[sub_channel] is NULL"; |
| 475 | return -1; |
| 476 | } |
| 477 | if (_chans.capacity() == 0) { |
| 478 | _chans.reserve(32); |
| 479 | } |
| 480 | SubChan sc; |
| 481 | sc.chan = sub_channel; |
| 482 | sc.ownership = ownership; |
| 483 | sc.call_mapper = call_mapper; |
| 484 | sc.merger = merger; |
| 485 | _chans.push_back(sc); |
| 486 | return 0; |
| 487 | } |
| 488 | |
| 489 | int ParallelChannel::AddChannel(ChannelBase* sub_channel, |
| 490 | ChannelOwnership ownership, |