Lines Matching refs:conp
135 static void disableConnection(ConnectionPrivate* conp) in disableConnection() argument
137 if((conp->flags&(CST_OPEN|CST_OPENING)) && in disableConnection()
138 !(conp->flags&(CST_NOTIFIED))) { in disableConnection()
139 conp->flags|=CST_NOTIFIED; in disableConnection()
140 sendDisconnect(conp->lap,conp->remoteSel,conp->localSel,REASON_USER); in disableConnection()
143 if(conp->sarBuffer) { in disableConnection()
144 freeMem(conp->sarBuffer); in disableConnection()
145 conp->sarBuffer=0; in disableConnection()
148 while(conp->sendHead) { in disableConnection()
149 SendBuf* sb=conp->sendHead; in disableConnection()
150 conp->sendHead=sb->next; in disableConnection()
154 if(conp->flags&(CST_OPENING|CST_OPEN)) { in disableConnection()
155 conp->flags&=~(CST_OPENING|CST_OPEN); in disableConnection()
156 if(conp->con.status) conp->con.status(&conp->con,CONN_CLOSED,0,0); in disableConnection()
160 static void freeConnection(ConnectionPrivate* conp) in freeConnection() argument
162 LAPPrivate* lapp=conp->lap; in freeConnection()
167 if(c==conp) { in freeConnection()
175 if(lapp->nextConn==conp) lapp->nextConn=0; in freeConnection()
176 freeMem(conp); in freeConnection()
343 ConnectionPrivate* conp; in lmData() local
356 for(conp=lapp->connections;conp;conp=conp->next) in lmData()
357 if((conp->flags&(CST_OPENING|CST_OPEN)) && in lmData()
358 conp->localSel==dlsap && in lmData()
359 conp->remoteSel==slsap) break; in lmData()
371 lsapControl(lapp,dlsap,slsap,opcode,conp,buf+4,len-4); in lmData()
379 } else if(!conp) { in lmData()
382 if(!(conp->flags&LM_TINY_TP)) { in lmData()
383 if(conp->con.data) conp->con.data(&conp->con,buf+2,len-2); in lmData()
385 if(conp->flags&CST_OPEN) { in lmData()
386 conp->sendCredits+=buf[2]&~TTP_M; in lmData()
388 if(conp->recvCredits>0) conp->recvCredits--; in lmData()
389 if(!conp->recvSduSize) { in lmData()
390 if(conp->con.data) conp->con.data(&conp->con,buf+3,len-3); in lmData()
391 } else if(conp->sarLength+len-3>conp->recvSduSize) { in lmData()
392 sendDisconnect(conp->lap,conp->remoteSel,conp->localSel,REASON_LINK_MANAGEMENT); in lmData()
393 disableConnection(conp); in lmData()
396 memcpy(conp->sarBuffer+conp->sarLength,buf+3,len-3); in lmData()
397 conp->sarLength+=len-3; in lmData()
398 } else if(conp->sarLength) { in lmData()
399 memcpy(conp->sarBuffer+conp->sarLength,buf+3,len-3); in lmData()
400 conp->sarLength+=len-3; in lmData()
401 if(conp->con.data) conp->con.data(&conp->con,conp->sarBuffer,conp->sarLength); in lmData()
402 conp->sarLength=0; in lmData()
404 if(conp->con.data) conp->con.data(&conp->con,buf+3,len-3); in lmData()
533 ConnectionPrivate* conp=(ConnectionPrivate*)con; in connClose() local
535 conp->con.status=0; in connClose()
536 disableConnection(conp); in connClose()
537 freeConnection(conp); in connClose()
542 ConnectionPrivate* conp=(ConnectionPrivate*)con; in connGetSendDataSize() local
543 return conp->sendSduSize ? conp->sendSduSize : conp->sendDataSize; in connGetSendDataSize()
548 ConnectionPrivate* conp=(ConnectionPrivate*)con; in connGetRecvDataSize() local
549 return conp->recvSduSize ? conp->recvSduSize : conp->recvDataSize; in connGetRecvDataSize()
555 ConnectionPrivate* conp=(ConnectionPrivate*)con; in connWrite() local
556 int ttp=conp->flags&LM_TINY_TP ? 1 : 0; in connWrite()
558 if(!(conp->flags&(CST_OPENING|CST_OPEN))) return FALSE; in connWrite()
560 if(len>(conp->sendSduSize ? conp->sendSduSize : conp->sendDataSize)) { in connWrite()
566 int len1=len<conp->sendDataSize ? len : conp->sendDataSize; in connWrite()
568 sb->buf[2]=conp->remoteSel; in connWrite()
569 sb->buf[3]=conp->localSel; in connWrite()
572 if(conp->sendHead) conp->sendTail->next=sb; in connWrite()
573 else conp->sendHead=sb; in connWrite()
574 conp->sendTail=sb; in connWrite()
587 ConnectionPrivate* conp=(ConnectionPrivate*)con; in connWrite2() local
588 int ttp=conp->flags&LM_TINY_TP ? 1 : 0; in connWrite2()
590 if(!(conp->flags&(CST_OPENING|CST_OPEN))) return FALSE; in connWrite2()
592 if(len1+len2>(conp->sendSduSize ? conp->sendSduSize : conp->sendDataSize)) { in connWrite2()
598 int len1x=len1<conp->sendDataSize ? len1 : conp->sendDataSize; in connWrite2()
599 int len2x=len2<conp->sendDataSize-len1x ? len2 : conp->sendDataSize-len1x; in connWrite2()
601 sb->buf[2]=conp->remoteSel; in connWrite2()
602 sb->buf[3]=conp->localSel; in connWrite2()
606 if(conp->sendHead) conp->sendTail->next=sb; in connWrite2()
607 else conp->sendHead=sb; in connWrite2()
608 conp->sendTail=sb; in connWrite2()