mirror of
https://github.com/slsdetectorgroup/slsDetectorPackage.git
synced 2025-04-28 09:10:01 +02:00
strtok is not thread safe..used to set receiver udp ip etc to detector, fixed
This commit is contained in:
Dhanya Maliakal
parent
5c230e2ac5
commit
65f5e1c1ab
@ -6041,151 +6041,175 @@ int slsDetector::setUDPConnection(){
|
|||||||
|
|
||||||
|
|
||||||
int slsDetector::configureMAC(){
|
int slsDetector::configureMAC(){
|
||||||
int i;
|
int i;
|
||||||
int ret=FAIL;
|
int ret=FAIL;
|
||||||
int fnum=F_CONFIGURE_MAC,fnum2=F_RECEIVER_SHORT_FRAME;
|
int fnum=F_CONFIGURE_MAC,fnum2=F_RECEIVER_SHORT_FRAME;
|
||||||
char mess[MAX_STR_LENGTH]="";
|
char mess[MAX_STR_LENGTH]="";
|
||||||
char arg[6][50]={"","","","","",""};
|
char arg[6][50]={"","","","","",""};
|
||||||
char cword[50]="", *pcword;
|
int retval=-1;
|
||||||
string sword;
|
|
||||||
int retval=-1;
|
|
||||||
|
|
||||||
|
|
||||||
//if udpip wasnt initialized in config file
|
//if udpip wasnt initialized in config file
|
||||||
if(!(strcmp(thisDetector->receiverUDPIP,"none"))){
|
if(!(strcmp(thisDetector->receiverUDPIP,"none"))){
|
||||||
//hostname is an ip address
|
//hostname is an ip address
|
||||||
if(strchr(thisDetector->receiver_hostname,'.')!=NULL)
|
if(strchr(thisDetector->receiver_hostname,'.')!=NULL)
|
||||||
strcpy(thisDetector->receiverUDPIP,thisDetector->receiver_hostname);
|
strcpy(thisDetector->receiverUDPIP,thisDetector->receiver_hostname);
|
||||||
//if hostname not ip, convert it to ip
|
//if hostname not ip, convert it to ip
|
||||||
else{
|
else{
|
||||||
struct hostent *he = gethostbyname(thisDetector->receiver_hostname);
|
struct hostent *he = gethostbyname(thisDetector->receiver_hostname);
|
||||||
if (he != NULL)
|
if (he != NULL)
|
||||||
strcpy(thisDetector->receiverUDPIP,inet_ntoa(*(struct in_addr*)he->h_addr));
|
strcpy(thisDetector->receiverUDPIP,inet_ntoa(*(struct in_addr*)he->h_addr));
|
||||||
else{
|
else{
|
||||||
std::cout << "configure mac failed. no rx_udpip given and invalid receiver hostname" << endl;
|
std::cout << "configure mac failed. no rx_udpip given and invalid receiver hostname" << endl;
|
||||||
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
||||||
return FAIL;
|
return FAIL;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
strcpy(arg[0],thisDetector->receiverUDPIP);
|
|
||||||
strcpy(arg[1],thisDetector->receiverUDPMAC);
|
|
||||||
sprintf(arg[2],"%x",thisDetector->receiverUDPPort);
|
|
||||||
strcpy(arg[3],thisDetector->detectorMAC);
|
|
||||||
strcpy(arg[4],thisDetector->detectorIP);
|
|
||||||
sprintf(arg[5],"%x",thisDetector->receiverUDPPort2);
|
|
||||||
|
|
||||||
#ifdef VERBOSE
|
|
||||||
std::cout<< "Configuring MAC"<< std::endl;
|
|
||||||
#endif
|
|
||||||
|
|
||||||
|
|
||||||
for(i=0;i<2;i++){
|
|
||||||
if(!strcmp(arg[i],"none")){
|
|
||||||
std::cout<< "Configure MAC Error. IP/MAC Addresses not set"<< std::endl;
|
|
||||||
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
|
||||||
return FAIL;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#ifdef VERBOSE
|
|
||||||
std::cout<< "IP/MAC Addresses valid "<< std::endl;
|
|
||||||
#endif
|
|
||||||
|
|
||||||
//converting IPaddress to hex.
|
|
||||||
pcword = strtok (arg[0],".");
|
|
||||||
while (pcword != NULL) {
|
|
||||||
sprintf(arg[0],"%02x",atoi(pcword));
|
|
||||||
strcat(cword,arg[0]);
|
|
||||||
pcword = strtok (NULL, ".");
|
|
||||||
}
|
|
||||||
strcpy(arg[0],cword);
|
|
||||||
#ifdef VERBOSE
|
|
||||||
std::cout<<"receiver udp ip:"<<arg[0]<<"."<<std::endl;
|
|
||||||
#endif
|
|
||||||
//converting MACaddress to hex.
|
|
||||||
sword.assign(arg[1]);
|
|
||||||
strcpy(arg[1],"");
|
|
||||||
stringstream sstr(sword);
|
|
||||||
while(getline(sstr,sword,':'))
|
|
||||||
strcat(arg[1],sword.c_str());
|
|
||||||
#ifdef VERBOSE
|
|
||||||
std::cout<<"receiver mac:"<<arg[1]<<"."<<std::endl;
|
|
||||||
#endif
|
|
||||||
#ifdef VERBOSE
|
|
||||||
std::cout<<"receiver udp port:"<<arg[2]<<"."<<std::endl;
|
|
||||||
#endif
|
|
||||||
//converting server MACaddress to hex.
|
|
||||||
sword.assign(arg[3]);
|
|
||||||
strcpy(arg[3],"");
|
|
||||||
stringstream ssstr(sword);
|
|
||||||
while(getline(ssstr,sword,':'))
|
|
||||||
strcat(arg[3],sword.c_str());
|
|
||||||
#ifdef VERBOSE
|
|
||||||
std::cout<<"detecotor mac:"<<arg[3]<<"."<<std::endl;
|
|
||||||
#endif
|
|
||||||
//converting IPaddress to hex.
|
|
||||||
strcpy(cword,"");
|
|
||||||
pcword = strtok (arg[4],".");
|
|
||||||
while (pcword != NULL) {
|
|
||||||
sprintf(arg[4],"%02x",atoi(pcword));
|
|
||||||
strcat(cword,arg[4]);
|
|
||||||
pcword = strtok (NULL, ".");
|
|
||||||
}
|
|
||||||
strcpy(arg[4],cword);
|
|
||||||
#ifdef VERBOSE
|
|
||||||
std::cout<<"detector ip:"<<arg[4]<<"."<<std::endl;
|
|
||||||
#endif
|
|
||||||
#ifdef VERBOSE
|
|
||||||
std::cout<<"receiver udp port2:"<<arg[5]<<"."<<std::endl;
|
|
||||||
#endif
|
|
||||||
|
|
||||||
//send to server
|
|
||||||
if (thisDetector->onlineFlag==ONLINE_FLAG) {
|
|
||||||
if (connectControl() == OK){
|
|
||||||
controlSocket->SendDataOnly(&fnum,sizeof(fnum));
|
|
||||||
controlSocket->SendDataOnly(arg,sizeof(arg));
|
|
||||||
controlSocket->ReceiveDataOnly(&ret,sizeof(ret));
|
|
||||||
if (ret==FAIL){
|
|
||||||
controlSocket->ReceiveDataOnly(mess,sizeof(mess));
|
|
||||||
std::cout<< "Detector returned error: " << mess << std::endl;
|
|
||||||
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
|
||||||
}
|
|
||||||
else
|
|
||||||
controlSocket->ReceiveDataOnly(&retval,sizeof(retval));
|
|
||||||
disconnectControl();
|
|
||||||
if (ret==FORCE_UPDATE)
|
|
||||||
updateDetector();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (ret==FAIL) {
|
|
||||||
ret=FAIL;
|
|
||||||
std::cout<< "Configuring MAC failed " << std::endl;
|
|
||||||
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
|
||||||
}
|
|
||||||
else if (thisDetector->myDetectorType==GOTTHARD){
|
|
||||||
//set frames per file - only for gotthard
|
|
||||||
pthread_mutex_lock(&ms);
|
|
||||||
if(retval==-1)
|
|
||||||
setFramesPerFile(MAX_FRAMES_PER_FILE);
|
|
||||||
else
|
|
||||||
setFramesPerFile(SHORT_MAX_FRAMES_PER_FILE);
|
|
||||||
pthread_mutex_unlock(&ms);
|
|
||||||
//connect to receiver
|
|
||||||
if(thisDetector->receiverOnlineFlag==ONLINE_FLAG){
|
|
||||||
#ifdef VERBOSE
|
|
||||||
std::cout << "Sending adc val to receiver " << retval << std::endl;
|
|
||||||
#endif
|
|
||||||
if (connectData() == OK){
|
|
||||||
ret=thisReceiver->sendInt(fnum2,retval,retval);
|
|
||||||
disconnectData();
|
|
||||||
}
|
}
|
||||||
if(ret==FAIL)
|
strcpy(arg[0],thisDetector->receiverUDPIP);
|
||||||
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
strcpy(arg[1],thisDetector->receiverUDPMAC);
|
||||||
}
|
sprintf(arg[2],"%x",thisDetector->receiverUDPPort);
|
||||||
}
|
strcpy(arg[3],thisDetector->detectorMAC);
|
||||||
|
strcpy(arg[4],thisDetector->detectorIP);
|
||||||
|
sprintf(arg[5],"%x",thisDetector->receiverUDPPort2);
|
||||||
|
|
||||||
return ret;
|
#ifdef VERBOSE
|
||||||
|
std::cout<< "Configuring MAC"<< std::endl;
|
||||||
|
#endif
|
||||||
|
|
||||||
|
|
||||||
|
for(i=0;i<2;i++){
|
||||||
|
if(!strcmp(arg[i],"none")){
|
||||||
|
std::cout<< "Configure MAC Error. IP/MAC Addresses not set"<< std::endl;
|
||||||
|
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
||||||
|
return FAIL;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#ifdef VERBOSE
|
||||||
|
std::cout<< "IP/MAC Addresses valid "<< std::endl;
|
||||||
|
#endif
|
||||||
|
|
||||||
|
|
||||||
|
{
|
||||||
|
//converting IPaddress to hex
|
||||||
|
stringstream ss(arg[0]);
|
||||||
|
char cword[50]="";
|
||||||
|
bzero(cword, 50);
|
||||||
|
string s;
|
||||||
|
while (getline(ss, s, '.')) {
|
||||||
|
sprintf(cword,"%s%02x",cword,atoi(s.c_str()));
|
||||||
|
}
|
||||||
|
bzero(arg[0], 50);
|
||||||
|
strcpy(arg[0],cword);
|
||||||
|
#ifdef VERBOSE
|
||||||
|
std::cout<<"receiver udp ip:"<<arg[0]<<"."<<std::endl;
|
||||||
|
#endif
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
{
|
||||||
|
//converting MACaddress to hex
|
||||||
|
stringstream ss(arg[1]);
|
||||||
|
char cword[50]="";
|
||||||
|
bzero(cword, 50);
|
||||||
|
string s;
|
||||||
|
while (getline(ss, s, ':')) {
|
||||||
|
sprintf(cword,"%s%s",cword,s.c_str());
|
||||||
|
}
|
||||||
|
bzero(arg[1], 50);
|
||||||
|
strcpy(arg[1],cword);
|
||||||
|
#ifdef VERBOSE
|
||||||
|
std::cout<<"receiver mac:"<<arg[1]<<"."<<std::endl;
|
||||||
|
#endif
|
||||||
|
}
|
||||||
|
|
||||||
|
#ifdef VERBOSE
|
||||||
|
std::cout<<"receiver udp port:"<<arg[2]<<"."<<std::endl;
|
||||||
|
#endif
|
||||||
|
|
||||||
|
{
|
||||||
|
stringstream ss(arg[3]);
|
||||||
|
char cword[50]="";
|
||||||
|
bzero(cword, 50);
|
||||||
|
string s;
|
||||||
|
while (getline(ss, s, ':')) {
|
||||||
|
sprintf(cword,"%s%s",cword,s.c_str());
|
||||||
|
}
|
||||||
|
bzero(arg[3], 50);
|
||||||
|
strcpy(arg[3],cword);
|
||||||
|
#ifdef VERBOSE
|
||||||
|
std::cout<<"detecotor mac:"<<arg[3]<<"."<<std::endl;
|
||||||
|
#endif
|
||||||
|
}
|
||||||
|
|
||||||
|
{
|
||||||
|
//converting IPaddress to hex
|
||||||
|
stringstream ss(arg[4]);
|
||||||
|
char cword[50]="";
|
||||||
|
bzero(cword, 50);
|
||||||
|
string s;
|
||||||
|
while (getline(ss, s, '.')) {
|
||||||
|
sprintf(cword,"%s%02x",cword,atoi(s.c_str()));
|
||||||
|
}
|
||||||
|
bzero(arg[4], 50);
|
||||||
|
strcpy(arg[4],cword);
|
||||||
|
#ifdef VERBOSE
|
||||||
|
std::cout<<"detector ip:"<<arg[4]<<"."<<std::endl;
|
||||||
|
#endif
|
||||||
|
}
|
||||||
|
|
||||||
|
#ifdef VERBOSE
|
||||||
|
std::cout<<"receiver udp port2:"<<arg[5]<<"."<<std::endl;
|
||||||
|
#endif
|
||||||
|
|
||||||
|
//send to server
|
||||||
|
if (thisDetector->onlineFlag==ONLINE_FLAG) {
|
||||||
|
if (connectControl() == OK){
|
||||||
|
controlSocket->SendDataOnly(&fnum,sizeof(fnum));
|
||||||
|
controlSocket->SendDataOnly(arg,sizeof(arg));
|
||||||
|
controlSocket->ReceiveDataOnly(&ret,sizeof(ret));
|
||||||
|
if (ret==FAIL){
|
||||||
|
controlSocket->ReceiveDataOnly(mess,sizeof(mess));
|
||||||
|
std::cout<< "Detector returned error: " << mess << std::endl;
|
||||||
|
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
||||||
|
}
|
||||||
|
else
|
||||||
|
controlSocket->ReceiveDataOnly(&retval,sizeof(retval));
|
||||||
|
disconnectControl();
|
||||||
|
if (ret==FORCE_UPDATE)
|
||||||
|
updateDetector();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (ret==FAIL) {
|
||||||
|
ret=FAIL;
|
||||||
|
std::cout<< "Configuring MAC failed " << std::endl;
|
||||||
|
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
||||||
|
}
|
||||||
|
else if (thisDetector->myDetectorType==GOTTHARD){
|
||||||
|
//set frames per file - only for gotthard
|
||||||
|
pthread_mutex_lock(&ms);
|
||||||
|
if(retval==-1)
|
||||||
|
setFramesPerFile(MAX_FRAMES_PER_FILE);
|
||||||
|
else
|
||||||
|
setFramesPerFile(SHORT_MAX_FRAMES_PER_FILE);
|
||||||
|
pthread_mutex_unlock(&ms);
|
||||||
|
//connect to receiver
|
||||||
|
if(thisDetector->receiverOnlineFlag==ONLINE_FLAG){
|
||||||
|
#ifdef VERBOSE
|
||||||
|
std::cout << "Sending adc val to receiver " << retval << std::endl;
|
||||||
|
#endif
|
||||||
|
if (connectData() == OK){
|
||||||
|
ret=thisReceiver->sendInt(fnum2,retval,retval);
|
||||||
|
disconnectData();
|
||||||
|
}
|
||||||
|
if(ret==FAIL)
|
||||||
|
setErrorMask((getErrorMask())|(COULD_NOT_CONFIGURE_MAC));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return ret;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user