aggregate query processing in peer to peer source code in the code project