X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/71d215251ec3eeb3e4192c0e14ec6dea8fd97007..cc4eceb15c80a597e44222b8c0ff60caf85db959:/examples/s4u/app-bittorrent/s4u-peer.cpp diff --git a/examples/s4u/app-bittorrent/s4u-peer.cpp b/examples/s4u/app-bittorrent/s4u-peer.cpp index 71a98e3cf1..d36aae49e9 100644 --- a/examples/s4u/app-bittorrent/s4u-peer.cpp +++ b/examples/s4u/app-bittorrent/s4u-peer.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2012-2018. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2012-2019. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -15,15 +15,15 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_bt_peer, "Messages specific for the peers"); * User parameters for transferred file data. For the test, the default values are : * File size: 10 pieces * 5 blocks/piece * 16384 bytes/block = 819200 bytes */ -#define FILE_PIECES 10UL -#define PIECES_BLOCKS 5UL -#define BLOCK_SIZE 16384 +constexpr unsigned long FILE_PIECES = 10UL; +constexpr unsigned long PIECES_BLOCKS = 5UL; +constexpr int BLOCK_SIZE = 16384; /** Number of blocks asked by each request */ -#define BLOCKS_REQUESTED 2UL +constexpr unsigned long BLOCKS_REQUESTED = 2UL; -#define ENABLE_END_GAME_MODE 1 -#define SLEEP_DURATION 1 +constexpr bool ENABLE_END_GAME_MODE = true; +constexpr double SLEEP_DURATION = 1.0; #define BITS_TO_BYTES(x) (((x) / 8 + (x) % 8) ? 1 : 0) Peer::Peer(std::vector args) @@ -91,12 +91,10 @@ bool Peer::getPeersFromTracker() try { XBT_DEBUG("Sending a peer request to the tracker."); tracker_mailbox->put(peer_request, TRACKER_COMM_SIZE, GET_PEERS_TIMEOUT); - } catch (xbt_ex& e) { - if (e.category == timeout_error) { - XBT_DEBUG("Timeout expired when requesting peers to tracker"); - delete peer_request; - return false; - } + } catch (simgrid::TimeoutError& e) { + XBT_DEBUG("Timeout expired when requesting peers to tracker"); + delete peer_request; + return false; } try { @@ -106,11 +104,9 @@ bool Peer::getPeersFromTracker() if (id != peer_id) connected_peers[peer_id] = new Connection(peer_id); delete answer; - } catch (xbt_ex& e) { - if (e.category == timeout_error) { - XBT_DEBUG("Timeout expired when requesting peers to tracker"); - return false; - } + } catch (simgrid::TimeoutError& e) { + XBT_DEBUG("Timeout expired when requesting peers to tracker"); + return false; } return true; } @@ -457,9 +453,8 @@ int Peer::selectPieceToDownload(Connection* remote_peer) // end game mode if (countPieces(current_pieces) >= (FILE_PIECES - countPieces(bitfield_)) && isInterestedBy(remote_peer)) { -#if ENABLE_END_GAME_MODE == 0 - return -1; -#endif + if (not ENABLE_END_GAME_MODE) + return -1; int nb_interesting_pieces = 0; // compute the number of interesting pieces for (unsigned int i = 0; i < FILE_PIECES; i++)