File tree Expand file tree Collapse file tree 3 files changed +0
-8
lines changed Expand file tree Collapse file tree 3 files changed +0
-8
lines changed Original file line number Diff line number Diff line change 82
82
sender. clone ( ) ,
83
83
actor_mesh_shape. clone ( ) ,
84
84
message,
85
- None , // TODO: reducer typehash
86
85
) ?;
87
86
88
87
comm_actor_ref. send (
Original file line number Diff line number Diff line change @@ -256,8 +256,6 @@ impl CommActor {
256
256
message. shape ( ) . clone ( ) ,
257
257
message. sender ( ) . clone ( ) ,
258
258
) ;
259
- // TODO(pzhang) split reply ports so children can reply to this comm
260
- // actor instead of parent.
261
259
cx. post (
262
260
cx. self_id ( )
263
261
. proc_id ( )
Original file line number Diff line number Diff line change @@ -54,8 +54,6 @@ pub struct CastMessageEnvelope {
54
54
dest_port : DestinationPort ,
55
55
/// The serialized message.
56
56
data : ErasedUnbound ,
57
- /// typehash of the reducer used to accumulate the message in split ports.
58
- pub reducer_typehash : Option < u64 > ,
59
57
/// The shape of the cast.
60
58
shape : Shape ,
61
59
}
@@ -67,7 +65,6 @@ impl CastMessageEnvelope {
67
65
sender : ActorId ,
68
66
shape : Shape ,
69
67
message : M ,
70
- reducer_typehash : Option < u64 > ,
71
68
) -> Result < Self , anyhow:: Error >
72
69
where
73
70
A : RemoteActor + RemoteHandles < IndexedErasedUnbound < M > > ,
@@ -80,7 +77,6 @@ impl CastMessageEnvelope {
80
77
sender,
81
78
dest_port : DestinationPort :: new :: < A , M > ( actor_name) ,
82
79
data,
83
- reducer_typehash,
84
80
shape,
85
81
} )
86
82
}
@@ -100,7 +96,6 @@ impl CastMessageEnvelope {
100
96
sender,
101
97
dest_port,
102
98
data : ErasedUnbound :: new ( data) ,
103
- reducer_typehash : None ,
104
99
shape,
105
100
}
106
101
}
You can’t perform that action at this time.
0 commit comments