13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
17
17
"""Server for smart-server protocol."""
62
62
from socket import error as socket_error
63
63
self._socket_error = socket_error
64
64
self._socket_timeout = socket_timeout
65
addrs = socket.getaddrinfo(host, port, socket.AF_UNSPEC,
65
addrs = socket.getaddrinfo(host, port, socket.AF_UNSPEC,
66
66
socket.SOCK_STREAM, 0, socket.AI_PASSIVE)[0]
68
68
(family, socktype, proto, canonname, sockaddr) = addrs
98
98
# We need all three because:
99
99
# * other machines see the first
100
100
# * local commits on this machine should be able to be mapped to
102
102
# * commits the server does itself need to be mapped across to this
104
104
# The latter two urls are different aliases to the servers url,
105
# so we group those in a list - as there might be more aliases
105
# so we group those in a list - as there might be more aliases
107
107
backing_urls = [self.backing_transport.base]
178
178
self._should_terminate = True
179
179
# close the socket - gives error to connections from here on in,
180
180
# rather than a connection reset error to connections made during
181
# the period between setting _should_terminate = True and
181
# the period between setting _should_terminate = True and
182
182
# the current request completing/aborting. It may also break out the
183
183
# main loop if it was currently in accept() (on some platforms).
210
210
Hooks.__init__(self)
211
# Introduced in 0.16:
212
# invoked whenever the server starts serving a directory.
213
# The api signature is (backing urls, public url).
214
self['server_started'] = []
215
# Introduced in 0.16:
216
# invoked whenever the server stops serving a directory.
217
# The api signature is (backing urls, public url).
218
self['server_stopped'] = []
211
self.create_hook(HookPoint('server_started',
212
"Called by the bzr server when it starts serving a directory. "
213
"server_started is called with (backing urls, public url), "
214
"where backing_url is a list of URLs giving the "
215
"server-specific directory locations, and public_url is the "
216
"public URL for the directory being served.", (0, 16), None))
217
self.create_hook(HookPoint('server_stopped',
218
"Called by the bzr server when it stops serving a directory. "
219
"server_stopped is called with the same parameters as the "
220
"server_started hook: (backing_urls, public_url).", (0, 16), None))
220
222
SmartTCPServer.hooks = SmartServerHooks()
223
225
class SmartTCPServer_for_testing(SmartTCPServer):
224
226
"""Server suitable for use by transport tests.
226
228
This server is backed by the process's cwd.
230
232
SmartTCPServer.__init__(self, None)
231
233
self.client_path_extra = None
232
234
self.thread_name_suffix = thread_name_suffix
234
236
def get_backing_transport(self, backing_transport_server):
235
237
"""Get a backing transport from a server we are decorating."""
236
238
return transport.get_transport(backing_transport_server.get_url())
238
240
def setUp(self, backing_transport_server=None,
239
241
client_path_extra='/extra/'):
240
242
"""Set up server for testing.
242
244
:param backing_transport_server: backing server to use. If not
243
245
specified, a LocalURLServer at the current working directory will
added
removed
bzrlib/smart/server.py
