#include "io_packets_p.h"
#include <gwenhywfar/iolayer_be.h>
#include <gwenhywfar/iorequest_be.h>
#include <gwenhywfar/iomanager.h>
#include <gwenhywfar/io_buffered.h>
#include "i18n_l.h"
#include <gwenhywfar/misc.h>
#include <gwenhywfar/debug.h>
#include <gwenhywfar/gui.h>
#include <gwenhywfar/text.h>
#include <assert.h>
#include <ctype.h>
Go to the source code of this file.
void GWEN_Io_LayerPackets_Abort | ( | GWEN_IO_LAYER * | io | ) |
Definition at line 322 of file io_packets.c.
References GWEN_ERROR_ABORTED, GWEN_INHERIT_GETDATA, GWEN_Io_Layer_DelRequest(), GWEN_Io_Layer_GetBaseLayer(), GWEN_Io_Layer_SetStatus(), GWEN_Io_Layer_StatusDisconnected, GWEN_Io_Request_Finished(), GWEN_Io_Request_free(), GWEN_Io_Request_List_Del(), GWEN_Io_Request_List_First(), GWEN_Io_Request_StatusFinished, and NULL.
Referenced by GWEN_Io_LayerPackets_AddRequest(), GWEN_Io_LayerPackets_freeData(), GWEN_Io_LayerPackets_WorkOnReadRequests(), and GWEN_Io_LayerPackets_WorkOnWriteRequests().
int GWEN_Io_LayerPackets_AddRequest | ( | GWEN_IO_LAYER * | io, | |
GWEN_IO_REQUEST * | r | |||
) |
Definition at line 142 of file io_packets.c.
References DBG_INFO, GWEN_ERROR_NOT_OPEN, GWEN_ERROR_NOT_SUPPORTED, GWEN_ERROR_TRY_AGAIN, GWEN_INHERIT_GETDATA, GWEN_Io_Layer_GetFlags(), GWEN_Io_Layer_GetStatus(), GWEN_Io_Layer_SetStatus(), GWEN_Io_Layer_StatusConnected, GWEN_Io_Layer_StatusDisconnected, GWEN_Io_Layer_StatusUnconnected, GWEN_Io_LayerPackets_Abort(), GWEN_Io_Request_Attach(), GWEN_Io_Request_Finished(), GWEN_Io_Request_GetFlags(), GWEN_Io_Request_GetType(), GWEN_Io_Request_List_Add(), GWEN_Io_Request_List_Clear(), GWEN_Io_Request_List_GetCount(), GWEN_Io_Request_StatusFinished, GWEN_Io_Request_TypeConnect, GWEN_Io_Request_TypeDisconnect, GWEN_Io_Request_TypeRead, GWEN_Io_Request_TypeWrite, GWEN_Io_RequestType_toString(), and GWEN_LOGDOMAIN.
Referenced by GWEN_Io_LayerPackets_new().
int GWEN_Io_LayerPackets_DelRequest | ( | GWEN_IO_LAYER * | io, | |
GWEN_IO_REQUEST * | r | |||
) |
Definition at line 214 of file io_packets.c.
References DBG_INFO, GWEN_ERROR_NOT_FOUND, GWEN_INHERIT_GETDATA, GWEN_Io_Layer_DelRequest(), GWEN_Io_Layer_GetBaseLayer(), GWEN_Io_Request_GetType(), GWEN_Io_Request_List_Del(), GWEN_Io_Request_TypeWrite, GWEN_LOGDOMAIN, and NULL.
Referenced by GWEN_Io_LayerPackets_new().
GWENHYWFAR_CB void GWEN_Io_LayerPackets_freeData | ( | void * | bp, | |
void * | p | |||
) |
Definition at line 69 of file io_packets.c.
References GWEN_FREE_OBJECT, GWEN_Io_LayerPackets_Abort(), and GWEN_Io_Request_List_free().
Referenced by GWEN_Io_LayerPackets_new().
int GWEN_Io_LayerPackets_GetMaxReadQueue | ( | const GWEN_IO_LAYER * | io | ) |
int GWEN_Io_LayerPackets_GetMaxWriteQueue | ( | const GWEN_IO_LAYER * | io | ) |
int GWEN_Io_LayerPackets_GetReadRequest | ( | GWEN_IO_LAYER * | io, | |
GWEN_IO_REQUEST ** | pRequest, | |||
uint32_t | guiid, | |||
int | msecs | |||
) |
Definition at line 85 of file io_packets.c.
References DBG_INFO, GWEN_ERROR_IO, GWEN_ERROR_TIMEOUT, GWEN_INHERIT_GETDATA, GWEN_Io_LayerPackets_WorkOnReadRequests(), GWEN_Io_Manager_WaitForRequest(), GWEN_Io_Request_GetGuiId(), GWEN_Io_Request_List_Del(), GWEN_Io_Request_List_First(), GWEN_Io_Request_SetGuiId(), GWEN_LOGDOMAIN, GWEN_TIMEOUT_NONE, and NULL.
Referenced by GWEN_IpcManager__Work().
int GWEN_Io_LayerPackets_GetReadSize | ( | const GWEN_IO_LAYER * | io | ) |
int GWEN_Io_LayerPackets_HasReadRequests | ( | const GWEN_IO_LAYER * | io | ) |
Definition at line 539 of file io_packets.c.
References GWEN_INHERIT_GETDATA, and GWEN_Io_Request_List_GetCount().
Referenced by GWEN_IpcManager__Work().
int GWEN_Io_LayerPackets_HasWaitingRequests | ( | GWEN_IO_LAYER * | io | ) |
Definition at line 521 of file io_packets.c.
References GWEN_INHERIT_GETDATA, and GWEN_Io_Request_List_GetCount().
Referenced by GWEN_Io_LayerPackets_new().
GWEN_IO_LAYER* GWEN_Io_LayerPackets_new | ( | GWEN_IO_LAYER * | baseLayer | ) |
Definition at line 42 of file io_packets.c.
References GWEN_INHERIT_SETDATA, GWEN_Io_Layer_new(), GWEN_IO_LAYER_PACKETS_DEFAULT_READQUEUE, GWEN_IO_LAYER_PACKETS_DEFAULT_READSIZE, GWEN_IO_LAYER_PACKETS_DEFAULT_WRITEQUEUE, GWEN_IO_LAYER_PACKETS_TYPE, GWEN_Io_Layer_SetAddRequestFn(), GWEN_Io_Layer_SetDelRequestFn(), GWEN_Io_Layer_SetHasWaitingRequestsFn(), GWEN_Io_Layer_SetWorkOnRequestsFn(), GWEN_Io_LayerPackets_AddRequest(), GWEN_Io_LayerPackets_DelRequest(), GWEN_Io_LayerPackets_freeData(), GWEN_Io_LayerPackets_HasWaitingRequests(), GWEN_Io_LayerPackets_WorkOnRequests(), GWEN_Io_Request_List_new(), and GWEN_NEW_OBJECT.
Referenced by GWEN_Io_LayerPackets_WorkOnRequests(), GWEN_IpcManager_AddClient(), and GWEN_IpcManager_AddServer().
void GWEN_Io_LayerPackets_SetMaxReadQueue | ( | GWEN_IO_LAYER * | io, | |
int | i | |||
) |
void GWEN_Io_LayerPackets_SetMaxWriteQueue | ( | GWEN_IO_LAYER * | io, | |
int | i | |||
) |
void GWEN_Io_LayerPackets_SetReadSize | ( | GWEN_IO_LAYER * | io, | |
int | i | |||
) |
GWEN_IO_LAYER_WORKRESULT GWEN_Io_LayerPackets_WorkOnReadRequests | ( | GWEN_IO_LAYER * | io | ) |
Definition at line 357 of file io_packets.c.
References DBG_INFO, DBG_WARN, GWEN_ERROR_EOF, GWEN_ERROR_TRY_AGAIN, GWEN_INHERIT_GETDATA, GWEN_Io_Layer_AddRequest(), GWEN_Io_Layer_GetBaseLayer(), GWEN_Io_Layer_GetStatus(), GWEN_Io_Layer_StatusConnected, GWEN_Io_Layer_WorkResultBlocking, GWEN_Io_Layer_WorkResultOk, GWEN_Io_LayerPackets_Abort(), GWEN_Io_Request_AddFlags(), GWEN_IO_REQUEST_FLAGS_PACKETBEGIN, GWEN_IO_REQUEST_FLAGS_PACKETEND, GWEN_IO_REQUEST_FLAGS_TAKEOVER, GWEN_Io_Request_free(), GWEN_Io_Request_GetFlags(), GWEN_Io_Request_GetResultCode(), GWEN_Io_Request_GetStatus(), GWEN_Io_Request_List_Add(), GWEN_Io_Request_List_GetCount(), GWEN_Io_Request_new(), GWEN_Io_Request_StatusFinished, GWEN_Io_Request_TypeRead, GWEN_LOGDOMAIN, and NULL.
Referenced by GWEN_Io_LayerPackets_GetReadRequest(), and GWEN_Io_LayerPackets_WorkOnRequests().
GWEN_IO_LAYER_WORKRESULT GWEN_Io_LayerPackets_WorkOnRequests | ( | GWEN_IO_LAYER * | io | ) |
Definition at line 483 of file io_packets.c.
References GWEN_INHERIT_GETDATA, GWEN_Io_Layer_AddIncomingLayer(), GWEN_Io_Layer_GetBaseLayer(), GWEN_Io_Layer_GetNextIncomingLayer(), GWEN_Io_Layer_GetStatus(), GWEN_Io_Layer_StatusListening, GWEN_Io_Layer_WorkOnRequests(), GWEN_Io_Layer_WorkResultBlocking, GWEN_Io_Layer_WorkResultOk, GWEN_Io_LayerPackets_new(), GWEN_Io_LayerPackets_WorkOnReadRequests(), and GWEN_Io_LayerPackets_WorkOnWriteRequests().
Referenced by GWEN_Io_LayerPackets_new().
GWEN_IO_LAYER_WORKRESULT GWEN_Io_LayerPackets_WorkOnWriteRequests | ( | GWEN_IO_LAYER * | io | ) |
Definition at line 432 of file io_packets.c.
References DBG_INFO, DBG_WARN, GWEN_ERROR_TRY_AGAIN, GWEN_INHERIT_GETDATA, GWEN_Io_Layer_AddRequest(), GWEN_Io_Layer_GetBaseLayer(), GWEN_Io_Layer_GetStatus(), GWEN_Io_Layer_StatusConnected, GWEN_Io_Layer_WorkResultBlocking, GWEN_Io_Layer_WorkResultOk, GWEN_Io_LayerPackets_Abort(), GWEN_Io_Request_AddFlags(), GWEN_IO_REQUEST_FLAGS_FLUSH, GWEN_IO_REQUEST_FLAGS_PACKETBEGIN, GWEN_IO_REQUEST_FLAGS_PACKETEND, GWEN_IO_REQUEST_FLAGS_WRITEALL, GWEN_Io_Request_free(), GWEN_Io_Request_GetStatus(), GWEN_Io_Request_List_Del(), GWEN_Io_Request_List_First(), GWEN_Io_Request_StatusFinished, GWEN_LOGDOMAIN, and NULL.
Referenced by GWEN_Io_LayerPackets_WorkOnRequests().