OSCInPort.h

#if IPHONE
#import <UIKit/UIKit.h>
#else
#import <Cocoa/Cocoa.h>
#endif

#import <VVBasics/VVBasics.h>
#import "OSCQueryReply.h"
//#import <sys/types.h>
//#import <sys/socket.h>
#import <netinet/in.h>
#import <unistd.h>
#import <libkern/OSAtomic.h>
#import "OSCPacket.h"
#import "OSCBundle.h"
#import "OSCMessage.h"
#import "OSCOutPort.h"





@interface OSCInPort : NSObject {
    BOOL                    deleted;    //  whether or not i'm deleted- ensures that socket gets closed
    BOOL                    bound;      //  whether or not the socket is bound
    OSSpinLock              socketLock;
    int                     sock;       //  socket file descriptor.  remember, everything in unix is files!
    struct sockaddr_in      addr;       //  struct that describes *my* address (this is an in port)
    unsigned short          port;       //  the port number i'm receiving from
    unsigned char           *buf;   //  the socket gets data and dumps it here immediately
    double                  interval;   //  how many times/sec you want the thread to run
    
    OSSpinLock              scratchLock;
    NSThread                *thread;
    VVStopwatch             *timeoutSWatch; //  used to check the query dict for timeouts
    MutLockDict             *queryDict; //  key is the address of the dispatched query, object is a OSCQueryReply object
    
    NSString                *portLabel;     
    OSSpinLock              zeroConfLock;
    VVStopwatch             *zeroConfSwatch;    //  bonjour services need ~5 seconds between destroy/creation or the changes get ignored- this is how we track this time
    NSNetService            *zeroConfDest;  //  bonjour service for publishing this input's address...only active if there's a portLabel!
    
    NSMutableArray          *scratchArray;  //  array of OSCMessage objects.  used for serial messaging.
    id                      delegate;   
}

//  Creates and returns an auto-released OSCInPort for the given port (or nil if the port's busy)
+ (id) createWithPort:(unsigned short)p;
//  Creates and returns an auto-released OSCInPort for the given port and label (or nil if the port's busy)
+ (id) createWithPort:(unsigned short)p labelled:(NSString *)n;
- (id) initWithPort:(unsigned short)p;
- (id) initWithPort:(unsigned short)p labelled:(NSString *)n;

- (void) prepareToBeDeleted;

- (NSDictionary *) createSnapshot;

- (BOOL) createSocket;
- (void) start;
- (void) stop;
- (void) OSCThreadProc;
- (void) parseRawBuffer:(unsigned char *)b ofMaxLength:(int)l fromAddr:(unsigned int)txAddr port:(unsigned short)txPort;

- (void) handleScratchArray:(NSArray *)a;
- (void) _addMessage:(OSCMessage *)val;



- (void) dispatchQuery:(OSCMessage *)m toOutPort:(OSCOutPort *)o timeout:(float)t replyHandler:(void (^)(OSCMessage *replyMsg))block;
- (void) dispatchQuery:(OSCMessage *)m toOutPort:(OSCOutPort *)o timeout:(float)t replyDelegate:(id <OSCQueryReplyDelegate>)d;

//  called internally by OSCManager when it's asked to dispatch a query.  you should never need to call this method manually.
- (void) _dispatchQuery:(OSCMessage *)m toOutPort:(OSCOutPort *)o;



- (unsigned short) port;
- (void) setPort:(unsigned short)n;
- (NSString *) portLabel;
- (void) setPortLabel:(NSString *)n;
- (NSString *) zeroConfName;
- (BOOL) bound;
- (NSString *) ipAddressString;

- (id) delegate;
- (void) setDelegate:(id)n;
- (void) setInterval:(double)n;

@end