mirror of
https://github.com/wassname/ray.git
synced 2026-07-13 17:45:08 +08:00
Remove unused AddContainedObjectIDs (#7323)
This commit is contained in:
@@ -1006,15 +1006,6 @@ cdef class CoreWorker:
|
||||
c_owner_id,
|
||||
c_owner_address)
|
||||
|
||||
def add_contained_object_ids(
|
||||
self, ObjectID object_id, contained_object_ids):
|
||||
cdef:
|
||||
CObjectID c_object_id = object_id.native()
|
||||
c_vector[CObjectID] c_contained_ids
|
||||
c_contained_ids = ObjectIDsToVector(contained_object_ids)
|
||||
self.core_worker.get().AddContainedObjectIDs(
|
||||
c_object_id, c_contained_ids)
|
||||
|
||||
# TODO: handle noreturn better
|
||||
cdef store_task_outputs(
|
||||
self, worker, outputs, const c_vector[CObjectID] return_ids,
|
||||
|
||||
@@ -149,9 +149,6 @@ cdef extern from "ray/core_worker/core_worker.h" nogil:
|
||||
const CObjectID &outer_object_id,
|
||||
const CTaskID &owner_id,
|
||||
const CAddress &owner_address)
|
||||
void AddContainedObjectIDs(
|
||||
const CObjectID &object_id,
|
||||
const c_vector[CObjectID] &contained_object_ids)
|
||||
|
||||
CRayStatus SetClientOptions(c_string client_name, int64_t limit)
|
||||
CRayStatus Put(const CRayObject &object,
|
||||
|
||||
@@ -378,11 +378,6 @@ void CoreWorker::RegisterOwnershipInfoAndResolveFuture(
|
||||
future_resolver_->ResolveFutureAsync(object_id, owner_id, owner_address);
|
||||
}
|
||||
|
||||
void CoreWorker::AddContainedObjectIDs(
|
||||
const ObjectID &object_id, const std::vector<ObjectID> &contained_object_ids) {
|
||||
// TODO(edoakes,swang): integrate with the reference counting logic.
|
||||
}
|
||||
|
||||
Status CoreWorker::SetClientOptions(std::string name, int64_t limit_bytes) {
|
||||
// Currently only the Plasma store supports client options.
|
||||
return plasma_store_provider_->SetClientOptions(name, limit_bytes);
|
||||
|
||||
@@ -169,14 +169,6 @@ class CoreWorker : public rpc::CoreWorkerServiceHandler {
|
||||
const TaskID &owner_id,
|
||||
const rpc::Address &owner_address);
|
||||
|
||||
/// Add metadata about the object IDs contained within another object ID.
|
||||
/// This should be called during deserialization of the outer object ID.
|
||||
///
|
||||
/// \param[in] object_id The object containing IDs.
|
||||
/// \param[in] contained_object_ids The IDs contained in the object.
|
||||
void AddContainedObjectIDs(const ObjectID &object_id,
|
||||
const std::vector<ObjectID> &contained_object_ids);
|
||||
|
||||
///
|
||||
/// Public methods related to storing and retrieving objects.
|
||||
///
|
||||
|
||||
Reference in New Issue
Block a user