-
Notifications
You must be signed in to change notification settings - Fork 22
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
CCF version reading - don't use stringview.compare(). Fixes #142
- Loading branch information
Showing
4 changed files
with
257 additions
and
5 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,239 @@ | ||
| /////////////////////////////////////////////////////////////////////// | ||
| // | ||
| // Test IO | ||
| // | ||
| // Purpose: | ||
| // This extends testcbsdk with explicit testing of data io. | ||
| // This is incomplete and only includes tests that were relevant to debugging specific problems. | ||
| // | ||
| // Call with -c to enable continuous data (not tested), -e to enable events (works ok), | ||
| // and -r <int> to specify a fixed runtime (?not working). | ||
| // while running, press Esc key to stop. | ||
| // | ||
| // Note: | ||
| // Make sure only the SDK is used here, and not cbhwlib directly | ||
| // this will ensure SDK is capable of whatever test suite can do | ||
| // Do not throw exceptions, catch possible exceptions and handle them the earliest possible in this library | ||
| // | ||
|
|
||
| #include <map> | ||
| #include <string> | ||
| #include <vector> | ||
| #include <stdio.h> | ||
| #include <iostream> | ||
| #ifdef WIN32 | ||
| #include <conio.h> | ||
| #endif //win32 | ||
| #include <inttypes.h> | ||
| #include "debugmacs.h" | ||
|
|
||
| #include "cbsdk.h" | ||
|
|
||
| #define INST 0 | ||
|
|
||
| typedef struct _cbsdk_config { | ||
| uint32_t nInstance; | ||
| uint32_t bActive; | ||
| uint16_t begchan; | ||
| uint32_t begmask; | ||
| uint32_t begval; | ||
| uint16_t endchan; | ||
| uint32_t endmask; | ||
| uint32_t endval; | ||
| bool bDouble; | ||
| uint32_t uWaveforms; | ||
| uint32_t uConts; | ||
| uint32_t uEvents; | ||
| uint32_t uComments; | ||
| uint32_t uTrackings; | ||
| bool bAbsolute; | ||
| } cbsdk_config; | ||
|
|
||
| void handleResult(cbSdkResult res) | ||
| { | ||
| switch (res) | ||
| { | ||
| case CBSDKRESULT_SUCCESS: | ||
| break; | ||
| case CBSDKRESULT_NOTIMPLEMENTED: | ||
| printf("Not implemented\n"); | ||
| break; | ||
| case CBSDKRESULT_INVALIDPARAM: | ||
| printf("Invalid parameter\n"); | ||
| break; | ||
| case CBSDKRESULT_WARNOPEN: | ||
| printf("Real-time interface already initialized\n"); | ||
| case CBSDKRESULT_WARNCLOSED: | ||
| printf("Real-time interface already closed\n"); | ||
| break; | ||
| case CBSDKRESULT_ERROPENCENTRAL: | ||
| printf("Unable to open library for Central interface\n"); | ||
| break; | ||
| case CBSDKRESULT_ERROPENUDP: | ||
| printf("Unable to open library for UDP interface\n"); | ||
| break; | ||
| case CBSDKRESULT_ERROPENUDPPORT: | ||
| printf("Unable to open UDP interface\n"); | ||
| break; | ||
| case CBSDKRESULT_OPTERRUDP: | ||
| printf("Unable to set UDP interface option\n"); | ||
| break; | ||
| case CBSDKRESULT_MEMERRUDP: | ||
| printf("Unable to assign UDP interface memory\n" | ||
| " Consider using sysctl -w net.core.rmem_max=8388608\n" | ||
| " or sysctl -w kern.ipc.maxsockbuf=8388608\n"); | ||
| break; | ||
| case CBSDKRESULT_INVALIDINST: | ||
| printf("Invalid UDP interface\n"); | ||
| break; | ||
| case CBSDKRESULT_ERRMEMORYTRIAL: | ||
| printf("Unable to allocate RAM for trial cache data\n"); | ||
| break; | ||
| case CBSDKRESULT_ERROPENUDPTHREAD: | ||
| printf("Unable to Create UDP thread\n"); | ||
| break; | ||
| case CBSDKRESULT_ERROPENCENTRALTHREAD: | ||
| printf("Unable to start Cerebus real-time data thread\n"); | ||
| break; | ||
| case CBSDKRESULT_ERRINIT: | ||
| printf("Library initialization error\n"); | ||
| break; | ||
| case CBSDKRESULT_ERRMEMORY: | ||
| printf("Library memory allocation error\n"); | ||
| break; | ||
| case CBSDKRESULT_TIMEOUT: | ||
| printf("Connection timeout error\n"); | ||
| break; | ||
| case CBSDKRESULT_ERROFFLINE: | ||
| printf("Instrument is offline\n"); | ||
| break; | ||
| default: | ||
| printf("Unexpected error\n"); | ||
| break; | ||
| } | ||
| } | ||
|
|
||
|
|
||
| cbSdkVersion testGetVersion(void) | ||
| { | ||
| // Library version can be read even before library open (return value is a warning) | ||
| // actual NSP version however needs library to be open | ||
| cbSdkVersion ver; | ||
| cbSdkResult res = cbSdkGetVersion(INST, &ver); | ||
| if (res != CBSDKRESULT_SUCCESS) | ||
| { | ||
| printf("Unable to determine instrument version\n"); | ||
| } | ||
| else { | ||
| printf("Initializing Cerebus real-time interface %d.%02d.%02d.%02d (protocol cb%d.%02d)...\n", ver.major, ver.minor, ver.release, ver.beta, ver.majorp, ver.minorp); | ||
| } | ||
| handleResult(res); | ||
| return ver; | ||
| } | ||
|
|
||
| // Author & Date: Ehsan Azar 24 Oct 2012 | ||
| // Purpose: Test opening the library | ||
| cbSdkResult testOpen(LPCSTR inst_ip, int inst_port, LPCSTR client_ip) | ||
| { | ||
| // Try to get the version. Should be a warning because we are not yet open. | ||
| cbSdkVersion ver = testGetVersion(); | ||
|
|
||
| // Open the device using default connection type. | ||
| cbSdkConnectionType conType = CBSDKCONNECTION_DEFAULT; | ||
| cbSdkConnection con = cbSdkConnection(); | ||
| con.szOutIP = inst_ip; | ||
| con.nOutPort = inst_port; | ||
| con.szInIP = client_ip; | ||
| cbSdkResult res = cbSdkOpen(INST, conType, con); | ||
| if (res != CBSDKRESULT_SUCCESS) | ||
| printf("Unable to open instrument connection.\n"); | ||
| handleResult(res); | ||
|
|
||
| cbSdkInstrumentType instType; | ||
| if (res >= 0) | ||
| { | ||
| // Return the actual opened connection | ||
| res = cbSdkGetType(INST, &conType, &instType); | ||
| if (res != CBSDKRESULT_SUCCESS) | ||
| printf("Unable to determine connection type\n"); | ||
| handleResult(res); | ||
| // if (instType == CBSDKINSTRUMENT_NPLAY || instType == CBSDKINSTRUMENT_REMOTENPLAY) | ||
| // printf("Unable to open UDP interface to nPlay\n"); | ||
|
|
||
|
|
||
| if (conType < 0 || conType > CBSDKCONNECTION_CLOSED) | ||
| conType = CBSDKCONNECTION_COUNT; | ||
| if (instType < 0 || instType > CBSDKINSTRUMENT_COUNT) | ||
| instType = CBSDKINSTRUMENT_COUNT; | ||
|
|
||
| char strConnection[CBSDKCONNECTION_COUNT + 1][8] = {"Default", "Central", "Udp", "Closed", "Unknown"}; | ||
| char strInstrument[CBSDKINSTRUMENT_COUNT + 1][13] = {"NSP", "nPlay", "Local NSP", "Remote nPlay", "Unknown"}; | ||
|
|
||
| // Now that we are open, get the version again. | ||
| ver = testGetVersion(); | ||
|
|
||
| // Summary results. | ||
| printf("%s real-time interface to %s (%d.%02d.%02d.%02d) successfully initialized\n", strConnection[conType], strInstrument[instType], ver.nspmajor, ver.nspminor, ver.nsprelease, ver.nspbeta); | ||
| } | ||
|
|
||
| return res; | ||
| } | ||
|
|
||
| // Author & Date: Ehsan Azar 25 Oct 2012 | ||
| // Purpose: Test closing the library | ||
| cbSdkResult testClose(void) | ||
| { | ||
| cbSdkResult res = cbSdkClose(INST); | ||
| if (res == CBSDKRESULT_SUCCESS) | ||
| { | ||
| printf("Interface closed successfully\n"); | ||
| } | ||
| else | ||
| { | ||
| printf("Unable to close interface.\n"); | ||
| handleResult(res); | ||
| } | ||
| return res; | ||
| } | ||
|
|
||
| ///////////////////////////////////////////////////////////////////////////// | ||
| // The test suit main entry | ||
| int main(int argc, char *argv[]) | ||
| { | ||
| LPCSTR inst_ip = cbNET_UDP_ADDR_CNT; | ||
| int inst_port = cbNET_UDP_PORT_CNT; | ||
| LPCSTR client_ip = ""; | ||
| if (argc < 2) { | ||
| std::cerr << "Usage: " << argv[0] << " <filename.ccf>" << std::endl; | ||
| return 1; | ||
| } | ||
| if (argc > 2) {inst_ip = argv[2];} | ||
| if (argc > 3) {inst_port = strtol(argv[3], NULL, 10);} | ||
| cbSdkResult res; | ||
| res = testOpen(inst_ip, inst_port, client_ip); | ||
| handleResult(res); | ||
|
|
||
| cbSdkCCF data; | ||
| res = cbSdkReadCCF( | ||
| INST, | ||
| &data, | ||
| argv[1], | ||
| true, | ||
| true, | ||
| false | ||
| ); | ||
| handleResult(res); | ||
|
|
||
| if (res == CBSDKRESULT_SUCCESS) | ||
| printf("cbSdkReadCCF successfully read %s with CCF format version %d.\n", argv[1], data.ccfver); | ||
| else | ||
| printf("cbSdkReadCCF failed to read %s.\n", argv[1]); | ||
|
|
||
| res = testClose(); | ||
| if (res < 0) | ||
| printf("testClose failed (%d)!\n", res); | ||
| else | ||
| printf("testClose succeeded\n"); | ||
|
|
||
| return 0; | ||
| } |