Package org.objectweb.speedo.pobjects.basic

Examples of org.objectweb.speedo.pobjects.basic.BasicA.readF2()

90
91
92
93
94
95
96
97
98
99
100
                pm2.currentTransaction().begin();
                logger.log(BasicLevel.INFO, "Thread2: getObjectById");
                BasicA ba = (BasicA) pm2.getObjectById(id, true);
                Assert.assertNotNull("Object not found", ba);
                logger.log(BasicLevel.INFO, "Thread2: read");
                ba.readF2();
                logger.log(BasicLevel.INFO, "Thread2: read done");
                logger.log(BasicLevel.INFO, "Thread2: commit");
                pm2.currentTransaction().commit();
                pm2.close();
            }
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
        pm = pmf.getPersistenceManager();
        pm.currentTransaction().begin();
        ba = (BasicA) pm.getObjectById(id, true);
        Assert.assertNotNull("Object not found", ba);
        Assert.assertEquals("Bad f1 value", "1", ba.readF1());
        Assert.assertEquals("Bad f2 value", 2, ba.readF2());
        pm.deletePersistent(ba);
        pm.currentTransaction().commit();
        pm.close();
    }
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
        pm1.currentTransaction().begin();
        logger.log(BasicLevel.INFO, "Thread1: getObjectById");
        ba = (BasicA) pm1.getObjectById(id, true);
        Assert.assertNotNull("Object not found", ba);
        logger.log(BasicLevel.INFO, "Thread1: read");
        ba.readF2();
        logger.log(BasicLevel.INFO, "Thread1: read done");

        // begin transaction 2
        Thread t = assertLock(new Runnable () {
            public void run () {
View Full Code Here
155
156
157
158
159
160
161
162
163
164
165
                pm2.currentTransaction().begin();
                logger.log(BasicLevel.INFO, "Thread2: getObjectById");
                BasicA ba = (BasicA) pm2.getObjectById(id, true);
                Assert.assertNotNull("Object not found", ba);
                logger.log(BasicLevel.INFO, "Thread2: write");
                ba.writeF2(ba.readF2() + 1);
                logger.log(BasicLevel.INFO, "Thread2: write done");
                logger.log(BasicLevel.INFO, "Thread2: commit");
                pm2.currentTransaction().commit();
                pm2.close();
            }
View Full Code Here
176
177
178
179
180
181
182
183
184
185
186
        pm = pmf.getPersistenceManager();
        pm.currentTransaction().begin();
        ba = (BasicA) pm.getObjectById(id, true);
        Assert.assertNotNull("Object not found", ba);
        Assert.assertEquals("Bad f1 value", "1", ba.readF1());
        Assert.assertEquals("Bad f2 value", 3, ba.readF2());
        pm.deletePersistent(ba);
        pm.currentTransaction().commit();
        pm.close();
    }
View Full Code Here
206
207
208
209
210
211
212
213
214
215
216
        pm1.currentTransaction().begin();
        logger.log(BasicLevel.INFO, "Thread1: getObjectById");
        ba = (BasicA) pm1.getObjectById(id, true);
        Assert.assertNotNull("Object not found", ba);
        logger.log(BasicLevel.INFO, "Thread1: write");
        ba.writeF2(ba.readF2() + 1);
        logger.log(BasicLevel.INFO, "Thread1: write done");

        // begin transaction 2
        Thread t = assertLock(new Runnable () {
            public void run () {
View Full Code Here
219
220
221
222
223
224
225
226
227
228
229
                pm2.currentTransaction().begin();
                logger.log(BasicLevel.INFO, "Thread2: getObjectById");
                BasicA ba = (BasicA) pm2.getObjectById(id, true);
                Assert.assertNotNull("Object not found", ba);
                logger.log(BasicLevel.INFO, "Thread2: read");
                ba.readF2();
                logger.log(BasicLevel.INFO, "Thread2: read done");
                logger.log(BasicLevel.INFO, "Thread2: commit");
                pm2.currentTransaction().commit();
                pm2.close();
            }
View Full Code Here
240
241
242
243
244
245
246
247
248
249
250
        pm = pmf.getPersistenceManager();
        pm.currentTransaction().begin();
        ba = (BasicA) pm.getObjectById(id, true);
        Assert.assertNotNull("Object not found", ba);
        Assert.assertEquals("Bad f1 value", "1", ba.readF1());
        Assert.assertEquals("Bad f2 value", 3, ba.readF2());
        pm.deletePersistent(ba);
        pm.currentTransaction().commit();
        pm.close();
    }
View Full Code Here
280
281
282
283
284
285
286
287
288
289
290
                pm2.currentTransaction().begin();
                logger.log(BasicLevel.INFO, "Thread2: getObjectById");
                BasicA ba2 = (BasicA) pm2.getObjectById(id, true);
                Assert.assertNotNull("Object not found", ba2);
                logger.log(BasicLevel.INFO, "Thread2: read");
                ba2.readF2();
                logger.log(BasicLevel.INFO, "Thread2: read done");
                logger.log(BasicLevel.INFO, "Thread2: commit");
                pm2.currentTransaction().commit();
                pm2.close();
            }
View Full Code Here
335
336
337
338
339
340
341
342
343
344
345
        pm1.currentTransaction().begin();
        logger.log(BasicLevel.INFO, "Thread1: getObjectById");
        ba = (BasicA) pm1.getObjectById(id, true);
        Assert.assertNotNull("Object not found", ba);
        logger.log(BasicLevel.INFO, "Thread1: write");
        ba.writeF2(ba.readF2() + 1);
        logger.log(BasicLevel.INFO, "Thread1: write done");

        // begin transaction 2
        Thread t = assertLock(new Runnable () {
            public void run () {
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.