X-Git-Url: https://git.stg.codes/stg.git/blobdiff_plain/44378b3654976b893daa96f44cea9fcb62092209..0b5942cd0189bbcc6b9fdc833d1e377100e5f3c7:/projects/stargazer/plugins/other/smux/utils.cpp?ds=inline
diff --git a/projects/stargazer/plugins/other/smux/utils.cpp b/projects/stargazer/plugins/other/smux/utils.cpp
index 8d3988eb..0ea39bbb 100644
--- a/projects/stargazer/plugins/other/smux/utils.cpp
+++ b/projects/stargazer/plugins/other/smux/utils.cpp
@@ -44,31 +44,10 @@ if (left < str.length())
}
arcs[arcPos++] = arc;
}
-OBJECT_IDENTIFIER_set_arcs(oi, arcs, sizeof(arcs[0]), arcPos);
+OBJECT_IDENTIFIER_set_arcs(oi, arcs, sizeof(arcs[0]), static_cast<unsigned int>(arcPos));
return true;
}
-std::string OI2String(OBJECT_IDENTIFIER_t * oi)
-{
-std::string res;
-
-int arcs[1024];
-int count = OBJECT_IDENTIFIER_get_arcs(oi, arcs, sizeof(arcs[0]), 1024);
-
-if (count > 1024)
- return "";
-
-for (int i = 0; i < count; ++i)
- {
- res += ".";
- std::string arc;
- strprintf(&arc, "%d", arcs[i]);
- res += arc;
- }
-
-return res;
-}
-
bool SendOpenPDU(int fd)
{
const char * description = "Stg SMUX Plugin";
@@ -101,12 +80,16 @@ if (error.encoded == -1)
}
else
{
- write(fd, buffer, error.encoded);
+ if (write(fd, buffer, error.encoded) < 0)
+ {
+ printfd(__FILE__, "Failed to send OpenPDU: %s\n", strerror(errno));
+ return false;
+ }
}
return true;
}
-int SendClosePDU(int fd)
+bool SendClosePDU(int fd)
{
ClosePDU_t msg;
@@ -124,16 +107,20 @@ if (error.encoded == -1)
{
printfd(__FILE__, "Could not encode ClosePDU (at %s)\n",
error.failed_type ? error.failed_type->name : "unknown");
- return -1;
+ return false;
}
else
{
- write(fd, buffer, error.encoded);
+ if (write(fd, buffer, error.encoded) < 0)
+ {
+ printfd(__FILE__, "Failed to send ClosePDU: %s\n", strerror(errno));
+ return false;
+ }
}
-return 0;
+return true;
}
-int SendRReqPDU(int fd)
+bool SendRReqPDU(int fd)
{
int oid[] = {1, 3, 6, 1, 4, 1, 38313, 1};
asn_enc_rval_t error;
@@ -157,13 +144,17 @@ if (error.encoded == -1)
{
printfd(__FILE__, "Could not encode RReqPDU (at %s)\n",
error.failed_type ? error.failed_type->name : "unknown");
- return -1;
+ return false;
}
else
{
- write(fd, buffer, error.encoded);
+ if (write(fd, buffer, error.encoded) < 0)
+ {
+ printfd(__FILE__, "Failed to send RReqPDU: %s\n", strerror(errno));
+ return false;
+ }
}
-return 0;
+return true;
}
SMUX_PDUs_t * RecvSMUXPDUs(int fd)
@@ -188,7 +179,7 @@ if(error.code != RC_OK)
return pdus;
}
-int SendGetResponsePDU(int fd, GetResponse_PDU_t * getResponse)
+bool SendGetResponsePDU(int fd, GetResponse_PDU_t * getResponse)
{
asn_enc_rval_t error;
@@ -200,19 +191,23 @@ if (error.encoded == -1)
{
printfd(__FILE__, "Could not encode GetResponsePDU (at %s)\n",
error.failed_type ? error.failed_type->name : "unknown");
- return -1;
+ return false;
}
else
{
- write(fd, buffer, error.encoded);
+ if (write(fd, buffer, error.encoded) < 0)
+ {
+ printfd(__FILE__, "Failed to send GetResponsePDU: %s\n", strerror(errno));
+ return false;
+ }
}
-return 0;
+return true;
}
-int SendGetResponseErrorPDU(int fd,
- const PDU_t * getRequest,
- int errorStatus,
- int errorIndex)
+bool SendGetResponseErrorPDU(int fd,
+ const PDU_t * getRequest,
+ int errorStatus,
+ int errorIndex)
{
asn_enc_rval_t error;
GetResponse_PDU_t msg;
@@ -235,11 +230,15 @@ if (error.encoded == -1)
{
printfd(__FILE__, "Could not encode GetResponsePDU for error (at %s)\n",
error.failed_type ? error.failed_type->name : "unknown");
- return -1;
+ return false;
}
else
{
- write(fd, buffer, error.encoded);
+ if (write(fd, buffer, error.encoded) < 0)
+ {
+ printfd(__FILE__, "Failed to send GetResponseErrorPDU: %s\n", strerror(errno));
+ return false;
+ }
}
-return 0;
+return true;
}