#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().
1.5.6