Package org.apache.cassandra.db

Examples of org.apache.cassandra.db.ReadResponse

108
109
110
111
112
113
114
115
116
117
118
119
            try
            {
                byte[] body = response.getMessageBody();
                ByteArrayInputStream bufIn = new ByteArrayInputStream(body);
                ReadResponse result = ReadResponse.serializer().deserialize(new DataInputStream(bufIn));
                byte[] digest = result.digest();

                if (!Arrays.equals(ColumnFamily.digest(row_.cf), digest))
                {
                    IResponseResolver<Row> readResponseResolver = new ReadResponseResolver(table_);
                    IAsyncCallback responseHandler;
View Full Code Here
157
158
159
160
161
162
163
164
165
166
167
        public DataRepairHandler(Row localRow, int responseCount, IResponseResolver<Row> readResponseResolver) throws IOException
        {
            this(responseCount, readResponseResolver);
            // wrap localRow in a response Message so it doesn't need to be special-cased in the resolver
            ReadResponse readResponse = new ReadResponse(localRow);
            DataOutputBuffer out = new DataOutputBuffer();
            ReadResponse.serializer().serialize(readResponse, out);
            byte[] bytes = new byte[out.getLength()];
            System.arraycopy(out.getData(), 0, bytes, 0, bytes.length);
            responses_.add(new Message(FBUtilities.getLocalAddress(), StageManager.RESPONSE_STAGE, StorageService.Verb.READ_RESPONSE, bytes));
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
121
            try
            {
                byte[] body = response.getMessageBody();
                ByteArrayInputStream bufIn = new ByteArrayInputStream(body);
                ReadResponse result = ReadResponse.serializer().deserialize(new DataInputStream(bufIn));
                ByteBuffer digest = result.digest();

                if (!ColumnFamily.digest(row_.cf).equals(digest))
                {
                    IResponseResolver<Row> readResponseResolver = new ReadResponseResolver(table_);
                    IAsyncCallback responseHandler;
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
        public DataRepairHandler(Row localRow, int responseCount, IResponseResolver<Row> readResponseResolver) throws IOException
        {
            this(responseCount, readResponseResolver);
            // wrap localRow in a response Message so it doesn't need to be special-cased in the resolver
            ReadResponse readResponse = new ReadResponse(localRow);
            DataOutputBuffer out = new DataOutputBuffer();
            ReadResponse.serializer().serialize(readResponse, out);
            byte[] bytes = new byte[out.getLength()];
            System.arraycopy(out.getData(), 0, bytes, 0, bytes.length);
            responses_.add(new Message(FBUtilities.getLocalAddress(), StorageService.Verb.READ_RESPONSE, bytes));
View Full Code Here
TOP

Related Classes of org.apache.cassandra.db.ReadResponse

  • org.apache.cassandra.net.Message
  • org.apache.cassandra.service.AbstractRowResolver
  • org.apache.cassandra.service.ConsistencyChecker$DataRepairHandler
  • org.apache.cassandra.service.ConsistencyChecker$DigestResponseHandler
  • org.apache.cassandra.service.ConsistencyManager$DigestResponseHandler
  • org.apache.cassandra.service.ReadResponseResolver
  • org.apache.cassandra.service.RowDigestResolver
  • org.apache.cassandra.service.StorageProxy
  • org.apache.cassandra.test.DataImporter
  • java.io.DataOutputStream
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.