Skip to content
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

IGNITE-20688 Fixed broken handles after binary object detached (lightweighted). #11292

Open
wants to merge 3 commits into
base: master
Choose a base branch
from

Conversation

petrov-mg
Copy link
Contributor

Thank you for submitting the pull request to the Apache Ignite.

In order to streamline the review of the contribution
we ask you to ensure the following steps have been taken:

The Contribution Checklist

  • There is a single JIRA ticket related to the pull request.
  • The web-link to the pull request is attached to the JIRA ticket.
  • The JIRA ticket has the Patch Available state.
  • The pull request body describes changes that have been made.
    The description explains WHAT and WHY was made instead of HOW.
  • The pull request title is treated as the final commit message.
    The following pattern must be used: IGNITE-XXXX Change summary where XXXX - number of JIRA issue.
  • A reviewer has been mentioned through the JIRA comments
    (see the Maintainers list)
  • The pull request has been checked by the Teamcity Bot and
    the green visa attached to the JIRA ticket (see TC.Bot: Check PR)

Notes

If you need any help, please email dev@ignite.apache.org or ask anу advice on http://asf.slack.com #ignite channel.

}

/** */
public byte[] readObject() {
Copy link
Contributor

Choose a reason for hiding this comment

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

Used only by test. Perhaps, can be replaced in test with copyObject() or, at least, can be package-private.

Comment on lines +288 to +290
skipBytes(Byte.BYTES); // String type.

skipBytes(in.readInt());
Copy link
Contributor

Choose a reason for hiding this comment

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

skipObject() ?

@@ -282,16 +284,33 @@ private byte[] valueBytesFromArray(CacheObjectValueContext ctx) {
* @return Detached binary object.
*/
public BinaryObjectImpl detach() {
return detach(true);
Copy link
Contributor

Choose a reason for hiding this comment

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

Why resolveCrossObjectReferences is true by default? Looks like it can be false.

import org.apache.ignite.internal.binary.streams.BinaryOutputStream;

/** */
public class RawBytesObjectReader implements BinaryPositionReadable {
Copy link
Contributor

Choose a reason for hiding this comment

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

Perhaps it's worth to add Binary word to class name. And we don't read objects in this class, so object readed is not very good name also. Perhaps extractor or something like this.


/** */
private void overrideHash(BinaryOutputStream writer, int writerRootObjStartPos, ObjectDescriptor objDesc) {
int hashCode = instance().hashCode(
Copy link
Contributor

Choose a reason for hiding this comment

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

Let's use method name with class name for instance() (without static import), or instance() can be readed as local class method.


/** {@inheritDoc} */
@Override public int compareTo(@NotNull ObjectDetachHelper.ObjectDescriptor other) {
return Integer.compare(objStartOffset, other.objDataStartOffset);
Copy link
Contributor

Choose a reason for hiding this comment

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

Why different fields are compared?

}

/** */
public BinaryObjectImpl detach(boolean resolveCrossObjectReferences) {
Copy link
Contributor

Choose a reason for hiding this comment

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

Abbreviation should be used for Object

BinaryReaderHandles hnds = new BinaryReaderHandles();

return (T)unwrapBinary(marsh.deserialize(in, hnds), hnds, clazz);
return (T)unwrapBinary(marsh.deserialize(in, new BinaryReaderHandles()), clazz);
Copy link
Contributor

Choose a reason for hiding this comment

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

One line statement with braces


/** */
@RunWith(Parameterized.class)
@WithSystemProperty(key = IGNITE_BINARY_SORT_OBJECT_FIELDS, value = "true")
Copy link
Contributor

Choose a reason for hiding this comment

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

BinaryUtils.FIELDS_SORTED_ORDER is a static field and initiated when BinaryUtils class is initiated. If current JVM run some other tests before (on TC, for example) field is not reinitiated with this system property.

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.

None yet

2 participants