Loading include/nmxp.h +10 −0 Original line number Diff line number Diff line Loading @@ -1154,6 +1154,16 @@ int nmxp_waitReady(int isock); int nmxp_sendDataRequest(int isock, int32_t key, int32_t start_time, int32_t end_time); /*! \brief Sends the message "RequestPending" on a socket * * \param isock A descriptor referencing the socket. * * \retval SOCKET_OK on success * \retval SOCKET_ERROR on error * */ int nmxp_sendRequestPending(int isock); /*! \brief Get the list of available channels from a server * * \param hostname host name Loading lib/nmxp.c +13 −0 Original line number Diff line number Diff line Loading @@ -467,6 +467,19 @@ int nmxp_sendDataRequest(int isock, int32_t key, int32_t start_time, int32_t end } int nmxp_sendRequestPending(int isock) { int ret; ret = nmxp_sendMessage(isock, NMXP_MSG_REQUESTPENDING, NULL, 0); if(ret != NMXP_SOCKET_OK) { nmxp_log(NMXP_LOG_ERR, NMXP_LOG_D_CONNFLOW, "Send a RequestPending message\n"); } return ret; } NMXP_CHAN_LIST *nmxp_getAvailableChannelList(char * hostname, int portnum, NMXP_DATATYPE datatype, int (*func_cond)(void)) { int naqssock; NMXP_CHAN_LIST *channelList = NULL, *channelList_subset = NULL; Loading Loading
include/nmxp.h +10 −0 Original line number Diff line number Diff line Loading @@ -1154,6 +1154,16 @@ int nmxp_waitReady(int isock); int nmxp_sendDataRequest(int isock, int32_t key, int32_t start_time, int32_t end_time); /*! \brief Sends the message "RequestPending" on a socket * * \param isock A descriptor referencing the socket. * * \retval SOCKET_OK on success * \retval SOCKET_ERROR on error * */ int nmxp_sendRequestPending(int isock); /*! \brief Get the list of available channels from a server * * \param hostname host name Loading
lib/nmxp.c +13 −0 Original line number Diff line number Diff line Loading @@ -467,6 +467,19 @@ int nmxp_sendDataRequest(int isock, int32_t key, int32_t start_time, int32_t end } int nmxp_sendRequestPending(int isock) { int ret; ret = nmxp_sendMessage(isock, NMXP_MSG_REQUESTPENDING, NULL, 0); if(ret != NMXP_SOCKET_OK) { nmxp_log(NMXP_LOG_ERR, NMXP_LOG_D_CONNFLOW, "Send a RequestPending message\n"); } return ret; } NMXP_CHAN_LIST *nmxp_getAvailableChannelList(char * hostname, int portnum, NMXP_DATATYPE datatype, int (*func_cond)(void)) { int naqssock; NMXP_CHAN_LIST *channelList = NULL, *channelList_subset = NULL; Loading