Skip to content

Commit

Permalink
Fixed write
Browse files Browse the repository at this point in the history
  • Loading branch information
jonathanpullano committed Apr 8, 2012
1 parent ff9e267 commit e5d9d5d
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 4 deletions.
7 changes: 4 additions & 3 deletions rpc/message/RpcMessageCall.java
Original file line number Diff line number Diff line change
Expand Up @@ -48,18 +48,19 @@ public static ReadResult SessionRead(ArrayList<IPP> ippList, SID sid, int change
return readResult;
}

public static boolean SessionWrite(Collection<IPP> ippList, SID sid, int changeCount, long discardTime) {
public static boolean SessionWrite(Collection<IPP> ippList, SID sid, int changeCount, String data, long discardTime) {
ArrayList<Object> arguments = new ArrayList<Object>();
arguments.add(sid);
arguments.add(changeCount);
arguments.add(data);
arguments.add(discardTime);
return send(ippList, RpcMessage.WRITE, arguments) != null;
}

public static boolean SessionWrite(IPP ipp, SID sid, int changeCount, long discardTime) {
public static boolean SessionWrite(IPP ipp, SID sid, int changeCount, String data, long discardTime) {
ArrayList<IPP> ippList = new ArrayList<IPP>();
ippList.add(ipp);
return SessionWrite(ippList, sid, changeCount, discardTime);
return SessionWrite(ippList, sid, changeCount, data, discardTime);
}

public static boolean SessionDelete(Collection<IPP> ippList, SID sid, int changeCount) {
Expand Down
2 changes: 1 addition & 1 deletion server/SessionManager.java
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ public static Cookie writeRequest(ServletContext context, String newData, SID si
for(IPP ipp : members) {
if(ipp.equals(ippLocal) || ipp.isNull())
continue;
if(RpcMessageCall.SessionWrite(ipp, sid, newChangeCount, discardTime)) {
if(RpcMessageCall.SessionWrite(ipp, sid, newChangeCount, newData, discardTime)) {
newIppBackup = ipp;
svn = new SVN(newChangeCount, newIppPrimary, newIppBackup);
HashSet<IPP> set = new HashSet<IPP>();
Expand Down

0 comments on commit e5d9d5d

Please sign in to comment.