1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
/*
* Copyright (c) 2009-2012 Eike Stepper (Berlin, Germany) and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Eike Stepper - initial API and implementation
*/
package org.eclipse.emf.cdo.internal.server.embedded;
import org.eclipse.emf.cdo.common.CDOCommonRepository;
import org.eclipse.emf.cdo.common.commit.CDOCommitInfo;
import org.eclipse.emf.cdo.common.id.CDOID;
import org.eclipse.emf.cdo.common.lock.CDOLockChangeInfo;
import org.eclipse.emf.cdo.session.remote.CDORemoteSessionMessage;
import org.eclipse.emf.cdo.spi.common.branch.InternalCDOBranch;
import org.eclipse.emf.cdo.spi.server.ISessionProtocol;
import org.eclipse.emf.cdo.spi.server.InternalRepository;
import org.eclipse.emf.cdo.spi.server.InternalSession;
import org.eclipse.net4j.util.lifecycle.Lifecycle;
import org.eclipse.net4j.util.security.DiffieHellman.Client.Response;
import org.eclipse.net4j.util.security.DiffieHellman.Server.Challenge;
import java.util.Set;
/**
* @author Eike Stepper
* @deprecated Not yet supported.
*/
@Deprecated
public class EmbeddedServerSessionProtocol extends Lifecycle implements ISessionProtocol
{
// A separate session protocol instance is required because the getSession() methods are ambiguous!
private EmbeddedClientSessionProtocol clientSessionProtocol;
private InternalSession session;
public EmbeddedServerSessionProtocol(EmbeddedClientSessionProtocol clientSessionProtocol)
{
this.clientSessionProtocol = clientSessionProtocol;
}
public EmbeddedClientSessionProtocol getClientSessionProtocol()
{
return clientSessionProtocol;
}
public InternalSession openSession(InternalRepository repository, boolean passiveUpdateEnabled)
{
session = repository.getSessionManager().openSession(this);
session.setPassiveUpdateEnabled(passiveUpdateEnabled);
return session;
}
public InternalSession getSession()
{
return session;
}
@Deprecated
public org.eclipse.emf.cdo.spi.common.CDOAuthenticationResult sendAuthenticationChallenge(byte[] randomToken)
throws Exception
{
return clientSessionProtocol.handleAuthenticationChallenge(randomToken);
}
public Response sendAuthenticationChallenge(Challenge challenge) throws Exception
{
throw new UnsupportedOperationException();
}
public void sendRepositoryTypeNotification(CDOCommonRepository.Type oldType, CDOCommonRepository.Type newType)
{
EmbeddedClientSession clientSession = clientSessionProtocol.getSession();
clientSession.handleRepositoryTypeChanged(oldType, newType);
}
@Deprecated
public void sendRepositoryStateNotification(CDOCommonRepository.State oldState, CDOCommonRepository.State newState)
{
sendRepositoryStateNotification(oldState, newState, null);
}
public void sendRepositoryStateNotification(CDOCommonRepository.State oldState, CDOCommonRepository.State newState,
CDOID rootResourceID)
{
EmbeddedClientSession clientSession = clientSessionProtocol.getSession();
clientSession.handleRepositoryStateChanged(oldState, newState);
}
public void sendBranchNotification(InternalCDOBranch branch)
{
EmbeddedClientSession clientSession = clientSessionProtocol.getSession();
clientSession.handleBranchNotification(branch);
}
@Deprecated
public void sendCommitNotification(CDOCommitInfo commitInfo)
{
EmbeddedClientSession clientSession = clientSessionProtocol.getSession();
clientSession.handleCommitNotification(commitInfo);
}
@Deprecated
public void sendCommitNotification(CDOCommitInfo commitInfo, boolean clearResourcePathCache) throws Exception
{
throw new UnsupportedOperationException();
}
public void sendCommitNotification(CDOCommitInfo commitInfo, boolean clearResourcePathCache, Set<CDOID> readOnly)
throws Exception
{
throw new UnsupportedOperationException();
}
public void sendLockNotification(CDOLockChangeInfo lockChangeInfo)
{
EmbeddedClientSession clientSession = clientSessionProtocol.getSession();
clientSession.handleLockNotification(lockChangeInfo, null);
}
public void sendRemoteSessionNotification(InternalSession sender, byte opcode)
{
throw new UnsupportedOperationException();
}
public void sendRemoteMessageNotification(InternalSession sender, CDORemoteSessionMessage message)
{
throw new UnsupportedOperationException();
}
}
|
