use PostgreSQL::Test::Cluster;

use PostgreSQL::Test::Utils;

use Test::More;

use Time::HiResqw(usleep);

{

has_streaming=> 1);

$node_standby->append_conf('postgresql.conf',

"allow_in_place_tablespaces = on");

$node_standby->append_conf('postgresql.conf',

"primary_slot_name = slot");

$node_standby->start;

$node_primary->poll_query_until('postgres',

'SELECT count(*) = 1 FROM pg_stat_replication');

$node_primary->safe_psql('postgres',"SELECT pg_drop_replication_slot('slot')");

$node_standby->safe_psql('postgres','CHECKPOINT');

$node_primary->wait_for_catchup($node_standby,'write',

$node_primary->lsn('write'));

];

$node_primary->safe_psql('postgres',$query);

$node_primary->wait_for_catchup($node_standby,'replay',

$node_primary->wait_for_catchup($node_standby,'write',

$node_primary->lsn('write'));

my$tspdir =$node_standby->data_dir ."/pg_tblspc/$tspoid";

File::Path::rmtree($tspdir);

my$logstart =get_log_size($node_standby);

my$logstart =-s$node_standby->logfile;

$node_primary->safe_psql(

my$max_attempts =$PostgreSQL::Test::Utils::timeout_default;

my$max_attempts =$PostgreSQL::Test::Utils::timeout_default * 10;

while ($max_attempts-- >= 0)

{

if (

find_in_log(

$node_standby,qr!WARNING: ( [A-Z0-9]+:)? creating missing directory: pg_tblspc/!,

$logstart));

sleep 1;

usleep(100_000);

}

ok($max_attempts > 0,"invalid directory creation is detected");

done_testing();

{

my ($node) =@_;

return (stat$node->logfile)[7];

}

{

my ($node,$pat,$off) =@_;

$off = 0unlessdefined$off;

my$log = PostgreSQL::Test::Utils::slurp_file($node->logfile);

return 0if (length($log) <=$off);

$log =substr($log,$off);

my$log = PostgreSQL::Test::Utils::slurp_file($node->logfile,$off);

return$log =~m/$pat/;

}