Changeset 3742

Timestamp:

2008-10-27 01:45:04 (2 months ago)

Author:

conrad

Message:

anx_import_ogg: re-order functions into separate sections for setup, read, open

Files:

• libannodex/trunk/src/importers/anx_import_ogg.c (modified) (6 diffs)

libannodex/trunk/src/importers/anx_import_ogg.c

@@ -279 +279 @@
-
-/***********************************************************
-
+Setup
- */
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
-static int
-read_packet_headers (OGGZ * oggz, ogg_packet * op, long serialno,
@@ -587 +532 @@
-}
-
-/***********************************************************
- * A filter predicate, used between the min seek granule
- * and the start time (ie. the bit between the prior keyframe
- * and the chop time) to filter packets which should be
- * included in the output.
- * \returns 0 Do not include \a op
- * \returns 1 Do include \a op
- */
-static int
-filter (AnxOggData * aod, AnxOggTrack * aot, long serialno, ogg_packet * op) {
-
-  AnxSourceTrack * track = &(aot->source_track);
-  double timestamp;
-
-#ifdef DEBUG
-  fprintf(aod->df, "state %s got_keygranule %d gp %llx keygranule %llx\n", 
-    aod->state == STATE_FILTER ? "FILTER" : "NOFILTER", 
-    aot->filter_got_keygranule, op->granulepos, aot->keygranule);
-#endif
-
-  /* TRUE if we're not in state FILTER */
-  if (aod->state != STATE_FILTER) return 1;
-
-  /* TRUE if we haven't done the seek yet */
-  if (aod->need_seek == NEED_SEEK_PENDING) return 1;
-
-  timestamp = gp_to_time (aod->oggz, serialno, op->granulepos);
-
-#ifdef DEBUG  
-  fprintf(aod->df, "timestamp %f start_time %f\n", timestamp, 
-            aod->anx_source->start_time);
-#endif
-
-  /* TRUE if we're beyond the start time */
-  if (timestamp-TOLERANCE >= aod->anx_source->start_time) {
-    aod->state = STATE_DATA;
-    return 1;
-  }
-
-  /* from here, we know we're filtering */
-
-  /* FALSE if we're not using granule_seek at all */
-  if (!aod->use_granule_seek) return 0;
-
-  /* FALSE if this track doesn't use granuleshift */
-  if (track->granuleshift == 0) return 0;
-
-  /* TRUE if we're beyond the keygranule for this track */
-  if (aot->filter_got_keygranule) return 1;
-
-  if (op->granulepos >= aot->keygranule) {
-    aot->filter_got_keygranule = 1;
-    return 1;
-  }
-
-  /* TRUE if we're after the keygranule time */
-#if 0
-  if (op->granulepos != -1 && timestamp+TOLERANCE >= aot->keygranule_time) {
-    aot->filter_got_keygranule = 1;
-    return 1;
-  }
-
-  /* XXX: TRUE if a theora from a keyframe, even if no granulepos */
-  if (!strcmp (track->content_type, THEORA_CONTENT_TYPE) &&
-      op->bytes > 0 && !(op->packet[0] & 0xC0)) {
-#ifdef DEBUG
-    fprintf (aod->df,
-             "anxogg::FILTER got Theora keyframe\n");
-#endif
-
-    aot->filter_got_keygranule = 1;
-    return 1;
-  }
-
-#endif
-
-  /* FALSE otherwise */
-  return 0;
-
-#if 0
-  /* FALSE if this track uses keygranules, and we're before its time */
-  if (granulepos != -1 && timestamp+TOLERANCE < aot->keygranule_time) return 0;
-
-  /* TRUE otherwise */
-  return 1;
-#endif
-}
-
-static int
-read_packet_data (OGGZ * oggz, ogg_packet * op, long serialno,
-                  void * user_data)
-{
-  AnxOggData * aod = (AnxOggData *)user_data;
-  AnxOggTrack * aot = NULL;
-  AnxOggPacket * aop;
-  AnxSource * m = aod->anx_source;
-  AnxSourceTrack * track = NULL;
-  anx_int64_t gp = oggz_tell_granulepos(oggz);
-  
-  op->granulepos = gp;
-
-#ifdef DEBUG
-  fprintf (aod->df, "anxogg::read_packet_data IN: %010ld, granulepos %llx\n",
-          serialno, gp);
-#endif
-
-  if (!(aod->cmml_serialno != -1 && serialno == aod->cmml_serialno)) {
-    aot = (AnxOggTrack *) oggz_table_lookup (aod->logicals, serialno);
-    if (aot == NULL) {
-#ifdef DEBUG
-      fprintf (aod->df,
-               "anxogg::read_packet_data: %010ld not found\n", serialno);
-#endif
-      return OGGZ_STOP_OK;
-    }
-  }
-
-  if (op->b_o_s) {
-    if (!strncmp ((char *)&op->packet[0], "AnxData", 7)) {
-      /* Mark this track as anxv2, and don't copy the AnxData packet
-       * into the bitstream */
-      if (aot) aot->anxv2_ignore_packet = 1;
-    }
-  } else {
-    if (aod->cmml_serialno != -1 && serialno == aod->cmml_serialno) {
-      double at_time;
-
-#ifdef DEBUG
-      fprintf (aod->df, "aod->cmml_serialno %010ld, op->granulepos %lld\n",
-              aod->cmml_serialno, gp);
-#endif
-
-      if (gp == -1) {
-              return OGGZ_STOP_ERR;
-      }
-      at_time = gp_to_time (aod->oggz, serialno, gp);
-      
-#ifdef DEBUG
-      {
-        char * header = (char *)op->packet;
-        fprintf (aod->df,
-                  "anxogg::read_packet_data: got CMML <%c%c%c%c> at %f\n",
-                  header[1], header[2], header[3], header[4], at_time);
-      }
-#endif
-
-      /* If this content doesn't use cmml_granuleshift, and this clip is
-       * before the start_time, drop it */
-      if 
-      (
-        aod->cmml_granuleshift == 0 && op->bytes > 6 
-        &&
-        !strncmp ((char *)op->packet, "<clip", 5) 
-        &&
-              at_time < aod->anx_source->start_time-TOLERANCE
-      ) 
-      {
-#ifdef DEBUG
-              fprintf (aod->df,
-                            "anxogg::read_packet_data: CMML clip too early, dropping\n");
-#endif
-        return OGGZ_STOP_OK;
-      }
-
-      if (aod->import_cmml) {
-        aod->import_cmml ((char *)op->packet, op->bytes, at_time,
-                                              aod->import_user_data);
-      }
-      return OGGZ_CONTINUE;
-    } else {
-      if (aot->anxv2_ignore_packet) {
-        aot->anxv2_ignore_packet = 0;
-        op->b_o_s = 1;
-      } else {
-        aod->got_non_bos = 1;
-      }
-    }
-  }
-
-  track = &(aot->source_track);
-
-  if (!track) {
-#ifdef DEBUG
-    fprintf (aod->df, "anxogg::read_packet: track NULL\n");
-#endif
-    return OGGZ_STOP_OK;
-  }
-
-  if (aod->nr_headers_remaining == 0 && !aod->got_end && 
-      (m->end_time != -1.0) && (gp != -1)) {
-        ogg_int64_t granule = gp_to_granule (oggz, serialno, gp);
-    if (granule >= track->end_granule) {
-#ifdef DEBUG
-      fprintf (aod->df, "anxogg::read_packet_data: got_end\n");
-#endif
-      aod->got_end = 1;
-    }
-  }
-
-#ifdef DEBUG
-  fprintf (aod->df, "anxogg::read_packet: Filter? (%s)\n", 
-        aod->state == STATE_FILTER ? "USE_FN" : "NO_FN");
-#endif
-
-  if (!aod->ignore_media && !aod->got_end && !aot->anxv2_ignore_packet &&
-      (aod->state != STATE_FILTER ||
-       filter (aod, aot, serialno, op))) {
-#ifdef DEBUG
-    fprintf (aod->df, "anxogg::read_packet_data: no, copy out\n");
-#endif
-    aop = anx_malloc (sizeof (AnxOggPacket));
-    aop->length = op->bytes;
-    aop->data = anx_malloc (op->bytes);
-    aop->granulepos = op->granulepos;
-    aop->current_time = ((double)oggz_tell_units (oggz)) / SUBSECONDS;
-    aop->source_track = track;
-    aop->eos = op->e_o_s;
-
-#if 0
-    if (aod->nr_headers_remaining == 0 && aop->granulepos != -1) {
-      aop->granulepos -= track->start_granule;
-    }
-#endif
-
-    memcpy (aop->data, op->packet, op->bytes);
-    
-    aod->media_packets = anx_list_append (aod->media_packets, aop);
-    
-    if (aot->nr_headers_remaining > 0) {
-      aod->nr_headers_remaining--;
-      aot->nr_headers_remaining--;
-
-#ifdef DEBUG
-      fprintf (aod->df,
-               "anxogg::read_packet_data: nr_headers_remaining = %d, start_time = %f\n",
-              aod->nr_headers_remaining, m->start_time);
-#endif
-    }
-
-    if 
-    (
-      aod->need_seek == NEED_SEEK_PENDING 
-      &&
-            aod->nr_headers_remaining == 0 
-      &&
-            m->start_time != 0.0
-    ) 
-    {
-      if (oggz_seek_units (oggz, 0, SEEK_CUR) >= 0) {
-#ifdef DEBUG
-        fprintf (aod->df, "anxogg::read_packet_data NEED seek\n");
-#endif
-        aod->need_seek = NEED_SEEK;
-        return OGGZ_CONTINUE;
-      }
-    }
-  }
-
-  return OGGZ_STOP_OK;
-}
-
-static int
-granuleinfo_update_state (AnxOggData * aod)
@@ -1005 +689 @@
-}
-
+
-static int
-anxogg_setup (AnxOggData * aod)
@@ -1114 +799 @@
-}
-
+/***********************************************************
+ * Read: Pass data packets to the writer
+ */
+
+static double
+anxogg_seek_update (AnxSource * source)
+{
+  AnxOggData * aod = (AnxOggData *)source->custom_data;
+  double seek_offset;
+  ogg_int64_t units, units_at;
+  double offset;
+
+  if (aod->use_granule_seek) {
+    seek_offset = aod->min_granule_seek;
+#ifdef DEBUG
+    fprintf(aod->df, "anxogg_seek_update: using min_granule_seek %f\n", 
+            seek_offset);
+#endif
+  } else {
+    seek_offset = source->start_time;
+#ifdef DEBUG
+    fprintf(aod->df, "anxogg_seek_update: using start time %f\n", seek_offset);
+#endif
+  }
+  seek_offset -= 1.0;
+  if (seek_offset < 0.0) seek_offset = 0.0;
+
+  units = (ogg_int64_t)(SUBSECONDS * seek_offset);
+  units_at = oggz_seek_units (aod->oggz, units, SEEK_SET);
+
+  if (units_at == -1) {
+#ifdef DEBUG
+    fprintf (aod->df, "anxogg_seek_update: oggz_seek_units FAIL\n");
+#endif
+    return -1.0;
+  }
+
+  offset = ((double)units_at) / SUBSECONDS;
+
+  aod->need_seek = NEED_SEEK_DONE;
+
+#ifdef DEBUG
+  fprintf (aod->df,
+           "anxogg: seek_update to %lld (wanted %lld (%f))\n", units_at,
+          units, seek_offset);
+#endif
+
+  if (source->end_time != -1.0 && offset >= source->end_time) {
+#ifdef DEBUG
+    fprintf (aod->df,
+             "anxoggg: seek update > end_time %f\n", source->end_time);
+#endif
+    aod->got_end = 1;
+  }
+
+  return offset;
+}
+
+static long
+anxogg_read_update (AnxSource * media)
+{
+  AnxOggData * aod = (AnxOggData *)media->custom_data;
+
+ do_read:
+
+  while ((aod->media_packets == NULL) && (oggz_read (aod->oggz, 1024)) != 0);
+
+  if (aod->need_seek == NEED_SEEK && aod->nr_headers_remaining == 0) {
+    anxogg_seek_update (media);
+    goto do_read;
+  }
+
+  return 0;
+}
+
+/***********************************************************
+ * A filter predicate, used between the min seek granule
+ * and the start time (ie. the bit between the prior keyframe
+ * and the chop time) to filter packets which should be
+ * included in the output.
+ * \returns 0 Do not include \a op
+ * \returns 1 Do include \a op
+ */
+static int
+filter (AnxOggData * aod, AnxOggTrack * aot, long serialno, ogg_packet * op) {
+
+  AnxSourceTrack * track = &(aot->source_track);
+  double timestamp;
+
+#ifdef DEBUG
+  fprintf(aod->df, "state %s got_keygranule %d gp %llx keygranule %llx\n", 
+    aod->state == STATE_FILTER ? "FILTER" : "NOFILTER", 
+    aot->filter_got_keygranule, op->granulepos, aot->keygranule);
+#endif
+
+  /* TRUE if we're not in state FILTER */
+  if (aod->state != STATE_FILTER) return 1;
+
+  /* TRUE if we haven't done the seek yet */
+  if (aod->need_seek == NEED_SEEK_PENDING) return 1;
+
+  timestamp = gp_to_time (aod->oggz, serialno, op->granulepos);
+
+#ifdef DEBUG  
+  fprintf(aod->df, "timestamp %f start_time %f\n", timestamp, 
+            aod->anx_source->start_time);
+#endif
+
+  /* TRUE if we're beyond the start time */
+  if (timestamp-TOLERANCE >= aod->anx_source->start_time) {
+    aod->state = STATE_DATA;
+    return 1;
+  }
+
+  /* from here, we know we're filtering */
+
+  /* FALSE if we're not using granule_seek at all */
+  if (!aod->use_granule_seek) return 0;
+
+  /* FALSE if this track doesn't use granuleshift */
+  if (track->granuleshift == 0) return 0;
+
+  /* TRUE if we're beyond the keygranule for this track */
+  if (aot->filter_got_keygranule) return 1;
+
+  if (op->granulepos >= aot->keygranule) {
+    aot->filter_got_keygranule = 1;
+    return 1;
+  }
+
+  /* TRUE if we're after the keygranule time */
+#if 0
+  if (op->granulepos != -1 && timestamp+TOLERANCE >= aot->keygranule_time) {
+    aot->filter_got_keygranule = 1;
+    return 1;
+  }
+
+  /* XXX: TRUE if a theora from a keyframe, even if no granulepos */
+  if (!strcmp (track->content_type, THEORA_CONTENT_TYPE) &&
+      op->bytes > 0 && !(op->packet[0] & 0xC0)) {
+#ifdef DEBUG
+    fprintf (aod->df,
+             "anxogg::FILTER got Theora keyframe\n");
+#endif
+
+    aot->filter_got_keygranule = 1;
+    return 1;
+  }
+
+#endif
+
+  /* FALSE otherwise */
+  return 0;
+
+#if 0
+  /* FALSE if this track uses keygranules, and we're before its time */
+  if (granulepos != -1 && timestamp+TOLERANCE < aot->keygranule_time) return 0;
+
+  /* TRUE otherwise */
+  return 1;
+#endif
+}
+
+static int
+read_packet_data (OGGZ * oggz, ogg_packet * op, long serialno,
+                  void * user_data)
+{
+  AnxOggData * aod = (AnxOggData *)user_data;
+  AnxOggTrack * aot = NULL;
+  AnxOggPacket * aop;
+  AnxSource * m = aod->anx_source;
+  AnxSourceTrack * track = NULL;
+  anx_int64_t gp = oggz_tell_granulepos(oggz);
+  
+  op->granulepos = gp;
+
+#ifdef DEBUG
+  fprintf (aod->df, "anxogg::read_packet_data IN: %010ld, granulepos %llx\n",
+          serialno, gp);
+#endif
+
+  if (!(aod->cmml_serialno != -1 && serialno == aod->cmml_serialno)) {
+    aot = (AnxOggTrack *) oggz_table_lookup (aod->logicals, serialno);
+    if (aot == NULL) {
+#ifdef DEBUG
+      fprintf (aod->df,
+               "anxogg::read_packet_data: %010ld not found\n", serialno);
+#endif
+      return OGGZ_STOP_OK;
+    }
+  }
+
+  if (op->b_o_s) {
+    if (!strncmp ((char *)&op->packet[0], "AnxData", 7)) {
+      /* Mark this track as anxv2, and don't copy the AnxData packet
+       * into the bitstream */
+      if (aot) aot->anxv2_ignore_packet = 1;
+    }
+  } else {
+    if (aod->cmml_serialno != -1 && serialno == aod->cmml_serialno) {
+      double at_time;
+
+#ifdef DEBUG
+      fprintf (aod->df, "aod->cmml_serialno %010ld, op->granulepos %lld\n",
+              aod->cmml_serialno, gp);
+#endif
+
+      if (gp == -1) {
+              return OGGZ_STOP_ERR;
+      }
+      at_time = gp_to_time (aod->oggz, serialno, gp);
+      
+#ifdef DEBUG
+      {
+        char * header = (char *)op->packet;
+        fprintf (aod->df,
+                  "anxogg::read_packet_data: got CMML <%c%c%c%c> at %f\n",
+                  header[1], header[2], header[3], header[4], at_time);
+      }
+#endif
+
+      /* If this content doesn't use cmml_granuleshift, and this clip is
+       * before the start_time, drop it */
+      if 
+      (
+        aod->cmml_granuleshift == 0 && op->bytes > 6 
+        &&
+        !strncmp ((char *)op->packet, "<clip", 5) 
+        &&
+              at_time < aod->anx_source->start_time-TOLERANCE
+      ) 
+      {
+#ifdef DEBUG
+              fprintf (aod->df,
+                            "anxogg::read_packet_data: CMML clip too early, dropping\n");
+#endif
+        return OGGZ_STOP_OK;
+      }
+
+      if (aod->import_cmml) {
+        aod->import_cmml ((char *)op->packet, op->bytes, at_time,
+                                              aod->import_user_data);
+      }
+      return OGGZ_CONTINUE;
+    } else {
+      if (aot->anxv2_ignore_packet) {
+        aot->anxv2_ignore_packet = 0;
+        op->b_o_s = 1;
+      } else {
+        aod->got_non_bos = 1;
+      }
+    }
+  }
+
+  track = &(aot->source_track);
+
+  if (!track) {
+#ifdef DEBUG
+    fprintf (aod->df, "anxogg::read_packet: track NULL\n");
+#endif
+    return OGGZ_STOP_OK;
+  }
+
+  if (aod->nr_headers_remaining == 0 && !aod->got_end && 
+      (m->end_time != -1.0) && (gp != -1)) {
+        ogg_int64_t granule = gp_to_granule (oggz, serialno, gp);
+    if (granule >= track->end_granule) {
+#ifdef DEBUG
+      fprintf (aod->df, "anxogg::read_packet_data: got_end\n");
+#endif
+      aod->got_end = 1;
+    }
+  }
+
+#ifdef DEBUG
+  fprintf (aod->df, "anxogg::read_packet: Filter? (%s)\n", 
+        aod->state == STATE_FILTER ? "USE_FN" : "NO_FN");
+#endif
+
+  if (!aod->ignore_media && !aod->got_end && !aot->anxv2_ignore_packet &&
+      (aod->state != STATE_FILTER ||
+       filter (aod, aot, serialno, op))) {
+#ifdef DEBUG
+    fprintf (aod->df, "anxogg::read_packet_data: no, copy out\n");
+#endif
+    aop = anx_malloc (sizeof (AnxOggPacket));
+    aop->length = op->bytes;
+    aop->data = anx_malloc (op->bytes);
+    aop->granulepos = op->granulepos;
+    aop->current_time = ((double)oggz_tell_units (oggz)) / SUBSECONDS;
+    aop->source_track = track;
+    aop->eos = op->e_o_s;
+
+#if 0
+    if (aod->nr_headers_remaining == 0 && aop->granulepos != -1) {
+      aop->granulepos -= track->start_granule;
+    }
+#endif
+
+    memcpy (aop->data, op->packet, op->bytes);
+    
+    aod->media_packets = anx_list_append (aod->media_packets, aop);
+    
+    if (aot->nr_headers_remaining > 0) {
+      aod->nr_headers_remaining--;
+      aot->nr_headers_remaining--;
+
+#ifdef DEBUG
+      fprintf (aod->df,
+               "anxogg::read_packet_data: nr_headers_remaining = %d, start_time = %f\n",
+              aod->nr_headers_remaining, m->start_time);
+#endif
+    }
+
+    if 
+    (
+      aod->need_seek == NEED_SEEK_PENDING 
+      &&
+            aod->nr_headers_remaining == 0 
+      &&
+            m->start_time != 0.0
+    ) 
+    {
+      if (oggz_seek_units (oggz, 0, SEEK_CUR) >= 0) {
+#ifdef DEBUG
+        fprintf (aod->df, "anxogg::read_packet_data NEED seek\n");
+#endif
+        aod->need_seek = NEED_SEEK;
+        return OGGZ_CONTINUE;
+      }
+    }
+  }
+
+  return OGGZ_STOP_OK;
+}
+
+static AnxOggPacket *
+anxogg_packet_free (AnxOggPacket * aop)
+{
+  anx_free (aop->data);
+  anx_free (aop);
+  return NULL;
+}
+
+static long
+anxogg_read (AnxSource * media, char * buf, long n, long bound)
+{
+  AnxOggData * aod = (AnxOggData *)media->custom_data;
+  AnxOggPacket * aop;
+  AnxList * head;
+  long bytes_to_read;
+
+  if (aod->ignore_media) return -1;
+
+  anxogg_read_update (media);
+
+  head = aod->media_packets;
+  if (head == NULL) {
+    media->eos = 1;
+    return 0;
+  }
+
+  aop = (AnxOggPacket *)head->data;
+  bytes_to_read = MIN (n, aop->length - aod->current_offset);
+
+  memcpy (buf, &aop->data[aod->current_offset], bytes_to_read);
+
+  aod->current_offset += bytes_to_read;
+
+  if (aod->headers_unread > 0) aod->headers_unread--;
+  if (aod->headers_unread == 0) media->written_secondaries = 1;
+
+  media->current_track = aop->source_track;
+
+#ifdef DEBUG_VERBOSE
+  fprintf (aod->df, "anxogg: reading from stream %s\n",
+          media->current_track->content_type);
+#endif
+
+  media->current_track->current_granule = aop->granulepos;
+  media->current_track->eos = aop->eos;
+
+  /* If that's finished this media packet, advance to the next one */
+  if (aod->current_offset >= aop->length) {
+    aod->media_packets =
+      anx_list_remove (aod->media_packets, head);
+
+    aop = anxogg_packet_free (aop);
+    anx_free (head);
+
+    aod->current_offset = 0;
+
+    anxogg_read_update (media);
+
+    if (aod->media_packets != NULL)
+      aop = (AnxOggPacket *)aod->media_packets->data;
+  }
+
+  /* Set current time to the current time of the next packet that would
+   * be served */
+  if (aop && aop->current_time != -1)
+    media->current_time = aop->current_time;   
+
+  return bytes_to_read;
+}
+
+static long
+anxogg_sizeof_next_read (AnxSource * media, long bound)
+{
+  AnxOggData * aod = (AnxOggData *)media->custom_data;
+  AnxOggPacket * aop;
+  long bytes_to_read;
+
+  if (aod->ignore_media) return -1;
+
+  while ((aod->media_packets == NULL) && (oggz_read (aod->oggz, 1024)) != 0);
+
+  if (aod->media_packets == NULL) {
+    media->eos = 1;
+    return 0;
+  }
+
+  aop = (AnxOggPacket *)aod->media_packets->data;
+  bytes_to_read = aop->length - aod->current_offset;
+
+  return bytes_to_read;
+}
+
+/***********************************************************
+ * Open
+ */
+
-static AnxOggData *
-aod_new (void)
@@ -1222 +1339 @@
-}
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
-static int
-anxogg_close (AnxSource * source)
@@ -1370 +1381 @@
-}
-
+/***********************************************************
+ * Importer instances
+ */
-static struct _AnxImporter anx_ogg_importer = {
-  (AnxImporterOpenFunc)anxogg_open,