Lines Matching refs:packet
115 void (*free)(OutgoingPacket* packet);
265 static void outgoingPacketFree(OutgoingPacket* packet) { in outgoingPacketFree() argument
267 free(packet); in outgoingPacketFree()
635 OutgoingPacket* packet = NULL; in peerProxyGetOrCreate() local
637 packet = calloc(1, sizeof(OutgoingPacket)); in peerProxyGetOrCreate()
638 if (packet == NULL) { in peerProxyGetOrCreate()
643 packet->header.type = CONNECTION_REQUEST; in peerProxyGetOrCreate()
644 packet->header.credentials = credentials; in peerProxyGetOrCreate()
645 packet->free = &outgoingPacketFree; in peerProxyGetOrCreate()
650 free(packet); in peerProxyGetOrCreate()
657 peerProxyEnqueueOutgoingPacket(masterProxy, packet); in peerProxyGetOrCreate()
802 static void outgoingPacketFreeSocket(OutgoingPacket* packet) { in outgoingPacketFreeSocket() argument
803 closeWithWarning(packet->socket); in outgoingPacketFreeSocket()
804 outgoingPacketFree(packet); in outgoingPacketFreeSocket()
853 OutgoingPacket* packet = calloc(1, sizeof(OutgoingPacket)); in masterReportConnectionError() local
854 if (packet == NULL) { in masterReportConnectionError()
860 packet->header.type = CONNECTION_ERROR; in masterReportConnectionError()
861 packet->header.credentials = credentials; in masterReportConnectionError()
862 packet->free = &outgoingPacketFree; in masterReportConnectionError()
864 peerProxyLockAndEnqueueOutgoingPacket(peerProxy, packet); in masterReportConnectionError()
1120 static void outgoingPacketFreeBytes(OutgoingPacket* packet) { in outgoingPacketFreeBytes() argument
1122 bufferFree(packet->bytes); in outgoingPacketFreeBytes()
1123 free(packet); in outgoingPacketFreeBytes()
1137 OutgoingPacket* packet = calloc(1, sizeof(OutgoingPacket)); in peerSendBytes() local
1138 if (packet == NULL) { in peerSendBytes()
1145 free(packet); in peerSendBytes()
1154 packet->bytes = copy; in peerSendBytes()
1155 packet->header.type = BYTES; in peerSendBytes()
1156 packet->header.size = size; in peerSendBytes()
1157 packet->free = outgoingPacketFreeBytes; in peerSendBytes()
1158 bufferPrepareForWrite(packet->bytes); in peerSendBytes()
1167 packet->free(packet); in peerSendBytes()
1170 peerProxyEnqueueOutgoingPacket(peerProxy, packet); in peerSendBytes()
1184 static void outgoingPacketFreeSharedBytes(OutgoingPacket* packet) { in outgoingPacketFreeSharedBytes() argument
1186 = (SharedBytesFreer*) packet->context; in outgoingPacketFreeSharedBytes()
1189 free(packet); in outgoingPacketFreeSharedBytes()
1205 OutgoingPacket* packet = calloc(1, sizeof(OutgoingPacket)); in peerSendSharedBytes() local
1206 if (packet == NULL) { in peerSendSharedBytes()
1213 free(packet); in peerSendSharedBytes()
1220 free(packet); in peerSendSharedBytes()
1228 packet->bytes = wrapper; in peerSendSharedBytes()
1229 packet->context = sharedBytesFreer; in peerSendSharedBytes()
1230 packet->header.type = BYTES; in peerSendSharedBytes()
1231 packet->header.size = size; in peerSendSharedBytes()
1232 packet->free = &outgoingPacketFreeSharedBytes; in peerSendSharedBytes()
1233 bufferPrepareForWrite(packet->bytes); in peerSendSharedBytes()
1242 packet->free(packet); in peerSendSharedBytes()
1245 peerProxyEnqueueOutgoingPacket(peerProxy, packet); in peerSendSharedBytes()