← Back to branch summary

~ubuntu-branches/ubuntu/utopic/gridengine/utopic

« back to all changes in this revision

Viewing changes to source/libs/gdi/sge_gdi_packet_queue.h

  • Committer: Bazaar Package Importer
  • Author(s): Mark Hymers
  • Date: 2008-06-25 22:36:13 UTC
  • Revision ID: james.westby@ubuntu.com-20080625223613-tvd9xlhuoct9kyhm
Tags: upstream-6.2~beta2
Import upstream version 6.2~beta2

Show diffs side-by-side

added added

removed removed

Lines of Context:
source/libs/gdi/sge_gdi_packet_queue.h
 
1
#ifndef __SGE_PACKET_QUEUE_H
 
2
#define __SGE_PACKET_QUEUE_H
 
3
/*___INFO__MARK_BEGIN__*/
 
4
/*************************************************************************
 
5
 * 
 
6
 *  The Contents of this file are made available subject to the terms of
 
7
 *  the Sun Industry Standards Source License Version 1.2
 
8
 * 
 
9
 *  Sun Microsystems Inc., March, 2001
 
10
 * 
 
11
 * 
 
12
 *  Sun Industry Standards Source License Version 1.2
 
13
 *  =================================================
 
14
 *  The contents of this file are subject to the Sun Industry Standards
 
15
 *  Source License Version 1.2 (the "License"); You may not use this file
 
16
 *  except in compliance with the License. You may obtain a copy of the
 
17
 *  License at http://gridengine.sunsource.net/Gridengine_SISSL_license.html
 
18
 * 
 
19
 *  Software provided under this License is provided on an "AS IS" basis,
 
20
 *  WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING,
 
21
 *  WITHOUT LIMITATION, WARRANTIES THAT THE SOFTWARE IS FREE OF DEFECTS,
 
22
 *  MERCHANTABLE, FIT FOR A PARTICULAR PURPOSE, OR NON-INFRINGING.
 
23
 *  See the License for the specific provisions governing your rights and
 
24
 *  obligations concerning the Software.
 
25
 * 
 
26
 *   The Initial Developer of the Original Code is: Sun Microsystems, Inc.
 
27
 * 
 
28
 *   Copyright: 2007 by Sun Microsystems, Inc.
 
29
 * 
 
30
 *   All Rights Reserved.
 
31
 * 
 
32
 ************************************************************************/
 
33
/*___INFO__MARK_END__*/
 
34
 
 
35
#include "uti/sge_monitor.h"
 
36
 
 
37
typedef struct _sge_gdi_packet_queue_class_t sge_gdi_packet_queue_class_t;
 
38
 
 
39
struct _sge_gdi_packet_queue_class_t {
 
40
   /* 
 
41
    * mutex to gard all members of this structure 
 
42
    */
 
43
   pthread_mutex_t mutex;
 
44
 
 
45
   /* 
 
46
    * used to block/signal threads 
 
47
    */
 
48
   pthread_cond_t cond;
 
49
 
 
50
   /* 
 
51
    * pointer to the first and last packet of a packet queue
 
52
    */
 
53
   sge_gdi_packet_class_t *first_packet;
 
54
   sge_gdi_packet_class_t *last_packet;
 
55
 
 
56
   /*
 
57
    * number of elements in the queue
 
58
    */
 
59
   u_long32 counter;
 
60
 
 
61
   /* 
 
62
    * if "true" then at least one thread waits to be signalled
 
63
    * with the pthread condition 'cond' part of this structure 
 
64
    */
 
65
   u_long32 waiting;
 
66
};
 
67
 
 
68
extern sge_gdi_packet_queue_class_t Master_Packet_Queue;
 
69
 
 
70
u_long32
 
71
sge_gdi_packet_queue_get_length(sge_gdi_packet_queue_class_t *packet_queue);
 
72
 
 
73
void
 
74
sge_gdi_packet_queue_store_notify(sge_gdi_packet_queue_class_t *packet_queue,
 
75
                                  sge_gdi_packet_class_t *packet, 
 
76
                                  monitoring_t *monitor);
 
77
 
 
78
void
 
79
sge_gdi_packet_queue_wakeup_all_waiting(sge_gdi_packet_queue_class_t *packet_queue);
 
80
 
 
81
bool
 
82
sge_gdi_packet_queue_wait_for_new_packet(sge_gdi_packet_queue_class_t *packet_queue,
 
83
                                         sge_gdi_packet_class_t **packet,
 
84
                                         monitoring_t *monitor);
 
85
 
 
86
#endif
 
87