| hg-reviewers |
Without this, we get a str/bytes mismatching when using %
formatting a few lines below.
| No Linters Available |
| No Unit Test Coverage |
| Path | Packages | |||
|---|---|---|---|---|
| M | hgext/fsmonitor/state.py (5 lines) |
| Commit | Parents | Author | Summary | Date |
|---|---|---|---|---|
| 1b04e78ab861 | 3c1f128a2624 | Gregory Szorc | Nov 2 2019, 4:34 PM |
| # state.py - fsmonitor persistent state | # state.py - fsmonitor persistent state | ||||
| # | # | ||||
| # Copyright 2013-2016 Facebook, Inc. | # Copyright 2013-2016 Facebook, Inc. | ||||
| # | # | ||||
| # This software may be used and distributed according to the terms of the | # This software may be used and distributed according to the terms of the | ||||
| # GNU General Public License version 2 or any later version. | # GNU General Public License version 2 or any later version. | ||||
| from __future__ import absolute_import | from __future__ import absolute_import | ||||
| import errno | import errno | ||||
| import os | import os | ||||
| import socket | import socket | ||||
| import struct | import struct | ||||
| from mercurial.i18n import _ | from mercurial.i18n import _ | ||||
| from mercurial import ( | from mercurial import ( | ||||
| encoding, | |||||
| pathutil, | pathutil, | ||||
| util, | util, | ||||
| ) | ) | ||||
| _version = 4 | _version = 4 | ||||
| _versionformat = b">I" | _versionformat = b">I" | ||||
| b'fsmonitor', | b'fsmonitor', | ||||
| b'fsmonitor: state file truncated (expected ' | b'fsmonitor: state file truncated (expected ' | ||||
| b'3 chunks, found %d), nuking state\n', | b'3 chunks, found %d), nuking state\n', | ||||
| len(state), | len(state), | ||||
| ) | ) | ||||
| self.invalidate() | self.invalidate() | ||||
| return None, None, None | return None, None, None | ||||
| diskhostname = state[0] | diskhostname = state[0] | ||||
| hostname = socket.gethostname() | hostname = encoding.strtolocal(socket.gethostname()) | ||||
| if diskhostname != hostname: | if diskhostname != hostname: | ||||
| # file got moved to a different host | # file got moved to a different host | ||||
| self._ui.log( | self._ui.log( | ||||
| b'fsmonitor', | b'fsmonitor', | ||||
| b'fsmonitor: stored hostname "%s" ' | b'fsmonitor: stored hostname "%s" ' | ||||
| b'different from current "%s", nuking state\n' | b'different from current "%s", nuking state\n' | ||||
| % (diskhostname, hostname), | % (diskhostname, hostname), | ||||
| ) | ) | ||||
| b'fsmonitor.state', b'wb', atomictemp=True, checkambig=True | b'fsmonitor.state', b'wb', atomictemp=True, checkambig=True | ||||
| ) | ) | ||||
| except (IOError, OSError): | except (IOError, OSError): | ||||
| self._ui.warn(_(b"warning: unable to write out fsmonitor state\n")) | self._ui.warn(_(b"warning: unable to write out fsmonitor state\n")) | ||||
| return | return | ||||
| with file: | with file: | ||||
| file.write(struct.pack(_versionformat, _version)) | file.write(struct.pack(_versionformat, _version)) | ||||
| file.write(socket.gethostname() + b'\0') | file.write(encoding.strtolocal(socket.gethostname()) + b'\0') | ||||
| file.write(clock + b'\0') | file.write(clock + b'\0') | ||||
| file.write(ignorehash + b'\0') | file.write(ignorehash + b'\0') | ||||
| if notefiles: | if notefiles: | ||||
| file.write(b'\0'.join(notefiles)) | file.write(b'\0'.join(notefiles)) | ||||
| file.write(b'\0') | file.write(b'\0') | ||||
| def invalidate(self): | def invalidate(self): | ||||
| try: | try: | ||||