equal
deleted
inserted
replaced
542 Bundle* response = new Bundle(); |
542 Bundle* response = new Bundle(); |
543 BPQResponse::create_bpq_response(response, |
543 BPQResponse::create_bpq_response(response, |
544 bundle, |
544 bundle, |
545 current_bundle, |
545 current_bundle, |
546 local_eid_); |
546 local_eid_); |
547 |
|
548 BPQBlock foo(response); |
|
549 ASSERT ( foo.kind() == BPQBlock::KIND_RESPONSE ); |
|
550 |
547 |
551 BundleReceivedEvent e(response, EVENTSRC_CACHE); |
548 BundleReceivedEvent e(response, EVENTSRC_CACHE); |
552 handle_event(&e); |
549 handle_event(&e); |
553 |
550 |
554 // TODO: update this logging |
551 // TODO: update this logging |
964 } |
961 } |
965 |
962 |
966 // If the even source is PEER, APP or STORE, |
963 // If the even source is PEER, APP or STORE, |
967 // try to handle a BPQ block |
964 // try to handle a BPQ block |
968 if ( event->source_ == EVENTSRC_PEER || |
965 if ( event->source_ == EVENTSRC_PEER || |
969 event->source_ == EVENTSRC_APP || |
|
970 event->source_ == EVENTSRC_STORE ) { |
966 event->source_ == EVENTSRC_STORE ) { |
971 handle_bpq_block(bundle, event); |
967 handle_bpq_block(bundle, event); |
972 } |
968 } |
973 |
969 |
974 // If the bundle contains a BPQ query that was successfully answered |
970 // If the bundle contains a BPQ query that was successfully answered |