Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit aa89211

Browse filesBrowse files
author
LENOVO-PC\Vasilis
committed
Added exceptions
1 parent d6f5124 commit aa89211
Copy full SHA for aa89211

File tree

Expand file treeCollapse file tree

3 files changed

+28
-26
lines changed
Filter options
Expand file treeCollapse file tree

3 files changed

+28
-26
lines changed

‎Assignment1/src/client/Client.java

Copy file name to clipboardExpand all lines: Assignment1/src/client/Client.java
+1Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ public static void main(String[] args) throws NotBoundException, IOException, In
3333
String msgText = split_line[1];
3434
VectorClock vt = new VectorClock(registry.list().length,Integer.parseInt(split_line[0]));
3535
int sender = Integer.parseInt(split_line[0]);
36+
System.out.println(sender);
3637
int receiver = Integer.parseInt(split_line[2]);
3738
temp = new Message(msgText,vt,new Buffer(), sender, receiver);
3839
runs.add(sender, new AtomicInteger(runs.get(sender).getAndIncrement()));

‎Assignment1/src/server/RemoteEntityImpl.java

Copy file name to clipboardExpand all lines: Assignment1/src/server/RemoteEntityImpl.java
+13-13Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ protected RemoteEntityImpl() throws RemoteException {
3131
}
3232

3333
@Override
34-
public void receive(Message m) {
34+
public void receive(Message m) throws RemoteException{
3535
Buffer receivedBuffer = m.getBuffer();
3636
int receiver = m.getReceiver();
3737

@@ -51,7 +51,7 @@ public void receive(Message m) {
5151
}
5252

5353
@Override
54-
public void sendMessage() {
54+
public void sendMessage() throws RemoteException{
5555
if (this.toBeSent.get(0)!= null){
5656
Message m = this.toBeSent.get(0);
5757
this.vt.incTimeVector(id);
@@ -62,7 +62,7 @@ public void sendMessage() {
6262
}
6363

6464
@Override
65-
public void deliver(Message m) {
65+
public void deliver(Message m) throws RemoteException{
6666
System.out.println("Message " + m.getText() + "has been delivered to " + m.getReceiver());
6767
this.vt.incTimeVector(m.getSender());
6868
msgBuffer.poll();
@@ -77,53 +77,53 @@ public void deliver(Message m) {
7777
}
7878

7979
@Override
80-
public void setVectorClock(int i, int l) {
80+
public void setVectorClock(int i, int l) throws RemoteException{
8181
this.vt = new VectorClock(i, l);
8282
}
8383

8484
@Override
85-
public void setEntities(IRemoteEntity[] entities) {
85+
public void setEntities(IRemoteEntity[] entities) throws RemoteException{
8686
this.RD = entities;
8787
}
8888

8989
@Override
90-
public void setRuns(int i) {
90+
public void setRuns(int i) throws RemoteException{
9191
this.runs = new AtomicInteger(i);
9292
}
9393

9494
@Override
95-
public AtomicInteger getRuns() {
95+
public AtomicInteger getRuns() throws RemoteException{
9696
return this.runs;
9797
}
9898

9999
@Override
100-
public void setName(String name) {
100+
public void setName(String name) throws RemoteException{
101101
this.name = name;
102102
}
103103

104104
@Override
105-
public String getName() {
105+
public String getName() throws RemoteException{
106106
// TODO Auto-generated method stub
107107
return name;
108108
}
109109

110110
@Override
111-
public void setId(int id) {
111+
public void setId(int id) throws RemoteException{
112112
this.id = id;
113113
}
114114

115115
@Override
116-
public int getId() {
116+
public int getId() throws RemoteException{
117117
return id;
118118
}
119119

120120
@Override
121-
public void addMessage(Message m) {
121+
public void addMessage(Message m) throws RemoteException{
122122
this.msgBuffer.add(m);
123123
}
124124

125125
@Override
126-
public void addMessageToBeSent(int i, Message m) {
126+
public void addMessageToBeSent(int i, Message m) throws RemoteException{
127127
this.toBeSent.add(i, m);
128128
}
129129
}

‎Assignment1/src/util/IRemoteEntity.java

Copy file name to clipboardExpand all lines: Assignment1/src/util/IRemoteEntity.java
+14-13Lines changed: 14 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -3,21 +3,22 @@
33
import message.Message;
44

55
import java.rmi.Remote;
6+
import java.rmi.RemoteException;
67
import java.util.List;
78
import java.util.concurrent.atomic.AtomicInteger;
89

910
public interface IRemoteEntity extends Remote {
10-
public void receive(Message m);
11-
public void sendMessage();
12-
public void deliver(Message m);
13-
public void setVectorClock(int id, int l);
14-
public void setEntities(IRemoteEntity[] enities);
15-
public void setRuns(int i);
16-
public AtomicInteger getRuns();
17-
public void setName(String name);
18-
public String getName();
19-
public void setId(int id);
20-
public int getId();
21-
public void addMessage(Message m);
22-
public void addMessageToBeSent(int i, Message m);
11+
public void receive(Message m) throws RemoteException;
12+
public void sendMessage() throws RemoteException;
13+
public void deliver(Message m) throws RemoteException;
14+
public void setVectorClock(int id, int l) throws RemoteException;
15+
public void setEntities(IRemoteEntity[] enities) throws RemoteException;
16+
public void setRuns(int i) throws RemoteException;
17+
public AtomicInteger getRuns() throws RemoteException;
18+
public void setName(String name) throws RemoteException;
19+
public String getName() throws RemoteException;
20+
public void setId(int id) throws RemoteException;
21+
public int getId() throws RemoteException;
22+
public void addMessage(Message m) throws RemoteException;
23+
public void addMessageToBeSent(int i, Message m) throws RemoteException;
2324
}

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.