URL
https://opencores.org/ocsvn/plasma/plasma/trunk
Subversion Repositories plasma
Compare Revisions
- This comparison shows the changes necessary to convert path
/
- from Rev 303 to Rev 304
- ↔ Reverse comparison
Rev 303 → Rev 304
/trunk/kernel/tcpip.c
624,7 → 624,7
static int IPProcessTCPPacket(IPFrame *frameIn) |
{ |
uint32 seq, ack; |
int length, ip_length, bytes, rc=0; |
int length, ip_length, bytes, rc=0, notify=0; |
IPSocket *socket, *socketNew; |
IPFrame *frameOut, *frame2, *framePrev; |
uint8 *packet, *packetOut; |
700,6 → 700,8
SocketHead->prev = socketNew; |
SocketHead = socketNew; |
OS_MutexPost(IPMutex); |
if(socketNew->funcPtr) |
OS_Job(socketNew->funcPtr, socketNew, 0, 0); |
return 0; |
} |
} |
789,6 → 791,7
//Check if RST flag set |
if(packet[TCP_FLAGS] & TCP_FLAGS_RST) |
{ |
notify = 1; |
if(socket->state == IP_FIN_SERVER) |
IPClose2(socket); |
else if(socket->state == IP_TCP) |
798,6 → 801,7
else if(socket->ack == seq && bytes > 0) |
{ |
//Insert packet into socket linked list |
notify = 1; |
if(socket->timeout) |
socket->timeout = socket->timeoutReset; |
if(IPVerbose) |
837,6 → 841,7
//Check if FIN flag set |
if(packet[TCP_FLAGS] & TCP_FLAGS_FIN) |
{ |
notify = 1; |
socket->timeout = SOCKET_TIMEOUT; |
if(IPVerbose) |
printf("F"); |
854,7 → 859,7
} |
|
//Notify application |
if(socket->funcPtr) |
if(socket->funcPtr && notify) |
OS_Job(socket->funcPtr, socket, 0, 0); |
return rc; |
} |
/trunk/kernel/rtos.c
905,8 → 905,6
{ |
jobQueue = OS_MQueueCreate("job", 100, 16); |
jobThread = OS_ThreadCreate("job", JobThread, NULL, 150, 4000); |
OS_ThreadCreate("job2", JobThread, NULL, 150, 4000); |
OS_ThreadCreate("job3", JobThread, NULL, 150, 4000); |
} |
OS_SemaphorePost(SemaphoreLock); |
|
914,12 → 912,7
message[1] = (uint32)arg0; |
message[2] = (uint32)arg1; |
message[3] = (uint32)arg2; |
do |
{ |
rc = OS_MQueueSend(jobQueue, message); |
if(rc) |
OS_ThreadSleep(1); |
} while(rc); |
rc = OS_MQueueSend(jobQueue, message); |
} |
|
|