NotificationsYou must be signed in to change notification settings
Fork35
Star147

Commit9a712d9

Oleg Gurev

committed

Added data_inserter to start/stop background wal record insertions for node

1 parentbb3d09b commit9a712d9Copy full SHA for 9a712d9

File tree

1 file changed

+28

-0

lines changed

testgres
- node.py

1 file changed

+28

-0

lines changed

`‎testgres/node.py`

Lines changed: 28 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -179,6 +179,10 @@ def __init__(self, name=None, base_dir=None, port=None, conn_params: ConnectionP`
`179`	`179`	`# Node state`
`180`	`180`	`self.is_started=False`
`181`	`181`
	`182`	`+# Data inserter thread`
	`183`	`+self._insert_thread=None`
	`184`	`+self._stop_insert_data=threading.Event()`
	`185`	`+`
`182`	`186`	`def__enter__(self):`
`183`	`187`	`returnself`
`184`	`188`
`@@ -883,6 +887,8 @@ def stop(self, params=[], wait=True):`
`883`	`887`	`"stop"`
`884`	`888`	`]+params# yapf: disable`
`885`	`889`
	`890`	`+self.stop_data_inserter()`
	`891`	`+`
`886`	`892`	`execute_utility(_params,self.utils_log_file)`
`887`	`893`
`888`	`894`	`self._maybe_stop_logger()`
`@@ -1837,6 +1843,28 @@ def _escape_config_value(value):`
`1837`	`1843`	`result+="'"`
`1838`	`1844`	`returnresult`
`1839`	`1845`
	`1846`	`+defstart_data_inserter(self,sleep_interval=1):`
	`1847`	`+self._stop_insert_data.clear()`
	`1848`	`+`
	`1849`	`+def_insert_loop():`
	`1850`	`+whilenotself._stop_insert_data.is_set():`
	`1851`	`+try:`
	`1852`	`+`
	`1853`	`+self.safe_psql(`
	`1854`	`+"postgres",`
	`1855`	`+"select txid_current()")`
	`1856`	`+exceptQueryException:`
	`1857`	`+break`
	`1858`	`+time.sleep(sleep_interval)`
	`1859`	`+`
	`1860`	`+self._insert_thread=threading.Thread(target=_insert_loop,daemon=True)`
	`1861`	`+self._insert_thread.start()`
	`1862`	`+`
	`1863`	`+defstop_data_inserter(self):`
	`1864`	`+ifself._insert_thread:`
	`1865`	`+self._stop_insert_data.set()`
	`1866`	`+self._insert_thread.join()`
	`1867`	`+self._insert_thread=None`
`1840`	`1868`
`1841`	`1869`	`classNodeApp:`
`1842`	`1870`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

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

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit9a712d9

File tree

1 file changed

1 file changed

`‎testgres/node.py`

0 commit comments