equal
deleted
inserted
replaced
188 extensions.wrapfunction( |
188 extensions.wrapfunction( |
189 wireprotov1server.commands[b'heads'], b'func', proto.heads |
189 wireprotov1server.commands[b'heads'], b'func', proto.heads |
190 ) |
190 ) |
191 # TODO also wrap wireproto.commandsv2 once heads is implemented there. |
191 # TODO also wrap wireproto.commandsv2 once heads is implemented there. |
192 |
192 |
193 # can't do this in reposetup because it needs to have happened before |
|
194 # wirerepo.__init__ is called |
|
195 proto.ssholdcallstream = sshpeer.sshv1peer._callstream |
|
196 proto.httpoldcallstream = httppeer.httppeer._callstream |
|
197 sshpeer.sshv1peer._callstream = proto.sshrepocallstream |
|
198 httppeer.httppeer._callstream = proto.httprepocallstream |
|
199 |
|
200 # override some extensions' stuff as well |
193 # override some extensions' stuff as well |
201 for name, module in extensions.extensions(): |
194 for name, module in extensions.extensions(): |
202 if name == b'rebase': |
195 if name == b'rebase': |
203 # TODO: teach exthelper to handle this |
196 # TODO: teach exthelper to handle this |
204 extensions.wrapfunction( |
197 extensions.wrapfunction( |