Examples of readData()

Examples of com.hazelcast.nio.serialization.Data.readData()

50
51
52
53
54
55
56
57
58
59
60
        this.name = in.readUTF();
        int size = in.readInt();
        this.keys = new HashSet<Data>(size);
        for (int i = 0; i < size; i++) {
            Data key = new Data();
            key.readData(in);
            keys.add(key);
        }
        this.entryProcessor = in.readObject();
    }
}
View Full Code Here

Examples of com.hazelcast.partition.MigrationInfo.readData()

147
148
149
150
151
152
153
154
155
156
157
        int migrationsSize = in.readInt();
        activeMigrations = new ArrayList<MigrationInfo>(migrationsSize);
        for (int i = 0; i < migrationsSize; i++) {
            MigrationInfo migrationInfo = new MigrationInfo();
            migrationInfo.readData(in);
            activeMigrations.add(migrationInfo);
        }

        int lockSize = in.readInt();
        lockInfos = new ArrayList<LockInfo>(lockSize);
View Full Code Here

Examples of com.hazelcast.query.impl.QueryResultEntryImpl.readData()

73
74
75
76
77
78
79
80
81
82
83
        }
        int rsize = in.readInt();
        if (rsize > 0) {
            for (int i = 0; i < rsize; i++) {
                final QueryResultEntryImpl resultEntry = new QueryResultEntryImpl();
                resultEntry.readData(in);
                result.add(resultEntry);
            }
        }
    }
}
View Full Code Here

Examples of com.hazelcast.queue.impl.QueueContainer.readData()

76
77
78
79
80
81
82
83
84
85
86
        int mapSize = in.readInt();
        migrationData = new HashMap<String, QueueContainer>(mapSize);
        for (int i = 0; i < mapSize; i++) {
            String name = in.readUTF();
            QueueContainer container = new QueueContainer(name);
            container.readData(in);
            migrationData.put(name, container);
        }
    }

    @Override
View Full Code Here

Examples of com.hazelcast.replicatedmap.impl.record.ReplicatedRecord.readData()

129
130
131
132
133
134
135
136
137
138
139
        origin.readData(in);
        recordCount = in.readInt();
        replicatedRecords = new ReplicatedRecord[recordCount];
        for (int i = 0; i < recordCount; i++) {
            ReplicatedRecord replicatedRecord = new ReplicatedRecord();
            replicatedRecord.readData(in);
            replicatedRecords[i] = replicatedRecord;
        }
        finalChunk = in.readBoolean();
    }
}
View Full Code Here

Examples of com.hazelcast.replicatedmap.record.ReplicatedRecord.readData()

129
130
131
132
133
134
135
136
137
138
139
        origin.readData(in);
        recordCount = in.readInt();
        replicatedRecords = new ReplicatedRecord[recordCount];
        for (int i = 0; i < recordCount; i++) {
            ReplicatedRecord replicatedRecord = new ReplicatedRecord();
            replicatedRecord.readData(in);
            replicatedRecords[i] = replicatedRecord;
        }
        finalChunk = in.readBoolean();
    }
}
View Full Code Here

Examples of com.linkedin.helix.manager.zk.ZkClient.readData()

38
39
40
41
42
43
44
45
46
47
48
    String zkAddr = "localhost:2187";
    ZkServer zkServer = TestHelper.startZkSever(zkAddr);
    ZkClient zkClient = ZKClientPool.getZkClient(zkAddr);
   
    zkClient.createPersistent("/" + testName, new ZNRecord(testName));
    ZNRecord record = zkClient.readData("/" + testName);
    Assert.assertEquals(record.getId(), testName);
   
    TestHelper.stopZkServer(zkServer);
   
    // restart zk
View Full Code Here

Examples of com.mysql.cluster.ndbj.NdbBlob.readData()

1313
1314
1315
1316
1317
1318
1319
1320
1321
1322
1323
            if (blob.getNull()) {
              continue;
            }
            int len = blob.getLength().intValue();
            byte[] buf = new byte[len];
            blob.readData(buf, len);
            attrBuilder.add(AttributeValues.create(attributeType,
              ByteString.wrap(buf)));
          } else {
            attrBuilder.add(AttributeValues.create(attributeType,
              ByteString.wrap(attrValBytes)));
View Full Code Here

Examples of com.ovea.jetty.session.serializer.jboss.serial.persister.Persister.readData()

117
118
119
120
121
122
123
124
125
126
127
        /*ObjectDescription description = new ObjectDescription();
       description.setMetaData(ClassMetamodelFactory.getClassMetaData(reference.getClassName(),cache.getLoader(),false));
       cache.putObjectInCache(reference,description); */

        Object value = persister.readData(cache.getLoader(), streamingClass, metaData, reference, cache, cache.getInput(), cache.getSubstitution());

        if (!(persister instanceof ClassReferencePersister)) //JBSER-83
        {
            if (cache.getSubstitution() != null) {
                value = cache.getSubstitution().replaceObject(value);
View Full Code Here

Examples of com.sun.star.configuration.backend.XLayer.readData()

136
137
138
139
140
141
142
143
144
145
146
            XLayer xLayer = (XLayer) UnoRuntime.queryInterface(XLayer.class,
                                                               LayerParser);

            XLayerHandlerImpl xLayerHandler = new XLayerHandlerImpl();

            xLayer.readData(xLayerHandler);

            res = xLayerHandler.getCalls().equals(getExpected());

            if (!res) {
                log.println("#### Getting: ");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.