equal
deleted
inserted
replaced
920 |
920 |
921 } |
921 } |
922 |
922 |
923 // If the even source is PEER or STORE, |
923 // If the even source is PEER or STORE, |
924 // try to handle a BPQ block |
924 // try to handle a BPQ block |
925 if ( event->source_ == EVENTSRC_PEER || |
925 if ( event->source_ == EVENTSRC_PEER || |
926 event->source_ == EVENTSRC_STORE ) { |
926 event->source_ == EVENTSRC_STORE || |
927 handle_bpq_block(bundle, event); |
927 event->source_ == EVENTSRC_FRAGMENTATION) { |
|
928 |
|
929 // TODO: change this to allow fragment responses be sent |
|
930 if ( ! bundle->is_fragment() ) { |
|
931 handle_bpq_block(bundle, event); |
|
932 } |
928 } |
933 } |
929 |
934 |
930 // If the bundle contains a BPQ query that was successfully answered |
935 // If the bundle contains a BPQ query that was successfully answered |
931 // a response has already been sent and the query deleted |
936 // a response has already been sent and the query deleted |
932 // so return from this function |
937 // so return from this function |