Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 5 additions & 1 deletion include/mqss-c/client.h
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,8 @@ extern "C" {

typedef struct MQSSOpaqueClient* MQSSClientRef;

MQSSClientRef MQSSClientCreateClient(char* token, char* urlOrQueue, bool isHpc);
MQSSClientRef MQSSClientCreateClient(const char* token,
const char* urlOrQueue, bool isHpc);

MQSSResourceRef* MQSSClientGetAllResources(MQSSClientRef client, int* size);

Expand All @@ -44,6 +45,9 @@ MQSSJobResultRef MQSSClientGetJobResult(MQSSClientRef client, MQSSJobRef job,
bool wait, unsigned int timeout);

int MQSSClientGetNumberPendingJobs(MQSSClientRef client, char* resourceName);

void MQSSClientFreeClient(MQSSClientRef client);

#ifdef __cplusplus
}
#endif
4 changes: 4 additions & 0 deletions include/mqss-c/job.h
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,10 @@ int MQSSClientGetJobResultSubmittedTimestamp(MQSSJobResultRef jobResult,
int MQSSClientGetJobResultScheduledTimestamp(MQSSJobResultRef jobResult,
uint64_t* scheduledTimestamp);

void MQSSClientFreeJob(MQSSJobRef job);

void MQSSClientFreeJobResult(MQSSJobResultRef result);

#ifdef __cplusplus
}
#endif
6 changes: 5 additions & 1 deletion src/c_bindings/client.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@

using namespace mqss::client;

MQSSClientRef MQSSClientCreateClient(char* token, char* urlOrQueue,
MQSSClientRef MQSSClientCreateClient(const char* token, const char* urlOrQueue,
bool isHpc) {
if (!token || !urlOrQueue)
return nullptr;
Expand Down Expand Up @@ -100,3 +100,7 @@ int MQSSClientGetNumberPendingJobs(MQSSClientRef client, char* resourceName) {

return unwrap<MQSSClient>(client)->getNumberPendingJobs(resourceName);
}

void MQSSClientFreeClient(MQSSClientRef client) {
delete unwrap<MQSSClient>(client);
}
8 changes: 8 additions & 0 deletions src/c_bindings/job.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -162,3 +162,11 @@ int MQSSClientGetJobResultScheduledTimestamp(MQSSJobResultRef jobResult,
}
return 0;
}

void MQSSClientFreeJob(MQSSJobRef job) {
delete unwrap<JobRequest>(job);
}

void MQSSClientFreeJobResult(MQSSJobResultRef result) {
delete unwrap<JobResult>(result);
}
Loading