File tree 3 files changed +5
-3
lines changed 3 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -38,8 +38,9 @@ ARROW_DEPRECATED("PLASMA_DEFAULT_RELEASE_DELAY is deprecated")
38
38
constexpr int64_t kDeprecatedPlasmaDefaultReleaseDelay = 64 ;
39
39
#define PLASMA_DEFAULT_RELEASE_DELAY kDeprecatedPlasmaDefaultReleaseDelay ;
40
40
41
- // / Number of objects that will be kept unreleased in the plasma client
42
- // / until we send a message to the store to release the object.
41
+ // / We keep a queue of unreleased objects cached in the client until we start
42
+ // / sending release requests to the store. This is to avoid frequently mapping
43
+ // / and unmapping objects and evicting data from processor caches.
43
44
constexpr int64_t kPlasmaDefaultReleaseDelay = 64 ;
44
45
45
46
// / Object buffer data structure.
Original file line number Diff line number Diff line change 18
18
// Plasma protocol specification
19
19
20
20
enum MessageType:int {
21
+ // Message that gets send when a client hangs up.
21
22
PlasmaDisconnectClient = 0,
22
23
// Create a new object.
23
24
PlasmaCreateRequest,
Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ using arrow::Status;
30
30
31
31
// / Number of times we try connecting to a socket.
32
32
constexpr int64_t kNumConnectAttempts = 50 ;
33
- // / Time to wait between connection attempts.
33
+ // / Time to wait between connection attempts to a socket .
34
34
constexpr int64_t kConnectTimeoutMs = 100 ;
35
35
36
36
namespace plasma {
You can’t perform that action at this time.
0 commit comments