Skip to content

Commit c53d2e8

Browse files
committed
restore larger transfer sizes
1 parent 7e65c3f commit c53d2e8

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

common/src/unifyfs_const.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,8 @@
7070
#define UNIFYFS_METADATA_CACHE_SECONDS 5 /* cached metadata valid for 5 sec */
7171

7272
// Server
73-
#define UNIFYFS_SERVER_MAX_BULK_TX_SIZE MIB /* to-server transmit size */
74-
#define UNIFYFS_SERVER_MAX_DATA_TX_SIZE MIB /* to-client transmit size */
73+
#define UNIFYFS_SERVER_MAX_BULK_TX_SIZE (4 * MIB) /* to-server transmit size */
74+
#define UNIFYFS_SERVER_MAX_DATA_TX_SIZE (8 * MIB) /* to-client transmit size */
7575
#define UNIFYFS_SERVER_MAX_NUM_APPS 64 /* max # apps/mountpoints supported */
7676
#define UNIFYFS_SERVER_MAX_APP_CLIENTS 256 /* max # clients per application */
7777
#define UNIFYFS_SERVER_MAX_READS 2048 /* max # server read reqs per reqmgr */

server/src/unifyfs_p2p_rpc.c

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1093,13 +1093,14 @@ static void process_get_extents_rpc(server_rpc_req_t* sreq)
10931093
send_extents = 1;
10941094
if (src_stamp.tv_sec == 0) {
10951095
/* source timestamp is zero, need to broadcast? */
1096+
send_extents = 0;
10961097
cmp = compare_timespec(&owner_stamp, &last_cache_bcast);
10971098
if (0 != cmp) {
10981099
last_cache_bcast = owner_stamp;
10991100
LOGDBG("broadcasting extents metadata to cache");
11001101
ret = unifyfs_invoke_broadcast_extents_cache(gfid);
1101-
if (UNIFYFS_SUCCESS == ret) {
1102-
send_extents = 0;
1102+
if (UNIFYFS_SUCCESS != ret) {
1103+
send_extents = 1;
11031104
}
11041105
}
11051106
}

0 commit comments

Comments
 (0)