@@ -80,7 +80,7 @@ using namespace plasma;
80
80
int main (int argc, char** argv) {
81
81
// Start up and connect a Plasma client.
82
82
PlasmaClient client;
83
- ARROW_CHECK_OK(client.Connect("/tmp/plasma", "", PLASMA_DEFAULT_RELEASE_DELAY ));
83
+ ARROW_CHECK_OK(client.Connect("/tmp/plasma", ""));
84
84
// Disconnect the Plasma client.
85
85
ARROW_CHECK_OK(client.Disconnect());
86
86
}
@@ -218,7 +218,7 @@ using namespace plasma;
218
218
int main (int argc, char** argv) {
219
219
// Start up and connect a Plasma client.
220
220
PlasmaClient client;
221
- ARROW_CHECK_OK(client.Connect("/tmp/plasma", "", PLASMA_DEFAULT_RELEASE_DELAY ));
221
+ ARROW_CHECK_OK(client.Connect("/tmp/plasma", ""));
222
222
// Create an object with a fixed ObjectID.
223
223
ObjectID object_id = ObjectID::from_binary("00000000000000000000");
224
224
int64_t data_size = 1000;
@@ -323,7 +323,7 @@ using namespace plasma;
323
323
int main (int argc, char** argv) {
324
324
// Start up and connect a Plasma client.
325
325
PlasmaClient client;
326
- ARROW_CHECK_OK(client.Connect("/tmp/plasma", "", PLASMA_DEFAULT_RELEASE_DELAY ));
326
+ ARROW_CHECK_OK(client.Connect("/tmp/plasma", ""));
327
327
ObjectID object_id = ObjectID::from_binary("00000000000000000000");
328
328
ObjectBuffer object_buffer;
329
329
ARROW_CHECK_OK(client.Get(&object_id, 1, -1, &object_buffer));
@@ -411,7 +411,7 @@ using namespace plasma;
411
411
int main(int argc, char** argv) {
412
412
// Start up and connect a Plasma client.
413
413
PlasmaClient client;
414
- ARROW_CHECK_OK(client.Connect("/tmp/plasma", "", PLASMA_DEFAULT_RELEASE_DELAY ));
414
+ ARROW_CHECK_OK(client.Connect("/tmp/plasma", ""));
415
415
416
416
int fd;
417
417
ARROW_CHECK_OK(client.Subscribe(&fd));
0 commit comments