Skip to content

End-to-end object size information passthrough #105

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 6 commits into from
Dec 9, 2016
Merged

Conversation

atumanov
Copy link
Contributor

@atumanov atumanov commented Dec 9, 2016

  • pass through object size information from Plasma store to Plasma manager to Redis.
  • a separate hash table struct is created for storing object attribute information.
  • object attribute table subscribe methods for schedulers to listen to object information.
  • separate subscribe methods for object keyspace notifications and object attribute pub/sub channel.

@pcmoritz
Copy link
Contributor

pcmoritz commented Dec 9, 2016

supersedes #90

void subscribe_success_objectinfo_available_callback(object_id object_id,
int64_t object_size,
void *user_context) {
printf("[object avail] XXXreceived object size = %d XXX\n", object_size);
Copy link
Contributor

@pcmoritz pcmoritz Dec 9, 2016

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

remove this print

time_left -= 0.2
time.sleep(0.2)

print("time waiting for plasma manager to fail = %.2f" % (10-time_left))
Copy link
Collaborator

@robertnishihara robertnishihara Dec 9, 2016

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

print("Time waiting for plasma manager to fail = {:.2}".format(10 - time_left))

@robertnishihara robertnishihara merged commit 0abbf5a into master Dec 9, 2016
@robertnishihara robertnishihara deleted the object-sizes branch December 9, 2016 08:51
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants