Package org.objectweb.speedo.pobjects.basic

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

349
350
351
352
353
354
355
356
357
358
359
                    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();
                } catch (JDOFatalException e) {
View Full Code Here
376
377
378
379
380
381
382
383
384
385
386
    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", 4, ba.readF2());
    pm.deletePersistent(ba);
    pm.currentTransaction().commit();
    pm.close();
  }
View Full Code Here
417
418
419
420
421
422
423
424
425
426
427
                    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();
                } catch (JDOFatalException e) {
View Full Code Here
433
434
435
436
437
438
439
440
441
442
443
        // end transaction 1
        logger.log(BasicLevel.INFO, "Thread1: write");
        boolean ok = true;
        try {
            ba.writeF2(ba.readF2() + 1);
            ok = true;
            logger.log(BasicLevel.INFO, "Thread1: write done");
            logger.log(BasicLevel.INFO, "Thread1: commit");
            pm1.currentTransaction().commit();
        } catch (JDOException e) {
View Full Code Here
453
454
455
456
457
458
459
460
461
462
463
        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", ( ok ? 4 : 3), ba.readF2());
        pm.deletePersistent(ba);
        pm.currentTransaction().commit();
        pm.close();
    }
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
                switch(actions[j]) {
                case W_ACTION:
                  a.incF2();
                  break;
                case R_W_ACTION:
                  a.writeF2(a.readF2() + 1);
                  break;
                case MIXED_ACTION:
                    if (action == W_ACTION) {
                        a.incF2();
                        action = R_W_ACTION;
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
                case MIXED_ACTION:
                    if (action == W_ACTION) {
                        a.incF2();
                        action = R_W_ACTION;
                    } else if (action == R_W_ACTION) {
                        a.writeF2(a.readF2() + 1);
                        action = W_ACTION;
                    }
                  break;
                }
                pm.currentTransaction().commit();
View Full Code Here
288
289
290
291
292
293
294
295
296
297
298
            }
            st.getLogger().log(BasicLevel.DEBUG, "Thread " + threadId + " expect: " + expected);
            Collection found = new ArrayList();
            for (Iterator iter = c.iterator(); iter.hasNext();) {
                ba = (BasicA) iter.next();
                int f2 = ba.readF2();
                found.add(new Integer(f2));
            }
            q.closeAll();
            st.getLogger().log(BasicLevel.DEBUG, "Thread " + threadId + " found: " + found);
            st.assertSameCollection("Bad query result"
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.