Skip to content

Commit 3bbf068

Browse files
committed
Add SWSSDBConnector_new_keyed to construct dbconnectors with a SonicDBKey to c-api
1 parent 38da2cc commit 3bbf068

File tree

2 files changed

+14
-0
lines changed

2 files changed

+14
-0
lines changed

common/c-api/dbconnector.cpp

+10
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,16 @@ SWSSResult SWSSDBConnector_new_named(const char *dbName, uint32_t timeout_ms, ui
3030
SWSSTry(*outDb = (SWSSDBConnector) new DBConnector(string(dbName), timeout_ms, isTcpConn));
3131
}
3232

33+
SWSSResult SWSSDBConnector_new_keyed(const char *dbName, uint32_t timeout_ms, uint8_t isTcpConn,
34+
const char *containerName, const char *netns, SWSSDBConnector *outDb) {
35+
SWSSTry({
36+
SonicDBKey key;
37+
key.containerName = string(containerName);
38+
key.netns = string(netns);
39+
*outDb = (SWSSDBConnector) new DBConnector(string(dbName), timeout_ms, isTcpConn, key);
40+
});
41+
}
42+
3343
SWSSResult SWSSDBConnector_free(SWSSDBConnector db) {
3444
SWSSTry(delete (DBConnector *)db);
3545
}

common/c-api/dbconnector.h

+4
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,10 @@ SWSSResult SWSSDBConnector_new_unix(int32_t dbId, const char *sock_path, uint32_
2626
// Pass 0 to timeout for infinity
2727
SWSSResult SWSSDBConnector_new_named(const char *dbName, uint32_t timeout_ms, uint8_t isTcpConn, SWSSDBConnector *outDb);
2828

29+
// Pass 0 to timeout for infinity
30+
SWSSResult SWSSDBConnector_new_keyed(const char *dbName, uint32_t timeout_ms, uint8_t isTcpConn,
31+
const char *containerName, const char *netns, SWSSDBConnector *outDb);
32+
2933
SWSSResult SWSSDBConnector_free(SWSSDBConnector db);
3034

3135
// Outputs 0 when key doesn't exist, 1 when key was deleted

0 commit comments

Comments
 (0)