1: mwChannel_new is called. If there is a channel in the outgoing collection in state NEW, then it is returned. Otherwise, a channel is allocated, assigned a unique outgoing id, marked as NEW, and returned.
2: channel is set to INIT status (effectively earmarking it as in- use). fields on the channel can then be set as necessary to prepare it for creation.
3: mwChannel_create is called. The channel is marked to WAIT status and a message is sent to the server. The channel is also marked as inactive as of that moment.
4: the channel is accepted (step 5) or rejected (step 7)
5: an accept message is received from the server, and the channel is marked as OPEN, and the inactive mark is removed. And messages in the in or out queues for that channel are processed. The channel is now ready to be used.
6: data is sent and received over the channel
7: the channel is closed either by receipt of a close message or by local action. If by local action, then a close message is sent to the server. The channel is cleaned up, its queues dumped, and it is set to NEW status to await re-use.
Life-cycle of an incoming channel:
1: a channel create message is received. A channel is allocated and given an id matching the message. It is placed in status WAIT, and marked as inactive as of that moment. The service matching that channel is alerted of the incoming creation request.
2: the service can either accept (step 3) or reject (step 5) the channel
3: mwChannel_accept is called. The channel is marked as OPEN, and an accept message is sent to the server. And messages in the in or out queues for that channel are processed. The channel is now ready to be used.
4: data is sent and received over the channel
5: The channel is closed either by receipt of a close message or by local action. If by local action, then a close message is sent to the server. The channel is cleaned up, its queues dumped, and it is deallocated.
#include <time.h>
#include "mw_common.h"
Go to the source code of this file.
Defines | |
#define | MW_MASTER_CHANNEL_ID 0x00000000 |
special ID indicating the master channel | |
#define | mwChannel_idIsIncoming(id) (! mwChannel_idIsOutgoing(id)) |
non-zero if a channel id appears to be that of an incoming channel | |
#define | mwChannel_idIsOutgoing(id) (! (0x80000000 & (id))) |
non-zero if a channel id appears to be that of an outgoing channel | |
#define | mwChannel_isIncoming(chan) mwChannel_idIsIncoming(mwChannel_getId(chan)) |
non-zero if a channel appears to be an incoming channel | |
#define | mwChannel_isOutgoing(chan) mwChannel_idIsOutgoing(mwChannel_getId(chan)) |
non-zero if a channel appears to be an outgoing channel | |
#define | mwChannel_isState(chan, state) (mwChannel_getState(chan) == (state)) |
Enumerations | |
enum | mwChannelState { mwChannel_NEW, mwChannel_INIT, mwChannel_WAIT, mwChannel_OPEN, mwChannel_DESTROY, mwChannel_ERROR, mwChannel_UNKNOWN } |
channel status More... | |
enum | mwChannelStatField { mwChannelStat_MSG_SENT, mwChannelStat_MSG_RECV, mwChannelStat_U_BYTES_SENT, mwChannelStat_U_BYTES_RECV, mwChannelStat_OPENED_AT, mwChannelStat_CLOSED_AT } |
channel statistic fields. More... | |
enum | mwEncryptPolicy { mwEncrypt_NONE = 0x0000, mwEncrypt_WHATEVER = 0x0001, mwEncrypt_ALL = 0x0002, mwEncrypt_RC2_40 = 0x1000, mwEncrypt_RC2_128 = 0x2000 } |
Policy for a channel, dictating what sort of encryption should be used, if any, and when. More... | |
Functions | |
int | mwChannel_accept (struct mwChannel *chan) |
Formally accept an incoming channel. | |
void | mwChannel_addSupportedCipherInstance (struct mwChannel *chan, struct mwCipherInstance *ci) |
add a cipher instance to a channel's list of supported ciphers. | |
int | mwChannel_create (struct mwChannel *chan) |
Formally open a channel. | |
int | mwChannel_destroy (struct mwChannel *chan, guint32 reason, struct mwOpaque *data) |
Destroy a channel. | |
mwChannel * | mwChannel_find (struct mwChannelSet *cs, guint32 chan) |
Obtain a reference to a channel by its id. | |
mwOpaque * | mwChannel_getAddtlAccept (struct mwChannel *) |
direct reference to the accept addtl information for a channel | |
mwOpaque * | mwChannel_getAddtlCreate (struct mwChannel *) |
direct reference to the create addtl information for a channel | |
guint16 | mwChannel_getEncryptPolicy (struct mwChannel *chan) |
Channel encryption policy. | |
guint32 | mwChannel_getId (struct mwChannel *) |
get the ID for a channel. | |
guint32 | mwChannel_getOptions (struct mwChannel *chan) |
guint32 | mwChannel_getProtoType (struct mwChannel *chan) |
guint32 | mwChannel_getProtoVer (struct mwChannel *chan) |
mwService * | mwChannel_getService (struct mwChannel *) |
get the service for a channel. | |
gpointer | mwChannel_getServiceData (struct mwChannel *chan) |
get service-specific data. | |
guint32 | mwChannel_getServiceId (struct mwChannel *) |
get the ID of the service for a channel. | |
mwSession * | mwChannel_getSession (struct mwChannel *) |
get the session for a channel. | |
enum mwChannelState | mwChannel_getState (struct mwChannel *) |
get the state of a channel | |
gpointer | mwChannel_getStatistic (struct mwChannel *chan, enum mwChannelStatField stat) |
obtain the value for a statistic field as a gpointer | |
GList * | mwChannel_getSupportedCipherInstances (struct mwChannel *chan) |
the list of supported ciphers for a channel. | |
mwLoginInfo * | mwChannel_getUser (struct mwChannel *chan) |
User at the other end of the channel. | |
mwChannel * | mwChannel_newIncoming (struct mwChannelSet *, guint32 id) |
Create an incoming channel with the given channel id. | |
mwChannel * | mwChannel_newOutgoing (struct mwChannelSet *) |
Create an outgoing channel. | |
void | mwChannel_populateSupportedCipherInstances (struct mwChannel *chan) |
automatically adds instances of all ciphers in the session to the list of supported ciphers for a channel | |
void | mwChannel_recv (struct mwChannel *chan, struct mwMsgChannelSend *msg) |
Feed data into a channel. | |
void | mwChannel_recvAccept (struct mwChannel *chan, struct mwMsgChannelAccept *msg) |
pass an accept message to a channel for handling | |
void | mwChannel_recvCreate (struct mwChannel *chan, struct mwMsgChannelCreate *msg) |
pass a create message to a channel for handling | |
void | mwChannel_recvDestroy (struct mwChannel *chan, struct mwMsgChannelDestroy *msg) |
pass a destroy message to a channel for handling | |
void | mwChannel_removeServiceData (struct mwChannel *chan) |
void | mwChannel_selectCipherInstance (struct mwChannel *chan, struct mwCipherInstance *ci) |
select a cipher instance for a channel. | |
int | mwChannel_send (struct mwChannel *chan, guint32 msg_type, struct mwOpaque *msg) |
Compose a send-on-channel message, encrypt it as per the channel's specification, and send it. | |
int | mwChannel_sendEncrypted (struct mwChannel *chan, guint32 msg_type, struct mwOpaque *msg, gboolean encrypt) |
Compose a send-on-channel message, and if encrypt is TRUE, encrypt it as per the channel's specification, and send it. | |
void | mwChannel_setOptions (struct mwChannel *chan, guint32 options) |
void | mwChannel_setProtoType (struct mwChannel *chan, guint32 proto_type) |
void | mwChannel_setProtoVer (struct mwChannel *chan, guint32 proto_ver) |
void | mwChannel_setService (struct mwChannel *chan, struct mwService *srvc) |
associate a channel with an owning service | |
void | mwChannel_setServiceData (struct mwChannel *chan, gpointer data, GDestroyNotify clean) |
set service-specific data. | |
void | mwChannelSet_free (struct mwChannelSet *) |
Clear and deallocate a channel set. | |
mwChannelSet * | mwChannelSet_new (struct mwSession *) |
Allocate and initialize a channel set for a session. |
|
special ID indicating the master channel
|
|
non-zero if a channel id appears to be that of an incoming channel
|
|
non-zero if a channel id appears to be that of an outgoing channel
|
|
non-zero if a channel appears to be an incoming channel
|
|
non-zero if a channel appears to be an outgoing channel
|
|
|
|
|
channel statistic fields.
|
|
Policy for a channel, dictating what sort of encryption should be used, if any, and when.
|
|
Formally accept an incoming channel. Instructs the session to send a channel accept message to the server, and to mark the channel as being OPEN. |
|
add a cipher instance to a channel's list of supported ciphers. Channel must be NEW. |
|
Formally open a channel. For outgoing channels: instruct the session to send a channel create message to the server, and to mark the channel (which must be in INIT status) as being in WAIT status. For incoming channels: configures the channel according to options in the channel create message. Marks the channel as being in WAIT status |
|
Destroy a channel. Sends a channel-destroy message to the server, and perform cleanup to remove the channel.
|
|
Obtain a reference to a channel by its id.
|
|
direct reference to the accept addtl information for a channel
|
|
direct reference to the create addtl information for a channel
|
|
Channel encryption policy. Cannot currently be set, used internally to automatically negotiate ciphers. Future revisions may allow this to be specified in a new channel to dictate channel encryption.
|
|
get the ID for a channel. 0x00 indicates an error, as that is not a permissible value |
|
|
|
|
|
|
|
get the service for a channel. This may be NULL for NEW channels |
|
get service-specific data. This is for use by service implementations to easily associate information with the channel |
|
get the ID of the service for a channel. This may be 0x00 for NEW channels |
|
get the session for a channel.
|
|
get the state of a channel
|
|
obtain the value for a statistic field as a gpointer
|
|
the list of supported ciphers for a channel. This list will be empty once a cipher has been selected for the channel |
|
User at the other end of the channel. The target user for outgoing channels, the creator for incoming channels |
|
Create an incoming channel with the given channel id. Channel's state will be set to WAIT. Primarily for use in mw_session |
|
Create an outgoing channel. Its channel ID will be generated by the owning channel set. Channel's state will be set to INIT |
|
automatically adds instances of all ciphers in the session to the list of supported ciphers for a channel
|
|
Feed data into a channel.
|
|
pass an accept message to a channel for handling
|
|
pass a create message to a channel for handling
|
|
pass a destroy message to a channel for handling
|
|
|
|
select a cipher instance for a channel. A NULL instance indicates that no encryption should be used. |
|
Compose a send-on-channel message, encrypt it as per the channel's specification, and send it.
|
|
Compose a send-on-channel message, and if encrypt is TRUE, encrypt it as per the channel's specification, and send it.
|
|
|
|
|
|
|
|
associate a channel with an owning service
|
|
set service-specific data. This is for use by service implementations to easily associate information with the channel |
|
Clear and deallocate a channel set. Closes, clears, and frees all contained channels. |
|
Allocate and initialize a channel set for a session.
|