rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-06-05 06:20:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Minor refectoring

Browse Source
This commit is contained in:
Konstantin Knizhnik
2023-11-10 08:25:05 +02:00
parent df938c889d
commit fd65d0eb80
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pgxn/neon/libpagestore.c
View File

@@ -174,6 +174,8 @@ load_shard_map(shardno_t shard_no, char* connstr)
{
sep = strchr(shard_connstr, ',');
connstr_len = sep != NULL ? sep - shard_connstr : strlen(shard_connstr);
if (connstr_len == 0)
break; /* trailing comma */
if (shard_map->n_shards >= MAX_SHARDS)
elog(ERROR, "Too many shards");
if (connstr_len >= MAX_PS_CONNSTR_LEN)
@@ -182,6 +184,9 @@ load_shard_map(shardno_t shard_no, char* connstr)
shard_connstr = sep + 1;
} while (sep != NULL);
if (shard_map->n_shards == 0)
elog(ERROR, "No shards were speciified");
shard_map->update_counter += 1;
}
shard_map_update_counter = shard_map->update_counter;
@@ -199,6 +204,7 @@ load_shard_map(shardno_t shard_no, char* connstr)
}
#define MB (1024*1024)
shardno_t
get_shard_number(BufferTag* tag)
{
@@ -316,7 +322,7 @@ pageserver_connect(shardno_t shard_no, int elevel)
}
}
neon_log(LOG, "libpagestore: connected to '%s'", shard_map->shard_connstr[shard_no]);
neon_log(LOG, "libpagestore: connected to '%s'", connstr);
page_servers[shard_no].conn = conn;
page_servers[shard_no].wes = wes;
max_attached_shard_no = Max(shard_no+1, max_attached_shard_no);