Eclipse Community Forums: EMF » [CDO] Is there any example for offline mode ?

Help

Home

Home » Modeling » EMF » [CDO] Is there any example for offline mode ?

Show: Today's Messages :: Show Polls :: Message Navigator

[CDO] Is there any example for offline mode ? [message #629562]

Tue, 28 September 2010 17:16

Guillaume P.

Messages: 69
Registered: June 2010
Location: Toulouse, France

Member

Hi,

Everything is in the title of the topic. ^^

(Sorry for the multiplication of topics, but I think it's best to separate my questions, when it is possible, to make searching easier for other users)

I would like to use the new feature of the CDO 3.0 version: the offline mode. But I find nowhere any concrete explanation of it (except in this document, but after creating the ISynchronizableRepository object, I don't know what to do with).
Does anybody have an example or some detailed information to help me please ?

Regards,
Guillaume

Report message to a moderator

Re: [CDO] Is there any example for offline mode ? [message #629664 is a reply to message #629562]

Wed, 29 September 2010 07:57

Martin Fluegge

Messages: 141
Registered: July 2009

Senior Member

Hi Guillaume,

unfortunately we do not have any example for offline mode prepared yet.

Eike is the expert for the offline stuff but he is currently on the way
to a conference and will not return until Thursday.

But he recently told me that he soon wants to write an article about the
offline mode and the fail-over scenario. This would certainly include
some examples.

Cheers,

Martin

Am 28.09.2010 19:16, schrieb Guillaume P.:
> Hi,
>
> Everything is in the title of the topic. ^^
>
> (Sorry for the multiplication of topics, but I think it's best to
> separate my questions, when it is possible, to make searching easier for
> other users)
>
> I would like to use the new feature of the CDO 3.0 version: the offline
> mode. But I find nowhere any concrete explanation of it (except in
> http://www.eclipse.org/cdo/documentation/relnotes_30/index.p hp#Offline_clones_are_now_supported,
> but after creating the ISynchronizableRepository object, I don't know
> what to do with).
> Does anybody have an example or some detailed information to help me
> please ?
>
> Regards,
> Guillaume

Report message to a moderator

Re: [CDO] Is there any example for offline mode ? [message #629694 is a reply to message #629664]

Wed, 29 September 2010 09:50

Guillaume P.

Messages: 69
Registered: June 2010
Location: Toulouse, France

Member

Ok, so I'll be waiting his return to have some hints about this.
Thank you for the information.

Regards,

Guillaume

Report message to a moderator

Re: [CDO] Is there any example for offline mode ? [message #630208 is a reply to message #629694]

Fri, 01 October 2010 07:29

Eike Stepper

Messages: 6682
Registered: July 2009

Senior Member

Am 29.09.2010 11:50, schrieb Guillaume P.:
> Ok, so I'll be waiting his return to have some hints about this.
> Thank you for the information.
BTW. there is an example setup in our tests: org.eclipse.emf.cdo.tests.config.impl.RepositoryConfig.Offli neConfig.createRepository(String)

Only the focus there is not to be self-explanatory.

Cheers
/Eike

Cheers
/Eike

----
http://www.esc-net.de
http://thegordian.blogspot.com
http://twitter.com/eikestepper

Report message to a moderator

Re: [CDO] Is there any example for offline mode ? [message #630239 is a reply to message #630208]

Fri, 01 October 2010 09:49

Guillaume P.

Messages: 69
Registered: June 2010
Location: Toulouse, France

Member

Sorry, but what tests are you speaking about ? It's probably written somewhere, but I'm unable to the org.eclipse.emf.cdo.tests package in cdo sources... :-/

Regards,
Guillaume

Report message to a moderator

Re: [CDO] Is there any example for offline mode ? [message #630250 is a reply to message #630239]

Fri, 01 October 2010 09:57

Eike Stepper

Messages: 6682
Registered: July 2009

Senior Member

Am 01.10.2010 11:49, schrieb Guillaume P.:
> Sorry, but what tests are you speaking about ? It's probably written somewhere, but I'm unable to the org.eclipse.emf.cdo.tests package in cdo sources... :-/
You're unable to "what"? To *see* the package? That package exists since 8 years ;-)

Cheers
/Eike

Cheers
/Eike

----
http://www.esc-net.de
http://thegordian.blogspot.com
http://twitter.com/eikestepper

Report message to a moderator

Re: [CDO] Is there any example for offline mode ? [message #630251 is a reply to message #630239]

Fri, 01 October 2010 09:59

Eike Stepper

Messages: 6682
Registered: July 2009

Senior Member

This is a multi-part message in MIME format.
--------------040105000008080006010006
Content-Type: text/plain; charset=UTF-8; format=flowed
Content-Transfer-Encoding: 7bit

Am 01.10.2010 11:49, schrieb Guillaume P.:
> Sorry, but what tests are you speaking about ? It's probably written somewhere, but I'm unable to the org.eclipse.emf.cdo.tests package in cdo sources... :-/
org.eclipse.emf.cdo.tests.config.impl.RepositoryConfig.Offli neConfig:

| @Override
*protected *InternalRepository createRepository(String name)
{
*boolean *failover = getTestFailover();
Map<String, String> props = getRepositoryProperties();

*final *String masterName = name + "_master";
IStore masterStore = createStore(masterName);

InternalRepository master;
*if *(failover)
{
InternalRepositorySynchronizer synchronizer = createSynchronizer("backup", name);
master = (InternalRepository)CDOServerUtil.createFailoverParticipant( masterName, masterStore, props,
synchronizer, *true*);
}
*else*
{
master = (InternalRepository)CDOServerUtil.createRepository(masterNam e, masterStore, props);
}

*synchronized *(repositories)
{
repositories.put(masterName, master);
}

LifecycleUtil.activate(master);
startMasterTransport();

InternalRepositorySynchronizer synchronizer = createSynchronizer("master", masterName);
IStore store = createStore(name);

*if *(failover)
{
*return *(InternalRepository)CDOServerUtil.createFailoverParticipant (name, store, props, synchronizer, *false*);
}
*else*
{
OfflineClone repository = *new *OfflineClone()
{
@Override
*public **void *handleCommitInfo(CDOCommitInfo commitInfo)
{
waitIfLockAvailable();
*super*.handleCommitInfo(commitInfo);
}

*private **void *waitIfLockAvailable()
{
*long *millis = getTestDelayedCommitHandling();
*if *(millis != 0L)
{
ConcurrencyUtil.sleep(millis);
}
}
};

repository.setName(name);
repository.setStore((InternalStore)store);
repository.setProperties(props);
repository.setSynchronizer(synchronizer);
*return *repository;
}
}

*protected *InternalRepositorySynchronizer createSynchronizer(*final *String acceptorName, *final *String repositoryName)
{
CDOSessionConfigurationFactory masterFactory = *new *CDOSessionConfigurationFactory()
{
*public *org.eclipse.emf.cdo.session.CDOSessionConfiguration createSessionConfiguration()
{
IManagedContainer container = getCurrentTest().getServerContainer();
IConnector connector = (IConnector)container.getElement("org.eclipse.net4j.connectors ", "jvm", acceptorName);

InternalCDORevisionManager revisionManager = (InternalCDORevisionManager)CDORevisionUtil
..createRevisionManager();
revisionManager.setCache(*new *NOOPRevisionCache());

CDOSessionConfiguration config = *new *CDONet4jSessionConfigurationImpl()
{
@Override
*public *InternalCDOSession createSession()
{
*return new *CDONet4jSessionImpl(*this*)
{
*volatile **int *counter = 1;

@Override
*public **void *handleCommitNotification(CDOCommitInfo commitInfo)
{
*long *delay = getTestDelayed2CommitHandling();
*if *(delay != 0L && counter++ % 2 == 0)
{
AbstractOMTest.sleep(delay);
}

*super*.handleCommitNotification(commitInfo);
}
};
}
};

config.setConnector(connector);
config.setRepositoryName(repositoryName);
config.setRevisionManager(revisionManager);
*return *config;
}
};

RepositorySynchronizer synchronizer = *new *RepositorySynchronizer();
synchronizer.setRemoteSessionConfigurationFactory(masterFact ory);
synchronizer.setRetryInterval(1);
synchronizer.setRawReplication(getTestRawReplication());
// synchronizer.setSqueezeCommitInfos(getTestSqueezeCommitInfos ());
*return *synchronizer;
}

*protected **boolean *getTestFailover()
{
Boolean result = (Boolean)getTestProperty(PROP_TEST_FAILOVER);
*if *(result == *null*)
{
result = *false*;
}

*return *result;
}

*protected **boolean *getTestRawReplication()
{
Boolean result = (Boolean)getTestProperty(PROP_TEST_RAW_REPLICATION);
*if *(result == *null*)
{
result = *false*;
}

*return *result;
}|

--------------040105000008080006010006
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: 8bit

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
<meta content="text/html; charset=UTF-8" http-equiv="Content-Type">
</head>
<body bgcolor="#ffffff" text="#000000">
Am 01.10.2010 11:49, schrieb Guillaume P.:
<blockquote cite="mid:i84alq$l8j$1@news.eclipse.org" type="cite">Sorry,
but what tests are you speaking about ? It's probably written
somewhere, but I'm unable to the org.eclipse.emf.cdo.tests package
in cdo sources... :-/
 
</blockquote>
org.eclipse.emf.cdo.tests.config.impl.RepositoryConfig.Offli neConfig: 
 
<style type="text/css">code { font-family: Courier New,Courier; font-size: 10pt; margin: 0px; }</style>
<div class="java" align="left">
<table bgcolor="#ffffff" border="0" cellpadding="3"
cellspacing="0">
<tbody>
<tr>
<td nowrap="nowrap" align="left" valign="top"> <code>
 @Override 
 protected InternalRepository createRepository(String name) 
 { 
 boolean failover = getTestFailover(); 
 Map<String, String> props = getRepositoryP roperties (); 
 
 final String masterName = name + "_master"; 
 IStore masterStore = createStore(masterName); 
 
 InternalRepository master; 
 if (failover) 
 { 
 InternalRepositorySynchronizer synchronizer = createSynch ronizer ("backup", name); 
 master = (InternalRepository)CDOServerUtil.createFailoverParticipant(masterName, masterStore, props, 
 synchronizer, true); 
 } 
 else 
 { 
 master = (InternalRepository)CDOServerUtil.createRepository(masterName, masterStore, props); 
 } 
 
 synchronized (repositories) 
 { 
 repositories.put(masterName, master); 
 } 
 
 LifecycleUtil.activate(master); 
 startMasterTransport(); 
 
 InternalRepositorySynchronizer synchronizer = createSynch ronizer ("master", masterName); 
 IStore store = createStore(name); 
 
 if (failover) 
 { 
 return (InternalRepository)CDOServerUtil.createFailoverParticipant(name, store, props, synchronizer, false); 
 } 
 else 
 { 
 OfflineClone repository = new OfflineClone() 
 { 
 @Override 
 public void handleCommitInfo(CDOCommitInfo commitInfo) 
 { 
 waitIfLockAvailable(); 
 super.handleCommitInfo(commitInfo); 
 } 
 
 private void waitIfLockAvailable() 
 { 
 long millis = getTestDelayedCommitHandling(); 
 if (millis != 0L) 
 { 
 ConcurrencyUtil.sleep(millis); 
 } 
 } 
 }; 
 
 repository.setName(name); 
 repository.setStore((InternalStore)store); 
 repository.setProperties(props); 
 repository.setSynchronizer(synchronizer); 
 return repository; 
 } 
 } 
 
 protected InternalRepositorySynchronizer createSynchronizer (final String acceptorName, final String repositoryName) 
 { 
 CDOSessionConfigurationFactory masterFactory = new CDOSessionConfigurationFactory() 
 { 
 public org.eclipse.emf.cdo.session.CDOSessionConfiguration createS essionConfiguration () 
 { 
 IManagedContainer container = getCurrentTest ().getServerContainer(); 
 IConnector connector = (IConnector)container.getElement("org.eclipse.net4j.connectors", "jvm", acceptorName); 
 
 InternalCDORevisionManager revisionManager = (InternalCDORevisionManager)CDORevisionUtil 
 .createRevisionManager(); 
 revisionManager.setCache(new NOOPRevisionCache()); 
 
 CDOSessionConfiguration config = new CDONet4jSessionConfigurationImpl() 
 { 
 @Override 
 public InternalCDOSession createSession() 
 { 
 return new CDONet4jSessionImpl(this) 
 { 
 volatile int counter = 1; 
 
 @Override 
 public void handleCommitNotification(CDOCommitInfo commitInfo) 
 { 
 long delay = getTestDelayed2CommitHandling(); 
 if (delay != 0L && counter++ % 2 == 0) 
 { 
 AbstractOMTest.sleep(delay); 
 } 
 
 super.handleCommitNotification(commitInfo); 
 } 
 }; 
 } 
 }; 
 
 config.setConnector(connector); 
 config.setRepositoryName(repositoryName); 
 config.setRevisionManager(revisionManager); 
 return config; 
 } 
 }; 
 
 RepositorySynchronizer synchronizer = new RepositorySynchronizer(); 
 synchronizer.setRemoteSessionConfigurationFactory (masterFactory); 
 synchronizer.setRetryInterval(1); 
 synchronizer.setRawReplication(getTestRawReplication()); 
 // synchronizer.setSqueezeCommitInfos(getTestSqueezeCommitI nfos()); 
 return synchronizer; 
 } 
 
 protected boolean getTestFailover() 
 { 
 Boolean result = (Boolean)getTestProperty(PROP_TEST_FAILOVER); 
 if (result == null) 
 { 
 result = false; 
 } 
 
 return result; 
 } 
 
 protected boolean getTestRawReplication() 
 { 
 Boolean result = (Boolean)getTestProperty(PROP_TEST_RAW_REPLICATION); 
 if (result == null) 
 { 
 result = false; 
 } 
 
 return result; 
 }</code>
</td>
</tr>
</tbody>
</table>
</div>
 
</body>
</html>

--------------040105000008080006010006--

Cheers
/Eike

----
http://www.esc-net.de
http://thegordian.blogspot.com
http://twitter.com/eikestepper

Report message to a moderator

Re: [CDO] Is there any example for offline mode ? [message #630298 is a reply to message #630251]

Fri, 01 October 2010 13:30

Guillaume P.

Messages: 69
Registered: June 2010
Location: Toulouse, France

Member

Yes, a word was missing.
I found the package you were speaking about: I had to add the " http://download.eclipse.org/modeling/emf/cdo/updates/3.0-rel eases" repository site, and then to add the "CDO Model Repository Test" plugin for that.
I'll check it to see if it can help me.

Thanks,
Guillaume

[Updated on: Fri, 01 October 2010 13:32]

Report message to a moderator

Previous Topic:	Incorrect use of namespace prefixes when namespace-prefix is overridden in an xsd:any element
Next Topic:	generate "wrapper" classes from annotated java

Goto Forum:

-=] Back to Top [=-

[ Syndicate this forum (XML) ] [

]

Current Time: Fri Apr 19 19:49:09 GMT 2024

.:: Contact :: Home ::.

Breadcrumbs

Sign up to our Newsletter