mirror of
https://github.com/wassname/ray.git
synced 2026-07-17 11:32:33 +08:00
Fix valgrind tests. (#1037)
* Comment out local scheduler valgrind test. * Fix free/delete error. * More free -> delete errors * One more free -> delete and also clean up callback state in plasma manager. * Add set -x to run_valgrind scripts. * Fix valgrind error in CreateLocalSchedulerInfoMessage.
This commit is contained in:
committed by
Philipp Moritz
parent
ba153adc4c
commit
ce278aa06a
@@ -1378,11 +1378,15 @@ void redis_local_scheduler_table_send_info(TableCallbackData *callback_data) {
|
||||
|
||||
void redis_local_scheduler_table_disconnect(DBHandle *db) {
|
||||
flatbuffers::FlatBufferBuilder fbb;
|
||||
LocalSchedulerInfoMessageBuilder builder(fbb);
|
||||
builder.add_db_client_id(to_flatbuf(fbb, db->client));
|
||||
builder.add_is_dead(true);
|
||||
auto message = builder.Finish();
|
||||
/* Create the flatbuffers message. */
|
||||
double empty_array[] = {};
|
||||
/* Most of the flatbuffer message fields don't matter here. Only the
|
||||
* db_client_id and the is_dead field matter. */
|
||||
auto message = CreateLocalSchedulerInfoMessage(
|
||||
fbb, to_flatbuf(fbb, db->client), 0, 0, 0,
|
||||
fbb.CreateVector(empty_array, 0), fbb.CreateVector(empty_array, 0), true);
|
||||
fbb.Finish(message);
|
||||
|
||||
redisReply *reply = (redisReply *) redisCommand(
|
||||
db->sync_context, "PUBLISH local_schedulers %b", fbb.GetBufferPointer(),
|
||||
fbb.GetSize());
|
||||
|
||||
@@ -2,6 +2,8 @@
|
||||
|
||||
# This needs to be run in the build tree, which is normally ray/build
|
||||
|
||||
set -x
|
||||
|
||||
# Cause the script to exit if a single command fails.
|
||||
set -e
|
||||
|
||||
|
||||
Reference in New Issue
Block a user